chore(jobs): 移除定时任务的执行注解

Administrator

17 hours ago f26e65f36e4cc96797a69e2ead3123fd305addd9

chore(jobs): 移除定时任务的执行注解

 src/main/java/cc/mrbird/febs/mall/quartz/BaiduJob.java

@@ -24,41 +24,41 @@
    @Resource
    RestTemplate restTemplate;

    @Scheduled(cron = "0 0 1 * * ? ")
    public void getAccessToken(){
        // 官网获取的 API Key 更新为你注册的
        String clientId = "MPHXcBxkGLIDOmoaahS9pIB7";
        // 官网获取的 Secret Key 更新为你注册的
        String clientSecret = "f5ueNY65fE9C6FzFTVKc6Imo8NdZSWMw";
        String authHost = "https://aip.baidubce.com/oauth/2.0/token?";
        String getAccessTokenUrl = authHost
                // 1. grant_type为固定参数
                + "grant_type=client_credentials"
                // 2. 官网获取的 API Key
                + "&client_id=" + clientId
                // 3. 官网获取的 Secret Key
                + "&client_secret=" + clientSecret;
        String jsonStr = restTemplate.getForObject(getAccessTokenUrl, String.class);

        /**
         * 返回结果
         * {"access_token":"ACCESS_TOKEN","expires_in":7200}
         */
        if (!jsonStr.contains("access_token")) {
            System.out.println("获取access_token失败");
        }
        JSONObject jsonObject = JSONObject.parseObject(jsonStr);
        String accessToken = jsonObject.getString("access_token");

        String accessTokenKey = WechatConfigure.BAIDU_ACCESS_TOKEN_REDIS_KEY;
        if (StrUtil.isEmpty(accessToken)) {
            log.error("获取baidu access_token失败: {}" , jsonObject.getString("errmsg"));
            throw new ApiException("获取access token失败");
        } else {
            log.info("baidu access_token : {}",accessToken);
            System.out.println(accessToken);
            redisUtils.set(accessTokenKey,accessToken);
        }
    }
//    @Scheduled(cron = "0 0 1 * * ? ")
//    public void getAccessToken(){
//        // 官网获取的 API Key 更新为你注册的
//        String clientId = "MPHXcBxkGLIDOmoaahS9pIB7";
//        // 官网获取的 Secret Key 更新为你注册的
//        String clientSecret = "f5ueNY65fE9C6FzFTVKc6Imo8NdZSWMw";
//        String authHost = "https://aip.baidubce.com/oauth/2.0/token?";
//        String getAccessTokenUrl = authHost
//                // 1. grant_type为固定参数
//                + "grant_type=client_credentials"
//                // 2. 官网获取的 API Key
//                + "&client_id=" + clientId
//                // 3. 官网获取的 Secret Key
//                + "&client_secret=" + clientSecret;
//        String jsonStr = restTemplate.getForObject(getAccessTokenUrl, String.class);
//
//        /**
//         * 返回结果
//         * {"access_token":"ACCESS_TOKEN","expires_in":7200}
//         */
//        if (!jsonStr.contains("access_token")) {
//            System.out.println("获取access_token失败");
//        }
//        JSONObject jsonObject = JSONObject.parseObject(jsonStr);
//        String accessToken = jsonObject.getString("access_token");
//
//        String accessTokenKey = WechatConfigure.BAIDU_ACCESS_TOKEN_REDIS_KEY;
//        if (StrUtil.isEmpty(accessToken)) {
//            log.error("获取baidu access_token失败: {}" , jsonObject.getString("errmsg"));
//            throw new ApiException("获取access token失败");
//        } else {
//            log.info("baidu access_token : {}",accessToken);
//            System.out.println(accessToken);
//            redisUtils.set(accessTokenKey,accessToken);
//        }
//    }

}

 src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java

@@ -40,35 +40,35 @@
    @Resource
    private HappyActivityService happyActivityService;

    /**
     * 活动时间结束更新
     *          一分钟运行一次
     */
    @Scheduled(cron = "0 0/1 * * * ? ")
    public void activityEnd() {
        happyActivityService.activityEnd();
    }

    /**
     * 活动时间开始更新
     *          一分钟运行一次
     */
    @Scheduled(cron = "0 0/1 * * * ? ")
    public void activityStart() {

        happyActivityService.activityStart();

    }



    /**
     * 订单失效
     *          五分钟运行一次
     */
    @Scheduled(cron = "0 0/5 * * * ? ")
    public void overtimeJob() {
        happyActivityService.overtimeJob();
    }
//    /**
//     * 活动时间结束更新
//     *          一分钟运行一次
//     */
//    @Scheduled(cron = "0 0/1 * * * ? ")
//    public void activityEnd() {
//        happyActivityService.activityEnd();
//    }
//
//    /**
//     * 活动时间开始更新
//     *          一分钟运行一次
//     */
//    @Scheduled(cron = "0 0/1 * * * ? ")
//    public void activityStart() {
//
//        happyActivityService.activityStart();
//
//    }
//
//
//
//    /**
//     * 订单失效
//     *          五分钟运行一次
//     */
//    @Scheduled(cron = "0 0/5 * * * ? ")
//    public void overtimeJob() {
//        happyActivityService.overtimeJob();
//    }

}

 src/main/java/cc/mrbird/febs/mall/quartz/WxxcxJob.java

@@ -77,27 +77,27 @@

    }

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

}