feat mall user info

dengwei
1 parent 7d925fdd
Showing 28 changed files with 936 additions and 24 deletions
cashier-mall/src/main/java/com/diligrp/cashier/mall/MallConstants.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/api/MallAuthApi.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/context/MallInitializeContext.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/RtMarkBaseCO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/RtMarkMessage.java → cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/RtMarkMessage.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/co/AuthLoginCO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/co/UserInfoCO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/domain/rtmall/vo/UserInfoVO.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/exception/MallExceptionHandler.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/property/MallDynamicProperty.java → cashier-mall/src/main/java/com/diligrp/cashier/mall/property/RtMallDynamicProperty.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/paychannel/AbstractPayChannel.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/paychannel/CardPayChannel.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/paychannel/WeChatPayChannel.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/sourcechannel/AbstractChannel.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/sourcechannel/RtMallChannel.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/sign/RtMallSign.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/type/OrderChannel.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/type/OrderSource.java
cashier-mall/src/main/java/com/diligrp/cashier/mall/type/OrderType.java
cashier-shared/build.gradle
 package com.diligrp.cashier.mall;
+/**
+ * 商城常量
+ */
 public interface MallConstants {
     String RESULT_SUCCESS = "success";
     String RESULT_FAILURE = "fail";
     Integer RT_MALL_SOURCE = 1;
+
+    String MALL_TOKEN = "mall_token:";
+    String MALL_USER_INFO = "mall_user_info:";
 }
