保税仓推送订单修改

This commit is contained in:
zhaoqing
2026-05-27 14:41:30 +08:00
parent 1679403f56
commit 55c62ef7e5
2 changed files with 15 additions and 4 deletions
@@ -1147,7 +1147,7 @@ public class ReservationStockOutOrderApplicationService {
gwStockOutOrder.setOrderList(orderList); gwStockOutOrder.setOrderList(orderList);
GwLog gwLog = new GwLog(); GwLog gwLog = new GwLog();
gwLog.setType("企业国别"); gwLog.setType("出口订单");
gwLog.setBusinessId(id); gwLog.setBusinessId(id);
gwLog.setRequestBody(com.alibaba.fastjson.JSONObject.toJSONString(gwStockOutOrder)); gwLog.setRequestBody(com.alibaba.fastjson.JSONObject.toJSONString(gwStockOutOrder));
gwLog.setResponseBody(""); gwLog.setResponseBody("");
@@ -1185,7 +1185,7 @@ public class ReservationStockOutOrderApplicationService {
gwLog.setErrorMsg(responseString); gwLog.setErrorMsg(responseString);
updatePushStatus(id, 4, new Date(), pushBy,pushByName); updatePushStatus(id, 4, new Date(), pushBy,pushByName);
failCount++; failCount++;
failMsg.append("erpCountryCode:").append(id).append("失败;"); failMsg.append("id:").append(id).append("失败;");
} }
gwLogMapper.updateById(gwLog); gwLogMapper.updateById(gwLog);
response.close(); response.close();
@@ -1196,8 +1196,8 @@ public class ReservationStockOutOrderApplicationService {
gwLogMapper.updateById(gwLog); gwLogMapper.updateById(gwLog);
updatePushStatus(id, 4, new Date(), pushBy,pushByName); updatePushStatus(id, 4, new Date(), pushBy,pushByName);
failCount++; failCount++;
failMsg.append("erpCountryCode:").append(id).append("异常:").append(e.getMessage()).append(";"); failMsg.append("id:").append(id).append("异常:").append(e.getMessage()).append(";");
log.error("企业国别推送异常: id={}, error={}", id, e.getMessage()); log.error("保税仓推送异常: id={}, error={}", id, e.getMessage());
} finally { } finally {
try { try {
httpClient.close(); httpClient.close();
@@ -210,4 +210,15 @@ public class ReservationStockOutOrderApi extends BaseController {
return AjaxResult.success(result); return AjaxResult.success(result);
} }
@ApiOperation("批量推送")
@PostMapping("/batchPush")
public AjaxResult batchPush(@RequestBody List<Long> idList){
if(idList == null || idList.isEmpty()){
return AjaxResult.error("没有数据需要推送");
}
return stockOutOrderApplicationService.batchPush(idList);
}
} }