收钱吧调用逻辑

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/GoblinShouQianBaServiceImpl.java

@@ -7,6 +7,7 @@ import com.liquidnet.commons.lang.util.MD5Utils;
 import com.liquidnet.service.goblin.param.shouqianba.request.CashierQueryRequest;
 import com.liquidnet.service.goblin.param.shouqianba.request.OrderCreateRequest;
 import com.liquidnet.service.goblin.param.shouqianba.request.SettlementCreateRequest;
+import com.liquidnet.service.goblin.param.shouqianba.response.OrderCreateResponse;
 import com.liquidnet.service.goblin.param.shouqianba.response.SettlementCreateResponse;
 import com.liquidnet.service.goblin.param.shouqianba.response.data.CashierQueryData;
 import com.liquidnet.service.goblin.param.shouqianba.response.data.OrderCreateData;
@@ -81,8 +82,39 @@ public class GoblinShouQianBaServiceImpl implements IGoblinShouQianBaService {
 
     @Override
     public OrderCreateData createOrder(OrderCreateRequest request) {
-        return null;
+        final String url = BASE_API + "/optimus/core/mall/createPreOrder";
+        log.info("[收钱吧] 创建订单, 请求URL: {}, 请求参数: {}", url, request);
+
+        try {
+            // body进行序列化成TreeMap以后 最后转成json（为了排序稳定）
+            TreeMap<String, Object> map = objectMapper.convertValue(
+                    request,
+                    new TypeReference<TreeMap<String, Object>>() {
+                    }
+            );
+            String requestBody = objectMapper.writeValueAsString(map);
+
+            // 构建请求头（添加签名参数）
+            MultiValueMap<String, String> headers = new LinkedMultiValueMap<>();
+            headers.add("Authorization", getSign(requestBody));
+
+            String responseStr = HttpUtil.postJson(url, requestBody, headers);
+            log.info("[收钱吧] 创建订单, 响应体: {}", responseStr);
 
+            // 转换响应报文
+            OrderCreateResponse response = objectMapper.readValue(responseStr, OrderCreateResponse.class);
+            if (response != null && Boolean.TRUE.equals(response.getSuccess())) {
+                return response.getData();
+            } else {
+                log.error("[收钱吧] 创建订单失败, code: {}, msg: {}",
+                        response != null ? response.getCode() : "null",
+                        response != null ? response.getMsg() : "null");
+                return null;
+            }
+        } catch (Exception e) {
+            log.error("[收钱吧] 创建订单发生异常, 请求参数: {}", request, e);
+            return null;
+        }
     }
 
     @Override