| | |
| | | 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>(); |
| | |
| | | needUpdateCgDetailList.Add(cgDetail); |
| | | needDeleteDataList.Add(inboundData); |
| | | } |
| | | } |
| | | |
| | | if (needDeleteDataList.Count == 0) { |
| | | LogHelper.Info($"轮询:入库信息同步:待更新的ERP物料信息,暂无物料可以覆盖,目前待更新数量:{inboundDataList.Count}"); |
| | | } |
| | | |
| | | using (var tran = db.Ado.UseTran()) { |
| | |
| | | |
| | | if (outboundDataList.Count== 0 ) { |
| | | LogHelper.Info($"轮询:出库信息同步:当前没有待同步的ERP物料信息"); |
| | | return; |
| | | } |
| | | |
| | | var needDeleteDataList = new List<TN_Outbound_DataRecord>(); |
| | |
| | | needUpdateCgDetailList.Add(cgDetail); |
| | | needDeleteDataList.Add(outboundData); |
| | | } |
| | | } |
| | | |
| | | if (needDeleteDataList.Count == 0) { |
| | | LogHelper.Info($"轮询:出库信息同步:待更新的ERP物料信息,暂无物料可以覆盖,目前待更新数量:{outboundDataList.Count}"); |
| | | } |
| | | |
| | | using (var tran = db.Ado.UseTran()) { |
| | |
| | | |
| | | } |
| | | catch (Exception ex) { |
| | | |
| | | LogHelper.Info($"发生了异常:{ex.Message}"); |
| | | } |
| | | } |