using iWareLog.ORM;
|
using iWareLog.LOG.Entity;
|
using iWareLog.LOG.Dao;
|
using iWareCommon.Common.Service;
|
using iWareCommon.Utils;
|
using System;
|
using iWareCommon.Common.EnumType;
|
using Newtonsoft.Json;
|
using iWareLog.Properties;
|
using iWareCommon.Common.Entity;
|
using System.Linq;
|
|
namespace iWareLog.LOG.Service
|
{
|
public class FailSentMessageService : CommonService<FailSentMessageEntity, LOGERRORFailSentMessage, DbModelLog>
|
{
|
private static object Lock = new object();
|
|
private FailSentMessageService() : base(FailSentMessageDao.GetInstance()) { }
|
|
private static FailSentMessageService Instance = null;
|
|
/// <summary>
|
/// 获取单例的方法
|
/// </summary>
|
/// <returns>log服务的单例实体</returns>
|
public static FailSentMessageService GetInstance()
|
{
|
|
if (Instance == null)
|
{
|
lock (Lock)
|
{
|
if (Instance == null)
|
{
|
Instance = new FailSentMessageService();
|
}
|
}
|
}
|
return Instance;
|
}
|
/// <summary>
|
/// 重新发送
|
/// </summary>
|
/// <param name="message"></param>
|
/// <param name="msg"></param>
|
/// <returns></returns>
|
public bool ReSend(int id, out string msg)
|
{
|
using (var dbModel = new DbModelLog())
|
{
|
try
|
{
|
msg = "";
|
var url = "";
|
|
var message = dbModel.LOGERRORFailSentMessages.FirstOrDefault(x => x.id == id);
|
|
if (message == null)
|
{
|
msg = string.Format("没有找到id为{0}的记录", id);
|
return false;
|
}
|
|
switch (message.url)
|
{
|
case "pushstatusforpreheating":
|
case "pushstatusforheatstorage":
|
case "pushstatusforbufferfeed":
|
case "preheatstoragefinish":
|
case "pushstatusforft":
|
case "pushstatusforecmfeedbyrcs":
|
case "pushstatusforecmblankingbyrcs":
|
case "pushstatusforheattrans":
|
case "pushstatusforartificialqualityinspection":
|
case "heatstoroutbindrfid":
|
case "heatstoroutbindfinish":
|
case "pushstatusforbuffertrans":
|
url = Resources.WipUrl + @"/";
|
break;
|
case "syncmaterialinfo":
|
case "materialstatemodify":
|
case "getloadingtablestatus":
|
case "getecmtablestatus":
|
case "businessexception":
|
case "equipwarn":
|
case "equipstatus":
|
case "agvrealtimelocation":
|
case "outstoragecompleted":
|
case "movestoragecompleted":
|
case "bufferlayingoffcompleted":
|
case "artificialwarehousing":
|
case "processcardforwcs":
|
case "resetprocesscardprintqueue":
|
url = Resources.WipUrl2 + @"/";
|
break;
|
case "reparsetask":
|
break;
|
|
|
}
|
|
var responseStr = HttpHelper.GetHttpResponse(url + message.url, JsonConvert.DeserializeObject(message.requeststr), 5000);
|
var resFormat = JsonConvert.DeserializeObject<ResEntity>(responseStr);
|
|
message.isok = resFormat.resCode == "00000" ? (int)EYesOrNo.是 : (int)EYesOrNo.否;
|
|
message.updatetime = DateTime.Now;
|
|
message.retrytimes += 1;
|
|
dbModel.SaveChanges();
|
|
if (message.isok == (int)EYesOrNo.否)
|
{
|
msg = resFormat.resMsg;
|
}
|
|
return message.isok == (int)EYesOrNo.是;
|
|
}
|
catch (Exception ex)
|
{
|
msg = ex.Message;
|
var message = dbModel.LOGERRORFailSentMessages.FirstOrDefault(x => x.id == id);
|
message.isok = (int)EYesOrNo.否;
|
|
message.updatetime = DateTime.Now;
|
|
message.retrytimes += 1;
|
|
dbModel.SaveChanges();
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "ReSend", msg);
|
return false;
|
}
|
}
|
}
|
|
public bool PushBusinessException(int id, out string msg)
|
{
|
using (var dbModel2 = new DbModelLog())
|
{
|
try
|
{
|
msg = "";
|
|
var message = dbModel2.LOGERRORFailSentMessages.FirstOrDefault(x => x.id == id);
|
|
if (message == null)
|
{
|
msg = string.Format("没有找到id为{0}的记录", id);
|
return false;
|
}
|
|
var requestBody = new
|
{
|
sysCode = "WCS",
|
taskNo = StringHelper.GetValue(message.requeststr, "taskNo"),
|
processCardNumber = StringHelper.GetValue(message.requeststr, "processCardNumber"),
|
exceptionCode = "001",
|
exceptionMsg = message.resmsg,
|
timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
|
};
|
|
var responseStr = HttpHelper.GetHttpResponse(Resources.WipUrl2 + @"/businessexception", requestBody, 5000);
|
|
LogTextHelper.WriteLine(Resources.LogDir, "PushBusinessException:responseStr = {0}", responseStr);
|
|
return true;
|
}
|
catch (Exception ex)
|
{
|
msg = ex.Message;
|
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "PushBusinessException", msg);
|
return false;
|
}
|
|
}
|
|
}
|
|
|
}
|
}
|
