|
@@ -1,8 +1,10 @@
|
|
|
package com.fdkankan.contro.mq.service.impl;
|
|
|
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
import com.fdkankan.common.util.FileUtils;
|
|
|
+import com.fdkankan.contro.bean.SceneJsonBean;
|
|
|
import com.fdkankan.contro.entity.*;
|
|
|
import com.fdkankan.contro.mq.service.IBuildSceneService;
|
|
|
import com.fdkankan.contro.service.*;
|
|
@@ -15,6 +17,8 @@ import com.fdkankan.model.utils.CreateObjUtil;
|
|
|
import com.fdkankan.rabbitmq.bean.BuildSceneCallMessage;
|
|
|
import com.fdkankan.rabbitmq.bean.BuildSceneResultMqMessage;
|
|
|
import com.fdkankan.rabbitmq.util.RabbitMqProducer;
|
|
|
+import com.fdkankan.redis.constant.RedisKey;
|
|
|
+import com.fdkankan.redis.util.RedisUtil;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
@@ -71,6 +75,9 @@ public class BuildObjServiceImpl implements IBuildSceneService {
|
|
|
@Autowired
|
|
|
private ISceneProEditService sceneProEditService;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private RedisUtil redisUtil;
|
|
|
+
|
|
|
@Override
|
|
|
public void buildScenePre(BuildSceneCallMessage message) {
|
|
|
boolean success = false;
|
|
@@ -211,8 +218,18 @@ public class BuildObjServiceImpl implements IBuildSceneService {
|
|
|
.set(ScenePlus::getSceneStatus, -2).eq(ScenePlus::getNum, projectNum);
|
|
|
scenePlusService.update(plusUpdateWrapper);
|
|
|
SceneEditInfo sceneEditInfo = sceneEditInfoService.getByScenePlusId(scenePlus.getId());
|
|
|
- sceneEditControlsService.update(new LambdaUpdateWrapper<SceneEditControls>().set(SceneEditControls::getShowMap,0)
|
|
|
- .eq(SceneEditControls::getEditInfoId,sceneEditInfo.getId()));
|
|
|
+ SceneEditControls sceneEditControls = sceneEditControlsService.getBySceneEditId(sceneEditInfo.getId());
|
|
|
+ sceneEditControls.setShowMap(0);
|
|
|
+ sceneEditControlsService.updateById(sceneEditControls);
|
|
|
+
|
|
|
+ // 更新scene.json
|
|
|
+ String dataViewPath = String.format(UploadFilePath.DATA_VIEW_PATH, projectNum);
|
|
|
+ SceneJsonBean jsonObject =JSONObject.parseObject(fYunFileService.getFileContent(dataViewPath + "scene.json"), SceneJsonBean.class);
|
|
|
+ jsonObject.getControls().setShowMap(0);
|
|
|
+ String jsonString = JSON.toJSONString(jsonObject);
|
|
|
+ fYunFileService.uploadFile(jsonString.getBytes(), dataViewPath + "scene.json");
|
|
|
+ //更新缓存
|
|
|
+ redisUtil.set(String.format(RedisKey.SCENE_JSON, projectNum), jsonString);
|
|
|
}
|
|
|
|
|
|
// 如果未升级V4,则升级V4
|