添加查询接口用量方法

cloud-market-common/src/main/java/com/muyu/market/domian/Connector.java

@@ -10,6 +10,8 @@ import lombok.EqualsAndHashCode;
 import lombok.NoArgsConstructor;
 import lombok.experimental.SuperBuilder;
 
+import java.util.function.Supplier;
+
 /**
  接口列表
  */
@@ -44,5 +46,25 @@ public class Connector extends BaseEntity {
      */
     private Integer status;
 
+    //添加
+    public static Connector addBuild(Connector connector){
+        return Connector.builder()
+                .connectorName(connector.connectorName)
+                .connectorDescription(connector.connectorDescription)
+                .connectorNum(connector.connectorNum)
+                .status(connector.status)
+                .build();
+    }
+
+    //修改
+    public static Connector updBuild(Connector connector, Supplier<Long> supplier){
+        return Connector.builder()
+                .connectorId(supplier.get())
+                .connectorName(connector.connectorName)
+                .connectorDescription(connector.connectorDescription)
+                .connectorNum(connector.connectorNum)
+                .status(connector.status)
+                .build();
+    }
 
 }

cloud-market-server/src/main/java/com/muyu/market/controller/ConnectorController.java

@@ -0,0 +1,89 @@
+package com.muyu.market.controller;
+
+import com.muyu.common.core.domain.Result;
+import com.muyu.market.domian.Connector;
+import com.muyu.market.domian.Pay;
+import com.muyu.market.service.ConnectorService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+@Log4j2
+@RestController
+@RequestMapping("/market")
+@Tag(name = "接口调用展示",description = "进行接口调用量的展示")
+public class ConnectorController {
+
+    @Autowired
+    private ConnectorService service;
+
+
+    /**
+     * 查询接口调用量
+     * @return
+     */
+    @RequestMapping(path = "/list",method = RequestMethod.POST)
+    @Operation(summary = "查询接口调用量",description = "查询接口调用量")
+    public Result<List<Connector>> showList(){
+        List<Connector> list=service.showList();
+        return Result.success(list);
+    }
+
+    /**
+     * 添加信息
+     * @param
+     * @return  添加结果
+     */
+    @PostMapping
+    @Operation(summary = "信息添加",description = "添加信息，添加成功之后才可以只用支付类的产品")
+    public Result<String> save(@Validated @RequestBody Connector connector){
+        service.save(Connector.addBuild(connector));
+        return Result.success(null,"操作成功");
+    }
+
+//    /**
+//     * 修改客户
+//     * @param
+//     * @return 修改结果
+//     */
+//    @PutMapping("/{connectorId}")
+//    @Operation(summary = "客户信息修改",description = "通过ID修改客户信息")
+//    public Result<String> update(
+//            @Schema(title = "客户ID",type = "Long",defaultValue = "1",description = "修改客户信息需要依据的唯一条件")
+//            @PathVariable("connectorId") Long connectorId,
+//            @RequestBody @Validated Connector connector){
+//        service.updateById(Connector.updBuild(connector,
+//                () -> connectorId));
+//        return Result.success(null,"操作成功");
+//    }
+
+    /**
+     * 删除客户
+     * @param connectorId 删除客户请求信息
+     * @return 删除结果
+     */
+    @DeleteMapping("/{connectorId}")
+    @Operation(summary = "信息删除",description = "通过ID删除信息")
+    public Result<String> delete(@PathVariable("connectorId") Long connectorId){
+        service.removeById(connectorId);
+        return Result.success(null,"操作成功");
+    }
+
+    /**
+     * 通过ID获取客户
+     * @param connectorId ID
+     * @return 客户信息
+     */
+    @GetMapping("/{connectorId}")
+    @Operation(summary = "通过ID获取信息",description = "通过ID获取信息")
+    public Result<Connector> findById(@PathVariable("connectorId") Long connectorId){
+        return Result.success(service.getById(connectorId),"操作成功");
+    }
+
+}

cloud-market-server/src/main/java/com/muyu/market/mapper/ConnectorMapper.java

@@ -0,0 +1,9 @@
+package com.muyu.market.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.muyu.market.domian.Connector;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface ConnectorMapper extends BaseMapper<Connector> {
+}

cloud-market-server/src/main/java/com/muyu/market/service/ConnectorService.java

@@ -0,0 +1,15 @@
+package com.muyu.market.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.muyu.market.domian.Connector;
+
+import java.util.List;
+
+public interface ConnectorService extends IService<Connector> {
+
+    /**
+     * 列表查询
+     * @return
+     */
+    List<Connector> showList();
+}

cloud-market-server/src/main/java/com/muyu/market/service/impl/ConnectorServiceImpl.java

@@ -0,0 +1,38 @@
+package com.muyu.market.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.muyu.market.domian.Connector;
+import com.muyu.market.mapper.ConnectorMapper;
+import com.muyu.market.service.ConnectorService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+@Service
+public class ConnectorServiceImpl
+        extends ServiceImpl<ConnectorMapper, Connector>
+        implements ConnectorService {
+
+
+    @Autowired
+    private ConnectorMapper mapper;
+
+
+    /**
+     * 列表查询
+     *
+     * @return
+     */
+    @Override
+    public List<Connector> showList() {
+
+        LambdaQueryWrapper<Connector> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.select(Connector::getConnectorId);
+        List<Connector> list = this.list();
+        list.stream().map(Connector::getConnectorId).collect(Collectors.toSet());
+        return this.list(queryWrapper).stream().toList();
+    }
+}