|
|
@ -579,8 +579,9 @@ namespace WY.NewJit.Job.ConsoleApp.Messages |
|
|
|
if (isRepeat == true) |
|
|
|
{ |
|
|
|
var succObj = _r100CheckDomainSrv.InsertR100Repeat(msgReceiveObj, r100Bill); |
|
|
|
_logger.LogDebug(_errorMessagePrefix + $"是重复报文:{msgReceiveObj.MessageFileName}"); |
|
|
|
return; |
|
|
|
string msg = _errorMessagePrefix + $"R100是重复报文:{msgReceiveObj.MessageFileName}"; |
|
|
|
_logger.LogDebug(msg); |
|
|
|
throw new Exception(msg); |
|
|
|
} |
|
|
|
} |
|
|
|
else if (billResObj.M100Bill != null) |
|
|
@ -590,8 +591,9 @@ namespace WY.NewJit.Job.ConsoleApp.Messages |
|
|
|
if (isRepeat == true) |
|
|
|
{ |
|
|
|
var succObj = _m100CheckDomainService.InsertM100RepeatBill(msgReceiveObj, m100Bill); |
|
|
|
_logger.LogDebug(_errorMessagePrefix + $"是重复报文:{msgReceiveObj.MessageFileName}"); |
|
|
|
return; |
|
|
|
string msg = _errorMessagePrefix + $"M100是重复报文:{msgReceiveObj.MessageFileName}"; |
|
|
|
_logger.LogDebug(msg); |
|
|
|
throw new Exception(msg); |
|
|
|
} |
|
|
|
} |
|
|
|
#endregion
|
|
|
@ -600,6 +602,10 @@ namespace WY.NewJit.Job.ConsoleApp.Messages |
|
|
|
string unknowPartCode = UpdatePartLargeType(billResObj); |
|
|
|
if (unknowPartCode.HasValue()) //有不识别零件
|
|
|
|
{ |
|
|
|
msgReceiveObj.ErrorCount = 3; |
|
|
|
msgReceiveObj.ErrorMessage = $"存在不识别的零件{unknowPartCode}"; |
|
|
|
_messageReceiveRepository.UpdateAsync(msgReceiveObj).GetAwaiter().GetResult(); |
|
|
|
|
|
|
|
throw new Exception($"存在不识别的零件{unknowPartCode}:{msgReceiveObj.MessageFileName}"); //零件大类没有维护时,直接返回解析失败,程序执行中断,报警(不进入未知总成)
|
|
|
|
} |
|
|
|
#endregion
|
|
|
@ -681,7 +687,7 @@ namespace WY.NewJit.Job.ConsoleApp.Messages |
|
|
|
msgReceiveObj.ErrorCount = errCnt + 1; |
|
|
|
msgReceiveObj.ErrorMessage = ex0.Message; |
|
|
|
msgReceiveObj.SetReceiveStatus(ReceiveStatusEnum.Received); |
|
|
|
_messageReceiveRepository.UpdateAsync(msgReceiveObj); |
|
|
|
var succObj = _messageReceiveRepository.UpdateAsync(msgReceiveObj); |
|
|
|
|
|
|
|
string errorMsg = $"{errorHeader}:{ex0.Message}"; |
|
|
|
_logRemindDomainService.WriteLogRemind(fileName, errorMsg, LogTypeEnum.None); |
|
|
|