Merge branch 'feature-2023-05' into 'developer'

feat: 测试用例

See merge request !111

gic-cloud-data-hook-api/src/main/java/com/gic/cloud/data/hook/api/service/IFreeQueryService.java

 package com.gic.cloud.data.hook.api.service;
 
+import com.gic.api.base.commons.ServiceResponse;
 import com.gic.cloud.data.hook.api.dto.*;
 
 import java.util.List;
@@ -87,4 +88,10 @@ public interface IFreeQueryService {
 	List<String> listFilterPhoneAndCardNoCardNumField();
 
 	List<String> listFilterUserName();
+
+
+	/**
+	 * 刷新所有应用相关缓存
+	 */
+	public ServiceResponse<String> testCacheDb(String taskId,String taskId2);
 }

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

 package com.gic.cloud.data.hook.service.impl;
 
+import cn.hutool.core.date.StopWatch;
 import cn.medubi.client.utils.LogPak;
 import com.alibaba.fastjson.JSON;
 import com.ctrip.framework.apollo.Config;
 import com.ctrip.framework.apollo.ConfigService;
+import com.gic.api.base.commons.ServiceResponse;
 import com.gic.cloud.data.hook.api.dto.*;
 import com.gic.cloud.data.hook.api.dto.DataDesensiType;
 import com.gic.cloud.data.hook.api.entity.*;
 import com.gic.cloud.data.hook.api.service.IDownloadTaskService;
 import com.gic.cloud.data.hook.api.service.IFreeQueryService;
 import com.gic.cloud.data.hook.service.*;
+import com.gic.cloud.data.hook.service.dao.DownloadTaskDao;
 import com.gic.cloud.data.hook.service.dao.FreeQueryRecordDao;
 import com.gic.cloud.data.hook.service.dao.FreeQuerySourceDao;
 import com.gic.cloud.data.hook.service.entity.CsvDataFilterMode;
@@ -32,6 +35,8 @@ import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.lang3.concurrent.BasicThreadFactory;
 import org.apache.poi.ss.usermodel.*;
 import org.apache.poi.xssf.streaming.SXSSFWorkbook;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;
