From 6b23bce8efc85090eb89b4b269e35f947f12af80 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Wed, 5 Jun 2019 12:27:28 +0800 Subject: [PATCH] =?UTF-8?q?[cUser=E6=9F=A5=E9=87=8D][=E6=96=B0=E5=A2=9E]:?= =?UTF-8?q?=E6=AF=8F=E5=A4=A9=E6=97=A9=E6=99=A8=E6=9F=A5=E9=87=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../schedule/WxCUserCheckSchedule.java | 46 +++++++++++++++++++ .../com/iformall/mapper/WxCUserMapper.java | 6 +-- .../main/resources/mapper/WxCUserMapper.xml | 4 ++ 3 files changed, 53 insertions(+), 3 deletions(-) create mode 100644 mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserCheckSchedule.java diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserCheckSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserCheckSchedule.java new file mode 100644 index 000000000..509c1d6a9 --- /dev/null +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserCheckSchedule.java @@ -0,0 +1,46 @@ +package com.iformall.schedule; + +import com.iformall.mapper.WxCUserMapper; +import com.iformall.service.MailService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import java.util.List; +import java.util.Map; + + +@Component +public class WxCUserCheckSchedule { + private final Logger logger = LoggerFactory.getLogger(this.getClass()); + + @Autowired + private boolean isFmException; + + @Autowired + private String fmExceptionEmails; + + @Autowired + private MailService mailService; + + @Autowired + private WxCUserMapper cUserMapper; + + @Scheduled(cron = "0 0 8 * * ?") // 每天凌晨08:00对c_user扫描查重 + // @Scheduled(cron = "0 */1 * * * ?") // 测试1分钟一次 + public void cuserCheckDuplicate() { + + List> mapList = cUserMapper.checkCountByTenantOpenId(); + if(mapList.size()> 0) { + String message = "wx_c_user异常,有重复数据"; + logger.error(message); + if(isFmException) { + String[] receivers = fmExceptionEmails.split(","); + //发送邮件 + mailService.sendSimpleMail(receivers, message, message); + } + } + } +} \ No newline at end of file diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java index ff4f07394..6d81d824f 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java @@ -1,9 +1,7 @@ package com.iformall.mapper; -import java.util.HashMap; import java.util.List; - -import org.apache.ibatis.annotations.Param; +import java.util.Map; import com.iformall.common.CommonMapper; import com.iformall.domain.dto.WxCUserBasicInfoDto; @@ -24,4 +22,6 @@ public interface WxCUserMapper extends CommonMapper { List listByChannel(WxCUser wxCUser); long countByChannel(WxCUser wxCUser); + + List> checkCountByTenantOpenId(); } diff --git a/mallinkService/src/main/resources/mapper/WxCUserMapper.xml b/mallinkService/src/main/resources/mapper/WxCUserMapper.xml index 75c45f9c4..db945f466 100644 --- a/mallinkService/src/main/resources/mapper/WxCUserMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxCUserMapper.xml @@ -293,4 +293,8 @@ + +