11
jinxin
2025-06-04 c96d07f7047f221b9ce1f8a330ab3db28c0be75e
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
using HH.WCS.Mobox3.YNJuXing.util;
using HH.WCS.Mobox3.YNJuXing.wms;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
 
namespace HH.WCS.Mobox3.YNJuXing.core
{
    internal class WMSCore
    {
        /// <summary>
        /// 遍历定版的发货单,生产分拣单主表和子表(也可以手动调接口触发)
        /// </summary>
        internal static void CheckShippingOrder()
        {
            //1.0、获取已经定版的发货单,生产分拣单子表和主表,设置【发货单】的业务状态 N_B_STATE = 1(待分拣)
            //2.0、如果发货单C_AUTO_SORTING=Y,则自动将分拣单状态设置为开始配货
 
        }
        /// <summary>
        /// 开始配货创建分拣单明细(改成调接口触发)
        /// </summary>
        internal static void CheckSortingOrder()
        {
            //new SortingOrder().N_B_STATE
            //1.0、获取 N_B_STATE = 1 (开始配货)状态的分拣单
            //2.0、遍历分拣单子表,创建分拣单明细,更新分拣单子表的明细汇总F_ACC_S_QTY
            //3.0、全部分拣单子表的明细创建完毕,子表明细汇总和子表数量一致,更新分拣单状态,N_B_STATE = 2配货完成
            //4.0、如果分拣单是自动作业,就直接更新到 N_B_STATE = 3开始作业
            //WMSHelper.GetWaitingSortingOrderList();
 
        }
 
