| | |
| | | // 创建出库单(DoOut) |
| | | GetTask(ThreadMenthod.CreateOutboundOrderFromDoOut), |
| | | // 创建出库作业 |
| | | GetTask(ThreadMenthod.CreateOutTaskFromDistributionCntrDetail), |
| | | GetTaskS(ThreadMenthod.CreateOutTaskFromDistributionCntrDetail), |
| | | // 作业完成以及错误修改 |
| | | GetTask(ThreadMenthod.AccomplishOperation), |
| | | // Directory读取文件,并处理 |
| | |
| | | return task; |
| | | } |
| | | |
| | | private Task GetTaskS(Action action) |
| | | { |
| | | var task = Task.Run(() => |
| | | { |
| | | while (true) |
| | | { |
| | | try |
| | | { |
| | | action(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | LogHelper.Error(ex.Message, ex); |
| | | } |
| | | |
| | | Thread.Sleep(12000); |
| | | } |
| | | }); |
| | | |
| | | return task; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// ftp上传与下载 |
| | | /// </summary> |
| | |
| | | var container = AdoSqlMethod<Container>.QueryFirst(p => p.S_CODE == task.S_CNTR_CODE); |
| | | |
| | | container.C_ENABLE = 'Y'; |
| | | container.N_DETAIL_COUNT = 0; |
| | | container.S_TYPE = null; |
| | | |
| | | AdoSqlMethod<Container>.UpdateFirst(container, p => new { p.C_ENABLE, p.N_DETAIL_COUNT, p.S_TYPE }); |
| | | |
| | | AdoSqlMethod<Container>.UpdateFirst(container, p => new { p.C_ENABLE, p.S_TYPE }); |
| | | |
| | | OutWareHouseService.ResultDeterminationGuideOut(task); |
| | | |
| | | |
| | | } |
| | | // 指引出库 |
| | | // 空托出库 |
| | | else if (task.N_TYPE == 7) |
| | | { |
| | | // 货位解锁 |