From d4f9900e343c2840d6c8fab05205e72109e3e678 Mon Sep 17 00:00:00 2001
From: yefei <yefei@ele-cloud.com>
Date: Tue, 17 Oct 2023 14:40:58 +0800
Subject: [PATCH] =?UTF-8?q?ariesy=20client=E5=8F=82=E6=95=B0=E6=8A=BD?=
 =?UTF-8?q?=E5=8F=96=E9=85=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/dxhy/core/task/SdnyClientTask.java    | 87 ++++++++++---------
 1 file changed, 46 insertions(+), 41 deletions(-)

diff --git a/dxhy-core/src/main/java/com/dxhy/core/task/SdnyClientTask.java b/dxhy-core/src/main/java/com/dxhy/core/task/SdnyClientTask.java
index 3fe32ba4..e599359d 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/task/SdnyClientTask.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/task/SdnyClientTask.java
@@ -37,6 +37,9 @@ public class SdnyClientTask extends AbstractController {
     @Value("${sdny.snYxUrl}")
     private String snYxUrl;
 
+    @Value("${sdny.client}")
+    private String client;
+
     @Value("${po.userName}")
     private String userName;
 
@@ -79,48 +82,50 @@ public class SdnyClientTask extends AbstractController {
                 scheduleJobService.updateById(scheduleJobEntity);
                 // 准备请求参数
                 // 需判断 设置不认证状态
-
-                List<GsClient> list = new ArrayList<>();
-                long startTime = System.currentTimeMillis();
-                SNSAPObject object = new SNSAPObject();
-                object.setSYSID("FPXT");
-                object.setIFYWID("FI846");
-                object.setBSKEY(UUID.randomUUID().toString().replace("-", ""));
-                object.setZFILED5("300");
-                object.setZDATA("");
-
-                //推送到SAP
-                log.info("推送山能数据:{}", JSONObject.toJSONString(object));
-                JSONObject request = new JSONObject();
-                request.put("IS_INPUT", object);
-
-                log.info("{}获取公司client入参:{}", LOGGER_MSG, request.toJSONString());
-                String result = HttpUtils.sendPo(snYxUrl, request.toJSONString(), userName, password);
-                log.info("{}获取公司client出参:{}", LOGGER_MSG, result);
-                PoCommonResponseParam poCommonResponseParam = JsonUtils.getInstance().parseObject(result, PoCommonResponseParam.class);
-                EsOutput es_output = poCommonResponseParam.getES_OUTPUT();
-                String ztype = es_output.getZTYPE();
-                String zmessage = es_output.getZMESSAGE();
-                Object zdata = es_output.getZDATA();
-                if ("s".equals(ztype)) {
-                    List<Map<String, String>> gsClientList = JsonUtils.getInstance().parseObject(zdata.toString(), List.class);
-                    gsClientList.stream().forEach(f -> {
-                        GsClient gsClient = new GsClient();
-                        gsClient.setGsdm(ObjectUtil.isNull(f.get("BUKRS")) ? "" : f.get("BUKRS").toString());
-                        gsClient.setGsmc(ObjectUtil.isNull(f.get("BUTXT")) ? "" : f.get("BUTXT").toString());
-                        gsClient.setClient(ObjectUtil.isNull(f.get("MANDT")) ? "" : f.get("MANDT").toString());
-                        gsClient.setCreateTime(new Date());
-                        list.add(gsClient);
-                    });
-                } else {
-                    log.error("{}client:{},获取公司client出错:{}", LOGGER_MSG, "200", zmessage);
+                String[] split = client.split(",");
+                for(int i = 0;i < split.length;i++) {
+                    List<GsClient> list = new ArrayList<>();
+                    long startTime = System.currentTimeMillis();
+                    SNSAPObject object = new SNSAPObject();
+                    object.setSYSID("FPXT");
+                    object.setIFYWID("FI846");
+                    object.setBSKEY(UUID.randomUUID().toString().replace("-", ""));
+                    object.setZFILED5(split[i]);
+                    object.setZDATA("");
+
+                    //推送到SAP
+                    log.info("推送山能数据:{}", JSONObject.toJSONString(object));
+                    JSONObject request = new JSONObject();
+                    request.put("IS_INPUT", object);
+
+                    log.info("{}获取公司client入参:{}", LOGGER_MSG, request.toJSONString());
+                    String result = HttpUtils.sendPo(snYxUrl, request.toJSONString(), userName, password);
+                    log.info("{}获取公司client出参:{}", LOGGER_MSG, result);
+                    PoCommonResponseParam poCommonResponseParam = JsonUtils.getInstance().parseObject(result, PoCommonResponseParam.class);
+                    EsOutput es_output = poCommonResponseParam.getES_OUTPUT();
+                    String ztype = es_output.getZTYPE();
+                    String zmessage = es_output.getZMESSAGE();
+                    Object zdata = es_output.getZDATA();
+                    if ("s".equals(ztype)) {
+                        List<Map<String, String>> gsClientList = JsonUtils.getInstance().parseObject(zdata.toString(), List.class);
+                        gsClientList.stream().forEach(f -> {
+                            GsClient gsClient = new GsClient();
+                            gsClient.setGsdm(ObjectUtil.isNull(f.get("BUKRS")) ? "" : f.get("BUKRS").toString());
+                            gsClient.setGsmc(ObjectUtil.isNull(f.get("BUTXT")) ? "" : f.get("BUTXT").toString());
+                            gsClient.setClient(ObjectUtil.isNull(f.get("MANDT")) ? "" : f.get("MANDT").toString());
+                            gsClient.setCreateTime(new Date());
+                            list.add(gsClient);
+                        });
+                    } else {
+                        log.error("{}client:{},获取公司client出错:{}", LOGGER_MSG, "200", zmessage);
+                    }
+                    log.info("{}删除gs_client表数据", LOGGER_MSG);
+                    gsClientMapper.deleteAll();
+                    log.info("{}插入gs_client表", LOGGER_MSG);
+                    gsClientMapper.insertList(list);
+                    long endTime = System.currentTimeMillis();
+                    log.debug("{}任务结束，耗时:{}", LOGGER_MSG, endTime - startTime);
                 }
-                log.info("{}删除gs_client表数据", LOGGER_MSG);
-                gsClientMapper.deleteAll();
-                log.info("{}插入gs_client表", LOGGER_MSG);
-                gsClientMapper.insertList(list);
-                long endTime = System.currentTimeMillis();
-                log.debug("{}任务结束，耗时:{}", LOGGER_MSG, endTime - startTime);
 
             } catch (Exception e) {
                 e.printStackTrace();