| | |
| | | { |
| | | var value = await _rep.AsQueryable().Where(x => x.PackageCode == input.PackageCode).FirstAsync(); |
| | | if (value == null) throw Oops.Oh("包装号不存在"); |
| | | if (value.PushStatus != (int)PushStatusEnum.NotPush || value.PushStatus != (int)PushStatusEnum.Pushing) throw Oops.Oh("重复推送"); |
| | | if (value.PushStatus != PushStatusEnum.NotPush || value.PushStatus != PushStatusEnum.Pushing) throw Oops.Oh("重复推送"); |
| | | string url = "http://localhost:8088/api/getwmstask/getwmstask"; |
| | | var respon = await url.SetHttpMethod(HttpMethod.Post).SetBody(input).PostAsStringAsync(); |
| | | var data = respon.FromJson<Respone>(); |
| | | if (data.iState == 1) |
| | | { |
| | | value.PushStatus = (int)PushStatusEnum.PushSuccess; |
| | | value.PushStatus = PushStatusEnum.PushSuccess; |
| | | value.ApiMessage = data.message; |
| | | value.PushNum++; |
| | | } |
| | | else |
| | | { |
| | | value.PushStatus = (int)PushStatusEnum.Pushing; |
| | | value.PushStatus = PushStatusEnum.Pushing; |
| | | value.ApiMessage = data.message; |
| | | value.PushNum++; |
| | | if (value.PushNum == 3) |
| | | { |
| | | value.PushStatus = (int)PushStatusEnum.PushFail; |
| | | value.PushStatus = PushStatusEnum.PushFail; |
| | | } |
| | | } |
| | | await _rep.UpdateAsync(value); |
| | |
| | | } |
| | | else |
| | | { |
| | | addItem.PushStatus = outPushStatus; |
| | | |
| | | } |
| | | |
| | | } |