推送进口订单修改

This commit is contained in:
zhaoqing
2026-05-26 17:55:14 +08:00
parent fc87d5cefb
commit 531901f0ff
3 changed files with 19 additions and 4 deletions
@@ -61,4 +61,7 @@ public class GwLog implements Serializable {
@ApiModelProperty("删除标记:1-正常,0-删除") @ApiModelProperty("删除标记:1-正常,0-删除")
private Integer delFlag; private Integer delFlag;
// @ApiModelProperty("推送人姓名")
// private String pushByName;
} }
@@ -1987,7 +1987,7 @@ public class ReservationStockInOrderApplicationService {
gwStockInOrder.setOrderList(orderList); gwStockInOrder.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(gwStockInOrder)); gwLog.setRequestBody(com.alibaba.fastjson.JSONObject.toJSONString(gwStockInOrder));
gwLog.setResponseBody(""); gwLog.setResponseBody("");
@@ -1997,6 +1997,7 @@ public class ReservationStockInOrderApplicationService {
gwLog.setTopOrganizationId(topOrganizationId); gwLog.setTopOrganizationId(topOrganizationId);
gwLog.setOrganizationName(organizationName); gwLog.setOrganizationName(organizationName);
gwLog.setCreateBy(pushBy); gwLog.setCreateBy(pushBy);
// gwLog.setPushByName(pushByName);
gwLog.setCreateTime(new Date()); gwLog.setCreateTime(new Date());
gwLog.setDelFlag(1); gwLog.setDelFlag(1);
gwLogMapper.insert(gwLog); gwLogMapper.insert(gwLog);
@@ -2025,7 +2026,7 @@ public class ReservationStockInOrderApplicationService {
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();
@@ -2036,8 +2037,8 @@ public class ReservationStockInOrderApplicationService {
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 ReservationStockInOrderApi extends BaseController {
} }
} }
@ApiOperation("批量推送")
@PostMapping("/batchPush")
public AjaxResult batchPush(@RequestBody List<Long> idList){
if(idList == null || idList.isEmpty()){
return AjaxResult.error("没有数据需要推送");
}
return stockInOrderApplicationService.batchPush(idList);
}
} }