|
@@ -50,7 +50,8 @@ public class KxsUserAmountLogServiceImpl extends ServiceImpl<KxsUserAmountLogMap
|
|
|
public AmountInExpendTotalVO amountInExpendTotal(String tradeMonth) {
|
|
public AmountInExpendTotalVO amountInExpendTotal(String tradeMonth) {
|
|
|
AmountInExpendTotalVO amountInExpendTotalVO = new AmountInExpendTotalVO();
|
|
AmountInExpendTotalVO amountInExpendTotalVO = new AmountInExpendTotalVO();
|
|
|
|
|
|
|
|
-
|
|
|
|
|
|
|
+ //每个请求线程维护一个month数据,避免多线程数据冲突
|
|
|
|
|
+ MonthTableNameHandler.setData(tradeMonth);
|
|
|
QueryWrapper<KxsUserAmountLog> queryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<KxsUserAmountLog> queryWrapper = new QueryWrapper<>();
|
|
|
queryWrapper.eq("user_id", SecurityUtils.getUser().getId());
|
|
queryWrapper.eq("user_id", SecurityUtils.getUser().getId());
|
|
|
queryWrapper.eq("DATE_FORMAT(create_time, '%Y-%m')", tradeMonth);
|
|
queryWrapper.eq("DATE_FORMAT(create_time, '%Y-%m')", tradeMonth);
|
|
@@ -69,7 +70,8 @@ public class KxsUserAmountLogServiceImpl extends ServiceImpl<KxsUserAmountLogMap
|
|
|
queryWrapper.select("IFNULL(SUM(amount),0) AS amount");
|
|
queryWrapper.select("IFNULL(SUM(amount),0) AS amount");
|
|
|
KxsUserAmountLog sub = baseMapper.selectOne(queryWrapper);
|
|
KxsUserAmountLog sub = baseMapper.selectOne(queryWrapper);
|
|
|
amountInExpendTotalVO.setExpend(sub.getAmount());
|
|
amountInExpendTotalVO.setExpend(sub.getAmount());
|
|
|
-
|
|
|
|
|
|
|
+ //删除线程,避免线程污染
|
|
|
|
|
+ MonthTableNameHandler.removeData();
|
|
|
return amountInExpendTotalVO;
|
|
return amountInExpendTotalVO;
|
|
|
}
|
|
}
|
|
|
|
|
|