好单库转链支持

admin

2020-06-15 3e4ef41ffacd7f5fda2e81c3810cd11a6375b83c

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

@@ -1,5 +1,6 @@
package com.yeshi.fanli.job.team;



import java.util.Calendar;

import java.util.Date;



import javax.annotation.Resource;

@@ -9,6 +10,7 @@
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;



/**

@@ -35,10 +37,25 @@
   @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.syncInviteData(minTime, maxTime);

      userTeamStatisticManager.syncInviteAndTotalData(minTime, maxTime);

      userTeamStatisticManager.syncVIPData(minTime, maxTime);

      return ReturnT.SUCCESS;

   }