修改

ms-biz/src/main/java/com/ms/biz/spi/callback/BatchCreateService.java

@@ -0,0 +1,28 @@
+package com.ms.biz.spi.callback;
+
+import com.jinritemai.cloud.base.api.BaseRequest;
+import com.jinritemai.cloud.base.api.BaseResponse;
+import com.jinritemai.cloud.base.api.ExtensionService;
+import com.jinritemai.cloud.base.api.ExtensionServiceHandler;
+import com.ms.biz.common.R;
+import com.ms.biz.common.SPIBaseService;
+import com.ms.biz.dto.openspi.request.BatchCreateParam;
+import com.ms.biz.dto.openspi.response.BatchCreateData;
+import com.ms.biz.service.DistributionOrderService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@ExtensionService("batchCreate")
+@Slf4j
+@AllArgsConstructor
+public class BatchCreateService extends SPIBaseService implements ExtensionServiceHandler<BatchCreateParam, BatchCreateData> {
+    private DistributionOrderService distributionOrderService;
+
+    @Override
+    public BaseResponse<BatchCreateData> handle(BaseRequest<BatchCreateParam> req) {
+        BatchCreateParam param = req.getData();
+        BatchCreateData data = new BatchCreateData();
+        distributionOrderService.batchCreate(param, data);
+        return R.ok(data);
+    }
+}

ms-biz/src/main/java/com/ms/biz/spi/callback/BatchPayService.java

@@ -0,0 +1,28 @@
+package com.ms.biz.spi.callback;
+
+import com.jinritemai.cloud.base.api.BaseRequest;
+import com.jinritemai.cloud.base.api.BaseResponse;
+import com.jinritemai.cloud.base.api.ExtensionService;
+import com.jinritemai.cloud.base.api.ExtensionServiceHandler;
+import com.ms.biz.common.R;
+import com.ms.biz.common.SPIBaseService;
+import com.ms.biz.dto.openspi.request.BatchPayParam;
+import com.ms.biz.dto.openspi.response.BatchPayData;
+import com.ms.biz.service.DistributionOrderService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@ExtensionService("batchPay")
+@Slf4j
+@AllArgsConstructor
+public class BatchPayService  extends SPIBaseService implements ExtensionServiceHandler<BatchPayParam, BatchPayData> {
+    private DistributionOrderService distributionOrderService;
+
+    @Override
+    public BaseResponse<BatchPayData> handle(BaseRequest<BatchPayParam> req) {
+        BatchPayParam param = req.getData();
+        BatchPayData data = new BatchPayData();
+        distributionOrderService.batchPay(param, data);
+        return R.ok(data);
+    }
+}

ms-biz/src/main/java/com/ms/biz/spi/callback/QuerySupplyPlatformAuthService.java

@@ -0,0 +1,28 @@
+package com.ms.biz.spi.callback;
+
+import com.jinritemai.cloud.base.api.BaseRequest;
+import com.jinritemai.cloud.base.api.BaseResponse;
+import com.jinritemai.cloud.base.api.ExtensionService;
+import com.jinritemai.cloud.base.api.ExtensionServiceHandler;
+import com.ms.biz.common.R;
+import com.ms.biz.common.SPIBaseService;
+import com.ms.biz.dto.openspi.request.QuerySupplyPlatformAuthParam;
+import com.ms.biz.dto.openspi.response.QuerySupplyPlatformAuthData;
+import com.ms.biz.service.ShopService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@ExtensionService("querySupplyPlatformAuth")
+@Slf4j
+@AllArgsConstructor
+public class QuerySupplyPlatformAuthService extends SPIBaseService implements ExtensionServiceHandler<QuerySupplyPlatformAuthParam, QuerySupplyPlatformAuthData> {
+    private ShopService shopService;
+
+    @Override
+    public BaseResponse<QuerySupplyPlatformAuthData> handle(BaseRequest<QuerySupplyPlatformAuthParam> req) {
+        QuerySupplyPlatformAuthParam param = req.getData();
+        QuerySupplyPlatformAuthData data = new QuerySupplyPlatformAuthData();
+        shopService.querySupplyPlatformAuth(param, data);
+        return R.ok(data);
+    }
+}