diff --git a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java index 194793e1c..e021f4c21 100644 --- a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java +++ b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java @@ -1,7 +1,6 @@ package com.logpm.factorydata.mengtian.mq; import cn.hutool.core.collection.CollUtil; -import cn.hutool.core.convert.Convert; import cn.hutool.core.util.EnumUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; @@ -321,13 +320,13 @@ public class NodeDataPushListener { String resBody = execute.body(); log.info("推送工厂结果:{}", resBody); JSONObject entries = JSONUtil.parseObj(resBody); - int resultCode = entries.getInt("Result"); + String resultCode = entries.getStr("Result"); // 存入日志表 entity.setContent(body); entity.setOperationCode(operationCode); entity.setSendUrl(mengTianProperties.getHost() + url); entity.setResultContent(resBody); - entity.setSendStatus(Convert.toStr(resultCode)); + entity.setSendStatus(StrUtil.isEmpty(resultCode) ? "0" : resultCode); factoryNodePushService.save(entity); }