feat: 测试用例

gic-cloud-data-hook-api/.flattened-pom.xml

@@ -4,12 +4,12 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.gic</groupId>
   <artifactId>gic-cloud-data-hook-api</artifactId>
-  <version>3.0-SNAPSHOT</version>
+  <version>2.45</version>
   <dependencies>
     <dependency>
       <groupId>com.gic</groupId>
       <artifactId>gic-cloud-web-service-api</artifactId>
-      <version>3.0-SNAPSHOT</version>
+      <version>3.80</version>
       <scope>compile</scope>
       <exclusions>
         <exclusion>
@@ -25,7 +25,7 @@
     <dependency>
       <groupId>com.gic</groupId>
       <artifactId>gic-cloud-commons</artifactId>
-      <version>3.0-SNAPSHOT</version>
+      <version>3.64</version>
       <scope>compile</scope>
       <exclusions>
         <exclusion>
@@ -41,7 +41,7 @@
     <dependency>
       <groupId>com.gic</groupId>
       <artifactId>gic-platform-config</artifactId>
-      <version>3.0-SNAPSHOT</version>
+      <version>2.29</version>
       <scope>compile</scope>
     </dependency>
     <dependency>

gic-cloud-data-hook-service/src/main/java/com/gic/cloud/data/hook/service/dao/DownloadTaskDao.java

@@ -81,4 +81,9 @@ public interface DownloadTaskDao {
 	 */
 	public List<DownloadTask> getDownloadTaskOfBuilding(@Param("queryDataSource") String queryDataSource);
 
+	/** 获取等待申请通过状态的任务
+	 * @return
+	 */
+	public List<DownloadTask> getDownloadTaskTest(@Param("from") Integer from , @Param("to") Integer to);
+
 }

gic-cloud-data-hook-service/src/main/java/com/gic/cloud/data/hook/service/impl/FreeQueryServiceImpl.java

@@ -397,64 +397,67 @@ public class FreeQueryServiceImpl implements IFreeQueryService {
 	public ServiceResponse<String> testCacheDb(String taskId,String taskId2) {
 		StopWatch stopWatch = new StopWatch();
 
+		String[] split = taskId.split("-");
+		String[] split2 = taskId2.split("-");
+
 		stopWatch.start();
-		DownloadTask downloadTask = downloadTaskDao.getDownloadTaskById(taskId);
+		List<DownloadTask> downloadTask = downloadTaskDao.getDownloadTaskTest(Integer.valueOf(split[0]), Integer.valueOf(split[1]));
 		stopWatch.stop();
 		logger.info("时间-1：{}",stopWatch.getLastTaskTimeMillis());
 
 		stopWatch.start();
-		downloadTask = downloadTaskDao.getDownloadTaskById(taskId);
+		downloadTask = downloadTask = downloadTaskDao.getDownloadTaskTest(Integer.valueOf(split[0]), Integer.valueOf(split[1]));
 		stopWatch.stop();
 		logger.info("时间-1-1：{}",stopWatch.getLastTaskTimeMillis());
 
 		stopWatch.start();
-		downloadTask = downloadTaskDao.getDownloadTaskById(taskId2);
+		downloadTask = downloadTask = downloadTaskDao.getDownloadTaskTest(Integer.valueOf(split2[0]), Integer.valueOf(split2[1]));
 		stopWatch.stop();
 		logger.info("时间-2：{}",stopWatch.getLastTaskTimeMillis());
 
 		stopWatch.start();
-		downloadTask = downloadTaskDao.getDownloadTaskById(taskId2);
+		downloadTask = downloadTaskDao.getDownloadTaskTest(Integer.valueOf(split2[0]), Integer.valueOf(split2[1]));
 		stopWatch.stop();
 		logger.info("时间-2-1：{}",stopWatch.getLastTaskTimeMillis());
 
 
 		stopWatch.start();
-		downloadTask = downloadTaskDao.getDownloadTaskById(taskId);
+		DownloadTask downloadTaskById = downloadTaskDao.getDownloadTaskById(downloadTask.get(0).getId());
 		stopWatch.stop();
 		logger.info("时间-1-2：{}",stopWatch.getLastTaskTimeMillis());
 
 
 
 		stopWatch.start();
-		downloadTask.setOverTime(new Date());
-		downloadTaskDao.updateDownloadTask(downloadTask);
+		downloadTaskById.setOverTime(new Date());
+		downloadTaskDao.updateDownloadTask(downloadTaskById);
 		stopWatch.stop();
 		logger.info("时间-update：{}",stopWatch.getLastTaskTimeMillis());
 
 		stopWatch.start();
-		downloadTask = downloadTaskDao.getDownloadTaskById(taskId);
+		downloadTask = downloadTaskDao.getDownloadTaskTest(Integer.valueOf(split[0]), Integer.valueOf(split[1]));
 		stopWatch.stop();
 		logger.info("时间-3：{}",stopWatch.getLastTaskTimeMillis());
 
 		stopWatch.start();
-		downloadTask = downloadTaskDao.getDownloadTaskById(taskId);
+		downloadTask = downloadTaskDao.getDownloadTaskTest(Integer.valueOf(split[0]), Integer.valueOf(split[1]));
 		stopWatch.stop();
 		logger.info("时间-4：{}",stopWatch.getLastTaskTimeMillis());
 
 		stopWatch.start();
-		downloadTask = downloadTaskDao.getDownloadTaskById(taskId2);
+		downloadTask = downloadTaskDao.getDownloadTaskTest(Integer.valueOf(split2[0]), Integer.valueOf(split2[1]));
 		stopWatch.stop();
 		logger.info("时间-5：{}",stopWatch.getLastTaskTimeMillis());
 
 
 
 		stopWatch.start();
-		downloadTask = downloadTaskDao.getDownloadTaskById(taskId2);
+		downloadTask = downloadTaskDao.getDownloadTaskTest(Integer.valueOf(split2[0]), Integer.valueOf(split2[1]));
 		stopWatch.stop();
 		logger.info("时间-6：{}",stopWatch.getLastTaskTimeMillis());
 
 		stopWatch.start();
-		downloadTask = downloadTaskDao.getDownloadTaskById(taskId);
+		downloadTask = downloadTaskDao.getDownloadTaskTest(Integer.valueOf(split[0]), Integer.valueOf(split[1]));
 		stopWatch.stop();
 		logger.info("时间-end：{}",stopWatch.getLastTaskTimeMillis());
 

gic-cloud-data-hook-service/src/main/resources/mapper/DownloadTaskDao.xml

@@ -244,4 +244,13 @@
 		order by start_time asc
 	</select>
 
+	<select id="getDownloadTaskTest" resultType="DownloadTask">
+		SELECT *
+		FROM
+		<include refid="queryTables"/>
+		<include refid="queryJoins"/>
+		WHERE
+		BETWEEN #{from} AND #{to} LIMIT 10
+	</select>
+
 </mapper>
\ No newline at end of file