using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using yunneiWCS.EnumDefine;
|
using System.ServiceModel;
|
using yunneiWCS.ORM;
|
using yunneiWCS.DataAccess;
|
using yunneiWCS.ExtendFunction;
|
|
namespace yunneiWCS.SystemInteraction.tianyong
|
{
|
public class TianYongSystem
|
{
|
/// <summary>机器人上料 安全交互信号
|
///
|
/// </summary>
|
/// <param name="station">站点号</param>
|
/// <param name="OutOrIn">1=进2=出</param>
|
/// <param name="taskId">任务id</param>
|
/// <returns></returns>
|
public static bool safetySignal(string station, int OutOrIn, string agvTaskNo, string remark)
|
{
|
bool res = false;
|
|
//放开代码 【EditBy shaocx,2023-10-13】
|
/*
|
//注意：暂时写为true，以后要修改为正式的 【EditBy shaocx,2022-03-18】!!!!
|
res = true;
|
remark = "【注意：本次是模拟天永返回TRUE】" + remark;
|
return res;
|
//*/
|
|
try
|
{
|
var materialCode = "";
|
using (dbmodel mod = new dbmodel())
|
{
|
task sf = mod.task.FirstOrDefault(x => x.AgvTaskNo == agvTaskNo);
|
int quantity = 0;
|
if (sf != null)
|
{
|
if (sf.taskType == (int)taskType.缸体上线 || sf.taskType == (int)taskType.缸体下线直接去上线点)
|
{
|
VproductStock stock = mod.VproductStock.FirstOrDefault(x => x.positionName == sf.toPlace);
|
if (stock != null)
|
{
|
quantity = (int)stock.quantity;
|
}
|
}
|
materialCode = sf.materialCode;
|
}
|
else
|
{
|
WZ.Useful.Commons.LogTextHelper.WriteLine("TianYongSystem", "safetySignal", "根据AgvTaskNo:" + agvTaskNo + "获取任务为NULL");
|
return false;
|
}
|
int taskId = (int)sf.taskId;
|
using (yunneiWCS.tianyong.AutoServiceSoapClient ty = new yunneiWCS.tianyong.AutoServiceSoapClient())
|
{
|
res = ty.safetySignal(station, OutOrIn, taskId, quantity, materialCode);
|
}
|
if (res)
|
{
|
remark = "推送成功," + remark;
|
sf.isSendTotianyong = 1;
|
sf.isSendTotianyongName = "是";
|
sf.SendTotianyongTime = DateTime.Now;
|
sf.SendTotianyongRemark = remark;
|
|
}
|
else
|
{
|
remark = "推送失败," + remark;
|
sf.isSendTotianyong = 0;
|
sf.isSendTotianyongName = "否";
|
sf.SendTotianyongTime = DateTime.Now;
|
sf.SendTotianyongRemark = remark;
|
}
|
|
TianYongLogHandler.AddTianYongLog(mod, sf, remark, res, "safetySignal", station, OutOrIn.ToString(), taskId.ToString(), quantity.ToString(), materialCode);
|
|
var res_SaveChanges = mod.SaveChanges();
|
if (res_SaveChanges > 0)
|
{
|
|
}
|
else
|
{
|
throw new Exception("更新数据失败");
|
}
|
|
Form1.agvInfo = "agv上下料:返回信息:" + res;
|
string resString = res == true ? "允许" : "不允许";
|
WZ.Useful.Commons.LogTextHelper.WriteLine("IyunneiWcf", "safetySignal", "收到安全信号站点号:" +
|
station + " 1=进2=出:" + OutOrIn + " 任务ID:" + taskId + " 数量:" + quantity + " 物料编码:" + materialCode + " 天永返回状态:" + resString);
|
|
}
|
|
}
|
catch (Exception ex)
|
{
|
WZ.Useful.Commons.LogTextHelper.WriteLine("TianYongSystem", "safetySignal", ex.ToString());
|
|
}
|
return res;
|
}
|
|
/// <summary>给天永发信号,缸体上线去旁路工位、缸盖进入、缸盖出去、人工缸盖进入、人工缸盖出去，人工缸体进入，人工缸体出去 的 交互信号
|
///
|
/// </summary>
|
/// <param name="station">站点号</param>
|
/// <param name="taskId">任务id</param>
|
/// <returns></returns>
|
public static bool UpdateStoreByTaskID(dbmodel mod, task task, string station, int taskId, string _SendTotianyongRemark)
|
{
|
bool res = false;
|
try
|
{
|
//using (dbmodel mod = new dbmodel())
|
//{
|
task sf = mod.task.FirstOrDefault(x => x.taskId == taskId);
|
if (sf == null)
|
{
|
throw new Exception("根据任务ID" + taskId + "没有找到任务");
|
}
|
int quantity = 0;
|
|
taskType _taskType = (taskType)Enum.Parse(typeof(taskType), sf.taskType.ToString());
|
switch (_taskType)
|
{
|
case taskType.缸盖上线:
|
case taskType.缸盖下线直接去上线点:
|
case taskType.缸体上线:
|
case taskType.缸体下线直接去上线点:
|
case taskType.缸体上线去旁路工位: //增加任务类型 【EditBy shaocx,2022-04-23】
|
quantity = (int)task.quantity;//直接使用数量，而不是去查库存了 【EditBy shaocx,2022-05-04】
|
// VproductStock stock = null;
|
//stock = mod.VproductStock.FirstOrDefault(x => x.positionName == sf.toPlace);
|
//if (stock != null)
|
//{
|
// quantity = (int)stock.quantity;
|
//}
|
//else
|
//{
|
// throw new Exception("根据站点" + sf.toPlace + "获取库存为NULL");
|
//}
|
break;
|
case taskType.空托回库:
|
case taskType.余料回库:
|
quantity = 0;
|
break;
|
}
|
|
var simulatorNote = "";
|
if (!MyExtendHelper.IsAllowSimulatorHandle(task))
|
{
|
simulatorNote = "[正式环境]";
|
using (yunneiWCS.tianyong.AutoServiceSoapClient ty = new yunneiWCS.tianyong.AutoServiceSoapClient())
|
{
|
res = ty.UpdateStoreByTaskID(taskId, quantity);
|
}
|
}
|
else
|
{
|
simulatorNote = "[模拟环境]";
|
res = true;//模拟写死
|
}
|
if (res)
|
{
|
sf.isSendTotianyong = 1;
|
sf.isSendTotianyongName = "是";
|
sf.SendTotianyongTime = DateTime.Now;
|
sf.SendTotianyongRemark = simulatorNote + "推送成功," + _SendTotianyongRemark;
|
// mod.SaveChanges();//不再更新，因为他上层方法已经更新了
|
}
|
else
|
{
|
sf.isSendTotianyong = 0;
|
sf.isSendTotianyongName = "否";
|
sf.SendTotianyongTime = DateTime.Now;
|
sf.SendTotianyongRemark = simulatorNote + "推送失败," + _SendTotianyongRemark;
|
// mod.SaveChanges();//不再更新，因为他上层方法已经更新了
|
}
|
TianYongLogHandler.AddTianYongLog(mod, sf, sf.SendTotianyongRemark, res, "UpdateStoreByTaskID", "", "", taskId.ToString(), quantity.ToString(), "");
|
|
|
|
string resString = res == true ? "允许" : "不允许";
|
WZ.Useful.Commons.LogTextHelper.WriteLine("TianYongSystem", "UpdateStoreByTaskID", "收到安全信号站点号:" +
|
station + " 任务ID:" + taskId + " 天永返回状态:" + resString);
|
|
//}
|
|
}
|
catch (Exception ex)
|
{
|
WZ.Useful.Commons.LogTextHelper.WriteLine("TianYongSystem", "UpdateStoreByTaskID", ex.ToString());
|
throw ex;
|
}
|
return res;
|
}
|
}
|
}
|
