|
using HH.WCS.JunzhouNongfu.device;
|
using HH.WCS.Mobox3.HD.device;
|
using HH.WCS.Mobox3.HD.dispatch;
|
using HH.WCS.Mobox3.HD.models;
|
using HH.WCS.Mobox3.HD.process;
|
using HH.WCS.Mobox3.HD.util;
|
using HH.WCS.Mobox3.HD.wms;
|
using Newtonsoft.Json;
|
using NLog;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Reflection;
|
using System.Threading.Tasks;
|
using static HH.WCS.Mobox3.HD.api.ApiModel;
|
using static HH.WCS.Mobox3.HD.dispatch.ShopFloorControl;
|
using static HH.WCS.Mobox3.HD.util.Settings;
|
|
|
namespace HH.WCS.Mobox3.HD.core {
|
internal class WCSCore {
|
public static void OperateAgvTaskStatus(AgvTaskState model) {
|
if (string.IsNullOrEmpty(model.No)) {
|
//无任务号请求(交管)
|
//DeviceProcess.Traffic(model.ForkliftNo, model.LockNo, model.State==1023);
|
}
|
else {
|
var TN_Task = WCSHelper.GetTask(model.No);
|
if (TN_Task != null) {
|
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:
|
WCSHelper.UpdateStatus(TN_Task, "卸货完成");
|
TaskProcess.OperateStatus(TN_Task, 6);
|
break;
|
#endregion
|
case 2:
|
WCSHelper.End(TN_Task);
|
break;
|
case 7:
|
//判断是否收到过强制取消，有就不做任何处理
|
if (!WCSHelper.CheckActionRecordExist(TN_Task.S_CODE, 17))
|
{
|
TaskProcess.OperateStatus(TN_Task, 7);
|
WCSHelper.Fail(TN_Task);
|
}
|
break;
|
}
|
WCSHelper.AddActionRecord(model.No, model.State, model.ForkliftNo, model.ExtData);
|
//调用第三方接口（如果有）TaskProcess.ReportStatus
|
}
|
else {
|
//安全请求等
|
TaskProcess.OperateReq(model.No, model.State, model.ForkliftNo, model.ExtData);
|
}
|
}
|
}
|
}
|
|
/// <summary>
|
/// 合力 任务状态反馈
|
/// </summary>
|
/// <param name="model"></param>
|
public static void OperateHLTaskStatus(HLAgvTaskState model)
|
{
|
if (string.IsNullOrEmpty(model.orderId))
|
{
|
//无任务号请求(交管)
|
//DeviceProcess.Traffic(model.ForkliftNo, model.LockNo, model.State==1023);
|
}
|
else
|
{
|
var wcsTask = WCSHelper.GetTask(model.orderId);
|
if (wcsTask != null && wcsTask.N_B_STATE != 3 && wcsTask.S_SCHEDULE_TYPE.Equals("HL"))
|
{
|
HLStatusInfo hLStatusInfo = null ;
|
WMSTask wmsTask = WMSHelper.GetWmsTask(wcsTask.S_OP_CODE);
|
if (wmsTask != null )
|
{
|
hLStatusInfo = new HLStatusInfo()
|
{
|
orderId = wmsTask.S_CODE,
|
agvId = model.agvId,
|
status = model.status,
|
reason = model.reason
|
};
|
}
|
|
//有任务号请求
|
switch (model.status)
|
{
|
case "1":
|
WCSHelper.Begin(wcsTask);
|
LocationHelper.UnBindingLoc(wcsTask.S_START_LOC, new List<string> { wcsTask.S_CNTR_CODE });
|
LocationHelper.UnLockLoc(wcsTask.S_START_LOC);
|
wcsTask.S_EQ_NO = model.agvId;
|
WCSHelper.UpdateStatus(wcsTask, "取货完成");
|
break;
|
|
case "2":
|
WCSHelper.End(wcsTask);
|
if (wcsTask.S_TYPE.Contains("入库"))
|
{
|
LocationHelper.BindingLoc(wcsTask.S_END_LOC, new List<string> { wcsTask.S_CNTR_CODE });
|
}
|
LocationHelper.UnLockLoc(wcsTask.S_END_LOC);
|
if (wmsTask != null)
|
{
|
// 判断作业任务是否已完成
|
if (wmsTask.S_END_LOC.Equals(wcsTask.S_END_LOC))
|
{
|
wmsTask.N_B_STATE = 2;
|
wmsTask.T_END_TIME = DateTime.Now;
|
WMSHelper.UpdateTaskState(wmsTask);
|
|
if (wmsTask.S_OP_DEF_NAME == "模具出库(初始化)")
|
{
|
// 删除模具信息
|
MouldHelper.deleteMouldByCntr(wmsTask.S_CNTR_CODE);
|
}
|
|
if (wmsTask.S_TYPE == "模具入库")
|
{
|
MouldHelper.updateMouldStatus(wmsTask.S_CNTR_CODE, "Y");
|
}
|
if (wmsTask.S_TYPE == "模具出库")
|
{
|
MouldHelper.updateMouldStatus(wmsTask.S_CNTR_CODE, "N");
|
}
|
if (wmsTask.S_TYPE == "钢卷出库") {
|
ContainerHelper.UpdateCntrItem(wmsTask.S_CNTR_CODE, 0);
|
}
|
if (wmsTask.S_TYPE == "钢卷入库" || wmsTask.S_TYPE == "钢卷来料入库")
|
{
|
ContainerHelper.UpdateCntrItem(wmsTask.S_CNTR_CODE, 1);
|
}
|
|
var cntrItemRels = ItemHelper.GetCntrItemByCntrCode(wmsTask.S_CNTR_CODE);
|
if (cntrItemRels != null && cntrItemRels.Count > 0)
|
{
|
foreach (var cntrItemRel in cntrItemRels)
|
{
|
// 更新出入库记录
|
WMSHelper.AddStockRecord(wmsTask, cntrItemRel);
|
// 终点货位在系统中没有维护，则删除容器物料信息
|
var endLoc = LocationHelper.GetLoc(wmsTask.S_END_LOC);
|
if (endLoc == null)
|
{
|
ContainerHelper.deleteCntrItem(wmsTask.S_CNTR_CODE);
|
}
|
else if (cntrItemRel.S_ITEM_TYPE.Equals("半成品"))
|
{
|
ContainerHelper.deleteCntrItem(wmsTask.S_CNTR_CODE);
|
}
|
}
|
}
|
else
|
{
|
// 更新出入库记录
|
WMSHelper.AddStockRecord(wmsTask, null);
|
}
|
}
|
else
|
{
|
if (wmsTask.S_END_LOC == "虚拟库位" && wmsTask.S_TYPE == "钢卷入库")
|
{
|
var gjWeight = getGjWeight(wcsTask.S_END_LOC , wcsTask.S_CNTR_CODE ,wmsTask.S_OP_DEF_CODE);
|
Location endLoc = WMSHelper.GetGJEndLocation(gjWeight);
|
if (endLoc != null)
|
{
|
wmsTask.S_END_LOC = endLoc.S_CODE;
|
wmsTask.S_END_AREA = endLoc.S_AREA_CODE;
|
WMSHelper.UpdateTask(wmsTask);
|
|
// 输送线称重回报车间控制器
|
SteelWeightInfo productWeightInfo = new SteelWeightInfo()
|
{
|
transferId = wmsTask.S_OP_DEF_CODE,
|
steelcoilCode = wmsTask.S_CNTR_CODE,
|
weight = gjWeight,
|
endStationCode = endLoc.S_CODE,
|
endAreaCode = endLoc.S_AREA_CODE
|
};
|
ShopFloorControl.reportSteelWeight(productWeightInfo);
|
}
|
else {
|
wmsTask.S_ERR = "没有可入的钢卷货位";
|
WMSHelper.UpdateTask(wmsTask);
|
}
|
}
|
var twoWcsTask = new WCSTask
|
{
|
S_OP_NAME = wmsTask.S_OP_DEF_NAME,
|
S_CODE = WCSHelper.GenerateTaskNo(),
|
S_TYPE = wmsTask.S_TYPE+"-2",
|
S_START_LOC = wcsTask.S_END_LOC,
|
S_START_AREA = wcsTask.S_END_AREA,
|
S_END_LOC = wmsTask.S_END_LOC,
|
S_END_AREA = wmsTask.S_END_AREA,
|
S_SCHEDULE_TYPE = "HL",
|
S_CNTR_CODE = wmsTask.S_CNTR_CODE,
|
N_CNTR_COUNT = 1,
|
S_OP_CODE = wmsTask.S_CODE,
|
N_PRIORITY = wmsTask.N_PRIORITY,
|
};
|
if (wmsTask.S_TYPE.Equals("半成品/成品出库")) {
|
twoWcsTask.S_SCHEDULE_TYPE = "LD-AUTO";
|
}
|
if (wmsTask.S_TYPE.Equals("成品出库")) {
|
twoWcsTask.S_SCHEDULE_TYPE = "LD";
|
}
|
if (WCSHelper.CreateTask(twoWcsTask))
|
{
|
LocationHelper.LockLoc(twoWcsTask.S_START_LOC, 2);
|
LocationHelper.LockLoc(twoWcsTask.S_END_LOC, 1);
|
}
|
}
|
}
|
break;
|
|
case "3":
|
// 任务取消
|
WCSHelper.Fail(wcsTask);
|
LocationHelper.UnLockLoc(wcsTask.S_START_LOC);
|
LocationHelper.UnLockLoc(wcsTask.S_END_LOC);
|
|
// 作业取消
|
wmsTask.N_B_STATE = 3;
|
wmsTask.T_END_TIME = DateTime.Now;
|
WMSHelper.UpdateTaskState(wmsTask);
|
LocationHelper.UnLockLoc(wmsTask.S_END_LOC);
|
LogHelper.Info("任务已取消，任务号：" + wcsTask.S_CODE, "合力");
|
break;
|
}
|
// 回报车间控制器合力任务状态
|
if (hLStatusInfo != null) {
|
ShopFloorControl.updateStatus(hLStatusInfo);
|
}
|
|
WCSHelper.AddActionRecord(model.orderId, int.Parse(model.status), model.agvId, null);
|
}
|
}
|
}
|
|
public static float getGjWeight(string locCode ,string cntrCode ,string transferId = null) {
|
var weightPlcInfo = weightPlcInfos.Where(a => a.location == locCode).FirstOrDefault();
|
LogHelper.Info("称重设备信息:" + JsonConvert.SerializeObject(weightPlcInfo), "Mobox");
|
|
float weight = 0;
|
if (weightPlcInfo != null) {
|
try
|
{
|
// 获取称重结果
|
LogHelper.Info("开始查询称重结果", "Mobox");
|
string hexString = TcpClient.SendHexOnce(weightPlcInfo.ip, 502, weightPlcInfo.command);
|
LogHelper.Info("hexString:" + hexString, "Mobox");
|
weight = Convert.ToInt32(hexString.Substring(6, 8), 16);
|
LogHelper.Info("称重结果:" + weight + " ;hexString:" + hexString, "Mobox");
|
|
// 更新物料重量数据
|
if (weight != 0)
|
{
|
var cntrItemRels = ItemHelper.GetCntrItemByCntrCode(cntrCode);
|
if (cntrItemRels != null && cntrItemRels.Count > 0)
|
{
|
foreach (var cntrItemRel in cntrItemRels)
|
{
|
cntrItemRel.F_WEIGHT = weight;
|
if (cntrItemRel.F_INIT_WEIGHT == 0)
|
{
|
cntrItemRel.F_INIT_WEIGHT = weight;
|
}
|
ItemHelper.updateCntrItem(cntrItemRel);
|
}
|
}
|
}
|
}
|
catch (Exception e) {
|
LogHelper.Info("获取称重数据错误，错误原因："+e.Message, "Mobox");
|
}
|
}
|
return weight;
|
}
|
|
/// <summary>
|
/// 任务分发，根据调度类型发给不同的调度系统
|
/// </summary>
|
internal static void Dispatch() {
|
|
//查询任务
|
//获取所有等待的任务
|
var list = WCSHelper.GetWaitingTaskList();
|
if (list.Count > 0) {
|
list.ForEach(task =>
|
{
|
if (TaskProcess.Intercept(task))
|
{
|
//使用自定义任务推送
|
TaskProcess.SendTask(task);
|
}
|
});
|
}
|
}
|
|
/// <summary>
|
/// 杭奥堆垛机信号反馈
|
/// </summary>
|
/// <param name="model"></param>
|
internal static void OperateHATaskStatus(HanAo.TaskStateInfoModel model) {
|
var wcsTask = WCSHelper.GetTask(model.requestPk);
|
if (wcsTask != null) {
|
if (model.code == "0") {
|
//
|
if (wcsTask.S_TYPE == "堆垛机入库") {
|
//终点托盘绑定
|
if (LocationHelper.BindingLoc(wcsTask.S_END_LOC, new List<string> { wcsTask.S_CNTR_CODE })) {
|
//修改托盘状态为可用，增加库存量表，后面分拣出可以计算到
|
ContainerHelper.Enable(wcsTask.S_CNTR_CODE, wcsTask.S_END_LOC);
|
}
|
}
|
else if (wcsTask.S_TYPE == "堆垛机出库") {
|
//起点托盘解绑
|
LocationHelper.UnBindingLoc(wcsTask.S_START_LOC, new List<string> { wcsTask.S_CNTR_CODE });
|
}
|
//标记任务完成
|
//标记作业完成
|
wcsTask.N_B_STATE = 3;
|
WCSHelper.UpdateStatus(wcsTask);
|
var wmsTask = WMSHelper.GetWmsTask(wcsTask.S_OP_CODE);
|
if (wmsTask != null) {
|
wmsTask.N_B_STATE = 2;
|
WMSHelper.UpdateTaskState(wmsTask);
|
}
|
}
|
}
|
}
|
|
public class IssueTaskModel
|
{
|
public int taskId { get; set; } // 任务号
|
public short targetAddress { get; set; } // WCS分配的目标地址
|
public short instruction { get; set; } // 下发命令 WCS下发的动作指令 入库=2 出库=1
|
public string trayCode { get; set; } // 托盘编码
|
}
|
}
|
}
|
