package com.yeshi.fanli.job;
|
|
import java.math.BigDecimal;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Random;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import com.yeshi.fanli.entity.bus.user.UserRankings;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.config.ConfigService;
|
import com.yeshi.fanli.service.inter.taobao.TaoBaoOrderService;
|
import com.yeshi.fanli.service.inter.user.UserRankingsService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.StringUtil;
|
|
/**
|
* 淘宝商品更细
|
*
|
* @author Administrator
|
*
|
*/
|
|
@Component
|
public class UserRankingsJob {
|
|
@Resource
|
private ConfigService configService;
|
|
@Resource
|
private UserRankingsService userRankingsService;
|
|
@Resource
|
private TaoBaoOrderService taoBaoOrderService;
|
|
|
// 1加,2减
|
private static int ADD = 1;
|
|
// 前端显示个数
|
private static int SHOW_NUM = 50;
|
|
// 每天00点10执行 ： 更改排行榜上的奖金
|
@Scheduled(cron = "0 5 0 * * ? ")
|
public void updateReward() {
|
|
if (!Constant.IS_TASK) {
|
return;
|
}
|
|
try {
|
|
LogHelper.test("------执行中--updateReward---------");
|
|
// 清理数据
|
userRankingsService.updateClearTradeState();
|
|
|
// 系统总条数
|
int count = (int) userRankingsService.queryCount(null, null, null);
|
|
Random random = new Random();
|
|
// 随机将显示的50个人信息
|
List<Long> listId = new ArrayList<Long>();
|
while (listId.size() < SHOW_NUM) {
|
long id = random.nextInt(count);
|
if (!listId.contains(id)) {
|
listId.add(id);
|
}
|
}
|
|
// 显示新的人
|
List<UserRankings> listNew = userRankingsService.listQueryByIds(listId);
|
|
Calendar cal=Calendar.getInstance();
|
cal.add(Calendar.DATE,-1);
|
Date time=cal.getTime();
|
|
// 昨日预计总收益
|
double countEstimate = taoBaoOrderService.countEstimate(new SimpleDateFormat("yyyy-MM-dd").format(time));
|
if (countEstimate == 0) {
|
countEstimate = 600;
|
}
|
// 均值：总预计收益*50%
|
double avgAmount = countEstimate * 0.5;
|
|
// 上下 浮动金额范围
|
double rangeAmount = 100;
|
String range = configService.get("reward_rank_range");
|
if (!StringUtil.isNullOrEmpty(range)) {
|
rangeAmount = Double.parseDouble(range);
|
}
|
|
|
for (UserRankings userRankings : listNew) {
|
|
// 状态
|
userRankings.setTradeState(1);
|
userRankings.setTradeTime(new Date());
|
|
// 浮动金额
|
double amount = Math.random() * rangeAmount;
|
|
int[] arr = { 1, 2 };
|
int index = random.nextInt(arr.length);
|
if (ADD == arr[index]) {
|
userRankings.setTradeReward(new BigDecimal(avgAmount + amount));
|
} else {
|
while (amount > avgAmount) {
|
amount = Math.random() * rangeAmount;
|
}
|
userRankings.setTradeReward(new BigDecimal(avgAmount - amount));
|
}
|
}
|
|
// 批量更新昨日数据-移除排行榜
|
userRankingsService.updateBatchSelective(listNew);
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
}
|
|
}
|