+package com.diligrp.cashier.mall.api;
+
+import com.diligrp.cashier.mall.MallConstants;
+import com.diligrp.cashier.mall.context.MallInitializeContext;
+import com.diligrp.cashier.mall.domain.rtmall.RtMarkMessage;
+import com.diligrp.cashier.mall.domain.rtmall.co.AuthLoginCO;
+import com.diligrp.cashier.mall.domain.rtmall.co.UserInfoCO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.UserInfoVO;
+import com.diligrp.cashier.mall.sign.RtMallSign;
+import com.diligrp.cashier.shared.annotation.ParamLogPrint;
+import com.diligrp.cashier.shared.annotation.Sign;
+import com.diligrp.cashier.shared.domain.Message;
+import com.diligrp.cashier.shared.util.JsonUtils;
+import jakarta.annotation.Resource;
+import jakarta.validation.Valid;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Objects;
+
+/**
+ * @ClassName MallAuthApi.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description MallAuthApi
+ */
+@RestController
+@RequestMapping("/mall")
+@Validated
+public class MallAuthApi {
+    private static final Logger log = LoggerFactory.getLogger(MallAuthApi.class);
+    @Resource
+    private RedisTemplate<String, Object> redisTemplate;
+
+    /**
+     * 获取授权连接
+     */
+    @PostMapping("/auth")
+    @ParamLogPrint(outPrint = true)
+    public Message<String> authLogin(@RequestBody @Valid AuthLoginCO authLogin) {
+        return Message.success(MallInitializeContext.getByChannel(authLogin.getChannel()).authLogin(authLogin));
+    }
+
+    /**
+     * 获取用户信息
+     */
+    @PostMapping("/user/info")
+    @ParamLogPrint(outPrint = true)
+    @Sign(sign = RtMallSign.class)
+    public RtMarkMessage<UserInfoVO> userInfo(@RequestBody @Valid Object req) {
+        UserInfoCO userInfo = JsonUtils.convertValue(req, UserInfoCO.class);
+        AuthLoginCO authLogin = JsonUtils.fromJsonString(Objects.requireNonNull(redisTemplate.opsForValue().get(MallConstants.MALL_TOKEN + userInfo.getToken())).toString(), AuthLoginCO.class);
+        UserInfoVO userInfoVO = MallInitializeContext.getByChannel(authLogin.getChannel()).userInfo(authLogin);
+        return RtMarkMessage.success(userInfoVO);
+    }
+}
+package com.diligrp.cashier.mall.context;
+
+import com.diligrp.cashier.mall.exception.MallException;
+import com.diligrp.cashier.mall.service.paychannel.AbstractPayChannel;
+import com.diligrp.cashier.mall.service.sourcechannel.AbstractChannel;
+import com.diligrp.cashier.shared.util.SpringContextUtils;
+import com.google.common.collect.Maps;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.DisposableBean;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+import java.util.Optional;
+
+/**
+ * @author dengwei
+ * @version 1.0.0
+ * @ClassName MallInitializeContext.java
+ * @Description MallInitializeContext
+ */
+@Component
+public class MallInitializeContext implements InitializingBean, DisposableBean {
+    private static final Logger log = LoggerFactory.getLogger(MallInitializeContext.class);
+    public static Map<String, AbstractChannel> SOURCE_CHANNEL_MAP = Maps.newConcurrentMap();
+    public static Map<Integer, AbstractPayChannel> PAY_CHANNEL_MAP = Maps.newConcurrentMap();
+
+    /**
+     * 容器启动完成加载
+     */
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        SpringContextUtils.getBeanOfTpe(AbstractChannel.class).forEach((key, value) -> {
+            SOURCE_CHANNEL_MAP.put(value.channel(), value);
+        });
+
+        SpringContextUtils.getBeanOfTpe(AbstractPayChannel.class).forEach((key, value) -> {
+            PAY_CHANNEL_MAP.put(value.getPayChannel(), value);
+        });
+    }
+
+    /**
+     * 容器销毁加载
+     */
+    @Override
+    public void destroy() throws Exception {
+        log.info("spring container destroy");
+    }
+
+    /**
+     * getByType
+     */
+    public static AbstractChannel getByChannel(String channel) {
+        return Optional.ofNullable(SOURCE_CHANNEL_MAP.get(channel)).orElseThrow(() -> new MallException("不支持该渠道！"));
+    }
+
+    /**
+     * getByPayChannel
+     */
+    public static AbstractPayChannel getByPayChannel(Integer payChannel) {
+        return Optional.ofNullable(PAY_CHANNEL_MAP.get(payChannel)).orElseThrow(() -> new MallException("不支持该渠道！"));
+    }
+}
+package com.diligrp.cashier.mall.domain.rtmall;
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import com.fasterxml.jackson.databind.annotation.JsonNaming;
+
+/**
+ * @ClassName RtMarkBaseCO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description RtMarkBaseCO
+ * @date 2025-12-25 16:26
+ */
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+public class RtMarkBaseCO {
+    private String appKey;
+    private String version;
+    private String timestamp;
+    private String nonceStr;
+    private String sign;
+
+    public String getAppKey() {
+        return appKey;
+    }
+
+    public void setAppKey(String appKey) {
+        this.appKey = appKey;
+    }
+
+    public String getVersion() {
+        return version;
+    }
+
+    public void setVersion(String version) {
+        this.version = version;
+    }
+
+    public String getTimestamp() {
+        return timestamp;
+    }
+
+    public void setTimestamp(String timestamp) {
+        this.timestamp = timestamp;
+    }
+
+    public String getNonceStr() {
+        return nonceStr;
+    }
+
+    public void setNonceStr(String nonceStr) {
+        this.nonceStr = nonceStr;
+    }
+
+    public String getSign() {
+        return sign;
+    }
+
+    public void setSign(String sign) {
+        this.sign = sign;
+    }
+}
-package com.diligrp.cashier.mall.domain;
+package com.diligrp.cashier.mall.domain.rtmall;
 import com.diligrp.cashier.mall.MallConstants;
 import com.diligrp.cashier.mall.type.RtMarkErrorCode;
