Compare commits
4 Commits
c659fd4930
...
dev
| Author | SHA1 | Date | |
|---|---|---|---|
| c33a55c2fb | |||
| 3811eec33f | |||
| d657598d59 | |||
| 10b9a3cc6d |
@@ -94,7 +94,7 @@ public class ManageUserController {
|
|||||||
return manageUserService.deleteUserAccount(coinVo);
|
return manageUserService.deleteUserAccount(coinVo);
|
||||||
}
|
}
|
||||||
|
|
||||||
@PostMapping("/deleteUserAccount")
|
@PostMapping("/addUserAccount")
|
||||||
@ApiOperation(value = "管理系统:重新上架已下架币种--把以前币种状态设置为5下架的改为 0")
|
@ApiOperation(value = "管理系统:重新上架已下架币种--把以前币种状态设置为5下架的改为 0")
|
||||||
public R<String> addUserAccount(@RequestBody CoinVo coinVo){
|
public R<String> addUserAccount(@RequestBody CoinVo coinVo){
|
||||||
return manageUserService.addUserAccount(coinVo);
|
return manageUserService.addUserAccount(coinVo);
|
||||||
|
|||||||
@@ -142,4 +142,13 @@ public interface ManageBroadcastMapper extends BaseMapper<ManageBroadcast> {
|
|||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
boolean updateUserAccountBalanceStatusByIds(@Param("ids") List<Long> ids, @Param("newStatus") int newStatus);
|
boolean updateUserAccountBalanceStatusByIds(@Param("ids") List<Long> ids, @Param("newStatus") int newStatus);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 更新只读页面表状态
|
||||||
|
* @param coin 币种
|
||||||
|
* @param oldStatus 旧状态
|
||||||
|
* @param newStatus 新状态
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
boolean updatePageInfoStatus(@Param("coin") String coin, @Param("oldStatus") int oldStatus, @Param("newStatus") int newStatus);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,6 @@
|
|||||||
package com.m2pool.manage.service.impl;
|
package com.m2pool.manage.service.impl;
|
||||||
|
|
||||||
|
import cn.hutool.json.JSONUtil;
|
||||||
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageHelper;
|
||||||
import com.github.pagehelper.PageInfo;
|
import com.github.pagehelper.PageInfo;
|
||||||
import com.m2pool.common.core.Result.R;
|
import com.m2pool.common.core.Result.R;
|
||||||
@@ -249,17 +250,16 @@ public class ManageUserServiceImpl implements ManageUserService {
|
|||||||
public TableDataInfo<SummaryOfPendingPaymentsDto> summaryOfPendingPayments(PageVo pageVo) {
|
public TableDataInfo<SummaryOfPendingPaymentsDto> summaryOfPendingPayments(PageVo pageVo) {
|
||||||
PageHelper.startPage(pageVo.getPageNum(), pageVo.getPageSize());
|
PageHelper.startPage(pageVo.getPageNum(), pageVo.getPageSize());
|
||||||
List<SummaryOfPendingPaymentsDto> summaryOfPendingPaymentsList = manageWalletOutInMapper.summaryOfPendingPayments();
|
List<SummaryOfPendingPaymentsDto> summaryOfPendingPaymentsList = manageWalletOutInMapper.summaryOfPendingPayments();
|
||||||
System.out.println("起付额:"+summaryOfPendingPaymentsList);
|
|
||||||
//查询起付额
|
//查询起付额
|
||||||
List<SummaryOfPendingPaymentsDto> startPayments = manageBroadcastMapper.getStartPayments(summaryOfPendingPaymentsList);
|
List<SummaryOfPendingPaymentsDto> startPayments = manageBroadcastMapper.getStartPayments(summaryOfPendingPaymentsList);
|
||||||
|
// 创建一个 Map 用于存储第二个集合中元素的 user 和 coin 组合对应的 startPayAmount
|
||||||
// 创建一个 Map 用于存储第二个集合中元素的 user 和 coin 组合对应的 startPayAmount . 这里可以优化一下,防止多key报错,不过一般不出这个问题
|
|
||||||
Map<String, BigDecimal> startPayAmountMap = startPayments.stream()
|
Map<String, BigDecimal> startPayAmountMap = startPayments.stream()
|
||||||
.collect(Collectors.toMap(
|
.collect(Collectors.toMap(
|
||||||
dto -> dto.getUser() + "_" + dto.getCoin(),
|
dto -> dto.getUser() + "_" + dto.getCoin(),
|
||||||
SummaryOfPendingPaymentsDto::getStartPayAmount
|
SummaryOfPendingPaymentsDto::getStartPayAmount,
|
||||||
|
(existing, replacement) -> replacement
|
||||||
));
|
));
|
||||||
System.out.println("起付额22:"+startPayAmountMap);
|
|
||||||
// 遍历第一个集合,根据 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();
|
||||||
@@ -311,8 +311,9 @@ public class ManageUserServiceImpl implements ManageUserService {
|
|||||||
if (!balanceIds.isEmpty()) {
|
if (!balanceIds.isEmpty()) {
|
||||||
result2 = manageBroadcastMapper.updateUserAccountBalanceStatusByIds(balanceIds, 5);
|
result2 = manageBroadcastMapper.updateUserAccountBalanceStatusByIds(balanceIds, 5);
|
||||||
}
|
}
|
||||||
|
boolean result3 = manageBroadcastMapper.updatePageInfoStatus(coinVo.getCoin(), 0, 5);
|
||||||
|
|
||||||
return (result1 && result2) ? R.success("删除成功") : R.fail("删除失败");
|
return (result1 && result2 && result3) ? R.success("删除成功") : R.fail("删除失败");
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@@ -344,7 +345,8 @@ public class ManageUserServiceImpl implements ManageUserService {
|
|||||||
if (!balanceIds.isEmpty()) {
|
if (!balanceIds.isEmpty()) {
|
||||||
result2 = manageBroadcastMapper.updateUserAccountBalanceStatusByIds(balanceIds, 0);
|
result2 = manageBroadcastMapper.updateUserAccountBalanceStatusByIds(balanceIds, 0);
|
||||||
}
|
}
|
||||||
|
boolean result3 = manageBroadcastMapper.updatePageInfoStatus(coinVo.getCoin(), 5, 0);
|
||||||
|
|
||||||
return (result1 && result2) ? R.success("添加成功") : R.fail("添加失败");
|
return (result1 && result2 && result3) ? R.success("添加成功") : R.fail("添加失败");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -167,10 +167,9 @@
|
|||||||
user_account_balance uab
|
user_account_balance uab
|
||||||
JOIN user_miner_account uma ON uma.id = uab.ma_id
|
JOIN user_miner_account uma ON uma.id = uab.ma_id
|
||||||
WHERE
|
WHERE
|
||||||
uab.status = 0 AND (
|
|
||||||
<foreach collection="list" item="item" separator="OR">
|
<foreach collection="list" item="item" separator="OR">
|
||||||
(`miner_user` = #{item.user} AND coin = #{item.coin})
|
(`miner_user` = #{item.user} AND coin = #{item.coin})
|
||||||
</foreach>)
|
</foreach>
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
<select id="getAccountIdsByCoinAndStatus" resultType="com.m2pool.manage.dto.AccountIdsDto">
|
<select id="getAccountIdsByCoinAndStatus" resultType="com.m2pool.manage.dto.AccountIdsDto">
|
||||||
@@ -193,10 +192,14 @@
|
|||||||
</update>
|
</update>
|
||||||
|
|
||||||
<update id="updateUserAccountBalanceStatusByIds">
|
<update id="updateUserAccountBalanceStatusByIds">
|
||||||
UPDATE user_account_balance SET status = #{newStatus} WHERE ma_id IN
|
UPDATE user_account_balance SET status = #{newStatus} WHERE id IN
|
||||||
<foreach collection="ids" item="id" separator="," open="(" close=")">
|
<foreach collection="ids" item="id" separator="," open="(" close=")">
|
||||||
#{id}
|
#{id}
|
||||||
</foreach>
|
</foreach>
|
||||||
</update>
|
</update>
|
||||||
|
|
||||||
|
<update id="updatePageInfoStatus">
|
||||||
|
UPDATE user_page_info SET status = #{newStatus} WHERE coin = #{coin} AND status = #{oldStatus}
|
||||||
|
</update>
|
||||||
|
|
||||||
</mapper>
|
</mapper>
|
||||||
|
|||||||
@@ -266,7 +266,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
|
|||||||
from
|
from
|
||||||
user_page_info
|
user_page_info
|
||||||
where
|
where
|
||||||
`user` =#{user}
|
`user` =#{user} and status = 0
|
||||||
order by coin,create_time desc
|
order by coin,create_time desc
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user