推送激光场景mq消息增加payStatus字段

src/main/java/com/fdkankan/contro/service/impl/IFdkkLaserServiceImpl.java

@@ -9,6 +9,7 @@ import com.fdkankan.contro.entity.ScenePlus;
 import com.fdkankan.contro.entity.ScenePlusExt;
 import com.fdkankan.contro.entity.ScenePro;
 import com.fdkankan.contro.service.IFdkkLaserService;
+import com.fdkankan.contro.service.IScenePlusExtService;
 import com.fdkankan.contro.service.IScenePlusService;
 import com.fdkankan.contro.service.ISceneProService;
 import com.fdkankan.fyun.face.FYunFileServiceInterface;
@@ -59,6 +60,9 @@ public class IFdkkLaserServiceImpl implements IFdkkLaserService {
 
 
     public void updateSceneStatus(String sceneCode, int sceneStatus, String path, Date createTime, Date algorithmTime, Integer shootCount) {
+
+        ScenePlus scenePlus = scenePlusService.getScenePlusByNum(sceneCode);
+
         Map<String, Object> params = new HashMap<>();
         params.put("sceneCode", sceneCode);
         params.put("status", sceneStatus);
@@ -69,6 +73,7 @@ public class IFdkkLaserServiceImpl implements IFdkkLaserService {
             params.put("path", path);
         }
         params.put("shootCount", shootCount);
+        params.put("payStatus", scenePlus.getPayStatus());
         rabbitMqProducer.sendByWorkQueue(updateScene, params);
     }
 
@@ -139,6 +144,7 @@ public class IFdkkLaserServiceImpl implements IFdkkLaserService {
         params.put("title", scenePlus.getTitle());
         params.put("userId", scenePlus.getUserId());
         params.put("sceneSource", scenePlus.getSceneSource());
+        params.put("payStatus", scenePlus.getPayStatus());
         if(Objects.nonNull(fdageJson)){
             params.put("location", fdageJson.getInteger("location"));
         }