add pwd

720yun_fd_consumer/gis_consumer/src/main/java/com/gis/entity/SceneQueueDTO.java

@@ -43,4 +43,7 @@ public class SceneQueueDTO {
 
    private String sceneName;
 
+    private String pwd;
+
+
 }

720yun_fd_consumer/gis_consumer/src/main/java/com/gis/listener/SceneListener.java

@@ -103,6 +103,9 @@ public class SceneListener {
             }if (ObjectUtil.isNotEmpty(workEntity)&&param.getStatus()==0){
                 //修改状态
                 workEntity.setCalcStatus(0);
+                if (ObjectUtil.isNotEmpty(param.getPwd())&&ObjectUtil.isEmpty(workEntity.getPassword())){
+                    workEntity.setPassword(param.getPwd());
+                }
                 workService.update(workEntity);
                 channel.basicAck(deliveryTag, false);
             }else if (ObjectUtil.isNotEmpty(param.getSceneCode())&&param.getStatus()==1){

720yun_fd_consumer/gis_consumer/src/main/java/com/gis/service/impl/WorkServiceImpl.java

@@ -1,5 +1,6 @@
 package com.gis.service.impl;
 
+import cn.hutool.core.util.ObjectUtil;
 import com.gis.constant.ConfigConstant;
 import com.gis.entity.SceneQueueDTO;
 import com.gis.entity.WorkEntity;
@@ -56,6 +57,9 @@ public class WorkServiceImpl extends IBaseStrServiceImpl<WorkEntity, String> imp
         entity.setSnCode(sceneQueueDTO.getSnCode());
         entity.setLocation(sceneQueueDTO.getLocation());
         entity.setSceneSource(sceneQueueDTO.getSceneSource());
+        if (ObjectUtil.isNotEmpty(sceneQueueDTO.getPwd())){
+            entity.setPassword(sceneQueueDTO.getPwd());
+        }
         this.save(entity);
         String id = entity.getId();
         log.info("创建对象完成： {}", id);