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 ;
using static System . Windows . Forms . VisualStyles . VisualStyleElement ;
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" ) ;
public static bool Lock2 = false ;
//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 [ "/api/wcs/thirdParty" ] = _ = > "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 ( ) ;
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 )
{
// task.taskId = task.taskId.Trim('D').Trim('C');
IO_CONTROL outtask = new IO_CONTROL ( task , wms_wcs . msgTime , wms_wcs . priority . ToString ( ) ) ;
if ( outtask . CheckData ( out string msg ) = = true )
{
outtask . sql . Clear ( ) ;
outtask . 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) " +
"VALUES( {0},'{1}','{2}', '{3}', '{4}', '{5}', '{6}', '{7}', '{8}', '{9}', '{10}',{11})" ,
outtask . wms_id , - 1 , 0 , outtask . barcode , outtask . control_type , outtask . tasklevel , outtask . warehouse , outtask . startdevice , outtask . warehouse , outtask . enddevice , outtask . begintime , 0 ) ) ;
dbo . ExceSQL ( outtask . sql . ToString ( ) ) ;
}
else {
isOk + + ;
outReturn . data + = "ID'" + task . taskId . ToString ( ) + $"'任务下发失败:{msg}" ;
}
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
{
dbo . TransBegin ( ) ;
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 ;
StringBuilder sql = new StringBuilder ( ) ;
DataView dv = new DataView ( ) ;
DataView dv1 = 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();
wms_wcs_cancel . taskId = wms_wcs_cancel . taskId . Trim ( 'D' ) . Trim ( 'C' ) ;
sql . Clear ( ) ;
sql . Append ( "select * from t_manage_task where FID = '" ) . Append ( wms_wcs_cancel . taskId ) . Append ( "'" ) ;
dv = dbo . ExceSQL ( sql . ToString ( ) ) . Tables [ 0 ] . DefaultView ;
if ( dv . Count = = 1 ) //存在需要删除的任务
{
int stepOk = Convert . ToInt32 ( dv [ 0 ] [ "FIntoStepOK" ] ) ; //拆分下发
int FSTATUS = Convert . ToInt32 ( dv [ 0 ] [ "FSTATUS" ] ) ; //任务未执行
if ( stepOk = = 0 ) //未拆分
{
//暂不考虑数据库执行删除指令失败的情况
sql . Clear ( ) ;
sql . Append ( "delete from t_manage_task where FID = '" ) . Append ( wms_wcs_cancel . taskId ) . Append ( "'" ) ;
dbo . ExecuteSql ( sql . ToString ( ) ) ;
//同时还要删除IOControl表的任务信息
sql . Clear ( ) ;
sql . Append ( "delete from IO_CONTROL where MANAGE_ID = '" ) . Append ( wms_wcs_cancel . taskId ) . Append ( "'" ) ;
dbo . ExecuteSql ( sql . ToString ( ) ) ;
wcs_wms_cancel . code = 0 ;
wcs_wms_cancel . msg = "" ;
wcs_wms_cancel . data = "" ;
}
else if ( stepOk = = 1 & & FSTATUS = = 0 ) {
sql . Remove ( 0 , sql . Length ) ;
sql . Append ( "INSERT INTO T_Manage_Task_BAK SELECT * FROM T_Manage_Task where FID=" ) . Append ( wms_wcs_cancel . taskId ) . Append ( " and F_ManageTaskKindIndex>=1" ) ;
dbo . ExecuteSql ( sql . ToString ( ) ) ;
sql . Clear ( ) ;
sql . Append ( "delete from T_Monitor_Task where F_ManageTaskIndex = '" ) . Append ( wms_wcs_cancel . taskId ) . Append ( "'" ) ;
dbo . ExecuteSql ( sql . ToString ( ) ) ;
sql . Clear ( ) ;
sql . Append ( "delete from t_manage_task where FID = '" ) . Append ( wms_wcs_cancel . taskId ) . Append ( "'" ) ;
var count = dbo . ExecuteSql ( sql . ToString ( ) ) ;
//暂不考虑数据库执行删除指令失败的情况
//同时还要删除IOControl表的任务信息
sql . Clear ( ) ;
sql . Append ( "delete from IO_CONTROL where MANAGE_ID = '" ) . Append ( wms_wcs_cancel . taskId ) . Append ( "'" ) ;
dbo . ExecuteSql ( sql . ToString ( ) ) ;
wcs_wms_cancel . code = 0 ;
wcs_wms_cancel . msg = "" ;
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 = "" ;
}
if ( wcs_wms_cancel . code = = 0 ) { //删除成功
sql . Clear ( ) ;
sql . Append ( "select * from IO_CONTROL where CONTROL_ID = '" ) . Append ( wms_wcs_cancel . taskId ) . Append ( "'" ) ;
dv1 = dbo . ExceSQL ( sql . ToString ( ) ) . Tables [ 0 ] . DefaultView ;
if ( dv1 . Count > 0 ) {
sql . Clear ( ) ;
sql . Append ( "delete from IO_CONTROL where CONTROL_ID = '" ) . Append ( wms_wcs_cancel . taskId ) . Append ( "'" ) ;
dbo . ExceSQL ( sql . ToString ( ) ) ;
}
}
}
returnJson = Model . JsonHelper . Serializer ( wcs_wms_cancel ) ;
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/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();
wms_wcs_cancel . taskId = wms_wcs_cancel . taskId . Trim ( 'D' ) . Trim ( 'C' ) ;
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 = "update t_manage_task set FTaskLevel=" + 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 = "数据库删除数据失败" ;
}
}
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/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();
if ( wms_wcs . pickput = = 1 ) //AGV取货 AGV取货站台要显示有货空闲才能取货
{
msg . putStatus = Convert . ToInt32 ( dataBackmsg [ 0 ] [ "F_AGVIOStatus" ] ) = = 2 ? 1 : 0 ;
}
else {
msg . putStatus = Convert . ToInt32 ( dataBackmsg [ 0 ] [ "F_AGVIOStatus" ] ) = = 1 ? 1 : 0 ;
}
wcs_wms . data = msg ;
sql . Clear ( ) ;
sql . Append ( "update T_AGVIOStation set F_AGVPutPickState = " ) . Append ( wms_wcs . pickput ) . Append ( " where F_DeviceIndex=" ) . Append ( wms_wcs . toStation ) ;
dbo . ExceSQL ( sql . ToString ( ) ) ;
}
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 = = 5 6 )
{
status = 9 ;
}
else if ( wms_wcs . agvTaskStatus = = 2 0 ) //开始取货
{
status = 1 ;
}
else if ( wms_wcs . agvTaskStatus = = 2 1 | | wms_wcs . agvTaskStatus = = 2 4 ) //取货完成,24已取到货
{
status = 2 ;
}
else if ( wms_wcs . agvTaskStatus = = 2 2 ) //开始放货
{
status = 4 ;
}
else if ( wms_wcs . agvTaskStatus = = 2 3 ) //放货完成
{
status = 5 ;
}
else {
status = 3 ;
}
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
{
public string wms_id ;
public int relative_id ;
public string barcode ;
public string startdevice ;
public string enddevice ;
public string begintime ;
public int control_type ;
public string warehouse = "1" ;
public string tasklevel ;
public int needAgv = 0 ;
public StringBuilder error_code = new StringBuilder ( ) ;
public StringBuilder sql = new StringBuilder ( ) ;
public IO_CONTROL ( CCallService . OUT_MOVE_DATA outdata , string time , string level ) //出库 移库
{
error_code . Clear ( ) ;
wms_id = outdata . taskId . Trim ( 'D' ) . Trim ( 'C' ) ;
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 = outdata . taskType ;
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 . Trim ( 'D' ) . Trim ( 'C' ) ;
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 ;
}
//检查参数是否正确
public bool CheckData ( out string msg )
{
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 ( long . TryParse ( this . wms_id , out long 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 ) ) ;
var data = dbo . ExceSQL ( sql . ToString ( ) ) . Tables [ 0 ] . DefaultView ;
if ( data . Count = = 0 )
{
error_code . Append ( ";" ) . Append ( "起点" ) . Append ( all_checking [ "CELL_NOT_EXIST" ] . des ) ; //起点货位不存在
}
else {
sql . Clear ( ) ;
sql . Append ( string . Format ( all_checking [ "CELL_NOT_EXIST" ] . sql , data [ 0 ] [ "FLaneWay" ] , enddevice ) ) ;
if ( data . Count = = 0 )
{
error_code . 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 ) ) ;
var data = dbo . ExceSQL ( sql . ToString ( ) ) . Tables [ 0 ] . DefaultView ;
if ( data . Count = = 0 )
{
error_code . Append ( ";" ) . Append ( "终点" ) . Append ( all_checking [ "CELL_NOT_EXIST" ] . des ) ; //终点货位不存在
}
else {
sql . Clear ( ) ;
sql . Append ( string . Format ( all_checking [ "CELL_NOT_EXIST" ] . sql , startdevice , data [ 0 ] [ "FLaneWay" ] ) ) ;
if ( data . Count = = 0 )
{
error_code . 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 ( "移库任务起点终点相同" ) ;
}
if ( Convert . ToInt32 ( startdevice . Substring ( 0 , 2 ) + 3 ) / 4 ! = Convert . ToInt32 ( startdevice . Substring ( 0 , 2 ) + 3 ) / 4 ) {
error_code . Append ( ";" ) . Append ( "移库任务起点终点不是同一个巷道" ) ;
}
}
#endregion
#endregion
//检查托盘码
if ( error_code . Length = = 0 )
{
msg = "" ;
return true ;
}
else
{
msg = error_code . ToString ( ) ;
return false ;
}
}
//
public bool Insert_IOCONTROL ( DBOperator db )
{
if ( CheckData ( out string msg ) = = 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 ) ) ;
db . ExceSQL ( sql . ToString ( ) ) ;
return true ;
}
catch ( Exception ex )
{
error_code . Append ( "WCS插入IO_ONTROL表失败！" ) ;
return false ;
}
}
return false ;
}
public bool Insert_IOCONTROL ( )
{
if ( CheckData ( out string msg ) = = 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 ) ) ;
}
}
}
}
}
