1：点火通知

陈威
1 parent d0ac4752
Showing 5 changed files with 146 additions and 7 deletions Show diff stats
zr-cloud/zr-modules/zr-schsf/src/main/java/com/chinagas/modules/schsf/domain/notice/McIgnitionTemplate.java
zr-cloud/zr-modules/zr-schsf/src/main/java/com/chinagas/modules/schsf/mapper/McIgnitionMapper.java
zr-cloud/zr-modules/zr-schsf/src/main/java/com/chinagas/modules/schsf/service/IMcIgnitionService.java
zr-cloud/zr-modules/zr-schsf/src/main/java/com/chinagas/modules/schsf/service/impl/McIgnitionServiceImpl.java
zr-cloud/zr-modules/zr-schsf/src/main/resources/mapper/McIgnitionMapper.xml
@@ -0,0 +1,27 @@
+package com.chinagas.modules.schsf.domain.notice;
+
+import com.chinagas.modules.schsf.domain.McIgnition;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+public class McIgnitionTemplate {
+    private McIgnition mcIgnition;
+
+    public McIgnitionTemplate(McIgnition mcIgnition) {
+        this.mcIgnition = mcIgnition;
+    }
+
+    public String getNoticemarkdown() {
+        return  "######  市场化收费-点火通知  \n  " +
+                "用户信息：" + mcIgnition.getUserName()+"(" +mcIgnition.getUserPhone()+ ")  \n  " +
+                "村/小区：" + mcIgnition.getVlgOrCmty() + "  \n  " +
+                "当前状态：" + mcIgnition.getStatusName() + "(客服)  \n  " +
+                "维护操作：点击链接进入维护页面：[https://schsf.chinagasholdings.com](https://schsf.chinagasholdings.com)  \n  " +
+                "---" +
+                "  \n  " +
+                "通知日期： " + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy/MM/dd HH:mm")) + "  \n  " +
+                "温馨提醒： 请按时完成维护，保障业务顺畅。  \n  ";
+    }
+
+}
 package com.chinagas.modules.schsf.mapper;
 import com.chinagas.modules.schsf.domain.McIgnition;
+import com.chinagas.modules.schsf.domain.dto.NodeUsersDto;
+import org.apache.ibatis.annotations.Param;
 import java.util.List;
@@ -62,4 +64,5 @@ public interface McIgnitionMapper
     List<McIgnition> selectMcIgnitionParamList(McIgnition mcIgnition);
+    List<NodeUsersDto> selectMcIgnitionNodeUserList(@Param("id")String id, @Param("nodeType") String nodeType);
 }
@@ -2,6 +2,7 @@ package com.chinagas.modules.schsf.service;
 import com.chinagas.modules.schsf.domain.McIgnition;
 import com.chinagas.modules.schsf.domain.McVisit;
+import com.chinagas.modules.schsf.domain.dto.NodeUsersDto;
 import com.chinagas.modules.schsf.domain.vo.McIgnitionMaintenanceVo;
 import java.util.List;
@@ -78,4 +79,14 @@ public interface IMcIgnitionService
     int updateMcIgnitionMaintenance(McIgnitionMaintenanceVo mcIgnitionMaintenanceVo) throws CloneNotSupportedException;
     void updateMcIgnitionCancel(Long visitId) throws CloneNotSupportedException;
+
+    /**
+     * 节点处理人
+     *
+     * @param id
+     * @return
+     */
+    List<NodeUsersDto> selectMcIgnitionNodeUserList(Long id);
+
+
 }
 package com.chinagas.modules.schsf.service.impl;
+import cn.hutool.core.bean.BeanUtil;
 import com.alibaba.fastjson2.JSON;
+import com.chinagas.common.core.exceptions.ServiceException;
 import com.chinagas.common.core.utils.DateUtils;
 import com.chinagas.common.core.utils.StringUtils;
 import com.chinagas.common.datascope.annotation.DataScope;
 import com.chinagas.common.security.utils.SecurityUtils;
 import com.chinagas.modules.schsf.domain.McIgnition;
 import com.chinagas.modules.schsf.domain.McVisit;
