From cdc0cc82123fa48d54803bedb86a64b87bf744cf Mon Sep 17 00:00:00 2001 From: yyb <1416014977@qq.com> Date: Fri, 5 Dec 2025 17:46:29 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E7=A7=9F=E8=B5=81=E7=B3=BB=E7=BB=9F?= =?UTF-8?q?=E8=AE=A2=E5=8D=95=E7=9B=B8=E5=85=B3=E6=8E=A5=E5=8F=A3=EF=BC=8C?= =?UTF-8?q?tcp=E5=AE=A2=E6=88=B7=E7=AB=AF=E7=9B=B8=E5=85=B3=E4=B8=9A?= =?UTF-8?q?=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../m2pool/lease/M2poolLeaseApplication.java | 19 +- .../LeaseOrderInfoV2Controller.java | 80 ++++ .../controller/LeaseProductController.java | 5 +- .../LeaseProductMachineController.java | 1 + .../LeaseProductMachineV2Controller.java | 96 ++++ .../controller/LeaseShopV2Controller.java | 69 +++ .../LeaseShoppingCartController.java | 11 +- .../LeaseShoppingCartV2Controller.java | 73 +++ .../lease/controller/LeaseUserController.java | 20 +- .../com/m2pool/lease/dto/OrderInfoDto.java | 4 + .../com/m2pool/lease/dto/OrderItemDto.java | 4 + .../java/com/m2pool/lease/dto/PageResult.java | 47 ++ .../m2pool/lease/dto/ProductMachineDto.java | 37 +- .../java/com/m2pool/lease/dto/ShopDto.java | 6 + .../com/m2pool/lease/dto/TableHeadersDto.java | 66 +++ .../lease/dto/v2/AlgorithmShopIdMapDto.java | 30 ++ .../lease/dto/v2/AsicCoinAndAlgoDto.java | 44 ++ .../lease/dto/v2/CartMachineInfoDto.java | 108 +++++ .../lease/dto/v2/CoinAndAlgorithmDto.java | 35 ++ .../lease/dto/v2/CoinAndAlgorithmListDto.java | 39 ++ .../com/m2pool/lease/dto/v2/GpuConfigDto.java | 39 ++ .../m2pool/lease/dto/v2/MachineInfoDto.java | 101 ++++ .../lease/dto/v2/MachineInfoInterface.java | 14 + .../lease/dto/v2/MiningCoinInfoDto.java | 43 ++ .../m2pool/lease/dto/v2/MiningConfigDto.java | 46 ++ .../lease/dto/v2/MiningConfigSelectDto.java | 49 ++ .../m2pool/lease/dto/v2/MiningInfoDto.java | 31 ++ .../lease/dto/v2/OrderMiningInfoDto.java | 43 ++ .../dto/v2/PayWithdrawSellerRecordDto.java | 77 +++ .../lease/dto/v2/PowerIncomeInfoDto.java | 50 ++ .../lease/dto/v2/SellerMachineInfoDto.java | 96 ++++ .../m2pool/lease/dto/v2/ShopCartV2Dto.java | 48 ++ .../com/m2pool/lease/dto/v2/ShopInfoDto.java | 58 +++ .../lease/dto/v2/ShopWalletInfoDto.java | 50 ++ .../m2pool/lease/entity/LeaseGpuConfig.java | 64 +++ .../com/m2pool/lease/entity/LeaseMachine.java | 120 +++++ .../lease/entity/LeaseMachineConfig.java | 99 ++++ .../lease/entity/LeaseMachinePrice.java | 59 +++ .../entity/LeaseMiningSoftwareConfig.java | 58 +++ .../m2pool/lease/entity/LeaseOrderItem.java | 2 + .../m2pool/lease/entity/LeaseOrderMining.java | 94 ++++ .../lease/entity/LeasePayWithdrawMessage.java | 5 + .../com/m2pool/lease/entity/LeaseProduct.java | 6 - .../entity/LeaseProductMachinePrice.java | 5 + .../com/m2pool/lease/entity/LeaseShop.java | 13 + .../m2pool/lease/entity/LeaseShopConfig.java | 5 + .../lease/entity/LeaseShoppingCartInfo.java | 18 +- .../exception/GlobalExceptionHandler.java | 5 + .../lease/exception/MachineException.java | 10 + .../lease/mapper/LeaseGpuConfigMapper.java | 27 ++ .../mapper/LeaseMachineConfigMapper.java | 41 ++ .../lease/mapper/LeaseMachineMapper.java | 119 +++++ .../lease/mapper/LeaseMachinePriceMapper.java | 41 ++ .../LeaseMiningSoftwareConfigMapper.java | 16 + .../lease/mapper/LeaseOrderMiningMapper.java | 16 + .../mapper/LeasePayWithdrawMessageMapper.java | 10 + .../mapper/LeaseProductMachineMapper.java | 1 + .../lease/mapper/LeaseShopConfigMapper.java | 15 + .../m2pool/lease/mapper/LeaseShopMapper.java | 8 +- .../mapper/LeaseShoppingCartInfoMapper.java | 7 +- .../com/m2pool/lease/mq/MessageReceiver.java | 41 +- .../lease/netty/handler/ChannelManager.java | 83 ++++ .../netty/handler/MessageToJsonDecoder.java | 43 ++ .../netty/handler/MessageToJsonEncoder.java | 31 ++ .../netty/handler/ServerChannelHandler.java | 301 ++++++++++++ .../message/ClientConfigurationMining.java | 52 ++ .../lease/netty/message/ClientMessage.java | 30 ++ .../netty/message/GpuAndSoftMessage.java | 24 + .../lease/netty/message/GpuMessage.java | 48 ++ .../lease/netty/message/MethodConstant.java | 28 ++ .../message/ServerConfigurationMining.java | 58 +++ .../lease/netty/message/ServerMessage.java | 31 ++ .../parser/ClientConfigMiningParser.java | 19 + .../netty/parser/GpuMessageMapParser.java | 21 + .../lease/netty/parser/MessageParser.java | 21 + .../parser/ServerConfigMiningParser.java | 19 + .../lease/netty/parser/StringParser.java | 19 + .../lease/netty/server/NettyTcpServer.java | 90 ++++ .../server/ServerChannelInitializer.java | 38 ++ .../service/LeaseMachineConfigService.java | 16 + .../service/LeaseMachinePriceService.java | 16 + .../lease/service/LeaseMachineService.java | 80 ++++ .../lease/service/LeaseOrderInfoService.java | 54 ++- .../lease/service/LeaseShopService.java | 39 +- .../service/LeaseShoppingCartService.java | 32 ++ .../lease/service/LeaseUserService.java | 16 + .../impl/LeaseMachineConfigServiceImpl.java | 20 + .../impl/LeaseMachinePriceServiceImpl.java | 20 + .../service/impl/LeaseMachineServiceImpl.java | 444 ++++++++++++++++++ .../impl/LeaseOrderInfoServiceImpl.java | 377 ++++++++++++++- .../service/impl/LeaseShopServiceImpl.java | 180 ++++++- .../impl/LeaseShoppingCartServiceImpl.java | 335 +++++++++---- .../service/impl/LeaseUserServiceImpl.java | 184 +++++++- .../com/m2pool/lease/vo/OrderAndCodeVo.java | 5 +- .../java/com/m2pool/lease/vo/OrderInfoVo.java | 9 +- .../com/m2pool/lease/vo/ProductMachineVo.java | 4 +- .../com/m2pool/lease/vo/ProductPageVo.java | 1 - .../main/java/com/m2pool/lease/vo/ShopVo.java | 4 + .../com/m2pool/lease/vo/v2/AddGoodsVo.java | 35 ++ .../m2pool/lease/vo/v2/AsicCoinAndAlgoVo.java | 44 ++ .../lease/vo/v2/AsicMachineParamsVo.java | 54 +++ .../com/m2pool/lease/vo/v2/CartInfoVo.java | 23 + .../lease/vo/v2/CoinAndAlgorithmVo.java | 26 + .../lease/vo/v2/GpuMachineParamsVo.java | 39 ++ .../m2pool/lease/vo/v2/MachinePayTypeVo.java | 40 ++ .../m2pool/lease/vo/v2/MachineStateVo.java | 34 ++ .../m2pool/lease/vo/v2/SellerMachineVo.java | 34 ++ .../com/m2pool/lease/vo/v2/ShopMachineVo.java | 73 +++ .../m2pool/lease/vo/v2/ShopWalletInfoVo.java | 36 ++ .../src/main/resources/bootstrap-dev.yml | 10 + .../src/main/resources/bootstrap-test.yml | 19 + .../mapper/lease/LeaseGpuConfigMapper.xml | 33 ++ .../mapper/lease/LeaseMachineConfigMapper.xml | 70 +++ .../mapper/lease/LeaseMachineMapper.xml | 410 ++++++++++++++++ .../mapper/lease/LeaseMachinePriceMapper.xml | 42 ++ .../lease/LeaseMiningSoftwareConfigMapper.xml | 20 + .../mapper/lease/LeaseOrderInfoMapper.xml | 3 +- .../mapper/lease/LeaseOrderMiningMapper.xml | 27 ++ .../lease/LeasePayWithdrawMessageMapper.xml | 16 + .../mapper/lease/LeaseProductMapper.xml | 2 +- .../mapper/lease/LeaseShopConfigMapper.xml | 28 ++ .../mapper/lease/LeaseShopMapper.xml | 8 +- .../lease/LeaseShoppingCartInfoMapper.xml | 16 +- 123 files changed, 6180 insertions(+), 198 deletions(-) create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseOrderInfoV2Controller.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseProductMachineV2Controller.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseShopV2Controller.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseShoppingCartV2Controller.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/TableHeadersDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/AlgorithmShopIdMapDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/AsicCoinAndAlgoDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/CartMachineInfoDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/CoinAndAlgorithmDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/CoinAndAlgorithmListDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/GpuConfigDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/MachineInfoDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/MachineInfoInterface.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/MiningCoinInfoDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/MiningConfigDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/MiningConfigSelectDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/MiningInfoDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/OrderMiningInfoDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/PayWithdrawSellerRecordDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/PowerIncomeInfoDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/SellerMachineInfoDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/ShopCartV2Dto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/ShopInfoDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/dto/v2/ShopWalletInfoDto.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/entity/LeaseGpuConfig.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/entity/LeaseMachine.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/entity/LeaseMachineConfig.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/entity/LeaseMachinePrice.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/entity/LeaseMiningSoftwareConfig.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/entity/LeaseOrderMining.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/exception/MachineException.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/mapper/LeaseGpuConfigMapper.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/mapper/LeaseMachineConfigMapper.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/mapper/LeaseMachineMapper.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/mapper/LeaseMachinePriceMapper.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/mapper/LeaseMiningSoftwareConfigMapper.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/mapper/LeaseOrderMiningMapper.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/handler/ChannelManager.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/handler/MessageToJsonDecoder.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/handler/MessageToJsonEncoder.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/handler/ServerChannelHandler.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/message/ClientConfigurationMining.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/message/ClientMessage.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/message/GpuAndSoftMessage.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/message/GpuMessage.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/message/MethodConstant.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/message/ServerConfigurationMining.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/message/ServerMessage.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/parser/ClientConfigMiningParser.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/parser/GpuMessageMapParser.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/parser/MessageParser.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/parser/ServerConfigMiningParser.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/parser/StringParser.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/server/NettyTcpServer.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/netty/server/ServerChannelInitializer.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/service/LeaseMachineConfigService.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/service/LeaseMachinePriceService.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/service/LeaseMachineService.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/service/impl/LeaseMachineConfigServiceImpl.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/service/impl/LeaseMachinePriceServiceImpl.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/service/impl/LeaseMachineServiceImpl.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/v2/AddGoodsVo.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/v2/AsicCoinAndAlgoVo.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/v2/AsicMachineParamsVo.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/v2/CartInfoVo.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/v2/CoinAndAlgorithmVo.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/v2/GpuMachineParamsVo.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/v2/MachinePayTypeVo.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/v2/MachineStateVo.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/v2/SellerMachineVo.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/v2/ShopMachineVo.java create mode 100644 m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/vo/v2/ShopWalletInfoVo.java create mode 100644 m2pool-modules/m2pool-lease/src/main/resources/mapper/lease/LeaseGpuConfigMapper.xml create mode 100644 m2pool-modules/m2pool-lease/src/main/resources/mapper/lease/LeaseMachineConfigMapper.xml create mode 100644 m2pool-modules/m2pool-lease/src/main/resources/mapper/lease/LeaseMachineMapper.xml create mode 100644 m2pool-modules/m2pool-lease/src/main/resources/mapper/lease/LeaseMachinePriceMapper.xml create mode 100644 m2pool-modules/m2pool-lease/src/main/resources/mapper/lease/LeaseMiningSoftwareConfigMapper.xml create mode 100644 m2pool-modules/m2pool-lease/src/main/resources/mapper/lease/LeaseOrderMiningMapper.xml diff --git a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/M2poolLeaseApplication.java b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/M2poolLeaseApplication.java index 3e27c64..6799051 100644 --- a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/M2poolLeaseApplication.java +++ b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/M2poolLeaseApplication.java @@ -3,19 +3,36 @@ package com.m2pool.lease; import com.m2pool.common.security.annotation.EnableCustomConfig; import com.m2pool.common.security.annotation.EnableM2PoolFeignClients; import com.m2pool.common.swagger.annotation.EnableCustomSwagger2; +import com.m2pool.lease.netty.server.NettyTcpServer; +import io.netty.channel.ChannelFuture; import org.mybatis.spring.annotation.MapperScan; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.CommandLineRunner; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; +import javax.annotation.Resource; + @EnableCustomConfig @EnableCustomSwagger2 @EnableM2PoolFeignClients @SpringBootApplication @MapperScan({"com.m2pool.lease.mapper"}) -public class M2poolLeaseApplication { +public class M2poolLeaseApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(M2poolLeaseApplication.class, args); } + @Resource + NettyTcpServer nettyTcpServer; + + + @Override + public void run(String... args) { + //启动服务端 + ChannelFuture start = nettyTcpServer.start(); + //服务端管道关闭的监听器并同步阻塞,直到channel关闭,线程才会往下执行,结束进程 + start.channel().closeFuture().syncUninterruptibly(); + } } diff --git a/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseOrderInfoV2Controller.java b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseOrderInfoV2Controller.java new file mode 100644 index 0000000..c2f003a --- /dev/null +++ b/m2pool-modules/m2pool-lease/src/main/java/com/m2pool/lease/controller/LeaseOrderInfoV2Controller.java @@ -0,0 +1,80 @@ +package com.m2pool.lease.controller; + + +import com.m2pool.lease.dto.PageResult; +import com.m2pool.lease.dto.Result; +import com.m2pool.lease.dto.UserOwnedProductDto; +import com.m2pool.lease.dto.v2.CoinAndAlgorithmListDto; +import com.m2pool.lease.dto.v2.MiningInfoDto; +import com.m2pool.lease.service.LeaseOrderInfoService; +import com.m2pool.lease.vo.BaseVo; +import com.m2pool.lease.vo.OrderAndCodeVo; +import com.m2pool.lease.vo.UserOwnedProductVo; +import com.m2pool.lease.vo.v2.CoinAndAlgorithmVo; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +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; + +/** + *
+ * 订单表 前端控制器 + *
+ * + * @author yyb + * @since 2025-07-23 + */ +@Api(tags = "v2版本--订单控制器") +@RestController +@RequestMapping("/v2/order/info") +public class LeaseOrderInfoV2Controller { + + + @Resource + private LeaseOrderInfoService leaseOrderInfoService; + + @ApiOperation("算法币种选择框:购物车结算获取选中矿机支持的算法和币种列表") + @PostMapping("/getMachineSupportCoinAndAlgorithm") + public Result