| | |
| | | detail.N_B_STATE = 2; |
| | | |
| | | var cntId = detail.S_CNTR_CODE; |
| | | var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); |
| | | |
| | | var erp_no = string.IsNullOrEmpty(detail.S_BS_NO) ? "" : detail.S_BS_NO; |
| | | var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName, detail.S_OO_NO, erp_no); |
| | | |
| | | LocationHelper.LockStartLoc(ref startLoc); // 起点出库锁 |
| | | LocationHelper.LockEndLoc(ref endLoc); // 终点入库锁 |
| | |
| | | LogHelper.Info(info); |
| | | continue; |
| | | } |
| | | |
| | | |
| | | if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new { |
| | | it.N_LOCK_STATE, |
| | |
| | | .Count(d => d.S_OO_NO == order.S_NO && d.N_B_STATE >= 2); // 执行中 |
| | | var allCount = db.Queryable<TN_SpotCheck_Detail>() |
| | | .Count(d => d.S_OO_NO == order.S_NO); |
| | | LogHelper.Info($"轮询--{taskName}--统计{taskName}单'{order.S_NO}'任务已下发:{doingCount}/{allCount}"); |
| | | LogHelper.Info($"轮询:{taskName}:统计{taskName}单'{order.S_NO}'任务已下发:{doingCount}/{allCount}"); |
| | | |
| | | if (doingCount == allCount) { |
| | | order.N_B_STATE = 2; // 所有任务都已执行 |
| | |
| | | .ToList(); |
| | | |
| | | if (checkDetailList.Count == 0) { |
| | | LogHelper.Info($"轮询--{taskName}--仍有任务未执行完成,但当前没有已下发的任务"); |
| | | LogHelper.Info($"轮询:{taskName}:仍有任务未执行完成,但当前没有已下发的任务"); |
| | | continue; |
| | | } |
| | | |
| | |
| | | .First(); |
| | | |
| | | if (startLoc == null) { |
| | | LogHelper.Info($"轮询--{taskName}:没有找到合适的起点货位!"); |
| | | LogHelper.Info($"轮询:{taskName}:没有找到合适的起点货位!"); |
| | | continue; |
| | | } |
| | | |
| | |
| | | .Where(a => a.N_CURRENT_NUM == 0).First(); |
| | | |
| | | if (endLoc == null) { |
| | | LogHelper.Info($"轮询--{taskName}:没有找到合适的终点货位!"); |
| | | LogHelper.Info($"轮询:{taskName}:没有找到合适的终点货位!"); |
| | | continue; |
| | | } |
| | | |
| | | detail.N_B_STATE = 2; |
| | | |
| | | var cntId = detail.S_CNTR_CODE; |
| | | var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); |
| | | var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName, detail.S_OO_NO); |
| | | |
| | | LocationHelper.LockStartLoc(ref startLoc); // 起点出库锁 |
| | | LocationHelper.LockEndLoc(ref endLoc); // 终点入库锁 |
| | |
| | | using (var tran = db.Ado.UseTran()) { |
| | | if (db.Updateable<TN_SpotCheck_Detail>(detail).UpdateColumns(it => it.N_B_STATE).ExecuteCommand() <= 0) { |
| | | tran.RollbackTran(); |
| | | LogHelper.Info($"轮询--{taskName}:修改{taskName}单明细表状态为完成--失败!"); |
| | | LogHelper.Info($"轮询:{taskName}:修改{taskName}单明细表状态为完成--失败!"); |
| | | continue; |
| | | } |
| | | |
| | |
| | | .ToList(); |
| | | |
| | | if (orderList.Count == 0) { |
| | | LogHelper.Info($"轮询--{taskName}--暂无待执行的{taskName}单"); |
| | | LogHelper.Info($"轮询:{taskName}:暂无待执行的{taskName}单"); |
| | | return; |
| | | } |
| | | |
| | |
| | | .Count(d => d.S_OO_NO == order.S_NO && d.N_B_STATE >= 2); // 执行中 |
| | | var allCount = db.Queryable<TN_RelocationList_Detail>() |
| | | .Count(d => d.S_OO_NO == order.S_NO); |
| | | LogHelper.Info($"轮询--{taskName}--统计{taskName}单'{order.S_NO}'任务已下发:{doingCount}/{allCount}"); |
| | | LogHelper.Info($"轮询:{taskName}:统计{taskName}单'{order.S_NO}'任务已下发:{doingCount}/{allCount}"); |
| | | |
| | | if (doingCount == allCount) { |
| | | order.N_B_STATE = 2; // 所有任务都已执行 |
| | |
| | | .ToList(); |
| | | |
| | | if (checkDetailList.Count == 0) { |
| | | LogHelper.Info($"轮询--{taskName}--仍有任务未执行完成,但当前没有已下发的任务"); |
| | | LogHelper.Info($"轮询:{taskName}:仍有任务未执行完成,但当前没有已下发的任务"); |
| | | continue; |
| | | } |
| | | |
| | |
| | | .First(); |
| | | |
| | | if (startLoc == null) { |
| | | LogHelper.Info($"轮询--{taskName}:没有找到合适的起点货位!"); |
| | | LogHelper.Info($"轮询:{taskName}:没有找到合适的起点货位!"); |
| | | continue; |
| | | } |
| | | |
| | |
| | | .Where(a => a.N_CURRENT_NUM == 0).First(); |
| | | |
| | | if (endLoc == null) { |
| | | LogHelper.Info($"轮询--{taskName}:没有找到合适的终点货位!"); |
| | | LogHelper.Info($"轮询:{taskName}:没有找到合适的终点货位!"); |
| | | continue; |
| | | } |
| | | |
| | | detail.N_B_STATE = 2; |
| | | |
| | | var cntId = detail.S_CNTR_CODE; |
| | | var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName); |
| | | var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName, detail.S_OO_NO); |
| | | |
| | | LocationHelper.LockStartLoc(ref startLoc); // 起点出库锁 |
| | | LocationHelper.LockEndLoc(ref endLoc); // 终点入库锁 |
| | |
| | | using (var tran = db.Ado.UseTran()) { |
| | | if (db.Updateable<TN_RelocationList_Detail>(detail).UpdateColumns(it => it.N_B_STATE).ExecuteCommand() <= 0) { |
| | | tran.RollbackTran(); |
| | | LogHelper.Info($"轮询--{taskName}:修改{taskName}单明细表状态为完成--失败!"); |
| | | LogHelper.Info($"轮询:{taskName}:修改{taskName}单明细表状态为完成--失败!"); |
| | | continue; |
| | | } |
| | | |