diff --git a/cloud-market-common/src/main/java/com/muyu/market/domian/Connector.java b/cloud-market-common/src/main/java/com/muyu/market/domian/Connector.java index 9a3bffe..8c05541 100644 --- a/cloud-market-common/src/main/java/com/muyu/market/domian/Connector.java +++ b/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 supplier){ + return Connector.builder() + .connectorId(supplier.get()) + .connectorName(connector.connectorName) + .connectorDescription(connector.connectorDescription) + .connectorNum(connector.connectorNum) + .status(connector.status) + .build(); + } } diff --git a/cloud-market-server/src/main/java/com/muyu/market/controller/ConnectorController.java b/cloud-market-server/src/main/java/com/muyu/market/controller/ConnectorController.java new file mode 100644 index 0000000..208ae23 --- /dev/null +++ b/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> showList(){ + List list=service.showList(); + return Result.success(list); + } + + /** + * 添加信息 + * @param + * @return 添加结果 + */ + @PostMapping + @Operation(summary = "信息添加",description = "添加信息，添加成功之后才可以只用支付类的产品") + public Result save(@Validated @RequestBody Connector connector){ + service.save(Connector.addBuild(connector)); + return Result.success(null,"操作成功"); + } + +// /** +// * 修改客户 +// * @param +// * @return 修改结果 +// */ +// @PutMapping("/{connectorId}") +// @Operation(summary = "客户信息修改",description = "通过ID修改客户信息") +// public Result 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 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 findById(@PathVariable("connectorId") Long connectorId){ + return Result.success(service.getById(connectorId),"操作成功"); + } + +} diff --git a/cloud-market-server/src/main/java/com/muyu/market/mapper/ConnectorMapper.java b/cloud-market-server/src/main/java/com/muyu/market/mapper/ConnectorMapper.java new file mode 100644 index 0000000..c1b769d --- /dev/null +++ b/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 { +} diff --git a/cloud-market-server/src/main/java/com/muyu/market/service/ConnectorService.java b/cloud-market-server/src/main/java/com/muyu/market/service/ConnectorService.java new file mode 100644 index 0000000..6136071 --- /dev/null +++ b/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 { + + /** + * 列表查询 + * @return + */ + List showList(); +} diff --git a/cloud-market-server/src/main/java/com/muyu/market/service/impl/ConnectorServiceImpl.java b/cloud-market-server/src/main/java/com/muyu/market/service/impl/ConnectorServiceImpl.java new file mode 100644 index 0000000..3ccc920 --- /dev/null +++ b/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 + implements ConnectorService { + + + @Autowired + private ConnectorMapper mapper; + + + /** + * 列表查询 + * + * @return + */ + @Override + public List showList() { + + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.select(Connector::getConnectorId); + List list = this.list(); + list.stream().map(Connector::getConnectorId).collect(Collectors.toSet()); + return this.list(queryWrapper).stream().toList(); + } +}