+package com.diligrp.cashier.mall.domain.rtmall.co;
+
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+
+/**
+ * @ClassName AuthLoginCO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description AuthLoginCO
+ * @date 2025-12-25 10:55
+ */
+public class AuthLoginCO {
+    /**
+     * 用户编号
+     */
+    @NotBlank(message = "用户编号不能为空！")
+    private String userCode;
+
+    /**
+     * 用户名
+     */
+    @NotBlank(message = "用户名称不能为空！")
+    private String username;
+
+    /**
+     * 渠道-中瑞 地利
+     * @see com.diligrp.cashier.mall.type.OrderChannel
+     */
+    @NotBlank(message = "渠道不能为空！")
+    private String channel;
+
+    /**
+     * 商户编号
+     */
+    @NotBlank(message = "商户编号不能为空！")
+    private String mchId;
+
+    /**
+     * 订单来源(1大润发 2山姆)
+     * @see com.diligrp.cashier.mall.type.OrderSource
+     */
+    @NotNull(message = "订单来源不能为空！")
+    private Integer source;
+
+    /**
+     * 订单类型-1线下扫码购，2 接口扫码购，3小程序
+     * @see com.diligrp.cashier.mall.type.OrderType
+     */
+    @NotNull(message = "订单类型不能为空！")
+    private Integer orderType;
+
+    /**
+     * 联系电话
+     */
+    private String mobile;
+
+    /**
+     * 经度
+     */
+    private String longitude;
+
+    /**
+     * 纬度
+     */
+    private String latitude;
+
+    public String getLatitude() {
+        return latitude;
+    }
+
+    public void setLatitude(String latitude) {
+        this.latitude = latitude;
+    }
+
+    public String getLongitude() {
+        return longitude;
+    }
+
+    public void setLongitude(String longitude) {
+        this.longitude = longitude;
+    }
+
+    public Integer getOrderType() {
+        return orderType;
+    }
+
+    public void setOrderType(Integer orderType) {
+        this.orderType = orderType;
+    }
+
+    public String getMobile() {
+        return mobile;
+    }
+
+    public void setMobile(String mobile) {
+        this.mobile = mobile;
+    }
+
+    public Integer getSource() {
+        return source;
+    }
+
+    public void setSource(Integer source) {
+        this.source = source;
+    }
+
+    public String getMchId() {
+        return mchId;
+    }
+
+    public void setMchId(String mchId) {
+        this.mchId = mchId;
+    }
+
+    public String getChannel() {
+        return channel;
+    }
+
+    public void setChannel(String channel) {
+        this.channel = channel;
+    }
+
+    public String getUserCode() {
+        return userCode;
+    }
+
+    public void setUserCode(String userCode) {
+        this.userCode = userCode;
+    }
+
+    public String getUsername() {
+        return username;
+    }
+
+    public void setUsername(String username) {
+        this.username = username;
+    }
+}
+package com.diligrp.cashier.mall.domain.rtmall.co;
+
+import com.diligrp.cashier.mall.domain.rtmall.RtMarkBaseCO;
+import com.diligrp.cashier.shared.jackson.deserializer.SecondToDateDeserializer;
+import com.diligrp.cashier.shared.jackson.serialization.DateToSecondSerializer;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import jakarta.validation.constraints.NotBlank;
+
+import java.time.LocalDateTime;
+
+/**
+ * @ClassName UserInfoCO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description UserInfoCO
+ * @date 2025-12-25 16:28
+ */
+public class UserInfoCO extends RtMarkBaseCO {
+    @NotBlank(message = "token不能为空！")
+    private String token;
+
+    @JsonSerialize(using = DateToSecondSerializer.class)
+    @JsonDeserialize(using = SecondToDateDeserializer.class)
+    private LocalDateTime createTime;
+
+    public String getToken() {
+        return token;
+    }
+
+    public void setToken(String token) {
+        this.token = token;
+    }
+
+    public LocalDateTime getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(LocalDateTime createTime) {
+        this.createTime = createTime;
+    }
+}
+package com.diligrp.cashier.mall.domain.rtmall.vo;
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import com.fasterxml.jackson.databind.annotation.JsonNaming;
+
+/**
+ * @ClassName UserInfoVO.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description UserInfoVO
+ * @date 2025-12-25 16:31
+ */
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+public class UserInfoVO {
+    private String userCode;
+    private String mobile;
+    private String userName;
+    private String companyCode;
+
+    public String getUserCode() {
+        return userCode;
+    }
+
+    public void setUserCode(String userCode) {
+        this.userCode = userCode;
+    }
+
+    public String getMobile() {
+        return mobile;
+    }
+
+    public void setMobile(String mobile) {
+        this.mobile = mobile;
+    }
+
+    public String getUserName() {
+        return userName;
+    }
+
+    public void setUserName(String userName) {
+        this.userName = userName;
+    }
+
+    public String getCompanyCode() {
+        return companyCode;
+    }
+
+    public void setCompanyCode(String companyCode) {
+        this.companyCode = companyCode;
+    }
+}
 package com.diligrp.cashier.mall.exception;
-import com.diligrp.cashier.mall.domain.RtMarkMessage;
+import com.diligrp.cashier.mall.domain.rtmall.RtMarkMessage;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.core.annotation.Order;
@@ -17,8 +17,8 @@ import java.util.Optional;
  */
 @Configuration
 @RefreshScope
