| | |
| | | internal static WMSTask GetTaskByStartLoc(string loc) |
| | | { |
| | | var db = new SqlHelper<WMSTask>().GetInstance(); |
| | | var task = db.Queryable<WMSTask>().Where(a => a.S_START_LOC == loc && a.S_B_STATE != "完成" && a.S_B_STATE != "取消" && a.S_B_STATE != "失败" && a.S_B_STATE != "已完成").OrderByDescending(b => b.T_CREATE).First(); |
| | | var task = db.Queryable<WMSTask>().Where(a => a.S_START_LOC == loc && a.S_B_STATE != "完成" && a.S_B_STATE != "取消" && a.S_B_STATE != "失败" && a.S_B_STATE != "已完成" && a.S_B_STATE != "未执行").OrderByDescending(b => b.T_CREATE).First(); |
| | | return task; |
| | | } |
| | | /// <summary> |
| | |
| | | internal static WMSTask GetTaskByEndLoc(string loc) |
| | | { |
| | | var db = new SqlHelper<WMSTask>().GetInstance(); |
| | | var task = db.Queryable<WMSTask>().Where(a => a.S_END_LOC == loc && a.S_B_STATE != "完成" && a.S_B_STATE != "取消" && a.S_B_STATE != "失败" && a.S_B_STATE != "已完成").OrderByDescending(b => b.T_CREATE).First(); |
| | | var task = db.Queryable<WMSTask>().Where(a => a.S_END_LOC == loc && a.S_B_STATE != "完成" && a.S_B_STATE != "取消" && a.S_B_STATE != "失败" && a.S_B_STATE != "已完成" && a.S_B_STATE != "未执行").OrderByDescending(b => b.T_CREATE).First(); |
| | | return task; |
| | | } |
| | | |
| | |
| | | |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 根据作业编码和设备类型获取单个任务 |
| | | /// </summary> |
| | | /// <param name="state"></param> |
| | | /// <returns></returns> |
| | | internal static WMSTask GetTaskByWork(string eq, string opCode) |
| | | { |
| | | try |
| | | { |
| | | var db = new SqlHelper<object>().GetInstance(); |
| | | return db.Queryable<WMSTask>().Where(a => a.S_SCHEDULE_TYPE.Contains(eq) && a.S_OP_CODE.Contains(opCode)).First(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | LogHelper.Error(ex.Message, ex); |
| | | return new WMSTask(); |
| | | } |
| | | |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 返回当前接驳位执行中任务数量 |
| | | /// </summary> |
| | | internal static int GetConnectionTask(string Connection) |
| | | { |
| | | var db = new SqlHelper<object>().GetInstance(); |
| | | |
| | | |
| | | var ConnectionList = 0; |
| | | ConnectionList = db.Queryable<WMSTask>().Where(a => a.S_END_LOC.Contains(Connection) && a.S_TYPE.Contains("出库") && a.S_B_STATE != "完成" && a.S_B_STATE != "取消" && a.S_B_STATE != "未执行").ToList().Count(); |
| | | |
| | | return ConnectionList; |
| | | } |
| | | |
| | | |
| | | //internal static bool CreateAgvState(AgvState agvState) |
| | | //{ |
| | | // try |
| | | // { |
| | | // var db = new SqlHelper<object>().GetInstance(); |
| | | |
| | | // return db.Insertable<AgvState>(agvState).ExecuteCommand() > 0; |
| | | // } |
| | | // catch (Exception ex) |
| | | // { |
| | | // LogHelper.Info($"添加Agv动作缓存异常" + ex.Message, "NDC"); |
| | | // throw; |
| | | // } |
| | | //} |
| | | |
| | | |
| | | internal static bool CreateMesKtTask(MesKtTask cntr) |
| | | { |
| | |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Console.WriteLine(ex.Message); |
| | | LogHelper.Info($"添加Mes空托缓存异常" + ex.Message, "Mes任务下发"); |
| | | throw; |
| | | } |