初始化galaxy项目

liquidnet-bus-api/liquidnet-service-galaxy-api/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>liquidnet-bus-api</artifactId>
+        <groupId>com.liquidnet</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>liquidnet-service-galaxy-api</artifactId>
+<!--    <dependencies>-->
+<!--        <dependency>-->
+<!--            <groupId>com.liquidnet</groupId>-->
+<!--            <artifactId>liquidnet-service-dragon-do</artifactId>-->
+<!--            <version>1.0-SNAPSHOT</version>-->
+<!--            <scope>compile</scope>-->
+<!--        </dependency>-->
+<!--    </dependencies>-->
+
+</project>

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/constant/GalaxyConstant.java

+package com.liquidnet.service.galaxy.constant;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: GalaxyConstant
+ * @Package com.liquidnet.service.galaxy.constant
+ * @Copyright: LightNet @ Copyright (c) 2022
+ * @date 2022/3/8 11:25
+ */
+public class GalaxyConstant {
+    public static final String REDIS_KET_PAY_CODE="dragon:pay:code:";// 支付流水号
+
+    public enum RouterEnum{
+        ZXINCHAIN("zxinchain","至信链"),
+        ETH ("eth","以太坊"),
+        ANTCHAIN ("antchain","蚂蚁链"),
+        XUPER("xuper","百度超级链");
+        private String code;
+        private String message;
+        RouterEnum(String code, String message) {
+            this.code = code;
+            this.message = message;
+        }
+
+        public String getCode() {
+            return code;
+        }
+    }
+
+    /**
+     * 路由业务枚举
+     */
+    public enum RouterBusinessEnum{
+        NFT("nft","数字藏品nft"),
+        DCI ("dci","数字存证dci");
+        private String code;
+        private String message;
+        RouterBusinessEnum(String code, String message) {
+            this.code = code;
+            this.message = message;
+        }
+
+        public String getCode() {
+            return code;
+        }
+    }
+
+
+    public enum DeviceFromEnum{
+        WEB("web",""),
+        WAP("wap",""),
+        WAPPAGE("wappage",""),
+        APP("app",""),
+        JS("js",""),
+        APPLET("applet","");
+        private String code;
+        private String message;
+        DeviceFromEnum(String code, String message) {
+            this.code = code;
+            this.message = message;
+        }
+        public String getCode() {
+            return code;
+        }
+    }
+
+    public static void main(String[] args) {
+        Integer aaa = 1;
+        if(aaa.toString().equals(RouterEnum.ZXINCHAIN.getCode())){
+            System.out.println("支付成功");
+        }
+    }
+}

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/constant/GalaxyErrorCodeEnum.java

+package com.liquidnet.service.galaxy.constant;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: GalaxyErrorCodeEnum
+ * @Package com.liquidnet.service.galaxy.constant
+ * @Copyright: LightNet @ Copyright (c) 2022
+ * @date 2022/3/8 11:25
+ */
+public enum GalaxyErrorCodeEnum {
+    TRADE_PAY_WAY_ERROR("PAY0010001","错误的支付方式"),
+    TRADE_WEIXIN_ERROR("PAY0010002","微信异常"),
+    TRADE_ORDER_ERROR("PAY0010003","错误的支付方式"),
+
+    TRADE_ORDER_STATUS_NOT_SUCCESS ("PAY0010004","交易不成功"),
+    TRADE_ALIPAY_ERROR ("PAY0010005","支付宝异常"),
+
+    TRADE_PARAM_ERROR("PAY0010006","支付参数异常"),
+
+    TRADE_ERROR_NOT_EXISTS("PAY0010007","订单不存在！"),
+
+    TRADE_ERROR_HAS_PAID("PAY0010008","订单已经支付成功！"),
+
+    TRADE_ALIPAY_SIGN_ERROR("PAY0010009","支付宝签名异常！"),
+
+    TRADE_ALIPAY_QUERY_ERROR("PAY0010010","支付宝订单查询失败！"),
+
+    TRADE_UNIONPAY_QUERY_ERROR("PAY0040002","银联订单查询失败,因缓存消失，查询不到订单导致！"),
+
+    TRADE_WEPAY_SIGN_ERROR("PAY0020001","微信签名异常！"),
+
+    TRADE_DOUYINPAY_SIGN_ERROR("PAY0030001","抖音签名异常！"),
+
+    TRADE_DOUYINPAY_QUERY_ERROR("PAY0030002","抖音查询支付订单异常！"),
+
+    TRADE_UNIONPAY_SIGN_ERROR("PAY0040001","银联签名异常！"),
+
+    TRADE_WEPAY_QUERY_ERROR("PAY0020002","微信订单查询失败！");
+
+    private String code;
+    private String message;
+    DragonErrorCodeEnum(String code, String message) {
+        this.code = code;
+        this.message = message;
+    }
+    public String getCode() {
+        return code;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+}

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/service/IGalaxyArtworkService.java

+package com.liquidnet.service.galaxy.service;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: 区块链艺术品相关
+ * @class: IGalaxyArtworkService
+ * @Package com.liquidnet.service.galaxy.service
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/3/8 11:45
+ */
+public interface IGalaxyArtworkService {
+}

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/service/IGalaxyPublishService.java

+package com.liquidnet.service.galaxy.service;
+
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: 区块链发行相关
+ * @class: IGalaxyPublishService
+ * @Package com.liquidnet.service.galaxy.service
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/3/8 11:45
+ */
+public interface IGalaxyPublishService {
+}

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/service/IGalaxyTradeService.java

+package com.liquidnet.service.galaxy.service;
+
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: 区块链交易相关
+ * @class: IGalaxyTradeService
+ * @Package com.liquidnet.service.galaxy.service
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/3/8 11:45
+ */
+public interface IGalaxyTradeService {
+}

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/service/IGalaxyUserService.java

+package com.liquidnet.service.galaxy.service;
+
+
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: 区块链用户相关
+ * @class: IGalaxyUserService
+ * @Package com.liquidnet.service.galaxy.service
+ * @Copyright: LightNet @ Copyright (c) 2022
+ * @date 2022/3/8 11:45
+ */
+public interface IGalaxyUserService {
+//    ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto);
+//
+//    String dragonNotify(HttpServletRequest request,String payType,String deviceFrom);
+//
+//    DragonPayOrderQueryRespDto checkOrderStatusByCode(String code);
+//
+//    boolean manulNotify(String code);
+}

liquidnet-bus-api/pom.xml

@@ -22,6 +22,7 @@
         <module>liquidnet-service-candy-api</module>
         <module>liquidnet-service-slime-api</module>
         <module>liquidnet-service-stone-api</module>
+        <module>liquidnet-service-galaxy-api</module>
     </modules>
     <dependencies>
         <dependency>

liquidnet-bus-common/liquidnet-common-base/src/main/java/com/liquidnet/commons/lang/util/spring/RestTemplateConfig.java

@@ -100,4 +100,8 @@ public class RestTemplateConfig {
             }
         }
     }
