Merge branch 'dongdingding' of http://39.101.188.84:7000/suzhou-jichuang-lanhai/zhiyuanzheJava

# Conflicts:
#	ruoyi-admin/src/main/java/com/ruoyi/zhiyuanzhe/quartz/VolunteerQuartz.java
#	ruoyi-admin/src/main/java/com/ruoyi/zhiyuanzhe/service/impl/BDistributionRecordsServiceImpl.java

ruoyi-admin/src/main/java/com/ruoyi/zhiyuanzhe/quartz/VolunteerQuartz.java

@@ -21,7 +21,7 @@ import javax.annotation.Resource;
 public class VolunteerQuartz {
     @Resource
     private IBDistributionRecordsService bDistributionRecordsService;
-    @Scheduled(cron = "0 0 3 * * ?")
+    @Scheduled(cron = "0 0 4 * * ?")
     public void volunteer() {
         bDistributionRecordsService.volunteer();
 

ruoyi-admin/src/main/java/com/ruoyi/zhiyuanzhe/service/impl/BDistributionRecordsServiceImpl.java

@@ -33,10 +33,20 @@ import com.ruoyi.zhiyuanzhe.service.IBDistributionRecordsService;
 import com.ruoyi.zhiyuanzhe.service.IBPersonTagsService;
 import com.ruoyi.zhiyuanzhe.utils.PushDataUtil;
 import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
 
 
 /**
@@ -321,44 +331,66 @@ public class BDistributionRecordsServiceImpl implements IBDistributionRecordsSer
     }
 
     public void processVolunteers(List<VolunteerDTO> volunteerDTOS) {
-        int a = 0;
+
+        // 创建一个固定大小的线程池，线程数根据实际情况进行配置
+        ExecutorService executorService = Executors.newFixedThreadPool(20);
+        List<Future<?>> futures = new ArrayList<>();
+
         List<SysUser> userList = new ArrayList<>();
         List<BPersonTags> tagsList = new ArrayList<>();
 
         for (VolunteerDTO dto : volunteerDTOS) {
-
-            // 创建用户
-            SysUser sysUser = new SysUser();
-            // 创建人员标签
-            BPersonTags tags = new BPersonTags();
-            // 填充用户信息
-            sysUser.setNickName(dto.getName());
-            sysUser.setUserName(dto.getPhone());
-            // 加密密码
-            sysUser.setPassword(SecurityUtils.encryptPassword("123456"));
-            sysUser.setStatus("0");
-            sysUser.setDelFlag("0");
-            sysUser.setSex("2");
-            sysUser.setRoleId(101L);
-            sysUser.setUserId(Long.valueOf(dto.getPhone()));
-            // 标记为导出数据
-            sysUser.setRemark("1");
-            userList.add(sysUser);
-            // 填充人员标签
-            tags.setUId(Long.valueOf(dto.getPhone()));
-            tags.setNationalityRange(dto.getCountryText());
-            tags.setProfessionalRange(dto.getSkillText());
-            tags.setIndustryRange(dto.getIndustryCateText());
-            tags.setEducationRange(dto.getEducationText());
-            // 标记为导出数据
-            tags.setRemark("1");
-            tagsList.add(tags);
-
-            a = a + 1;
-            System.out.println("测试" + a);
+            // 创建一个Runnable任务
+            Runnable task = () -> {
+                // 创建用户
+                SysUser sysUser = new SysUser();
+                // 创建人员标签
+                BPersonTags tags = new BPersonTags();
+                // 填充用户信息
+                sysUser.setNickName(dto.getName());
+                sysUser.setUserName(dto.getPhone());
+                // 加密密码
+                sysUser.setPassword(SecurityUtils.encryptPassword("123456"));
+                sysUser.setStatus("0");
+                sysUser.setDelFlag("0");
+                sysUser.setSex("2");
+                sysUser.setRoleId(101L);
+                String phone = dto.getPhone();
+                Pattern pattern = Pattern.compile("\\D"); // 匹配所有非数字字符
+                Matcher matcher = pattern.matcher(phone);
+                String result = matcher.replaceAll("");
+                if (!result.isEmpty()) {
+                    long userId = Long.parseLong(result);
+                    sysUser.setUserId(userId);
+                }
+                // 标记为导出数据
+                sysUser.setRemark("1");
+                userList.add(sysUser);
+                // 填充人员标签
+                tags.setUId(Long.valueOf(dto.getPhone()));
+                tags.setNationalityRange(dto.getCountryText());
+                tags.setProfessionalRange(dto.getSkillText());
+                tags.setIndustryRange(dto.getIndustryCateText());
+                tags.setEducationRange(dto.getEducationText());
+                // 标记为导出数据
+                tags.setRemark("1");
+                tagsList.add(tags);
+            };
+
+            // 提交任务给线程池并获取Future对象
+            Future<?> future = executorService.submit(task);
+            futures.add(future);
         }
-        ;
 
+        // 等待所有任务执行完成
+        for (Future<?> future : futures) {
+            try {
+                future.get();
+            } catch (InterruptedException | ExecutionException e) {
+                // 处理异常
+                e.printStackTrace();
+            }
+        }
 
         // 所有任务执行完成后执行批量保存操作
         if (CollectionUtil.isNotEmpty(userList)) {
@@ -370,17 +402,18 @@ public class BDistributionRecordsServiceImpl implements IBDistributionRecordsSer
             personTagsService.addAll(tagsList);
         }
 
+        // 关闭线程池
+        executorService.shutdown();
     }
 
     /**
      * 同步志愿者数据
      */
     @Override
-    @Transactional(rollbackFor = Exception.class)
     public void volunteer() {
         // 删除所有导入的用户以及标签
-//        sysUserService.delByRemark();
-//        personTagsService.delByRemark();
+        sysUserService.delByRemark();
+        personTagsService.delByRemark();
         // 将字符串日期转换为Date对象
         Date startTime = DateUtil.parse("2012-01-01 00:00:00");
         Date localTime = new Date();

ruoyi-admin/src/main/resources/application-dev.yml

@@ -24,7 +24,7 @@ spring:
       master:
         url: jdbc:mysql://localhost:3306/zhi_yuan_zhe?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
         username: root
-        password: 123456
+        password: adminadmin
       # 从库数据源
       slave:
         # 从数据源开关/默认关闭