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