Просмотр исходного кода

注册用户复制示例场景

dengsixing 1 месяц назад
Родитель
Сommit
fa9260f16d

+ 3 - 0
src/main/java/com/fdkankan/scene/entity/ScenePlus.java

@@ -134,5 +134,8 @@ public class ScenePlus implements Serializable {
     @TableField("has_floorplan_ai")
     private Integer hasFloorplanAi;
 
+    @TableField("demo")
+    private Integer demo;
+
 
 }

+ 1 - 1
src/main/java/com/fdkankan/scene/service/ILaserService.java

@@ -2,7 +2,7 @@ package com.fdkankan.scene.service;
 
 public interface ILaserService {
 
-    void copy(String oldNum , String newNum, String  path,Boolean flag);
+    void copy(String oldNum , String newNum, String  path,Boolean flag, Long userId, Integer demo);
 
     void cloudPointBuild(String oldNum, String newNum);
 }

+ 11 - 1
src/main/java/com/fdkankan/scene/service/impl/LaserServiceImpl.java

@@ -2,7 +2,9 @@ package com.fdkankan.scene.service.impl;
 
 import com.fdkankan.fyun.face.FYunFileServiceInterface;
 import com.fdkankan.rabbitmq.util.RabbitMqProducer;
+import com.fdkankan.scene.entity.User;
 import com.fdkankan.scene.service.ILaserService;
+import com.fdkankan.scene.service.IUserService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -31,13 +33,21 @@ public class LaserServiceImpl implements ILaserService {
     private String laserCopyScene;
     @Value("${queue.application.laser.copy-scene:laser-copy-scene-init}")
     private String laserInitCopyScene;
+    @Autowired
+    private IUserService userService;
     @Override
-    public void copy(String oldNum, String newNum, String path, Boolean flag) {
+    public void copy(String oldNum, String newNum, String path, Boolean flag, Long userId, Integer demo) {
         Map<String,Object> params = new HashMap<>();
         params.put("sceneCode", newNum);
         params.put("oldSceneCode", oldNum);
         params.put("path",path);
         params.put("init",flag);
+        params.put("userId",userId);
+        if(userId != null){
+            User user = userService.getById(userId);
+            params.put("userName",user.getUserName());
+        }
+        params.put("demo",demo);//注册新用户时,复制出来的示例场景做一个标示
         if(flag){
             rabbitMqProducer.sendByWorkQueue(laserInitCopyScene,params);
             return;

+ 5 - 4
src/main/java/com/fdkankan/scene/service/impl/SceneCopyServiceImpl.java

@@ -7,6 +7,7 @@ import cn.hutool.extra.qrcode.QrCodeUtil;
 import cn.hutool.extra.qrcode.QrConfig;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.fdkankan.common.constant.CommonStatus;
 import com.fdkankan.common.constant.SceneSource;
 import com.fdkankan.common.constant.SceneVersionType;
 import com.fdkankan.common.exception.BusinessException;
@@ -147,7 +148,7 @@ public class SceneCopyServiceImpl implements ISceneCopyService {
             }
 
             if(scenePlus.getSceneSource() == 4 || scenePlus.getSceneSource() == 5 || scenePlus.getSceneSource() == 7){  //深时复制
-                laserService.copy(oldNum,newNum,newDataSource,true);
+                laserService.copy(oldNum,newNum,newDataSource,true, userId, scenePlus.getDemo());
             }else {
                 laserService.cloudPointBuild(oldNum,newNum);
             }
@@ -168,7 +169,7 @@ public class SceneCopyServiceImpl implements ISceneCopyService {
             this.updateNasSceneJson(targetData,oldNum,newNum,scenePlus.getTitle(),"v4","scene.json");
 
             if(scenePlus.getSceneSource() == 4 || scenePlus.getSceneSource() == 5 || scenePlus.getSceneSource() == 7){  //深时复制
-                laserService.copy(oldNum,newNum,newDataSource,false);
+                laserService.copy(oldNum,newNum,newDataSource,false, userId, scenePlus.getDemo());
             }else {
                 scenePlus.setSceneStatus(-2);
                 scenePlusService.updateById(scenePlus);
@@ -231,7 +232,7 @@ public class SceneCopyServiceImpl implements ISceneCopyService {
             sceneProEditService.save(oldEditScene);
 
             if(scenePro.getSceneSource() == 4 || scenePro.getSceneSource() == 5) {  //深时复制
-                laserService.copy(oldNum,newNum,newDataSource,true);
+                laserService.copy(oldNum,newNum,newDataSource,true, null, CommonStatus.NO.code().intValue());
             }
             //重新生成编辑页基础设置二维码
             this.createNewQrCode(SceneVersionType.V3.code(),oldEditScene.getShareLogo(),newNum,scenePro.getWebSite());
@@ -259,7 +260,7 @@ public class SceneCopyServiceImpl implements ISceneCopyService {
             this.copyOssAndNasV3(oldNum,scenePro.getNum(),sourceVoice,targetVoice);
 
             if(scenePro.getSceneSource() == 4 || scenePro.getSceneSource() == 5){  //深时复制
-                laserService.copy(oldNum,newNum,newDataSource,false);
+                laserService.copy(oldNum,newNum,newDataSource,false, null, CommonStatus.NO.code().intValue());
             }else {
                 scenePro.setStatus(-2);
                 sceneProService.updateById(scenePro);