using HH.WCS.JingyuNongfu.core;
using HH.WCS.JingyuNongfu.device;
using HH.WCS.JingyuNongfu.dispatch;
using HH.WCS.JingyuNongfu.util;
using HH.WCS.JingyuNongfu.wms;
using Newtonsoft.Json;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Security.Cryptography;
using static HH.WCS.JingyuNongfu.api.ApiModel;
namespace HH.WCS.JingyuNongfu.process
{
internal class TaskProcess
{
private static HttpHelper httpHelper = new HttpHelper();
#region 任务相关
//--------------------------------------------------任务相关--------------------------------------------------
private static object locLocker = new object();
///
/// 申请出入库任务
///
///
///
///
///
///
///
///
///
internal static bool ApplyWMSTask(Location ls, ref List cntrs, string area, string itemCode, string itemBatch, string taskType, bool insStock = true)
{
var result = false;
lock (locLocker)
{
try
{
if (insStock)
{
Console.WriteLine($"LocationHelperCreateTask: {area}-{itemCode}-{itemBatch}-{taskType}");
var endLocation = WMSHelper.IntensiveArea.GetLocation4In(area, itemCode, itemBatch, 3);
if (endLocation != null)
{
var endLayer = endLocation.N_CURRENT_NUM == 0 ? 1 : 2;
var taskNo = DateTime.Now.Ticks.ToString();
result = TaskProcess.CreateTransport(ls.S_LOC_CODE, endLocation.S_LOC_CODE, taskType, cntrs, 1, endLayer, 3, 70);
}
else
{
Console.WriteLine($"LocationHelperCreateTask: 未找到终点货位");
}
}
else
{
var startLocation = WMSHelper.IntensiveArea.GetLocation4Out(area, itemCode, itemBatch, 3);
if (startLocation != null)
{
var startLayer = startLocation.N_CURRENT_NUM <= 3 ? 1 : 2;
var taskNo = DateTime.Now.Ticks.ToString();
var carryCount = startLocation.N_CURRENT_NUM > 3 ? startLocation.N_CURRENT_NUM - 3 : startLocation.N_CURRENT_NUM;
//出库要从起点获取托盘
var cntrList = LocationHelper.GetLocCntr(startLocation.S_LOC_CODE);
if (cntrList.Count == startLocation.N_CURRENT_NUM)
{
cntrs = cntrList.OrderByDescending(a => a.T_CREATE).Take(carryCount).Select(a => a.S_CNTR_CODE.Trim()).ToList();
result = TaskProcess.CreateTransport(startLocation.S_LOC_CODE, ls.S_LOC_CODE, taskType, cntrs, startLayer, 1, carryCount, 65);
}
else
{
Console.WriteLine($"起点托盘数量和货位容器表不符合,请检查【货位表】和【货位容器表】");
}
}
}
}
catch (Exception ex)
{
Console.WriteLine("LocationHelperCreateTask:" + ex.Message);
LogHelper.Error("LocationHelperCreateTask:" + ex.Message, ex);
}
}
return result;
}
///
/// 取货卸货完成,缓存位状态更新
///
///
///
internal static void CacheBitUpdate(WMSTask mst, bool load)
{
var trayCarryCount = mst.N_CNTR_COUNT > 0 ? mst.N_CNTR_COUNT : 1;
if (load)
{
Console.WriteLine($"任务{mst.S_TASK_NO} 货位{mst.S_START_LOC}取货完成,起点解绑容器{mst.S_CNTRS}");
LogHelper.Info($"任务{mst.S_TASK_NO} 货位{mst.S_START_LOC}取货完成,起点解绑容器{mst.S_CNTRS}");
LocationHelper.UnBindingLoc(mst.S_START_LOC, mst.S_CNTRS.Split(',').ToList());
}
else
{
Console.WriteLine($"任务{mst.S_TASK_NO} 货位{mst.S_END_LOC}卸货完成,终点绑定容器{mst.S_CNTRS}");
LogHelper.Info($"任务{mst.S_TASK_NO} 货位{mst.S_END_LOC}卸货完成,终点绑定容器{mst.S_CNTRS}");
LocationHelper.BindingLoc(mst.S_END_LOC, mst.S_CNTRS.Split(',').ToList());
}
}
///
/// 任务取消,缓存位状态更新
///
///
internal static void CacheBitCancelUpdate(WMSTask mst)
{
//任务取消,取货完成前的,起点的loadingCount和终点unLoadingCount都清除,取货完成的只处理终点
if (TaskHelper.CheckActionRecordExist(mst.S_TASK_NO, "4"))
{
//终点绑定
CacheBitUpdate(mst, false);
//todo: 如果是电梯卸货任务电梯任务中间表状态,如
LocationHelper.UnLockLoc(mst.S_END_LOC);
}
else
{
//电梯卸货任务表直接删除
//起点终点解锁
LocationHelper.UnLockLoc(mst.S_START_LOC);
LocationHelper.UnLockLoc(mst.S_END_LOC);
//todo: 如果是电梯卸货任务取消删除,如果是电梯取货任务取消修改任务状态
}
}
///
/// 安全请求
///
///
///
///
///
internal static void OperateReq(string no, int state, string forkliftNo, string extData)
{
//1103呼叫空托 卸货 1104 呼叫空托 卸货完成
var mst = TaskHelper.GetTask(no);
if (state == 1103 || state == 1104)
{
Console.WriteLine($"进入安全请求,state:{state}");
if (mst != null)
{
Console.WriteLine($"获取到任务,进行卸料");
DeviceProcess.Xieliao(mst, state == 1103);
}
else
{
Console.WriteLine($"没获取到任务,不进行卸料");
}
}
else if (state == 1101 || state == 1102)
{
Console.WriteLine($"进入安全请求,state:{state}");
if (mst != null)
{
Console.WriteLine($"获取到任务,进行取料");
DeviceProcess.QuLiao(mst, state == 1101);
}
else
{
Console.WriteLine($"获取到任务,不进行取料");
}
}
}
///
/// 任务拦截
///
///
///
internal static bool Intercept(WMSTask mst)
{
var result = false;
//翻斗机叠空框
//电梯任务不推送,单独处理
if (mst.S_TYPE.Contains("-电梯"))
{
result = true;
}
if (mst.S_TYPE.Trim() == "翻斗机叠空框" && mst.N_PRIORITY == 90)
{
//判断相同终点的叠托任务是否存在,是否取货完成
var list = TaskHelper.GetTaskByEnd(mst.S_END_LOC);
var otherTask = list.Where(a => a.N_PRIORITY == 99).FirstOrDefault();
if (otherTask != null && !TaskHelper.CheckActionRecordExist(otherTask.S_TASK_NO, "4"))
{
TaskHelper.UpdateStatus(mst, "未执行");
result = true;
}
}
return result;
}
///
/// 任务状态更新处理
///
///
///
internal static void OperateStatus(WMSTask mst, int state, string TaskNo)
{
LogHelper.Info("任务信息 Request:" + JsonConvert.SerializeObject(mst), "HosttoagvTask");
var db = new SqlHelper