@@ -54,6 +59,8 @@ import java.util.zip.ZipOutputStream;
  */
 public class FreeQueryServiceImpl implements IFreeQueryService {
 
+	private static Logger logger = LoggerFactory.getLogger(FreeQueryServiceImpl.class);
+
 	/** 日志类 */
 	private static LogPak log = new LogPak(FreeQueryServiceImpl.class);
 
@@ -62,6 +69,8 @@ public class FreeQueryServiceImpl implements IFreeQueryService {
 	/** csv / xls 下载目录 */
 	public static final String SAVE_FOLDER = "/usr/local/data-hook-file";
 
+	@Autowired
+	private DownloadTaskDao downloadTaskDao;
 
 	@Autowired
 	IDownloadTaskService downloadTaskService;
@@ -384,6 +393,74 @@ public class FreeQueryServiceImpl implements IFreeQueryService {
 		return FilterFieldUtils.FILETERS_USER_NAME;
 	}
 
+	@Override
+	public ServiceResponse<String> testCacheDb(String taskId,String taskId2) {
+		StopWatch stopWatch = new StopWatch();
+
+		stopWatch.start();
+		DownloadTask downloadTask = downloadTaskDao.getDownloadTaskById(taskId);
+		stopWatch.stop();
+		logger.info("时间-1：{}",stopWatch.getLastTaskTimeMillis());
+
+		stopWatch.start();
+		downloadTask = downloadTaskDao.getDownloadTaskById(taskId);
+		stopWatch.stop();
+		logger.info("时间-1-1：{}",stopWatch.getLastTaskTimeMillis());
+
+		stopWatch.start();
+		downloadTask = downloadTaskDao.getDownloadTaskById(taskId2);
+		stopWatch.stop();
+		logger.info("时间-2：{}",stopWatch.getLastTaskTimeMillis());
+
+		stopWatch.start();
+		downloadTask = downloadTaskDao.getDownloadTaskById(taskId2);
+		stopWatch.stop();
+		logger.info("时间-2-1：{}",stopWatch.getLastTaskTimeMillis());
+
+
+		stopWatch.start();
+		downloadTask = downloadTaskDao.getDownloadTaskById(taskId);
+		stopWatch.stop();
+		logger.info("时间-1-2：{}",stopWatch.getLastTaskTimeMillis());
+
+
+
+		stopWatch.start();
+		downloadTask.setOverTime(new Date());
+		downloadTaskDao.updateDownloadTask(downloadTask);
+		stopWatch.stop();
+		logger.info("时间-update：{}",stopWatch.getLastTaskTimeMillis());
+
+		stopWatch.start();
+		downloadTask = downloadTaskDao.getDownloadTaskById(taskId);
+		stopWatch.stop();
+		logger.info("时间-3：{}",stopWatch.getLastTaskTimeMillis());
+
+		stopWatch.start();
+		downloadTask = downloadTaskDao.getDownloadTaskById(taskId);
+		stopWatch.stop();
+		logger.info("时间-4：{}",stopWatch.getLastTaskTimeMillis());
+
+		stopWatch.start();
+		downloadTask = downloadTaskDao.getDownloadTaskById(taskId2);
+		stopWatch.stop();
+		logger.info("时间-5：{}",stopWatch.getLastTaskTimeMillis());
+
+
+
+		stopWatch.start();
+		downloadTask = downloadTaskDao.getDownloadTaskById(taskId2);
+		stopWatch.stop();
+		logger.info("时间-6：{}",stopWatch.getLastTaskTimeMillis());
+
+		stopWatch.start();
+		downloadTask = downloadTaskDao.getDownloadTaskById(taskId);
+		stopWatch.stop();
+		logger.info("时间-end：{}",stopWatch.getLastTaskTimeMillis());
+
+		return ServiceResponse.success();
+	}
+
 	private static SimpleDateFormat datetimeFormatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
 
 	private static SimpleDateFormat dateFormatter = new SimpleDateFormat("yyyy-MM-dd");

gic-cloud-data-hook-service/src/test/java/com/gic/Test2.java

@@ -11,8 +11,8 @@ public class Test2 {
 
     @Test
     public void test(){
-       String str="微信开卡/pos开卡/微盟开卡";
-       Integer id=47;
+       String str="卡券投放/图文消息嵌入/ECM智能引擎/门店展架/自定义展架/积分兑换/线上游戏/成就奖励/任务奖励/第三方发券/其他/小程序自定义页面领取卡券/裂变纺发券/微盟发券/好办聊天/好办扫码/好办分享有礼/好办内购券/卡券转赠/兑换码/新版游戏";
+       Integer id=13;
         String[] split = str.split("/");
         for (String s : split) {
             if (StringUtils.isEmpty(s)){

gic-cloud-data-hook/src/main/java/com/gic/cloud/data/hook/web/FreeQueryController.java

 package com.gic.cloud.data.hook.web;
 
 import com.alibaba.fastjson.JSON;
+import com.gic.api.base.commons.ServiceResponse;
 import com.gic.clerk.api.dto.AuthorizedUser;
 import com.gic.cloud.common.api.base.Page;
 import com.gic.cloud.data.hook.api.dto.*;
@@ -245,5 +246,18 @@ public class FreeQueryController {
 		return freeQuerySource;
 	}
 
+	/**
+	 * 测试
+	 * @param a
+	 * @param b
+	 * @return
+	 */
+	@RequestMapping("/get-db-cache")
+	public FreeQuerySource cache(String a,String b){
+		ServiceResponse<String> stringServiceResponse = this.freeQueryService.testCacheDb(a, b);
+		System.out.println(JSON.toJSONString(stringServiceResponse));
+		return new FreeQuerySource();
+	}
+
 
 }