|
@@ -31,7 +31,13 @@ import java.util.function.Function;
|
|
|
public class WMSServiceImpl implements WMSService {
|
|
|
private static final String errorMsg = "当前下传数据中存在多个仓库的业务数据下传失败,请检查数据,一次只能下传一个仓库的业务数据";
|
|
|
|
|
|
- private static final ThreadPoolExecutor EXECUTOR = new ThreadPoolExecutor(512, 512, 1, TimeUnit.SECONDS, new LinkedBlockingQueue<>(4096));
|
|
|
+ private static final ThreadPoolExecutor EXECUTOR = new ThreadPoolExecutor(
|
|
|
+ 512,
|
|
|
+ 512,
|
|
|
+ 1,
|
|
|
+ TimeUnit.SECONDS,
|
|
|
+ new LinkedBlockingQueue<>(4096)
|
|
|
+ );
|
|
|
|
|
|
private static final String API = "/wms/api";
|
|
|
// 山西
|
|
@@ -48,6 +54,11 @@ public class WMSServiceImpl implements WMSService {
|
|
|
private static final String GZ = "http://10.0.30.225:8102";
|
|
|
// 海南
|
|
|
private static final String HN = "http://10.0.30.225:8109";
|
|
|
+ // 河南
|
|
|
+ // private static final String HEN = "http://10.0.30.225:8110";
|
|
|
+ // 云南
|
|
|
+ private static final String YN = "http://10.0.30.220:18999";
|
|
|
+
|
|
|
// 物流中心编码与WebService服务映射
|
|
|
private static final ConcurrentMap<String, String> WMS_MAPPING = new ConcurrentHashMap<String, String>() {{
|
|
|
put("D104", ""); // 山西鸿翔一心堂药业有限公司
|
|
@@ -61,7 +72,7 @@ public class WMSServiceImpl implements WMSService {
|
|
|
put("D106", CD); // 成都鸿翔一心堂药业有限公司
|
|
|
put("D109", HN); // 海南鸿翔一心堂药业有限公司
|
|
|
put("D301", HN); // 海南一心堂医药有限公司
|
|
|
- put("D100", ""); // 一心堂药业集团股份有限公司
|
|
|
+ put("D100", YN); // 一心堂药业集团股份有限公司
|
|
|
put("D300", ""); // 云南鸿云药业有限公司
|
|
|
put("D108", ""); // 天津鸿翔一心堂药业有限公司
|
|
|
put("D900", ""); // 一心到家科技公司(电商仓)
|
|
@@ -72,7 +83,8 @@ public class WMSServiceImpl implements WMSService {
|
|
|
|
|
|
@SneakyThrows
|
|
|
public WMSServiceImpl() {
|
|
|
- final String wsdl = IOUtils.toString(new ClassPathResource("WMSService.xml").getInputStream(), StandardCharsets.UTF_8);
|
|
|
+ // final String wsdl = IOUtils.toString(new ClassPathResource("WMSService.xml").getInputStream(), StandardCharsets.UTF_8);
|
|
|
+ final String wsdl = IOUtils.toString(new ClassPathResource("YN_WMSService.xml.xml").getInputStream(), StandardCharsets.UTF_8);
|
|
|
final String usrHome = System.getProperty("user.home");
|
|
|
for (Map.Entry<String, String> entry : WMS_MAPPING.entrySet()) {
|
|
|
final String bwkey = entry.getKey();
|
|
@@ -223,4 +235,24 @@ public class WMSServiceImpl implements WMSService {
|
|
|
WMSService::MT_KUNNR_IN_WMS10_2
|
|
|
);
|
|
|
}
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<DT_KUNNR_IN_RT_16> MT_KUNNR_IN_WMS16(List<DT_KUNNR_IN_16> params) {
|
|
|
+ return distribute(
|
|
|
+ "MT_KUNNR_IN_WMS16",
|
|
|
+ params,
|
|
|
+ DT_KUNNR_IN_16::getBWKEY,
|
|
|
+ WMSService::MT_KUNNR_IN_WMS16
|
|
|
+ );
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<DT_KUNNR_IN_RT_17> MT_KUNNR_IN_WMS17(List<DT_KUNNR_IN_17> params) {
|
|
|
+ return distribute(
|
|
|
+ "MT_KUNNR_IN_WMS17",
|
|
|
+ params,
|
|
|
+ DT_KUNNR_IN_17::getBWKEY,
|
|
|
+ WMSService::MT_KUNNR_IN_WMS17
|
|
|
+ );
|
|
|
+ }
|
|
|
}
|