调整

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

@@ -1,5 +1,6 @@
 package org.jeecg.modules.push.utils;
 
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import lombok.extern.slf4j.Slf4j;
 import net.sf.ezmorph.object.DateMorpher;
@@ -103,15 +104,13 @@ public class MqttClientCallback implements MqttCallback, MqttCallbackExtended{
         JSONObject jsonObject = JSONObject.fromObject(message.toString());
         // 炉次实绩
         if(topic.contains("trace/performance/converter/add")){
-            JSONUtils.getMorpherRegistry().registerMorpher(new DateMorpher(new String[] {"yyyy-MM-dd", "yyyy-MM-dd HH:mm:ss"}));
-            HeatsActuals heatsActuals = (HeatsActuals)JSONObject.toBean(jsonObject, HeatsActuals.class);
+            HeatsActuals heatsActuals =  JSON.parseObject(jsonObject.toString(), HeatsActuals.class);
             heatsActualsService.addC(heatsActuals);
             return;
         }
         // 铸坯实绩
         if(topic.contains("trace/performance/billet/add")){
-            JSONUtils.getMorpherRegistry().registerMorpher(new DateMorpher(new String[] {"yyyy-MM-dd", "yyyy-MM-dd HH:mm:ss"}));
-            BilletBasicInfo billetBasicInfo = (BilletBasicInfo) JSONObject.toBean(jsonObject, BilletBasicInfo.class);
+            BilletBasicInfo billetBasicInfo =  JSON.parseObject(jsonObject.toString(), BilletBasicInfo.class);
             billetBasicInfoService.addC(billetBasicInfo);
             return;
         }