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 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"); // }); // } }