浏览代码

feat:增加分红缺失邮件发送功能

chenjianhua 1 月之前
父节点
当前提交
7a4ada537f

+ 12 - 0
service-manage/src/main/java/com/simuwang/manage/api/company/CompanyContactInformationController.java

@@ -139,6 +139,18 @@ public class CompanyContactInformationController{
     }
     }
 
 
     /**
     /**
+     * 根据companyIdList发送数据缺失邮件
+     * @param idListVO  已选行的companyIdList
+     * @return
+     */
+    @SystemLog(value = "发送缺失数据")
+    @PostMapping("send-distribute-email")
+    public boolean sendDistributeEmail(@RequestBody IdListVO idListVO){
+        companyEmailConfigService.sendDistributeEmailById(idListVO.getIdList());
+        return true;
+    }
+
+    /**
      * 上传联系人信息
      * 上传联系人信息
      *
      *
      * @param file
      * @param file

+ 3 - 1
service-manage/src/main/java/com/simuwang/manage/service/CompanyEmailConfigService.java

@@ -24,5 +24,7 @@ public interface CompanyEmailConfigService {
 
 
     void sendEmail(String companyId, String emails);
     void sendEmail(String companyId, String emails);
 
 
-    void sendDistributeEmail(String companyId, String string);
+    void sendDistributeEmail(String companyId, String emails);
+
+    void sendDistributeEmailById(List<Integer> idList);
 }
 }

+ 15 - 0
service-manage/src/main/java/com/simuwang/manage/service/impl/CompanyEmailConfigServiceImpl.java

@@ -424,6 +424,21 @@ public class CompanyEmailConfigServiceImpl implements CompanyEmailConfigService
         }
         }
     }
     }
 
 
+    @Override
+    public void sendDistributeEmailById(List<Integer> idList) {
+        List<CompanyEmailConfigDO> configDOList = companyEmailConfigMapper.selectCompanyEmailConfigByIdList(idList);
+        Map<String,List<CompanyEmailConfigDO>> companyListMap = configDOList.stream().collect(Collectors.groupingBy(e -> e.getCompanyId()));
+        for(String companyId : companyListMap.keySet()){
+            StringBuffer emails = new StringBuffer();
+            List<CompanyEmailConfigDO> configDOS = companyListMap.get(companyId);
+            for(CompanyEmailConfigDO configDO: configDOS){
+                emails.append(configDO.getEmail()).append(";");
+            }
+            //把缺失数据的邮件发送到该公司名下的邮箱地址
+            sendDistributeEmail(companyId,emails.toString());
+        }
+    }
+
 
 
     private void saveCompanyEmailSendHistory(String companyId, String email,Integer sendStatus,String msg) {
     private void saveCompanyEmailSendHistory(String companyId, String email,Integer sendStatus,String msg) {
         CompanyEmailSendHistoryDO historyDO = new CompanyEmailSendHistoryDO();
         CompanyEmailSendHistoryDO historyDO = new CompanyEmailSendHistoryDO();