src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/common/config/ControllerResAdvice.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
@@ -56,6 +56,8 @@ private OpenService openService; @Autowired private SnowflakeIdWorker snowflakeIdWorker; @Autowired private ApiLogService apiLogService; @Override @Transactional @@ -289,7 +291,8 @@ for (DetlDto detlDto : detlDtos) { mesCombParam.getList().add(new MesCombParam.Detl(detlDto.getMatnr(), detlDto.getAnfme())); } String response; String response = ""; boolean success = false; try { response = new HttpHandler.Builder() .setUri(MesConstant.URL) @@ -299,7 +302,7 @@ .doPost(); JSONObject jsonObject = JSON.parseObject(response); if (jsonObject.getInteger("code").equals(200)) { log.info("请求接口成功!!!"); success = true; } else if (jsonObject.getInteger("code").equals(500)) { log.error("请求接口失败!!!url:{};request:{};response:{}", MesConstant.URL+MesConstant.PACK_DOWN_URL, JSON.toJSONString(mesCombParam), response); throw new CoolException(jsonObject.getString("msg")); @@ -310,6 +313,19 @@ } catch (Exception e) { log.error("fail", e); throw new CoolException(e.getMessage()); } finally { try { // 保存接口日志 // apiLogService.save( // "打包下线帮托上报", // MesConstant.URL + MesConstant.PACK_DOWN_URL, // null, // "127.0.0.1", // JSON.toJSONString(mesCombParam), // response, // success // ); } catch (Exception e) { log.error("", e); } } } src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java
@@ -6,6 +6,7 @@ import com.core.exception.CoolException; import com.zy.asrs.entity.Order; import com.zy.asrs.entity.OrderDetl; import com.zy.asrs.service.ApiLogService; import com.zy.asrs.service.OrderDetlService; import com.zy.asrs.service.OrderService; import com.zy.asrs.task.AbstractHandler; @@ -35,6 +36,8 @@ private OrderService orderService; @Autowired private OrderDetlService orderDetlService; @Autowired private ApiLogService apiLogService; @Transactional public ReturnT<String> start(Order order) { @@ -47,9 +50,10 @@ for (OrderDetl orderDetl : orderDetls) { pakinParam.getList().add(new MesPakinParam.Detl(orderDetl.getMatnr(), orderDetl.getAnfme())); } String response = ""; boolean success = false; try { String response = new HttpHandler.Builder() response = new HttpHandler.Builder() .setUri(MesConstant.URL) .setPath(MesConstant.PAKIN_URL) .setJson(JSON.toJSONString(pakinParam)) @@ -57,6 +61,7 @@ .doPost(); JSONObject jsonObject = JSON.parseObject(response); if (jsonObject.getInteger("code").equals(200)) { success = true; // 修改订单状态 4.完成 ===>> 6.已上报 if (!orderService.updateSettle(order.getId(), 6L, null)) { throw new CoolException("服务器内部错误,请联系管理员"); @@ -69,6 +74,19 @@ log.error("fail", e); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return FAIL.setMsg(e.getMessage()); } finally { try { // 保存接口日志 // apiLogService.save( // "成品库入库上报", // MesConstant.URL + MesConstant.PAKIN_URL, // null, // "127.0.0.1", // JSON.toJSONString(pakinParam), // response, // success // ); } catch (Exception e) { log.error("", e); } } return SUCCESS; } src/main/java/com/zy/common/config/ControllerResAdvice.java
@@ -51,7 +51,7 @@ IpTools.gainRealIp(request), JSON.toJSONString(request.getParameterMap()), JSON.toJSONString(o), Boolean.TRUE String.valueOf(((R) o).get("code")).equalsIgnoreCase("200") ); } }