task|定时任务处理数量添加到数据库

@@ -21,6 +21,9 @@ public interface ParamConfigConstants {
       * @Date 2024/11/20
       */
     interface TASK_PARAM_KEYS{
-
+        //推送进口文件定时任务处理数量
+        String PUSH_CON_NUMBER = "push_con_number";
+        //
+        String NOTIFICATION_SENDER_NUMBER = "notification_sender_number";
     }
 }

@@ -31,4 +31,6 @@ public class AbstractDaoRepository {
     protected PortclearEmailMappingExtMapper portclearEmailMappingExtMapper;
     @Autowired
     protected PushObMapperExt pushObMapperExt;
+    @Autowired
+    protected ParamConfigExtMapper paramConfigExtMapper;
 }
\ No newline at end of file

@@ -9,7 +9,7 @@ import java.util.List;
 
 @Mapper
 public interface EmailExtMapper {
-    List<Email> findEmailsByDic(String typeCode,String statusCode);
+    List<Email> findEmailsByDic(String typeCode,String statusCode,String rowLimit);
 
     @Delete("DELETE FROM T_BIZ_EMAIL WHERE ID = #{id}")
     void deleteById(@Param("id") Long id);

+package com.fedex.connect.task.repository.dao;
+
+import com.fedex.connect.common.model.sys.ParamConfig;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+@Mapper
+public interface ParamConfigExtMapper {
+
+    @Select("SELECT * FROM T_SYS_PARAM_CONFIG WHERE CODE = #{code}")
+    ParamConfig findByCode(@Param("code") String code);
+}

@@ -10,6 +10,6 @@
         AND STATUS_CODE = #{statusCode}
         ORDER BY CREATED_DATE DESC
         )
-        WHERE ROWNUM < 500
+        WHERE ROWNUM < #{rowLimit}
     </select>
 </mapper>
\ No newline at end of file

@@ -5,7 +5,7 @@ import com.fedex.connect.common.model.biz.Email;
 import java.util.List;
 
 public interface IEmailRepository {
-    List<Email> findEmailsByDic(String typeCode,String statusCode);
+    List<Email> findEmailsByDic(String typeCode,String statusCode,String configCode);
 
     void deleteById(Long id);
 

 package com.fedex.connect.task.repository.repo.biz.impl;
 
 import com.fedex.connect.common.model.biz.Email;
+import com.fedex.connect.common.model.sys.ParamConfig;
 import com.fedex.connect.task.repository.base.AbstractDaoRepository;
 import com.fedex.connect.task.repository.repo.biz.IEmailRepository;
 import org.springframework.stereotype.Repository;
@@ -9,8 +10,12 @@ import java.util.List;
 
 @Repository
 public class EmailRepositoryImpl extends AbstractDaoRepository implements IEmailRepository {
-    public List<Email> findEmailsByDic(String typeCode,String statusCode){
-        return emailExtMapper.findEmailsByDic(typeCode,statusCode);
+    public List<Email> findEmailsByDic(String typeCode,String statusCode,String configCode){
+        /**
+         * 获取查询数量
+         */
+        ParamConfig paramConfig = paramConfigExtMapper.findByCode(configCode);
+        return emailExtMapper.findEmailsByDic(typeCode,statusCode,paramConfig.getValue());
     }
 
     @Override

 package com.fedex.connect.task.service.biz.impl;
 
 import com.fedex.connect.common.dependencies.cache.CacheSystem;
+import com.fedex.connect.common.dependencies.contants.ParamConfigConstants;
 import com.fedex.connect.common.dependencies.enums.biz.EmailStatusEnum;
 import com.fedex.connect.common.dependencies.enums.biz.EmailTypeEnum;
 import com.fedex.connect.common.model.biz.Email;
@@ -37,7 +38,7 @@ public class DuplicateConsignmentEmailServiceImpl extends BaseService implements
          *  查询邮件发送日志表中状态为待推送且类型为“提醒发件人”的数据
          */
         List<Email> emails = iEmailExtRepository.findEmailsByDic(cacheSystem.getDicEmailType(EmailTypeEnum.NOTIFICATION_SENDER.getEnMsg()).getCode(),
-                cacheSystem.getDicEmailStatus(EmailStatusEnum.PENDING.getEnMsg()).getCode());
+                cacheSystem.getDicEmailStatus(EmailStatusEnum.PENDING.getEnMsg()).getCode(), ParamConfigConstants.TASK_PARAM_KEYS.NOTIFICATION_SENDER_NUMBER);
         /**
          * 发送邮件
          */

 package com.fedex.connect.task.service.biz.impl;
 
 import com.fedex.connect.common.dependencies.cache.CacheSystem;
+import com.fedex.connect.common.dependencies.contants.ParamConfigConstants;
 import com.fedex.connect.common.dependencies.enums.biz.EmailStatusEnum;
 import com.fedex.connect.common.dependencies.enums.biz.EmailTypeEnum;
 import com.fedex.connect.common.dependencies.util.NIOFileUtils;
@@ -56,7 +57,7 @@ public class PushConsignmentFileServiceImpl extends BaseService implements IPush
         String finalPath = "";
         //查询需要发送的数据
         List<Email> conPushEmails = iEmailExtRepository.findEmailsByDic(cacheSystem.getDicEmailType(EmailTypeEnum.PUSH_CON_FILE.getEnMsg()).getCode(),
-                cacheSystem.getDicEmailStatus(EmailStatusEnum.PENDING.getEnMsg()).getCode());
+                cacheSystem.getDicEmailStatus(EmailStatusEnum.PENDING.getEnMsg()).getCode(),ParamConfigConstants.TASK_PARAM_KEYS.PUSH_CON_NUMBER);
 
         for (Email conPushEmail : conPushEmails) {
             //获取待发送的文件并打zip包