| | |
| | | @Autowired |
| | | private PlatformTransactionManager transactionManager; |
| | | |
| | | @Value("${mes-wk.base-url.test:http://192.168.0.41}") |
| | | @Value("${mes-wk.base-url.test:http://192.168.0.41:8080}") |
| | | private String mesWkBaseUrlTest; |
| | | |
| | | @Value("${mes-wk.base-url.prod:http://192.168.0.42}") |
| | | @Value("${mes-wk.base-url.prod:http://192.168.0.42:8080}") |
| | | private String mesWkBaseUrlProd; |
| | | |
| | | @Value("${mes-wk.auth.ent-code:lfd}") |
| | |
| | | // 模拟调用仓库1接口 |
| | | private String syncToWarehouse1(ErpMat mat) { |
| | | log.info("Calling Warehouse 1 API for mat: {}", mat.getMatNr()); |
| | | return callMatSyncApi(mat, "http://localhost:8888"); |
| | | return callMatSyncApi(mat, "http://localhost:8080"); |
| | | } |
| | | |
| | | // 模拟调用仓库2接口 |
| | | private String syncToWarehouse2(ErpMat mat) { |
| | | log.info("Calling Warehouse 2 API for mat: {}", mat.getMatNr()); |
| | | return callMatSyncApi(mat, "http://localhost:8080"); |
| | | return callMatSyncApi(mat, "http://192.168.0.17:8080"); |
| | | } |
| | | |
| | | // 模拟调用仓库3接口 |
| | | private String syncToWarehouse3(ErpMat mat) { |
| | | log.info("Calling Warehouse 3 API for mat: {}", mat.getMatNr()); |
| | | return callMatSyncApi(mat, "http://localhost:8080"); |
| | | return callMatSyncApi(mat, "http://192.168.0.17:8080"); |
| | | } |
| | | |
| | | private String callMatSyncApi(ErpMat mat, String baseUrl) { |
| | |
| | | } else { |
| | | throw new CoolException("不支持的wkType:" + param.getWkType()); |
| | | } |
| | | payload.put("warehouseId", "WH01"); |
| | | |
| | | try { |
| | | Map<String, Object> res = callMesWkApi(baseUrl, path, headers, payload, bizDesc); |
| | |
| | | } |
| | | String wh = wareHouseId.trim(); |
| | | if ("WH01".equalsIgnoreCase(wh) || "WH1".equalsIgnoreCase(wh)) { |
| | | return "http://localhost:8888"; |
| | | return "http://localhost:8080"; |
| | | } |
| | | if ("WH02".equalsIgnoreCase(wh) || "WH2".equalsIgnoreCase(wh)) { |
| | | return "http://localhost:8080"; |
| | | return "http://192.168.0.17:8080"; |
| | | } |
| | | if ("WH03".equalsIgnoreCase(wh) || "WH3".equalsIgnoreCase(wh)) { |
| | | return "http://localhost:8080"; |
| | | return "http://192.168.0.17:8080"; |
| | | } |
| | | return null; |
| | | } |
| | |
| | | return "http://" + v; |
| | | } |
| | | } |
| | | |
| | | String wkType = param != null ? param.getWkType() : null; |
| | | String norm = wkType == null ? "" : wkType.trim().toLowerCase(); |
| | | if (norm.contains("test") || norm.contains("41") || norm.contains("测试")) { |
| | | boolean result = true; |
| | | if (result) { |
| | | return normalizeHttpBaseUrl(mesWkBaseUrlTest); |
| | | } |
| | | return normalizeHttpBaseUrl(mesWkBaseUrlProd); |
| | |
| | | // 模拟调用仓库1接口 |
| | | private String syncOrderToWarehouse1(ErpOrder order, List<ErpOrderDetl> details, Integer orderType) { |
| | | log.info("Calling Warehouse 1 API for order: {}", order.getOrderNo()); |
| | | return callOrderSyncApi(order, details, orderType, "http://localhost:8888"); |
| | | return callOrderSyncApi(order, details, orderType, "http://localhost:8080"); |
| | | } |
| | | |
| | | // 模拟调用仓库2接口 |
| | | private String syncOrderToWarehouse2(ErpOrder order, List<ErpOrderDetl> details, Integer orderType) { |
| | | log.info("Calling Warehouse 2 API for order: {}", order.getOrderNo()); |
| | | return callOrderSyncApi(order, details, orderType, "http://localhost:8080"); |
| | | return callOrderSyncApi(order, details, orderType, "http://192.168.0.17:8080"); |
| | | } |
| | | |
| | | // 模拟调用仓库3接口 |
| | | private String syncOrderToWarehouse3(ErpOrder order, List<ErpOrderDetl> details, Integer orderType) { |
| | | log.info("Calling Warehouse 3 API for order: {}", order.getOrderNo()); |
| | | return callOrderSyncApi(order, details, orderType, "http://localhost:8080"); |
| | | return callOrderSyncApi(order, details, orderType, "http://192.168.0.17:8080"); |
| | | } |
| | | |
| | | private String callOrderSyncApi(ErpOrder order, List<ErpOrderDetl> details, Integer orderType, String baseUrl) { |
| | |
| | | param.setOrderNo(order.getOrderNo()); |
| | | param.setOrderType(order.getWkType()); |
| | | param.setOrderTime(DateUtils.convert(new Date(order.getBusinessTime()))); |
| | | param.setWareHouseId(order.getWarehouseId()); |
| | | |
| | | List<DetlDto> detlDtos = new ArrayList<>(); |
| | | for (ErpOrderDetl d : details) { |
| | |
| | | url, |
| | | request, |
| | | null, |
| | | null, |
| | | request, |
| | | response, |
| | | success |
| | | ); |