添加CgDetail信息同步字段和锁状态字段，修改相关逻辑

kazelee

5 天以前 656f90b301ba307c909de4ee94b88af817adf0d8

 core/Monitor.cs

@@ -20,7 +20,11 @@
            var db = new SqlHelper<object>().GetInstance();
            try {
                var inboundDataList = db.Queryable<TN_Inbound_DataRecord>().ToList();
                LogHelper.Info($"轮询：入库信息同步：当前没有待同步的ERP物料信息");
                
                if (inboundDataList.Count == 0 ) {
                    LogHelper.Info($"轮询：入库信息同步：当前没有待同步的ERP物料信息");
                    return;
                }

                var needDeleteDataList = new List<TN_Inbound_DataRecord>();
                var needUpdateLocCntrRelList = new List<TN_Loc_Container>();
@@ -34,14 +38,30 @@
                            LogHelper.Info($"轮询：入库信息同步：货位容器表中，包含货位={locCntrRel.S_LOC_CODE}, 容器={locCntrRel.S_CNTR_CODE}；但容器对应的物料表，没有找到物料！");
                            continue;
                        }
                        // ERP 数据 -> CG_Detail
                        cgDetail.S_ITEM_CODE = inboundData.S_ITEM_CODE;

                        cgDetail.S_ITEM_SHORT_DESC = inboundData.S_ITEM_SHORT_DESC; // 物料短描述
                        //cgDetail.S_INVENTORY_MAN = inboundData.S_INVENTORY_MAN; // 库存责任人姓名
                        cgDetail.S_IN_QUANTITY = inboundData.S_IN_QUANTITY; // 入库数量
                        cgDetail.S_STOCK_QUANTITY = inboundData.S_STOCK_QUANTITY; // 库存数量
                        cgDetail.S_TOTAL_PRICE = inboundData.S_TOTAL_PRICE; // 库存总价
                        cgDetail.S_STORE_KEEPER = inboundData.S_STORE_KEEPER;
                        cgDetail.S_LINE_CODE = inboundData.S_LINE_CODE;

                        cgDetail.T_MODIFY = DateTime.Now;

                        locCntrRel.N_LOCK_STATE = 1;
                        cgDetail.N_LOCK_STATE = 1;
                        locCntrRel.T_MODIFY = DateTime.Now;
                        needUpdateLocCntrRelList.Add(locCntrRel);
                        needUpdateCgDetailList.Add(cgDetail);
                        needDeleteDataList.Add(inboundData);
                    }
                }

                if (needDeleteDataList.Count == 0) {
                    LogHelper.Info($"轮询：入库信息同步：待更新的ERP物料信息，暂无物料可以覆盖，目前待更新数量：{inboundDataList.Count}");
                }

                using (var tran = db.Ado.UseTran()) {
@@ -81,8 +101,9 @@

                if (outboundDataList.Count== 0 ) {
                    LogHelper.Info($"轮询：出库信息同步：当前没有待同步的ERP物料信息");
                    return;
                }

                
                var needDeleteDataList = new List<TN_Outbound_DataRecord>();
                var needUpdateLocCntrRelList = new List<TN_Loc_Container>();
                var needUpdateCgDetailList = new List<TN_CG_Detail>();
@@ -96,13 +117,20 @@
                            continue;
                        }
                        cgDetail.S_ITEM_CODE = outboundData.S_ITEM_CODE;
                        cgDetail.S_STORE_KEEPER = outboundData.S_STORE_KEEPER;

                        cgDetail.T_MODIFY = DateTime.Now;
                        locCntrRel.N_LOCK_STATE = 1;
                        cgDetail.N_LOCK_STATE = 1;
                        locCntrRel.T_MODIFY = DateTime.Now;
                        needUpdateLocCntrRelList.Add(locCntrRel);
                        needUpdateCgDetailList.Add(cgDetail);
                        needDeleteDataList.Add(outboundData);
                    }
                }

                if (needDeleteDataList.Count == 0) {
                    LogHelper.Info($"轮询：出库信息同步：待更新的ERP物料信息，暂无物料可以覆盖，目前待更新数量：{outboundDataList.Count}");
                }

                using (var tran = db.Ado.UseTran()) {
@@ -130,10 +158,11 @@

            }
            catch (Exception ex) {

                LogHelper.Info($"发生了异常：{ex.Message}");
            }
        }

        
    }

}