using Hanhe.iWCS.Business;
|
using Hanhe.iWCS.Common;
|
using Hanhe.iWCS.MData;
|
using MongoDB.Bson;
|
using MongoDB.Driver;
|
using MongoDB.Driver.Builders;
|
using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using static Hanhe.iWCS.JingmenGEMTwoProtocol.MESHelper;
|
using static Hanhe.iWCS.JingmenGEMTwoProtocol.PLCControl;
|
using static Hanhe.iWCS.JingmenGEMTwoProtocol.ProcessHelper;
|
using static Hanhe.iWCS.JingmenGEMTwoProtocol.ProtocolAnalysis;
|
|
namespace Hanhe.iWCS.JingmenGEMTwoProtocol
|
{
|
/// <summary>
|
/// ams接口辅助类
|
/// </summary>
|
public class ApiHelper
|
{
|
private static ICallTaskProcessing callTaskProcessing = new ICallTaskProcessing();
|
static ApiHelper()
|
{
|
|
}
|
|
internal static SimpleResult SendTask(AddTaskModel model)
|
{
|
SimpleResult result = new SimpleResult();
|
if (model.taskType == 1)
|
{
|
//PLan A.当WMS调AMS生成空托出库任务时，直接拦截存入中间表，待到线程循环读取推送电梯一段任务时，优先推送
|
//MongoDBSingleton.Instance.Insert<ElevatorTask>(new ElevatorTask { taskNo = DateTime.Now.ToString(), wmsTaskNo = DateTime.Now.ToString(), startBit = model.startBit, endBit = PLCControl.DeviceBit8(), wmsEndBit = model.endBit, startFloor = 1, endFloor = 3, sendFlag = 0, create = DateTime.Now.ToString() });
|
|
//Plan B.当WMS调AMS生成空托出库任务时，接受并创建空托出库任务，待到任务推送时，根据任务类型进行拦截
|
var r = AMSHelper.CreateTask(DateTime.Now.ToString(), model.startBit, model.endBit, "空托出库", 1);
|
result.success = r.success;
|
}
|
else if (model.taskType == 2)
|
{
|
//1楼成品货架区到1楼出库缓存位 --此任务需要添加虚拟终点，根据1楼出库缓存位的广电信号来分配AGV一个终点（四个点位，空的则可以入）
|
//WMS不需要传输终点，终点由AMS根据光电PLC信号，判断哪个信号是空的，再通知AGV终点，在此之前先使用虚拟终点
|
var r = AMSHelper.CreateTask(DateTime.Now.ToString(), model.startBit, model.endBit, "3楼成品出库", 1);
|
result.success = r.success;
|
}
|
else if (model.taskType == 3)
|
{
|
//PDA：1楼空托线边区到1楼成品空托位 ——应该有起点和终点位，直接推送——需反馈WMS任务状态
|
var r = AMSHelper.CreateTask(DateTime.Now.ToString(), model.startBit, model.endBit, "空托线边", 1);
|
result.success = r.success;
|
}
|
return result;
|
}
|
public class AddTaskModel
|
{
|
/// <summary>
|
/// 任务起点
|
/// </summary>
|
public string startBit { get; set; }
|
/// <summary>
|
/// 任务终点
|
/// </summary>
|
public string endBit { get; set; }
|
/// <summary>
|
/// 任务类别 1.1楼成品空托区到3楼补给成品空托区
|
/// 2.1楼成品货架区到1楼出库缓存位
|
/// 3.PDA：1楼空托线边区到1楼成品空托位
|
/// </summary>
|
public int taskType { get; set; }
|
}
|
public class SimpleResult
|
{
|
public bool success { get; set; }
|
public int errCode { get; set; }
|
public string errMsg { get; set; }
|
}
|
|
#region NG任务设备状态
|
|
internal static SimpleResult NgTask(NgTaskModel model)
|
{
|
SimpleResult result = new SimpleResult();
|
if (model.fcBit == 0)
|
{
|
var setus = MongoDBSingleton.Instance.FindOne<NgTaskModel>(Query.EQ("bzBit", model.bzBit), "NgTaskModel");
|
if (setus == null)
|
{
|
MongoDBSingleton.Instance.Insert<NgTaskModel>(new NgTaskModel { fcBit = model.fcBit, fcSetus = model.fcSetus, bzBit = model.bzBit, bzSetus = model.bzSetus });
|
}
|
else
|
{
|
var updateBuider = Update.Set("fcBit", model.fcBit).Set("fcSetus", model.fcSetus).Set("bzBit", model.bzBit).Set("bzSetus", model.bzSetus);
|
MongoDBSingleton.Instance.Update<NgTaskModel>(Query.EQ("bzBit", model.bzBit), updateBuider, UpdateFlags.None);
|
}
|
}
|
else
|
{
|
var setus = MongoDBSingleton.Instance.FindOne<NgTaskModel>(Query.EQ("fcBit", model.fcBit), "NgTaskModel");
|
if (setus == null)
|
{
|
//SecondWeighState
|
MongoDBSingleton.Instance.Insert<NgTaskModel>(new NgTaskModel { fcBit = model.fcBit, fcSetus = model.fcSetus, bzBit = model.bzBit, bzSetus = model.bzSetus });
|
MongoDBSingleton.Instance.Update<SecondWeighState>(Query.EQ("location", GetSecondWeighBit()), Update.Set("ng", 2), UpdateFlags.None);
|
}
|
else
|
{
|
var updateBuider = Update.Set("fcBit", model.fcBit).Set("fcSetus", model.fcSetus).Set("bzBit", model.bzBit).Set("bzSetus", model.bzSetus);
|
MongoDBSingleton.Instance.Update<NgTaskModel>(Query.EQ("fcBit", model.fcBit), updateBuider, UpdateFlags.None);
|
MongoDBSingleton.Instance.Update<SecondWeighState>(Query.EQ("location", GetSecondWeighBit()), Update.Set("ng", model.fcSetus), UpdateFlags.None);
|
}
|
}
|
|
return result;
|
}
|
|
public class NgTaskModel
|
{
|
/// <summary>
|
/// 默认情况下全都都传0
|
/// </summary>
|
public ObjectId _id { get; set; }
|
/// <summary>
|
/// 复称平台点位 复称平台有问题，就传值1
|
/// </summary>
|
public int fcBit { get; set; }
|
/// <summary>
|
/// 复称平台状态 复称平台有问题的情况下，传值2
|
/// </summary>
|
public int fcSetus { get; set; }
|
/// <summary>
|
/// 包装点位 包装机有问题，传包装机数字编号，例如1~9
|
/// </summary>
|
public int bzBit { get; set; }
|
/// <summary>
|
/// 包装状态 包装机有问题的情况下，传值2
|
/// </summary>
|
public int bzSetus { get; set; }
|
}
|
|
#endregion
|
|
#region MES接口模拟测试
|
internal static MESData MESTest(MESSendData model)
|
{
|
MESData result = new MESData();
|
|
var mesRequst = MongoDBSingleton.Instance.FindOne<MESReSult>(Query.EQ("machineNo", model.machineNo), "MESReSult");
|
if (mesRequst != null)
|
{
|
result.machineNo = mesRequst.machineNo;
|
result.lotNo = mesRequst.lotNo;
|
result.bagNo = mesRequst.bagNo;
|
result.productType = mesRequst.productType;
|
result.materialCode = mesRequst.materialCode;
|
result.overlappingLayers = mesRequst.overlappingLayers;
|
}
|
else
|
{
|
MongoDBSingleton.Instance.Insert<MESReSult>(new MESReSult { machineNo = "T1" });
|
}
|
return result;
|
}
|
public class MESSendData
|
{
|
/// <summary>
|
/// 包装机号
|
/// </summary>
|
public string machineNo { get; set; }
|
}
|
public class MESTaskData
|
{
|
/// <summary>
|
/// 包装补空点
|
/// </summary>
|
public string emptyPoint { get; set; }
|
}
|
public class MESReSult
|
{
|
public ObjectId _id { get; set; }
|
/// <summary>
|
/// mes返回的包装机号（T1，T2，......，T9）
|
/// </summary>
|
public string machineNo { get; set; }
|
/// <summary>
|
/// mes返回的成品批次号
|
/// </summary>
|
public string lotNo { get; set; }
|
/// <summary>
|
/// mes返回的袋号
|
/// </summary>
|
public string bagNo { get; set; }
|
/// <summary>
|
/// mes返回的产品型号
|
/// </summary>
|
public string productType { get; set; }
|
/// <summary>
|
/// mes返回的物料编码
|
/// </summary>
|
public string materialCode { get; set; }
|
/// <summary>
|
/// mes返回的叠包层数 （例1,2,3：1代表不叠包，2代表叠2层，3代表叠3层）
|
/// </summary>
|
public string overlappingLayers { get; set; }
|
}
|
public class MESData
|
{
|
/// <summary>
|
/// mes返回的包装机号（T1，T2，......，T9）
|
/// </summary>
|
public string machineNo { get; set; }
|
/// <summary>
|
/// mes返回的成品批次号
|
/// </summary>
|
public string lotNo { get; set; }
|
/// <summary>
|
/// mes返回的袋号
|
/// </summary>
|
public string bagNo { get; set; }
|
/// <summary>
|
/// mes返回的产品型号
|
/// </summary>
|
public string productType { get; set; }
|
/// <summary>
|
/// mes返回的物料编码
|
/// </summary>
|
public string materialCode { get; set; }
|
/// <summary>
|
/// mes返回的叠包层数 （例1,2,3：1代表不叠包，2代表叠2层，3代表叠3层）
|
/// </summary>
|
public string overlappingLayers { get; set; }
|
}
|
#endregion
|
|
#region Json数据写入写出中间表测试
|
public static int[] machinedown = new int[16];
|
internal static JsonData Json(JsonData model)
|
{
|
JsonData result = new JsonData();
|
|
|
|
for (int i = 0; i <= 15; i++)
|
{
|
machinedown[i] = i;
|
}
|
var json = JsonConvert.SerializeObject(machinedown);
|
|
//Console.WriteLine("json数据" + json);
|
var jsonMachine = MongoDBSingleton.Instance.FindOne<JsonDataMod>(Query.EQ("order", model.order), "JsonDataMod");
|
var arr = JsonConvert.DeserializeObject(jsonMachine.jsonOne);
|
//Console.WriteLine("var数据" + arr);
|
if (jsonMachine != null)
|
{
|
result.jsonOne = jsonMachine.jsonOne;
|
result.jsonTwo = jsonMachine.jsonTwo;
|
result.jsonThree = jsonMachine.jsonThree;
|
}
|
else
|
{
|
MongoDBSingleton.Instance.Insert<JsonDataMod>(new JsonDataMod { order = model.order, jsonOne = json });
|
}
|
var arr1 = JsonConvert.DeserializeObject<List<int>>(jsonMachine.jsonOne);
|
//Console.WriteLine("数组数据：" + arr1);
|
for (int i = 0; i <= 15; i++)
|
{
|
//Console.WriteLine($"循环打印数组单个数据{arr1[i]}");
|
}
|
|
return result;
|
}
|
public class JsonData
|
{
|
public int order { get; set; }
|
public string jsonOne { get; set; }
|
public JsonConverter jsonTwo { get; set; }
|
public JsonData jsonThree { get; set; }
|
}
|
public class JsonDataMod
|
{
|
public ObjectId _id { get; set; }
|
public int order { get; set; }
|
public string jsonOne { get; set; }
|
public JsonConverter jsonTwo { get; set; }
|
public JsonData jsonThree { get; set; }
|
}
|
#endregion
|
|
public class AgvStateModel
|
{
|
/// <summary>
|
/// X坐标
|
/// </summary>
|
public int XCoordinates { get; set; }
|
/// <summary>
|
/// Y坐标
|
/// </summary>
|
public string YCoordinates { get; set; }
|
/// <summary>
|
/// 方向
|
/// </summary>
|
public int direction { get; set; }
|
}
|
|
public class bzxxModel
|
{
|
public string mesCode { get; set; }
|
}
|
|
|
#region 教称流程，人工PDA返回复称平台，包装机复称信息
|
|
internal static SimpleResult SecondResult(secondResultCache model)
|
{
|
SimpleResult result = new SimpleResult();
|
var weigh = MongoDBSingleton.Instance.FindOne<secondResult>(Query.EQ("Bit", model.Bit), "secondResult");
|
if (weigh != null)
|
{
|
MongoDBSingleton.Instance.Update<secondResult>(Query.EQ("Bit", model.Bit), Update.Set("Bit", model.Bit).Set("Status", model.Status), UpdateFlags.None);
|
result.success = true;
|
CMMLog.Info($"返回状态接口调用成功，当前点位：{model.Bit},点位状态：{model.Status}");
|
//Console.WriteLine($"返回状态接口调用成功，当前点位：{model.Bit},点位状态：{model.Status}");
|
}
|
else
|
{
|
MongoDBSingleton.Instance.Insert<secondResult>(new secondResult { Bit = model.Bit, Status = model.Status });
|
result.success = true;
|
CMMLog.Info($"返回状态接口调用成功，当前点位：{model.Bit},点位状态：{model.Status}");
|
//Console.WriteLine($"返回状态接口调用成功，当前点位：{model.Bit},点位状态：{model.Status}");
|
}
|
if(model.Bit == GetSecondWeighBit())
|
{
|
int i = model.Status == "OK" ? 1 : 2;
|
MongoDBSingleton.Instance.Update<SecondWeighState>(Query.EQ("location", GetSecondWeighBit()), Update.Set("secondNg", i));
|
}
|
return result;
|
}
|
|
internal static SimpleResult AgvState(AgvStateModel model)
|
{
|
SimpleResult result = new SimpleResult();
|
|
return result;
|
}
|
|
/// <summary>
|
/// AGV状态处理
|
/// </summary>
|
/// <param name="a"></param>
|
internal static void AGVDeviceReceiveSet(AgvDeviceStatus a)
|
{
|
if (!string.IsNullOrEmpty(a.forkliftNo))
|
{
|
var agvStateInfo = MongoDBSingleton.Instance.FindOne<AGV_STATE>(Query.EQ("forkliftNo", a.forkliftNo), "AGV_STATE");
|
if (agvStateInfo != null)
|
{
|
if (string.IsNullOrEmpty(a.xPos)) a.xPos = "0";
|
if (string.IsNullOrEmpty(a.yPos)) a.yPos = "0";
|
if(agvStateInfo.xPos != a.xPos || agvStateInfo.yPos != a.yPos || agvStateInfo.errCode != a.errCode || agvStateInfo.errCode2 != a.errCode2 || agvStateInfo.faildCode != a.faildCode || agvStateInfo.Degree != a.Degree)
|
{
|
var query1 = Query.EQ("forkliftNo", a.forkliftNo);
|
UpdateBuilder updateBuider = Update.Set("forkliftNo", a.forkliftNo).
|
Set("errCode", a.errCode).Set("errCode2", a.errCode2).
|
Set("faildCode", a.faildCode).Set("xPos", a.xPos).
|
Set("yPos", a.yPos).Set("battery", a.battery).Set("goods_visible", a.goods_visible).
|
Set("Degree", a.Degree);
|
MongoDBSingleton.Instance.Update<AGV_STATE>(query1, updateBuider, UpdateFlags.None);
|
|
writeAGVInfo(a.forkliftNo);
|
}
|
}
|
else
|
{
|
MongoDBSingleton.Instance.Insert<AGV_STATE>(new AGV_STATE { forkliftNo = a.forkliftNo, errCode = a.errCode, errCode2 = a.errCode2, faildCode = a.faildCode, xPos = a.xPos, yPos = a.yPos, battery = a.battery, goods_visible = a.goods_visible, Degree = a.Degree });
|
writeAGVInfo(a.forkliftNo);
|
}
|
}
|
}
|
|
internal static ErrInfoResult getErrInfo(string factory)
|
{
|
ErrInfoResult result = new ErrInfoResult() { sucess = false };
|
|
if(factory == "sanyuan")
|
{
|
var errList = MongoDBSingleton.Instance.FindAll<errInfoTable>("ErrInfoResult");
|
if (errList.Count > 0)
|
{
|
result.sucess = true;
|
errList.ForEach(r =>
|
{
|
result.errInfo.Add(new errInfo { taskName = r.taskName, errMsg = r.errMsg, time = r.dateTime });
|
});
|
}
|
}
|
else
|
{
|
|
}
|
|
return result;
|
}
|
|
internal static ZZTPWNumResult ZZTPWNum(string factory)
|
{
|
ZZTPWNumResult result = new ZZTPWNumResult() { sucess = false };
|
|
if(factory == "sanyuan")
|
{
|
var bzEmpInfo = MongoDBSingleton.Instance.FindAll<BZEmptyPoint>("BZEmptyPoint");
|
if (bzEmpInfo.Count > 0)
|
{
|
result.sucess = true;
|
bzEmpInfo.ForEach(r =>
|
{
|
result.zztpwInfo.Add(new zztpwInfo { S_LOC_CODE = r.Bit, N_QTY = r.Quantity });
|
});
|
}
|
}
|
else
|
{
|
|
}
|
return result;
|
}
|
|
internal static BZXXResult Bzxx(bzxxModel models)
|
{
|
BZXXResult result = new BZXXResult() {sucess = false };
|
if(models != null && !string.IsNullOrEmpty(models.mesCode))
|
{
|
//通过mesCode获取mes的物料信息
|
|
}
|
else
|
{
|
result.errMsg = "参数输入错误";
|
}
|
return result;
|
}
|
|
public class AGV_STATE
|
{
|
public ObjectId _id { get; set; }
|
public string forkliftNo { get; set; }
|
/// <summary>
|
/// 停止状态码
|
/// </summary>
|
public string errCode { get; set; } = "";
|
/// <summary>
|
/// 停止状态码2
|
/// </summary>
|
public string errCode2 { get; set; } = "";
|
/// <summary>
|
/// 失败状态码
|
/// </summary>
|
public string faildCode { get; set; } = "";
|
/// <summary>
|
/// 车辆X坐标（CM）
|
/// </summary>
|
public string xPos { get; set; } = "0";
|
/// <summary>
|
/// 车辆Y坐标（Y）
|
/// </summary>
|
public string yPos { get; set; } = "0";
|
/// <summary>
|
/// 电池电量
|
/// </summary>
|
public string battery { get; set; } = "";
|
|
public string detail { get; set; }
|
/// <summary>
|
/// 是否有货状态码
|
/// </summary>
|
public string goods_visible { get; set; } = "";
|
/// <summary>
|
/// 方向
|
/// </summary>
|
public string Degree { get; set; } = "";
|
/// <summary>
|
/// 小车状态
|
/// </summary>
|
public int agvState { get; set; }
|
/// <summary>
|
/// 是否有货
|
/// </summary>
|
public int haveItem { get; set; }
|
}
|
|
public class secondResultCache
|
{
|
/// <summary>
|
/// 教称点位
|
/// </summary>
|
public string Bit { get; set; }
|
/// <summary>
|
/// 教称点位状态
|
/// </summary>
|
public string Status { get; set; }
|
}
|
public class secondResult
|
{
|
public ObjectId _id { get; set; }
|
/// <summary>
|
/// 教称点位
|
/// </summary>
|
public string Bit { get; set; }
|
/// <summary>
|
/// 教称点位状态
|
/// </summary>
|
public string Status { get; set; }
|
}
|
|
public class ReturnResult
|
{
|
public int ResultCode { get; set; }
|
public string ResultMsg { get; set; }
|
}
|
|
public class ErrInfoResult
|
{
|
public bool sucess { get; set; }
|
public List<errInfo> errInfo { get; set; }
|
}
|
|
public class errInfo
|
{
|
public string taskName { get; set; }
|
public string errMsg { get; set; }
|
public DateTime time { get; set; }
|
}
|
|
public class ZZTPWNumResult
|
{
|
public bool sucess { get; set; }
|
public List<zztpwInfo> zztpwInfo { get; set; }
|
}
|
|
public class zztpwInfo
|
{
|
public string S_LOC_CODE { get; set; }
|
public int N_QTY { get; set; }
|
}
|
|
public class BZXXResult
|
{
|
public bool sucess { get; set;}
|
public string errMsg { get; set; }
|
}
|
|
/// <summary>
|
/// hosttoagv上报车辆状态（参数在hosttoagv服务配置，可修改）
|
/// </summary>
|
public class AgvDeviceStatus
|
{
|
public string infoType { get; set; }
|
public string inMapRoute { get; set; }
|
//public string detail { get; set; }
|
public string CumInfo { get; set; }
|
public string forkliftNo { get; set; }
|
/// <summary>
|
/// 停止状态码
|
/// </summary>
|
public string errCode { get; set; } = "";
|
/// <summary>
|
/// 停止状态码2
|
/// </summary>
|
public string errCode2 { get; set; } = "";
|
/// <summary>
|
/// 失败状态码
|
/// </summary>
|
public string faildCode { get; set; } = "";
|
/// <summary>
|
/// 车辆X坐标（CM）
|
/// </summary>
|
public string xPos { get; set; } = "";
|
/// <summary>
|
/// 车辆Y坐标（Y）
|
/// </summary>
|
public string yPos { get; set; } = "";
|
/// <summary>
|
/// 电池电量
|
/// </summary>
|
public string battery { get; set; } = "";
|
/// <summary>
|
/// 是否有货状态码
|
/// </summary>
|
public string goods_visible { get; set; } = "";
|
/// <summary>
|
/// 方向
|
/// </summary>
|
public string Degree { get; set; } = "";
|
}
|
|
#endregion
|
|
|
}
|
}
|
