淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

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

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



import java.util.Date;

import java.util.List;



import javax.annotation.Resource;



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 com.yeshi.fanli.util.TimeUtil;



/**

 * 金币任务

 * 
 * @author Administrator

 *

 */

@Component

public class IntegralTaskJob {



   @Resource

   private PushService pushService;



   @Resource

   private IntegralTaskRecordService integralTaskRecordService;



   @Resource

   private IntegralTaskClassService integralTaskClassService;



   /**

    * 推送签到提醒(每天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) {// 如果未签到，需要推送信息

                  try {

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

                           null);

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

}