| | |
|---|
| | | package cc.mrbird.febs.mall.quartz; |
|---|
| | | |
|---|
| | | import cc.mrbird.febs.common.properties.XcxProperties; |
|---|
| | | import cc.mrbird.febs.common.utils.HttpCurlUtil; |
|---|
| | | import cc.mrbird.febs.common.utils.RedisUtils; |
|---|
| | | import cc.mrbird.febs.common.utils.SpringContextHolder; |
|---|
| | | import cc.mrbird.febs.mall.entity.MallMemberCoupon; |
|---|
| | | import cc.mrbird.febs.mall.mapper.MallMemberCouponMapper; |
|---|
| | | import cc.mrbird.febs.mall.service.MallInvoiceService; |
|---|
| | | import cc.mrbird.febs.pay.util.WechatConfigure; |
|---|
| | | import cn.hutool.core.collection.CollUtil; |
|---|
| | | import cn.hutool.core.date.DateUtil; |
|---|
| | | import cn.hutool.core.util.StrUtil; |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.baomidou.mybatisplus.extension.exceptions.ApiException; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; |
|---|
| | | import org.springframework.scheduling.annotation.Scheduled; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | import org.springframework.web.client.RestTemplate; |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.io.IOException; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.List; |
|---|
| | | |
|---|
| | | @Slf4j |
|---|
| | | @Component |
|---|
| | | @ConditionalOnProperty(prefix = "system", name = "job", havingValue = "true") |
|---|
| | | public class WxxcxJob { |
|---|
| | | |
|---|
| | | private final XcxProperties xcxProperties = SpringContextHolder.getBean(XcxProperties.class); |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private RedisUtils redisUtils; |
|---|
| | | @Autowired |
|---|
| | | private MallMemberCouponMapper mallMemberCouponMapper; |
|---|
| | | @Autowired |
|---|
| | | private MallInvoiceService mallInvoiceService; |
|---|
| | | @Resource |
|---|
| | | RestTemplate restTemplate; |
|---|
| | | // @Autowired |
|---|
| | | // private SpringContextHolder springContextHolder; |
|---|
| | | /** |
|---|
| | | * 获取access_token |
|---|
| | | * 有效期两小时 |
|---|
| | | */ |
|---|
| | | @Scheduled(cron = "0 0/5 * * * ? ") |
|---|
| | | @Scheduled(cron = "0 0 0/1 * * ? ") |
|---|
| | | public void getAccessToken() throws IOException { |
|---|
| | | log.info("执行access_token刷新"); |
|---|
| | | String appId = xcxProperties.getXcxAppid(); |
|---|
| | | String appSecret = xcxProperties.getXcxSecret(); |
|---|
| | | String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appId + "&secret=" + appSecret; |
|---|
| | |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Scheduled(cron = "0 0 0/1 * * ? ") |
|---|
| | | public void expireCoupon() { |
|---|
| | | List<MallMemberCoupon> mallMemberCoupons = mallMemberCouponMapper.selectListByExpireTime(DateUtil.date()); |
|---|
| | | if(CollUtil.isEmpty(mallMemberCoupons)){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | for(MallMemberCoupon mallMemberCoupon : mallMemberCoupons){ |
|---|
| | | mallMemberCoupon.setState(3); |
|---|
| | | mallMemberCouponMapper.updateById(mallMemberCoupon); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | // /** |
|---|
| | | // * 更新发票记录表数据 |
|---|
| | | // * 定时，每天凌晨一点 |
|---|
| | | // * 已完成的订单，更新到发票记录中 |
|---|
| | | // */ |
|---|
| | | // @Scheduled(cron = "0 0 1 * * ?") |
|---|
| | | // public void mallInvoiceJob() { |
|---|
| | | // mallInvoiceService.mallInvoiceJob(); |
|---|
| | | // } |
|---|
| | | |
|---|
| | | } |
|---|
