淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

 fanli/src/main/java/com/yeshi/fanli/job/IntegralTaskJob.java

@@ -1,92 +1,92 @@
package com.yeshi.fanli.job;



import java.util.Date;

import java.util.List;



import javax.annotation.Resource;



import com.yeshi.fanli.entity.SystemEnum;

import com.yeshi.fanli.service.inter.user.UserInfoService;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;



import com.yeshi.fanli.entity.integral.IntegralTaskClass;

import com.yeshi.fanli.entity.integral.IntegralTaskClass.UniqueKeyEnum;

import com.yeshi.fanli.exception.push.PushException;

import com.yeshi.fanli.entity.integral.IntegralTaskRecord;

import com.yeshi.fanli.service.inter.push.PushService;

import com.yeshi.fanli.service.inter.user.integral.IntegralTaskClassService;

import com.yeshi.fanli.service.inter.user.integral.IntegralTaskRecordService;

import com.yeshi.fanli.util.Constant;

import org.yeshi.utils.TimeUtil;



/**

 * 金币任务

 *

 * @author Administrator

 */

@Component

public class IntegralTaskJob {



    @Resource

    private PushService pushService;



    @Resource

    private IntegralTaskRecordService integralTaskRecordService;



    @Resource

    private IntegralTaskClassService integralTaskClassService;



    @Resource

    private UserInfoService userInfoService;



    /**

     * 推送签到提醒(每天15点半查询)

     */

    @Scheduled(cron = "0 30 15 * * ? ")

    public void pushSignInNotify() {

        if (!Constant.IS_TASK)

            return;

        // 获取昨天签到过的

        IntegralTaskClass dailySignClass = integralTaskClassService.getByUniqueKey(UniqueKeyEnum.dailySign.name());

        if (dailySignClass == null)

            return;

        Long cid = dailySignClass.getId();



        long timeStamp = System.currentTimeMillis();

        Date minTime = new Date(TimeUtil.convertToTimeTemp(

                TimeUtil.getGernalTime(timeStamp - 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));

        Date maxTime = new Date(

                TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(timeStamp, "yyyy-MM-dd"), "yyyy-MM-dd"));



        Date todayMinTime = new Date(

                TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(timeStamp, "yyyy-MM-dd"), "yyyy-MM-dd"));



        Date todayMaxTime = new Date(TimeUtil.convertToTimeTemp(

                TimeUtil.getGernalTime(timeStamp + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));



        long count = integralTaskRecordService.countByCidAndUidAndCreateTime(cid, null, minTime, maxTime);

        int page = (int) (count % 200 == 0 ? count / 200 : count / 200 + 1);

        for (int p = 0; p < page; p++) {

            List<IntegralTaskRecord> list = integralTaskRecordService.listByCidAndUidAndCreateTime(cid, null, minTime,

                    maxTime, p + 1, 200);

            if (list != null) {

                for (IntegralTaskRecord record : list) {

                    // 查询今天是否已经签到

                    long todayCount = integralTaskRecordService.countByCidAndUidAndCreateTime(cid, record.getUid(),

                            todayMinTime, todayMaxTime);

                    if (todayCount <= 0) {// 如果未签到，需要推送信息

                        SystemEnum system = userInfoService.getUserSystem(record.getUid());

                        try {

                            pushService.pushUserSignInNotification(record.getUid(), "今日未签到提醒", "今日还未签到，连续签到金币翻倍哦", null,

                                    null,system);

                        } catch (PushException e) {

                            e.printStackTrace();

                        }

                    }

                }

            }

        }

    }



}

package com.yeshi.fanli.job;

import java.util.Date;
import java.util.List;

import javax.annotation.Resource;

import com.yeshi.fanli.entity.SystemEnum;
import com.yeshi.fanli.service.inter.user.UserInfoService;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import com.yeshi.fanli.entity.integral.IntegralTaskClass;
import com.yeshi.fanli.entity.integral.IntegralTaskClass.UniqueKeyEnum;
import com.yeshi.fanli.exception.push.PushException;
import com.yeshi.fanli.entity.integral.IntegralTaskRecord;
import com.yeshi.fanli.service.inter.push.PushService;
import com.yeshi.fanli.service.inter.user.integral.IntegralTaskClassService;
import com.yeshi.fanli.service.inter.user.integral.IntegralTaskRecordService;
import com.yeshi.fanli.util.Constant;
import org.yeshi.utils.TimeUtil;

/**
 * 金币任务
 *
 * @author Administrator
 */
@Component
public class IntegralTaskJob {

    @Resource
    private PushService pushService;

    @Resource
    private IntegralTaskRecordService integralTaskRecordService;

    @Resource
    private IntegralTaskClassService integralTaskClassService;

    @Resource
    private UserInfoService userInfoService;

    /**
     * 推送签到提醒(每天15点半查询)
     */
    @Scheduled(cron = "0 30 15 * * ? ")
    public void pushSignInNotify() {
        if (!Constant.IS_TASK)
            return;
        // 获取昨天签到过的
        IntegralTaskClass dailySignClass = integralTaskClassService.getByUniqueKey(UniqueKeyEnum.dailySign.name());
        if (dailySignClass == null)
            return;
        Long cid = dailySignClass.getId();

        long timeStamp = System.currentTimeMillis();
        Date minTime = new Date(TimeUtil.convertToTimeTemp(
                TimeUtil.getGernalTime(timeStamp - 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));
        Date maxTime = new Date(
                TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(timeStamp, "yyyy-MM-dd"), "yyyy-MM-dd"));

        Date todayMinTime = new Date(
                TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(timeStamp, "yyyy-MM-dd"), "yyyy-MM-dd"));

        Date todayMaxTime = new Date(TimeUtil.convertToTimeTemp(
                TimeUtil.getGernalTime(timeStamp + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));

        long count = integralTaskRecordService.countByCidAndUidAndCreateTime(cid, null, minTime, maxTime);
        int page = (int) (count % 200 == 0 ? count / 200 : count / 200 + 1);
        for (int p = 0; p < page; p++) {
            List<IntegralTaskRecord> list = integralTaskRecordService.listByCidAndUidAndCreateTime(cid, null, minTime,
                    maxTime, p + 1, 200);
            if (list != null) {
                for (IntegralTaskRecord record : list) {
                    // 查询今天是否已经签到
                    long todayCount = integralTaskRecordService.countByCidAndUidAndCreateTime(cid, record.getUid(),
                            todayMinTime, todayMaxTime);
                    if (todayCount <= 0) {// 如果未签到，需要推送信息
                        SystemEnum system = userInfoService.getUserSystem(record.getUid());
                        try {
                            pushService.pushUserSignInNotification(record.getUid(), "今日未签到提醒", "今日还未签到，连续签到金币翻倍哦", null,
                                    null,system);
                        } catch (PushException e) {
                            e.printStackTrace();
                        }
                    }
                }
            }
        }
    }

}