bugfix

ruoyi-admin/src/main/java/com/ruoyi/jjh/declaration/component/TimingRemindImpl.java

@@ -3,6 +3,7 @@ package com.ruoyi.jjh.declaration.component;
 import com.ruoyi.common.core.domain.entity.SysUser;
 import com.ruoyi.jjh.declaration.service.IBmsEnterpriseBasicInfoService;
 import com.ruoyi.jjh.ent.entity.JContacts;
+import com.ruoyi.jjh.ent.entity.JEnterpriseContact;
 import com.ruoyi.jjh.ent.entity.JSmartDeclaration;
 import com.ruoyi.jjh.ent.service.JContactsService;
 import com.ruoyi.jjh.ent.service.JEnterpriseContactService;
@@ -95,13 +96,15 @@ public class TimingRemindImpl implements TimingRemindService {
      */
     public void getContact(String code, String s) {
         if (isTiming) {
-//            List<JEnterpriseContact> list1 = jEnterpriseContactService.lambdaQuery().eq(JEnterpriseContact::getEnterpriseCode, code).list();
-//            list1.forEach(y -> {
-//                //先添加工单再发送短信
-//                //可在导入或者新增的时候将该常用联系人的手机号添加进工单
-//                smsAlertsService.enterSms(y.getEnterpriseName(), s, y.getContactPhone());
-//                log.info(y.getEnterpriseName() + "发送短信成功!");
-//            });
+            List<JEnterpriseContact> list1 = jEnterpriseContactService.lambdaQuery().eq(JEnterpriseContact::getEnterpriseCode, code).list();
+            if (list1 != null && !list1.isEmpty()) {
+                list1.forEach(y -> {
+                    //先添加工单再发送短信
+                    //可在导入或者新增的时候将该常用联系人的手机号添加进工单
+                    smsAlertsService.enterSms(y.getEnterpriseName(), s, y.getContactPhone());
+                    log.info(y.getEnterpriseName() + "发送短信成功!");
+                });
+            } else {
                 List<JContacts> list = jContactsService.lambdaQuery().eq(JContacts::getTyshxydm, code)
                         .eq(JContacts::getDefaultcontact, "1").list();
                 list.forEach(y -> {
@@ -113,6 +116,7 @@ public class TimingRemindImpl implements TimingRemindService {
                 });
             }
         }
+    }
 
     /**
      * 政务端要定时新增数据，并且还要发短信

ruoyi-admin/src/main/java/com/ruoyi/jjh/declaration/service/impl/BmsTemplateRecordServiceImpl.java

@@ -30,7 +30,10 @@ import org.springframework.transaction.annotation.Transactional;
 import javax.annotation.Resource;
 import java.time.Year;
 import java.util.ArrayList;
+import java.util.HashSet;
 import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
 
 /**
  * 在线模板Service业务层处理
@@ -226,13 +229,19 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
         List<BmsDeclarationRecords> drlist = new ArrayList<>();
         //如果前端部分企业名录集合为空
         if (null != enterpriseDirectoryList && enterpriseDirectoryList.size() > 0) {
-            enterpriseDirectoryList.forEach(x -> {
+            List<BmsEnterpriseDirectory> deduplicatedList = new ArrayList<>(enterpriseDirectoryList.stream()
+                    .collect(Collectors.toMap(
+                            BmsEnterpriseDirectory::getCreditCode,
+                            p -> p, // 映射为 Person 对象
+                            (existing, replacement) -> existing)) // 如果 id 重复，保留第一个
+                    .values());
+            deduplicatedList.forEach(x -> {
                 getDeclarationRecordsList(bmsTemplateRecordAddDto, drlist, x.getCreditCode().trim(), tp.getTemplateJson());
                 x.setTemplateRecordId(bmsTemplateRecordAddDto.getId());
                 x.setCreditCode(x.getCreditCode().trim());
                 x.setEnterpriseName(x.getEnterpriseName().trim());
             });
-            enterpriseDirectoryService.saveBatch(enterpriseDirectoryList);
+            enterpriseDirectoryService.saveBatch(deduplicatedList);
         } else {
             List<BmsEnterpriseBasicInfo> list = iBmsEnterpriseBasicInfoService.list();
             List<BmsEnterpriseDirectory> copyList = new ArrayList<>();
@@ -252,12 +261,11 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
         if (isTiming) {
             List<BmsEnterpriseDirectory> list = enterpriseDirectoryService.lambdaQuery().eq(BmsEnterpriseDirectory::getTemplateRecordId, bmsTemplateRecordAddDto.getId()).list();
             for (BmsEnterpriseDirectory x : list) {
-                timingRemindImpl.getContact(x.getCreditCode(), "您有1个新的申报任务[待填报]");
+                timingRemindImpl.getContact(x.getCreditCode(), "各重点企业，现开展生产性服务业企业或项目支撑新型工业化的相关案例征集，详情请登录金鸡湖现代服务业品牌管理系统https://idp.sipac.gov.cn/bms/#/login  首页查看待办事项，感谢支持！");
             }
         }
         return num;
     }
-
     /**
      * 生成在线申报记录
      */