luminghui
/
sdny-jxpt
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ariesy client参数抽取配置

Browse Source
release
yefei 2 years ago
parent b5284da765
commit d4f9900e34
1 changed files with 46 additions and 41 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 87
      dxhy-core/src/main/java/com/dxhy/core/task/SdnyClientTask.java

87
dxhy-core/src/main/java/com/dxhy/core/task/SdnyClientTask.java
Unescape View File

@ -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();

Write Preview
Loading…
Cancel
Save