回调接口暴露，先打印至日志，打印日志的报文供调试，后续需要的话手动计算解密存储至DB

framework/src/main/java/cn/lili/modules/order/customs/JiangyinServiceManager.java

@@ -72,7 +72,6 @@ public class JiangyinServiceManager {
         // 开始调用
         Map<String, Object> paramMap = BeanUtil.beanToMap(param);
         log.info("request body: {}", paramMap);
-//        String res = "";
         String res = HttpUtil.post(JIANGYIN_ORDER_PUSH_URL, paramMap, 30000);
         log.info("response msg: {}", res);
         customsRec.setResMsg(res);

framework/src/main/java/cn/lili/modules/order/order/service/OrderService.java

@@ -291,4 +291,11 @@ public interface OrderService extends IService<Order> {
      * @return 是否成功
      */
     boolean checkFictitiousOrder(String pintuanId, Integer requiredNum, Boolean fictitious);
+
+    /**
+     * 保存回执报文
+     * @param content 回执报文
+     * @param copMsgId 企业消息ID
+     */
+    void saveCustomsCallback(String content, String copMsgId);
 }

framework/src/main/java/cn/lili/modules/order/order/serviceimpl/OrderServiceImpl.java

@@ -63,6 +63,7 @@ import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.poi.ss.util.CellRangeAddressList;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -84,6 +85,7 @@ import java.util.stream.Collectors;
  * @author Chopper
  * @since 2020/11/17 7:38 下午
  */
+@Slf4j
 @Service
 public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {
 
@@ -468,6 +470,13 @@ public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements
     }
 
     @Override
+    public void saveCustomsCallback(String content, String copMsgId) {
+        // 根据copMsgId取出企业对应报关元数据
+        // 解密存储
+        log.info("receive callback message: [{}, {}]", content, copMsgId);
+    }
+
+    @Override
     @OrderLogPoint(description = "'订单['+#orderSn+']核销，核销码['+#verificationCode+']'", orderSn = "#orderSn")
     public Order take(String orderSn, String verificationCode) {
 

seller-api/src/main/java/cn/lili/controller/order/OrderStoreController.java

@@ -180,4 +180,15 @@ public class OrderStoreController {
     public ResultMessage<Object> customsPush(@NotBlank(message = "订单编号不能为空") @PathVariable String orderSn) {
         return ResultUtil.data(orderService.customsPush(orderSn)? "推送成功" : "推送失败");
     }
+
+    @ApiOperation(value = "报关回调接口")
+    @PostMapping(path = "/customs/callback")
+    public ResultMessage<Object> customsCallback(String signMsg, String content, String msgType, String copMsgId) {
+        log.info("callback param:[{},{},{},{}]", signMsg, content, msgType, copMsgId);
+        // String key = CustomPayload.JiangyinXingguang.signKey;
+        // Assert.isTrue(signMsg.equals(AesEncrypt.decrypt(content + key, key)));
+        // TODO 验签
+        orderService.saveCustomsCallback(content, copMsgId);
+        return ResultUtil.success();
+    }
 }

seller-api/src/main/resources/application.yml

@@ -121,6 +121,7 @@ ignored:
     - /source/**
     - /store/passport/login/**
     - /store/passport/login/refresh/**
+    - /store/order/order/customs/callback
     - /druid/**
     - /swagger-ui.html
     - /doc.html