+
+    public static void main(String[] args) {
+        System.out.println(getMaxCpuCore());
+    }
 }

liquidnet-bus-config/liquidnet-config/liquidnet-service-zxlnft-dev.yml → liquidnet-bus-config/liquidnet-config/liquidnet-service-galaxy-dev.yml

@@ -3,12 +3,12 @@ liquidnet:
     updating:
       switch: false
   info:
-    port: 9013
-    context: /zxlnft
-    name: liquidnet-service-zxlnft
+    port: 9015
+    context: /galaxy
+    name: liquidnet-service-galaxy
   logfile:
     path: /data/logs
-    name: service-chime
+    name: service-galaxy
     config: classpath:logback-spring.xml
     file-max-size: 200MB
     pattern-file: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'

liquidnet-bus-do/liquidnet-service-galaxy-do/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>liquidnet-bus-do</artifactId>
+        <groupId>com.liquidnet</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>liquidnet-service-galaxy-do</artifactId>
+
+
+</project>

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/MybatisPlusCodeGenerator.java

+package com.liquidnet.service.galaxy;
+
+import com.baomidou.mybatisplus.core.toolkit.StringPool;
+import com.baomidou.mybatisplus.generator.AutoGenerator;
+import com.baomidou.mybatisplus.generator.InjectionConfig;
+import com.baomidou.mybatisplus.generator.config.*;
+import com.baomidou.mybatisplus.generator.config.po.TableInfo;
+import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;
+import com.baomidou.mybatisplus.generator.engine.FreemarkerTemplateEngine;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class MybatisPlusCodeGenerator {
+    /**
+     * @param moduleRootPath 项目模块根路径 到 /src 之前 ex：E:\projects\trlabs-bus-v1\trlabs-bus-service\trlabs-common\trlabs-mybatis
+     * @param dsc            数据源
+     * @param parentName     相当于业务模块名 com.liquidnet.service.adam 全限定类名
+     * @param tableNames     表名
+     */
+    public static void doGenerator(String moduleRootPath,
+                                   DataSourceConfig dsc,
+                                   String parentName,
+                                   String[] tableNames) {
+        AutoGenerator mpg = new AutoGenerator();
+        // 全局配置BankMybatisPlusCodeGenerator
+        GlobalConfig gc = new GlobalConfig();
+        gc.setOutputDir(moduleRootPath + "/src/main/java");
+        gc.setAuthor("liquidnet");
+        gc.setOpen(false);
+        // gc.setSwagger2(true); 实体属性 Swagger2 注解
+        mpg.setGlobalConfig(gc);
+
+        // 数据源配置
+        mpg.setDataSource(dsc);
+
+        // 包配置
+        PackageConfig pc = new PackageConfig();
+        pc.setParent(parentName);
+        mpg.setPackageInfo(pc);
+
+        // 自定义配置
+        InjectionConfig cfg = new InjectionConfig() {
+            @Override
+            public void initMap() {
+                // to do nothing
+            }
+        };
+
+        // 如果模板引擎是 freemarker
+        String templatePath = "/templates/mapper.xml.ftl";
+        // 自定义输出配置
+        List<FileOutConfig> focList = new ArrayList<>();
+        // 自定义配置会被优先输出
+        focList.add(new FileOutConfig(templatePath) {
+            @Override
+            public String outputFile(TableInfo tableInfo) {
+                // 自定义输出文件名 ， 如果你 Entity 设置了前后缀、此处注意 xml 的名称会跟着发生变化！！
+                return moduleRootPath + "/src/main/resources/com/liquidnet/service/sweet/mapper/" + pc.getModuleName()
+                        + "/" + tableInfo.getEntityName() + "Mapper" + StringPool.DOT_XML;
+            }
+        });
+        cfg.setFileOutConfigList(focList);
+        mpg.setCfg(cfg);
+
+        // 配置模板
+        TemplateConfig templateConfig = new TemplateConfig();
+
+        templateConfig.setXml(null);
+        mpg.setTemplate(templateConfig);
+
+        // 策略配置
+        StrategyConfig strategy = new StrategyConfig();
+        strategy.setNaming(NamingStrategy.underline_to_camel);
+        strategy.setColumnNaming(NamingStrategy.underline_to_camel);
+        // strategy.setSuperEntityClass("你自己的父类实体,没有就不用设置!");
+        strategy.setEntityLombokModel(true);
+        strategy.setRestControllerStyle(true);
+        strategy.setInclude(tableNames);
+        strategy.setControllerMappingHyphenStyle(true);
+        strategy.setTablePrefix(pc.getModuleName() + "_");
+        mpg.setStrategy(strategy);
+        mpg.setTemplateEngine(new FreemarkerTemplateEngine());
+        mpg.execute();
+    }
+
+    public static void main(String[] args) {
+
+        DataSourceConfig dsc = new DataSourceConfig();
+//        dsc.setSchemaName("public");
+        dsc.setDriverName("com.mysql.cj.jdbc.Driver");
+        dsc.setUrl("jdbc:mysql://39.106.122.201:3308/dev_ln_scene?useUnicode=true&useSSL=false&characterEncoding=utf8&serverTimezone=CST");
+        dsc.setUsername("testmall");
+        dsc.setPassword("zhengzai!mYT");
+
+        String resourcePath = "/Users/hujiachen/Downloads/tmp";
+        String directory = "com.liquidnet.service.sweet";
+        String[] dbTableArray = new String[]{"sweet_artists", "sweet_manual", "sweet_manual_artists","sweet_manual_notify", "sweet_richtext","sweet_stage"};
+
+        doGenerator(resourcePath, dsc, directory, dbTableArray);
+    }
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/dto/DragonOrderLogsDto.java

+package com.liquidnet.service.galaxy.dto;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class DragonOrderLogsDto implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Long mid;
+
+    /**
+     * order_id
+     */
+    private String orderId;
+
+    /**
+     * payment_type
+     */
+    private String paymentType;
+
+    /**
+     * content
+     */
+    private String content;
+
+    /**
+     * created_at
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * updated_at
+     */
+    private LocalDateTime updatedAt;
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/dto/DragonOrdersDto.java

+package com.liquidnet.service.galaxy.dto;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: DragonOrdersDto
+ * @Package com.liquidnet.service.galaxy.dto
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/13 19:36
+ */
+@Data
+public class DragonOrdersDto implements Serializable, Cloneable {
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Long mid;
+
+    /**
+     * order_id
+     */
+    private String orderId;
+
+    /**
+     * status
+     */
+    private Integer status;
+
+    /**
+     * code
+     */
+    private String code;
+
+    /**
+     * type
+     */
+    private String type;
+
+    /**
+     * price
+     */
+    private BigDecimal price;
+
+    /**
+     * name
+     */
+    private String name;
+
+    /**
+     * detail
+     */
+    private String detail;
+
+    /**
+     * order_code
+     */
+    private String orderCode;
+
+    /**
+     * order_code_id
+     */
+    private String orderCodeId;
+
+    /**
+     * client_ip
+     */
+    private String clientIp;
+
+    /**
+     * notify_url
+     */
+    private String notifyUrl;
+
+    /**
+     * 通知状态(0初始化 1通知成功 2 通知失败 3通知超时)
+     */
+    private Integer notifyStatus;
+
+    /**
+     * payment_type
+     */
+    private String paymentType;
+
+    /**
+     * payment_id
+     */
+    private String paymentId;
+
+    /**
+     * payment_at
+     */
+    private LocalDateTime paymentAt;
+
+    /**
+     * finished_at
+     */
+    private LocalDateTime finishedAt;
+
+    /**
+     * created_at
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * updated_at
+     */
+    private LocalDateTime updatedAt;
+
+    /**
+     * deleted_at
+     */
+    private LocalDateTime deletedAt;
+
+    private static final DragonOrdersDto obj = new DragonOrdersDto();
+
+    public static DragonOrdersDto getNew() {
+        try {
+            return (DragonOrdersDto) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new DragonOrdersDto();
+        }
+    }
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/entity/DragonOrderLogs.java

+package com.liquidnet.service.galaxy.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 支付订单日志表
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class DragonOrderLogs implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Long mid;
+
+    /**
+     * 订单id
+     */
+    private String code;
+
+    /**
+     * 支付类型
+     */
+    private String paymentType;
+
+    /**
+     * 支付通知内容
+     */
+    private String content;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updatedAt;
+
+    /**
+     * 删除时间
+     */
+    private LocalDateTime deletedAt;
+
+
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/entity/DragonOrderRefundLogs.java

+package com.liquidnet.service.galaxy.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 退款订单信息表
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class DragonOrderRefundLogs implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Long mid;
+
+    /**
+     * 订单id
+     */
+    private String orderId;
+
+    /**
+     * 退款订单id
+     */
+    private String orderRefundId;
+
+    /**
+     * 退款类型
+     */
+    private String refundType;
+
+    /**
+     * 退款通知内容
+     */
+    private String content;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updatedAt;
+
+    /**
+     * 删除时间
+     */
+    private LocalDateTime deletedAt;
+
+
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/entity/DragonOrderRefunds.java

+package com.liquidnet.service.galaxy.entity;
+
+import java.math.BigDecimal;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 退款订单表
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class DragonOrderRefunds implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Long mid;
+
+    /**
+     * order_refund_id
+     */
+    private String orderRefundId;
+
+    /**
+     * 订单id
+     */
+    private Long orderId;
+
+    /**
+     * 订单退款状态
+     */
+    private Integer status;
+
+    /**
+     * 订单退款编号
+     */
+    private String code;
+
+    /**
+     * 调用端订单退款编号
+     */
+    private String orderRefundCode;
+
+    /**
+     * 退款价格
+     */
+    private BigDecimal price;
+
+    /**
+     * 退款原因
+     */
+    private String reason;
+
+    /**
+     * 退款完成通知回调地址
+     */
+    private String notifyUrl;
+
+    /**
+     * 退款类型
+     */
+    private String refundType;
+
+    /**
+     * 退款的订单号
+     */
+    private String refundId;
+
+    /**
+     * 退款失败原因
+     */
+    private String refundError;
+
+    /**
+     * 退款时间
+     */
+    private LocalDateTime refundAt;
+
+    /**
+     * 退款结束时间
+     */
+    private LocalDateTime finishedAt;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updatedAt;
+
+    /**
+     * 删除时间
+     */
+    private LocalDateTime deletedAt;
+
+
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/entity/DragonOrders.java

+package com.liquidnet.service.galaxy.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 支付订单表
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class DragonOrders implements Serializable, Cloneable {
+
+    private static final long serialVersionUID = -4897000205961106873L;
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Long mid;
+
+    /**
+     * order_id
+     */
+    private String orderId;
+
+    /**
+     * 订单状态(0未支付 1支付成功 2支付失败)
+     */
+    private Integer status;
+
+    /**
+     * 订单支付编号
+     */
+    private String code;
+
+    /**
+     * 订单类型
+     */
+    private String type;
+
+    /**
+     * 总价格
+     */
+    private BigDecimal price;
+
+    /**
+     * 类别或名称
+     */
+    private String name;
+
+    /**
+     * 详情或描述
+     */
+    private String detail;
+
+    /**
+     * 调用端订单编号
+     */
+    private String orderCode;
+
+    /**
+     * 用户客户端ip地址
+     */
+    private String clientIp;
+
+    /**
+     * 支付完成通知回调地址
+     */
+    private String notifyUrl;
+
+    /**
+     * 通知状态(0初始化 1通知成功 2 通知失败 3通知超时)
+     */
+    private Integer notifyStatus;
+
+    /**
+     * 支付类型
+     */
+    private String paymentType;
+
+    /**
+     * 支付的订单号
+     */
+    private String paymentId;
+
+    /**
+     * 支付时间
+     */
+    private LocalDateTime paymentAt;
+
+    /**
+     * 结束时间
+     */
+    private LocalDateTime finishedAt;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updatedAt;
+
+    /**
+     * 删除时间
+     */
+    private LocalDateTime deletedAt;
+
+    private static final DragonOrders obj = new DragonOrders();
+
+    public static DragonOrders getNew() {
+        try {
+            return (DragonOrders) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new DragonOrders();
+        }
+    }
+
+
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/entity/DragonPayNotify.java

+package com.liquidnet.service.galaxy.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 支付通知成功
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class DragonPayNotify implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Long mid;
+
+    /**
+     * 订单支付编号
+     */
+    private String code;
+
+    /**
+     * 订单编号
+     */
+    private String orderCode;
+
+    /**
+     * 通知url
+     */
+    private String notifyUrl;
+
+    /**
+     * 通知参数
+     */
+    private String notifyData;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updatedAt;
+
+
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/entity/DragonPayNotifyFail.java

+package com.liquidnet.service.galaxy.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 支付通知失败记录
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class DragonPayNotifyFail implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Long mid;
+
+    /**
+     * 订单支付编号
+     */
+    private String code;
+
+    /**
+     * 订单编号
+     */
+    private String orderCode;
+
+    /**
+     * 通知url
+     */
+    private String notifyUrl;
+
+    /**
+     * 通知参数
+     */
+    private String notifyData;
+
+    /**
+     * 失败描述
+     */
+    private String failDesc;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updatedAt;
+
+
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/mapper/DragonOrderLogsMapper.java

+package com.liquidnet.service.galaxy.mapper;
+
+import com.liquidnet.service.galaxy.entity.DragonOrderLogs;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 支付订单日志表 Mapper 接口
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+public interface DragonOrderLogsMapper extends BaseMapper<DragonOrderLogs> {
+
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/mapper/DragonOrderRefundLogsMapper.java

+package com.liquidnet.service.galaxy.mapper;
+
+import com.liquidnet.service.galaxy.entity.DragonOrderRefundLogs;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 退款订单信息表 Mapper 接口
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+public interface DragonOrderRefundLogsMapper extends BaseMapper<DragonOrderRefundLogs> {
+
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/mapper/DragonOrderRefundsMapper.java

+package com.liquidnet.service.galaxy.mapper;
+
+import com.liquidnet.service.galaxy.entity.DragonOrderRefunds;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 退款订单表 Mapper 接口
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+public interface DragonOrderRefundsMapper extends BaseMapper<DragonOrderRefunds> {
+
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/mapper/DragonOrdersMapper.java

+package com.liquidnet.service.galaxy.mapper;
+
+import com.liquidnet.service.galaxy.entity.DragonOrders;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 支付订单表 Mapper 接口
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+public interface DragonOrdersMapper extends BaseMapper<DragonOrders> {
+
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/mapper/DragonPayNotifyFailMapper.java

+package com.liquidnet.service.galaxy.mapper;
+
+import com.liquidnet.service.galaxy.entity.DragonPayNotifyFail;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 支付通知失败记录 Mapper 接口
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+public interface DragonPayNotifyFailMapper extends BaseMapper<DragonPayNotifyFail> {
+
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/java/com/liquidnet/service/galaxy/mapper/DragonPayNotifyMapper.java

+package com.liquidnet.service.galaxy.mapper;
+
+import com.liquidnet.service.galaxy.entity.DragonPayNotify;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 支付通知成功 Mapper 接口
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-07-20
+ */
+public interface DragonPayNotifyMapper extends BaseMapper<DragonPayNotify> {
+
+}

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/resources/com/liquidnet/service/dragon/mapper/DragonOrderLogsMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.liquidnet.service.dragon.mapper.DragonOrderLogsMapper">
+
+</mapper>

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/resources/com/liquidnet/service/dragon/mapper/DragonOrderRefundLogsMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.liquidnet.service.dragon.mapper.DragonOrderRefundLogsMapper">
+
+</mapper>

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/resources/com/liquidnet/service/dragon/mapper/DragonOrderRefundsMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.liquidnet.service.dragon.mapper.DragonOrderRefundsMapper">
+
+</mapper>

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/resources/com/liquidnet/service/dragon/mapper/DragonOrdersMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.liquidnet.service.dragon.mapper.DragonOrdersMapper">
+
+</mapper>

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/resources/com/liquidnet/service/dragon/mapper/DragonPayNotifyFailMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.liquidnet.service.dragon.mapper.DragonPayNotifyFailMapper">
+
+</mapper>

liquidnet-bus-do/liquidnet-service-galaxy-do/src/main/resources/com/liquidnet/service/dragon/mapper/DragonPayNotifyMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.liquidnet.service.dragon.mapper.DragonPayNotifyMapper">
+
+</mapper>

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>liquidnet-service-zxlnft</artifactId>
+        <groupId>com.liquidnet</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>liquidnet-service-galaxy-impl</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-mongodb</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.liquidnet</groupId>
+            <artifactId>liquidnet-common-third-zxlnft</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+</project>

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/ServiceGalaxyApplication.java

+package com.liquidnet.service;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.core.env.Environment;
+
+import java.net.InetAddress;
+import java.util.Arrays;
+
+@Slf4j
+@EnableFeignClients
+@SpringBootApplication(scanBasePackages = {"com.liquidnet"})
+public class ServiceGalaxyApplication implements CommandLineRunner {
+    @Autowired
+    private Environment environment;
+
+    public static void main(String[] args) {
+        SpringApplication.run(ServiceGalaxyApplication.class, args);
+    }
+
+    @Override
+    public void run(String... strings) {
+        try {
+            log.info("\n----------------------------------------------------------\n\t" +
+                            "Application '{}' is running! Access URLs:\n\t" +
+                            "Local: \t\thttp://127.0.0.1:{}\n\t" +
+                            "External: \thttp://{}:{}{}/doc.html\n\t" +
+                            "Profile(s): \t{}\n----------------------------------------------------------",
+                    environment.getProperty("spring.application.name"),
+                    environment.getProperty("server.port"),
+                    InetAddress.getLocalHost().getHostAddress(),
+                    environment.getProperty("server.port"),
+                    environment.getProperty("server.servlet.context-path"),
+                    Arrays.toString(environment.getActiveProfiles()));
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+}

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/GalaxyRouterStrategyContext.java

+package com.liquidnet.service.galaxy.router.strategy;
+
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: GalaxyRouterStrategyContext
+ * @Package com.liquidnet.service.galaxy.router.strategy
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/3/8 11:26
+ */
+@Component
+public class GalaxyRouterStrategyContext {
+    private final Map<String, IGalaxyRouterStrategy> handlerMap = new HashMap<>();
+
+    public IGalaxyRouterStrategy getStrategy(String type) {
+        return handlerMap.get(type);
+    }
+
+    public void putStrategy(String code, IGalaxyRouterStrategy strategy) {
+        handlerMap.put(code, strategy);
+    }
+}

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/GalaxyRouterStrategyListener.java

+package com.liquidnet.service.galaxy.router.strategy;
+
+import com.liquidnet.service.galaxy.router.strategy.annotation.StrategyPayChannelHandler;
+import org.springframework.context.ApplicationListener;
+import org.springframework.context.event.ContextRefreshedEvent;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: GalaxyRouterStrategyListener
+ * @Package com.liquidnet.service.galaxy.router.strategy
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/3/8 11:26
+ */
+@Component
+public class GalaxyRouterStrategyListener  implements ApplicationListener<ContextRefreshedEvent> {
+    @Override
+    public void onApplicationEvent(ContextRefreshedEvent event) {
+        Map<String, Object> beans = event.getApplicationContext().getBeansWithAnnotation(StrategyPayChannelHandler.class);
+        GalaxyRouterStrategyContext strategyContext = event.getApplicationContext().getBean(PayChannelStrategyContext.class);
+        beans.forEach((name, bean) -> {
+            StrategyPayChannelHandler typeHandler = bean.getClass().getAnnotation(StrategyPayChannelHandler.class);
+            strategyContext.putStrategy(typeHandler.value().getCode(), (IPayChannelStrategy) bean);
+        });
+    }
+}

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/IGalaxyRouterStrategy.java

+package com.liquidnet.service.galaxy.router.strategy;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: Test
+ * @Package com.liquidnet.service.galaxy.router.strategy
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/3/8 10:27
+ */
+public interface IGalaxyRouterStrategy {
+//    ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto);
+//
+//    String dragonNotify(HttpServletRequest request, String payType, String deviceFrom);
+//
+//    DragonPayOrderQueryRespDto checkOrderStatus(String code);
+}

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/annotation/StrategyGalaxyRouterHandler.java

+package com.liquidnet.service.galaxy.router.strategy.annotation;
+
+import java.lang.annotation.*;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: StrategyGalaxyRouterHandler
+ * @Package com.liquidnet.service.galaxy.router.strategy.annotation
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/3/8 11:31
+ */
+@Documented
+@Inherited
+@Target(ElementType.TYPE)
+@Retention(RetentionPolicy.RUNTIME)
+public interface StrategyGalaxyRouterHandler {
+    GalaxyC.PayChannelEnum value();
+}

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/impl/AbstractGalaxyRouterStrategyImpl.java

+package com.liquidnet.service.galaxy.router.strategy.impl;
+
+import com.liquidnet.service.galaxy.router.strategy.IGalaxyRouterStrategy;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: AbstractPayChannelStrategyImpl
+ * @Package com.liquidnet.service.dragon.channel.strategy.impl
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/16 13:04
+ */
+@Slf4j
+public abstract class AbstractGalaxyRouterStrategyImpl implements IGalaxyRouterStrategy {
+//    @Autowired
+//    private DragonPayBiz dragonPayBiz;
+//    @Autowired
+//    private DataUtils dataUtils;
+//
+//    @Autowired
+//    private DragonServiceCommonBiz dragonServiceCommonBiz;
+//
+//    @Override
+//    public abstract ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto);
+//
+//    @Override
+//    public abstract String dragonNotify(HttpServletRequest request, String payType, String deviceFrom);
+//
+//    @Override
+//    public abstract DragonPayOrderQueryRespDto checkOrderStatus(String code);
+//
+//    /**
+//     * 支付成功方法
+//     * @param dragonOrdersDto
+//     * @param bankTrxNo
+//     * @param timeEnd
+//     * @param bankReturnMsg
+//     */
+//    @Transactional(rollbackFor = Exception.class)
+//    protected boolean completeSuccessOrder(DragonOrdersDto dragonOrdersDto, String bankTrxNo, LocalDateTime timeEnd, String bankReturnMsg) {
+//        log.info("订单支付成功!");
+//        dragonOrdersDto.setPaymentAt(timeEnd);
+//        dragonOrdersDto.setPaymentId(bankTrxNo);// 设置银行流水号
+//        dragonOrdersDto.setStatus(Integer.parseInt(DragonConstant.PayStatusEnum.STATUS_PAID.getCode()));
+//        //更新缓存
+//        dataUtils.updateOrderStatus(dragonOrdersDto.getCode(),dragonOrdersDto);
+//        //修改订单状态
+//        dragonServiceCommonBiz.updateOrderStatus(dragonOrdersDto.getCode(),dragonOrdersDto.getStatus(),bankTrxNo);
+//        //通知商户
+//        return dragonPayBiz.sendNotify(dragonPayBiz.buildPayNotifyReqBo(dragonOrdersDto));
+//    }
+//
+//    /**
+//     * 支付失败方法
+//     * @param dragonOrdersDto
+//     * @param bankReturnMsg
+//     */
+//    protected boolean completeFailOrder(DragonOrdersDto dragonOrdersDto, String bankReturnMsg) {
+//        log.info("订单支付失败!");
+////        dragonOrdersDto.setPaymentAt(timeEnd);
+////        dragonOrdersDto.setPaymentId(bankTrxNo);// 设置银行流水号
+//        dragonOrdersDto.setStatus(Integer.parseInt(DragonConstant.PayStatusEnum.STATUS_PAY_FAIL.getCode()));
+//        //更新缓存
+//        dataUtils.updateOrderStatus(dragonOrdersDto.getCode(),dragonOrdersDto);
+//        //修改订单状态
+//        dragonServiceCommonBiz.updateOrderStatus(dragonOrdersDto.getCode(),dragonOrdersDto.getStatus(),null);
+//        //通知商户
+//        return dragonPayBiz.sendNotify(dragonPayBiz.buildPayNotifyReqBo(dragonOrdersDto));
+//    }
+
+}

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/impl/GalaxyRouterStrategyEthImpl.java

+package com.liquidnet.service.galaxy.router.strategy.impl;
+
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.dragon.channel.strategy.annotation.StrategyPayChannelHandler;
+import com.liquidnet.service.dragon.constant.DragonConstant;
+import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
+import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
+import com.liquidnet.service.dragon.dto.DragonPayOrderQueryRespDto;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: PayChannelStrategyApplepayImpl
+ * @Package com.liquidnet.service.dragon.channel.strategy.impl
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/13 13:06
+ */
+@Slf4j
+@Component
+@StrategyPayChannelHandler(DragonConstant.PayChannelEnum.APPLEPAY)
+public class GalaxyRouterStrategyEthImpl extends AbstractGalaxyRouterStrategyImpl {
+
+//    @Override
+//    public ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto) {
+//        return null;
+//    }
+//
+//    @Override
+//    public String dragonNotify(HttpServletRequest request,String payType,String deviceFrom) {
+//        return null;
+//    }
+//
+//    @Override
+//    public DragonPayOrderQueryRespDto checkOrderStatus(String code) {
+//        return null;
+//    }
+}

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/strategy/impl/GalaxyRouterStrategyZxlImpl.java

+package com.liquidnet.service.galaxy.router.strategy.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.alipay.api.AlipayApiException;
+import com.alipay.api.internal.util.AlipaySignature;
+import com.liquidnet.common.exception.LiquidnetServiceException;
+import com.liquidnet.commons.lang.util.DateUtil;
+import com.liquidnet.commons.lang.util.StringUtil;
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.dragon.biz.DragonServiceCommonBiz;
+import com.liquidnet.service.dragon.channel.alipay.biz.AlipayBiz;
+import com.liquidnet.service.dragon.channel.alipay.constant.AlipayConstant;
+import com.liquidnet.service.dragon.channel.alipay.strategy.AlipayStrategyContext;
+import com.liquidnet.service.dragon.channel.strategy.annotation.StrategyPayChannelHandler;
+import com.liquidnet.service.dragon.channel.strategy.biz.DragonPayBiz;
+import com.liquidnet.service.dragon.constant.DragonConstant;
+import com.liquidnet.service.dragon.constant.DragonErrorCodeEnum;
+import com.liquidnet.service.dragon.dto.DragonOrdersDto;
+import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
+import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
+import com.liquidnet.service.dragon.dto.DragonPayOrderQueryRespDto;
+import com.liquidnet.service.dragon.service.impl.DragonOrderRefundsServiceImpl;
+import com.liquidnet.service.dragon.utils.DataUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import javax.servlet.http.HttpServletRequest;
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: PayChannelStrategyAlipayImpl
+ * @Package com.liquidnet.service.dragon.channel.strategy.impl
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/13 13:06
+ */
+@Slf4j
+@Component
+@StrategyPayChannelHandler(DragonConstant.PayChannelEnum.ALIPAY)
+public class GalaxyRouterStrategyZxlImpl extends AbstractGalaxyRouterStrategyImpl {
+//    @Autowired
+//    private AlipayStrategyContext alipayStrategyContext;
+//
+//    @Autowired
+//    private DataUtils dataUtils;
+//
+//    @Autowired
+//    private AlipayBiz alipayBiz;
+//
+//    @Autowired
+//    private DragonPayBiz dragonPayBiz;
+//
+//    @Autowired
+//    private DragonServiceCommonBiz dragonServiceCommonBiz;
+//
+//    @Autowired
+//    private DragonOrderRefundsServiceImpl dragonOrderRefundsService;
+//
+//    @Value("${liquidnet.dragon.alipay.appId}")
+//    private String appId;
+//    @Value("${liquidnet.dragon.alipay.merchantPubKey}")
+//    private String merchantPubKey;
+//    @Value("${liquidnet.dragon.alipay.merchantPrivateKey}")
+//    private String merchantPrivateKey;
+//    @Value("${liquidnet.dragon.alipay.signtType}")
+//    private String signtType;
+//    @Value("${liquidnet.dragon.alipay.charset}")
+//    private String charset;
+//
+//    @Override
+//    public ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto) {
+//        return alipayStrategyContext.getStrategy(dragonPayBaseReqDto.getDeviceFrom()).dragonPay(dragonPayBaseReqDto);
+//    }
+//
+//    @Override
+//    public String dragonNotify(HttpServletRequest request,String payType,String deviceFrom) {
+//        log.info("alipay-->notify-->begin payType:{} deviceFrom:{}",payType,deviceFrom);
+//        Map<String, String[]> requestParams = request.getParameterMap();
+//        Map<String, String> notifyMap = new HashMap<String, String>();
+//        notifyMap = alipayBiz.parseNotifyMsg(requestParams);
+//        log.info("dragonNotify-->alipay json : {}", JSON.toJSONString(notifyMap));
+//        log.info("接收到{}支付结果{}", payType, notifyMap);
+//
+//
+//        String returnStr = "fail";
+//        String code = notifyMap.get("out_trade_no");
+//
+//        //持久化通知记录
+//        dragonServiceCommonBiz.createDragonOrderLogs(code,dragonPayBiz.getPaymentType(payType,deviceFrom),JSON.toJSONString(notifyMap));
+//
+//        //退款
+//        if(notifyMap.containsKey("refund_fee") || notifyMap.containsKey("gmt_refund") || notifyMap.containsKey("out_biz_no")) {
+//            returnStr = dragonOrderRefundsService.aliPayRefundCallBack(JSON.toJSONString(notifyMap));
+//            return returnStr;
+//        }
+//
+//        // 根据银行订单号获取支付信息
+//        DragonOrdersDto dragonOrdersDto = dataUtils.getPayOrderByCode(code);
+//        if (dragonOrdersDto == null) {
+//            throw new LiquidnetServiceException(DragonErrorCodeEnum.TRADE_ERROR_NOT_EXISTS.getCode(),DragonErrorCodeEnum.TRADE_ERROR_NOT_EXISTS.getMessage());
+//        }
+//
+//        if (DragonConstant.PayStatusEnum.STATUS_PAID.getCode().equals(dragonOrdersDto.getStatus())) {
+//            throw new LiquidnetServiceException(DragonErrorCodeEnum.TRADE_ERROR_HAS_PAID.getCode(),DragonErrorCodeEnum.TRADE_ERROR_HAS_PAID.getMessage());
+//        }
+//
+//        try {
+//            if (AlipaySignature.rsaCheckV1(notifyMap, merchantPubKey, "UTF-8", "RSA2")){
+//                String tradeStatus = notifyMap.get("trade_status");
+//                boolean notifyResult = false;
+//
+//                if (AlipayConstant.AlipayTradeStateEnum.TRADE_SUCCESS.name().equals(tradeStatus)
+//                        ||AlipayConstant.AlipayTradeStateEnum.TRADE_FINISHED.name().equals(tradeStatus)) {
+//
+//                    String gmtPaymentStr = notifyMap.get("gmt_payment");// 付款时间
+//                    LocalDateTime timeEnd = null;
+//                    if (!StringUtil.isEmpty(gmtPaymentStr)) {
+//                        timeEnd = DateUtil.Formatter.yyyyMMddHHmmss.parse(gmtPaymentStr);
+//                    }
+//                    notifyResult = this.completeSuccessOrder(dragonOrdersDto, notifyMap.get("trade_no"), timeEnd, notifyMap.toString());
+//                } else {
+//                    notifyResult = this.completeFailOrder(dragonOrdersDto, notifyMap.toString());
+//                }
+//                if(notifyResult){
+//                    returnStr = "success";
+//                }
+//            } else {// 验证失败
+//                log.error("alipay notify fail code:{} msg:{} ",DragonErrorCodeEnum.TRADE_ALIPAY_SIGN_ERROR.getCode(),DragonErrorCodeEnum.TRADE_ALIPAY_SIGN_ERROR.getMessage());
+//                return returnStr;
+//            }
+//        } catch (AlipayApiException e) {
+//            log.error("alipay notify fail 验签失败：e:{}" , e);
+//            log.error("alipay notify fail 验签失败：code:{} msg:{}" ,DragonErrorCodeEnum.TRADE_ALIPAY_SIGN_ERROR.getCode(),DragonErrorCodeEnum.TRADE_ALIPAY_SIGN_ERROR.getMessage());
+//        }
+//
+//        log.info("返回支付通道{}信息{}", payType, returnStr);
+//        log.info("alipay-->notify-->end payType:{} deviceFrom:{}",payType,deviceFrom);
+//        return returnStr;
+//    }
+//
+//    @Override
+//    public DragonPayOrderQueryRespDto checkOrderStatus(String code) {
+//        DragonOrdersDto ordersDto = dataUtils.getPayOrderByCode(code);
+//        Map<String, Object> resultMap = alipayBiz.tradeQuery(code);
+//        DragonPayOrderQueryRespDto respDto = dragonPayBiz.buildPayOrderQueryRespDto(ordersDto);
+//        if ("10000".equals(resultMap.get("code"))) {
+//            // 当返回状态为“TRADE_FINISHED”交易成功结束和“TRADE_SUCCESS”支付成功时更新交易状态
+//            if (AlipayConstant.AlipayTradeStateEnum.TRADE_SUCCESS.getCode().equals(resultMap.get("tradeStatus"))
+//                    || AlipayConstant.AlipayTradeStateEnum.TRADE_FINISHED.getCode().equals(resultMap.get("tradeStatus"))) {
+//                respDto.setStatus(Integer.valueOf(DragonConstant.PayStatusEnum.STATUS_PAID.getCode()));
+//            }else{
+//                respDto.setStatus(Integer.valueOf(DragonConstant.PayStatusEnum.STATUS_PAY_FAIL.getCode()));
+//            }
+////            throw new LiquidnetServiceException(DragonErrorCodeEnum.TRADE_ALIPAY_QUERY_ERROR.getCode(),DragonErrorCodeEnum.TRADE_ALIPAY_QUERY_ERROR.getMessage());
+//        }else if("40004".equals(resultMap.get("code"))&&"ACQ.TRADE_NOT_EXIST".equalsIgnoreCase(resultMap.get("subCode").toString())){
+//            respDto.setStatus(Integer.valueOf(DragonConstant.PayStatusEnum.STATUS_UNPAID.getCode()));
+//        }else{
+//            throw new LiquidnetServiceException(DragonErrorCodeEnum.TRADE_ALIPAY_QUERY_ERROR.getCode(),DragonErrorCodeEnum.TRADE_ALIPAY_QUERY_ERROR.getMessage());
+//        }
+//        return respDto;
+//    }
+}

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/resources/bootstrap-dev.yml

+# begin-dev-这里是配置信息基本值
+liquidnet:
+  cloudConfig:
+    profile: dev
+  security:
+    username: user
+    password: user123
+  eureka:
+    host: 127.0.0.1:7001
+# end-dev-这里是配置信息基本值
+
+spring:
+  profiles:
+    include: service-galaxy

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/resources/bootstrap-prod.yml

+# begin-dev-这里是配置信息基本值
+liquidnet:
+  cloudConfig:
+    profile: prod
+  security:
+    username: user
+    password: user123
+  eureka:
+    host: 172.17.207.189:7001
+# end-dev-这里是配置信息基本值
+
+spring:
+  profiles:
+    include: service-galaxy
\ No newline at end of file

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/resources/bootstrap-test.yml

+# begin-dev-这里是配置信息基本值
+liquidnet:
+  cloudConfig:
+    profile: test
+  security:
+    username: user
+    password: user123
+  eureka:
+    host: 172.17.207.177:7001
+    #instance:
+    #  prefer-ip-address: true
+    #host: eureka-test-0.eureka-test-svc.zhengzai-test:7001/eureka-server/eureka,eureka-test-1.eureka-test-svc.zhengzai-test:7001/eureka-server/eureka,eureka-test-2.eureka-test-svc.zhengzai-test:7001/eureka-server/eureka
+    #host: 192.168.193.41:7001
+# end-dev-这里是配置信息基本值
+
+spring:
+  profiles:
+    include: service-galaxy

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/test/java/com/liquidnet/service/galaxy/TestZxlnftBiz.java

+package com.liquidnet.service.galaxy;
+
+import com.liquidnet.common.third.zxlnft.biz.ZxlnftBiz;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: TestZxlnftBiz
+ * @Package com.liquidnet.service.zxlnft.test
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/2/21 11:44
+ */
+@Slf4j
+@RunWith(SpringJUnit4ClassRunner.class)
+@SpringBootTest
+public class TestZxlnftBiz {
+    @Autowired
+    private ZxlnftBiz zxlnftBiz;
+
+    @Test
+    public void buildHeader(){
+        MultiValueMap<String, String> commonHeader = new LinkedMultiValueMap();
+        zxlnftBiz.buildHeader(commonHeader);
+        System.out.println(commonHeader.toString());
+    }
+
+    @Test
+    public void buildPlatFormHeader(){
+        MultiValueMap<String, String> commonHeader = new LinkedMultiValueMap();
+        zxlnftBiz.buildPlatFormHeader(commonHeader);
+        System.out.println(commonHeader.toString());
+    }
+}

liquidnet-bus-service/liquidnet-service-galaxy/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>liquidnet-bus-service</artifactId>
+        <groupId>com.liquidnet</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>liquidnet-service-galaxy</artifactId>
+    <packaging>pom</packaging>
+    <modules>
+        <module>liquidnet-service-galaxy-impl</module>
+    </modules>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.liquidnet</groupId>
+            <artifactId>liquidnet-common-swagger</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.liquidnet</groupId>
+            <artifactId>liquidnet-common-web</artifactId>
+        </dependency>
+    </dependencies>
+</project>

liquidnet-bus-service/liquidnet-service-meta/liquidnet-service-meta-impl/src/main/resources/bootstrap-service-zxlnft.yml

+#eurekaServer配置
+eureka:
+  client:
+    register-with-eureka: false
+    fetch-registry: true
+    serviceUrl:
+      defaultZone: http://${liquidnet.security.username}:${liquidnet.security.password}@${liquidnet.eureka.host}/eureka-server/eureka
+#configServer配置
+spring:
+  cloud:
+    config:
+#      uri: http://39.105.38.151:7002/support-config
+#      uri: http://39.106.122.201:7002/support-config
+#      uri: http://127.0.0.1:7002/support-config
+      profile: ${liquidnet.cloudConfig.profile}
+      name: ${spring.application.name} #默认为spring.application.name
+      discovery:
+        enabled: true
+        service-id: liquidnet-support-config

liquidnet-bus-service/liquidnet-service-meta/liquidnet-service-meta-impl/src/main/resources/bootstrap.yml

+spring:
+  application:
+    name: liquidnet-service-zxlnft
+  profiles:
+    active: dev

liquidnet-bus-service/liquidnet-service-meta/liquidnet-service-meta-impl/src/main/resources/errors.properties

+40001=登录信息有误
+40002=账号已在另一台设备登录
+40003=登录已过期
+# ------------------------ 4开头错误码作系统保留

liquidnet-bus-service/pom.xml

@@ -42,7 +42,7 @@
         <module>liquidnet-service-candy</module>
         <module>liquidnet-service-slime</module>
         <module>liquidnet-service-stone</module>
-        <module>liquidnet-service-zxlnft</module>
+        <module>liquidnet-service-galaxy</module>
         <!--        <module>liquidnet-service-example</module>-->
 <!--        <module>liquidnet-service-sequence</module>-->
 <!--        <module>liquidnet-service-account</module>-->

liquidnet-bus-support/liquidnet-support-config/src/main/resources/application-dev.yml

@@ -18,8 +18,10 @@ liquidnet:
     username: admin
     password: admin
   config:
-#    location: /Users/hujiachen/IdeaProjects/liquidnet-bus-v1/liquidnet-bus-config/liquidnet-config
-    location: /app/support-config
+#    location: /Users/hujiachen/JavaProject/liquidnet-bus-v1/liquidnet-bus-config/liquidnet-config
+#    location: /app/support-config
+#    location: /Users/edy/Project/liquidnet-bus-v1/liquidnet-bus-config/liquidnet-config
+    location: /Users/anjiabin/mdsky_gitlab/liquidnet-bus-v1/liquidnet-bus-config/liquidnet-config
 # end-dev-这里是配置信息基本值
 
 spring: