Merge remote-tracking branch 'origin/master'

sys-api-feign/src/main/java/com/xy/feign/AlgorithmFeign.java

@@ -0,0 +1,21 @@
+package com.xy.feign;
+
+import com.xy.FeignInterceptor;
+import com.xy.consts.ServiceConsts;
+import com.xy.service.AlgorithmService;
+import io.swagger.annotations.Api;
+import org.springframework.cloud.openfeign.FeignClient;
+
+/**
+ * <p>
+ * 算法平台 feign
+ * </p>
+ *
+ * @author xy
+ * @since 2023-01-12
+ */
+@Api(tags = "算法平台feign")
+@FeignClient(value = ServiceConsts.SERVICE_NAME, configuration = FeignInterceptor.class)
+public interface AlgorithmFeign extends AlgorithmService {
+
+}

sys-api-service/src/main/java/com/xy/entity/Algorithm.java

@@ -0,0 +1,34 @@
+package com.xy.entity;
+
+import com.xy.base.BaseEntity2;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+/**
+ * <p>
+ * 算法平台
+ * </p>
+ *
+ * @author hechunping
+ * @since 2023-01-12
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="Algorithm对象", description="算法平台")
+public class Algorithm extends BaseEntity2<Algorithm> implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "算法平台名称")
+    private String name;
+
+    @ApiModelProperty(value = "接口域名")
+    private String host;
+
+}

sys-api-service/src/main/java/com/xy/mapper/AlgorithmMapper.java

@@ -0,0 +1,16 @@
+package com.xy.mapper;
+
+import com.xy.entity.Algorithm;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 算法平台 Mapper 接口
+ * </p>
+ *
+ * @author hechunping
+ * @since 2023-01-12
+ */
+public interface AlgorithmMapper extends BaseMapper<Algorithm> {
+
+}

sys-api-service/src/main/java/com/xy/service/AlgorithmServiceImpl.java

@@ -0,0 +1,74 @@
+package com.xy.service;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xy.dto.AlgorithmDto;
+import com.xy.entity.Algorithm;
+import com.xy.mapper.AlgorithmMapper;
+import com.xy.utils.AuthorizeUtils;
+import com.xy.utils.MybatisPlusQuery;
+import com.xy.utils.R;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import java.util.List;
+
+import static com.xy.utils.Beans.copy;
+
+
+/**
+* <p>
+* 算法平台 服务实现类
+* </p>
+*
+* @author hechunping
+* @since 2023-01-12
+*/
+@Service
+@AllArgsConstructor
+@Api(tags = "算法平台")
+public class AlgorithmServiceImpl extends ServiceImpl<AlgorithmMapper, Algorithm> implements AlgorithmService {
+
+    @Override
+    @ApiOperation("集合查询")
+    public R<List<AlgorithmDto.Vo>> list(@RequestBody AlgorithmDto.SelectList selectList) {
+        LambdaQueryWrapper<Algorithm> lambdaQueryWrapper = new MybatisPlusQuery().eqWrapper(selectList, Algorithm.class).build();
+        List<Algorithm> list = list(lambdaQueryWrapper);
+        return R.ok(copy(AlgorithmDto.Vo.class, list));
+    }
+
+    @Override
+    @ApiOperation(value = "新增、更新算法平台", notes = "不传id为新增，传id为修改")
+    public R saveOrUpdate(@Validated @RequestBody AlgorithmDto.Save saveDto) {
+        Long id = saveDto.getId();
+        boolean isAdd = id == null || id == 0;
+        //判断品牌是否存在
+        LambdaQueryWrapper<Algorithm> lambdaQueryWrapper = Wrappers.lambdaQuery();
+        lambdaQueryWrapper.eq(Algorithm::getName, saveDto.getName()).last("limit 1").select(Algorithm::getName);
+        Algorithm exists = getOne(lambdaQueryWrapper);
+        if (exists != null) {
+            if (isAdd) {
+                return R.fail("平台已存在");
+            } else {
+                if (exists.getId().intValue() != saveDto.getId().intValue()) {
+                    return R.fail("平台已存在");
+                }
+            }
+        }
+        Algorithm algorithm = copy(Algorithm.class, saveDto);
+        if (isAdd) {
+            algorithm.createUserTime(AuthorizeUtils.getLoginId(Long.class)).createId();
+            baseMapper.insert(algorithm);
+        } else {
+            algorithm.updateUserTime(AuthorizeUtils.getLoginId(Long.class));
+            baseMapper.updateById(algorithm);
+        }
+
+        return R.ok();
+    }
+}

sys-api/src/main/java/com/xy/dto/AlgorithmDto.java

@@ -0,0 +1,79 @@
+package com.xy.dto;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.xy.utils.PageBean;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import javax.validation.constraints.NotBlank;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 算法平台
+ * </p>
+ *
+ * @author hechunping
+ * @since 2023-01-12
+ */
+public class AlgorithmDto {
+
+    @Data
+    @Accessors(chain = true)
+    public static class SelectList extends Vo {
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Page extends Vo {
+
+        @ApiModelProperty(value = "分页对象", required = true)
+        private PageBean page;
+
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Save{
+        @ApiModelProperty(value = "id")
+        private Long id;
+
+        @NotBlank(message = "名称不能为空")
+        @ApiModelProperty("算法平台名称")
+        private String name;
+
+        @ApiModelProperty(value = "接口地址前缀")
+        private String host;
+    }
+
+    @Data
+    @Accessors(chain = true)
+    public static class Vo {
+
+        @ApiModelProperty(value = "id")
+        private Long id;
+
+        @ApiModelProperty(value = "算法平台名称")
+        private String name;
+
+        @ApiModelProperty(value = "接口域名")
+        private String host;
+
+        @ApiModelProperty(value = "创建人")
+        private Long createUser;
+
+        @ApiModelProperty(value = "创建时间")
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+        private LocalDateTime createTime;
+
+        @ApiModelProperty(value = "更新人")
+        private Long updateUser;
+
+        @ApiModelProperty(value = "更新时间")
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+        private LocalDateTime updateTime;
+    }
+
+}

sys-api/src/main/java/com/xy/service/AlgorithmService.java

@@ -0,0 +1,27 @@
+package com.xy.service;
+
+import com.xy.annotate.RestMappingController;
+import com.xy.dto.AlgorithmDto;
+import com.xy.utils.R;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 算法平台 服务类
+ * </p>
+ *
+ * @author hechunping
+ * @since 2023-01-12
+ */
+@RestMappingController("/algorithm")
+public interface AlgorithmService {
+    @PostMapping("list")
+    R<List<AlgorithmDto.Vo>> list(@RequestBody AlgorithmDto.SelectList selectList);
+
+    @PostMapping("saveOrUpdate")
+    R saveOrUpdate(@Validated @RequestBody AlgorithmDto.Save saveDto);
+}

sys-start/src/main/java/com/xy/PushDoc.java

@@ -0,0 +1,16 @@
+package com.xy;
+
+import cn.torna.swaggerplugin.SwaggerPlugin;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+ 
+public class PushDoc {
+
+
+    public static void main(String[] args) {
+        //手动推送更新torna文档
+        SwaggerPlugin.pushDoc();
+    }
+
+}