using Hanhe.iWCS.Business;
|
using Hanhe.iWCS.Common;
|
using Hanhe.iWCS.MData;
|
using Hanhe.iWCS.Model;
|
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.TaizhouGEMTwoProtocol.PLCControl;
|
using static Hanhe.iWCS.TaizhouGEMTwoProtocol.ProcessHelper;
|
|
namespace Hanhe.iWCS.TaizhouGEMTwoProtocol
|
{
|
/// <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, "成品出库", 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 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
|
|
#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;
|
}
|
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; }
|
}
|
|
#endregion
|
|
|
/// <summary>
|
/// AGV状态处理
|
/// </summary>
|
/// <param name="a"></param>
|
internal static void AGVDeviceReceiveSet(AgvDeviceStatus a)
|
{
|
if (!string.IsNullOrEmpty(a.forkliftNo))
|
{
|
a.xPos = string.IsNullOrEmpty(a.xPos) ? "0" : a.xPos;
|
a.yPos = string.IsNullOrEmpty(a.yPos) ? "0" : a.yPos;
|
a.Degree = string.IsNullOrEmpty(a.Degree) ? "0" : a.Degree;
|
|
var agvStateInfo = MongoDBSingleton.Instance.FindOne<AGV_STATE>(Query.EQ("forkliftNo", a.forkliftNo), "AGV_STATE");
|
if (agvStateInfo != null)
|
{
|
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("detail", a.detail).Set("goods_visible", a.goods_visible).
|
Set("Degree", a.Degree);
|
MongoDBSingleton.Instance.Update<AGV_STATE>(query1, updateBuider, "AGV_STATE", UpdateFlags.None);
|
}
|
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,
|
detail = a.detail,
|
goods_visible = a.goods_visible,
|
Degree = a.Degree
|
}, "AGV_STATE");
|
}
|
}
|
}
|
|
/// <summary>
|
/// 库位相机处理
|
/// </summary>
|
/// <param name="a"></param>
|
internal static SimpleResult CameraInfo(cameraModel a)
|
{
|
SimpleResult result = new SimpleResult();
|
|
var cameraInfo = MongoDBSingleton.Instance.FindOne<CameraTable>(Query.EQ("site", a.PointCode), "CameraTable");
|
if (cameraInfo != null)
|
{
|
if (cameraInfo.site == a.PointCode && cameraInfo.state == a.PointStatus)
|
{
|
cameraInfo.time += 1;
|
MongoDBSingleton.Instance.Update<CameraTable>(Query.EQ("site", a.PointCode), Update.Set("time", cameraInfo.time), UpdateFlags.None);
|
}
|
else
|
{
|
MongoDBSingleton.Instance.Remove<CameraTable>(Query.EQ("site", a.PointCode), RemoveFlags.Single);
|
}
|
}
|
else
|
{
|
if (a.PointStatus == 0)
|
{
|
MongoDBSingleton.Instance.Insert<CameraTable>(new CameraTable
|
{
|
site = a.PointCode,
|
state = a.PointStatus,
|
time = 1
|
}, "CameraTable");
|
}
|
}
|
|
try
|
{
|
var cameraInfoList = MongoDBSingleton.Instance.FindAll<CameraTable>("CameraTable");
|
if (cameraInfoList.Count > 0)
|
{
|
cameraInfoList.ForEach(it => {
|
if (it.time > 10)
|
{
|
CMMLog.Info("CameraTable表大于10次的数据：" + JsonConvert.SerializeObject(cameraInfoList));
|
|
//调用wms解绑接口
|
result.success = WMSHelper.WMSEmptyUnbind(it.site);
|
|
if (result.success)
|
{
|
MongoDBSingleton.Instance.Remove<CameraTable>(Query.EQ("site", it.site), RemoveFlags.Single);
|
result.errCode = 0;
|
}
|
CMMLog.Info($"发货货架解绑成功，货位号：{it.site}");
|
|
}
|
});
|
}
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Error(ex.Message, ex);
|
}
|
|
return result;
|
}
|
|
public class CameraTable
|
{
|
public ObjectId _id { get; set; }
|
/// <summary>
|
/// 点位
|
/// </summary>
|
public string site { get; set; }
|
/// <summary>
|
/// 状态
|
/// </summary>
|
public int state { get; set; }
|
/// <summary>
|
/// 接收到了数据次数
|
/// </summary>
|
public int time { get; set; }
|
}
|
|
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; } = "0";
|
}
|
|
/// <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; } = "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; } = "0";
|
}
|
|
public class ReturnResult
|
{
|
public int ResultCode { get; set; }
|
public string ResultMsg { get; set; }
|
}
|
|
public class cameraModel
|
{
|
/// <summary>
|
/// 点位
|
/// </summary>
|
public string PointCode { get; set; }
|
/// <summary>
|
/// 状态 0 - 无货 1 - 有货 3 - 异常
|
/// </summary>
|
public int PointStatus { get; set; }
|
}
|
}
|
}
|
