feat 分账接收方开发

daxpay-single/daxpay-single-admin/src/main/java/cn/bootx/platform/daxpay/admin/controller/allocation/AllocationGroupController.java

@@ -0,0 +1,101 @@
+package cn.bootx.platform.daxpay.admin.controller.allocation;
+
+import cn.bootx.platform.common.core.rest.PageResult;
+import cn.bootx.platform.common.core.rest.Res;
+import cn.bootx.platform.common.core.rest.ResResult;
+import cn.bootx.platform.common.core.rest.param.PageParam;
+import cn.bootx.platform.common.core.util.ValidationUtil;
+import cn.bootx.platform.daxpay.service.core.payment.allocation.service.AllocationGroupService;
+import cn.bootx.platform.daxpay.service.dto.allocation.AllocationGroupDto;
+import cn.bootx.platform.daxpay.service.dto.allocation.AllocationGroupReceiverResult;
+import cn.bootx.platform.daxpay.service.param.allocation.AllocationGroupBindParam;
+import cn.bootx.platform.daxpay.service.param.allocation.AllocationGroupParam;
+import cn.bootx.platform.daxpay.service.param.allocation.AllocationGroupUnbindParam;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * 分账组
+ * @author xxm
+ * @since 2024/4/2
+ */
+@Tag(name = "分账组")
+@RestController
+@RequestMapping("/allocation/group")
+@RequiredArgsConstructor
+public class AllocationGroupController {
+    private final AllocationGroupService allocationGroupService;
+
+    @Operation(summary = "分页")
+    @GetMapping("/page")
+    public ResResult<PageResult<AllocationGroupDto>> page(PageParam pageParam, AllocationGroupParam query){
+        return Res.ok(allocationGroupService.page(pageParam,query));
+    }
+
+    @Operation(summary = "查询详情")
+    @GetMapping("/findById")
+    public ResResult<AllocationGroupDto> findById(Long id){
+        return Res.ok(allocationGroupService.findById(id));
+    }
+
+    @Operation(summary = "查询分账接收方信息")
+    @GetMapping("/findReceiversByGroups")
+    public ResResult<List<AllocationGroupReceiverResult>> findReceiversByGroups(Long groupId){
+        return Res.ok(allocationGroupService.findReceiversByGroups(groupId));
+    }
+
+    @Operation(summary = "创建")
+    @PostMapping("/create")
+    public ResResult<Void> create(@RequestBody AllocationGroupParam param){
+        allocationGroupService.create(param);
+        return Res.ok();
+    }
+
+    @Operation(summary = "修改")
+    @PostMapping("/update")
+    public ResResult<Void> update(@RequestBody AllocationGroupParam param){
+        allocationGroupService.update(param);
+        return Res.ok();
+    }
+
+    @Operation(summary = "删除")
+    @PostMapping("/delete")
+    public ResResult<Void> delete(Long id){
+        allocationGroupService.delete(id);
+        return Res.ok();
+    }
+
+    @Operation(summary = "批量绑定接收者")
+    @PostMapping("/bindReceivers")
+    public ResResult<Void> bindReceivers(@RequestBody AllocationGroupBindParam param){
+        ValidationUtil.validateParam(param);
+        allocationGroupService.bindReceivers(param);
+        return Res.ok();
+    }
+
+    @Operation(summary = "批量取消绑定接收者")
+    @PostMapping("/unbindReceivers")
+    public ResResult<Void> unbindReceivers(@RequestBody AllocationGroupUnbindParam param){
+        allocationGroupService.unbindReceivers(param);
+        return Res.ok();
+    }
+
+    @Operation(summary = "取消绑定接收者")
+    @PostMapping("/unbindReceiver")
+    public ResResult<Void> unbindReceiver(Long receiverId){
+        allocationGroupService.unbindReceiver(receiverId);
+        return Res.ok();
+    }
+
+    @Operation(summary = "修改分账比例")
+    @PostMapping("/updateRate")
+    public ResResult<Void> updateRate(Long receiverId, Integer rate){
+        allocationGroupService.updateRate(receiverId,rate);
+        return Res.ok();
+    }
+
+}

daxpay-single/daxpay-single-admin/src/main/java/cn/bootx/platform/daxpay/admin/controller/allocation/AllocationReceiverController.java

@@ -3,6 +3,7 @@ package cn.bootx.platform.daxpay.admin.controller.allocation;
 import cn.bootx.platform.common.core.rest.PageResult;
 import cn.bootx.platform.common.core.rest.Res;
 import cn.bootx.platform.common.core.rest.ResResult;
+import cn.bootx.platform.common.core.rest.dto.LabelValue;
 import cn.bootx.platform.common.core.rest.param.PageParam;
 import cn.bootx.platform.daxpay.service.core.payment.allocation.service.AllocationReceiverService;
 import cn.bootx.platform.daxpay.service.dto.allocation.AllocationReceiverDto;
@@ -11,10 +12,9 @@ import cn.bootx.platform.daxpay.service.param.allocation.AllocationReceiverQuery
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
 
 /**
  * 对账接收方控制器
@@ -41,20 +41,38 @@ public class AllocationReceiverController {
         return Res.ok(receiverService.findById(id));
     }
 
+    @Operation(summary = "获取可以分账的通道")
+    @GetMapping("/findChannels")
+    public ResResult<List<LabelValue>> findChannels(){
+        return Res.ok(receiverService.findChannels());
+    }
+    @Operation(summary = "根据通道获取分账接收方类型")
+    @GetMapping("/findReceiverTypeByChannel")
+    public ResResult<List<LabelValue>> findReceiverTypeByChannel(String channel){
+        return Res.ok(receiverService.findReceiverTypeByChannel(channel));
+    }
+
     @Operation(summary = "新增")
-    @PostMapping("")
-    public ResResult<Void> add(AllocationReceiverParam param){
+    @PostMapping("add")
+    public ResResult<Void> add(@RequestBody AllocationReceiverParam param){
         receiverService.add(param);
         return Res.ok();
     }
 
     @Operation(summary = "修改")
     @PostMapping("update")
-    public ResResult<Void> update(AllocationReceiverParam param){
+    public ResResult<Void> update(@RequestBody AllocationReceiverParam param){
         receiverService.update(param);
         return Res.ok();
     }
 
+    @Operation(summary = "删除")
+    @PostMapping("delete")
+    public ResResult<Void> delete(Long id){
+        receiverService.remove(id);
+        return Res.ok();
+    }
+
     @Operation(summary = "同步到三方支付系统中")
     @PostMapping("registerByGateway")
     public ResResult<Void> registerByGateway(Long id){