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