update 后台管理新增定时任务开关,收益入库定时任务修改。新增用户待支付汇总 接口

This commit is contained in:
yyb 2025-09-05 14:18:23 +08:00
parent ec8faeb41d
commit f0a2309b42
4 changed files with 22 additions and 12 deletions

View File

@ -80,11 +80,11 @@ public class ManageUserController {
} }
@GetMapping("/summaryOfPendingPayments") @PostMapping("/summaryOfPendingPayments")
@ApiOperation(value = "管理系统:用户待支付汇总") @ApiOperation(value = "管理系统:用户待支付汇总")
@RequiresLogin @RequiresLogin
@RequiresRoles(value = {"back_admin","admin"}, logical = Logical.OR) @RequiresRoles(value = {"back_admin","admin"}, logical = Logical.OR)
public R<List<SummaryOfPendingPaymentsDto>> summaryOfPendingPayments(){ public TableDataInfo<SummaryOfPendingPaymentsDto> summaryOfPendingPayments(@RequestBody PageVo pageVo){
return manageUserService.summaryOfPendingPayments(); return manageUserService.summaryOfPendingPayments(pageVo);
} }
} }

View File

@ -67,5 +67,5 @@ public interface ManageUserService{
* @param coinVo * @param coinVo
* @return * @return
*/ */
R<List<SummaryOfPendingPaymentsDto>> summaryOfPendingPayments(); TableDataInfo<SummaryOfPendingPaymentsDto> summaryOfPendingPayments(PageVo pageVo);
} }

View File

@ -245,7 +245,8 @@ public class ManageUserServiceImpl implements ManageUserService {
} }
@Override @Override
public R<List<SummaryOfPendingPaymentsDto>> summaryOfPendingPayments() { public TableDataInfo<SummaryOfPendingPaymentsDto> summaryOfPendingPayments(PageVo pageVo) {
PageHelper.startPage(pageVo.getPageNum(), pageVo.getPageSize());
List<SummaryOfPendingPaymentsDto> summaryOfPendingPaymentsList = manageWalletOutInMapper.summaryOfPendingPayments(); List<SummaryOfPendingPaymentsDto> summaryOfPendingPaymentsList = manageWalletOutInMapper.summaryOfPendingPayments();
System.out.println("起付额:"+summaryOfPendingPaymentsList); System.out.println("起付额:"+summaryOfPendingPaymentsList);
//查询起付额 //查询起付额
@ -261,12 +262,21 @@ public class ManageUserServiceImpl implements ManageUserService {
// 遍历第一个集合根据 user coin Map 中查找对应的 startPayAmount 并填充 // 遍历第一个集合根据 user coin Map 中查找对应的 startPayAmount 并填充
for (SummaryOfPendingPaymentsDto dto : summaryOfPendingPaymentsList) { for (SummaryOfPendingPaymentsDto dto : summaryOfPendingPaymentsList) {
String key = dto.getUser() + "_" + dto.getCoin(); String key = dto.getUser() + "_" + dto.getCoin();
if (startPayAmountMap.containsKey(key)) { dto.setStartPayAmount(startPayAmountMap.getOrDefault(key, BigDecimal.ZERO));
dto.setStartPayAmount(startPayAmountMap.get(key));
}else{
dto.setStartPayAmount(BigDecimal.ZERO);
} }
return getPageData(summaryOfPendingPaymentsList);
} }
return R.success(summaryOfPendingPaymentsList);
private TableDataInfo<SummaryOfPendingPaymentsDto> getPageData(List<SummaryOfPendingPaymentsDto> list)
{
TableDataInfo<SummaryOfPendingPaymentsDto> rspData = new TableDataInfo<>();
rspData.setCode(HttpStatus.SUCCESS);
rspData.setRows(list);
rspData.setMsg("查询成功");
PageInfo<SummaryOfPendingPaymentsDto> pageInfo = new PageInfo<>(list);
rspData.setTotal(pageInfo.getTotal());
rspData.setTotalPage(pageInfo.getPages());
PageHelper.clearPage();
return rspData;
} }
} }

View File

@ -45,6 +45,6 @@
</where> </where>
</select> </select>
<select id="summaryOfPendingPayments" resultType="com.m2pool.manage.dto.SummaryOfPendingPaymentsDto"> <select id="summaryOfPendingPayments" resultType="com.m2pool.manage.dto.SummaryOfPendingPaymentsDto">
select coin, max(max_height) as maxHeight, max(should_out_date) AS shouldOutDate, `user`, sum(amount) as needPayAmount from wallet_in where state = 2 group by coin,`user`; select coin, max(max_height) as maxHeight, max(should_out_date) AS shouldOutDate, `user`, sum(amount) as needPayAmount from wallet_in where state = 2 group by coin,`user`
</select> </select>
</mapper> </mapper>