From 4e23775014aeb1be55581696cbbc9dfeef36344b Mon Sep 17 00:00:00 2001 From: yyb <1416014977@qq.com> Date: Mon, 22 Dec 2025 09:43:40 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E7=A7=9F=E8=B5=81=E7=B3=BB=E7=BB=9F1.?= =?UTF-8?q?1.0=20=E9=92=B1=E5=8C=85=E5=9C=B0=E5=9D=80=E5=8F=82=E6=95=B0?= =?UTF-8?q?=E5=8A=A0=E5=AF=86,gpu=E7=9F=BF=E6=9C=BA=E6=96=B0=E5=A2=9E?= =?UTF-8?q?=E5=88=B0=E8=AE=A2=E5=8D=95=E6=B5=81=E7=A8=8B=E6=B5=8B=E8=AF=95?= =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=AD=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/LeaseOrderInfoController.java | 2 ++ .../controller/LeaseShopV2Controller.java | 12 +++++-- .../lease/controller/LeaseUserController.java | 2 ++ .../lease/dto/v2/OrderMiningInfoDto.java | 2 ++ .../lease/mapper/LeaseMachineMapper.java | 7 ++++ .../lease/netty/handler/ChannelManager.java | 22 ++++-------- .../service/impl/LeaseMachineServiceImpl.java | 3 ++ .../com/m2pool/lease/task/info/BlockInfo.java | 34 +++++++++++++++++++ .../java/com/m2pool/lease/vo/BalanceVo.java | 4 ++- .../mapper/lease/LeaseMachineMapper.xml | 16 +++++++-- 10 files changed, 83 insertions(+), 21 deletions(-) create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/task/info/BlockInfo.java diff --git a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseOrderInfoController.java b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseOrderInfoController.java index 714ec68..3cf2e79 100644 --- a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseOrderInfoController.java +++ b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseOrderInfoController.java @@ -2,6 +2,7 @@ package com.m2pool.lease.controller; import com.m2pool.common.security.annotation.RequiresLogin; +import com.m2pool.lease.annotation.Decrypt; import com.m2pool.lease.dto.OrderInfoDto; import com.m2pool.lease.dto.PageResult; import com.m2pool.lease.dto.PaymentRecordDto; @@ -38,6 +39,7 @@ public class LeaseOrderInfoController { @ApiOperation("创建订单及订单详情 + 支付订单(返回二维码内容)") @PostMapping("/addOrders") + @Decrypt public Result addOrders(@RequestBody OrderAndCodeVo orderAndCodeVo) { return leaseOrderInfoService.addOrders(orderAndCodeVo); } diff --git a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseShopV2Controller.java b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseShopV2Controller.java index 58096fd..600f1b2 100644 --- a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseShopV2Controller.java +++ b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseShopV2Controller.java @@ -1,18 +1,22 @@ package com.m2pool.lease.controller; -import com.m2pool.lease.dto.*; +import com.m2pool.lease.annotation.Decrypt; +import com.m2pool.lease.dto.PageResult; +import com.m2pool.lease.dto.Result; import com.m2pool.lease.dto.v2.PayWithdrawSellerRecordDto; import com.m2pool.lease.dto.v2.ShopWalletInfoDto; import com.m2pool.lease.service.LeaseShopService; -import com.m2pool.lease.vo.BalancePageVo; import com.m2pool.lease.vo.BalanceVo; import com.m2pool.lease.vo.BaseVo; import com.m2pool.lease.vo.PageVo; import com.m2pool.lease.vo.v2.ShopWalletInfoVo; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; -import org.springframework.web.bind.annotation.*; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; import java.util.List; @@ -46,12 +50,14 @@ public class LeaseShopV2Controller { @PostMapping("/withdrawBalanceForSeller") @ApiOperation(value = "卖家店铺钱包余额提现") + @Decrypt public Result withdrawBalanceForSeller(@RequestBody BalanceVo balanceVo){ return leaseShopService.withdrawBalanceForSeller(balanceVo); } @ApiOperation("钱包配置----根据配置id 修改商铺收款钱包配置") @PostMapping("/updateShopConfigV2") + @Decrypt public Result updateShopConfigV2(@RequestBody ShopWalletInfoVo shopWalletInfoVo) { return leaseShopService.updateShopConfigV2(shopWalletInfoVo); } diff --git a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseUserController.java b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseUserController.java index 557f4ec..101657e 100644 --- a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseUserController.java +++ b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseUserController.java @@ -2,6 +2,7 @@ package com.m2pool.lease.controller; import com.m2pool.common.security.annotation.RequiresLogin; +import com.m2pool.lease.annotation.Decrypt; import com.m2pool.lease.dto.*; import com.m2pool.lease.service.LeaseUserService; import com.m2pool.lease.vo.*; @@ -52,6 +53,7 @@ public class LeaseUserController { @PostMapping("/withdrawBalance") @ApiOperation(value = "申请余额提现") + @Decrypt public Result withdrawBalance(@RequestBody BalanceVo balanceVo){ return leaseUserService.withdrawBalance(balanceVo); } diff --git a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/OrderMiningInfoDto.java b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/OrderMiningInfoDto.java index b17527d..cf577f6 100644 --- a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/OrderMiningInfoDto.java +++ b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/OrderMiningInfoDto.java @@ -1,5 +1,6 @@ package com.m2pool.lease.dto.v2; +import com.m2pool.lease.annotation.EncryptedField; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.AllArgsConstructor; @@ -33,6 +34,7 @@ public class OrderMiningInfoDto { private Long machineId; @ApiModelProperty(value = "挖矿钱包(用户自己输入)") + @EncryptedField private String walletAddress; @ApiModelProperty(value = "挖矿账号(用户自己输入)") diff --git a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/mapper/LeaseMachineMapper.java b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/mapper/LeaseMachineMapper.java index 976b953..569e927 100644 --- a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/mapper/LeaseMachineMapper.java +++ b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/mapper/LeaseMachineMapper.java @@ -155,4 +155,11 @@ public interface LeaseMachineMapper extends BaseMapper { * @return */ boolean updateBatchSaleNumbers(@Param("list") List list); + + /** + * 检测店铺下是否有已出售的矿机 + * @return + */ + int checkHasSaleMachineByShopId(@Param("shopId") Long shopId); + } diff --git a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/handler/ChannelManager.java b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/handler/ChannelManager.java index 2fe7f92..b5fa676 100644 --- a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/handler/ChannelManager.java +++ b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/handler/ChannelManager.java @@ -19,11 +19,6 @@ public class ChannelManager { */ private static final Map channelMap = new ConcurrentHashMap<>(); - /** - * key channel value mac - */ - public static final Map macMap = new ConcurrentHashMap<>(); - /** * key channel value id */ @@ -49,9 +44,7 @@ public class ChannelManager { Channel channel = channelMap.get(ip); if (channel != null){ idMap.remove(channel); - macMap.remove(channel); channelMap.remove(ip); - } @@ -68,21 +61,20 @@ public class ChannelManager { } /** - * 根据mac地址获取Channel - * @param mac + * 根据id: 邮箱::mac地址获取Channel + * @param id * @return */ - public static Channel getChannelByMac(String mac) { - Optional key = macMap.entrySet() + public static Channel getChannelById(String id) { + Optional key = idMap.entrySet() .stream() - .filter(entry -> mac.equals(entry.getValue())) + .filter(entry -> id.equals(entry.getValue())) .map(Map.Entry::getKey) .findFirst(); return key.orElse(null); } - public static boolean sendToClient(String mac, Object message) { - - Channel channel = getChannelByMac(mac); + public static boolean sendToClient(String id, Object message) { + Channel channel = getChannelById(id); if (channel != null && channel.isActive()) { channel.writeAndFlush(message).syncUninterruptibly(); return false; diff --git a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/service/impl/LeaseMachineServiceImpl.java b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/service/impl/LeaseMachineServiceImpl.java index 39b73e7..96dca13 100644 --- a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/service/impl/LeaseMachineServiceImpl.java +++ b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/service/impl/LeaseMachineServiceImpl.java @@ -210,6 +210,9 @@ public class LeaseMachineServiceImpl extends ServiceImpl getShopMachineListForSeller(SellerMachineVo sellerMachineVo) { LeaseShop leaseShop = getShopById(); + if (leaseShop == null){ + return PageResult.fail(new ArrayList<>(), "暂无店铺"); + } PageHelper.startPage(sellerMachineVo.getPageNum(), sellerMachineVo.getPageSize()); List machineInfoDtoList = leaseMachineMapper.getShopMachineListForSeller(sellerMachineVo,leaseShop.getId()); PageInfo pageInfo = new PageInfo<>(machineInfoDtoList); diff --git a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/task/info/BlockInfo.java b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/task/info/BlockInfo.java new file mode 100644 index 0000000..127f788 --- /dev/null +++ b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/task/info/BlockInfo.java @@ -0,0 +1,34 @@ +package com.m2pool.lease.task.info; + +import lombok.Data; + +import java.math.BigDecimal; + +/** + * @Description 算法信息类 + * @Date 2025/12/16 15:43 + * @Author yyb + */ +@Data +public class BlockInfo { + + /** + * 币种 + */ + private String coin; + + /** + * 每日报块数 + */ + private String blocks; + + /** + * 报块间隔 + */ + private BigDecimal blockInterval; + + /** + * 报块奖励 + */ + private BigDecimal blockReward; +} diff --git a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/BalanceVo.java b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/BalanceVo.java index 2b7aee7..f64fea4 100644 --- a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/BalanceVo.java +++ b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/BalanceVo.java @@ -1,12 +1,12 @@ package com.m2pool.lease.vo; +import com.m2pool.lease.annotation.EncryptedField; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.AllArgsConstructor; import lombok.Builder; import lombok.Data; import lombok.NoArgsConstructor; -import org.apache.poi.openxml4j.opc.PackageRelationship; import java.math.BigDecimal; @@ -48,11 +48,13 @@ public class BalanceVo { private BigDecimal serviceCharge; @ApiModelProperty(value = "绑定的地址",required = true) + @EncryptedField private String fromAddress; /** * 提现地址(用户自定义) */ @ApiModelProperty(value = "提现地址(用户自定义)",required = true) + @EncryptedField private String toAddress; @ApiModelProperty(value = "谷歌双重验证验证码",required = true) diff --git a/m2pool-modules/m2pool-lease/src/main/resources/mapper/lease/LeaseMachineMapper.xml b/m2pool-modules/m2pool-lease/src/main/resources/mapper/lease/LeaseMachineMapper.xml index 55ef04a..7261d98 100644 --- a/m2pool-modules/m2pool-lease/src/main/resources/mapper/lease/LeaseMachineMapper.xml +++ b/m2pool-modules/m2pool-lease/src/main/resources/mapper/lease/LeaseMachineMapper.xml @@ -126,7 +126,7 @@ FROM lease_machine lm JOIN - lease_machine_config gpc ON lm.id = gpc.machine_id AND lm.type = #{shopMachineVo.type} AND lm.shop_id = #{shopMachineVo.shopId} AND lm.online_status = true AND lm.sale_state = 0 + lease_machine_config gpc ON lm.id = gpc.machine_id AND lm.type = #{shopMachineVo.type} AND lm.shop_id = #{shopMachineVo.shopId} AND lm.online_status = true AND lm.sale_state = 0 AND lm.state = 0 GROUP BY lm.id,gpc.coin,gpc.algorithm ) sub LEFT JOIN lease_machine_price mp @@ -139,7 +139,6 @@ AND (sub.coin LIKE CONCAT('%', #{shopMachineVo.keyword}, '%') OR sub.algorithm LIKE CONCAT('%', #{shopMachineVo.keyword}, '%')) - @@ -445,6 +444,8 @@ + + UPDATE lease_machine @@ -456,4 +457,15 @@ + +