package com.sinata.rest.modular.mall.job;
|
|
import cn.hutool.core.date.DateUtil;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.sinata.common.enums.EnumIsDelete;
|
import com.sinata.rest.common.SpringUtil;
|
import com.sinata.rest.core.aliyun.sms.HwSmsApi;
|
import com.sinata.rest.modular.member.model.MemUser;
|
import com.sinata.rest.modular.member.service.IMemUserService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.util.List;
|
|
/**
|
* 定时任务-生日推送（祝福语、礼品券）
|
*/
|
@Slf4j
|
@Component
|
@EnableScheduling
|
public class BirthdayPushWork {
|
|
@Autowired
|
IMemUserService memUserService;
|
|
/**
|
* 生日推送检测
|
*/
|
@Scheduled(cron = "0 0 8 * * *")
|
public void run() {
|
// 非prod环境，终止
|
if(!SpringUtil.getActiveProfile().equals("prod")){
|
return;
|
}
|
log.debug("生日推送检测");
|
|
// 查询生日用户
|
List<MemUser> list = memUserService.list(
|
Wrappers.<MemUser>query().lambda()
|
.eq(MemUser::getIsDelete, EnumIsDelete.EXISTED.index)
|
.likeLeft(MemUser::getBirthday, DateUtil.format(DateUtil.date(), "MM-dd"))
|
);
|
|
for (MemUser o : list) {
|
log.info(o.getId() + o.getNickName() + " 生日快乐！");
|
HwSmsApi.sendSmsBirthday(o.getPhone(), o.getNickName());
|
}
|
}
|
|
}
|
