using Hanhe.iWCS.Business;
|
using Hanhe.iWCS.Common;
|
using Hanhe.iWCS.DeviceDriver;
|
using Hanhe.iWCS.MData;
|
using Hanhe.iWCS.Model;
|
using MongoDB.Bson;
|
using MongoDB.Driver;
|
using MongoDB.Driver.Builders;
|
using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace Hanhe.iWCS.TaizhouGEMTwoProtocol
|
{
|
public class AMSHelper
|
{
|
|
public static HHAmsExecuteResult CreateTask(string taskNo, string locationFrom, string locationTo, string type, int priorityNo, string batchNo = "",string timeStamp = "") {
|
var result = new HHAmsExecuteResult();
|
List<HHAmsTaskEntity> entities = new List<HHAmsTaskEntity>();
|
HHAmsTaskEntity entity = new HHAmsTaskEntity();
|
entity.batchNo = batchNo;
|
entity.taskNo = taskNo;
|
entity.businessType = type;
|
entity.locationFrom = locationFrom;
|
entity.locationTo = locationTo;
|
entity.priority = priorityNo;
|
entity.ext2 = timeStamp;
|
entity.deviceName = "AMS";
|
entity.sysName = "AMS";
|
entities.Add(entity);
|
|
result = AddTask(entities);
|
|
return result;
|
}
|
public static HHAmsExecuteResult AddTask(List<HHAmsTaskEntity> data) {
|
HardwareAccessObject hao = HardwareAccessHelper.Instance.GetEquipmentsHAO(Constants.WMS_DEVICE_TYPE_AMS);
|
//string url = "http://10.15.73.28:9435/api/AmsInf/"; //正式环境需要改回去
|
string msg = "";
|
string feedback = "";
|
|
var param = JsonConvert.SerializeObject(data);
|
HHAmsExecuteResult amsResponse = new HHAmsExecuteResult() ;
|
if (hao != null) {
|
//if (string.IsNullOrEmpty(url)) {
|
try {
|
string webAPIUrl = hao._WebApiClientInstance.WebApiUrl.Replace("AmsInf", "HHAms") + "AddTask";
|
//string webAPIUrl = url.Replace("AmsInf", "HHAms") + "AddTask";
|
Console.WriteLine(webAPIUrl);
|
feedback = new WebApiHelper().WebPost(webAPIUrl, param);
|
if (!string.IsNullOrEmpty(feedback)) {
|
amsResponse = JsonConvert.DeserializeObject<HHAmsExecuteResult>(feedback);
|
//var res = feedback.Replace("{", "").Replace("}", "").Replace(":", "=").Replace(",", ";").Replace('"', ' ');
|
if (amsResponse.success == true) {
|
msg = "【ams create task】success！;WebUrl=" + hao.WebUrl + "AmsInf/AddTask;param=" + param;
|
}
|
else {
|
string errMsg = amsResponse.errMsg;
|
msg = "【ams create task】fail！err=" + errMsg + ";WebUrl=" + webAPIUrl + ";param=" + param;
|
}
|
}
|
else {
|
string errMsg = "can't find the address";
|
msg = "【ams create task】fail！err=" + errMsg + ";WebUrl=" + webAPIUrl + ";param=" + param;
|
}
|
}
|
catch (Exception e) {
|
CMMLog.Error(string.Format("【ams create task】fail！err={0}", e.Message), e);
|
}
|
}
|
else {
|
msg = string.Format("ams create task fail，ams workcenter not set！");
|
}
|
if (msg != "") {
|
CMMLog.Info(msg);
|
}
|
return amsResponse;
|
|
//{"Success":false,"ErrorCode":"1","FailList":[{"Agv_TaskNo":"sample string 5","Error_Code":"1","Err_Msg":"未配置相关设备的事件解释！"},{"Agv_TaskNo":"sample string 5","Error_Code":"1","Err_Msg":"未配置相关设备的事件解释！"},{"Agv_TaskNo":"sample string 5","Error_Code":"1","Err_Msg":"未配置相关设备的事件解释！"}]}
|
}
|
|
/// <summary>
|
/// 创建任务
|
/// </summary>
|
/// <param name="jasonStr"></param>
|
/// <returns></returns>
|
private static bool CreateAMSTask(string jasonStr) {
|
bool bResult = false;
|
HardwareAccessObject AMSCreateHao = HardwareAccessHelper.Instance.GetEquipmentsHAO(Constants.WMS_DEVICE_TYPE_AMS);
|
if (AMSCreateHao != null) {
|
try {
|
string webAPIUrl = AMSCreateHao._WebApiClientInstance.WebApiUrl.Replace("AmsInf", "HHAms");
|
string amsReturnValue = AMSCreateHao._WebApiClientInstance.GetWebRequest(webAPIUrl + "AddTask", jasonStr, "application/json");
|
var dynamicObject = JsonConvert.DeserializeObject<dynamic>(amsReturnValue);
|
if (dynamicObject.success == "True" || dynamicObject.success == "true") {
|
bResult = true;
|
CMMLog.Info("AMS任务创建成功;请求参数=" + jasonStr + "");
|
}
|
else {
|
CMMLog.Info("AMS任务创建失败;请求参数=" + jasonStr + "");
|
}
|
}
|
catch (Exception ex) {
|
CMMLog.Info("AMS任务创建异常;请求参数=" + jasonStr + ";Exception=" + ex.Message);
|
}
|
}
|
return bResult;
|
}
|
|
/// <summary>
|
/// 变更任务目的地
|
/// </summary>
|
/// <param name="jasonStr"></param>
|
/// <returns></returns>
|
public static bool ChangeTaskTargetBit(string jasonStr) {
|
bool bResult = false;
|
HardwareAccessObject AMSCreateHao = HardwareAccessHelper.Instance.GetEquipmentsHAO(Constants.WMS_DEVICE_TYPE_AMS);
|
if (AMSCreateHao != null) {
|
try {
|
string amsReturnValue = AMSCreateHao._WebApiClientInstance.GetWebRequest(AMSCreateHao._WebApiClientInstance.WebApiUrl + "ChangeTaskTargetBit", jasonStr, "application/json");
|
var dynamicObject = JsonConvert.DeserializeObject<dynamic>(amsReturnValue);
|
if (dynamicObject.Success == "True" || dynamicObject.Success == "true") {
|
bResult = true;
|
CMMLog.Info("AMS变更任务目的地成功;请求参数=" + jasonStr + "");
|
}
|
else {
|
CMMLog.Info("AMS变更任务目的地失败;请求参数=" + jasonStr + "");
|
}
|
}
|
catch (Exception ex) {
|
CMMLog.Info("AMS变更任务目的地异常;请求参数=" + jasonStr + ";Exception=" + ex.Message);
|
}
|
}
|
return bResult;
|
}
|
|
/// <summary>
|
/// 反馈AMS的状态
|
/// </summary>
|
/// <param name="taskNo"></param>
|
/// <param name="orderNo"></param>
|
/// <param name="actionCode"></param>
|
public static void SetStatus(string taskNo, int orderNo, string actionCode, string forkliftNo, bool success = false) {
|
HardwareAccessObject AMSHao = HardwareAccessHelper.Instance.GetEquipmentsHAO(Constants.WMS_DEVICE_TYPE_AMS);
|
if (AMSHao != null)
|
{
|
// if (actionCode == "2")
|
// {
|
//actionCode = "完成";
|
// }
|
string data = "{\"TaskNo\":\"" + taskNo + "\",\"OrderIndex\":\"" + orderNo + "\",\"TaskStatus\":\"" + actionCode + "\",\"ForkliftNo\":\"" + forkliftNo + "\",\"Success\":\"" + success + "\",\"ErrorMsg\":\"\"}";
|
CMMLog.Debug(data);
|
//string resultCode = AMSHao._WebApiClientInstance.GetWebRequest(AMSHao._WebApiClientInstance.WebApiUrl + "SetStatus?jsonData=" + data);
|
WebApiHelper api = new WebApiHelper();
|
api.WebPost(AMSHao._WebApiClientInstance.WebApiUrl + "SetStatus?jsonData=" + data, "");
|
}
|
}
|
|
/// <summary>
|
/// 消息交互日志
|
/// </summary>
|
/// <param name="taskNo"></param>
|
/// <param name="orderNo"></param>
|
/// <param name="cmd"></param>
|
/// <param name="statusText"></param>
|
/// <param name="success"></param>
|
/// <param name="errMsg"></param>
|
/// <param name="createUser"></param>
|
/// <param name="createUserName"></param>
|
public static void TaskTrackLogMessage(string taskNo, string orderNo, string cmd, string statusText, string remark = "") {
|
HardwareAccessObject AMSHao = HardwareAccessHelper.Instance.GetEquipmentsHAO(Constants.WMS_DEVICE_TYPE_AMS);
|
if (AMSHao != null) {
|
string data = "{\"CN_N_ORDER\":\"" + orderNo + "\",\"CN_S_CMD\":\"" + cmd + "\",\"CN_S_CREATOR\":\"wcs\",\"CN_S_CREATOR_NAME\":\"wcs\",\"CN_S_SUCCESS\":\"true\",\"CN_S_TASK_NO\":\"" + taskNo + "\",\"CN_S_TASK_STATUS\":\"" + statusText + "\",\"CN_S_ERROR\":\"" + remark + "\"}";
|
string resultCode = AMSHao._WebApiClientInstance.GetWebRequest(AMSHao._WebApiClientInstance.WebApiUrl + "TaskTrackLogMessage?jsonData=" + data);
|
}
|
}
|
|
|
|
public static void ChangeEndBitNew(TN_I_TASK_MST mstTask, out int agvBit) {
|
string newEndBitCode = mstTask.CN_S_END_BIT;
|
agvBit = StockInstance.Instance.GetAGVCodeForBitCode(newEndBitCode);
|
UpdateEndBit(mstTask, newEndBitCode, agvBit);
|
}
|
private static void UpdateEndBit(TN_I_TASK_MST mstTask, string newEndBitCode, int agvBit) {
|
var updateBuider = Update.Set("CN_S_END_BIT", newEndBitCode);//新目的地
|
updateBuider = updateBuider.Set("CN_N_END_AGV_BIT", agvBit);
|
MongoDBSingleton.Instance.Update<TN_I_TASK_DTL>(Query.EQ("CN_S_TASK_NO", mstTask.CN_S_TASK_NO), updateBuider, UpdateFlags.None);
|
var query = Query.EQ("_id", mstTask._id);
|
updateBuider = Update.Set("CN_S_END_BIT", newEndBitCode).Set("Ext3", "J2SSHB199");
|
updateBuider = updateBuider.Set("CN_S_END_AGVBIT", agvBit.ToString());
|
MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(query, updateBuider, UpdateFlags.None);
|
}
|
|
|
public class HHAmsTaskEntity
|
{
|
//public List<TransportInfo> transportInfo { get; set; }
|
public string batchNo { get; set; }
|
public string businessType { get; set; }
|
public string sysName { get; set; }
|
public string deviceName { get; set; }
|
public string taskNo { get; set; }
|
public string locationFrom { get; set; }
|
public string locationTo { get; set; }
|
public int priority { get; set; }
|
public string ext1 { get; set; }
|
public string ext2 { get; set; }
|
public string ext3 { get; set; }
|
//public class TransportInfo {
|
// /// <summary>
|
// /// 物料编码
|
// /// </summary>
|
// public string itemCode { get; set; }
|
|
// /// <summary>
|
// /// 物料扩展编码
|
// /// </summary>
|
// public string itemPCode { get; set; }
|
|
// /// <summary>
|
// /// 物料名称
|
// /// </summary>
|
// public string itemName { get; set; }
|
|
// /// <summary>
|
// /// 托盘码
|
// /// </summary>
|
// public string trayCode { get; set; }
|
|
// /// <summary>
|
// /// 物料重量
|
// /// </summary>
|
// public string itemWeight { get; set; }
|
|
// /// <summary>
|
// /// 物料特征
|
// /// </summary>
|
// public string itemFeatures { get; set; }
|
//}
|
|
}
|
public class HHAmsExecuteResult
|
{
|
public bool success { get; set; }
|
/// <summary>
|
/// 0:成功 1：数据异常 2：已存在任务 3：程序异常
|
/// </summary>
|
public string errCode { get; set; }
|
public string errMsg { get; set; }
|
|
private List<HHAmsAddTaskResult> _failList = new List<HHAmsAddTaskResult>();
|
public List<HHAmsAddTaskResult> failList {
|
get { return _failList; }
|
set { _failList = value; }
|
}
|
}
|
public class HHAmsAddTaskResult
|
{
|
public string taskNo { get; set; }
|
public string errCode { get; set; }
|
public string errMsg { get; set; }
|
}
|
public class WMSResponseModel
|
{
|
//{"success":false,"errCode":null,"errMsg":"算法返回结果库存不足","okList":[],"failList":[{"index":0,"errCode":null,"errMsg":"算法返回结果库存不足"}],"tasks":[]}
|
public bool success { get; set; }
|
public string errMsg { get; set; }
|
public string errCode { get; set; }
|
//public OKInfo[] tasks { get; set; }
|
//public FailInfo[] failList { get; set; }
|
public OKInfo[] okList { get; set; }
|
public class FailInfo
|
{
|
public int index { get; set; }
|
public string errCode { get; set; }
|
public string errMsg { get; set; }
|
}
|
|
public class OKInfo
|
{
|
public string taskNo { get; set; }
|
public string startStock { get; set; }
|
public string startArea { get; set; }
|
public string startBit { get; set; }
|
public string endStock { get; set; }
|
public string endArea { get; set; }
|
public string endBit { get; set; }
|
}
|
}
|
|
|
|
|
internal static void UpdatePriority(string taskNo, int priority) {
|
//http://localhost:60116/api/AmsInf/UpdatePriority?taskNo=12312313&priority=2
|
HardwareAccessObject AMSHao = HardwareAccessHelper.Instance.GetEquipmentsHAO(Constants.WMS_DEVICE_TYPE_AMS);
|
if (AMSHao != null) {
|
string data = string.Format("taskNo={0}&priority={1}", taskNo, priority);
|
CMMLog.Debug(data);
|
//string resultCode = AMSHao._WebApiClientInstance.GetWebRequest(AMSHao._WebApiClientInstance.WebApiUrl + "UpdatePriority?" + data);
|
WebApiHelper api = new WebApiHelper();
|
api.WebPost(AMSHao._WebApiClientInstance.WebApiUrl + "UpdatePriority?" + data, "");
|
}
|
}
|
}
|
}
|
