feat cashier mall init

dengwei
1 parent e8bc3fd8
Showing 31 changed files with 1228 additions and 13 deletions
cashier-boss/src/main/java/com/diligrp/cashier/boss/CashierServiceBootstrap.java
cashier-boss/src/main/java/com/diligrp/cashier/boss/aop/LogPrintAop.java
cashier-mall/build.gradle
cashier-mall/src/main/java/com/diligrp/cashier/mall/MallConfiguration.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/MallConstants.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/api/TestRtMallApi.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/dao/package-info.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/RtMarkMessage.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/exception/MallException.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/exception/MallExceptionHandler.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/exception/RtMartMallException.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/property/MallDynamicProperty.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/sign/RtMallSign.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/type/RtMarkErrorCode.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/util/HttpClientUtils.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/util/RtMallSignMd5Utils.java
cashier-mall/src/main/resources/package.json
cashier-shared/build.gradle
cashier-shared/src/main/java/com/diligrp/cashier/shared/annotation/ParamLogPrint.java
cashier-shared/src/main/java/com/diligrp/cashier/shared/annotation/RepeatSubmit.java
 package com.diligrp.cashier.boss;
 import com.diligrp.cashier.assistant.AssistantConfiguration;
+import com.diligrp.cashier.mall.MallConfiguration;
 import com.diligrp.cashier.pipeline.PipelineConfiguration;
 import com.diligrp.cashier.shared.SharedConfiguration;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.SpringBootConfiguration;
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 import org.springframework.context.annotation.Import;
 @SpringBootConfiguration
 @EnableAutoConfiguration
-@Import({BossConfiguration.class, PipelineConfiguration.class, AssistantConfiguration.class, SharedConfiguration.class})
+@Import({BossConfiguration.class, PipelineConfiguration.class,
+        AssistantConfiguration.class, SharedConfiguration.class,
+        MallConfiguration.class
+})
 @EnableDiscoveryClient
 public class CashierServiceBootstrap {
     public static void main(String[] args) {
         SpringApplication.run(CashierServiceBootstrap.class, args);
     }
-}
 \ No newline at end of file
+}
+package com.diligrp.cashier.boss.aop;
+
+import com.diligrp.cashier.shared.annotation.ParamLogPrint;
+import com.diligrp.cashier.shared.util.JsonUtils;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+import org.apache.commons.lang3.BooleanUtils;
+import org.aspectj.lang.JoinPoint;
+import org.aspectj.lang.Signature;
+import org.aspectj.lang.annotation.AfterReturning;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Before;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.*;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName LogPrintAspect.java
+ * @Description 方法参数打印切面
+ */
+@Component
+@Aspect
+@Order(0)
+public class LogPrintAop {
+    private static final Logger log = LoggerFactory.getLogger(LogPrintAop.class);
+    private static final String VERSION = "feat_1.0.0";
+
+    /**
+     * 参数
+     */
+    @Before("@annotation(commonParamLogPrint)")
+    public void paramLogPrint(JoinPoint joinPoint, ParamLogPrint commonParamLogPrint) {
+        try {
+            boolean print = commonParamLogPrint.print();
+            if (!print) {
+                return;
+            }
+            Signature signature = joinPoint.getSignature();
+            // 使用下述方法需要开启--enable-preview预览功能
+            // String className = STR."\{signature.getDeclaringTypeName()}.\{signature.getName()}";
+            String className = signature.getDeclaringTypeName() + "." + signature.getName();
+            Object[] args = joinPoint.getArgs();
+
+            List<Object> argsList = this.listArgs(args);
+
+            Map<String, Object> logInfo = new LinkedHashMap<>(2);
+            logInfo.put("version", VERSION);
+            logInfo.put("method", className);
+            logInfo.put("args", argsList);
+            log.info("{}：{}", commonParamLogPrint.desc(), JsonUtils.toJsonString(logInfo));
+        } catch (Exception exception) {
+            log.warn("param log error");
+        }
+    }
+
+    /**
+     * 处理完请求后执行
+     */
+    @AfterReturning(pointcut = "@annotation(print)", returning = "jsonResult")
+    public void doAfterReturning(JoinPoint joinPoint, ParamLogPrint print, Object jsonResult) {
+        try {
+            if (BooleanUtils.isTrue(print.outPrint())) {
+                log.warn("{} rsp：{}", print.desc(), JsonUtils.toJsonString(jsonResult));
+            }
+        } catch (Exception e) {
+            log.warn("after return error!");
+        }
+    }
+
+    /**
+     * 参数列表
+     *
+     * @param args args
+     * @return {@link List}<{@link Object}>
+     */
+    private List<Object> listArgs(Object[] args) {
+        List<Object> argsList = new LinkedList<>();
+        for (Object arg : args) {
+            Object param;
+            if (arg instanceof HttpServletResponse) {
+                param = HttpServletResponse.class.getSimpleName();
+            } else if (arg instanceof HttpServletRequest) {
+                param = HttpServletRequest.class.getSimpleName();
+            } else if (arg instanceof MultipartFile) {
+                param = MultipartFile.class.getSimpleName();
+            } else {
+                param = arg;
+            }
+            if (Objects.nonNull(param)) {
+                argsList.add(param);
+            }
+        }
+        return argsList;
+    }
+}
 dependencies {
     implementation project(':cashier-shared')
     implementation project(':cashier-trade')
-}
 \ No newline at end of file
