淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

 fanli/src/main/java/com/yeshi/fanli/job/team/TeamStatisticJob.java

@@ -1,50 +1,63 @@
package com.yeshi.fanli.job.team;



import java.util.Date;



import javax.annotation.Resource;



import org.springframework.stereotype.Component;



import com.xxl.job.core.biz.model.ReturnT;

import com.xxl.job.core.handler.annotation.XxlJob;

import com.yeshi.fanli.service.manger.user.UserTeamStatisticManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;



/**

 * 团队统计

 * @author Administrator

 *

 */

@Component

public class TeamStatisticJob {



   @Resource

   private UserTeamStatisticManager userTeamStatisticManager;



   /**

    * 更新团队统计中的会员等级统计

    * @Title: updatePDDOrder

    * @Description: 
    * @param param

    * @return

    * @throws Exception 
    * ReturnT<String> 返回类型

    * @throws

    */

   @XxlJob("updateTeamStatisticLevelCount")

   public ReturnT<String> updatePDDOrder(String param) throws Exception {

      long now = System.currentTimeMillis();

      if (!StringUtil.isNullOrEmpty(param)) {

         now = TimeUtil.convertToTimeTemp(param, "yyyy-MM-dd");

      }

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

      Date maxTime = new Date(TimeUtil

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

      userTeamStatisticManager.syncInviteAndTotalData(minTime, maxTime);

      userTeamStatisticManager.syncVIPData(minTime, maxTime);

      return ReturnT.SUCCESS;

   }



}

package com.yeshi.fanli.job.team;

import java.util.Calendar;
import java.util.Date;

import javax.annotation.Resource;

import org.springframework.stereotype.Component;

import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.yeshi.fanli.service.manger.user.UserTeamStatisticManager;
import com.yeshi.fanli.util.StringUtil;
import org.yeshi.utils.TimeUtil;

/**
 * 团队统计
 * @author Administrator
 *
 */
@Component
public class TeamStatisticJob {

   @Resource
   private UserTeamStatisticManager userTeamStatisticManager;

   /**
    * 更新团队统计中的会员等级统计
    * @Title: updatePDDOrder
    * @Description: 
    * @param param
    * @return
    * @throws Exception 
    * ReturnT<String> 返回类型
    * @throws
    */
   @XxlJob("updateTeamStatisticLevelCount")
   public ReturnT<String> updatePDDOrder(String param) throws Exception {
      long now = System.currentTimeMillis();
      if (!StringUtil.isNullOrEmpty(param)) {
         now = TimeUtil.convertToTimeTemp(param, "yyyy-MM-dd");
      } else {// 每天零点需要同步上一天的数据
         Calendar calendar = Calendar.getInstance();
         calendar.setTimeInMillis(now);
         if (calendar.get(Calendar.HOUR_OF_DAY) == 0) {
            Date minTime = new Date(TimeUtil.convertToTimeTemp(
                  TimeUtil.getGernalTime(now - 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));
            Date maxTime = new Date(
                  TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(now, "yyyy-MM-dd"), "yyyy-MM-dd"));

            userTeamStatisticManager.syncInviteAndTotalData(minTime, maxTime);
            userTeamStatisticManager.syncVIPData(minTime, maxTime);
         }
      }
      Date minTime = new Date(TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(now, "yyyy-MM-dd"), "yyyy-MM-dd"));
      Date maxTime = new Date(TimeUtil
            .convertToTimeTemp(TimeUtil.getGernalTime(now + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));
      userTeamStatisticManager.syncInviteAndTotalData(minTime, maxTime);
      userTeamStatisticManager.syncVIPData(minTime, maxTime);
      return ReturnT.SUCCESS;
   }

}