        /// <summary>
        /// 遍历分拣单明细创建出库作业
        /// </summary>
        internal static void CheckSortingTask()
        {
            var db = new SqlHelper<object>().GetInstance();
            //new SortingOrder().N_B_STATE
            //遍历N_B_STATE = 3的分拣单创建作业
            //或 遍历分拣单明细创建分拣作业,因为一个分拣单里面的明细都是批量生成的
            var list = WMSHelper.GetWaitingSortingOperationList();
            LogHelper.Info($"获取配盘数量 {list.Count}");
            if (list.Count > 0)
            {
                list.ForEach(a =>
                {
                    var startloc = db.Queryable<Location>().Where(it => it.S_CODE == a.S_LOC_CODE).First();
                    if (startloc != null && startloc.S_LOCK_STATE == "其它锁")
                    {
 
                        Location endbit = null;
                      
                        //计算托盘进行出库
 
                        if (endbit != null)
                        {
                            var optask = new WMSTask
                            {
                                S_CODE = WMSHelper.GenerateTaskNo(),
                                S_START_LOC = a.S_LOC_CODE,
                                S_START_AREA = startloc.S_AREA_CODE,
                                S_START_WH = startloc.S_WH_CODE,
                                S_END_LOC = endbit.S_CODE,
                                S_END_AREA = endbit.S_AREA_CODE,
                                S_END_WH = endbit.S_WH_CODE,
                                S_STATION_LOC = a.S_OUT_TO,
                                S_TYPE = "出库",
                                N_TYPE = 2,
                                N_B_STATE = 0,
                                S_CNTR_CODE = a.S_CNTR_CODE,
                                S_OP_DEF_NAME = a.S_BS_TYPE
                            };
                            var note = Settings.Tasktypes.Where(it => it.StartArea == optask.S_START_AREA && it.EndArea == optask.S_END_AREA).FirstOrDefault();
                            if (note != null)
                            {
                                optask.S_NOTE = note.TaskType;
                            }
                            var res = db.Insertable(optask).ExecuteCommand() > 0;
                            if (res)
                            {
                                startloc.N_LOCK_STATE = 2;
                                startloc.S_LOCK_STATE = "出库锁";
                                db.Updateable(startloc).UpdateColumns(it => new { it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();
                                LocationHelper.LockLoc(endbit.S_CODE, 1);
                                a.N_B_STATE = 2;
                                a.S_B_STATE = "作业启动";
                                db.Updateable(a).UpdateColumns(it => new { it.S_B_STATE, it.N_B_STATE }).ExecuteCommand();
                            }
                        }
                        else LogHelper.Info($"配盘 未找到可用分拣货位");
                    }
                    else LogHelper.Info($"配盘 未找到出库口库区编码{a.S_EXIT_AREA_CODE} 对应的配置文件");
 
                });
            }
 
 
        }
 
        /// <summary>
        /// 作业启动,创建子任务
        /// </summary>
        internal static void Start()
        {
            LogHelper.Info($"作业启动 创建子任务");
            var db = new SqlHelper<object>().GetInstance();
            List<WMSTask> list = WMSHelper.GetWaitingOperationList();
            LogHelper.Info($"获取任务数据 数量{list.Count}");
            if (list.Count > 0)
            {
                //如果是出库的作业锁定托盘的时候已经明确起点了,如果发货单或分拣单指定了终点,
                //如果没有作业、任务的顺序限制就可以启动,创建子任务了
                foreach (var a in list)
                {
                    try
                    {
                        if (a.N_TYPE == 1)
                        {
                            //查询托盘所在位置
                            //计算终点
                            Location end = WMSHelper.GetEnd(a);
                            if (end != null)
                            {
                                LogHelper.Info($"作业{a.S_CODE} 获取终点成功 任务终点{end.S_CODE}");
                                WMSHelper.UpdateTaskEnd(a);
                                LocationHelper.LockLoc(end.S_CODE, 1);
                                var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == a.S_START_LOC).First();
                                var endinfo = db.Queryable<Location>().Where(it => it.S_CODE == end.S_CODE).First();
                                var wcsTask = new WCSTask
                                {
                                    S_OP_CODE = a.S_CODE,
                                    S_OP_NAME = "入库",
                                    S_CODE = WCSHelper.GenerateTaskNo(),
                                    S_TYPE = a.S_OP_DEF_NAME,
                                    S_START_LOC = a.S_START_LOC,
                                    S_START_AREA = startinfo.S_AREA_CODE,
                                    S_START_WH = startinfo.S_WH_CODE,
                                    S_END_LOC = end.S_CODE,
                                    S_END_AREA = endinfo.S_AREA_CODE,
                                    S_END_WH = endinfo.S_WH_CODE,
                                    S_SCHEDULE_TYPE = "NDC",
                                    N_CNTR_COUNT = 1,
                                    S_CNTR_CODE = a.S_CNTR_CODE,
                                };
                                if (WCSHelper.CreateTask(wcsTask))
                                {
                                    //更新作业状态为执行
                                    a.N_B_STATE = 1;
                                    a.S_B_STATE = "执行";
                                    WMSHelper.UpdateTaskState(a);
                                }
                            }
                            else
                            {
                                LogHelper.Info($"作业{a.S_CODE} 获取终点失败");
                            }
                        }
                        else if (a.N_TYPE == 2)
                        {
                            //通过托盘获取到对应的分拣单 通过分拣单查找发货单上的终点库区 如果是备货出库的话 从配置文件中找一个空闲的点位
                            //计算终点
                            Location end = WMSHelper.GetEnd(a);
                            if (end != null)
                            {
                                WMSHelper.UpdateTaskEnd(a);
                                LocationHelper.LockLoc(end.S_CODE, 1);
 
 
 
                                var startinfo = db.Queryable<Location>().Where(it => it.S_CODE == a.S_START_LOC).First();
                                var endinfo = db.Queryable<Location>().Where(it => it.S_CODE == end.S_CODE).First();
                                //创建wcs任务
                                var wcsTask = new WCSTask
                                {
                                    S_OP_CODE = a.S_CODE,
                                    S_OP_NAME = "出库",
                                    S_CODE = WCSHelper.GenerateTaskNo(),
                                    S_TYPE = a.S_OP_DEF_NAME,
                                    S_START_LOC = a.S_START_LOC,
                                    S_START_AREA = startinfo.S_AREA_CODE,
                                    S_START_WH = startinfo.S_WH_CODE,
                                    S_END_LOC = end.S_CODE,
                                    S_END_AREA = endinfo.S_AREA_CODE,
                                    S_END_WH = endinfo.S_WH_CODE,
                                    S_SCHEDULE_TYPE = "NDC",
                                    N_CNTR_COUNT = 1,
                                    S_CNTR_CODE = a.S_CNTR_CODE,
                                };
 
                                if (WCSHelper.CreateTask(wcsTask))
                                {
                                    //更新作业状态为执行
                                    a.N_B_STATE = 1;
                                    a.S_B_STATE = "执行";
                                    WMSHelper.UpdateTaskState(a);
                                }
                            }
                            else
                            {
                                LogHelper.Info($"作业{a.S_CODE} 获取终点失败");
                            }
                        }
                    }
                    catch (Exception ex)
                    {
                        LogHelper.Error($"作业启动异常 异常信息={ex.Message}", ex);
                    }
                }
            }
        }
    }
}