f

application/src/main/java/com/lyg/application/controller/TaMandatoryLeaveController.java

 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+
 /**
  * 强制休假表;(ta_mandatory_leave)表控制层
  *
                          @ApiParam("对应重要岗位") @RequestParam(value = "counterImpPost", required = false) String counterImpPost,
                          @ApiParam("对应总行条线") @RequestParam(value = "counterHeadOfficeLine", required = false) String counterHeadOfficeLine,
 
+                         @ApiParam("休假起始时间开始") @RequestParam(value = "startVacation", required = false) String startVacation,
+                         @ApiParam("休假起始时间结束") @RequestParam(value = "endVacation", required = false) String endVacation,
+
+
                          @ApiParam("正序排列") @RequestParam(value = "sortAsc", defaultValue = "create_date") String sortAsc,
                          @ApiParam("倒序排列") @RequestParam(value = "sortDesc", required = false) String sortDesc
     ) throws Exception {
-
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); // 定义日期格式化模式
+        LocalDate startDate = null;
+        LocalDate endDate = null;
+        if (StringUtil.isNotEmpty(startVacation)) {
+            startDate = LocalDate.parse(startVacation, formatter);
+            endDate = LocalDate.parse(endVacation, formatter);
+        }
         IPage<TaMandatoryLeave> pg = new Page<>(pageNum, pageSize);
         QueryWrapper<TaMandatoryLeave> queryWrapper = new QueryWrapper<>();
+
+        queryWrapper.between(startDate != null, "start_time_vacation", startDate, endDate);
+
         queryWrapper.eq(StringUtil.isNotEmpty(checkAuth()), "CREATE_USER", checkAuth());
         queryWrapper.like(StringUtil.isNotEmpty(headOfficeOrg), "head_office_org", headOfficeOrg);
         queryWrapper.eq(StringUtil.isNotEmpty(employeeNum), "employee_num", employeeNum);

application/src/main/java/com/lyg/application/controller/TaRotationController.java

 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.lyg.application.DTO.ErrorDto;
 import com.lyg.application.entity.TaRotation;
 import com.lyg.application.service.TaRotationService;
-import com.lyg.application.util.CreateResponse;
 import com.lyg.application.util.Rule;
 import com.lyg.common.util.StringUtil;
 import com.lyg.framework.accesslimit.AccessLimit;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
-import java.util.ArrayList;
-import java.util.List;
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
 
 /**
  * 轮岗列表;(ta_rotation)表控制层
                          @ApiParam("对应机构层次") @RequestParam(value = "counterInstitutionsLevel", required = false) String counterInstitutionsLevel,
                          @ApiParam("对应重要岗位") @RequestParam(value = "counterImpPositions", required = false) String counterImpPositions,
                          @ApiParam("对应总行条线") @RequestParam(value = "counterHeadOfficeLine", required = false) String counterHeadOfficeLine,
+                         @ApiParam("轮岗截止日期开始") @RequestParam(value = "startDeadline", required = false) String startDeadline,
+                         @ApiParam("轮岗截止日期结束") @RequestParam(value = "endDeadline", required = false) String endDeadline,
 
+                         @ApiParam("轮岗执行时间开始") @RequestParam(value = "startExeTime", required = false) String startExeTime,
+                         @ApiParam("轮岗执行时间结束") @RequestParam(value = "endExeTime", required = false) String endExeTime,
 
                          @ApiParam("正序排列") @RequestParam(value = "sortAsc", defaultValue = "create_date") String sortAsc,
                          @ApiParam("倒序排列") @RequestParam(value = "sortDesc", required = false) String sortDesc
     ) throws Exception {
 
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); // 定义日期格式化模式
+        LocalDate startDate = null;
+        LocalDate endDate = null;
+        if (StringUtil.isNotEmpty(startDeadline)) {
+            startDate = LocalDate.parse(startDeadline, formatter);
+            endDate = LocalDate.parse(endDeadline, formatter);
+        }
+        if (StringUtil.isNotEmpty(startExeTime)) {
+            startDate = LocalDate.parse(startExeTime, formatter);
+            endDate = LocalDate.parse(endExeTime, formatter);
+        }
+
+
         IPage<TaRotation> pg = new Page<>(pageNum, pageSize);
         QueryWrapper<TaRotation> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq(StringUtil.isNotEmpty(checkAuth()), "CREATE_USER", checkAuth());
+        queryWrapper.between(startDate != null, "rotation_deadline", startDate, endDate);
+        queryWrapper.between(startDate != null, "rotation_exe_time", startDate, endDate);
+
+
         queryWrapper.like(StringUtil.isNotEmpty(headOfficeOrg), "head_office_org", headOfficeOrg);
         queryWrapper.eq(StringUtil.isNotEmpty(employeeNum), "employee_num", employeeNum);
         queryWrapper.like(StringUtil.isNotEmpty(employeeName), "employee_name", employeeName);

application/src/main/java/com/lyg/application/controller/UploadController.java

     public void promptWarning() throws Exception {
 
 //        taRotationService.selectGetWaring();
-//        taMandatoryLeaveService.selectGetPrompt();
+        taMandatoryLeaveService.selectGetPrompt();
 
     }
 

application/src/main/java/com/lyg/application/job/MandatoryJobTime.java

 
 
 import com.lyg.application.service.TaMandatoryLeaveService;
-import com.lyg.application.service.TaRotationService;
 import com.lyg.framework.accesslimit.AccessLimit;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
     @Autowired
     private TaMandatoryLeaveService taMandatoryLeaveService;
 
+
     /**
      *  定时提醒   每年12月20号8点
      * @throws Exception
      */
     @AccessLimit()
