修改参数

ad-platform-common/ad-platform-common-auth/src/main/java/com/baiye/util/MobileUtil.java

@@ -51,9 +51,7 @@ public class MobileUtil {
     public static boolean checkChinaMobile(String phone) {
         if (StringUtils.isNotBlank(phone)) {
             Pattern regexp = Pattern.compile(CHINA_MOBILE_PATTERN);
-            if (regexp.matcher(phone).matches()) {
-                return true;
-            }
+            return regexp.matcher(phone).matches();
         }
         return false;
     }
@@ -68,9 +66,7 @@ public class MobileUtil {
     public static boolean checkChinaUnicom(String phone) {
         if (StringUtils.isNotBlank(phone)) {
             Pattern regexp = Pattern.compile(CHINA_UNICOM_PATTERN);
-            if (regexp.matcher(phone).matches()) {
-                return true;
-            }
+            return regexp.matcher(phone).matches();
         }
         return false;
     }
@@ -85,9 +81,7 @@ public class MobileUtil {
     public static boolean checkChinaTelecom(String phone) {
         if (StringUtils.isNotBlank(phone)) {
             Pattern regexp = Pattern.compile(CHINA_TELECOM_PATTERN);
-            if (regexp.matcher(phone).matches()) {
-                return true;
-            }
+            return regexp.matcher(phone).matches();
         }
         return false;
     }

manage/ad-platform-management/src/main/java/com/baiye/util/CSVFileUtil.java

@@ -69,7 +69,7 @@ public class CSVFileUtil {
         // 去除重复
         List<String> phoneSets = Lists.newArrayList(Sets.newHashSet(phoneList));
 
-        File csvFile = new File("C:\\Users\\a\\Desktop\\11-24-dmp.csv");
+        File csvFile = new File("C:\\Users\\a\\Desktop\\12-1.csv");
         //导入HuTool中CSV工具包的CsvWriter类
         //设置导出字符类型, CHARSET_UTF_8
         CsvWriter writer = CsvUtil.getWriter(csvFile, CharsetUtil.CHARSET_UTF_8);

services/ad-platform-source/src/main/java/com/baiye/task/MailSourceTask.java

@@ -16,6 +16,7 @@ import com.baiye.constant.DefaultNumberConstants;
 import com.baiye.exception.BadRequestException;
 import com.baiye.feign.DownRecordClient;
 import com.baiye.feign.TaskClient;
+import com.baiye.module.dao.ClueTalkRepository;
 import com.baiye.module.entity.DeliveryRecord;
 import com.baiye.module.entity.Task;
 import com.baiye.module.service.ClueService;
@@ -62,6 +63,8 @@ public class MailSourceTask {
 
     private final ClueService clueService;
 
+    private final ClueTalkRepository clueTalkRepository;
+
     private final DownRecordClient downRecordClient;
 
     private final DeliveryProperties deliveryProperties;
@@ -142,7 +145,7 @@ public class MailSourceTask {
                                         clueService.saveClue(tagList, decryptList, byTaskName.getTaskId(),
                                                 byTaskName.getUserId(), DefaultNumberConstants.FOUR_NUMBER);
                                         // 修改任务总条数
-                                        Integer taskNum = clueService.findTaskNum(taskId);
+                                        Integer taskNum = clueTalkRepository.findTaskNum(taskId);
                                         task.setId(taskId);
                                         task.setTotalNumber(taskNum);
                                         task.setIsDistribution(DefaultNumberConstants.ONE_NUMBER);