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