星空二开对接地磅，电子称方案分享

栏目：云星空知识作者：金蝶来源：金蝶云社区发布：2024-09-16浏览：1

星空二开对接地磅，电子称方案分享

因为社区上对接地磅的案例比较少，今天就厚脸皮分享一个不太成熟的案例给大家！不足之处望各位大佬多多指教

业务场景：客户需要扫描托码或者箱码，箱/托的标准重量应当事先维护好一个值，也可以给客户做一个装托/箱单，给他生成托码箱码标准重量信息这些，这里就只分享地磅的对接方法和代码。

准备工作：端口模拟工具(VSPD6.9)，端口模拟发送软件(bittly)，这种软件不一定要用这两个，网上搜一堆，主要是用来模拟连接地磅，模拟地磅发送数据的。因为我们大部分的电子称，地磅基本都是用串口连接的，所以我们本地开发需要这些工具。还需要了解一下端口传输速率的一些基础知识，或者看这个类也可以：KDSerialPortConfig，上面会有相关的参数属性说明，对着地磅，电子称的说明抄就可以了。

设计说明：如下图案例是根发货通知单来进行称重的，所以开发了扫描发货单号自动拉取发货单的相关信息到称重单上。

49.3区域显示当前地磅的重量，右侧显示当前箱码，当前地磅重量与标准重量对比是否符合称重要求。如满足则自动将当前箱/托信息记录到明细行。

代码：

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Globalization;
using System.Linq;
using System.Text;
using BW.K3Cloud.DiBangApp.Business.Plugin.Utils;
using Kingdee.BOS;
using Kingdee.BOS.App;
using Kingdee.BOS.App.Data;
using Kingdee.BOS.Contracts;
using Kingdee.BOS.Core.Bill.PlugIn;
using Kingdee.BOS.Core.Bill.PlugIn.Args;
using Kingdee.BOS.Core.DynamicForm;
using Kingdee.BOS.Core.DynamicForm.Operation;
using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
using Kingdee.BOS.Core.DynamicForm.PlugIn.ControlModel;
using Kingdee.BOS.Core.Enums;
using Kingdee.BOS.Core.List;
using Kingdee.BOS.Core.Metadata.ConvertElement;
using Kingdee.BOS.Core.Metadata.ConvertElement.ServiceArgs;
using Kingdee.BOS.DataEntity;
using Kingdee.BOS.Orm;
using Kingdee.BOS.Orm.DataEntity;
using Kingdee.BOS.ServiceHelper;
using Kingdee.BOS.Util;