-    @Scheduled(cron = "0 0 8 20 12 *")
+    @Scheduled(cron = "${yz.job.task2}")
     public void promptWarning() throws Exception {
         taMandatoryLeaveService.selectGetPrompt();
     }

application/src/main/java/com/lyg/application/job/TotationJobTime.java

      */
 
     @AccessLimit()
-    @Scheduled(cron = "0 0 8 * * *")
+    @Scheduled(cron = "${yz.job.task1}")
     public void promptWarning() throws Exception {
         taRotationService.selectGetWaring();
 

application/src/main/java/com/lyg/application/service/impl/TaMandatoryLeaveServiceImpl.java

  */
 @Service
 public class TaMandatoryLeaveServiceImpl extends BaseServiceImpl<TaMandatoryLeaveMapper, TaMandatoryLeave> implements TaMandatoryLeaveService {
-    private final List<String> errorMessages = new ArrayList<>();
-
     private static final String MESSAGE_SOURCE_NAME = "taMandatoryLeave";
     private static final String PROMPT_TYPE = "prompt";
-
+    private final List<String> errorMessages = new ArrayList<>();
+    
+    @Autowired
     @Value("${yz.holidayTmp}")
     String holidayTmp;
 
 
 //        messageHandle.handleMandatoryLeaves(localDate, holidayTmp, PROMPT_TYPE);
         // 提示消息处理
-        messageHandle.handleMandatoryLeaves(localDate, holidayTmp, PROMPT_TYPE,MESSAGE_SOURCE_NAME, baseMapper::prompt);
-//        List<TaMandatoryLeave> promptList = baseMapper.prompt(localDate);
+        messageHandle.handleMandatoryLeaves(localDate, holidayTmp, PROMPT_TYPE, MESSAGE_SOURCE_NAME, baseMapper::prompt);
+//        List<TaMandatoryLeave> promptList = baseMapper.prompt(localDate)PROMPT_TYPE;
 //
 //        if (promptList.size() != 0) {
 //            for (TaMandatoryLeave item : promptList) {

application/src/main/java/com/lyg/application/util/MessageHandle.java

      * @param messageType 消息类型
      */
     private void processItem(TaRotation item, String tmp, String messageType, String sourceName) {
-        StringBuilder stringBuilder = new StringBuilder();
+        String newTmp = null;
         TaMessage taMessage = new TaMessage();
         Map<String, String> params = new HashMap<>();
 
         taMessage.setMessageId(uuid);
         taMessage.setSourceId(item.getRotationId());
 
-        // 使用描述性强的常量代替硬编码值
-        stringBuilder.append(tmp); // 假设warningTmp或promptTmp已经定义且包含插入点
-        stringBuilder.insert(Constants.numI, item.getEmployeeNum());
-        int insertPos = item.getEmployeeNum().length() + Constants.nameI;
-        stringBuilder.insert(insertPos, item.getEmployeeName());
-        taMessage.setContentSent(stringBuilder.toString());
+//        // 使用描述性强的常量代替硬编码值
+//        stringBuilder.insert(Constants.numI, item.getEmployeeNum());
+//        int insertPos = item.getEmployeeNum().length() + Constants.nameI;
+//        stringBuilder.insert(insertPos, item.getEmployeeName());
+        String employeeNum = item.getEmployeeNum();
+        String employeeName = item.getEmployeeName();
+        newTmp = tmp.replace("code", employeeNum).replace("name", employeeName);
+        taMessage.setContentSent(newTmp);
         taMessage.setSourceName(sourceName);
         taMessage.setWaringType(messageType);
         params.put("sourceName", sourceName);
         params.put("waringType", messageType);
-        params.put("contentSent", stringBuilder.toString());
+        params.put("contentSent", newTmp);
         Long count = taMessageService.countBy("source_id", item.getRotationId(), true);
         if (count == 0) {
             taMessageMapper.insert(taMessage);
     }
 
     private void processItemLeaves(TaMandatoryLeave item, String tmp, String messageType, String sourceName) {
-        StringBuilder stringBuilder = new StringBuilder();
         TaMessage taMessage = new TaMessage();
         Map<String, String> params = new HashMap<>();
 
         taMessage.setMessageId(uuid);
         taMessage.setSourceId(item.getLeaveId());
 
-        // 使用描述性强的常量代替硬编码值
-        stringBuilder.append(tmp); // 假设warningTmp或promptTmp已经定义且包含插入点
-        stringBuilder.insert(Constants.numI, item.getEmployeeNum());
-        int insertPos = item.getEmployeeNum().length() + Constants.nameI;
-        stringBuilder.insert(insertPos, item.getEmployeeName());
-        taMessage.setContentSent(stringBuilder.toString());
+//        // 使用描述性强的常量代替硬编码值
+        StringBuilder sb = new StringBuilder(tmp);
+        // 假设warningTmp或promptTmp已经定义且包含插入点
+//        stringBuilder.insert(Constants.numI, item.getEmployeeNum());
+//        int insertPos = item.getEmployeeNum().length() + Constants.nameI;
+//        stringBuilder.insert(insertPos, item.getEmployeeName());
+        String employeeNum = item.getEmployeeNum();
+        String employeeName = item.getEmployeeName();
+        String newTmp = null;
+        newTmp = tmp.replace("code", employeeNum).replace("name", employeeName);
+        taMessage.setContentSent(newTmp);
         taMessage.setSourceName(sourceName);
         taMessage.setWaringType(messageType);
         params.put("sourceName", "taMandatoryLeave");
         params.put("waringType", "prompt");
-        params.put("contentSent", stringBuilder.toString());
+        params.put("contentSent", newTmp);
         Long count = taMessageService.countBy("source_id", item.getLeaveId(), true);
         if (count == 0) {
             taMessageMapper.insert(taMessage);

application/src/main/resources/application.yml

-
 # 端口
 server:
   port: 8001
     date-format: yyyy-MM-dd HH:mm:ss
     time-zone: GMT+8
   datasource:
-    url: jdbc:oracle:thin:@192.168.89.10:1521:orcl
+    url: jdbc:oracle:thin:@192.168.89.147:1521:orcl
     username: job_waring
     password: job_waring@ABCD1234
     driver-class-name: oracle.jdbc.OracleDriver
 ###
 yz:
   appid: job_warning
-  warningTmp: 工号：, 名字：, 超过轮岗截止日期, 请及时处理
-  promptTmp: 工号：, 名字：, 即将轮岗, 请及时处理
-  holidayTmp: 工号：, 名字：, 还未休假, 请及时处理
+  warningTmp: 工号：code, 名字：name, 超过轮岗截止日期, 请及时处理
+  promptTmp: 工号：code, 名字：name, 即将轮岗, 请及时处理
+  holidayTmp: 工号：code, 名字：name, 还未休假, 请及时处理
+  job:
+    task1: 0 0 8 * * *
+    task2: 0 30 8 20 12 *
   upload:
     path: E:\work\public-upload
   sso: