You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
869 lines
40 KiB
869 lines
40 KiB
using Nancy;
|
|
using Nancy.Bootstrapper;
|
|
using Nancy.Hosting.Self;
|
|
using Newtonsoft.Json;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Reflection;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using Model;
|
|
using WcfControlMonitorLib;
|
|
using System.Security.Cryptography;
|
|
using Nancy.Helpers;
|
|
using DBFactory;
|
|
using System.Data;
|
|
using System.Diagnostics.Eventing.Reader;
|
|
using System.Data.SqlClient;
|
|
using WcfInterfaceServer.Properties;
|
|
using System.Runtime;
|
|
using System.Collections;
|
|
using System.Configuration;
|
|
using System.Xml;
|
|
using static WcfControlMonitorLib.CCallService;
|
|
|
|
namespace WindowsFormsApp1
|
|
{
|
|
public class APIChannel : NancyModule
|
|
{
|
|
static DBOperator dbo = CStaticClass.dbo;
|
|
static DBOperator dboMan = CStaticClass.dboM;
|
|
static String ERROR = String.Empty;
|
|
private static NancyHost _server;
|
|
static string address = CommonClassLib.AppSettings.GetValue("Serveradderss");
|
|
//private static ServiceReference1.I_Managely5Client I_ManageClient = new ServiceReference1.I_Managely5Client();
|
|
public static void Start()
|
|
{
|
|
//_server = new NancyHost(new Bootstrapper(), new Uri("http://192.168.39.10:8080"));
|
|
_server = new NancyHost(new Bootstrapper(), new Uri(address));
|
|
_server.Start();
|
|
}
|
|
|
|
public APIChannel()
|
|
{
|
|
|
|
Get["/"] = _ => "This is WCS APIServer";
|
|
////查询
|
|
//Post["/api/BindTrayInfo/AgvGetBindTrayInfo", true] = async (x, ct) =>
|
|
//{
|
|
// var body = this.Request.Body;
|
|
// int length = (int)body.Length; // this is a dynamic variable
|
|
// byte[] data = new byte[length];
|
|
// body.Read(data, 0, length);
|
|
|
|
// string jsonStr = System.Text.Encoding.Default.GetString(data);
|
|
// return "a";//I_ManageClient.HandleControlAGVQueryApplyYB(jsonStr);
|
|
//};
|
|
|
|
|
|
#region WMS调用, 在此处理，出库以及移库任务 多条任务 任务下发
|
|
Post["/api/wcs/thirdParty/receiveWmsTask", true] = async (x, ct) =>
|
|
{
|
|
|
|
dbo.TransBegin(IsolationLevel.ReadCommitted);
|
|
try
|
|
{
|
|
var body = this.Request.Body;
|
|
int length = (int)body.Length;
|
|
byte[] data = new byte[length];
|
|
body.Read(data, 0, length);
|
|
string jsonStr = System.Text.Encoding.Default.GetString(data);
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "收到报文", jsonStr.ToString(), "");
|
|
|
|
CCallService.WMS_WCS_PARAM_OUT_MOVE wms_wcs = Model.JsonHelper.Deserialize<CCallService.WMS_WCS_PARAM_OUT_MOVE>(jsonStr);
|
|
// CCallService.WCS_WMS_PARAM_OUT_MOVE wcs_wms = new CCallService.WCS_WMS_PARAM_OUT_MOVE(); //返回的报文
|
|
CCallService.OUT_MOVE_RES answer_outdata = new CCallService.OUT_MOVE_RES();//返回数据
|
|
string err = string.Empty;
|
|
string returnJson = string.Empty;
|
|
DataView dv = new DataView();
|
|
CCallService.OUT_MOVE_RES outReturn = new CCallService.OUT_MOVE_RES();
|
|
if (wms_wcs != null)
|
|
{
|
|
List<CCallService.OUT_MOVE_DATA> outdata = wms_wcs.tasks; //任务信息
|
|
int isOk = 0;
|
|
// CCallService.OUT_MOVE_RES outReturn = new CCallService.OUT_MOVE_RES();
|
|
foreach (var task in outdata)
|
|
{
|
|
|
|
IO_CONTROL outtask = new IO_CONTROL(task, wms_wcs.msgTime, task.taskType, wms_wcs.priority.ToString());
|
|
|
|
if (outtask.Insert_IOCONTROL() == false)
|
|
{
|
|
isOk++;
|
|
outReturn.data += "ID'" + task.taskId.ToString() + "'任务下发失败:";
|
|
}
|
|
if (isOk == 0)
|
|
{
|
|
outReturn.code = 0;
|
|
outReturn.msg = "";
|
|
}
|
|
else
|
|
{
|
|
outReturn.code = 1;
|
|
outReturn.msg = "任务接收失败";
|
|
}
|
|
}
|
|
|
|
}
|
|
returnJson = Model.JsonHelper.Serializer(outReturn);
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "返回报文", returnJson, "");
|
|
dbo.TransCommit();
|
|
return returnJson;
|
|
}
|
|
catch (Exception ex) {
|
|
string errorjson = Model.JsonHelper.Serializer(new
|
|
{
|
|
code = 1,
|
|
msg = "WCS解析json异常",
|
|
data = ex.Message.ToString()
|
|
});
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "返回报文", ex.Message.ToString(), "");
|
|
dbo.TransRollback();
|
|
return errorjson;
|
|
}
|
|
};
|
|
#endregion
|
|
|
|
#region WMS调用, 在此处理，取消任务 单条形式
|
|
Post["/api/wcs/thirdParty/cancelWmsTask", true] = async (x, ct) =>
|
|
{
|
|
try
|
|
{
|
|
var body = this.Request.Body;
|
|
int length = (int)body.Length;
|
|
byte[] data = new byte[length];
|
|
body.Read(data, 0, length);
|
|
string jsonStr = System.Text.Encoding.Default.GetString(data);
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "收到报文", jsonStr.ToString(), "");
|
|
CCallService.WMS_WCS_PARAM_Priority wms_wcs_cancel = Model.JsonHelper.Deserialize<CCallService.WMS_WCS_PARAM_Priority>(jsonStr);
|
|
CCallService.WCS_WMS_PARAM_Priority wcs_wms_cancel = new CCallService.WCS_WMS_PARAM_Priority(); //返回的报文
|
|
string err = string.Empty;
|
|
string returnJson = string.Empty;
|
|
DataView dv = new DataView();
|
|
if (wms_wcs_cancel != null)
|
|
{
|
|
//CCallService.CANCEL_DATA canceldata = new CCallService.CANCEL_DATA();
|
|
//canceldata = wms_wcs_cancel.data;
|
|
// CCallService.CANCEL_RES_DATA cancelReturn = new CCallService.CANCEL_RES_DATA();
|
|
string sql = "select * from t_manage_task where FID = '" + wms_wcs_cancel.taskId + "'";
|
|
dv = dbo.ExceSQL(sql).Tables[0].DefaultView;
|
|
if (dv.Count == 1)
|
|
{
|
|
|
|
int stepOk = Convert.ToInt32(dv[0]["FIntoStepOK"]);//拆分下发
|
|
if (stepOk == 0)//未拆分
|
|
{
|
|
try
|
|
{
|
|
sql = "delete from t_manage_task where FMANAGEID = '" + wms_wcs_cancel.taskId + "'";
|
|
int count = dbo.ExecuteSql(sql);
|
|
if (count > 0)
|
|
{
|
|
wcs_wms_cancel.code = 0;
|
|
wcs_wms_cancel.msg = "";
|
|
wcs_wms_cancel.data = "";
|
|
}
|
|
else
|
|
{
|
|
wcs_wms_cancel.code = 1;
|
|
wcs_wms_cancel.msg = "取消任务失败，WCS无法删除任务!";
|
|
wcs_wms_cancel.data = "数据库删除数据失败";
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
wcs_wms_cancel.code = 1;
|
|
wcs_wms_cancel.msg = "取消任务失败，WCS无法删除任务!";
|
|
wcs_wms_cancel.data = "";
|
|
}
|
|
}
|
|
else
|
|
{
|
|
wcs_wms_cancel.code = 1;
|
|
wcs_wms_cancel.msg = "取消任务失败，任务已执行！";
|
|
wcs_wms_cancel.data = "";
|
|
}
|
|
|
|
}
|
|
else if (dv.Count == 0)
|
|
{
|
|
wcs_wms_cancel.code = 0;
|
|
wcs_wms_cancel.msg = "取消任务成功，WCS中无此任务！" + wms_wcs_cancel.taskId;
|
|
wcs_wms_cancel.data = "";
|
|
|
|
}
|
|
else
|
|
{
|
|
wcs_wms_cancel.code = 1;
|
|
wcs_wms_cancel.msg = "取消任务失败，WCS中有多条相同任务！";
|
|
wcs_wms_cancel.data = "";
|
|
}
|
|
}
|
|
returnJson = Model.JsonHelper.Serializer(wcs_wms_cancel);
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "返回报文", returnJson, "");
|
|
return returnJson;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
string errorjson = Model.JsonHelper.Serializer(new
|
|
{
|
|
code = 1,
|
|
msg = "WCS解析json异常",
|
|
data = ex.Message.ToString()
|
|
});
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "返回报文", ex.Message.ToString(), "");
|
|
return errorjson;
|
|
}
|
|
};
|
|
#endregion
|
|
#region WMS调用, 在此处理，任务优先级 单条形式
|
|
Post["/api/wcs/thirdParty/changePriorityWmsTask", true] = async (x, ct) =>
|
|
{
|
|
try
|
|
{
|
|
var body = this.Request.Body;
|
|
int length = (int)body.Length;
|
|
byte[] data = new byte[length];
|
|
body.Read(data, 0, length);
|
|
string jsonStr = System.Text.Encoding.Default.GetString(data);
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "收到报文", jsonStr.ToString(), "");
|
|
CCallService.WMS_WCS_PARAM_Priority wms_wcs_cancel = Model.JsonHelper.Deserialize<CCallService.WMS_WCS_PARAM_Priority>(jsonStr);
|
|
CCallService.WCS_WMS_PARAM_CANCEL wcs_wms_cancel = new CCallService.WCS_WMS_PARAM_CANCEL(); //返回的报文
|
|
string returnJson = string.Empty;
|
|
DataView dv = new DataView();
|
|
if (wms_wcs_cancel != null)
|
|
{
|
|
//CCallService.CANCEL_DATA canceldata = new CCallService.CANCEL_DATA();
|
|
//canceldata = wms_wcs_cancel.data;
|
|
// CCallService.CANCEL_RES_DATA cancelReturn = new CCallService.CANCEL_RES_DATA();
|
|
string sql = "select * from t_manage_task where FID = '" + wms_wcs_cancel.taskId + "'";
|
|
dv = dbo.ExceSQL(sql).Tables[0].DefaultView;
|
|
if (dv.Count == 1)
|
|
{
|
|
|
|
string sql1 = "updata t_manage_task set F_MonitorTaskLevel="+ wms_wcs_cancel.priority+ " where FID = '" + wms_wcs_cancel.taskId + "'";
|
|
int count = dbo.ExecuteSql(sql1);
|
|
if (count > 0)
|
|
{
|
|
wcs_wms_cancel.code = 0;
|
|
wcs_wms_cancel.msg = "";
|
|
wcs_wms_cancel.data = null;
|
|
}
|
|
else
|
|
{
|
|
wcs_wms_cancel.code = 1;
|
|
wcs_wms_cancel.msg = "调整失败，WCS数据库无法调整任务!";
|
|
wcs_wms_cancel.data = null;
|
|
}
|
|
}
|
|
else if (dv.Count > 1)
|
|
{
|
|
wcs_wms_cancel.code = 1;
|
|
wcs_wms_cancel.msg = "任务优先级调整失败，存在多条相同任务号的任务!";
|
|
wcs_wms_cancel.data = "数据库删除数据失败";
|
|
}
|
|
else {
|
|
wcs_wms_cancel.code = 1;
|
|
wcs_wms_cancel.msg = "任务优先级调整失败，不存在任务!";
|
|
wcs_wms_cancel.data = "数据库删除数据失败";
|
|
}
|
|
}
|
|
return returnJson;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
string errorjson = Model.JsonHelper.Serializer(new
|
|
{
|
|
code = 1,
|
|
msg = "WCS解析json异常",
|
|
data = ex.Message.ToString()
|
|
});
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "返回报文", ex.Message.ToString(), "");
|
|
return errorjson;
|
|
}
|
|
};
|
|
#endregion
|
|
|
|
#region WMS调用, 在此处理，入库任务 单条形式
|
|
Post["/api/wcs/thirdParty/deliverWmsInTask", true] = async (x, ct) =>
|
|
{
|
|
try
|
|
{
|
|
var body = this.Request.Body;
|
|
int length = (int)body.Length;
|
|
byte[] data = new byte[length];
|
|
body.Read(data, 0, length);
|
|
string jsonStr = System.Text.Encoding.Default.GetString(data);
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "收到报文", jsonStr.ToString(), "");
|
|
|
|
CCallService.WMS_WCS_PARAM_IN wms_wcs = Model.JsonHelper.Deserialize<CCallService.WMS_WCS_PARAM_IN>(jsonStr);
|
|
CCallService.WCS_WMS_PARAM_IN wcs_wms = new CCallService.WCS_WMS_PARAM_IN(); //返回的报文
|
|
|
|
string err = string.Empty;
|
|
string returnJson = string.Empty;
|
|
DataView dv = new DataView();
|
|
if (wms_wcs != null)
|
|
{
|
|
|
|
IO_CONTROL ruku = new IO_CONTROL(wms_wcs, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), wms_wcs.priority);
|
|
|
|
if (ruku.Insert_IOCONTROL() == true)
|
|
{
|
|
wcs_wms.code = 0;
|
|
wcs_wms.msg = "";
|
|
wcs_wms.data = null;
|
|
}
|
|
else
|
|
{
|
|
wcs_wms.code = 1;
|
|
wcs_wms.msg = "入库任务接收失败！" + ruku.error_code;
|
|
wcs_wms.data = null;
|
|
}
|
|
}
|
|
returnJson = Model.JsonHelper.Serializer(wcs_wms);
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "返回报文", returnJson, "");
|
|
return returnJson;
|
|
}
|
|
catch (Exception ex) {
|
|
string errorjson = Model.JsonHelper.Serializer(new
|
|
{
|
|
code = 1,
|
|
msg = "WCS解析json异常",
|
|
data = ex.Message.ToString()
|
|
});
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "返回报文", ex.Message.ToString(), "");
|
|
return errorjson;
|
|
}
|
|
};
|
|
#endregion
|
|
|
|
#region WMS调用, 在此处理，WCS 允许 AGV 可取可放
|
|
Post["/api/wcs/thirdParty/getStationStatus", true] = async (x, ct) =>
|
|
{
|
|
try
|
|
{
|
|
var body = this.Request.Body;
|
|
int length = (int)body.Length;
|
|
byte[] data = new byte[length];
|
|
body.Read(data, 0, length);
|
|
string jsonStr = System.Text.Encoding.Default.GetString(data);
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "收到报文", jsonStr.ToString(), "");
|
|
|
|
CCallService.LCS_WCS_AGVStationStauts wms_wcs = Model.JsonHelper.Deserialize<CCallService.LCS_WCS_AGVStationStauts>(jsonStr);
|
|
CCallService.LCS_WCS_AGVStationStautsBack wcs_wms = new CCallService.LCS_WCS_AGVStationStautsBack(); //返回的报文
|
|
|
|
string err = string.Empty;
|
|
string returnJson = string.Empty;
|
|
DataView dv = new DataView();
|
|
if (wms_wcs != null)
|
|
{
|
|
StringBuilder sql = new StringBuilder();
|
|
sql.Clear();
|
|
sql.Append("select * from T_AGVIOStation where F_DeviceIndex=").Append(wms_wcs.toStation);
|
|
DataView dataBackmsg = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
|
|
if (dataBackmsg.Count > 0) {
|
|
wcs_wms.code = 0;
|
|
wcs_wms.msg = "";
|
|
LCS_WCS_AGVStationStautsBackData msg = new LCS_WCS_AGVStationStautsBackData();
|
|
msg.taskId = wms_wcs.taskId;
|
|
//msg.taskId = dataBackmsg[0]["F_TaskID"].ToString();
|
|
wcs_wms.data = msg;
|
|
}
|
|
else {
|
|
wcs_wms.code = 1;
|
|
wcs_wms.msg = $"WCS未找到站台{wms_wcs.toStation}信息";
|
|
}
|
|
}
|
|
returnJson = Model.JsonHelper.Serializer(wcs_wms);
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "返回报文", returnJson, "");
|
|
return returnJson;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
string errorjson = Model.JsonHelper.Serializer(new
|
|
{
|
|
code = 1,
|
|
msg = "WCS解析json异常",
|
|
data = ex.Message.ToString()
|
|
});
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "返回报文", ex.Message.ToString(), "");
|
|
return errorjson;
|
|
}
|
|
};
|
|
#endregion
|
|
|
|
#region WMS调用, LCS 返回 AGV 取放货状态给 WCS 8接口
|
|
Post["/api/wcs/thirdParty/submitAgvStatus", true] = async (x, ct) =>
|
|
{
|
|
try
|
|
{
|
|
var body = this.Request.Body;
|
|
int length = (int)body.Length;
|
|
byte[] data = new byte[length];
|
|
body.Read(data, 0, length);
|
|
string jsonStr = System.Text.Encoding.Default.GetString(data);
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "收到报文", jsonStr.ToString(), "");
|
|
|
|
CCallService.LCS_WCS_AGVStatus wms_wcs = Model.JsonHelper.Deserialize<CCallService.LCS_WCS_AGVStatus>(jsonStr);
|
|
CCallService.LCS_WCS_AGVStatusBack wcs_wms = new CCallService.LCS_WCS_AGVStatusBack(); //返回的报文
|
|
|
|
string err = string.Empty;
|
|
string returnJson = string.Empty;
|
|
DataView dv = new DataView();
|
|
if (wms_wcs != null)
|
|
{
|
|
StringBuilder sql = new StringBuilder();
|
|
sql.Clear();
|
|
sql.Append("select * from T_AGVIOStation where F_DeviceIndex=").Append(wms_wcs.toStation);
|
|
DataView dataBackmsg = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
|
|
if (dataBackmsg.Count > 0)
|
|
{
|
|
int status = 0;//1AGV运动中，2AGV已离开，或者动作完成
|
|
if (wms_wcs.agvTaskStatus == 23 || wms_wcs.agvTaskStatus == 21 || wms_wcs.agvTaskStatus == 56)
|
|
{
|
|
status = 2;
|
|
}
|
|
else {
|
|
status = 1;
|
|
}
|
|
wcs_wms.code = 0;
|
|
wcs_wms.msg = "";
|
|
sql.Clear();
|
|
sql.Append("update T_AGVIOStation set F_AGVStatus = ").Append(status). Append(" F_TaskID=").Append(wms_wcs.taskId).Append(" where F_DeviceIndex=").Append(wms_wcs.toStation);
|
|
dbo.ExceSQL(sql.ToString());
|
|
LCS_WCS_AGVStatusBackData msg = new LCS_WCS_AGVStatusBackData();
|
|
msg.taskId = wms_wcs.taskId;
|
|
wcs_wms.data = msg;
|
|
|
|
}
|
|
else
|
|
{
|
|
wcs_wms.code = 1;
|
|
wcs_wms.msg = $"WCS未找到站台{wms_wcs.toStation}信息";
|
|
}
|
|
}
|
|
returnJson = Model.JsonHelper.Serializer(wcs_wms);
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "返回报文", returnJson, "");
|
|
return returnJson;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
string errorjson = Model.JsonHelper.Serializer(new
|
|
{
|
|
code = 1,
|
|
msg = "WCS解析json异常",
|
|
data = ex.Message.ToString()
|
|
});
|
|
CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "返回报文", ex.Message.ToString(), "");
|
|
return errorjson;
|
|
}
|
|
};
|
|
#endregion
|
|
#region test
|
|
//Post["/STATUS", true] = async (x, ct) =>
|
|
//{
|
|
// var body = this.Request.Body;
|
|
// int length = (int)body.Length;
|
|
// byte[] data = new byte[length];
|
|
// body.Read(data, 0, length);
|
|
// string jsonStr = System.Text.Encoding.Default.GetString(data);
|
|
// CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "收到报文", jsonStr.ToString(), "");
|
|
|
|
// CCallService.WMS_WCS_111 wms_wcs = Model.JsonHelper.Deserialize<CCallService.WMS_WCS_111>(jsonStr);
|
|
// CCallService.WCS_WMS_111 wcs_wms = new CCallService.WCS_WMS_111(); //返回的报文
|
|
|
|
// string err = string.Empty;
|
|
// string returnJson = string.Empty;
|
|
// DataView dv = new DataView();
|
|
// if (wms_wcs != null)
|
|
// {
|
|
// switch (wms_wcs.method)
|
|
// {
|
|
// case "wcs_stack_status"://WMS出库任务
|
|
|
|
|
|
// List<CCallService.STATUS_111> outdata = wms_wcs.data;
|
|
// List<CCallService.OUT_MOVE_RES> answer_outdata = new List<CCallService.OUT_MOVE_RES>();
|
|
// foreach (var item in outdata)
|
|
// {
|
|
// string a = item.battery;
|
|
// string b = item.stackindex;
|
|
|
|
// //IO_CONTROL outtask = new IO_CONTROL(item, wms_wcs.timestamp, 2);
|
|
// //CCallService.OUT_MOVE_RES outReturn = new CCallService.OUT_MOVE_RES();
|
|
// //if (outtask.Insert_IOCONTROL() == true)
|
|
// //{
|
|
// // outReturn.code = "00";
|
|
// // outReturn.msg = "出库任务接收成功";
|
|
// // outReturn.taskId = item.taskId.ToString();
|
|
// //}
|
|
// //else
|
|
// //{
|
|
// // outReturn.code = "01";
|
|
// // outReturn.msg = "出库任务接收失败！" + outtask.error_code;
|
|
// // outReturn.taskId = item.taskId.ToString();
|
|
// //}
|
|
// //answer_outdata.Add(outReturn);
|
|
|
|
|
|
// }
|
|
// wcs_wms.data = answer_outdata;
|
|
// wcs_wms.timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
|
// wcs_wms.method = wms_wcs.method;
|
|
// break;
|
|
|
|
|
|
|
|
// default:
|
|
|
|
// string errorjson = Model.JsonHelper.Serializer(new
|
|
// {
|
|
// method = wms_wcs.method,
|
|
// timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
|
|
// data = new
|
|
// {
|
|
// code = "11",
|
|
// msg = "WCS解析jason异常"
|
|
// }
|
|
// });
|
|
// CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "返回报文", errorjson, "");
|
|
// return errorjson;
|
|
// }
|
|
|
|
// }
|
|
// returnJson = Model.JsonHelper.Serializer(wcs_wms);
|
|
// CommonClassLib.CCarryConvert.WriteLog("WEBAPI", "返回报文", returnJson, "");
|
|
// return returnJson;
|
|
//};
|
|
#endregion
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// 通过读取XML文档获得DBFactory.dll.config的内容
|
|
/// </summary>
|
|
/// <returns>appSettings所有key的值</returns>
|
|
private static IDictionary GetConfig()
|
|
{
|
|
// Open and parse configuration file for specified
|
|
// assembly, returning collection to caller for future
|
|
// use outside of this class.
|
|
//
|
|
try
|
|
{
|
|
Assembly asm = Assembly.GetCallingAssembly();
|
|
|
|
string cfgFile = asm.Location + ".config";
|
|
const string nodeName = "appSettings";
|
|
|
|
XmlDocument doc = new XmlDocument();
|
|
doc.Load(cfgFile);//20100726
|
|
|
|
XmlNodeList nodes = doc.GetElementsByTagName(nodeName);
|
|
|
|
foreach (XmlNode node in nodes)
|
|
{
|
|
if (node.LocalName == nodeName)
|
|
{
|
|
DictionarySectionHandler handler = new DictionarySectionHandler();
|
|
return (IDictionary)handler.Create(null, null, node);
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
throw (ex);
|
|
}
|
|
|
|
return (null);
|
|
}
|
|
#region 向 IO_CONTROL 插入出库倒库任务等
|
|
public class IO_CONTROL
|
|
{
|
|
string wms_id;
|
|
int relative_id;
|
|
string barcode;
|
|
string startdevice;
|
|
string enddevice;
|
|
string begintime;
|
|
int control_type;
|
|
string warehouse ="1";
|
|
string tasklevel;
|
|
int needAgv = 0;
|
|
public StringBuilder error_code = new StringBuilder();
|
|
|
|
StringBuilder sql = new StringBuilder();
|
|
|
|
public IO_CONTROL(CCallService.OUT_MOVE_DATA outdata, string time,int controltype,string level)//出库 移库
|
|
{
|
|
error_code.Clear();
|
|
wms_id = outdata.taskId;
|
|
relative_id = -1;
|
|
barcode = outdata.containerCode;
|
|
if (outdata.taskType == 2 || outdata.taskType == 3)
|
|
{ //起点是库位
|
|
startdevice = outdata.startRow.ToString("D2") + "-" + outdata.startColumn.ToString("D2") + "-" + outdata.startLayer.ToString("D2");
|
|
enddevice = outdata.endNode;
|
|
}
|
|
else if(outdata.taskType == 1 || outdata.taskType == 4) //终点是库位
|
|
{
|
|
startdevice = outdata.startNode;
|
|
enddevice = outdata.endRow.ToString("D2") + "-" + outdata.endColumn.ToString("D2") + "-" + outdata.endLayer.ToString("D2");
|
|
}
|
|
control_type = controltype;
|
|
string dTime1 = DateTime.Now.ToString("u");
|
|
begintime = dTime1.Substring(0, dTime1.Length - 1);
|
|
tasklevel = level;
|
|
needAgv = outdata.carryType == 2 ? 1 : 0;
|
|
}
|
|
public IO_CONTROL(CCallService.WMS_WCS_PARAM_IN indata, string time, string level)//入库
|
|
{
|
|
error_code.Clear();
|
|
wms_id = indata.taskId;
|
|
relative_id = -1;
|
|
barcode = indata.containerCode;
|
|
if (indata.taskType == 2 || indata.taskType == 3)
|
|
{ //起点是库位
|
|
// startdevice = outdata.startRow.ToString("D2") + "-" + outdata.startColumn.ToString("D2") + "-" + outdata.startLayer.ToString("D2");
|
|
enddevice = indata.endNode;
|
|
}
|
|
else if (indata.taskType == 1 || indata.taskType == 4) //终点是库位
|
|
{
|
|
startdevice = indata.startNode;
|
|
enddevice = indata.endRow.ToString("D2") + "-" + indata.endColumn.ToString("D2") + "-" + indata.endLayer.ToString("D2");
|
|
}
|
|
control_type = 1;
|
|
string dTime1 = DateTime.Now.ToString("u");
|
|
begintime = dTime1.Substring(0, dTime1.Length - 1);
|
|
tasklevel = level;
|
|
|
|
}
|
|
|
|
//检查参数是否正确
|
|
bool CheckData()
|
|
{
|
|
Dictionary<string, WEBAPI_CKECKING> all_checking = new Dictionary<string, WEBAPI_CKECKING>();
|
|
|
|
#region 从数据库中读取要检测的SQL
|
|
sql.Clear();
|
|
sql.Append("select * from WEBAPI_CKECKING");
|
|
DataView dv = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
|
|
for(int i=0; i<dv.Count; i++)
|
|
{
|
|
WEBAPI_CKECKING wac = new WEBAPI_CKECKING();
|
|
|
|
wac.check_id = dv[i]["CKECK_ID"].ToString();
|
|
wac.check_name = dv[i]["CKECK_NAME"].ToString();
|
|
wac.sql = dv[i]["SQL"].ToString();
|
|
wac.des = dv[i]["DESCRIPTION"].ToString();
|
|
|
|
all_checking.Add(wac.check_name, wac);
|
|
}
|
|
#endregion
|
|
|
|
error_code.Clear();
|
|
|
|
#region 检查是否重复，CONTROL_ID, 托盘码重复， 起始货位重复，终止货位重复(结果大于零)
|
|
|
|
sql.Clear();
|
|
sql.Append(string.Format(all_checking["CONTROL_ID_REPEAT"].sql, wms_id));
|
|
if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count > 0)
|
|
{
|
|
error_code.Append(";").Append(all_checking["CONTROL_ID_REPEAT"].des); //fid重复
|
|
}
|
|
|
|
//sql.Clear();
|
|
//sql.Append(string.Format(all_checking["BARCODE_REPEAT"].sql, barcode));
|
|
//if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count > 0)
|
|
//{
|
|
// error_code.Append(";").Append(all_checking["BARCODE_REPEAT"].des); //托盘条码重复
|
|
//}
|
|
if (string.IsNullOrEmpty(tasklevel))
|
|
{
|
|
error_code.Append(";").Append("任务优先级为空");
|
|
}
|
|
if (string.IsNullOrEmpty(wms_id))
|
|
{
|
|
error_code.Append(";").Append("任务号为空");
|
|
}
|
|
if (string.IsNullOrEmpty(barcode))
|
|
{
|
|
error_code.Append(";").Append("条码为空");
|
|
}
|
|
|
|
if (int.TryParse(this.wms_id, out int controlid) == false)
|
|
{
|
|
error_code.Append(";").Append(all_checking["CONTROL_ID_NOT_NUM"].des); //controlid不为数字
|
|
}
|
|
|
|
|
|
if (control_type == 2 )//出库任务
|
|
{
|
|
|
|
sql.Clear();
|
|
sql.Append(string.Format(all_checking["START_CEEE_REPEAT"].sql, startdevice, control_type));
|
|
if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count > 0)
|
|
{
|
|
error_code.Append(";").Append(all_checking["START_CEEE_REPEAT"].des); //起始货位重复
|
|
}
|
|
if (this.startdevice.Length != 8)
|
|
{
|
|
error_code.Append(";").Append("起点").Append(all_checking["CELL_LENGTH_ERROR"].des); //起点货位编码长度错误
|
|
}
|
|
sql.Clear();
|
|
sql.Append(string.Format(all_checking["CELL_NOT_EXIST"].sql, startdevice));
|
|
if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count == 0)
|
|
{
|
|
error_code.Append(";").Append("起点").Append(all_checking["CELL_NOT_EXIST"].des); //起点货位不存在
|
|
|
|
}
|
|
|
|
int endGate = 0;
|
|
if (int.TryParse(this.enddevice, out endGate) == false)
|
|
{
|
|
error_code.Append(";").Append(all_checking["END_GATE_ERROR"].des); //终点站台不正确，无法转为整数
|
|
}
|
|
|
|
sql.Clear();
|
|
sql.Append(string.Format(all_checking["END_GATE_NOT_EXIST"].sql, enddevice));
|
|
if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count == 0)
|
|
{
|
|
error_code.Append(";").Append(all_checking["END_GATE_NOT_EXIST"].des); //终点站台不存在
|
|
}
|
|
|
|
}
|
|
|
|
if (control_type == 1)//入库任务
|
|
{
|
|
sql.Clear();
|
|
sql.Append(string.Format(all_checking["END_CEEE_REPEAT"].sql, enddevice, control_type));
|
|
if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count > 0)
|
|
{
|
|
error_code.Append(";").Append(all_checking["END_CEEE_REPEAT"].des); //终点货位重复
|
|
}
|
|
if (this.enddevice.Length != 8 )
|
|
{
|
|
error_code.Append(";").Append("终点").Append(all_checking["CELL_LENGTH_ERROR"].des); //终点货位编码长度错误
|
|
}
|
|
|
|
sql.Clear();
|
|
sql.Append(string.Format(all_checking["CELL_NOT_EXIST"].sql, enddevice));
|
|
if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count == 0)
|
|
{
|
|
error_code.Append(";").Append("终点").Append(all_checking["CELL_NOT_EXIST"].des); //终点货位不存在
|
|
}
|
|
sql.Clear();
|
|
sql.Append(string.Format(all_checking["START_GATE_NOT_EXIST"].sql, startdevice));
|
|
if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count == 0)
|
|
{
|
|
error_code.Append(";").Append(all_checking["START_GATE_NOT_EXIST"].des); //起点站台不存在
|
|
}
|
|
}
|
|
#region 校验代码需优化20250310
|
|
if (control_type == 3) //移库任务
|
|
{
|
|
if (this.startdevice.Length != 8)
|
|
{
|
|
error_code.Append(";").Append("起点").Append(all_checking["CELL_LENGTH_ERROR"].des); //终点货位编码长度错误
|
|
}
|
|
if (this.enddevice.Length != 8 )
|
|
{
|
|
error_code.Append(";").Append("终点").Append(all_checking["CELL_LENGTH_ERROR"].des); //终点货位编码长度错误
|
|
}
|
|
|
|
sql.Clear();
|
|
sql.Append(string.Format(all_checking["CELL_NOT_EXIST"].sql, startdevice));
|
|
if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count == 0)
|
|
{
|
|
error_code.Append(";").Append("起点").Append(all_checking["CELL_NOT_EXIST"].des); //起点货位不存在
|
|
|
|
}
|
|
sql.Clear();
|
|
sql.Append(string.Format(all_checking["CELL_NOT_EXIST"].sql, enddevice));
|
|
if (dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView.Count == 0)
|
|
{
|
|
error_code.Append(";").Append("终点").Append(all_checking["CELL_NOT_EXIST"].des); //终点货位不存在
|
|
}
|
|
|
|
//移库任务如果不同层，校验不要移
|
|
if (startdevice.Substring(6, 2) != enddevice.Substring(6, 2))
|
|
{
|
|
error_code.Append(";").Append("移库任务起点终点层值不同");
|
|
}
|
|
if (startdevice == enddevice)
|
|
{
|
|
error_code.Append(";").Append("移库任务起点终点相同");
|
|
}
|
|
|
|
}
|
|
#endregion
|
|
#endregion
|
|
|
|
//检查托盘码
|
|
|
|
if (error_code.Length == 0)
|
|
{
|
|
return true;
|
|
}
|
|
else
|
|
{
|
|
return false;
|
|
}
|
|
}
|
|
|
|
//
|
|
public bool Insert_IOCONTROL()
|
|
{
|
|
if (CheckData() == true)
|
|
{
|
|
try
|
|
{
|
|
sql.Clear();
|
|
sql.Append(string.Format("INSERT INTO IO_CONTROL (CONTROL_ID, RELATIVE_CONTROL_ID, MANAGE_ID, STOCK_BARCODE, CONTROL_TASK_TYPE, CONTROL_TASK_LEVEL," +
|
|
" START_WAREHOUSE_CODE, START_DEVICE_CODE, END_WAREHOUSE_CODE, END_DEVICE_CODE, CONTROL_BEGIN_TIME,CONTROL_STATUS,NeedAgv) " +
|
|
"VALUES( {0},'{1}','{2}', '{3}', '{4}', '{5}', '{6}', '{7}', '{8}', '{9}', '{10}',{11})",
|
|
wms_id, -1, 0, barcode, control_type, tasklevel, warehouse, startdevice, warehouse, enddevice, begintime,0,needAgv));
|
|
dbo.ExceSQL(sql.ToString());
|
|
return true;
|
|
}
|
|
catch(Exception ex)
|
|
{
|
|
error_code.Append("WCS插入IO_ONTROL表失败！");
|
|
return false;
|
|
}
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
|
|
}
|
|
#endregion
|
|
|
|
|
|
// public static Dictionary<string, WEBAPI_CKECKING> all_checking = new Dictionary<string, WEBAPI_CKECKING>();
|
|
|
|
public class WEBAPI_CKECKING
|
|
{
|
|
public string check_id;
|
|
public string check_name;
|
|
public string sql;
|
|
public string des;
|
|
}
|
|
|
|
public class Bootstrapper : DefaultNancyBootstrapper
|
|
{
|
|
/// <summary>
|
|
/// Register only NancyModules found in this assembly
|
|
/// </summary>
|
|
protected override IEnumerable<ModuleRegistration> Modules
|
|
{
|
|
get
|
|
{
|
|
return GetType().Assembly.GetTypes().Where(type => type.BaseType == typeof(NancyModule)).Select(type => new ModuleRegistration(type));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|