|
@@ -14,6 +14,7 @@ import com.game.common.core.redis.RedisCache;
|
|
|
import com.game.common.entity.KeyValue;
|
|
import com.game.common.entity.KeyValue;
|
|
|
import com.game.common.utils.DateUtils;
|
|
import com.game.common.utils.DateUtils;
|
|
|
import com.game.common.utils.StringUtils;
|
|
import com.game.common.utils.StringUtils;
|
|
|
|
|
+import lombok.extern.log4j.Log4j2;
|
|
|
import org.redisson.api.RLock;
|
|
import org.redisson.api.RLock;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.scheduling.annotation.Async;
|
|
import org.springframework.scheduling.annotation.Async;
|
|
@@ -27,6 +28,7 @@ import java.util.stream.Collectors;
|
|
|
import java.util.Date;
|
|
import java.util.Date;
|
|
|
|
|
|
|
|
@Service
|
|
@Service
|
|
|
|
|
+@Log4j2
|
|
|
public class AppUserCountServiceImpl extends ServiceImpl<AppUserCountMapper, AppUserCount> implements IAppUserCountService {
|
|
public class AppUserCountServiceImpl extends ServiceImpl<AppUserCountMapper, AppUserCount> implements IAppUserCountService {
|
|
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
@@ -151,6 +153,7 @@ public class AppUserCountServiceImpl extends ServiceImpl<AppUserCountMapper, App
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public void staticsUserCount(Long gameId,String dateTime,String gameDate) {
|
|
public void staticsUserCount(Long gameId,String dateTime,String gameDate) {
|
|
|
|
|
+ log.info("开始更新游戏{}，期号：{}，开奖统计",gameId,gameDate);
|
|
|
Date curDate = DateUtils.getNowDate();
|
|
Date curDate = DateUtils.getNowDate();
|
|
|
if (StringUtils.isNotBlank(dateTime)) {
|
|
if (StringUtils.isNotBlank(dateTime)) {
|
|
|
curDate = DateUtil.parse(dateTime, "yyyy-MM-dd");
|
|
curDate = DateUtil.parse(dateTime, "yyyy-MM-dd");
|
|
@@ -194,6 +197,8 @@ public class AppUserCountServiceImpl extends ServiceImpl<AppUserCountMapper, App
|
|
|
});
|
|
});
|
|
|
//更新周盈亏数据
|
|
//更新周盈亏数据
|
|
|
appUserCountDividendService.reloadCache(null,userIds);
|
|
appUserCountDividendService.reloadCache(null,userIds);
|
|
|
|
|
+ }else{
|
|
|
|
|
+ log.info("游戏{}，期号：{}，未查到开奖数据",gameId,gameDate);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
dos