删除冗余的注释和功能，优化部分代码

kazelee

2025-06-23 6b9801e47304eac1640cf737ef6bc039ff104dd1

 core/WCSCore.cs

@@ -20,27 +20,15 @@
        public static ReturnResult OperateAgvTaskStatus(AgvTaskState model) {
            var result = new ReturnResult();
            try {
                switch (model.state) {
                    case 1023:
                        break;
                    case 1025:
                        break;
                    case 1012:
                        break;
                    case 1004:
                        break;
                    case 1103:
                        break;
                    default:
                        // AGV 执行任务的逻辑处理
                        if (!AgvTaskProcessOk(model)) {
                            // 执行不OK，说明没有找到任务
                            result.ResultCode = 1;
                            result.ResultMsg = $"根据Model.No未找到对应的任务，{model.task_no}";
                            LogHelper.Info(result.ResultMsg, "API");
                            return result;
                        }
                        break;
                if (model.state > 0) {
                    // AGV 执行任务的逻辑处理
                    if (!AgvTaskProcessOk(model)) {
                        // 执行不OK，说明没有找到任务
                        result.ResultCode = 1;
                        result.ResultMsg = $"根据Model.No未找到对应的任务，{model.task_no}";
                        LogHelper.Info(result.ResultMsg, "API");
                        return result;
                    }
                }

                result.ResultCode = 0;
@@ -50,7 +38,7 @@
            }
            catch (Exception ex) {
                result.ResultCode = -1;
                result.ResultMsg = $"发生了异常：+{ex.Message}";
                result.ResultMsg = $"发生了异常：{ex.Message}";
                LogHelper.Info(result.ResultMsg, "Error");
                return result;
            }
@@ -88,9 +76,9 @@
                        var nextOutboundTask = Task.Run(() => {
                            UpdateOutboundTaskState(3);
                        });
                        //var pickUpReturnErpTask = Task.Run(() => {
                        //    PickUpReturnErp(TN_Task);
                        //});
                        var pickUpReturnErpTask = Task.Run(() => {
                            PickUpReturnErp(TN_Task);
                        });
                    }

                    break;
@@ -162,7 +150,17 @@
                    isInbound= true;
                }

                var record = new TN_Record_Table {
                //var needUpdateRecordTable = false;
                var record = db.Queryable<TN_Record_Table>()
                    .Where(r => r.S_TASK_NO == task.S_CODE).First();
                if (record != null) {
                    //needUpdateRecordTable = true;
                    info = $"出入库记录表中已经存在任务号{task.S_CODE}"; // 防止测试时反复调用134562导致重复记录
                    LogHelper.Info(info);
                    return;
                }

                record = new TN_Record_Table {
                    S_ITEM_CODE = cgDetail.S_ITEM_CODE,
                    S_BATCH_NO = cgDetail.S_BATCH_NO,
                    S_ITEM_NAME = cgDetail.S_ITEM_NAME,
@@ -175,12 +173,12 @@
                    S_TASK_NO = task.S_CODE,
                    T_RECORD_TIME = DateTime.Now,
                    S_TYPE = task.S_TYPE,
                    S_BS_CODE = task.S_BS_TYPE,
                    S_BS_CODE = task.S_BS_NO, // ERP单号，默认为空
                    N_QTY = cgDetail.N_ITEM_NUM,
                    S_NO = task.S_OP_CODE, // 出库/抽检/移库单
                };

                // 数据库操作

                if (db.Insertable<TN_Record_Table>(record).ExecuteCommand() <= 0) {
                    info = "插入出入库记录表失败：" + JsonConvert.SerializeObject(record);
                    LogHelper.Info(info);
@@ -261,7 +259,6 @@
                    info = $"向输送线写入允许取货信号成功";
                    LogHelper.Info(info);
                    return NewReturnResult(0, info);

                }
                else if (model.apply_code == "1") { // 请求卸货
                    if (prodLineDevice.AllowAgvPlacePallet != 1) {
@@ -302,7 +299,7 @@
                .First(d => d.N_B_STATE == 2);

            if (detail == null) {
                LogHelper.Info($"{taskName}--AGV取货--查询明细单：当前没有执行中的明细单");
                LogHelper.Info($"{taskName}：AGV取货：查询明细单：当前没有执行中的明细单");
                return;
            }

@@ -310,14 +307,14 @@
                detail.N_B_STATE = spotStateCode;
                if (db.Updateable<TN_Outbound_Detail>(detail).UpdateColumns(it => it.N_B_STATE).ExecuteCommand() <= 0) {
                    tran.RollbackTran();
                    LogHelper.Info($"{taskName}--AGV取货：修改明细单状态为3任务执行完成--失败！");
                    LogHelper.Info($"{taskName}：AGV取货：修改明细单状态为【3任务执行完成】失败！");
                    return;
                }

                var finishedCount = db.Queryable<TN_Outbound_Detail>().Count(d => d.S_OO_NO == detail.S_OO_NO && d.N_B_STATE == 3);
                var allCount = db.Queryable<TN_Outbound_Detail>().Count(d => d.S_OO_NO == detail.S_OO_NO);

                LogHelper.Info($"{taskName}--AGV取货--统计任务已完成：{finishedCount}/{allCount}");
                LogHelper.Info($"{taskName}：AGV取货：统计任务已完成：{finishedCount}/{allCount}");

                if (finishedCount == allCount) { // 当前出库单下的所有明细单，任务都已经完成

@@ -326,7 +323,7 @@
                        .ExecuteCommand() <= 0) {

                        tran.RollbackTran();
                        LogHelper.Info($"{taskName}--AGV取货--所有任务完成时：修改单据状态为3任务执行完成--失败！");
                        LogHelper.Info($"{taskName}：AGV取货：所有任务完成时：修改单据状态为3任务执行完成--失败！");
                        return;
                    }
                }
@@ -336,13 +333,98 @@
        }

        public static void PickUpReturnErp(TN_Task task) {
            var db = new SqlHelper<object>().GetInstance();
            var info = "";
            var httpH = new HttpHelper();
            var model = new OtherModel.PickUpReturnErpInfo();
            model.LocCode = task.S_START_LOC;
            
            try {
                var plan = db.Queryable<TN_Outbound_Plan>()
                    .Where(p => p.JHDH == task.S_BS_NO)
                    .First();

                if (plan == null) {
                    info = $"计划单号{task.S_BS_NO}不存在！";
                    LogHelper.Info(info);
                }

                var cgDetail = db.Queryable<TN_CG_Detail>()
                    .Where(d => d.S_CNTR_CODE == task.S_CNTR_CODE)
                    .First();

                if (cgDetail == null) {
                    info = $"物料编码不存在！";
                    LogHelper.Info(info);
                }

                var model = new OtherModel.PickUpReturnErpInfo {
                    jhdh = plan.JHDH, // 计划单号（唯一标识）
                    ckzt = plan.CKZT, // 出库状态（需要返回）
                    jhlb = plan.JHLB, // 计划类别
                    ckdh = plan.CKDH, // 参考单号
                    cph = plan.CPH, // 车牌号
                    ysfs = plan.YSFS, // 运输方式
                    cpzt = plan.CPZT, // 产品状态
                    mddw = plan.MDDW, // 买断单位
                    cpdm = plan.CPDM, // 产品代码
                    cplb = plan.CPLB, // 产品类别
                    cplbmx = plan.CPLBMX, // 产品类别明细
                    pp = plan.PP, // 品牌
                    dj = plan.DJ, // 等级（需要返回）
                    gh = plan.GH, // 罐号
                    ph = plan.PH, // 批号（需要返回）
                    bzlx = plan.BZLX, // 包装类型
                    pzdh = plan.PZDH, // 派装单号
                    pzd_dw = plan.PZD_DW, // 派装单单位
                    pzd_dybh = plan.PZD_DYBH, // 派装单调运编号
                    pzjs = plan.PZJS, // 派装件数
                    pzsl = plan.PZSL, // 派装数量
                    pz_rq = plan.PZ_RQ, // 派装日期(yyyy-mm-dd)
                    pz_czrq = plan.PZ_CZRQ, // 派装操作日期
                    pz_zfbj = plan.PZ_ZFBJ, // 派装作废标记
                    pz_zfrq = plan.PZ_ZFRQ, // 派装作废日期
                    pz_bz = plan.PZ_BZ, // 派装备注
                    ckdbh = plan.CKDBH, // 出库单编号
                    sfjs = plan.SFJS, // 实发件数（需要返回）--更新
                    sfsl = plan.SFSL, // 实发数量（需要返回）--更新
                    //sfcs = plan.SFCS , // 实发车数（需要返回）
                    //zcsj = plan.ZCSJ , // 装车时间（需要返回）
                    //jldw = plan.JLDW , // 计量单位（需要返回）
                    //fhrq = plan.FHRQ , // 发货日期（需要返回）
                    //ckdm = plan.CKDM , // 仓库代码（需要返回）
                    //fhr = plan.FHR , // 发货人（需要返回）
                    //czydm = plan.CZYDM , // 操作员（需要返回）
                    shr_username = plan.SHR_USERNAME, // 审核人
                    shrq = plan.SHRQ, // 审核日期
                    zfbj = plan.ZFBJ, // 作废标记
                    zfrq = plan.ZFRQ, // 作废日期
                    jsdw = plan.JSDW, // 结算单位
                    shdw = plan.SHDW, // 收货单位
                    ysdw = plan.YSDW, // 运输单位
                    lxr = plan.LXR, // 联系人
                    //ry_zxg = plan.RY_ZXG , // 装卸工（需要返回）
                    //ry_ccsj = plan.RY_CCSJ , // 叉车司机（需要返回）
                    erphx_jhdh = plan.ERPHX_JHDH, // erp交货单号
                    erphx_wlbm = plan.ERPHX_WLBM, // erp物料编码
                    erphx_wlmc = plan.ERPHX_WLMC, // erp物料名称
                    erphx_cjrq = plan.ERPHX_CJRQ, // erp创建日期
                    hw = plan.HW, // 货位（需要返回）
                    hwzt = plan.HWZT // 货位状态（需要返回）
                };
                model.sfjs = cgDetail.N_ITEM_NUM;
                model.sfsl = (decimal) cgDetail.F_QTY; // TEMP
                model.hwzt = "已出库";

                var jsonInfo = JsonConvert.SerializeObject(model);
                var result = httpH.WebPost(Settings.ErpApiUrl + "PickUpReturn", jsonInfo);
                // TODO

                LogHelper.InfoApi($"取货完成反馈ERP接口，结果={result}，调用参数：", model);

                plan.SFJS = model.sfjs;
                plan.SFSL = model.sfsl;
                plan.HWZT = model.hwzt;
                var success = db.Updateable<TN_Outbound_Plan>(plan).UpdateColumns(p => new { p.SFJS, p.SFSL, p.HWZT }).ExecuteCommand() > 0;
                info = "更新出库计划单记录表" + (success ? "成功" : "失败");
                LogHelper.Info(info);
            }
            catch (Exception ex) {
                LogHelper.InfoEx(ex);
@@ -361,7 +443,6 @@
                list.ForEach(task => {
                    //使用自定义任务推送
                    TaskProcess.SendTask(task);//调度NDC或杭奥或国自设备
                    //TaskProcess.SendGZTask(task);///调度国自设备
                });
            }
            else {