package com.stylefeng.guns.modular.system.util;
|
|
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.stylefeng.guns.modular.account.controller.AppOrderController;
|
import com.stylefeng.guns.modular.crossCity.server.IOrderCrossCityService;
|
import com.stylefeng.guns.modular.smallLogistics.server.IOrderLogisticsService;
|
import com.stylefeng.guns.modular.specialTrain.model.OrderPrivateCar;
|
import com.stylefeng.guns.modular.specialTrain.server.IOrderPrivateCarService;
|
import com.stylefeng.guns.modular.system.model.UserInfo;
|
import com.stylefeng.guns.modular.system.service.IUserCouponRecordService;
|
import com.stylefeng.guns.modular.system.service.IUserInfoService;
|
import com.stylefeng.guns.modular.system.service.IUserMerchantCouponService;
|
import com.stylefeng.guns.modular.system.util.qianyuntong.SMSUtil;
|
import com.stylefeng.guns.modular.system.util.qianyuntong.model.SendSmsRequest;
|
import com.stylefeng.guns.modular.taxi.model.OrderTaxi;
|
import com.stylefeng.guns.modular.taxi.service.IOrderTaxiService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
|
/**
|
* 定时任务工具类
|
*/
|
@Component
|
public class TaskUtil {
|
|
@Autowired
|
private IUserCouponRecordService userCouponRecordService;
|
|
@Autowired
|
private IUserMerchantCouponService userMerchantCouponService;
|
|
@Autowired
|
private AppOrderController appOrderController;
|
|
@Autowired
|
private IOrderPrivateCarService orderPrivateCarService;
|
|
|
@Autowired
|
private IOrderCrossCityService orderCrossCityService;
|
|
@Autowired
|
private IOrderLogisticsService orderLogisticsService;
|
|
@Autowired
|
private IOrderTaxiService orderTaxiService;
|
|
@Autowired
|
private ChinaMobileUtil chinaMobileUtil;
|
|
@Autowired
|
private IUserInfoService userInfoService;
|
|
|
|
/**
|
* 每隔一分钟去处理的定时任务
|
*/
|
@Scheduled(fixedRate = 1000 * 60)
|
public void taskMinute(){
|
try {
|
//修改过期的优惠券
|
userCouponRecordService.updateTimeOut();
|
//修改过期的商家优惠券
|
userMerchantCouponService.updateExpired();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
/**
|
* 每天的凌晨执行的任务
|
*/
|
@Scheduled(fixedRate = 1000 * 60)
|
public void taskDay(){
|
}
|
|
|
|
/**
|
* 每天中午12点发送提醒短信
|
*/
|
@Scheduled(cron = "0 0 12 * * ?")
|
public void taskMonth(){
|
try {
|
List<OrderPrivateCar> orderPrivateCars = orderPrivateCarService.selectList(new EntityWrapper<OrderPrivateCar>().eq("isDelete", 1)
|
.eq("state", 7).eq("abnormal", 1)
|
.last(" and now() > DATE_ADD(endServiceTime, INTERVAL 24 HOUR)"));
|
for (OrderPrivateCar orderPrivateCar : orderPrivateCars) {
|
UserInfo userInfo = userInfoService.selectById(orderPrivateCar.getUserId());
|
SendSmsRequest request = new SendSmsRequest();
|
request.setDestAddress(userInfo.getPhone());
|
request.setTemplateId("TPL202507300002");
|
Map<String, String> templateParams = new HashMap<>();
|
request.setTemplateParams(templateParams);
|
request.setSpId("Y86asr7J");
|
SMSUtil.sendSms(request);
|
}
|
List<OrderTaxi> orderTaxis = orderTaxiService.selectList(new EntityWrapper<OrderTaxi>().eq("isDelete", 1)
|
.eq("state", 7).eq("abnormal", 1)
|
.last(" and now() > DATE_ADD(endServiceTime, INTERVAL 24 HOUR)"));
|
for (OrderTaxi orderTaxi : orderTaxis) {
|
UserInfo userInfo = userInfoService.selectById(orderTaxi.getUserId());
|
SendSmsRequest request = new SendSmsRequest();
|
request.setDestAddress(userInfo.getPhone());
|
request.setTemplateId("TPL202507300002");
|
Map<String, String> templateParams = new HashMap<>();
|
request.setTemplateParams(templateParams);
|
request.setSpId("Y86asr7J");
|
SMSUtil.sendSms(request);
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
}
|