+import com.chinagas.modules.schsf.domain.dto.NodeUsersDto;
+import com.chinagas.modules.schsf.domain.notice.McIgnitionTemplate;
 import com.chinagas.modules.schsf.domain.vo.McIgnitionMaintenanceVo;
 import com.chinagas.modules.schsf.enums.IgnitionStatusEnums;
 import com.chinagas.modules.schsf.enums.YesNoEnums;
 import com.chinagas.modules.schsf.mapper.McIgnitionMapper;
+import com.chinagas.modules.schsf.service.DingtalkService;
 import com.chinagas.modules.schsf.service.IMcIgnitionService;
 import com.chinagas.modules.schsf.service.IMcOperationLogService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import java.time.LocalDateTime;
+import java.util.Collections;
 import java.util.List;
+import java.util.stream.Collectors;
 /**
  * 点火维护Service业务层处理
@@ -26,6 +34,7 @@ import java.util.List;
  * @author cw
  * @date 2024-05-22
  */
+@Slf4j
 @Transactional
 @Service
 public class McIgnitionServiceImpl implements IMcIgnitionService {
@@ -33,6 +42,8 @@ public class McIgnitionServiceImpl implements IMcIgnitionService {
     private McIgnitionMapper mcIgnitionMapper;
     @Autowired
     private IMcOperationLogService iMcOperationLogService;
+    @Autowired
+    private DingtalkService dingtalkService;
     /**
      * 根据mcVisit插入mcIgnition
@@ -51,8 +62,6 @@ public class McIgnitionServiceImpl implements IMcIgnitionService {
         String userAccount = SecurityUtils.getUsername();
         String userName = SecurityUtils.getLoginUser().getSysUser().getNickName();
-
-
         McIgnition mcIgnition = new McIgnition();
         mcIgnition.setRegionName(mcVisit.getRegionName());
         mcIgnition.setGroupName(mcVisit.getGroupName());
@@ -90,6 +99,9 @@ public class McIgnitionServiceImpl implements IMcIgnitionService {
         //1:添加记录
         iMcOperationLogService.insertMcOperationLog("mc_ignition", mcIgnition.getId(), "schsf:mcVisit:ticket_submitAuditTwo",
                 "发起", "1", "导入基础数据-户数", null, JSON.toJSONString(mcIgnition));
+        if (i > 0) {
+            this.sendMcIgnitionNotification(mcIgnition.getId());
+        }
         return i;
     }
@@ -164,6 +176,7 @@ public class McIgnitionServiceImpl implements IMcIgnitionService {
     /**
      * 点火维护
+     *
      * @param mcIgnition
      * @return
      */
@@ -175,7 +188,7 @@ public class McIgnitionServiceImpl implements IMcIgnitionService {
         String userName = SecurityUtils.getLoginUser().getSysUser().getNickName();
         //老数据
         McIgnition mcIgnition_old = mcIgnitionMapper.selectMcIgnitionById(mcIgnitionMaintenanceVo.getId());
-        if (mcIgnition_old==null){
+        if (mcIgnition_old == null) {
             throw new RuntimeException("被审核信息不存在！");
         }
         //新数据
@@ -185,8 +198,8 @@ public class McIgnitionServiceImpl implements IMcIgnitionService {
         mcIgnition_new.setnIgnRsn(mcIgnitionMaintenanceVo.getnIgnRsn());
         mcIgnition_new.setUpdateBy(userId.toString());
         mcIgnition_new.setUpdateTime(time);
-        mcIgnition_new.setStatusCode(mcIgnitionMaintenanceVo.getIgnCnfStatusCode().equals("Y")?IgnitionStatusEnums.MAINTENANCE_YES.getCode():IgnitionStatusEnums.MAINTENANCE_NO.getCode());
-        mcIgnition_new.setStatusName(mcIgnitionMaintenanceVo.getIgnCnfStatusCode().equals("Y")?IgnitionStatusEnums.MAINTENANCE_YES.getInfo():IgnitionStatusEnums.MAINTENANCE_NO.getInfo());
+        mcIgnition_new.setStatusCode(mcIgnitionMaintenanceVo.getIgnCnfStatusCode().equals("Y") ? IgnitionStatusEnums.MAINTENANCE_YES.getCode() : IgnitionStatusEnums.MAINTENANCE_NO.getCode());
+        mcIgnition_new.setStatusName(mcIgnitionMaintenanceVo.getIgnCnfStatusCode().equals("Y") ? IgnitionStatusEnums.MAINTENANCE_YES.getInfo() : IgnitionStatusEnums.MAINTENANCE_NO.getInfo());
         mcIgnition_new.setCnfPersonId(userId);
         mcIgnition_new.setCnfPersonAccount(userAccount);
         mcIgnition_new.setCnfPersonName(userName);
@@ -200,6 +213,7 @@ public class McIgnitionServiceImpl implements IMcIgnitionService {
     /**
      * 作废
+     *
      * @param visitId
      */
     @Override
@@ -209,10 +223,10 @@ public class McIgnitionServiceImpl implements IMcIgnitionService {
         String userAccount = SecurityUtils.getUsername();
         String userName = SecurityUtils.getLoginUser().getSysUser().getNickName();
-        McIgnition mcIgnition= new McIgnition();
+        McIgnition mcIgnition = new McIgnition();
         mcIgnition.setVisitId(visitId);
         List<McIgnition> mcIgnitions = mcIgnitionMapper.selectMcIgnitionList(mcIgnition);
-        if (mcIgnitions !=null && mcIgnitions.size()>0){
+        if (mcIgnitions != null && mcIgnitions.size() > 0) {
             for (McIgnition mcIgnition_old : mcIgnitions) {
                 //新数据
                 McIgnition mcIgnition_new = mcIgnition_old.clone();
@@ -227,4 +241,42 @@ public class McIgnitionServiceImpl implements IMcIgnitionService {
             }
         }
     }
+
+    /**
+     * 点火节点处理人
+     *
+     * @param id
+     * @return
+     */
+    @Override
+    public List<NodeUsersDto> selectMcIgnitionNodeUserList(Long id) {
+        McIgnition mcIgnition = mcIgnitionMapper.selectMcIgnitionById(id);
+        if (mcIgnition == null) {
+            throw new ServiceException("点火信息不存在！");
+        }
+        //待维护
+        if (mcIgnition.getStatusCode().equals(IgnitionStatusEnums.MAINTENANCE.getCode())) {
+            return mcIgnitionMapper.selectMcIgnitionNodeUserList(String.valueOf(id), "schsf:mcIgnition:maintenance");
+        }
+        return Collections.emptyList();
+    }
+
+    /**
+     * 发送钉钉通知
+     *
+     * @param id
+     */
+    private void sendMcIgnitionNotification(Long id) {
+        McIgnition mcIgnition = mcIgnitionMapper.selectMcIgnitionById(id);
+        log.info("点火维护-钉钉通知，点火信息对象:{}", mcIgnition);
+        if (BeanUtil.isEmpty(mcIgnition)) {
+            throw new ServiceException("未查询到记录");
+        }
+        //发送通知
+        List<NodeUsersDto> mcVisitNodeUsersDtos = this.selectMcIgnitionNodeUserList(id);
+        if (mcVisitNodeUsersDtos != null) {
+            List<String> userIds = mcVisitNodeUsersDtos.stream().filter(mcVisitNodeUsersDto -> StringUtils.isNotEmpty(mcVisitNodeUsersDto.getDingTalkUserId())).map(NodeUsersDto::getDingTalkUserId).collect(Collectors.toList());
+            dingtalkService.sendMarketFeeNotification(userIds, "市场化收费-点火维护", new McIgnitionTemplate(mcIgnition).getNoticemarkdown());
+        }
+    }
 }
@@ -220,4 +220,50 @@ PUBLIC &quot;-//mybatis.org//DTD Mapper 3.0//EN&quot;
             and t.vlg_or_cmty = #{vlgOrCmty}
     </select>
+    <select id="selectMcIgnitionNodeUserList" resultType="com.chinagas.modules.schsf.domain.dto.NodeUsersDto" parameterType="String">
+        SELECT DISTINCT us.user_name,us.nick_name,un.user_id,un.ding_talk_union_id,un.ding_talk_user_id
+        FROM sys_menu menu
+        INNER JOIN sys_role_menu roleMenu on roleMenu.menu_id=menu.menu_id
+        INNER JOIN sys_role role on role.role_id= roleMenu.role_id
+        INNER JOIN sys_user_role userRole on userRole.role_id = role.role_id
+        INNER JOIN sys_user us on us.user_id = userRole.user_id
+        LEFT JOIN  sys_user_unite un on un.user_id=us.user_id
+        WHERE menu.perms=#{nodeType,jdbcType=VARCHAR}
+        and role.data_scope='1'
+        UNION
+        SELECT DISTINCT us.user_name,us.nick_name,un.user_id,un.ding_talk_union_id,un.ding_talk_user_id
+        FROM sys_menu menu
+        INNER JOIN sys_role_menu roleMenu on roleMenu.menu_id=menu.menu_id
+        INNER JOIN sys_role role on role.role_id= roleMenu.role_id
+        INNER JOIN sys_user_role userRole on userRole.role_id = role.role_id
+        INNER JOIN sys_user us on us.user_id = userRole.user_id
+        INNER JOIN sys_user_dept userDept  on userDept.user_id=us.user_id and userDept.dept_id in ( SELECT ignition.company_code FROM mc_ignition ignition WHERE ignition.id= #{id})
+        LEFT JOIN  sys_user_unite un on un.user_id=us.user_id
+        WHERE menu.perms=#{nodeType,jdbcType=VARCHAR}
+        and role.data_scope='3'
+        UNION
+        SELECT DISTINCT us.user_name,us.nick_name,un.user_id,un.ding_talk_union_id,un.ding_talk_user_id
+        FROM sys_menu menu
+        INNER JOIN sys_role_menu roleMenu on roleMenu.menu_id=menu.menu_id
+        INNER JOIN sys_role role on role.role_id= roleMenu.role_id
+        INNER JOIN sys_user_role userRole on userRole.role_id = role.role_id
+        INNER JOIN sys_user us on us.user_id = userRole.user_id
+        INNER JOIN sys_user_dept userDept  on userDept.user_id=us.user_id
+        INNER JOIN sys_dept dept on dept.dept_id =userDept.dept_id
+        INNER JOIN sys_dept dept2 on dept2.dept_id in (SELECT a.dept_id FROM sys_dept a WHERE a.dept_id = dept.dept_id or find_in_set(  dept.parent_id , ancestors ) )
+        and dept2.dept_id  = (SELECT ignition.company_code FROM mc_ignition ignition  WHERE ignition.id= #{id} )
+        LEFT JOIN  sys_user_unite un on un.user_id=us.user_id
+        WHERE menu.perms= #{nodeType,jdbcType=VARCHAR}
+        and role.data_scope='4'
+        UNION
+        SELECT DISTINCT us.user_name,us.nick_name,un.user_id,un.ding_talk_union_id,un.ding_talk_user_id
+        FROM sys_menu menu
+        INNER JOIN sys_role_menu roleMenu on roleMenu.menu_id=menu.menu_id
+        INNER JOIN sys_role role on role.role_id= roleMenu.role_id
+        INNER JOIN sys_user_role userRole on userRole.role_id = role.role_id and userRole.user_id = (SELECT ignition.create_by FROM mc_ignition ignition WHERE ignition.id= #{id} )
+        INNER JOIN sys_user us on us.user_id = userRole.user_id
+        LEFT JOIN  sys_user_unite un on un.user_id=us.user_id
+        WHERE menu.perms=#{nodeType,jdbcType=VARCHAR}
+        and role.data_scope='5'
+    </select>
 </mapper>
@@ -0,0 +1,27 @@		@@ -0,0 +1,27 @@
	1	+package com.chinagas.modules.schsf.domain.notice;
	2	+
	3	+import com.chinagas.modules.schsf.domain.McIgnition;
	4	+
	5	+import java.time.LocalDateTime;
	6	+import java.time.format.DateTimeFormatter;
	7	+
	8	+public class McIgnitionTemplate {
	9	+ private McIgnition mcIgnition;
	10	+
	11	+ public McIgnitionTemplate(McIgnition mcIgnition) {
	12	+ this.mcIgnition = mcIgnition;
	13	+ }
	14	+
	15	+ public String getNoticemarkdown() {
	16	+ return "###### 市场化收费-点火通知 \n " +
	17	+ "用户信息：" + mcIgnition.getUserName()+"(" +mcIgnition.getUserPhone()+ ") \n " +
	18	+ "村/小区：" + mcIgnition.getVlgOrCmty() + " \n " +
	19	+ "当前状态：" + mcIgnition.getStatusName() + "(客服) \n " +
	20	+ "维护操作：点击链接进入维护页面：[https://schsf.chinagasholdings.com](https://schsf.chinagasholdings.com) \n " +
	21	+ "---" +
	22	+ " \n " +
	23	+ "通知日期： " + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy/MM/dd HH:mm")) + " \n " +
	24	+ "温馨提醒：请按时完成维护，保障业务顺畅。 \n ";
	25	+ }
	26	+
	27	+}
	@@ -2,6 +2,7 @@ package com.chinagas.modules.schsf.service;		@@ -2,6 +2,7 @@ package com.chinagas.modules.schsf.service;
2		2
3	import com.chinagas.modules.schsf.domain.McIgnition;	3	import com.chinagas.modules.schsf.domain.McIgnition;
4	import com.chinagas.modules.schsf.domain.McVisit;	4	import com.chinagas.modules.schsf.domain.McVisit;
		5	+import com.chinagas.modules.schsf.domain.dto.NodeUsersDto;
5	import com.chinagas.modules.schsf.domain.vo.McIgnitionMaintenanceVo;	6	import com.chinagas.modules.schsf.domain.vo.McIgnitionMaintenanceVo;
6		7
7	import java.util.List;	8	import java.util.List;
	@@ -78,4 +79,14 @@ public interface IMcIgnitionService		@@ -78,4 +79,14 @@ public interface IMcIgnitionService
78	int updateMcIgnitionMaintenance(McIgnitionMaintenanceVo mcIgnitionMaintenanceVo) throws CloneNotSupportedException;	79	int updateMcIgnitionMaintenance(McIgnitionMaintenanceVo mcIgnitionMaintenanceVo) throws CloneNotSupportedException;
79		80
80	void updateMcIgnitionCancel(Long visitId) throws CloneNotSupportedException;	81	void updateMcIgnitionCancel(Long visitId) throws CloneNotSupportedException;
		82	+
		83	+ /**
		84	+ * 节点处理人
		85	+ *
		86	+ * @param id
		87	+ * @return
		88	+ */
		89	+ List<NodeUsersDto> selectMcIgnitionNodeUserList(Long id);
		90	+
		91	+
81	}	92	}
	@@ -220,4 +220,50 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"		@@ -220,4 +220,50 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
220	and t.vlg_or_cmty = #{vlgOrCmty}	220	and t.vlg_or_cmty = #{vlgOrCmty}
221	</select>	221	</select>
222		222
		223	+ <select id="selectMcIgnitionNodeUserList" resultType="com.chinagas.modules.schsf.domain.dto.NodeUsersDto" parameterType="String">
		224	+ SELECT DISTINCT us.user_name,us.nick_name,un.user_id,un.ding_talk_union_id,un.ding_talk_user_id
		225	+ FROM sys_menu menu
		226	+ INNER JOIN sys_role_menu roleMenu on roleMenu.menu_id=menu.menu_id
		227	+ INNER JOIN sys_role role on role.role_id= roleMenu.role_id
		228	+ INNER JOIN sys_user_role userRole on userRole.role_id = role.role_id
		229	+ INNER JOIN sys_user us on us.user_id = userRole.user_id
		230	+ LEFT JOIN sys_user_unite un on un.user_id=us.user_id
		231	+ WHERE menu.perms=#{nodeType,jdbcType=VARCHAR}
		232	+ and role.data_scope='1'
		233	+ UNION
		234	+ SELECT DISTINCT us.user_name,us.nick_name,un.user_id,un.ding_talk_union_id,un.ding_talk_user_id
		235	+ FROM sys_menu menu
		236	+ INNER JOIN sys_role_menu roleMenu on roleMenu.menu_id=menu.menu_id
		237	+ INNER JOIN sys_role role on role.role_id= roleMenu.role_id
		238	+ INNER JOIN sys_user_role userRole on userRole.role_id = role.role_id
		239	+ INNER JOIN sys_user us on us.user_id = userRole.user_id
		240	+ INNER JOIN sys_user_dept userDept on userDept.user_id=us.user_id and userDept.dept_id in ( SELECT ignition.company_code FROM mc_ignition ignition WHERE ignition.id= #{id})
		241	+ LEFT JOIN sys_user_unite un on un.user_id=us.user_id
		242	+ WHERE menu.perms=#{nodeType,jdbcType=VARCHAR}
		243	+ and role.data_scope='3'
		244	+ UNION
		245	+ SELECT DISTINCT us.user_name,us.nick_name,un.user_id,un.ding_talk_union_id,un.ding_talk_user_id
		246	+ FROM sys_menu menu
		247	+ INNER JOIN sys_role_menu roleMenu on roleMenu.menu_id=menu.menu_id
		248	+ INNER JOIN sys_role role on role.role_id= roleMenu.role_id
		249	+ INNER JOIN sys_user_role userRole on userRole.role_id = role.role_id
		250	+ INNER JOIN sys_user us on us.user_id = userRole.user_id
		251	+ INNER JOIN sys_user_dept userDept on userDept.user_id=us.user_id
		252	+ INNER JOIN sys_dept dept on dept.dept_id =userDept.dept_id
		253	+ INNER JOIN sys_dept dept2 on dept2.dept_id in (SELECT a.dept_id FROM sys_dept a WHERE a.dept_id = dept.dept_id or find_in_set( dept.parent_id , ancestors ) )
		254	+ and dept2.dept_id = (SELECT ignition.company_code FROM mc_ignition ignition WHERE ignition.id= #{id} )
		255	+ LEFT JOIN sys_user_unite un on un.user_id=us.user_id
		256	+ WHERE menu.perms= #{nodeType,jdbcType=VARCHAR}
		257	+ and role.data_scope='4'
		258	+ UNION
		259	+ SELECT DISTINCT us.user_name,us.nick_name,un.user_id,un.ding_talk_union_id,un.ding_talk_user_id
		260	+ FROM sys_menu menu
		261	+ INNER JOIN sys_role_menu roleMenu on roleMenu.menu_id=menu.menu_id
		262	+ INNER JOIN sys_role role on role.role_id= roleMenu.role_id
		263	+ INNER JOIN sys_user_role userRole on userRole.role_id = role.role_id and userRole.user_id = (SELECT ignition.create_by FROM mc_ignition ignition WHERE ignition.id= #{id} )
		264	+ INNER JOIN sys_user us on us.user_id = userRole.user_id
		265	+ LEFT JOIN sys_user_unite un on un.user_id=us.user_id
		266	+ WHERE menu.perms=#{nodeType,jdbcType=VARCHAR}
		267	+ and role.data_scope='5'
		268	+ </select>
223	</mapper>	269	</mapper>