using HH.WCS.JunzhouNongfu.device;
|
using HH.WCS.Mobox3.YNJT_BZP.api;
|
using HH.WCS.Mobox3.YNJT_BZP.dispatch;
|
using HH.WCS.Mobox3.YNJT_BZP.models;
|
using HH.WCS.Mobox3.YNJT_BZP.process;
|
using HH.WCS.Mobox3.YNJT_BZP.util;
|
using HH.WCS.Mobox3.YNJT_BZP.wms;
|
using Newtonsoft.Json;
|
using Org.BouncyCastle.Asn1.X509;
|
using S7.Net;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Net.Sockets;
|
using System.Runtime.Remoting.Metadata.W3cXsd2001;
|
using System.Threading.Tasks;
|
using static HH.WCS.Mobox3.YNJT_BZP.api.AgvController;
|
using static HH.WCS.Mobox3.YNJT_BZP.api.ApiModel;
|
using static HH.WCS.Mobox3.YNJT_BZP.dispatch.GtDispatch;
|
|
namespace HH.WCS.Mobox3.YNJT_BZP.core {
|
internal class WCSCore {
|
public static void OperateAgvTaskStatus(AgvTaskState model) {
|
LogHelper.Info($"AGV任务状态反馈，入参：{JsonConvert.SerializeObject(model)}", "AGV");
|
try
|
{
|
if (string.IsNullOrEmpty(model.No))
|
{
|
LogHelper.Info("任务号为空", "AGV");
|
}
|
else
|
{
|
var TN_Task = WCSHelper.GetTask(model.No);
|
if (TN_Task != null)
|
{
|
bool isExist = WCSHelper.CheckActionRecordExist(TN_Task.S_CODE, model.State);
|
if (!isExist)
|
{
|
WCSHelper.AddActionRecord(model.No, model.State, model.ForkliftNo, model.ExtData);
|
if (model.State <= 7)
|
{
|
//有任务号请求
|
switch (model.State)
|
{
|
case 1:
|
WCSHelper.Begin(TN_Task);
|
break;
|
#region MyRegion
|
case 3:
|
WCSHelper.UpdateStatus(TN_Task, "开始取货");
|
break;
|
case 4:
|
WCSHelper.UpdateStatus(TN_Task, "取货完成");
|
TaskProcess.OperateStatus(TN_Task, 4);
|
break;
|
case 5:
|
WCSHelper.UpdateStatus(TN_Task, "开始卸货");
|
break;
|
case 6:
|
TaskProcess.OperateStatus(TN_Task, 6);
|
WCSHelper.UpdateStatus(TN_Task, "卸货完成");
|
break;
|
#endregion
|
case 2:
|
WCSHelper.End(TN_Task);
|
|
var cntrItemRels = ContainerHelper.GetCntrItemRel(TN_Task.S_CNTR_CODE);
|
if (cntrItemRels.Count > 0)
|
{
|
string shift = ApiHelper.getShift(DateTime.Now.TimeOfDay);
|
string ydate_shiftName = "";
|
if (shift == "III")
|
{
|
ydate_shiftName = DateTime.Now.AddDays(-1).ToString("yy/MM/dd") + "-" + shift;
|
}
|
else
|
{
|
ydate_shiftName = DateTime.Now.ToString("yy/MM/dd") + "-" + shift;
|
}
|
WmsToGtLokasiModel wmsToGtLokasiModel = new WmsToGtLokasiModel()
|
{
|
ydate_shiftName = ydate_shiftName,
|
bc_entried = cntrItemRels[0].S_CG_ID,
|
loc_from = TN_Task.S_START_LOC,
|
loc_to = TN_Task.S_END_LOC,
|
qty = 1,
|
lot = 1,
|
scantime = TN_Task.T_CREATE.ToString("yyyy-MM-dd HH:mm:ss"),
|
pic = model.ForkliftNo
|
};
|
GtDispatch.agvTaskFeedback(wmsToGtLokasiModel);
|
}
|
break;
|
case 7:
|
//判断是否收到过强制取消，有就不做任何处理
|
if (!WCSHelper.CheckActionRecordExist(TN_Task.S_CODE, 17))
|
{
|
TaskProcess.OperateStatus(TN_Task, 7);
|
WCSHelper.Cancel(TN_Task);
|
}
|
break;
|
}
|
}
|
else if (model.State == 1002)
|
{
|
//查询当前终点是等待区，则查询入库agv接驳位
|
var waitLoc = Settings.getAgvWaitLoc(TN_Task.S_END_LOC);
|
if (waitLoc != null)
|
{
|
string endLoc = AGVApplyEndLoc(model.No);
|
|
|
}
|
|
//如果不是等待区货位，则查询终点货位是否是入库接驳位
|
var agvJBLoc = Settings.getAgvJBLoc(TN_Task.S_END_LOC);
|
if (agvJBLoc != null && agvJBLoc.type == 1 && agvJBLoc.action == 1)
|
{
|
//是则查询WCS的任务执行情况
|
var wcsTask = WCSHelper.GetTaskBySrcNoAndScheduleType(TN_Task.S_OP_CODE ,"WCS");
|
if (wcsTask != null)
|
{
|
bool existAction = WCSHelper.CheckActionRecordExist(wcsTask.S_CODE, 7);
|
if (existAction)
|
{
|
//如果WCS反馈7取消任务，则rfid校验失败，生成新任务到异常区，并变更agv任务号、起点、终点
|
var mst = WMSHelper.GetWmsTask(TN_Task.S_OP_CODE);
|
var endLoc = WMSHelper.getErrorBufferAreaLoc();
|
if (endLoc != null)
|
{
|
LocationHelper.UnLockLoc(mst.S_END_LOC);
|
mst.S_END_LOC = endLoc.S_CODE;
|
mst.S_END_AREA = endLoc.S_AREA_CODE;
|
|
WMSHelper.UpdateTaskEnd(mst);
|
WCSCore.createLastTask(TN_Task.S_END_LOC, mst, 2);
|
}
|
else
|
{
|
LogHelper.Info("", "AGV");
|
}
|
}
|
|
existAction = WCSHelper.CheckActionRecordExist(wcsTask.S_CODE, 3);
|
if (existAction)
|
{
|
//WCS反馈3已取货，则agv任务正常结束
|
|
}
|
}
|
}
|
}
|
else
|
{
|
//安全请求等
|
TaskProcess.OperateReq(model.No, model.State, model.ForkliftNo, model.ExtData);
|
}
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Info($"agv回报错误，错误原因：{ex.Message}", "AGV");
|
}
|
}
|
|
/// <summary>
|
/// 创建最后一个任务
|
/// </summary>
|
/// <param name="startLocCode"></param>
|
/// <param name="mst"></param>
|
/// <param name="actType">1.入库 2.出库</param>
|
/// <returns></returns>
|
public static bool createLastTask(string startLocCode , WMSTask mst ,int actType)
|
{
|
LogHelper.Info("创建下一段任务", "WMS");
|
var startLoc = LocationHelper.GetLoc(startLocCode);
|
if (startLoc != null)
|
{
|
string cntrCode = "";
|
string scheduleType = "";
|
if (actType == 1)
|
{
|
var locCntrRels = LocationHelper.GetLocCntr(startLocCode);
|
if (locCntrRels.Count > 0)
|
{
|
foreach (var cntr in locCntrRels)
|
{
|
cntrCode = cntrCode + ","+ cntr.S_CNTR_CODE;
|
}
|
cntrCode = cntrCode.Substring(1, cntrCode.Length-1);
|
}
|
scheduleType = "WCS";
|
}
|
|
if (actType == 2)
|
{
|
cntrCode = mst.S_CNTR_CODE;
|
scheduleType = "AGV";
|
}
|
|
// 创建一段入库任务
|
WCSTask wcsTask = new WCSTask()
|
{
|
S_OP_NAME = mst.S_OP_DEF_NAME,
|
S_OP_CODE = mst.S_CODE,
|
S_CODE = WCSHelper.GenerateTaskNo(),
|
S_CNTR_CODE = cntrCode,
|
S_TYPE = mst.S_TYPE + "-2",
|
S_START_LOC = startLoc.S_CODE,
|
S_START_AREA = startLoc.S_AREA_CODE,
|
S_END_LOC = mst.S_END_LOC,
|
S_END_AREA = mst.S_END_AREA,
|
S_SCHEDULE_TYPE = scheduleType,
|
N_PRIORITY = mst.N_PRIORITY,
|
T_START_TIME = DateTime.Now,
|
};
|
|
if (WCSHelper.CreateTask(wcsTask))
|
{
|
// 起点、接驳点、终点加锁
|
LocationHelper.LockLoc(wcsTask.S_START_LOC, 2);
|
LocationHelper.LockLoc(wcsTask.S_END_LOC, 1);
|
|
WMSHelper.UpdateTaskEnd(mst);
|
return true;
|
}
|
}
|
return false;
|
}
|
|
/// <summary>
|
/// 任务分发，根据调度类型发给不同的调度系统
|
/// </summary>
|
internal static void Dispatch() {
|
var db = new SqlHelper<object>().GetInstance();
|
//查询任务
|
//获取所有等待的任务
|
var list = WCSHelper.GetWaitingTaskList();
|
if (list.Count > 0) {
|
foreach (var task in list)
|
{
|
if (!TaskProcess.Intercept(task))
|
{
|
//使用自定义任务推送
|
TaskProcess.SendTask(task);
|
}
|
}
|
}
|
}
|
|
|
|
/// <summary>
|
/// agv申请终点
|
/// </summary>
|
/// <param name="taskNo"></param>
|
public static string AGVApplyEndLoc(string taskNo)
|
{
|
LogHelper.Info($"任务号：{taskNo},AGV等待区申请终点", "AGV");
|
var cst = WCSHelper.GetTask(taskNo);
|
if (cst != null && cst.N_B_STATE < 3)
|
{
|
var mst = WMSHelper.GetWmsTask(cst.S_OP_CODE);
|
if (mst != null && mst.N_B_STATE < 2 && mst.S_END_LOC == "虚拟货位")
|
{
|
var container = ContainerHelper.GetCntr(cst.S_CNTR_CODE);
|
if (container != null)
|
{
|
var endLoc = WMSHelper.GetInstockEndLoc(container.N_TYPE);
|
if (endLoc != null)
|
{
|
Location agvLoc = null;
|
var locCodes = Settings.getAgvJBLocList(1, endLoc.N_ROADWAY, 1);
|
if (locCodes.Count > 0)
|
{
|
foreach (var locCode in locCodes)
|
{
|
agvLoc = LocationHelper.GetLoc(locCode);
|
if (agvLoc != null && agvLoc.C_ENABLE == "Y")
|
{
|
cst.S_END_LOC = agvLoc.S_CODE;
|
cst.S_END_AREA = agvLoc.S_AREA_CODE;
|
WCSHelper.UpdateTaskEnd(cst);
|
|
mst.S_END_LOC = endLoc.S_CODE;
|
mst.S_END_AREA = endLoc.S_AREA_CODE;
|
WMSHelper.UpdateTaskEnd(mst);
|
LocationHelper.LockLoc(endLoc.S_CODE, 1);
|
|
LogHelper.Info($"任务号：{taskNo},AGV申请的终点：{agvLoc.S_CODE}", "AGV");
|
return agvLoc.S_CODE;
|
}
|
}
|
|
LogHelper.Info($"任务号：{taskNo},入库接驳位货位都已禁用", "AGV");
|
}
|
else
|
{
|
LogHelper.Info($"任务号：{taskNo},没有配置立库接驳位", "AGV");
|
}
|
}
|
else
|
{
|
LogHelper.Info($"任务号：{taskNo},立库没有满足条件的空货位", "AGV");
|
}
|
}
|
else
|
{
|
LogHelper.Info($"任务号：{taskNo},AGV任务的容器：{cst.S_CNTR_CODE}不存在", "AGV");
|
}
|
}
|
else
|
{
|
LogHelper.Info($"任务号：{taskNo},AGV任务已申请终点，请勿重复申请", "AGV");
|
}
|
}
|
else
|
{
|
LogHelper.Info($"任务号：{taskNo},AGV任务已完成或取消", "AGV");
|
}
|
return null;
|
}
|
|
}
|
}
|