+    implementation 'cn.hutool:hutool-http:5.8.42'
+}
+package com.diligrp.cashier.mall;
+
+import com.diligrp.cashier.shared.mybatis.MybatisMapperSupport;
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@ComponentScan("com.diligrp.cashier.mall")
+@MapperScan(basePackages = {"com.diligrp.cashier.mall.dao"}, markerInterface = MybatisMapperSupport.class)
+public class MallConfiguration {
+
+}
+package com.diligrp.cashier.mall;
+
+
+public interface MallConstants {
+    String RESULT_SUCCESS = "success";
+    String RESULT_FAILURE = "fail";
+
+    Integer RT_MALL_SOURCE = 1;
+}
+package com.diligrp.cashier.mall.api;
+
+import com.diligrp.cashier.mall.sign.RtMallSign;
+import com.diligrp.cashier.shared.annotation.Sign;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @ClassName TestRtMallApi.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description TestRtMallApi
+ */
+@RestController
+@RequestMapping("/test")
+public class TestRtMallApi {
+    private static final Logger log = LoggerFactory.getLogger(TestRtMallApi.class);
+
+    @RequestMapping("/sign")
+    @Sign(sign = RtMallSign.class)
+    public String rtMall(@RequestBody Object request) {
+        log.info("rt mall");
+        return "rt mall";
+    }
+}
+/**
+ * @ClassName package-info.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description TODO
+ * @date 2025-12-23 17:30
+ */
+package com.diligrp.cashier.mall.dao;
+package com.diligrp.cashier.mall.domain;
+
+import com.diligrp.cashier.mall.MallConstants;
+import com.diligrp.cashier.mall.type.RtMarkErrorCode;
+
+/**
+ * 大润发返回消息
+ *
+ * @author dengwei
+ * @date 2025/12/24 18:05
+ */
+public class RtMarkMessage<T> {
+    private String result;
+    private String code;
+    private String msg;
+    private T data;
+
+    public RtMarkMessage() {
+    }
+
+    public String getResult() {
+        return result;
+    }
+
+    public void setResult(String result) {
+        this.result = result;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    public T getData() {
+        return data;
+    }
+
+    public void setData(T data) {
+        this.data = data;
+    }
+
+    public static RtMarkMessage<?> success() {
+        return failure(RtMarkErrorCode.E0000.getCode(), MallConstants.RESULT_SUCCESS);
+    }
+
+    public static <E> RtMarkMessage<E> success(E data) {
+        RtMarkMessage<E> result = new RtMarkMessage<>();
+        result.code = RtMarkErrorCode.E0000.getCode();
+        result.result = MallConstants.RESULT_SUCCESS;
+        result.data = data;
+        return result;
+    }
+
+    public static RtMarkMessage<?> failure(String message) {
+        return failure(RtMarkErrorCode.E5000.getCode(), message);
+    }
+
+    public static RtMarkMessage<?> failure(String code, String message) {
+        RtMarkMessage<?> result = new RtMarkMessage<>();
+        result.setResult(MallConstants.RESULT_FAILURE);
+        result.code = code;
+        result.msg = message;
+        return result;
+    }
+}
+package com.diligrp.cashier.mall.exception;
+
+
+import com.diligrp.cashier.shared.ErrorCode;
+import com.diligrp.cashier.shared.exception.PlatformServiceException;
+
+/**
+ * @ClassName MallException.java
+ * @author dengwei
+ * @version 1.0.0
+ * @date 2025-12-25 14:34
+ */
+public class MallException extends PlatformServiceException {
+
+    public MallException(String message) {
+        super(ErrorCode.SYSTEM_UNKNOWN_ERROR, message);
+    }
+
+    public MallException(String code, String message) {
+        super(code, message);
+    }
+}
+package com.diligrp.cashier.mall.exception;
+
+import com.diligrp.cashier.mall.domain.RtMarkMessage;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.core.annotation.Order;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+/**
+ * 商城独立处理器
+ * 优先于默认
+ * 大润发方已经确定好了一套返回标准
+ *
+ * @author dengwei
+ */
+@RestControllerAdvice
+@Order(-1)
+public class MallExceptionHandler {
+    private final Logger LOG = LoggerFactory.getLogger(this.getClass());
+
+    @ExceptionHandler(RtMartMallException.class)
+    public RtMarkMessage<?> rtMartMallException(RtMartMallException ex) {
+        LOG.warn("rt mart mall exception", ex);
+        return RtMarkMessage.failure(ex.getCode(), ex.getMessage());
+    }
+}
+package com.diligrp.cashier.mall.exception;
+
+import com.diligrp.cashier.mall.MallConstants;
+import com.diligrp.cashier.mall.type.RtMarkErrorCode;
+import com.diligrp.cashier.shared.ErrorCode;
+
+/**
+ * @ClassName RtmartMallException.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description 大润发异常
+ * @date 2025-12-24 18:05
+ */
+public class RtMartMallException extends MallException {
+    public RtMartMallException(String message) {
+        super(RtMarkErrorCode.E5000.getCode(), message);
+    }
+
+    public RtMartMallException(int code) {
+        super(RtMarkErrorCode.E5000.getCode(), ErrorCode.MESSAGE_SYSTEM_BUSY);
+    }
+
+    public RtMartMallException(String code, String message) {
+        super(code, message);
+    }
+}
+package com.diligrp.cashier.mall.property;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.Optional;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName MallDynamicProperty.java
+ * @Description MallDynamicProperty
+ */
+@Configuration
+@RefreshScope
+@ConfigurationProperties(prefix = "sign")
+public class MallDynamicProperty {
+
+    private List<AppSecretDynamicProperty> appSecrets;
+
+    public static class AppSecretDynamicProperty {
+        @Value("${source:1}")
+        private Integer source;
+
+        @Value("${appKey:}")
+        private String appKey;
+
+        @Value("${appSecret:}")
+        private String appSecret;
+
+        @Value("${authUrl:https://hourh5-em-shop.feiniugo.com}")
+        private String authUrl;
+
+        public Integer getSource() {
+            return source;
+        }
+
+        public void setSource(Integer source) {
+            this.source = source;
+        }
+
+        public String getAppKey() {
+            return appKey;
+        }
+
+        public void setAppKey(String appKey) {
+            this.appKey = appKey;
+        }
+
+        public String getAppSecret() {
+            return appSecret;
+        }
+
+        public void setAppSecret(String appSecret) {
+            this.appSecret = appSecret;
+        }
+
+        public String getAuthUrl() {
+            return authUrl;
+        }
+
+        public void setAuthUrl(String authUrl) {
+            this.authUrl = authUrl;
+        }
+    }
+
+    public List<AppSecretDynamicProperty> getAppSecrets() {
+        return appSecrets;
+    }
+
+    public void setAppSecrets(List<AppSecretDynamicProperty> appSecrets) {
+        this.appSecrets = appSecrets;
+    }
+
+    /**
+     * getBySource
+     *
+     */
+    public AppSecretDynamicProperty getBySource(Integer source) {
+        return Optional.ofNullable(appSecrets)
+                .orElse(Collections.emptyList())
+                .stream()
+                .filter(item -> item.getSource().equals(source))
+                .findFirst()
+                .orElse(null);
+    }
+}
+package com.diligrp.cashier.mall.sign;
+
+import com.diligrp.cashier.mall.MallConstants;
+import com.diligrp.cashier.mall.exception.RtMartMallException;
+import com.diligrp.cashier.mall.property.MallDynamicProperty;
+import com.diligrp.cashier.mall.type.RtMarkErrorCode;
+import com.diligrp.cashier.mall.util.RtMallSignMd5Utils;
+import com.diligrp.cashier.shared.handler.sign.SecuritySign;
+import com.diligrp.cashier.shared.util.JsonUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
+import jakarta.annotation.Resource;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+import org.springframework.util.Assert;
+
+import java.util.Objects;
+import java.util.TreeMap;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName RtMallSign.java
+ * @Description RtMallSign
+ * 大润发参数验签
+ */
+@Component
+public class RtMallSign implements SecuritySign {
+    private static final Logger log = LoggerFactory.getLogger(RtMallSign.class);
+
+    @Resource
+    private MallDynamicProperty mallDynamicProperty;
+
+    @Override
+    public void sign(HttpServletRequest request, HttpServletResponse response, Object data) {
+        log.info("allParameters:{}", JsonUtils.toJsonString(data));
+
+        TreeMap<String, Object> paramMap = JsonUtils.fromJsonString(JsonUtils.toJsonString(data), new TypeReference<>() {
+        });
+
+        Object appKey = paramMap.get("app_key");
+        if (Objects.isNull(appKey)) {
+            throw new RtMartMallException(RtMarkErrorCode.E4003.getCode(), RtMarkErrorCode.E4003.getMessage());
+        }
+
+        MallDynamicProperty.AppSecretDynamicProperty property = mallDynamicProperty.getBySource(MallConstants.RT_MALL_SOURCE);
+        if (Objects.isNull(property)) {
+            throw new RtMartMallException(RtMarkErrorCode.E4001.getCode(), RtMarkErrorCode.E4001.getMessage());
+        }
+
+        try {
+            log.info("appKey：{}, secretKey：{}", property.getAppKey(), property.getAppSecret());
+            String signKey = RtMallSignMd5Utils.generateSign(paramMap, property.getAppSecret());
+            Assert.isTrue(Objects.equals(signKey, paramMap.get("sign").toString()), "验签失败！");
+        } catch (Exception e) {
+            throw new RtMartMallException(RtMarkErrorCode.E4004.getCode(), RtMarkErrorCode.E4004.getMessage());
+        }
+    }
+}
+package com.diligrp.cashier.mall.type;
+
+/**
+ * @ClassName RtmarkErrorCode.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description RtmarkErrorCode
+ * @date 2025-12-23 18:25
+ */
+public enum RtMarkErrorCode {
+    E0000("E0000", "成功"),
+    E4001("E4001", "验签缺少参数"),
+    E4002("E4002", "timestamp 不合法"),
+    E4003("E4003", "app_key 错误"),
+    E4004("E4004", "签名错误"),
+    E5000("E5000", "未知错误");
+
+    private final String code;
+    private final String message;
+
+    RtMarkErrorCode(String code, String message) {
+        this.code = code;
+        this.message = message;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+}
+package com.diligrp.cashier.mall.util;
+
+import cn.hutool.core.util.IdUtil;
+import cn.hutool.http.HttpException;
+import cn.hutool.http.HttpRequest;
+import com.diligrp.cashier.mall.exception.MallException;
+import com.diligrp.cashier.shared.util.JsonUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.MediaType;
+
+import java.util.Map;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName HttpClientUtils.java
+ * @Description HttpClientUtils
+ * @date 2025-12-24 14:54
+ */
+public class HttpClientUtils {
+    private static final Logger log = LoggerFactory.getLogger(HttpClientUtils.class);
+
+    /**
+     * postJson
+     */
+    public static String postJson(String url,
+                                  Object body,
+                                  Map<String, String> header,
+                                  String serviceName) {
+
+        try {
+            String traceId = IdUtil.fastSimpleUUID();
+            log.info("traceId:{}，url:{}, body:{}", traceId, url, JsonUtils.toJsonString(body));
+            String responseBody = HttpRequest
+                    .post(url)
+                    .header("content-type", MediaType.APPLICATION_JSON_VALUE)
+                    .addHeaders(header)
+                    .timeout(60000)
+                    .body(JsonUtils.toJsonString(body))
+                    .execute()
+                    .body();
+            if (StringUtils.isBlank(responseBody)) {
+                return null;
+            }
+            log.info("traceId:{}，responseBody:{}", traceId, responseBody);
+            return responseBody;
+        } catch (HttpException e) {
+            log.error("http error url：{}", url, e);
+            throw new MallException(serviceName + "服务异常！");
+        }
+    }
+
+    /**
+     * postJson
+     */
+    public static <R> R postJson(String url,
+                                 Object body,
+                                 Map<String, String> header,
+                                 TypeReference<R> jsonTypeReference,
+                                 String serviceName) {
+        String responseBody = postJson(url, body, header, serviceName);
+        if (StringUtils.isBlank(responseBody)) {
+            return null;
+        }
+        return JsonUtils.fromJsonString(responseBody, jsonTypeReference);
+    }
+}
+package com.diligrp.cashier.mall.util;
+
+import com.diligrp.cashier.shared.util.JsonUtils;
+import com.fasterxml.jackson.core.type.TypeReference;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.security.MessageDigest;
+import java.util.*;
+
+/**
+ * @ClassName SignMd5Utils.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description
+ * 签名算法
+ * 参考大润发定义：https://shopex.yuque.com/hl0rrx/vlp0m4/kmcazgnimg28d8ih?singleDoc#
+ */
+public class RtMallSignMd5Utils {
+    private static final Logger log = LoggerFactory.getLogger(RtMallSignMd5Utils.class);
+
+    /**
+     * 生成签名
+     *
+     */
+    public static String generateSign(Object data, String appSecret) {
+        Map<String, Object> params = JsonUtils.convertValueV2(data, new TypeReference<>() {
+        });
+        // 1. 过滤 null，转换 boolean，递归规范化并排序
+        String normalized = normalizeAndSort(params);
+        log.info("normalize: {}", normalized);
+        // 2. 拼接私钥
+        String signSource = appSecret + normalized + appSecret;
+        log.info("signSource: {}", signSource);
+        // 3. MD5 + 大写
+        String sign = md5ToUpper(signSource);
+        log.info("sign: {}", sign);
+        return sign;
+    }
+
+    /**
+     * 递归规范化并排序，返回拼接字符串（无分隔符）
+     */
+    @SuppressWarnings("unchecked")
+    private static String normalizeAndSort(Object obj) {
+        switch (obj) {
+            case null -> {
+                return "";
+            }
+            case Map map1 -> {
+                Map<String, Object> map = (Map<String, Object>) obj;
+                // 过滤 null，并转换 boolean
+                Map<String, Object> filtered = new LinkedHashMap<>();
+                for (Map.Entry<String, Object> entry : map.entrySet()) {
+                    if (entry.getValue() == null) {
+                        continue;
+                    }
+                    Object val = convertBoolean(entry.getValue());
+                    filtered.put(entry.getKey(), val);
+                }
+                // 按 key 字典序排序
+                List<String> sortedKeys = new ArrayList<>(filtered.keySet());
+                Collections.sort(sortedKeys); // 字典序
+
+
+                StringBuilder sb = new StringBuilder();
+                for (String key : sortedKeys) {
+                    sb.append(key).append(normalizeAndSort(filtered.get(key)));
+                }
+                return sb.toString();
+            }
+            case List list1 -> {
+                List<Object> list = (List<Object>) obj;
+                // 转为 Map<String, Object>，key 为索引字符串
+                Map<String, Object> indexMap = new LinkedHashMap<>();
+                for (int i = 0; i < list.size(); i++) {
+                    indexMap.put(String.valueOf(i), list.get(i));
+                }
+                // 递归处理（会自动过滤 null、转换 boolean、排序 key）
+                return normalizeAndSort(indexMap);
+                // 递归处理（会自动过滤 null、转换 boolean、排序 key）
+            }
+            case Object[] array -> {
+                // 处理数组类型，转换为 Map 并递归处理
+                Map<String, Object> arrayMap = new LinkedHashMap<>();
+                for (int i = 0; i < array.length; i++) {
+                    arrayMap.put(String.valueOf(i), array[i]);
+                }
+                return normalizeAndSort(arrayMap);
+            }
+            default -> {
+            }
+        }
+
+        // 基本类型：转字符串
+        return obj.toString();
+    }
+
+    /**
+     * 转换 Boolean 为 "1"/"0"
+     */
+    private static Object convertBoolean(Object obj) {
+        if (obj instanceof Boolean) {
+            return (Boolean) obj ? "1" : "0";
+        }
+        return obj;
+    }
+
+    /**
+     * MD5 并转大写
+     */
+    private static String md5ToUpper(String input) {
+        try {
+            MessageDigest md = MessageDigest.getInstance("MD5");
+            byte[] digest = md.digest(input.getBytes("UTF-8"));
+            StringBuilder sb = new StringBuilder();
+            for (byte b : digest) {
+                sb.append(String.format("%02x", b));
+            }
+            return sb.toString().toUpperCase();
+        } catch (Exception e) {
+            throw new RuntimeException("MD5 failed", e);
+        }
+    }
+
+    public static void main(String[] args) {
+        // 构建顶层参数 Map
+        Map<String, Object> params = new HashMap<>();
+
+        params.put("app_key", "221zzcwxee30nucj0rx1");
+        params.put("timestamp", 1734351194L); // 使用 Long 避免溢出
+        params.put("nonce_str", "cvwEv8JRNzHd3eaV");
+        params.put("order_id", "1234567890"); // order_id 可以是字符串或数字，这里按字符串处理更安全
+
+        // 构建 item_list
+        List<Map<String, Object>> itemList = new ArrayList<>();
+
+        for (int i = 1; i <= 11; i++) {
+            Map<String, Object> subOrder = new HashMap<>();
+            subOrder.put("sub_order_id", i);
+            subOrder.put("price", 100);
+            itemList.add(subOrder);
+        }
+        params.put("item_list", itemList);
+
+        // 打印验证（可选）
+        log.info("Params: {}", JsonUtils.toJsonString(params));
+
+        String sign = generateSign(params, "ho7ygrsrwged4zwhwpbadtdgzugmulez");
+        log.info("Sign: {}", sign);
+    }
+}
+{
+  "name": "resources",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "repository": {
+    "type": "git",
+    "url": "https://git3.nong12.com/cashierdesk/dili-cashier.git"
+  },
+  "private": true
+}
@@ -6,6 +6,7 @@ dependencies {
     api 'org.springframework.boot:spring-boot-starter-amqp'
     api 'org.springframework.cloud:spring-cloud-starter-loadbalancer'
     api 'org.springframework.cloud:spring-cloud-starter-openfeign'
+    api 'org.springframework.boot:spring-boot-starter-aop'
     api libs.cache.caffeine
     api libs.common.collections4
+package com.diligrp.cashier.shared.annotation;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName LogPrint.java
+ * @Description 参数日志是否打印
+ */
+@Target({ElementType.METHOD})
+@Retention(RetentionPolicy.RUNTIME)
+public @interface ParamLogPrint {
+    /**
+     * 使用该注解默认打印
+     *
+     * @return boolean
+     */
+    boolean print() default true;
+
+    /**
+     * desc
+     * 触发点：HTTP MQ and so on
+     *
+     * @return {@link String}
+     */
+    String desc() default "HTTP接口";
+
+    /**
+     * outPrint
+     */
+    boolean outPrint() default false;
+}
+package com.diligrp.cashier.shared.annotation;
+
+
+import com.diligrp.cashier.shared.handler.duplication.DuplicationSubmit;
+import com.diligrp.cashier.shared.handler.duplication.IgnoreDuplicationSubmit;
+
+import java.lang.annotation.*;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName RepeatSubmit.java
+ * @Description RepeatSubmit
+ */
+@Inherited
+@Target(ElementType.METHOD)
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+public @interface RepeatSubmit {
+    /**
+     * 前缀
+     */
+    String prefix() default "";
+
+    /**
+     * 用于存放SpEL表达式的数组
+     */
+    String[] value() default {};
+
+    /**
+     * 是否值保留一个值
+     */
+    boolean onlyOne() default false;
+
+    /**
+     * 等待获取锁的最大时长
+     * 未设置的-快速失败
+     * 设置-等待指定时间
+     */
+    int waitTime() default 0;
+
+    /**
+     * 获取锁之后，锁的自动释放时间
+     */
+    int leaseTime() default 0;
+
+    /**
+     * 时间单位
+     */
+    TimeUnit timeUnit() default TimeUnit.SECONDS;
+
+    /**
+     * 重复提交
+     */
+    Class<? extends DuplicationSubmit> duplicationSubmit() default IgnoreDuplicationSubmit.class;
+}
+package com.diligrp.cashier.shared.annotation;
+
+
+import com.diligrp.cashier.shared.handler.sign.NoSign;
+import com.diligrp.cashier.shared.handler.sign.SecuritySign;
+
+import java.lang.annotation.*;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName Sign.java
+ * @Description 签名验签
+ **/
+@Target({ElementType.TYPE, ElementType.METHOD})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+public @interface Sign {
+    Class<? extends SecuritySign> sign() default NoSign.class;
+}
+package com.diligrp.cashier.shared.aop;
+
+import com.diligrp.cashier.shared.ErrorCode;
+import com.diligrp.cashier.shared.annotation.RepeatSubmit;
+import com.diligrp.cashier.shared.domain.handler.AspectIdempotent;
+import com.diligrp.cashier.shared.exception.PlatformServiceException;
+import com.diligrp.cashier.shared.handler.duplication.DuplicationSubmit;
+import com.diligrp.cashier.shared.util.SpringContextUtils;
+import jakarta.annotation.Resource;
+import org.apache.commons.lang3.StringUtils;
+import org.aspectj.lang.JoinPoint;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.AfterThrowing;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName RepeatSubmitAop.java
+ * @Description 防重提交
+ */
+@Aspect
+@Component
+@Order(2)
+public class RepeatSubmitAop {
+    private static final Logger log = LoggerFactory.getLogger(RepeatSubmitAop.class);
+
+    @Resource
+    private RedissonClient redissonClient;
+
+    /**
+     * around
+     */
+    @Around(value = "@annotation(repeatSubmit)")
+    public Object around(ProceedingJoinPoint joinPoint, RepeatSubmit repeatSubmit) throws Throwable {
+        DuplicationSubmit<AspectIdempotent> duplicationSubmit = SpringContextUtils.getBean(repeatSubmit.duplicationSubmit());
+        // 获取锁key
+        String key = duplicationSubmit.key(new AspectIdempotent(joinPoint, repeatSubmit));
+        log.info("repeat submit aspect key: {}", key);
+        if (StringUtils.isBlank(key)) {
+            return joinPoint.proceed();
+        }
+
+        RLock lock = redissonClient.getLock(key);
+        boolean repeat = repeatSubmit.waitTime() > 0 ?
+                lock.tryLock(repeatSubmit.waitTime(), repeatSubmit.leaseTime(), repeatSubmit.timeUnit()) :
+                lock.tryLock();
+        try {
+            if (!repeat) {
+                log.info("重复操作 key={}", key);
+                throw new PlatformServiceException(ErrorCode.SYSTEM_BUSY_ERROR, "请勿重复操作！");
+            }
+            return joinPoint.proceed();
+        } finally {
+            if (lock.isHeldByCurrentThread()) {
+                lock.unlock();
+            }
+        }
+    }
+
+    /**
+     * 拦截异常操作
+     * 未进入目标方法抛出的异常无法监听
+     */
+    @AfterThrowing(value = "@annotation(repeatSubmit)", throwing = "e")
+    public void doAfterThrowing(JoinPoint joinPoint, RepeatSubmit repeatSubmit, Exception e) {
+        log.error("repeat submit aspect after throwing");
+    }
+}
+package com.diligrp.cashier.shared.aop;
+
+import com.diligrp.cashier.shared.annotation.Sign;
+import com.diligrp.cashier.shared.handler.sign.NoSign;
+import com.diligrp.cashier.shared.handler.sign.SecuritySign;
+import com.diligrp.cashier.shared.util.SpringContextUtils;
+import org.apache.commons.lang3.ArrayUtils;
+import org.aspectj.lang.JoinPoint;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Before;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName SecuritySignAop.java
+ * @Description SecuritySignAop
+ * 验签流程 放到网关合理点 前期先放到AOP下
+ */
+@Aspect
+@Component
+@Order(1)
+public class SecuritySignAop {
+    /**
+     * doBefore
+     */
+    @Before(value = "@annotation(sign)")
+    public void doBefore(JoinPoint joinPoint, Sign sign) {
+        Class<? extends SecuritySign> securitySign = sign.sign();
+        if (securitySign == NoSign.class) {
+            return;
+        }
+
+        Object[] args = joinPoint.getArgs();
+        if (ArrayUtils.isEmpty(args)) {
+            return;
+        }
+        SecuritySign signBean = SpringContextUtils.getBean(securitySign);
+        signBean.sign(null, null, args[0]);
+    }
+}
+package com.diligrp.cashier.shared.domain.handler;
+
+import com.diligrp.cashier.shared.annotation.RepeatSubmit;
+import org.aspectj.lang.ProceedingJoinPoint;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName AspectIdempotent.java
+ * @Description AspectIdempotent
+ * @date 2025-07-03 10:42
+ */
+public class AspectIdempotent {
+    private ProceedingJoinPoint joinPoint;
+    private RepeatSubmit repeatSubmit;
+
+    public AspectIdempotent() {
+    }
+
+    public AspectIdempotent(ProceedingJoinPoint joinPoint, RepeatSubmit repeatSubmit) {
+        this.joinPoint = joinPoint;
+        this.repeatSubmit = repeatSubmit;
+    }
+
+    public ProceedingJoinPoint getJoinPoint() {
+        return joinPoint;
+    }
+
+    public void setJoinPoint(ProceedingJoinPoint joinPoint) {
+        this.joinPoint = joinPoint;
+    }
+
+    public RepeatSubmit getRepeatSubmit() {
+        return repeatSubmit;
+    }
+
+    public void setRepeatSubmit(RepeatSubmit repeatSubmit) {
+        this.repeatSubmit = repeatSubmit;
+    }
+}
+package com.diligrp.cashier.shared.handler.duplication;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName RepeatSubmit.java
+ * @Description RepeatSubmit
+ * @date 2025-07-03 10:56
+ */
+public interface DuplicationSubmit<T> {
+    String key(T param);
+}
+package com.diligrp.cashier.shared.handler.duplication;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName TokenDuplicationSubmit.java
+ * @Description TokenDuplicationSubmit
+ */
+@Component
+public class IgnoreDuplicationSubmit implements DuplicationSubmit<Object> {
+    private static final Logger LOGGER = LoggerFactory.getLogger(IgnoreDuplicationSubmit.class);
+
+    @Override
+    public String key(Object param) {
+        LOGGER.info("ignore");
+        return "ignore";
+    }
+}
+package com.diligrp.cashier.shared.handler.duplication;
+
+import com.diligrp.cashier.shared.annotation.RepeatSubmit;
+import com.diligrp.cashier.shared.domain.handler.AspectIdempotent;
+import org.apache.commons.lang3.ArrayUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.reflect.MethodSignature;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.expression.EvaluationContext;
+import org.springframework.expression.Expression;
+import org.springframework.expression.ExpressionParser;
+import org.springframework.expression.spel.standard.SpelExpressionParser;
+import org.springframework.expression.spel.support.StandardEvaluationContext;
+import org.springframework.stereotype.Component;
+
+import java.util.Objects;
+import java.util.Optional;
+import java.util.StringJoiner;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName SpelDuplicationSubmit.java
+ * @Description SpelDuplicationSubmit
+ */
+@Component
+public class SpelDuplicationSubmit implements DuplicationSubmit<AspectIdempotent> {
+    private static final Logger log = LoggerFactory.getLogger(SpelDuplicationSubmit.class);
+
+    private final ExpressionParser parser = new SpelExpressionParser();
+
+    @Override
+    public String key(AspectIdempotent param) {
+        log.info("spel duplicationSubmit~~~~");
+        return getKey(param.getJoinPoint(), param.getRepeatSubmit());
+    }
+
+    /**
+     * 根据spel获取值
+     */
+    private String getKey(ProceedingJoinPoint joinPoint, RepeatSubmit repeatSubmit) {
+        String[] spelValStr = repeatSubmit.value();
+        if (ArrayUtils.isEmpty(spelValStr)) {
+            return null;
+        }
+
+        // 获取方法参数名和参数值
+        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
+        String[] parameterNames = signature.getParameterNames();
+        Object[] args = joinPoint.getArgs();
+
+        // 创建EvaluationContext并设置变量
+        EvaluationContext context = new StandardEvaluationContext();
+        for (int i = 0; i < parameterNames.length; i++) {
+            context.setVariable(parameterNames[i], args[i]);
+        }
+
+        boolean onlyOne = repeatSubmit.onlyOne();
+        StringJoiner stringJoiner = new StringJoiner("_", repeatSubmit.prefix(), StringUtils.EMPTY);
+        for (String expression : spelValStr) {
+            try {
+                Expression exp = parser.parseExpression(expression);
+                Object targetValue = exp.getValue(context);
+                Optional.ofNullable(targetValue).ifPresent(value -> {
+                    stringJoiner.add(value.toString());
+                });
+                // 如果只强制拿取一个并且不为空
+                if (onlyOne && Objects.nonNull(targetValue)) {
+                    break;
+                }
+            } catch (Exception e) {
+                log.warn("expression get value error", e);
+            }
+        }
+        return stringJoiner.toString();
+    }
+}
+package com.diligrp.cashier.shared.handler.sign;
+
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName NoSign.java
+ * @Description NoSign
+ */
+@Component
+public class NoSign implements SecuritySign {
+    private static final Logger log = LoggerFactory.getLogger(NoSign.class);
+
+    @Override
+    public void sign(HttpServletRequest request, HttpServletResponse response, Object handler) {
+        log.info("该无需验签~~");
+    }
+}
+package com.diligrp.cashier.shared.handler.sign;
+
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName ParameterSign.java
+ * @Description SecuritySign
+ * 迁移至网关实现
+ * @date 2025-07-09 16:08
+ */
+public interface SecuritySign {
+    void sign(HttpServletRequest request, HttpServletResponse response, Object handler);
+}
@@ -28,7 +28,7 @@ public class JsonUtils {
     private static ObjectMapper objectMapper = initObjectMapper();
-    private static ObjectMapper initObjectMapper(){
+    private static ObjectMapper initObjectMapper() {
         Jackson2ObjectMapperBuilder jackson2ObjectMapperBuilder = new Jackson2ObjectMapperBuilder();
         initObjectMapperBuilder(jackson2ObjectMapperBuilder);
         ObjectMapper objectMapper = jackson2ObjectMapperBuilder.createXmlMapper(false).build();
@@ -42,15 +42,15 @@ public class JsonUtils {
         builder.timeZone(TimeZone.getTimeZone(ZoneOffset.of("+8")));
         builder.serializationInclusion(JsonInclude.Include.NON_NULL);
         builder.featuresToDisable(
-            DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, // Json串的属性无JavaBean字段对应时，避免抛出异常
-            DeserializationFeature.FAIL_ON_NULL_FOR_PRIMITIVES, // JavaBean中primitive类型的字段无Json属性时，避免抛出异常
-            DeserializationFeature.FAIL_ON_NUMBERS_FOR_ENUMS, // Json串数字类型属性，赋值JavaBean中Enum字段时，避免抛出异常
-            SerializationFeature.WRITE_DATES_AS_TIMESTAMPS,
-            SerializationFeature.FAIL_ON_EMPTY_BEANS
+                DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, // Json串的属性无JavaBean字段对应时，避免抛出异常
+                DeserializationFeature.FAIL_ON_NULL_FOR_PRIMITIVES, // JavaBean中primitive类型的字段无Json属性时，避免抛出异常
+                DeserializationFeature.FAIL_ON_NUMBERS_FOR_ENUMS, // Json串数字类型属性，赋值JavaBean中Enum字段时，避免抛出异常
+                SerializationFeature.WRITE_DATES_AS_TIMESTAMPS,
+                SerializationFeature.FAIL_ON_EMPTY_BEANS
         );
         builder.featuresToEnable(
-            DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT,
-            DeserializationFeature.USE_JAVA_ARRAY_FOR_JSON_ARRAY
+                DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT,
+                DeserializationFeature.USE_JAVA_ARRAY_FOR_JSON_ARRAY
         );
         var dateTimeFormatter = DateTimeFormatter.ofPattern(Constants.DATE_TIME_FORMAT);
@@ -74,7 +74,7 @@ public class JsonUtils {
         }
     }
-    public static <T> T fromJsonString(String json, TypeReference<T> typeReference){
+    public static <T> T fromJsonString(String json, TypeReference<T> typeReference) {
         try {
             return objectMapper.readValue(json, typeReference);
         } catch (JsonProcessingException ex) {
@@ -106,6 +106,10 @@ public class JsonUtils {
         return fromJsonString(toJsonString(value), type);
     }
+    public static <T> T convertValueV2(Object value, TypeReference<T> type) {
+        return fromJsonString(toJsonString(value), type);
+    }
+
     public static <T> String toJsonString(T object) {
         try {
+package com.diligrp.cashier.shared.util;
+
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+
+/**
+ * SpringUtil
+ *
+ * @author dengwei
+ * @date 2025/12/24 18:05
+ */
+@Component
+public class SpringContextUtils implements ApplicationContextAware {
+
+    private static ApplicationContext applicationContext;
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        if (SpringContextUtils.applicationContext == null) {
+            SpringContextUtils.applicationContext = applicationContext;
+        }
+    }
+
+    public static ApplicationContext getApplicationContext() {
+        return applicationContext;
+    }
+
+    // 通过name获取Bean
+    public static Object getBean(String name) {
+        return getApplicationContext().getBean(name);
+    }
+
+    // 通过class获取Bean
+    public static <T> T getBean(Class<T> clazz) {
+        return getApplicationContext().getBean(clazz);
+    }
+
+    // 通过name,以及Clazz返回指定的Bean
+    public static <T> T getBean(String name, Class<T> clazz) {
+        return getApplicationContext().getBean(name, clazz);
+    }
+
+    public static <T> Map<String, T> getBeanOfTpe(Class<T> clazz) {
+        return getApplicationContext().getBeansOfType(clazz);
+    }
+
+}