using Newtonsoft.Json;/********************************************************************************
|
|
** auth： DBS
|
|
** date： 2019/2/18 17:07:51
|
|
** desc： 尚未编写描述
|
|
** Ver.: V1.0.0
|
|
*********************************************************************************/
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Reflection;
|
using System.Text;
|
using System.Threading.Tasks;
|
using HH.WMS.DAL;
|
using HH.WMS.Entitys;
|
using HH.WMS.Entitys.Basic;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using HH.WMS.Entitys.Ams;
|
using HH.WMS.Common;
|
using HH.WMS.Entitys.External;
|
|
namespace HH.WMS.BLL.Interface
|
{
|
public class OtherSysApi : DapperBaseBLL
|
{
|
/// <summary>
|
/// 出库确认
|
/// </summary>
|
/// <param name="opNo">发货通知单号</param>
|
/// <returns></returns>
|
public OperateResult OutOrderConmit(string opType, string fromOpNo)
|
{
|
TN_WMS_REQ_LOGEntity req = new TN_WMS_REQ_LOGEntity()
|
{
|
CN_GUID = Guid.NewGuid().ToString(),
|
CN_S_INTERFACE = "OutOrderConmit",
|
CN_S_INTERFACE_NAME = "发货确认",
|
CN_T_CREATE = DateTime.Now
|
};
|
try
|
{
|
Log.Info("===>出库确认调用上游系统接口", opType + fromOpNo);
|
OperateResult result = new OperateResult();
|
//返回接口定义数据
|
TN_WM_INTERFACE_DEFEntity entity = CreateDAL<DapperDAL<TN_WM_INTERFACE_DEFEntity>>().GetSingleEntity(new { CN_S_INTF_CODE = "OutOrderConmit" });
|
if (entity == null)
|
{
|
Log.Info("===>出库确认调用上游系统接口", "未配置该接口定义");
|
return OperateResult.Error("未配置该接口定义");
|
}
|
else if (entity.CN_C_IS_ENABLE.Equals("N"))
|
{
|
return OperateResult.Succeed();
|
}
|
switch (entity.CN_S_PROTOCOL.Trim())
|
{
|
case "WebApi":
|
string requestContext = "opFromNo=" + fromOpNo + "&opType=" + opType;
|
req.CN_S_REQUEST = requestContext;
|
Log.Info("===>调用上游系统接口", requestContext);
|
string res = WebApiManager.HttpGet(entity.CN_S_URL, "", "opFromNo=" + fromOpNo + "&opType=" + opType);
|
Log.Info("===>调用上游系统接口", res);
|
req.CN_S_RESPONSE = res;
|
|
CreateDAL<DapperDAL<TN_WMS_REQ_LOGEntity>>().Add(req);
|
|
if (res == "")
|
return OperateResult.Error("接口访问失败！");
|
else
|
return OperateResult.Succeed();
|
break;
|
}
|
return result;
|
}
|
catch (Exception ex)
|
{
|
Log.Info("===>出库确认调用上游系统接口,程序异常：", ex.Message);
|
CreateDAL<DapperDAL<TN_WMS_REQ_LOGEntity>>().Add(req);
|
return OperateResult.Error(ex.Message);
|
}
|
}
|
|
/// <summary>
|
/// 下达任务给AMS
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public OperateResult SendAmsTask(TN_WM_TASKEntity model)
|
{
|
//返回接口定义数据
|
|
//if (GetStrategy(model.CN_S_STOCK_CODE, Constants.IsUseAms) == "Y")
|
//{
|
return SendAms(model);
|
// }
|
// return OperateResult.Succeed();
|
//return OperateResult.Succeed();
|
}
|
public OperateResult SendAmsCreateTask(TN_WM_TASKEntity model)
|
{
|
List<JObject> sendParams = new List<JObject>();
|
JObject sendParam = new JObject();
|
sendParam.Add("businessType", "转运");
|
sendParam.Add("whNoFrom", model.CN_S_STOCK_CODE);
|
sendParam.Add("whNoTo", model.CN_S_STOCK_CODE);
|
sendParam.Add("sysName", "WMS");
|
sendParam.Add("deviceName", "WMS");
|
sendParam.Add("taskNo", model.CN_S_TASK_NO);
|
sendParam.Add("locationFrom", model.CN_S_START_BIT);
|
sendParam.Add("locationTo", model.CN_S_END_BIT);
|
sendParam.Add("priority", model.CN_N_PRIORITY);
|
sendParam.Add("areaTo", JsonConvert.SerializeObject(model.END_AREAS));
|
sendParams.Add(sendParam);
|
string sendData = JsonConvert.SerializeObject(sendParams);
|
Log.Info("===>发送任务给AMS", sendData);
|
string postOmsData = JsonConvert.SerializeObject(sendParams);
|
string result = WebApiManager.HttpAms_Post("api/HHAms/AddTask", postOmsData);
|
Log.Info("===>AMS返回结果", result);
|
|
if (result == "")
|
return OperateResult.Error("请检查AMS访问地址！");
|
|
try
|
{
|
AmsResponse s = JsonConvert.DeserializeObject<AmsResponse>(result);
|
if (s.success)
|
{
|
return OperateResult.Succeed();
|
}
|
else
|
{
|
return OperateResult.Error(s.failList[0].errMsg);
|
}
|
}
|
catch (Exception ex)
|
{
|
Log.Info("===>AMS返回结果异常", ex.Message);
|
return OperateResult.Error("AMS返回结果异常");
|
}
|
}
|
private OperateResult SendAms(TN_WM_TASKEntity model)
|
{
|
List<JObject> sendParams = new List<JObject>();
|
JObject sendParam = new JObject();
|
sendParam.Add("businessType", "转运");
|
sendParam.Add("whNoFrom", "");
|
sendParam.Add("whNoTo", "");
|
sendParam.Add("sysName", "WMS");
|
sendParam.Add("deviceName", "WMS");
|
sendParam.Add("taskNo", model.CN_S_TASK_NO);
|
sendParam.Add("locationFrom", model.CN_S_START_BIT);
|
sendParam.Add("locationTo", model.CN_S_END_BIT);
|
sendParam.Add("priority", model.CN_N_PRIORITY);
|
sendParam.Add("areaTo", JsonConvert.SerializeObject(model.END_AREAS));
|
sendParams.Add(sendParam);
|
|
string sendData = JsonConvert.SerializeObject(sendParams);
|
Log.Info("===>发送任务给AMS", sendData);
|
string postOmsData = JsonConvert.SerializeObject(sendParams);
|
string result = WebApiManager.HttpAms_Post("api/HHAms/AddTask", postOmsData);
|
Log.Info("===>AMS返回结果", result);
|
|
TN_WMS_REQ_LOGEntity req = new TN_WMS_REQ_LOGEntity()
|
{
|
CN_GUID = System.Guid.NewGuid().ToString().ToUpper(),
|
CN_S_INTERFACE = "SendAmsTask",
|
CN_S_INTERFACE_NAME = "下达任务",
|
CN_S_REQUEST = postOmsData,
|
CN_S_RESPONSE = result,
|
CN_T_CREATE = DateTime.Now
|
};
|
OperateResult r = CreateDAL<DapperDAL<TN_WMS_REQ_LOGEntity>>().Add(req);
|
if (result == "")
|
return OperateResult.Error("请检查AMS访问地址！");
|
|
try
|
{
|
AmsResponse s = JsonConvert.DeserializeObject<AmsResponse>(result);
|
if (s.success)
|
{
|
return OperateResult.Succeed();
|
}
|
else
|
{
|
return OperateResult.Error(s.failList[0].errMsg);
|
}
|
}
|
catch (Exception ex)
|
{
|
Log.Info("===>AMS返回结果异常", ex.Message);
|
return OperateResult.Error("AMS返回结果异常");
|
}
|
}
|
public OperateResult SendAmsCreateTaskHK(TN_WM_TRANSPORT_TASKEntity model)
|
{
|
List<JObject> sendParams = new List<JObject>();
|
JObject sendParam = new JObject();
|
sendParam.Add("businessType", model.AMSTaskType);
|
sendParam.Add("whNoFrom", model.CN_S_STOCK_CODE);
|
sendParam.Add("whNoTo", model.CN_S_STOCK_CODE);
|
sendParam.Add("sysName", "WMS");
|
sendParam.Add("deviceName", "WMS");
|
sendParam.Add("taskNo", model.CN_S_TASK_NO);
|
sendParam.Add("locationFrom", model.CN_S_START_BIT);
|
sendParam.Add("locationTo", model.CN_S_END_BIT);
|
sendParam.Add("priority", model.CN_N_PRIORITY);
|
sendParam.Add("ext2", model.CN_S_REMARK);
|
sendParam.Add("areaTo", JsonConvert.SerializeObject(model.END_AREAS));
|
sendParams.Add(sendParam);
|
string sendData = JsonConvert.SerializeObject(sendParams);
|
Log.Info("===>发送任务给AMS", sendData);
|
string postOmsData = JsonConvert.SerializeObject(sendParams);
|
string result = WebApiManager.HttpAms_Post("api/HHAms/AddTask", postOmsData);
|
Log.Info("===>AMS返回结果", result);
|
|
if (result == "")
|
return OperateResult.Error("请检查AMS访问地址！");
|
|
try
|
{
|
AmsResponse s = JsonConvert.DeserializeObject<AmsResponse>(result);
|
if (s.success)
|
{
|
return OperateResult.Succeed();
|
}
|
else
|
{
|
return OperateResult.Error(s.failList[0].errMsg);
|
}
|
}
|
catch (Exception ex)
|
{
|
Log.Info("===>AMS返回结果异常", ex.Message);
|
return OperateResult.Error("AMS返回结果异常");
|
}
|
}
|
public OperateResult SendAmsCreateTask(TN_WM_TRANSPORT_TASKEntity model)
|
{
|
List<JObject> sendParams = new List<JObject>();
|
JObject sendParam = new JObject();
|
sendParam.Add("businessType", "转运");
|
sendParam.Add("whNoFrom", model.CN_S_STOCK_CODE);
|
sendParam.Add("whNoTo", model.CN_S_STOCK_CODE);
|
sendParam.Add("sysName", "WMS");
|
sendParam.Add("deviceName", "WMS");
|
sendParam.Add("taskNo", model.CN_S_TASK_NO);
|
sendParam.Add("locationFrom", model.CN_S_START_BIT);
|
sendParam.Add("locationTo", model.CN_S_END_BIT);
|
sendParam.Add("priority", model.CN_N_PRIORITY);
|
sendParam.Add("areaTo", JsonConvert.SerializeObject(model.END_AREAS));
|
sendParams.Add(sendParam);
|
string sendData = JsonConvert.SerializeObject(sendParams);
|
Log.Info("===>发送任务给AMS", sendData);
|
string postOmsData = JsonConvert.SerializeObject(sendParams);
|
string result = WebApiManager.HttpAms_Post("api/HHAms/AddTask", postOmsData);
|
Log.Info("===>AMS返回结果", result);
|
|
if (result == "")
|
return OperateResult.Error("请检查AMS访问地址！");
|
|
try
|
{
|
AmsResponse s = JsonConvert.DeserializeObject<AmsResponse>(result);
|
if (s.success)
|
{
|
return OperateResult.Succeed();
|
}
|
else
|
{
|
return OperateResult.Error(s.failList[0].errMsg);
|
}
|
}
|
catch (Exception ex)
|
{
|
Log.Info("===>AMS返回结果异常", ex.Message);
|
return OperateResult.Error("AMS返回结果异常");
|
}
|
}
|
public OperateResult SendAmsCreateTaskJX(TN_WM_TRANSPORT_TASKEntity model)
|
{
|
List<JObject> sendParams = new List<JObject>();
|
//List<string> lstTray = new List<string>();
|
//lstTray.Add(model.CN_S_CIR_OBJ_CODE);
|
JObject sendParam = new JObject();
|
sendParam.Add("businessType", "转运");
|
sendParam.Add("whNoFrom", "");
|
sendParam.Add("whNoTo", "");
|
sendParam.Add("sysName", "WMS");
|
sendParam.Add("deviceName", "WMS");
|
sendParam.Add("batchNo", model.CN_S_CIR_OBJ_CODE);
|
sendParam.Add("taskNo", model.CN_S_TASK_NO);
|
sendParam.Add("locationFrom", model.CN_S_START_BIT);
|
sendParam.Add("locationTo", model.CN_S_END_BIT);
|
sendParam.Add("priority", model.CN_N_PRIORITY);
|
sendParam.Add("ext1", model.CN_S_REMARK);
|
sendParam.Add("areaTo", JsonConvert.SerializeObject(model.END_AREAS));
|
sendParams.Add(sendParam);
|
string sendData = JsonConvert.SerializeObject(sendParams);
|
Log.Info("===>巨星 发送任务给AMS", sendData);
|
string postOmsData = JsonConvert.SerializeObject(sendParams);
|
string result = WebApiManager.HttpAms_Post("api/HHAms/AddTask", postOmsData);
|
Log.Info("===>AMS返回结果", result);
|
if (result == "")
|
return OperateResult.Error("请检查AMS访问地址！");
|
|
try
|
{
|
AmsResponse s = JsonConvert.DeserializeObject<AmsResponse>(result);
|
if (s.success)
|
{
|
return OperateResult.Succeed();
|
}
|
else
|
{
|
return OperateResult.Error(s.failList[0].errMsg);
|
}
|
}
|
catch (Exception ex)
|
{
|
Log.Info("===>AMS返回结果异常", ex.Message);
|
return OperateResult.Error("AMS返回结果异常");
|
}
|
}
|
|
public OperateResult SendAmsCreateTaskLJ(TN_WM_TRANSPORT_TASKEntity model)
|
{
|
List<JObject> sendParams = new List<JObject>();
|
JObject sendParam = new JObject();
|
sendParam.Add("businessType", "人工");
|
sendParam.Add("whNoFrom", model.CN_S_STOCK_CODE);
|
sendParam.Add("whNoTo", model.CN_S_STOCK_CODE);
|
sendParam.Add("sysName", "WMS");
|
sendParam.Add("deviceName", "WMS");
|
sendParam.Add("taskNo", model.CN_S_TASK_NO);
|
sendParam.Add("locationFrom", model.CN_S_START_BIT);
|
sendParam.Add("locationTo", model.CN_S_END_BIT);
|
sendParam.Add("priority", model.CN_N_PRIORITY);
|
sendParam.Add("areaTo", JsonConvert.SerializeObject(model.END_AREAS));
|
sendParam.Add("ext2", model.CN_S_REMARK);
|
sendParam.Add("ext3", model.CN_S_EXT3);
|
sendParams.Add(sendParam);
|
string sendData = JsonConvert.SerializeObject(sendParams);
|
Log.Info("===>发送任务给AMS-隆基", sendData);
|
string postOmsData = JsonConvert.SerializeObject(sendParams);
|
string result = WebApiManager.HttpAms_Post("api/HHAms/AddTask", postOmsData);
|
Log.Info("===>AMS返回结果", result);
|
|
if (result == "")
|
return OperateResult.Error("请检查AMS访问地址！");
|
|
try
|
{
|
AmsResponse s = JsonConvert.DeserializeObject<AmsResponse>(result);
|
if (s.success)
|
{
|
return OperateResult.Succeed();
|
}
|
else
|
{
|
return OperateResult.Error(s.failList[0].errMsg);
|
}
|
}
|
catch (Exception ex)
|
{
|
Log.Info("===>AMS返回结果异常", ex.Message);
|
return OperateResult.Error("AMS返回结果异常");
|
}
|
}
|
public OperateResult SendAmsCreateTaskLJ(TN_WM_TASKEntity model)
|
{
|
List<JObject> sendParams = new List<JObject>();
|
JObject sendParam = new JObject();
|
sendParam.Add("businessType", "人工");
|
sendParam.Add("whNoFrom", model.CN_S_STOCK_CODE);
|
sendParam.Add("whNoTo", model.CN_S_STOCK_CODE);
|
sendParam.Add("sysName", "WMS");
|
sendParam.Add("deviceName", "WMS");
|
sendParam.Add("taskNo", model.CN_S_TASK_NO);
|
sendParam.Add("locationFrom", model.CN_S_START_BIT);
|
sendParam.Add("locationTo", model.CN_S_END_BIT);
|
sendParam.Add("priority", model.CN_N_PRIORITY);
|
sendParam.Add("areaTo", JsonConvert.SerializeObject(model.END_AREAS));
|
sendParam.Add("ext2", model.mesInfo);
|
sendParam.Add("ext3", model.CN_S_EXT3);
|
sendParams.Add(sendParam);
|
string sendData = JsonConvert.SerializeObject(sendParams);
|
Log.Info("===>发送任务给AMS-隆基", sendData);
|
string postOmsData = JsonConvert.SerializeObject(sendParams);
|
string result = WebApiManager.HttpAms_Post("api/HHAms/AddTask", postOmsData);
|
Log.Info("===>AMS返回结果", result);
|
|
if (result == "")
|
return OperateResult.Error("请检查AMS访问地址！");
|
|
try
|
{
|
AmsResponse s = JsonConvert.DeserializeObject<AmsResponse>(result);
|
if (s.success)
|
{
|
return OperateResult.Succeed();
|
}
|
else
|
{
|
return OperateResult.Error(s.failList[0].errMsg);
|
}
|
}
|
catch (Exception ex)
|
{
|
Log.Info("===>AMS返回结果异常", ex.Message);
|
return OperateResult.Error("AMS返回结果异常");
|
}
|
}
|
|
public OperateResult SendAmsCreateTaskHK(TN_WM_TASKEntity model)
|
{
|
List<JObject> sendParams = new List<JObject>();
|
JObject sendParam = new JObject();
|
sendParam.Add("businessType", model.CN_S_TASK_TYPE);
|
sendParam.Add("whNoFrom", model.CN_S_STOCK_CODE);
|
sendParam.Add("whNoTo", model.CN_S_STOCK_CODE);
|
sendParam.Add("sysName", "WMS");
|
sendParam.Add("deviceName", "WMS");
|
sendParam.Add("taskNo", model.CN_S_TASK_NO);
|
sendParam.Add("locationFrom", model.CN_S_START_BIT);
|
sendParam.Add("locationTo", model.CN_S_END_BIT);
|
sendParam.Add("priority", model.CN_N_PRIORITY);
|
sendParam.Add("areaTo", JsonConvert.SerializeObject(model.END_AREAS));
|
sendParams.Add(sendParam);
|
string sendData = JsonConvert.SerializeObject(sendParams);
|
Log.DomainInfo("===>发送任务给AMS", sendData);
|
string postOmsData = JsonConvert.SerializeObject(sendParams);
|
string result = WebApiManager.HttpAms_Post("api/HHAms/AddTask", postOmsData);
|
Log.DomainInfo("===>AMS返回结果", result);
|
|
if (result == "")
|
return OperateResult.Error("请检查AMS访问地址！");
|
|
try
|
{
|
AmsResponse s = JsonConvert.DeserializeObject<AmsResponse>(result);
|
if (s.success)
|
{
|
return OperateResult.Succeed();
|
}
|
else
|
{
|
return OperateResult.Error(s.failList[0].errMsg);
|
}
|
}
|
catch (Exception ex)
|
{
|
Log.DomainInfo("===>AMS返回结果异常", ex.Message);
|
return OperateResult.Error("AMS返回结果异常");
|
}
|
}
|
}
|
}
|
