代码调整

pqs-prepare/prepare-boot/pom.xml

@@ -29,6 +29,11 @@
             <artifactId>common-core</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>com.njcn</groupId>
+            <artifactId>process-api</artifactId>
+            <version>${project.version}</version>
+        </dependency>
         <dependency>
             <groupId>com.njcn</groupId>
             <artifactId>harmonic-api</artifactId>
@@ -117,7 +122,6 @@
         </dependency>
 
 
-
         <dependency>
             <groupId>com.squareup.okhttp3</groupId>
             <artifactId>okhttp</artifactId>

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/PrepareApplication.java

@@ -17,10 +17,10 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
 @EnableFeignClients(basePackages = "com.njcn")
 @SpringBootApplication(scanBasePackages = "com.njcn")
 @EnableMPP
-public class PrepareHarmonicApplication {
+public class PrepareApplication {
 
     public static void main(String[] args) {
-        SpringApplication.run(PrepareHarmonicApplication.class,args);
+        SpringApplication.run(PrepareApplication.class,args);
     }
 
 }

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/process/PmsTerminalDetectionMapper.java

@@ -0,0 +1,21 @@
+package com.njcn.prepare.harmonic.mapper.mysql.process;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njcn.process.pojo.param.TerminalParam;
+import com.njcn.process.pojo.po.PmsTerminalDetection;
+import com.njcn.process.pojo.vo.TerminalVO;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author wr
+ * @since 2023-02-27
+ */
+public interface PmsTerminalDetectionMapper extends BaseMapper<PmsTerminalDetection> {
+
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/process/mapping/PmsTerminalDetectionMapper.xml

@@ -0,0 +1,7 @@
+<?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.process.mapper.PmsTerminalDetectionMapper">
+
+
+
+</mapper>

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/RMpPassRateDServiceImpl.java

@@ -1,10 +1,14 @@
 package com.njcn.prepare.harmonic.service.mysql.Impl.line;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
 import com.njcn.prepare.harmonic.mapper.mysql.line.RMpPassRateDMapper;
 import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpPassRateDPO;
 import com.njcn.prepare.harmonic.service.mysql.line.RMpPassRateDService;
 import org.springframework.stereotype.Service;
+
+import java.util.List;
+
 /**
  * 
  * Description:
@@ -17,4 +21,10 @@ import org.springframework.stereotype.Service;
 @Service
 public class RMpPassRateDServiceImpl extends MppServiceImpl<RMpPassRateDMapper, RMpPassRateDPO> implements RMpPassRateDService{
 
+
+    @DS("process")
+    @Override
+    public List<RMpPassRateDPO> getAll() {
+        return this.list();
+    }
 }

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/RMpPassRateDService.java

@@ -2,6 +2,9 @@ package com.njcn.prepare.harmonic.service.mysql.line;
 
 import com.github.jeffreyning.mybatisplus.service.IMppService;
 import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpPassRateDPO;
+
+import java.util.List;
+
 /**
  * 
  * Description:
@@ -13,5 +16,5 @@ import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpPassRateDPO;
  */
 public interface RMpPassRateDService extends IMppService<RMpPassRateDPO> {
 
-
+    List<RMpPassRateDPO> getAll();
 }

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/process/PmsTerminalDetectionService.java

@@ -0,0 +1,23 @@
+package com.njcn.prepare.harmonic.service.mysql.process;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.process.pojo.param.TerminalParam;
+import com.njcn.process.pojo.po.PmsTerminalDetection;
+import com.njcn.process.pojo.vo.TerminalVO;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+
+/**
+ * <p>
+ *  终端检测监督
+ * </p>
+ *
+ * @author wr
+ * @since 2023-02-27
+ */
+public interface PmsTerminalDetectionService extends IService<PmsTerminalDetection> {
+
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/process/impl/PmsTerminalDetectionServiceImpl.java

@@ -0,0 +1,25 @@
+package com.njcn.prepare.harmonic.service.mysql.process.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.process.PmsTerminalDetectionMapper;
+import com.njcn.prepare.harmonic.service.mysql.process.PmsTerminalDetectionService;
+import com.njcn.process.pojo.po.PmsTerminalDetection;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 终端检测监督
+ * </p>
+ *
+ * @author wr
+ * @since 2023-02-27
+ */
+@Service
+@RequiredArgsConstructor
+@DS("process")
+public class PmsTerminalDetectionServiceImpl extends ServiceImpl<PmsTerminalDetectionMapper, PmsTerminalDetection> implements PmsTerminalDetectionService {
+
+
+}

pqs-prepare/prepare-boot/src/test/java/com/njcn/BaseJunitTest.java

@@ -0,0 +1,19 @@
+package com.njcn;
+
+import com.njcn.prepare.PrepareApplication;
+import org.junit.runner.RunWith;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+import org.springframework.test.context.web.WebAppConfiguration;
+
+/**
+ * @author hongawen
+ * @version 1.0.0
+ * @date 2021年12月10日 15:05
+ */
+@RunWith(SpringRunner.class)
+@WebAppConfiguration
+@SpringBootTest(classes = PrepareApplication.class)
+public class BaseJunitTest {
+
+}

pqs-prepare/prepare-boot/src/test/java/com/njcn/DemoTest.java

@@ -0,0 +1,42 @@
+package com.njcn;
+
+import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpPassRateDPO;
+import com.njcn.prepare.harmonic.service.mysql.line.RMpPassRateDService;
+import com.njcn.prepare.harmonic.service.mysql.process.PmsTerminalDetectionService;
+import com.njcn.process.pojo.po.PmsTerminalDetection;
+import lombok.SneakyThrows;
+import org.junit.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.List;
+
+/**
+ * @author hongawen
+ * @version 1.0.0
+ * @date 2021年12月14日 12:55
+ */
+public class DemoTest extends BaseJunitTest {
+
+    @Autowired
+    private RMpPassRateDService rMpPassRateDService;
+
+    @Autowired
+    private PmsTerminalDetectionService pmsTerminalDetectionService;
+
+
+    @SneakyThrows
+    @Test
+    public void test() {
+        //查询pms库
+        List<RMpPassRateDPO> list1 = rMpPassRateDService.list();
+
+        //测试方法注解技术监督库
+        List<RMpPassRateDPO> list2 = rMpPassRateDService.getAll();
+
+        //测试service类注解技术监督库
+        List<PmsTerminalDetection> list = pmsTerminalDetectionService.list();
+        System.out.println("hello");
+
+    }
+
+}