BindPushJob.java
3.93 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
package com.sincere.quartz.job;
import com.sincere.common.dto.smartCampus.BindPushDto;
import com.sincere.common.dto.smartCampus.ParentDto;
import com.sincere.common.enums.PushTypeEnums;
import com.sincere.common.util.DateUtils;
import com.sincere.quartz.feign.ScFeign;
import com.sincere.quartz.model.ShortMsg;
import com.sincere.quartz.service.SmsService;
import org.apache.commons.lang3.StringUtils;
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.Service;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* 用户注册激活提醒
* @author chen
* @version 1.0
* @date 2019/12/10 0010 8:31
*/
@Service
public class BindPushJob {
private Logger logger = LoggerFactory.getLogger(BindPushJob.class);
@Autowired
ScFeign scFeign;
@Autowired
SmsService smsService;
private static Map<String , String> intervalDaysMap = new HashMap<>(); //redis 持久化 替换 可避免重启导致间隔的错误
@Scheduled(cron = "0 0-59 * * * ? ")
public void bindPush(){
Date nowDate = new Date();
List<BindPushDto> schoolList = scFeign.selectBindPushSchool();
for(BindPushDto school : schoolList){
if(school.getBeginDate().compareTo(nowDate) <= 0 && school.getEndDate().compareTo(nowDate) >= 0){
String lastDate = intervalDaysMap.get(school.getSchoolId()+"_"+school.getType());
if(StringUtils.isBlank(lastDate)){
//下发推送
bindPush(school,nowDate);
}else {
int day = DateUtils.getDateDifference(nowDate,DateUtils.string2Date(lastDate,DateUtils.format1),"day") ;
if(day == school.getIntervalDays() + 1) {
//下发推送
bindPush(school,nowDate);
}
}
}
}
}
private void bindPush(BindPushDto bindPushDto , Date nowDate){
if(bindPushDto.getPushTime().equals(DateUtils.date2String(nowDate,DateUtils.format4))){
intervalDaysMap.put(bindPushDto.getSchoolId()+"_"+bindPushDto.getType(),DateUtils.date2String(nowDate,DateUtils.format1));
//未关注
List<ParentDto> unFollowList = scFeign.selectNotFollow(bindPushDto.getSchoolId());
logger.info(bindPushDto.getSchoolName()+"未关注人数"+unFollowList.size());
for(ParentDto parentDto : unFollowList){
sendMessage(parentDto,bindPushDto.getMsg());
}
//未绑定
List<ParentDto> unBindList =scFeign.selectNotBind(bindPushDto.getSchoolId(),getThirdType(bindPushDto.getType()));
logger.info(bindPushDto.getSchoolName()+"未绑定人数"+unBindList.size());
for(ParentDto parentDto : unBindList){
sendMessage(parentDto,bindPushDto.getMsg());
}
}
}
private void sendMessage(ParentDto parentDto , String message){
//手机号为空
if(StringUtils.isNotBlank(parentDto.getMobile())){
String tableSuffix = DateUtils.date2String(new Date(), DateUtils.format);
ShortMsg shortMsg = new ShortMsg();
shortMsg.setTableName("smsNew"+tableSuffix);
shortMsg.setSchoolId(parentDto.getSchoolId());
shortMsg.setMobile(parentDto.getMobile());
shortMsg.setMsg(message);
smsService.insertSMS(shortMsg);
logger.info("----学校Id---"+parentDto.getSchoolId() + "----手机号----"+parentDto.getMobile()+"---"+message);
}
}
// 0是企业号，1是钉钉
private int getThirdType(int type){
if(type == 0){
return PushTypeEnums.QIYEHAO.getType() ;
}else {
return PushTypeEnums.DING.getType() ;
}
}
}