namespace BW.K3Cloud.DiBangApp.Business.Plugin
{
[Description("称重单表单插件")]
[HotUpdate]
public class WeighBillEdit : AbstractBillPlugIn
{
private readonly string red = "#FF0000";
private readonly string green = "#00FF00";
private readonly string blue = "#0000FF";
/// 是否显示保存信息
private bool isShowMessage = true;

public override void AfterBindData(EventArgs e)
{
base.AfterBindData(e);
int height = 25;
this.View.GetControl("FScan").SetCustomPropertyValue("height", height);
this.View.GetControl("FTorrSTDWeight").SetCustomPropertyValue("height", height);
this.View.GetControl("FErrorRate").SetCustomPropertyValue("height", height);
this.View.GetControl("FSCSWeight").SetCustomPropertyValue("height", height);

//设置按钮大小颜色
this.View.GetControl("FStartWeight").SetCustomPropertyValue("FontSize", 16);
this.View.GetControl("FEndWeight").SetCustomPropertyValue("FontSize", 16);

this.View.GetControl("FScan").Enabled = false;
// this.View.GetControl("FDeliveryNotice").SetFocus();
}

public override void BeforeF7Select(BeforeF7SelectEventArgs e)
{
base.BeforeF7Select(e);
//发货通知选单
if (e.FieldKey.EqualsIgnoreCase("FDeliveryNotice"))
{
ListShowParameter show = new ListShowParameter();
show.FormId = "SAL_DELIVERYNOTICE";
show.IsLookUp = true; //是否显示返回数据
show.MultiSelect = false; //是否多选
show.IsUseDefaultScheme = true;
show.ListType = Convert.ToInt32(BOSEnums.Enu_GetListDataType.List);
show.ListFilterParameter.Filter =
"FDocumentStatus='C' and FCLOSESTATUS='A' and FCancelStatus='A' and FTerminationStatus='A'";
this.View.ShowForm(show, result =>
{
var returnData = result.ReturnData;
if (returnData == null) return;
var resObj = (ListSelectedRowCollection)returnData;
var fhObj = KEDUtils.GetQueryData(this.Context, "SAL_DELIVERYNOTICE",
$"FID = {resObj[0].PrimaryKeyValue}");
this.setHeadValue(fhObj);
});
}
}

public override void ButtonClick(ButtonClickEventArgs e)
{
base.ButtonClick(e);
//开始称重
if (e.Key.EqualsIgnoreCase("FStartWeight"))
{
//获取端口名称
var comPort = this.Model.GetValue("FDBProt").ToString();
//new 一个串口配置对象
var kdSerialPort = new KDSerialPortConfig
{
PortName = comPort,
Rate = 9600,
Parity = 0,
Bits = 8,
StopBits = 1,
Timeout = -1
};
this.View.GetControl<SerialPortControl>("FSerialPortCtrl").Init(kdSerialPort); // 初始化并打开端口
this.View.ShowMessage("地磅连接成功！");
this.View.GetControl("FScan").Enabled = true;
this.View.GetControl("FScan").SetFocus();
}
//结束称重
if (e.Key.EqualsIgnoreCase("FEndWeight"))
{
this.View.GetControl<SerialPortControl>("FSerialPortCtrl").Close();//关闭串口
this.View.GetControl("FScan").Enabled = false;
this.View.ShowMessage("地磅连接关闭成功！");
}
}

public override void BarItemClick(BarItemClickEventArgs e)
{
base.BarItemClick(e);
if (e.BarItemKey.EqualsIgnoreCase("tbPushSaleOutStock"))
{
var pkValue = this.Model.GetValue("FFHFID",0).ToString();
var billTypeId = "193822715afc48aa9fa6d6beca7700ab";//标准发货通知单
var ruleId = "DeliveryNotice-OutStock"; //默认单据转换为发货通知单
var targetFormId = "SAL_OUTSTOCK"; //默认目标单为销售出库单
Dictionary<string, object> dic = this.GetPushData();
var pushEntryIds = dic.Keys.ToList();
DynamicObject[] objects = this.Push(this.Context, "SAL_DELIVERYNOTICE", targetFormId, ruleId,
pkValue, pushEntryIds, "FEntity", billTypeId);
var outView = KEDUtils.CreateBillView(this.Context, targetFormId);
outView.Model.DataObject = objects[0];
var fhEntry = outView.Model.GetEntityDataObject(outView.Model.BusinessInfo.GetEntity("FEntity")).ToList();
foreach (var valuePair in dic)
{
int index = fhEntry.FindIndex(x => x["FSourceEntryId"].ToString().Equals(valuePair.Key));
outView.Model.SetValue("FRealQty", valuePair.Value, index);
outView.InvokeFieldUpdateService("FRealQty", index);
}

var saveBill = KEDUtils.SaveBill(this.Context, targetFormId, outView.Model.DataObject);
if (saveBill.IsSuccess)
{
this.Model.SetValue("FJoinOutBills", saveBill.OperateResult.First().Number);
isShowMessage = false;
this.View.InvokeFormOperation(FormOperationEnum.Save);
this.View.ShowMessage("下推出库单成功！");
if (Convert.ToBoolean(this.Model.GetValue("FOutBillAudit")))
{
IOperationResult result = KEDUtils.SubmitAndAuditBill(this.Context, targetFormId,
new[] { saveBill.OperateResult.First().PKValue });
if (!result.IsSuccess)
{
throw new KDException("下推单据自动审核失败！", result.ValidationErrors[0].Message);
}
}
}
else
throw new KDException("下推单据保存失败！", saveBill.ValidationErrors[0].Message);
}
}

public override void PortDataReceived(KDSerialPortEventArgs e)
{
base.PortDataReceived(e);
var hexToStr = this.HexToStr(e.Value.ToString());
if (hexToStr.Length == 12)
{
string substring = hexToStr.Substring(2, 6);
var int32 = Convert.ToDouble(substring);
var sjWeight = Math.Round(int32/10,1);
this.Model.SetValue("FSCSWeight",sjWeight,0);
}
}

public override void DataChanged(DataChangedEventArgs e)
{
base.DataChanged(e);
//条码扫描
if (e.Field.Key.EqualsIgnoreCase("FScan"))
{
var fhBillNo = this.Model.GetValue("FDeliveryNotice");
var boxCodes = DBUtils.ExecuteDynamicObject(this.Context,
"/*dialect*/select A.FPackBoxNo,A.FBoxQty,A.FTorrNo,A.FTorrMaterialId,A.FTorrWeight,A.FSTDWeight,A.FPackSTDWeight " +
"from KED_T_PackBoxEntry A join KED_T_InstallTorr B on A.FID=B.FID " +
$"where B.FDeliveryNotice='{fhBillNo}' and A.FPackBoxNo='{e.NewValue}'");
if (!boxCodes.Any())
{
this.View.ShowErrMessage($"根据当前发货通知单号:{fhBillNo},托码:{e.NewValue},找不到对应的装托数据！请确认条码是否正确！");
return;
}

var sjWeight = Convert.ToDouble(this.Model.GetValue("FSCSWeight"));//地磅重量
var boxCodeObj = boxCodes[0];
var bzWeight = Convert.ToDouble(boxCodeObj["FTorrWeight"]);//标准重量
var btQty = Convert.ToDouble(boxCodeObj["FBoxQty"]);//本托数量
this.Model.SetValue("FTorrSTDWeight",bzWeight,0);
this.Model.SetValue("FTorrQty",btQty,0);
this.SetBigFont("FTorrLable",e.NewValue,blue);
//判断重量是否满足
if (IsOk())
{
var boxEntry = this.Model.GetEntityDataObject(Model.BusinessInfo.GetEntity("FPackBoxEntry"));
if (boxEntry.Any())
{
var any = boxEntry.Any(x => x["FPackBoxNo"].Equals(e.NewValue));
if (any)
{
this.View.ShowErrMessage("当前托已称过重量！请勿重复操作！");
return;
}
}
this.Model.CreateNewEntryRow("FPackBoxEntry");
var rowIndex = this.Model.GetEntryCurrentRowIndex("FPackBoxEntry");
this.Model.SetValue("FPackBoxNo",e.NewValue,rowIndex);
this.Model.SetValue("FBoxQty",boxCodeObj["FBoxQty"],rowIndex);
this.Model.SetValue("FTorrWeight",bzWeight,rowIndex);
this.Model.SetValue("FTorrActualWeight",sjWeight,rowIndex);
this.Model.SetItemValueByID("FBTMaterialId",boxCodeObj["FTorrMaterialId"],rowIndex);

//获取发货明细行索引
var informEntity = this.Model.GetEntityDataObject(this.View.BusinessInfo.GetEntity("FEntity")).ToList();
int fhIndex = informEntity.FindIndex(x => x["FFHMaterialId_Id"].ToString().Equals(boxCodeObj["FTorrMaterialId"].ToString()));
//计算已装托数量，写到发货明细单据体
this.Model.SetValue("FWeightOKQty",Convert.ToInt32(informEntity[fhIndex]["FWeightOKQty"]) + btQty ,fhIndex);

this.SetBigFont("FIsOkLable","通过",green);
this.View.GetControl("FCorrectMp3").InvokeControlMethod("Play", null);
}
else
{
this.SetBigFont("FIsOkLable","不通过",red);
this.View.GetControl("FScanErrorMp3").InvokeControlMethod("Play", null);
}

}

//发货通知单单号值更新-扫码录入
if (e.Field.Key.EqualsIgnoreCase("FDeliveryNotice"))
{
var fhObj = KEDUtils.GetQueryData(this.Context, "SAL_DELIVERYNOTICE",
$"FBillNo = '{e.NewValue}' and FDocumentStatus='C' and FCLOSESTATUS='A' and FCancelStatus='A' and FTerminationStatus='A'");
if (fhObj ==