钢坯实绩 异常处理 sign 验证是否传值

zgzt-sys-java/jeecg-module-conn/src/main/java/org/jeecg/modules/push/utils/MqttClientCallback.java

@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import lombok.extern.slf4j.Slf4j;
 import org.eclipse.paho.client.mqttv3.*;
 import org.jeecg.common.util.SpringContextHolder;
+import org.jeecg.common.util.oConvertUtils;
 import org.jeecg.modules.billetActual.entity.BilletBasicInfo;
 import org.jeecg.modules.billetActual.entity.BilletBasicInfoException;
 import org.jeecg.modules.billetActual.service.IBilletBasicInfoExceptionService;
@@ -20,6 +21,7 @@ import org.jeecg.modules.heatsActuals.entity.HeatsActuals;
 import org.jeecg.modules.heatsActuals.service.IHeatsActualsService;
 import org.jeecg.modules.stackingAndLoadingVehicles.service.IStackingAndLoadingVehiclesService;
 import org.jeecg.modules.storageBill.service.IStorageBillService;
+import org.jeecg.modules.system.controller.LoginController;
 import org.springframework.beans.BeanUtils;
 
 import java.util.Date;
@@ -233,7 +235,8 @@ public class MqttClientCallback implements MqttCallback, MqttCallbackExtended {
     private void handleBilletBasicInfo(String payload) {
         try {
             JSONObject jsonObject = JSON.parseObject(payload);
-            String sign = jsonObject.getString("sign");
+            // 验证sign 是否存在
+            String sign = oConvertUtils.isNotEmpty(jsonObject.getString("sign")) ? jsonObject.getString("sign") : "";
             // sign："1"，正常数据；sign："2"，异常数据
             if ("2".equals(sign)) {
                 BilletBasicInfo billetBasicInfo = JSON.parseObject(payload, BilletBasicInfo.class);