沂南应急极光推送消息逻辑修改

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/action/ContingencyAction.java

@@ -476,15 +476,7 @@ public class ContingencyAction implements CustomerAction {
                 log.error("optionarea 加入队列失败-->" + e.getMessage());
             }
 
-            MessageVO messageVO = new MessageVO();
-            messageVO.setTitle("应急处置事项提醒");
-            messageVO.setBody("【" + actionName + "】" + DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
-            messageVO.setMsgType("emergencyPlan");
-            messageVO.setCategory(1);
-            messageVO.setIsSendApp(true);
-            messageVO.setIsSendWeb(true);
-            messageVO.setRelationId(batchNo);
-            planVisual3dService.sendMessage(buttonCode, messageVO);
+
         }
     }
 
@@ -998,6 +990,17 @@ public class ContingencyAction implements CustomerAction {
             contingencyPlanInstance.setStepCode(stepCode);
             contingencyPlanInstance.setContent(buttonJson);
             contingencyPlanInstanceRepository.save(contingencyPlanInstance);
+
+            MessageVO messageVO = new MessageVO();
+            messageVO.setTitle("应急处置事项提醒");
+            messageVO.setBody("【" + taskName + "】" + DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
+            messageVO.setMsgType("emergencyPlan");
+            messageVO.setCategory(1);
+            messageVO.setIsSendApp(true);
+            messageVO.setIsSendWeb(true);
+            messageVO.setRelationId(batchNo);
+            planVisual3dService.sendMessage(roleCode, messageVO);
+
         }
     }
 }

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/dao/mapper/PlanOperationRecordMapper.java

@@ -5,6 +5,7 @@ import com.yeejoin.amos.fas.dao.entity.PlanRule;
 import com.yeejoin.amos.fas.datasync.bo.PlanOperationRecordSyncBo;
 import org.springframework.stereotype.Repository;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 
@@ -42,6 +43,12 @@ public interface PlanOperationRecordMapper {
      */
     String getLastBatchNo();
 
+    /**
+     * 获取batchNo
+     * @return
+     */
+    List<String> getArraysUserIds(String roleCode);
+
     Map<String, Object> getLatestFireEquipId();
 
     PlanRule getPlanRuleByBatchNo(String batchNo);

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/PlanVisual3dServiceImpl.java

@@ -611,10 +611,10 @@ public class PlanVisual3dServiceImpl implements IPlanVisual3dService {
     }
 
     @Override
-    public void sendMessage(String buttonCode, MessageVO messageVO) {
+    public void sendMessage(String roleCode, MessageVO messageVO) {
         //  添加极光推送开关
         if (auroraPushSwitch) {
-            List<String> userIds = getUserIds(buttonCode);
+            List<String> userIds = getUserIds(roleCode);
             if (!CollectionUtils.isEmpty(userIds)) {
                 messageVO.setRecivers(userIds);
                 sendMessage(messageVO);
@@ -731,50 +731,9 @@ public class PlanVisual3dServiceImpl implements IPlanVisual3dService {
         return contingencyPlanInstance;
     }
 
-    private List<String> getUserIds(String buttonCode) {
-        String planStepJson = planStepService.getPlanStep();
-        List<PlanStepJsonVO> planStepJsonList = JSONObject.parseArray(planStepJson, PlanStepJsonVO.class);
-        List<String> collect = planStepJsonList.stream().filter(code -> code.getButtonCode().equals(buttonCode)).map(PlanStepJsonVO::getRoleCode).collect(Collectors.toList());
-        Toke toke = remoteSecurityService.getServerToken();
-        RequestContext.setToken(toke.getToke());
-        RequestContext.setProduct(toke.product);
-        RequestContext.setAppKey(toke.appKey);
-        ArrayList<String> userIds = new ArrayList<>();
-        ArrayList<String> roleIds = new ArrayList<>();
-
-        // 查询按钮下角色id
-        for (String roleName : collect) {
-            FeignClientResult roleList;
-            List<Map> roleModelList = null;
-            try {
-                roleList = privilegeFeign.getRoleList(RequestContext.getAppKey(), RequestContext.getProduct(), RequestContext.getToken(), roleName);
-                roleModelList = (List<Map>) roleList.getResult();
-            } catch (InnerInvokException e) {
-                e.printStackTrace();
-            }
-            if (!CollectionUtils.isEmpty(roleModelList)) {
-
-                for (Map map : roleModelList) {
-                    roleIds.add(String.valueOf(map.get("sequenceNbr")));
-                }
-            }
-        }
+    private List<String> getUserIds(String roleCode) {
 
-        // 查询角色下用户
-        FeignClientResult userResult;
-        List<Map> userList = null;
-        try {
-            userResult = privilegeFeign.getUserByRoleIds(RequestContext.getAppKey(), RequestContext.getProduct(), RequestContext.getToken(), String.join(",", roleIds));
-            userList = (List<Map>) userResult.getResult();
-        } catch (InnerInvokException e) {
-            e.printStackTrace();
-        }
-        if (!CollectionUtils.isEmpty(userList)) {
-            for (Map map : userList) {
-                userIds.add(String.valueOf(map.get("userId")));
-            }
-        }
-        return userIds;
+        return planOperationRecordMapper.getArraysUserIds(roleCode);
     }
 
     @Override

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/intfc/IPlanVisual3dService.java

@@ -110,10 +110,10 @@ public interface IPlanVisual3dService {
     /**
      * 极光推送消息
      *
-     * @param buttonCode
+     * @param roleCode
      * @param messageVO
      */
-    void sendMessage(String buttonCode, MessageVO messageVO);
+    void sendMessage(String roleCode, MessageVO messageVO);
 
 
     /**

YeeAmosFireAutoSysStart/src/main/resources/db/mapper/PlanOperationRecordMapper.xml

@@ -140,4 +140,9 @@
   <select id="getLastPlanPattern" resultType="java.lang.Integer">
     select plan_pattern as planPattern from c_plan_operation_record where is_delete = 0 order by create_date desc limit 1
   </select>
+    <select id="getArraysUserIds" resultType="java.lang.String">
+      SELECT  amos_id from c_emergency_relation cer where obligationId in (
+        select id from f_dict fd where dict_value = #{roleCode}
+      )
+    </select>
 </mapper>
\ No newline at end of file