-@ConfigurationProperties(prefix = "sign")
-public class MallDynamicProperty {
+@ConfigurationProperties(prefix = "rtmall.sign")
+public class RtMallDynamicProperty {
     private List<AppSecretDynamicProperty> appSecrets;
@@ -26,12 +26,18 @@ public class MallDynamicProperty {
         @Value("${source:1}")
         private Integer source;
+        @Value("${orderType:3}")
+        private Integer orderType;
+
         @Value("${appKey:}")
         private String appKey;
         @Value("${appSecret:}")
         private String appSecret;
+        @Value("${companyCode:}")
+        private String companyCode;
+
         @Value("${authUrl:https://hourh5-em-shop.feiniugo.com}")
         private String authUrl;
@@ -66,6 +72,22 @@ public class MallDynamicProperty {
         public void setAuthUrl(String authUrl) {
             this.authUrl = authUrl;
         }
+
+        public Integer getOrderType() {
+            return orderType;
+        }
+
+        public void setOrderType(Integer orderType) {
+            this.orderType = orderType;
+        }
+
+        public String getCompanyCode() {
+            return companyCode;
+        }
+
+        public void setCompanyCode(String companyCode) {
+            this.companyCode = companyCode;
+        }
     }
     public List<AppSecretDynamicProperty> getAppSecrets() {
@@ -88,4 +110,30 @@ public class MallDynamicProperty {
                 .findFirst()
                 .orElse(null);
     }
+
+    /**
+     * getBySource
+     *
+     */
+    public AppSecretDynamicProperty getBySourceAndType(Integer source, Integer orderType) {
+        return Optional.ofNullable(appSecrets)
+                .orElse(Collections.emptyList())
+                .stream()
+                .filter(item -> item.getSource().equals(source) && item.getOrderType().equals(orderType))
+                .findFirst()
+                .orElse(null);
+    }
+
+    /**
+     * getBySource
+     *
+     */
+    public AppSecretDynamicProperty getByAppKey(String appKey) {
+        return Optional.ofNullable(appSecrets)
+                .orElse(Collections.emptyList())
+                .stream()
+                .filter(item -> item.getAppKey().equals(appKey))
+                .findFirst()
+                .orElse(null);
+    }
 }
+package com.diligrp.cashier.mall.service.paychannel;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * @ClassName AbstractPayChannel.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description AbstractPayChannel
+ * @date 2025-12-25 17:07
+ */
+public abstract class AbstractPayChannel {
+    protected final Logger log = LoggerFactory.getLogger(getClass());
+
+    public abstract Integer getPayChannel();
+}
+package com.diligrp.cashier.mall.service.paychannel;
+
+import org.springframework.stereotype.Component;
+
+/**
+ * @ClassName CardPayChannel.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description CardPayChannel
+ * @date 2025-12-25 17:08
+ */
+@Component
+public class CardPayChannel extends AbstractPayChannel {
+    @Override
+    public Integer getPayChannel() {
+        return 0;
+    }
+}
+package com.diligrp.cashier.mall.service.paychannel;
+
+import org.springframework.stereotype.Component;
+
+/**
+ * @ClassName WeChatPayChannel.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description WeChatPayChannel
+ * @date 2025-12-25 17:08
+ */
+@Component
+public class WeChatPayChannel extends AbstractPayChannel {
+    @Override
+    public Integer getPayChannel() {
+        return 1;
+    }
+}
+package com.diligrp.cashier.mall.service.sourcechannel;
+
+import cn.hutool.core.util.IdUtil;
+import com.diligrp.cashier.mall.MallConstants;
+import com.diligrp.cashier.mall.domain.rtmall.co.AuthLoginCO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.UserInfoVO;
+import com.diligrp.cashier.mall.property.RtMallDynamicProperty;
+import com.diligrp.cashier.shared.util.DateUtils;
+import com.diligrp.cashier.shared.util.JsonUtils;
+import jakarta.annotation.Resource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @ClassName AbstractChannel.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description AbstractChannel
+ * @date 2025-12-25 11:19
+ */
+public abstract class AbstractChannel {
+    private static final Logger log = LoggerFactory.getLogger(AbstractChannel.class);
+
+    @Resource
+    protected RtMallDynamicProperty rtMallDynamicProperty;
+    @Resource
+    protected RedisTemplate<String, Object> redisTemplate;
+
+    /**
+     * authLogin
+     */
+    public String authLogin(AuthLoginCO authLogin) {
+        String token = IdUtil.fastSimpleUUID();
+        long timestamp = DateUtils.timestampInSeconds();
+
+        String authUrl = authUrl(authLogin, token, timestamp);
+
+        // token 缓存
+        String tokenKey = MallConstants.MALL_TOKEN + token;
+        redisTemplate.opsForValue().set(tokenKey, JsonUtils.toJsonString(authLogin), 1, TimeUnit.DAYS);
+
+        // 用户信息缓存 中瑞、dili是独立系统部署 可能存在相同用户id 所以需要加上渠道
+        String userKey = MallConstants.MALL_USER_INFO + authLogin.getUserCode() + "_" + authLogin.getChannel();
+        redisTemplate.opsForValue().set(userKey, JsonUtils.toJsonString(authLogin), 1, TimeUnit.DAYS);
+        return authUrl;
+    }
+
+    /**
+     * userInfo
+     *
+     */
+    public UserInfoVO userInfo(AuthLoginCO authLogin) {
+        RtMallDynamicProperty.AppSecretDynamicProperty property = rtMallDynamicProperty.getBySourceAndType(authLogin.getSource(), authLogin.getOrderType());
+        log.info("authUrl property: {}", JsonUtils.toJsonString(property));
+
+        UserInfoVO userInfoVO = JsonUtils.convertValue(authLogin, UserInfoVO.class);
+        userInfoVO.setUserCode(authLogin.getUserCode() + "_" + authLogin.getChannel());
+        userInfoVO.setUserName(authLogin.getUsername());
+
+        userInfoChannel(userInfoVO, property);
+        return userInfoVO;
+    }
+
+    /**
+     * 渠道
+     */
+    public abstract String channel();
+
+    /**
+     * authLoginUrl
+     */
+    public abstract String authUrl(AuthLoginCO authLogin, String token, long timestamp);
+
+    public abstract void userInfoChannel(UserInfoVO authLogin, RtMallDynamicProperty.AppSecretDynamicProperty userInfoVO);
+}
+package com.diligrp.cashier.mall.service.sourcechannel;
+
+import com.diligrp.cashier.mall.domain.rtmall.co.AuthLoginCO;
+import com.diligrp.cashier.mall.domain.rtmall.vo.UserInfoVO;
+import com.diligrp.cashier.mall.property.RtMallDynamicProperty;
+import com.diligrp.cashier.mall.type.OrderChannel;
+import com.diligrp.cashier.mall.util.RtMallSignMd5Utils;
+import com.diligrp.cashier.shared.util.JsonUtils;
+import com.diligrp.cashier.shared.util.UrlParamParserUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * @ClassName RtMallChannel.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description RtMallChannel
+ * @date 2025-12-25 11:20
+ */
+@Component
+public class RtMallChannel extends AbstractChannel {
+    private static final Logger log = LoggerFactory.getLogger(RtMallChannel.class);
+
+    @Override
+    public String authUrl(AuthLoginCO authLogin, String token, long timestamp) {
+        RtMallDynamicProperty.AppSecretDynamicProperty property = rtMallDynamicProperty.getBySourceAndType(authLogin.getSource(), authLogin.getOrderType());
+        log.info("authUrl property: {}", JsonUtils.toJsonString(property));
+
+        // 替换参数
+        String authUrl = property.getAuthUrl();
+        authUrl = String.format(authUrl, token, timestamp, authLogin.getLongitude(), authLogin.getLatitude());
+        log.info("authUrl format1: {}", authUrl);
+
+        // 获取参数
+        Map<String, String> queryParams = UrlParamParserUtils.parseQueryParams(authUrl);
+        log.info("authUrl queryParams: {}", JsonUtils.toJsonString(queryParams));
+
+        // 生成签名
+        String sign = RtMallSignMd5Utils.generateSign(queryParams, property.getAppSecret());
+        log.info("authUrl sign: {}", sign);
+        authUrl = authUrl.concat("&sign=").concat(sign);
+        return authUrl;
+    }
+
+    /**
+     * userInfo
+     */
+    @Override
+    public void userInfoChannel(final UserInfoVO authLogin,
+                                final RtMallDynamicProperty.AppSecretDynamicProperty property) {
+        authLogin.setCompanyCode(property.getCompanyCode());
+    }
+
+    @Override
+    public String channel() {
+        return OrderChannel.RT_MART.getCode();
+    }
+}
 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.property.RtMallDynamicProperty;
 import com.diligrp.cashier.mall.type.RtMarkErrorCode;
 import com.diligrp.cashier.mall.util.RtMallSignMd5Utils;
 import com.diligrp.cashier.shared.handler.sign.SecuritySign;
@@ -31,7 +30,7 @@ public class RtMallSign implements SecuritySign {
     private static final Logger log = LoggerFactory.getLogger(RtMallSign.class);
     @Resource
-    private MallDynamicProperty mallDynamicProperty;
+    private RtMallDynamicProperty mallDynamicProperty;
     @Override
     public void sign(HttpServletRequest request, HttpServletResponse response, Object data) {
@@ -45,15 +44,21 @@ public class RtMallSign implements SecuritySign {
             throw new RtMartMallException(RtMarkErrorCode.E4003.getCode(), RtMarkErrorCode.E4003.getMessage());
         }
-        MallDynamicProperty.AppSecretDynamicProperty property = mallDynamicProperty.getBySource(MallConstants.RT_MALL_SOURCE);
+        Object sign = paramMap.get("sign");
+        if (Objects.isNull(sign)) {
+            throw new RtMartMallException(RtMarkErrorCode.E4004.getCode(), RtMarkErrorCode.E4004.getMessage());
+        }
+        paramMap.remove("sign");
+
+        RtMallDynamicProperty.AppSecretDynamicProperty property = mallDynamicProperty.getByAppKey(appKey.toString());
         if (Objects.isNull(property)) {
-            throw new RtMartMallException(RtMarkErrorCode.E4001.getCode(), RtMarkErrorCode.E4001.getMessage());
+            throw new RtMartMallException(RtMarkErrorCode.E4003.getCode(), RtMarkErrorCode.E4003.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()), "验签失败！");
+            Assert.isTrue(Objects.equals(signKey, sign.toString()), "验签失败！");
         } catch (Exception e) {
             throw new RtMartMallException(RtMarkErrorCode.E4004.getCode(), RtMarkErrorCode.E4004.getMessage());
         }
+package com.diligrp.cashier.mall.type;
+
+/**
+ * @ClassName OrderChannel.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description OrderChannel
+ * @date 2025-12-25 11:18
+ */
+public enum OrderChannel {
+    RT_MART("1", "大润发"),
+    SAM("2", "山姆");
+
+    public final String code;
+    public final String description;
+
+    OrderChannel(String code, String description) {
+        this.code = code;
+        this.description = description;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+}
+package com.diligrp.cashier.mall.type;
+
+/**
+ * @ClassName OrderSrouce.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description OrderSource
+ * @date 2025-12-25 15:11
+ */
+public enum OrderSource {
+    RT_MART(1, "大润发"),
+    SAM_CLUB(2, "山姆");
+
+    public final int code;
+    public final String name;
+
+    OrderSource(int code, String name) {
+        this.code = code;
+        this.name = name;
+    }
+
+    public int getCode() {
+        return code;
+    }
+
+    public String getName() {
+        return name;
+    }
+}
+package com.diligrp.cashier.mall.type;
+
+/**
+ * @ClassName OrderType.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description OrderType
+ * @date 2025-12-25 11:17
+ */
+public enum OrderType {
+    OFFLINE_SCAN(1, "线下扫码购"),
+    API_SCAN(2, "接口扫码购"),
+    MINI_PROGRAM(3, "小程序");
+
+    private final int code;
+    private final String description;
+
+    OrderType(int code, String description) {
+        this.code = code;
+        this.description = description;
+    }
+
+    public int getCode() {
+        return code;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+}
@@ -7,8 +7,10 @@ dependencies {
     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 'org.springframework.boot:spring-boot-starter-validation'
     api libs.cache.caffeine
     api libs.common.collections4
+    api libs.google.guava
     runtimeOnly libs.mysql.driver
 }
@@ -16,6 +16,8 @@ public class ErrorCode {
     public static final String OBJECT_NOT_FOUND = "300004";
     // 对象已存在
     public static final String OBJECT_ALREADY_EXISTS = "300005";
+    // 请求方式
+    public static final String METHOD_NOT_SUPPORTED_ERROR = "300006";
     // 数据并发修改
     public static final String SYSTEM_BUSY_ERROR = "301000";
     // 无效对象状态
@@ -2,11 +2,24 @@ package com.diligrp.cashier.shared.exception;
 import com.diligrp.cashier.shared.ErrorCode;
 import com.diligrp.cashier.shared.domain.Message;
+import jakarta.validation.ConstraintViolation;
+import jakarta.validation.ConstraintViolationException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.context.support.DefaultMessageSourceResolvable;
+import org.springframework.validation.BindException;
+import org.springframework.validation.BindingResult;
+import org.springframework.validation.ObjectError;
+import org.springframework.web.HttpRequestMethodNotSupportedException;
+import org.springframework.web.bind.MethodArgumentNotValidException;
+import org.springframework.web.bind.MissingServletRequestParameterException;
 import org.springframework.web.bind.annotation.ExceptionHandler;
 import org.springframework.web.bind.annotation.RestControllerAdvice;
+import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
+
 @RestControllerAdvice
 public class DefaultExceptionHandler {
     private final Logger LOG = LoggerFactory.getLogger(this.getClass());
@@ -23,6 +36,40 @@ public class DefaultExceptionHandler {
         return Message.failure(ErrorCode.ILLEGAL_ARGUMENT_ERROR, ex.getMessage());
     }
+    @ExceptionHandler(value = ConstraintViolationException.class)
+    public Message<?> constraintViolationException(ConstraintViolationException exs) {
+        Set<ConstraintViolation<?>> violations = exs.getConstraintViolations();
+        String msg = violations.stream().map(ConstraintViolation::getMessage)
+                .collect(Collectors.joining(","));
+        return Message.failure(ErrorCode.ILLEGAL_ARGUMENT_ERROR, msg);
+    }
+
+    @ExceptionHandler(value = {MethodArgumentNotValidException.class, BindException.class})
+    public Message<?> methodArgumentNotValidException(Exception e) {
+        BindingResult bindingResult;
+        if (e instanceof MethodArgumentNotValidException) {
+            bindingResult = ((MethodArgumentNotValidException) e).getBindingResult();
+        } else {
+            bindingResult = ((BindException) e).getBindingResult();
+        }
+        List<ObjectError> allErrors = bindingResult.getAllErrors();
+        String msg = allErrors.stream().map(DefaultMessageSourceResolvable::getDefaultMessage)
+                .collect(Collectors.joining("、"));
+
+        return Message.failure(ErrorCode.ILLEGAL_ARGUMENT_ERROR, msg);
+    }
+
+    @ExceptionHandler(MissingServletRequestParameterException.class)
+    public Message<?> missingServletRequestParameterExceptionHandler(MissingServletRequestParameterException ex) {
+        return Message.failure(ErrorCode.ILLEGAL_ARGUMENT_ERROR, String.format("缺少参数：%s", ex.getParameterName()));
+    }
+
+    @ExceptionHandler({HttpRequestMethodNotSupportedException.class})
+    public Message<?> handleRequestMethodNotSupportedException(HttpRequestMethodNotSupportedException ex) {
+        return Message.failure(ErrorCode.METHOD_NOT_SUPPORTED_ERROR, "请求方式错误！");
+    }
+
+
     @ExceptionHandler(Exception.class)
     public Message<?> defaultExceptionHandler(Exception ex) {
         LOG.warn("assistant platform service exception", ex);
@@ -30,10 +30,10 @@ public class PlatformServiceException extends RuntimeException {
         super(message, ex);
     }
-    @Override
-    public Throwable fillInStackTrace() {
-        return stackTrace ? super.fillInStackTrace() : this;
-    }
+//    @Override
+//    public Throwable fillInStackTrace() {
+//        return stackTrace ? super.fillInStackTrace() : this;
+//    }
     public String getCode() {
         return code;
+package com.diligrp.cashier.shared.jackson.deserializer;
+
+import com.fasterxml.jackson.core.JacksonException;
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.databind.DeserializationContext;
+import com.fasterxml.jackson.databind.JsonDeserializer;
+
+import java.io.IOException;
+import java.time.Instant;
+import java.time.LocalDateTime;
+import java.time.ZoneOffset;
+
+/**
+ * @ClassName SecondToDateDeserializer.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description SecondToDateDeserializer
+ * @date 2025-12-25 17:54
+ */
+public class SecondToDateDeserializer extends JsonDeserializer<LocalDateTime> {
+    @Override
+    public LocalDateTime deserialize(JsonParser parser, DeserializationContext deserializationContext) throws IOException, JacksonException {
+        long timestamp = parser.getValueAsLong();
+        return LocalDateTime.ofInstant(
+                Instant.ofEpochSecond(timestamp),
+                ZoneOffset.UTC
+        );
+    }
+}
+package com.diligrp.cashier.shared.jackson.serialization;
+
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.databind.JsonSerializer;
+import com.fasterxml.jackson.databind.SerializerProvider;
+
+import java.io.IOException;
+import java.time.LocalDateTime;
+import java.time.ZoneOffset;
+
+/**
+ * @ClassName DateToSecondSerializer.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description DateToSecondSerializer
+ * @date 2025-12-25 17:57
+ */
+public class DateToSecondSerializer extends JsonSerializer<LocalDateTime> {
+    @Override
+    public void serialize(LocalDateTime value, JsonGenerator gen, SerializerProvider serializers) throws IOException {
+        gen.writeNumber(value.toInstant(ZoneOffset.UTC).getEpochSecond());
+    }
+}
@@ -3,6 +3,7 @@ package com.diligrp.cashier.shared.util;
 import com.diligrp.cashier.shared.Constants;
 import java.text.SimpleDateFormat;
+import java.time.Instant;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.ZoneOffset;
@@ -51,11 +52,11 @@ public class DateUtils {
     public static String format(Date date) {
         return format(date, Constants.DATE_TIME_FORMAT);
     }
-    
+
     public static LocalDateTime addDays(long amount) {
-    	LocalDateTime localDateTime = LocalDateTime.now();
-    	localDateTime.plusDays(amount);
-    	return localDateTime;
+        LocalDateTime localDateTime = LocalDateTime.now();
+        localDateTime.plusDays(amount);
+        return localDateTime;
     }
     public static String format(Date date, String format) {
@@ -112,17 +113,25 @@ public class DateUtils {
     }
     /**
-    * 获取时间戳
-    */
-    public static long parseMilliSecond(LocalDateTime localDateTime){
-        return parseMilliSecond(localDateTime,null);
+     * 获取时间戳
+     */
+    public static long parseMilliSecond(LocalDateTime localDateTime) {
+        return parseMilliSecond(localDateTime, null);
     }
-    public static long parseMilliSecond(LocalDateTime localDateTime, String zoneNumStr){
+    public static long parseMilliSecond(LocalDateTime localDateTime, String zoneNumStr) {
         //默认东八区
-        if (ObjectUtils.isEmpty(zoneNumStr)){
+        if (ObjectUtils.isEmpty(zoneNumStr)) {
             zoneNumStr = "+8";
         }
         return localDateTime.toInstant(ZoneOffset.of(zoneNumStr)).toEpochMilli();
     }
+
+    /**
+     * 时间戳-秒
+     *
+     */
+    public static long timestampInSeconds() {
+        return Instant.now().getEpochSecond();
+    }
 }
+package com.diligrp.cashier.shared.util;
+
+import com.diligrp.cashier.shared.exception.PlatformServiceException;
+
+import java.net.URI;
+import java.net.URLDecoder;
+import java.nio.charset.StandardCharsets;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @ClassName UrlParamParserUtils.java
+ * @author dengwei
+ * @version 1.0.0
+ * @Description UrlParamParserUtils
+ * @date 2025-12-25 15:34
+ */
+public class UrlParamParserUtils {
+    public static Map<String, String> parseQueryParams(String url) {
+        try {
+            URI uri = new URI(url);
+            String query = uri.getQuery();
+            if (query == null || query.isEmpty()) {
+                return new HashMap<>();
+            }
+
+            Map<String, String> params = new HashMap<>();
+            String[] pairs = query.split("&");
+            for (String pair : pairs) {
+                String[] keyValue = pair.split("=", 2);
+                String key = URLDecoder.decode(keyValue[0], StandardCharsets.UTF_8);
+                String value = keyValue.length > 1 ? URLDecoder.decode(keyValue[1], StandardCharsets.UTF_8) : "";
+                params.put(key, value);
+            }
+            return params;
+        } catch (Exception e) {
+            throw new PlatformServiceException("Invalid URL");
+        }
+    }
+}
@@ -9,6 +9,8 @@ mysqlDriverVersion = &quot;8.0.33&quot;
 redissonVersion = "3.52.0"
 caffeineVersion = "3.2.3"
 collections4Version= "4.5.0"
+guavaVersion = "33.5.0-jre"
+
 [libraries]
 #spring-boot-starter = {module = 'org.springframework.boot:spring-boot-starter', version.ref = 'springBootVersion'}
@@ -20,6 +22,7 @@ mysql-driver = {module = &#39;mysql:mysql-connector-java&#39;, version.ref = &#39;mysqlDrive
 redisson-starter = {module = 'org.redisson:redisson-spring-boot-starter', version.ref = 'redissonVersion'}
 cache-caffeine = {module = 'com.github.ben-manes.caffeine:caffeine', version.ref = 'caffeineVersion'}
 common-collections4 = {module = 'org.apache.commons:commons-collections4', version.ref = 'collections4Version'}
+google-guava = {module = 'com.google.guava:guava', version.ref = 'guavaVersion'}
 [plugins]
 spring-boot = {id = 'org.springframework.boot', version.ref = 'springBootVersion'}