| | |
|---|
| | | public class mesStockDataForRealMes |
|---|
| | | { |
|---|
| | | public static LogType _logType = LogType.mesStockDataForRealMes; |
|---|
| | | public static LogType _logTypeForInfo = LogType.mesStockDetailsInfo; |
|---|
| | | public static async void Handler() |
|---|
| | | { |
|---|
| | | while (true) |
|---|
| | |
|---|
| | | if (sendMesData.Count > 0) |
|---|
| | | { |
|---|
| | | SystemWarningMsg.mesStockDataForRealMes = $"{MyExtend.MsgTimeStr()},要推送{sendMesData.Count()}条!"; |
|---|
| | | ApiResponse<object> ret = null; |
|---|
| | | mesMsg ret = null; |
|---|
| | | List<InboundStockInfoToMes> pushData = new List<InboundStockInfoToMes>(); |
|---|
| | | foreach (var itemTask in sendMesData) |
|---|
| | | { |
|---|
| | | pushData.Add(new InboundStockInfoToMes() |
|---|
| | | { |
|---|
| | | identifier = Yitter.IdGenerator.YitIdHelper.NextId().ToString(), |
|---|
| | | containerCode = itemTask.containerCode, |
|---|
| | | createTime = itemTask.createTime?.ToString("yyyy-MM-dd HH:mm:ss"), |
|---|
| | | materialCode = itemTask.productCode, |
|---|
| | | materialCode = itemTask.materialCode, |
|---|
| | | materialName = itemTask.productName, |
|---|
| | | positionName = itemTask.positionName, |
|---|
| | | productName = itemTask.materialName, |
|---|
| | | serialNumber = itemTask.serialNumber, |
|---|
| | | supplier = itemTask.supplier, |
|---|
| | | version = itemTask.version, |
|---|
| | | Creator = "wms" |
|---|
| | | |
|---|
| | | }); |
|---|
| | | |
|---|
| | | } |
|---|
| | | ret = PushMesHandler.Mes_StockSend(pushData, _logType); |
|---|
| | | ret = PushMesHandler.Mes_StockSend(_logType, pushData, _logTypeForInfo); |
|---|
| | | SystemWarningMsg.mesStockDataForRealMes = $"{MyExtend.MsgTimeStr()},已推送结束，{sendMesData.Count()}条!返回:{JsonConvert.SerializeObject(ret)}"; |
|---|
| | | } |
|---|
| | | else |
|---|
