WMSPrjInstance/HH-0127_YinNiJiaTong.git

New file
			@@ -0,0 +1,262 @@
			using HH.WCS.Mobox3.FJJF.models;
			using HH.WCS.Mobox3.FJJT.api;
			using HH.WCS.Mobox3.FJJT.device;
			using HH.WCS.Mobox3.FJJT.dispatch;
			using HH.WCS.Mobox3.FJJT.process;
			using HH.WCS.Mobox3.FJJT.wms;
			using Newtonsoft.Json;
			using System;
			using System.Collections.Generic;
			using System.Linq;
			using System.Web.Http;
			using static HH.WCS.Mobox3.FJJT.api.ApiHelper;
			using static HH.WCS.Mobox3.FJJT.api.ApiModel;
			using HH.WCS.Mobox3.FJJT.util;

			namespace HH.WCS.Mobox3.FJJT.core {
			internal class WCSCore {

			/// <summary>
			/// AGV任务回报
			/// 1.根据回报AGV任务状态，更新货位信息和任务状态
			/// 2.判断WMSTask是否是出库任务，是，如果工装内有物料，则判断物料是否合格，不合格，则生成不合格品入库任务
			/// 3.如果合格，则触发余料/空托回库任务
			/// </summary>
			/// <param name="model"></param>
			public static void OperateAgvTaskStatus(AgvTaskState model) {
			try
			{
			if (string.IsNullOrEmpty(model.No))
			{
			//无任务号请求(交管)
			//DeviceProcess.Traffic(model.ForkliftNo, model.LockNo, model.State==1023);
			}
			else
			{
			var cst = WCSHelper.GetTask(model.No);

			if (cst != null)
			{
			var mst = WMSHelper.GetWmsTask(cst.S_OP_CODE);
			if (mst != null)
			{
			WCSHelper.AddActionRecord(model.No, model.State, model.ForkliftNo, model.ExtData);
			if (model.State <= 7)
			{
			//有任务号请求
			switch (model.State)
			{
			case 1:
			WCSHelper.Begin(cst);
			WMSHelper.updateMesTaskStatus(mst.S_CODE, "2"); // 更新MES任务状态
			break;
			#region MyRegion
			case 3:
			WCSHelper.UpdateStatus(cst, "开始取货");
			var locCntrRels = LocationHelper.GetLocCntr(cst.S_START_LOC);
			if (locCntrRels.Count > 0)
			{
			cst.S_CNTR_CODE = locCntrRels[0].S_CNTR_CODE;
			WCSHelper.UpdateWcsTask(cst);
			}
			break;
			case 4:
			WCSHelper.UpdateStatus(cst, "取货完成");
			LocationHelper.UnLockLoc(cst.S_START_LOC);
			TaskProcess.OperateStatus(cst, 4);
			break;
			case 5:
			WCSHelper.UpdateStatus(cst, "开始卸货");
			break;
			case 6:
			WCSHelper.UpdateStatus(cst, "卸货完成");
			LocationHelper.UnLockLoc(cst.S_END_LOC);
			TaskProcess.OperateStatus(cst, 6);
			break;
			#endregion
			case 2:
			WCSHelper.End(cst);
			break;
			case 7:
			TaskProcess.OperateStatus(cst, 7);
			WCSHelper.Fail(cst);
			break;
			}
			}
			else if (model.State == 1012)
			{
			LogHelper.Info("开始进行RFID扫描", "AGV");
			ContainerHelper.UpdateCntrState(cst.S_CNTR_CODE, 1);
			WMSHelper.addRfidAnomalyRecord(cst.S_CNTR_CODE, 2, cst.S_START_LOC, null);
			// 查询扫描的RFID
			// 发送 00 04 71 02到扫码器，接受返回数据并解析
			byte[] bytes = new byte[] { 00, 04, 71, 02 };
			var plc = Settings.carDeviceInfos.Where(a => a.deviceNo == model.ForkliftNo && a.enable == 1).FirstOrDefault();
			TcpServer.TcpServerSend(plc.address, bytes);
			}
			else if (model.State == 1002)
			{
			LogHelper.Info("开始获取AGV终点", "AGV");
			// 更新AGV终点
			// 判断容器是否异常，修改1002的终点参数，并将参数6修改为1
			Container container = ContainerHelper.GetCntr(cst.S_CNTR_CODE);
			if (container != null)
			{
			LogHelper.Info($"容器的异常状态为：{container.N_E_STATE}", "AGV");
			string agvEndLoc = null;
			if (container.N_E_STATE == 0)
			{
			agvEndLoc = ApiHelper.AGVApplyDest(model.No, cst.S_START_LOC, cst.S_CNTR_CODE, "1");
			}
			else
			{
			agvEndLoc = ApiHelper.AGVApplyDest(model.No, cst.S_START_LOC, cst.S_CNTR_CODE, "2");
			}

			ChangeParamModel paramModel = new ChangeParamModel()
			{
			task_no = model.No,
			param_no = 0,
			param = $"{model.No};{cst.S_START_LOC};{cst.S_END_LOC};4;512;0;1"
			};
			NDCApi.ChangeOrderParam(paramModel);
			LogHelper.Info($"变更AGV终点：{agvEndLoc}", "AGV");
			}
			else
			{
			WMSHelper.addAlarmRecord("流程异常", "中", $"AGV任务回报,任务容器编码:{cst.S_CNTR_CODE}的容器没有录入到WMS系统","AGV");
			}
			}
			else
			{
			//安全请求等
			TaskProcess.OperateReq(model.No, model.State, model.ForkliftNo, model.ExtData);
			}

			// AGV任务完成
			if (model.State == 2)
			{
			// 检测物料是否合格,如不合格，
			// 判断物料是否是环带库物料，是则回环带库，并让环带下发新的物料
			// 非环带库物料，则退出立库，同时下发新的物料出库任务
			if (cst.S_TYPE.Contains("叫料出库任务"))
			{
			var cntrItemRels = ContainerHelper.GetCntrItemRel(cst.S_CNTR_CODE);
			if (cntrItemRels != null && cntrItemRels.Count > 0)
			{
			if (cntrItemRels[0].S_ITEM_STATE == "2")
			{
			// 不合格品回库
			ApiHelper.rejectReturnStock(mst, cst);
			}
			}
			}

			// 检测是否是读码位，非读码位，可以激活预创建任务
			var transfe = WMSHelper.GetTransfeRelevance(cst.S_END_LOC); // 接驳位属性
			if (transfe != null && transfe.N_READ_LOC == 1)
			{
			WCSHelper.ActivatePreCreateTask(mst.S_CODE);
			}
			else if ( transfe.N_READ_LOC == 0)
			{
			if (cst.S_TYPE.Contains("【异常】"))
			{
			WCSHelper.ActivatePreCreateTask(mst.S_CODE,1);
			}
			else
			{
			WCSHelper.ActivatePreCreateTask(mst.S_CODE);
			}
			}

			// 查询是否有未完成的任务
			if (WMSHelper.isFinishTask(mst.S_CODE))
			{
			// 更新作业任务状态
			mst.N_B_STATE = 2;
			mst.T_END_TIME = DateTime.Now;
			WMSHelper.UpdateTaskState(mst);

			// 更新任务中间表状态
			WMSHelper.updateMesTaskStatus(mst.S_CODE, "3");

			// 如果作业名称为成型机叫料出库任务，则触发余料/空托搬运任务
			string locCode = WMSHelper.getReturnMaterialLocCode(mst.S_END_LOC);
			ApiHelper.returnMaterialOrEmptyTray(locCode);
			}
			}
			}
			else
			{
			WMSHelper.addAlarmRecord("系统错误", "高", $"AGV任务状态回报，作业号:{cst.S_OP_CODE}，未查询到作业","AGV");
			}
			}
			else
			{
			WMSHelper.addAlarmRecord("系统错误", "高", $"AGV任务状态回报，任务号:{model.No}，未查询到任务","AGV");
			}
			}
			}
			catch (Exception ex)
			{
			WMSHelper.addAlarmRecord("系统错误","高", $"WMS内部错误：agv任务状态回报错误，错误原因:{ex.Message}","AGV");
			}
			}

			/// <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 })) {
			//修改托盘状态为可用，增加库存量表，后面分拣出可以计算到


			}
			}
			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);
			}
			}
			}
			}
			}
			}