场景升级改造

4dkankan-center-scene/src/main/java/com/fdkankan/scene/service/impl/SceneUpgradeToV4Service.java

@@ -168,11 +168,10 @@ public class SceneUpgradeToV4Service implements ISceneUpgradeToV4Service {
             redisUtil.set(RedisKey.scene_upgrade_progress_num, JSON.toJSONString(progress));
 
             //发送mq
-            rabbitMqProducer.sendByWorkQueue(upgradeToV4,
-                UpgradeBean.builder()
-                    .sceneProId(sceneProV3.getId())
-                    .reUpgrade(param.isReUpgrade())
-                    .build());
+            HashMap<String, Object> msg = new HashMap<>();
+            msg.put("sceneProId", sceneProV3.getId());
+            msg.put("reUpgrade", param.isReUpgrade());
+            rabbitMqProducer.sendByWorkQueue(upgradeToV4, msg);
 
         }catch (Exception e){
             log.error("场景升级失败", e);