using HH.WMS.Common;
|
using HH.WMS.Entitys.Common;
|
using HH.WMS.Entitys.External;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace HH.WMS.BLL.External
|
{
|
class InfRequest
|
{
|
#region 发送AMS指令
|
/// <summary>
|
/// 发送AMS指令
|
/// </summary>
|
/// <param name="objs"></param>
|
/// <param name="from"></param>
|
/// <returns></returns>
|
public SqlExecuteResult SendTask(List<JObject> objs, string from)
|
{
|
SqlExecuteResult msg = new SqlExecuteResult();
|
|
try
|
{
|
var content = JsonConvert.SerializeObject(objs);
|
string result = WebApiManager.HttpAms_Post("api/HHAms/AddTask", content);
|
|
Log.Info("调用AMS接口下达任务", "发送内容：" + content + ", 接收结果：" + result);
|
|
if (!string.IsNullOrEmpty(result))
|
{
|
AmsReturnResultEntity amsre = JsonHelper.ParseFormJson<AmsReturnResultEntity>(result);
|
if (amsre.success)
|
{
|
msg.Success = true;
|
return msg;
|
}
|
else
|
{
|
//失败
|
msg.Exception = new Exception(amsre.errMsg);
|
msg.Success = true;//为了当AMS执行失败时，WMS可以继续作业
|
return msg;
|
}
|
}
|
else
|
{
|
msg.Exception = new Exception("失败");
|
}
|
}
|
catch (Exception ex)
|
{
|
msg.Success = false;
|
msg.Exception = ex;
|
return msg;
|
}
|
finally
|
{
|
|
}
|
msg.Success = true;
|
return msg;
|
|
}
|
#endregion
|
|
#region 转运任务下达AMS指令
|
/// <summary>
|
/// 下达转运任务给AMS
|
/// </summary>
|
/// <param name="list"></param>
|
/// <returns></returns>
|
/// <History>[Hanhe(DBS)] 2018-5-23</History>
|
public SqlExecuteResult SendTask(List<TN_WM_TRANSPORT_TASKEntity> taskList)
|
{
|
try
|
{
|
List<JObject> sendParams = new List<JObject>();
|
foreach (TN_WM_TRANSPORT_TASKEntity m in taskList)
|
{
|
JObject sendParam = new JObject();
|
sendParam.Add("businessType", "转运");
|
sendParam.Add("whNoFrom", m.CN_S_STOCK_CODE);
|
sendParam.Add("whNoTo", m.CN_S_STOCK_CODE);
|
sendParam.Add("sysName", "WMS");
|
sendParam.Add("deviceName", "WMS");
|
sendParam.Add("taskNo", m.CN_S_TASK_NO);
|
sendParam.Add("locationFrom", m.CN_S_START_BIT);
|
sendParam.Add("locationTo", m.CN_S_END_BIT);
|
sendParam.Add("priority", m.CN_N_PRIORITY);
|
sendParam.Add("areaTo", (m.END_AREAS == null || m.END_AREAS.Count == 0) ? null : JsonConvert.SerializeObject(m.END_AREAS));
|
sendParams.Add(sendParam);
|
}
|
return new InfRequest().SendTask(sendParams, "");
|
}
|
catch (Exception ex)
|
{
|
|
return new SqlExecuteResult() { Exception = ex };
|
}
|
}
|
#endregion
|
}
|
}
|
