| | |
| | | CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"RabbitMQ 物料 解析异常:{ex.Message}"); |
| | | } |
| | | } |
| | | |
| | | //Dictionary<string, Task> dic_ispass = new Dictionary<string, Task>();///value为收到数据 |
| | | |
| | | public async Task<string> MESForBasketAsync(string ztype, string zlsn, string zlpn, string zstatus, string zversion, int timeoutMes = 30000) |
| | |
| | | { |
| | | |
| | | CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Information, $"RabbitMQ {keystr}二次接收 返回值正常 {tem.receive}"); |
| | | |
| | | |
| | | return tem.receive; |
| | | } |
| | | Thread.Sleep(1000); |
| | | } |
| | | MSGClasses.RemoveAll(u => u.key == keystr); |
| | | CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Information, $"RabbitMQ {keystr}二次接收 返回值为空"); |
| | | if (MSGClasses.Count > 10) |
| | | { |
| | | MSGClasses.RemoveAt(0); |
| | | CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Information, $"RabbitMQ二次接收数据超过十条 清除第一条超时数据"); |
| | | } |
| | | //MSGClasses.RemoveAll(u => u.key == keystr); |
| | | |
| | | |
| | | return null; |
| | | } |