package com.panzhihua.service_community.schedule;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.panzhihua.common.model.vos.R;
|
import com.panzhihua.common.model.vos.community.acid.ComActAcidMemberVO;
|
import com.panzhihua.common.model.vos.community.reserve.FiveCount;
|
import com.panzhihua.common.utlis.DateUtils;
|
import com.panzhihua.common.utlis.WxUtil;
|
import com.panzhihua.common.utlis.WxXCXTempSend;
|
import com.panzhihua.service_community.dao.ComActAcidMemberDao;
|
import com.panzhihua.service_community.dao.ComActAcidRecordDao;
|
import com.panzhihua.service_community.entity.ComActAcidMember;
|
import com.panzhihua.service_community.entity.ComActAcidRecord;
|
import com.panzhihua.service_community.service.ComActAcidMemberService;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
import java.util.List;
|
|
import static java.util.Objects.nonNull;
|
|
/**
|
* 定时每天早上推送当天防疫数据
|
* @author zzj
|
*/
|
@Component
|
public class AcidSchedule {
|
@Resource
|
private ComActAcidMemberDao comActAcidMemberDao;
|
@Resource
|
private ComActAcidRecordDao comActAcidRecordDao;
|
|
@Scheduled(cron = "0 0 9 * * *")
|
public void push(){
|
List<ComActAcidMemberVO> comActAcidMemberList=comActAcidMemberDao.selectPushList("");
|
comActAcidMemberList.forEach(comActAcidMember -> {
|
FiveCount fiveCount=comActAcidRecordDao.pushStatics(DateUtils.getDateFormatString(DateUtils.addDay(new Date(),-1),"yyyy-MM-dd"),comActAcidMember.getRelationName());
|
WxXCXTempSend util = new WxXCXTempSend();
|
String accessToken = null;
|
try {
|
accessToken = util.getAccessToken();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
WxUtil.sendSubscribeStatics(comActAcidMember.getOpenid(), accessToken, fiveCount, "Yr5idSziLRiRo0t07mcz284sMm41Kr2KsA5UmSc0jWU");
|
});
|
}
|
}
|
