项目移动

2023-03-30 10:01:57 +08:00
parent 346530b0a0
commit d6489cc376
39 changed files with 270 additions and 126 deletions
--- a/pqs-algorithm/algorithm-boot/pom.xml
+++ b/pqs-algorithm/algorithm-boot/pom.xml
@@ -0,0 +1,135 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>pqs-algorithm</artifactId>
+        <groupId>com.njcn</groupId>
+        <version>1.0.0</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.njcn</groupId>
+            <artifactId>common-web</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.njcn</groupId>
+            <artifactId>common-db</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.njcn</groupId>
+            <artifactId>common-swagger</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.njcn</groupId>
+            <artifactId>event-api</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.njcn</groupId>
+            <artifactId>pq-device-api</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.njcn</groupId>
+            <artifactId>system-api</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.njcn</groupId>
+            <artifactId>user-api</artifactId>
+            <version>1.0.0</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.njcn</groupId>
+            <artifactId>algorithm-api</artifactId>
+            <version>1.0.0</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.njcn</groupId>
+            <artifactId>common-oss</artifactId>
+            <version>1.0.0</version>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+
+    <artifactId>algorithm-boot</artifactId>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+    <build>
+        <finalName>algorithmboot</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.8.0</version>
+                <configuration>
+                    <compilerArgument>-Xlint:unchecked</compilerArgument>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+
+<!--            <plugin>-->
+<!--                <groupId>com.spotify</groupId>-->
+<!--                <artifactId>docker-maven-plugin</artifactId>-->
+<!--                <version>1.0.0</version>-->
+<!--                <executions>-->
+<!--                    &lt;!&ndash;执行mvn package,即执行 mvn clean package docker:build&ndash;&gt;-->
+<!--                    <execution>-->
+<!--                        <id>build-image</id>-->
+<!--                        <phase>${docker.operate}</phase>-->
+<!--                        <goals>-->
+<!--                            <goal>build</goal>-->
+<!--                        </goals>-->
+<!--                    </execution>-->
+<!--                </executions>-->
+<!--                <configuration>-->
+<!--                    &lt;!&ndash;<serverId>36dockerHarbor</serverId>&ndash;&gt;-->
+<!--                    <registryUrl>http://${docker.repostory}</registryUrl>-->
+<!--                    &lt;!&ndash; 镜像名称 &ndash;&gt;-->
+<!--                    <imageName>${docker.repostory}/${docker.registry.name}/${project.artifactId}</imageName>-->
+<!--                    &lt;!&ndash; 指定标签 &ndash;&gt;-->
+<!--                    <imageTags>-->
+<!--                        <imageTag>latest</imageTag>-->
+<!--                    </imageTags>-->
+<!--                    &lt;!&ndash; 指定远程 Docker API地址  &ndash;&gt;-->
+<!--                    <dockerHost>${docker.url}</dockerHost>-->
+<!--                    <dockerDirectory>${basedir}/</dockerDirectory>-->
+<!--                    &lt;!&ndash; 复制 jar包到docker容器指定目录&ndash;&gt;-->
+<!--                    <resources>-->
+<!--                        <resource>-->
+<!--                            <targetPath>/ROOT</targetPath>-->
+<!--                            &lt;!&ndash; 用于指定需要复制的根目录，${project.build.directory}表示target目录 &ndash;&gt;-->
+<!--                            <directory>${project.build.directory}</directory>-->
+<!--                            &lt;!&ndash; 用于指定需要复制的文件，${project.build.finalName}.jar就是打包后的target目录下的jar包名称　&ndash;&gt;-->
+<!--                            <include>${project.build.finalName}.jar</include>-->
+<!--                        </resource>-->
+<!--                    </resources>-->
+<!--                </configuration>-->
+<!--            </plugin>-->
+        </plugins>
+    </build>
+
+</project>
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/AlgorithmBootApplication.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/AlgorithmBootApplication.java
@@ -0,0 +1,22 @@
+package com.njcn.algorithm;
+/**
+ * @author denghuajun
+ * @version 1.0.0
+ * @date 2022年08月18日 09:33
+ */
+import lombok.extern.slf4j.Slf4j;
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+@Slf4j
+@MapperScan("com.njcn.**.mapper")
+@EnableFeignClients(basePackages = "com.njcn")
+@SpringBootApplication(scanBasePackages = "com.njcn")
+public class
+AlgorithmBootApplication {
+    public static void main(String[] args)  {
+        SpringApplication.run(AlgorithmBootApplication.class, args);
+    }
+}
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/project/AppProjectController.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/project/AppProjectController.java
@@ -0,0 +1,74 @@
+package com.njcn.algorithm.controller.project;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.njcn.algorithm.pojo.param.AppProjectAddParm;
+import com.njcn.algorithm.pojo.param.AppProjectAuditParm;
+import com.njcn.algorithm.pojo.param.AppProjectQueryParm;
+import com.njcn.algorithm.pojo.vo.AppProjectVO;
+import com.njcn.algorithm.service.AppProjectService;
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/27  10:54【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Slf4j
+@RestController
+@RequestMapping("/project")
+@Api(tags = " 项目管理")
+@AllArgsConstructor
+public class AppProjectController  extends BaseController {
+
+
+    private final AppProjectService appProjectService;
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/queryProject")
+    @ApiOperation("项目查询")
+    @ApiImplicitParam(name = "appProjectQueryParm", value = "项目查询参数", required = true)
+    public HttpResult<IPage<AppProjectVO>> queryProject(@Validated @RequestBody AppProjectQueryParm appProjectQueryParm){
+        String methodDescribe = getMethodDescribe("queryProject");
+
+        IPage<AppProjectVO> appProjectVOIPage  = appProjectService.queryProject (appProjectQueryParm);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, appProjectVOIPage, methodDescribe);
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/addAppProject")
+    @ApiOperation("新增项目")
+    public HttpResult<Boolean> addAppProject(@Validated  AppProjectAddParm appProjectAddParm){
+        String methodDescribe = getMethodDescribe("addAppProject");
+
+        Boolean flag = appProjectService.addAppProject(appProjectAddParm);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, flag, methodDescribe);
+    }
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/auditAppProject")
+    @ApiOperation("修改/删除项目")
+    @ApiImplicitParam(name = "appProjectAuditParm", value = "修改项目参数", required = true)
+    public HttpResult<Boolean> auditAppProject(@Validated @RequestBody AppProjectAuditParm appProjectAuditParm){
+        String methodDescribe = getMethodDescribe("auditAppProject");
+
+        Boolean flag = appProjectService.AuditAppProject(appProjectAuditParm);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, flag, methodDescribe);
+    }
+}
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/project/AppTopologyController.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/project/AppTopologyController.java
@@ -0,0 +1,90 @@
+package com.njcn.algorithm.controller.project;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.njcn.algorithm.pojo.param.AppTopologyDiagramAddParm;
+import com.njcn.algorithm.pojo.param.AppTopologyDiagramAuditParm;
+import com.njcn.algorithm.pojo.param.AppTopologyDiagramQueryPageParm;
+import com.njcn.algorithm.pojo.param.AppTopologyDiagramQueryParm;
+import com.njcn.algorithm.pojo.vo.AppTopologyDiagramVO;
+import com.njcn.algorithm.service.AppTopologyDiagramService;
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/27  15:31【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Slf4j
+@RestController
+@RequestMapping("/topologyDiagram")
+@Api(tags = " 项目拓扑图")
+@AllArgsConstructor
+public class AppTopologyController extends BaseController {
+
+    private final AppTopologyDiagramService appTopologyDiagramService;
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/addAppTopologyDiagram")
+    @ApiOperation("新增拓扑图")
+//    @ApiImplicitParam(name = "appTopologyDiagramAddParm", value = "新增项目参数", required = true)
+    public HttpResult<Boolean> addAppTopologyDiagram(@Validated AppTopologyDiagramAddParm appTopologyDiagramAddParm){
+        String methodDescribe = getMethodDescribe("addAppTopologyDiagram");
+
+        Boolean flag = appTopologyDiagramService.addAppTopologyDiagram(appTopologyDiagramAddParm);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, flag, methodDescribe);
+    }
+
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/AuditAppTopologyDiagram")
+    @ApiOperation("修改拓扑图")
+    public HttpResult<Boolean> AuditAppTopologyDiagram(@Validated AppTopologyDiagramAuditParm appTopologyDiagramAuditParm){
+        String methodDescribe = getMethodDescribe("addAppProject");
+
+        Boolean flag = appTopologyDiagramService.AuditAppTopologyDiagram(appTopologyDiagramAuditParm);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, flag, methodDescribe);
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/queryAppTopologyDiagram")
+    @ApiOperation("查询拓扑图")
+    @ApiImplicitParam(name = "appTopologyDiagramQueryParm", value = "拓扑图查询参数", required = true)
+    public HttpResult<List<AppTopologyDiagramVO>> queryAppTopologyDiagram(@Validated @RequestBody AppTopologyDiagramQueryParm appTopologyDiagramQueryParm){
+        String methodDescribe = getMethodDescribe("queryAppTopologyDiagram");
+
+        List<AppTopologyDiagramVO> appTopologyDiagramVOList = appTopologyDiagramService.queryAppTopologyDiagram(appTopologyDiagramQueryParm);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, appTopologyDiagramVOList, methodDescribe);
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/queryTopologyDiagramPage")
+    @ApiOperation("查询拓扑图分页")
+    @ApiImplicitParam(name = "appTopologyDiagramQueryPageParm", value = "拓扑图查询参数", required = true)
+    public HttpResult<IPage<AppTopologyDiagramVO>> queryTopologyDiagramPage(@Validated @RequestBody AppTopologyDiagramQueryPageParm  appTopologyDiagramQueryPageParm){
+        String methodDescribe = getMethodDescribe("queryTopologyDiagramPage");
+
+        IPage<AppTopologyDiagramVO> appTopologyDiagramVOList = appTopologyDiagramService.queryTopologyDiagramPage(appTopologyDiagramQueryPageParm);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, appTopologyDiagramVOList, methodDescribe);
+    }
+
+}
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/project/LineTopologyDiagramController.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/project/LineTopologyDiagramController.java
@@ -0,0 +1,26 @@
+package com.njcn.algorithm.controller.project;
+
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/30  9:02【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Slf4j
+@RestController
+@RequestMapping("/lineTopologyDiagram")
+@Api(tags = " 拓扑图-监测点")
+@AllArgsConstructor
+public class LineTopologyDiagramController extends BaseController {
+
+
+}
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/AppLineTopologyDiagramMapper.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/AppLineTopologyDiagramMapper.java
@@ -0,0 +1,16 @@
+package com.njcn.algorithm.mapper;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.algorithm.pojo.po.AppLineTopologyDiagramPO;
+
+/**
+ * 
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/27  10:18【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+public interface AppLineTopologyDiagramMapper extends MppBaseMapper<AppLineTopologyDiagramPO> {
+}
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/AppProjectMapper.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/AppProjectMapper.java
@@ -0,0 +1,57 @@
+package com.njcn.algorithm.mapper;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.algorithm.pojo.param.AppProjectQueryParm;
+import com.njcn.algorithm.pojo.po.AppProjectPO;
+import com.njcn.algorithm.pojo.vo.AppProjectVO;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+/**
+ * 
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/27  10:24【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+public interface AppProjectMapper extends MppBaseMapper<AppProjectPO> {
+    @Select (
+            {"<script>",
+            "SELECT\n" +
+            "\ta.id id,\n" +
+            "\ta.`name` name,\n" +
+            "\ta.user_id user_id,\n" +
+            "\t\"username\" user_name,\n" +
+            "\ta.area area,\n" +
+//            "\tb.file_path topologyDiagramPath,\n" +
+            "\ta.lng lng,\n" +
+            "\ta.lat lat,\n" +
+            "\ta.`status` STATUS,\n" +
+            "\ta.create_by create_by,\n" +
+            "\ta.create_time create_time,\n" +
+            "\ta.update_by update_by,\n" +
+            "\ta.update_time update_time\n" +
+            "FROM\n" +
+            "\tcs_project a\n" +
+            "LEFT JOIN cs_topology_diagram b ON a.id = b.project_id\n" +
+            "WHERE\n" +
+            "\t1 = 1 AND a.status=\"1\"\n" ,
+                    "<when test='temp.projectId!=null and temp.projectId!=\"\"'>",
+            "AND a.id = #{temp.projectId} "+
+                    "</when>",
+                    "<when test='temp.endTime!=null and temp.endTime!=\"\"'>",
+                    "AND a.create_time &lt;= #{temp.endTime}" +
+                            "</when>",
+                    "<when test='temp.startTime!=null and temp.startTime!=\"\"'>",
+            "AND a.create_time &gt;= #{temp.startTime}" +
+                    "</when>",
+                    "<when test='temp.searchValue!=null and temp.searchValue!=\"\"'>",
+            "AND a.`name` like concat('%',#{temp.searchValue},'%')",
+                    "</when>",
+                    "</script>"}
+                    )
+    Page<AppProjectVO> getPageVo(Page<AppProjectVO> returnpage, @Param("temp")AppProjectQueryParm appProjectQueryParm);
+}
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/AppTopologyDiagramMapper.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/AppTopologyDiagramMapper.java
@@ -0,0 +1,16 @@
+package com.njcn.algorithm.mapper;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.algorithm.pojo.po.AppTopologyDiagramPO;
+
+/**
+ * 
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/27  10:24【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+public interface AppTopologyDiagramMapper extends MppBaseMapper<AppTopologyDiagramPO> {
+}
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/AppLineTopologyDiagramMapper.xml
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/AppLineTopologyDiagramMapper.xml
@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.njcn.algorithm.mapper.AppLineTopologyDiagramMapper">
+  <resultMap id="BaseResultMap" type="com.njcn.algorithm.pojo.po.AppLineTopologyDiagramPO">
+    <!--@mbg.generated-->
+    <!--@Table app_line_topology_diagram-->
+    <id column="id" jdbcType="VARCHAR" property="id" />
+    <result column="line_id" jdbcType="VARCHAR" property="lineId" />
+    <result column="status" jdbcType="TINYINT" property="status" />
+    <result column="create_by" jdbcType="CHAR" property="createBy" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+    <result column="update_by" jdbcType="CHAR" property="updateBy" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, line_id, `status`, create_by, create_time, update_by, update_time
+  </sql>
+</mapper>
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/AppProjectMapper.xml
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/AppProjectMapper.xml
@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.njcn.algorithm.mapper.AppProjectMapper">
+  <resultMap id="BaseResultMap" type="com.njcn.algorithm.pojo.po.AppProjectPO">
+    <!--@mbg.generated-->
+    <!--@Table app_project-->
+    <id column="id" jdbcType="VARCHAR" property="id" />
+    <result column="name" jdbcType="VARCHAR" property="name" />
+    <result column="user_id" jdbcType="VARCHAR" property="userId" />
+    <result column="area_id" jdbcType="VARCHAR" property="areaId" />
+    <result column="lng" jdbcType="DECIMAL" property="lng" />
+    <result column="lat" jdbcType="DECIMAL" property="lat" />
+    <result column="status" jdbcType="TINYINT" property="status" />
+    <result column="create_by" jdbcType="CHAR" property="createBy" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+    <result column="update_by" jdbcType="CHAR" property="updateBy" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, `name`, user_id, area_id, lng, lat, `status`, create_by, create_time, update_by, 
+    update_time
+  </sql>
+</mapper>
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/AppTopologyDiagramMapper.xml
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/AppTopologyDiagramMapper.xml
@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.njcn.algorithm.mapper.AppTopologyDiagramMapper">
+  <resultMap id="BaseResultMap" type="com.njcn.algorithm.pojo.po.AppTopologyDiagramPO">
+    <!--@mbg.generated-->
+    <!--@Table app_topology_diagram-->
+    <id column="id" jdbcType="VARCHAR" property="id" />
+    <result column="name" jdbcType="VARCHAR" property="name" />
+    <result column="file_size" jdbcType="INTEGER" property="fileSize" />
+    <result column="project_id" jdbcType="VARCHAR" property="projectId" />
+    <result column="file_path" jdbcType="VARCHAR" property="filePath" />
+    <result column="status" jdbcType="TINYINT" property="status" />
+    <result column="create_by" jdbcType="CHAR" property="createBy" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+    <result column="update_by" jdbcType="CHAR" property="updateBy" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, `name`, file_size, project_id, file_path, `status`, create_by, create_time, update_by, 
+    update_time
+  </sql>
+</mapper>
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/AppLineTopologyDiagramService.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/AppLineTopologyDiagramService.java
@@ -0,0 +1,17 @@
+package com.njcn.algorithm.service;
+
+import com.github.jeffreyning.mybatisplus.service.IMppService;
+import com.njcn.algorithm.pojo.po.AppLineTopologyDiagramPO;
+    /**
+ * 
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/27  10:18【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+public interface AppLineTopologyDiagramService extends IMppService<AppLineTopologyDiagramPO> {
+
+
+}
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/AppProjectService.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/AppProjectService.java
@@ -0,0 +1,46 @@
+package com.njcn.algorithm.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.github.jeffreyning.mybatisplus.service.IMppService;
+import com.njcn.algorithm.pojo.param.AppProjectAddParm;
+import com.njcn.algorithm.pojo.param.AppProjectAuditParm;
+import com.njcn.algorithm.pojo.param.AppProjectQueryParm;
+import com.njcn.algorithm.pojo.po.AppProjectPO;
+import com.njcn.algorithm.pojo.vo.AppProjectVO;
+
+/**
+ * 
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/27  10:24【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+public interface AppProjectService extends IMppService<AppProjectPO> {
+
+        /** 
+        * @Description: addOrAuditPlan 
+        * @Param: [appProjectAddOrAuditParm] 
+        * @return: java.lang.Boolean 
+        * @Author: clam
+        * @Date: 2023/3/27 
+        */ 
+        Boolean addAppProject(AppProjectAddParm appProjectAddOrAuditParm);
+        /** 
+        * @Description: AuditAppProject 
+        * @Param: [appProjectAuditParm] 
+        * @return: java.lang.Boolean 
+        * @Author: clam
+        * @Date: 2023/3/27 
+        */ 
+        Boolean AuditAppProject(AppProjectAuditParm appProjectAuditParm);
+        /** 
+        * @Description: queryProject 
+        * @Param: [appProjectQueryParm] 
+        * @return: com.baomidou.mybatisplus.core.metadata.IPage<com.njcn.advance.pojo.vo.AppProjectVO> 
+        * @Author: clam
+        * @Date: 2023/3/28 
+        */ 
+        IPage<AppProjectVO> queryProject(AppProjectQueryParm appProjectQueryParm);
+    }
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/AppTopologyDiagramService.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/AppTopologyDiagramService.java
@@ -0,0 +1,57 @@
+package com.njcn.algorithm.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.github.jeffreyning.mybatisplus.service.IMppService;
+import com.njcn.algorithm.pojo.param.AppTopologyDiagramAddParm;
+import com.njcn.algorithm.pojo.param.AppTopologyDiagramAuditParm;
+import com.njcn.algorithm.pojo.param.AppTopologyDiagramQueryPageParm;
+import com.njcn.algorithm.pojo.param.AppTopologyDiagramQueryParm;
+import com.njcn.algorithm.pojo.po.AppTopologyDiagramPO;
+import com.njcn.algorithm.pojo.vo.AppTopologyDiagramVO;
+
+import java.util.List;
+
+/**
+ * 
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/27  10:24【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+public interface AppTopologyDiagramService extends IMppService<AppTopologyDiagramPO> {
+
+        /** 
+        * @Description: addAppTopologyDiagram 
+        * @Param: [appTopologyDiagramAddParm] 
+        * @return: java.lang.Boolean 
+        * @Author: clam
+        * @Date: 2023/3/27 
+        */ 
+        Boolean addAppTopologyDiagram(AppTopologyDiagramAddParm appTopologyDiagramAddParm);
+        /** 
+        * @Description: AuditAppTopologyDiagram 
+        * @Param: [appTopologyDiagramAuditParm] 
+        * @return: java.lang.Boolean 
+        * @Author: clam
+        * @Date: 2023/3/27 
+        */ 
+        Boolean AuditAppTopologyDiagram(AppTopologyDiagramAuditParm appTopologyDiagramAuditParm);
+        /** 
+        * @Description: queryAppTopologyDiagram 
+        * @Param: [appTopologyDiagramAuditParm] 
+        * @return: java.util.List<com.njcn.advance.pojo.vo.AppTopologyDiagramVO> 
+        * @Author: clam
+        * @Date: 2023/3/29 
+        */ 
+        List<AppTopologyDiagramVO> queryAppTopologyDiagram(AppTopologyDiagramQueryParm appTopologyDiagramAuditParm);
+        /** 
+        * @Description: queryTopologyDiagramPage 
+        * @Param: [appTopologyDiagramQueryPageParm] 
+        * @return: com.baomidou.mybatisplus.core.metadata.IPage<com.njcn.advance.pojo.vo.AppTopologyDiagramVO> 
+        * @Author: clam
+        * @Date: 2023/3/29 
+        */ 
+    IPage<AppTopologyDiagramVO> queryTopologyDiagramPage(AppTopologyDiagramQueryPageParm appTopologyDiagramQueryPageParm);
+}
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/AppLineTopologyDiagramServiceImpl.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/AppLineTopologyDiagramServiceImpl.java
@@ -0,0 +1,21 @@
+package com.njcn.algorithm.service.impl;
+
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.algorithm.mapper.AppLineTopologyDiagramMapper;
+import com.njcn.algorithm.pojo.po.AppLineTopologyDiagramPO;
+import com.njcn.algorithm.service.AppLineTopologyDiagramService;
+import org.springframework.stereotype.Service;
+
+/**
+ * 
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/27  10:18【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Service
+public class AppLineTopologyDiagramServiceImpl extends MppServiceImpl<AppLineTopologyDiagramMapper, AppLineTopologyDiagramPO> implements AppLineTopologyDiagramService {
+
+}
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/AppProjectServiceImpl.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/AppProjectServiceImpl.java
@@ -0,0 +1,131 @@
+package com.njcn.algorithm.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.algorithm.enums.AlgorithmResponseEnum;
+import com.njcn.algorithm.mapper.AppProjectMapper;
+import com.njcn.algorithm.pojo.param.*;
+import com.njcn.algorithm.pojo.po.AppProjectPO;
+import com.njcn.algorithm.pojo.vo.AppProjectVO;
+import com.njcn.algorithm.pojo.vo.AppTopologyDiagramVO;
+import com.njcn.algorithm.service.AppProjectService;
+import com.njcn.algorithm.service.AppTopologyDiagramService;
+import com.njcn.common.pojo.exception.BusinessException;
+import com.njcn.oss.utils.FileStorageUtil;
+import lombok.RequiredArgsConstructor;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/27  10:24【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Service
+@RequiredArgsConstructor
+public class AppProjectServiceImpl extends MppServiceImpl<AppProjectMapper, AppProjectPO> implements AppProjectService {
+
+    private final AppProjectMapper appProjectMapper;
+    private final AppTopologyDiagramService appTopologyDiagramService;
+    private final FileStorageUtil fileStorageUtil;
+
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Boolean addAppProject(AppProjectAddParm appProjectAddOrAuditParm) {
+        AppProjectPO appProjectPO = new AppProjectPO ( );
+        Boolean result = checkName (appProjectAddOrAuditParm.getUserId ( ), appProjectAddOrAuditParm.getName ( ));
+        if (result) {
+            throw new BusinessException (AlgorithmResponseEnum.PROJECT_COMMON_ERROR);
+        }
+        BeanUtils.copyProperties (appProjectAddOrAuditParm, appProjectPO);
+        appProjectPO.setStatus ("1");
+        boolean save = this.save (appProjectPO);
+        for (int i = 0; i < appProjectAddOrAuditParm.getFiles ( ).length; i++) {
+
+            AppTopologyDiagramAddParm appTopologyDiagramAddParm = new AppTopologyDiagramAddParm ( );
+            appTopologyDiagramAddParm.setProjectId (appProjectPO.getId ( ));
+            appTopologyDiagramAddParm.setTopologyDiagramName (appProjectAddOrAuditParm.getFiles ( )[i].getOriginalFilename ( ));
+            appTopologyDiagramAddParm.setFile (appProjectAddOrAuditParm.getFiles ( )[i]);
+            appTopologyDiagramService.addAppTopologyDiagram (appTopologyDiagramAddParm);
+        }
+        return save;
+    }
+
+    private Boolean checkName(String userId, String name) {
+        QueryWrapper<AppProjectPO> queryWrapper = new QueryWrapper ( );
+        queryWrapper.select ("1").
+                eq ("status", "1").
+                eq ("user_id", userId).
+                eq ("name", name);
+        Integer integer = appProjectMapper.selectCount (queryWrapper);
+        return integer > 0 ? true : false;
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Boolean AuditAppProject(AppProjectAuditParm appProjectAuditParm) {
+        AppProjectPO appProjectPO = new AppProjectPO ( );
+
+        QueryWrapper<AppProjectPO> queryWrapper = new QueryWrapper ( );
+        queryWrapper.eq ("id", appProjectAuditParm.getId ( ));
+        AppProjectPO appProjectPO1 = appProjectMapper.selectOne (queryWrapper);
+        if (appProjectAuditParm.getUserId ( ) != null || appProjectAuditParm.getName ( ) != null) {
+            Boolean result = checkName (appProjectAuditParm.getUserId ( ) != null ? appProjectAuditParm.getUserId ( ) : appProjectPO1.getUserId ( ),
+                    appProjectAuditParm.getName ( ) != null ? appProjectAuditParm.getName ( ) : appProjectPO1.getName ( ));
+            if (result) {
+                throw new BusinessException (AlgorithmResponseEnum.PROJECT_COMMON_ERROR);
+            }
+        }
+
+        BeanUtils.copyProperties (appProjectAuditParm, appProjectPO);
+        UpdateWrapper<AppProjectPO> updateWrapper = new UpdateWrapper ( );
+        updateWrapper.eq ("id", appProjectAuditParm.getId ( ));
+
+        int i = appProjectMapper.update (appProjectPO, updateWrapper);
+        Boolean result = checkName (appProjectPO.getUserId ( ), appProjectPO.getName ( ));
+        if (result) {
+            throw new BusinessException (AlgorithmResponseEnum.PROJECT_COMMON_ERROR);
+        }
+        return i == 1 ? true : false;
+    }
+
+    @Override
+    public IPage<AppProjectVO> queryProject(AppProjectQueryParm appProjectQueryParm) {
+
+        Page<AppProjectVO> returnpage = new Page<> (appProjectQueryParm.getCurrentPage ( ), appProjectQueryParm.getPageSize ( ));
+        returnpage = appProjectMapper.getPageVo (returnpage, appProjectQueryParm);
+        Page<AppProjectPO> appProjectPOPage = new Page<> (appProjectQueryParm.getCurrentPage ( ), appProjectQueryParm.getPageSize ( ));
+        QueryWrapper<AppProjectPO> queryWrapper = new QueryWrapper ( );
+        queryWrapper.eq ("status", "1").
+                eq (StringUtils.isNotBlank (appProjectQueryParm.getProjectId ( )), "id", appProjectQueryParm.getProjectId ( )).
+                le (StringUtils.isNotBlank (appProjectQueryParm.getEndTime ( )), "create_time", appProjectQueryParm.getEndTime ( )).
+                ge (StringUtils.isNotBlank (appProjectQueryParm.getStartTime ( )), "create_time", appProjectQueryParm.getStartTime ( )).
+                like (StringUtils.isNotBlank (appProjectQueryParm.getSearchValue ( )), "name", appProjectQueryParm.getSearchValue ( ));
+        Page<AppProjectPO> appProjectPOPage1 = appProjectMapper.selectPage (appProjectPOPage, queryWrapper);
+        List<AppProjectVO> collect = appProjectPOPage1.getRecords ( ).stream ( ).map (temp -> {
+                    AppProjectVO vo = new AppProjectVO ( );
+                    BeanUtils.copyProperties (temp, vo);
+                    AppTopologyDiagramQueryParm appTopologyDiagramQueryParm = new AppTopologyDiagramQueryParm ( );
+                    appTopologyDiagramQueryParm.setProjectId (vo.getId ( ));
+                    List<AppTopologyDiagramVO> appTopologyDiagramVOList = appTopologyDiagramService.queryAppTopologyDiagram (appTopologyDiagramQueryParm);
+                    List<String> collect1 = appTopologyDiagramVOList.stream ( ).map (AppTopologyDiagramVO::getFilePath).collect (Collectors.toList ( ));
+                    vo.setTopologyDiagramPaths (collect1);
+                    return vo;
+                }
+
+        ).collect (Collectors.toList ( ));
+        return returnpage;
+    }
+}
--- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/AppTopologyDiagramServiceImpl.java
+++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/service/impl/AppTopologyDiagramServiceImpl.java
@@ -0,0 +1,125 @@
+package com.njcn.algorithm.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.google.common.base.Objects;
+import com.njcn.algorithm.mapper.AppTopologyDiagramMapper;
+import com.njcn.algorithm.pojo.param.AppTopologyDiagramAddParm;
+import com.njcn.algorithm.pojo.param.AppTopologyDiagramAuditParm;
+import com.njcn.algorithm.pojo.param.AppTopologyDiagramQueryPageParm;
+import com.njcn.algorithm.pojo.param.AppTopologyDiagramQueryParm;
+import com.njcn.algorithm.pojo.po.AppTopologyDiagramPO;
+import com.njcn.algorithm.pojo.vo.AppTopologyDiagramVO;
+import com.njcn.algorithm.service.AppTopologyDiagramService;
+import com.njcn.oss.constant.OssPath;
+import com.njcn.oss.utils.FileStorageUtil;
+import lombok.RequiredArgsConstructor;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * 
+ * Description:
+ * 接口文档访问地址：http://serverIP:port/swagger-ui.html
+ * Date: 2023/3/27  10:24【需求编号】d
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Service
+@RequiredArgsConstructor
+public class AppTopologyDiagramServiceImpl extends MppServiceImpl<AppTopologyDiagramMapper, AppTopologyDiagramPO> implements AppTopologyDiagramService {
+
+
+    private final FileStorageUtil fileStorageUtil;
+
+    private final AppTopologyDiagramMapper appTopologyDiagramMapper;
+    @Override
+    @Transactional(rollbackFor = {Exception.class})
+    public Boolean addAppTopologyDiagram(AppTopologyDiagramAddParm appTopologyDiagramAddParm) {
+        AppTopologyDiagramPO appTopologyDiagramPO = new AppTopologyDiagramPO();
+
+        MultipartFile file = appTopologyDiagramAddParm.getFile ( );
+        long size = file.getSize ( );
+        String filePath = fileStorageUtil.uploadMultipart (file, OssPath.TOPOLOGY);
+        appTopologyDiagramPO.setFilePath (filePath);
+        appTopologyDiagramPO.setProjectId (appTopologyDiagramAddParm.getProjectId ()==null?"":appTopologyDiagramAddParm.getProjectId ());
+        appTopologyDiagramPO.setName (appTopologyDiagramAddParm.getTopologyDiagramName ());
+        appTopologyDiagramPO.setFileSize (Integer.valueOf (size+""));
+        appTopologyDiagramPO.setStatus ("1");
+        boolean save = this.save (appTopologyDiagramPO);
+        return save;
+    }
+
+    @Override
+    public Boolean AuditAppTopologyDiagram(AppTopologyDiagramAuditParm appTopologyDiagramAuditParm) {
+        AppTopologyDiagramPO appTopologyDiagramPO = new AppTopologyDiagramPO();
+        if(!Objects.equal (appTopologyDiagramAuditParm.getFile (),null )){
+            MultipartFile file = appTopologyDiagramAuditParm.getFile ( );
+            long size = file.getSize ( );
+            String filePath = fileStorageUtil.uploadMultipart (file, OssPath.TOPOLOGY);
+            appTopologyDiagramPO.setFilePath (filePath);
+            appTopologyDiagramPO.setFileSize (Integer.valueOf (size+""));
+        }
+        if(appTopologyDiagramAuditParm.getProjectId ()!=null&&appTopologyDiagramAuditParm.getProjectId ()!=""){
+            appTopologyDiagramPO.setProjectId (appTopologyDiagramAuditParm.getProjectId ());
+        }
+        if(appTopologyDiagramAuditParm.getTopologyDiagramName ()!=null&&appTopologyDiagramAuditParm.getTopologyDiagramName ()!=""){
+            appTopologyDiagramPO.setName (appTopologyDiagramAuditParm.getTopologyDiagramName ());
+        }
+        if(appTopologyDiagramAuditParm.getStatus ()!=null&&appTopologyDiagramAuditParm.getTopologyDiagramName ()!=""){
+            appTopologyDiagramPO.setStatus (appTopologyDiagramAuditParm.getStatus ());
+        }
+        UpdateWrapper<AppTopologyDiagramPO> updateWrapper = new UpdateWrapper<> ();
+        updateWrapper.eq ("id",appTopologyDiagramAuditParm.getId ());
+        boolean update = this.update (appTopologyDiagramPO, updateWrapper);
+        return update;
+    }
+
+    @Override
+    public List<AppTopologyDiagramVO> queryAppTopologyDiagram(AppTopologyDiagramQueryParm appTopologyDiagramAuditParm) {
+        QueryWrapper<AppTopologyDiagramPO> queryWrapper = new QueryWrapper<> ();
+        queryWrapper.eq ("status","1").
+                eq (StringUtils.isNotBlank (appTopologyDiagramAuditParm.getId ()),"id",appTopologyDiagramAuditParm.getId ()).
+                eq (StringUtils.isNotBlank (appTopologyDiagramAuditParm.getProjectId ()),"project_id",appTopologyDiagramAuditParm.getProjectId ()).
+                like (StringUtils.isNotBlank (appTopologyDiagramAuditParm.getName ()),"name", appTopologyDiagramAuditParm.getName ());
+        List<AppTopologyDiagramPO> list = this.list (queryWrapper);
+        List<AppTopologyDiagramVO> collect = list.stream ( ).map (temp -> {
+            AppTopologyDiagramVO vo = new AppTopologyDiagramVO ( );
+            BeanUtils.copyProperties (temp, vo);
+            vo.setFilePath (fileStorageUtil.getFileUrl (vo.getFilePath ()));
+            return vo;
+        }).collect (Collectors.toList ( ));
+        return collect;
+    }
+
+    @Override
+    public IPage<AppTopologyDiagramVO> queryTopologyDiagramPage(AppTopologyDiagramQueryPageParm appTopologyDiagramQueryPageParm) {
+
+        Page<AppTopologyDiagramVO> returnpage = new Page<> (appTopologyDiagramQueryPageParm.getCurrentPage ( ), appTopologyDiagramQueryPageParm.getPageSize ( ));
+        Page<AppTopologyDiagramPO> tempPage = new Page<> (appTopologyDiagramQueryPageParm.getCurrentPage ( ), appTopologyDiagramQueryPageParm.getPageSize ( ));
+
+        QueryWrapper<AppTopologyDiagramPO> queryWrapper = new QueryWrapper<> ();
+        queryWrapper.eq ("status","1").
+                eq (StringUtils.isNotBlank (appTopologyDiagramQueryPageParm.getProjectId ()),"project_id",appTopologyDiagramQueryPageParm.getProjectId ()).
+                like (StringUtils.isNotBlank (appTopologyDiagramQueryPageParm.getSearchValue ()),"name", appTopologyDiagramQueryPageParm.getSearchValue ());
+        tempPage = appTopologyDiagramMapper.selectPage (tempPage, queryWrapper);
+        List<AppTopologyDiagramVO> collect = tempPage.getRecords ( ).stream ( ).map (temp -> {
+            AppTopologyDiagramVO vo = new AppTopologyDiagramVO ( );
+            BeanUtils.copyProperties (temp, vo);
+            vo.setFilePath (fileStorageUtil.getFileUrl (temp.getFilePath ( )));
+            return vo;
+        }).collect (Collectors.toList ( ));
+        returnpage.setRecords (collect);
+        return returnpage;
+    }
+}
--- a/pqs-algorithm/algorithm-boot/src/main/resources/bootstrap.yml
+++ b/pqs-algorithm/algorithm-boot/src/main/resources/bootstrap.yml
@@ -0,0 +1,53 @@
+#当前服务的基本信息
+microservice:
+  ename: @artifactId@
+  name: '@name@'
+  version: @version@
+  sentinel:
+    url: @sentinel.url@
+  gateway:
+    url: @gateway.url@
+server:
+  port: 10210
+#feign接口开启服务熔断降级处理
+feign:
+  sentinel:
+    enabled: true
+
+spring:
+  application:
+    name: @artifactId@
+  #nacos注册中心以及配置中心的指定
+  cloud:
+    nacos:
+      discovery:
+        ip: @service.server.url@
+        server-addr: @nacos.url@
+        namespace: @nacos.namespace@
+      config:
+        server-addr: @nacos.url@
+        namespace: @nacos.namespace@
+        file-extension: yaml
+        shared-configs:
+          - data-id: share-config.yaml
+            refresh: true
+          - data-Id: share-config-datasource-db.yaml
+            refresh: true
+  main:
+    allow-bean-definition-overriding: true
+
+
+#项目日志的配置
+logging:
+  config: http://@nacos.url@/nacos/v1/cs/configs?tenant=@nacos.namespace@&group=DEFAULT_GROUP&dataId=logback.xml
+  level:
+    root: info
+
+
+#mybatis配置信息
+mybatis-plus:
+  #别名扫描
+  type-aliases-package: com.njcn.algorithm.pojo
+
+mqtt:
+  client-id: @artifactId@${random.value}
--- a/pqs-algorithm/algorithm-boot/src/main/resources/qvvr_balance.dll
+++ b/pqs-algorithm/algorithm-boot/src/main/resources/qvvr_balance.dll
--- a/pqs-algorithm/algorithm-boot/src/main/resources/qvvr_dll.dll
+++ b/pqs-algorithm/algorithm-boot/src/main/resources/qvvr_dll.dll
--- a/pqs-algorithm/algorithm-boot/src/main/resources/qvvr_dll_cause.dll
+++ b/pqs-algorithm/algorithm-boot/src/main/resources/qvvr_dll_cause.dll
--- a/pqs-algorithm/algorithm-boot/src/main/resources/sql20230227dll.sql
+++ b/pqs-algorithm/algorithm-boot/src/main/resources/sql20230227dll.sql
@@ -0,0 +1,46 @@
+DROP TABLE IF EXISTS `app_project`;
+CREATE TABLE `app_project` (
+                               `id` varchar(36) NOT NULL COMMENT '项目Id',
+                               `name` varchar(200) NOT NULL COMMENT '项目名称',
+                               `user_id` varchar(100) NOT NULL COMMENT '关联用户Id',
+                               `area_id` varchar(100) NOT NULL COMMENT '地市Id',
+                               `lng` decimal(10,6)  NULL COMMENT '中心点经度',
+                               `lat` decimal(10,6)  NULL COMMENT '中心点纬度',
+                               `status` tinyint(1) NOT NULL COMMENT '0：删除 1：正常',
+                               `create_by` char(32)  NULL COMMENT '创建用户',
+                               `create_time` datetime NOT NULL COMMENT '创建时间',
+                               `update_by` char(32)  NULL COMMENT '更新用户',
+                               `update_time` datetime  NULL COMMENT '更新时间',
+                               PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='项目表';
+
+
+
+DROP TABLE IF EXISTS `app_topology_diagram`;
+CREATE TABLE `app_topology_diagram` (
+                                        `id` varchar(36) Not NULL COMMENT '拓扑图Id' ,
+                                        `name` varchar(200) Not NULL COMMENT '拓扑图名称' ,
+                                        `file_size` int Not NULL COMMENT '文件大小(kb)' ,
+                                        `project_id` varchar(36) NULL COMMENT '项目Id' ,
+                                        `file_path` varchar(200) Not NULL COMMENT '拓扑图文件路径' ,
+                                        `status` tinyint(1) NOT NULL COMMENT '0：删除 1：正常',
+                                        `create_by` char(32)  NULL COMMENT '创建用户',
+                                        `create_time` datetime NOT NULL COMMENT '创建时间',
+                                        `update_by` char(32)  NULL COMMENT '更新用户',
+                                        `update_time` datetime  NULL COMMENT '更新时间',
+                                        PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='项目拓扑图关系表';
+
+DROP TABLE IF EXISTS `app_line_topology_diagram`;
+CREATE TABLE `app_line_topology_diagram` (
+                                             `id` varchar(36) Not NULL COMMENT '拓扑图Id' ,
+                                             `line_id` varchar(200) Not NULL COMMENT '拓扑图名称' ,
+                                             `status` tinyint(1) NOT NULL COMMENT '0：删除 1：正常',
+                                             `create_by` char(32)  NULL COMMENT '创建用户',
+                                             `create_time` datetime NOT NULL COMMENT '创建时间',
+                                             `update_by` char(32)  NULL COMMENT '更新用户',
+                                             `update_time` datetime  NULL COMMENT '更新时间',
+                                             PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='项目拓扑图关系表';
+
+