F

application/src/main/java/com/lyg/application/DTO/ErrorDto.java

     private String specificNameOrgRotation; //轮岗列表 轮岗之后单位名
     private String orgNumJobRotation; //轮岗列表 轮岗之后单位号
 
-//    private String counterImpPositionRotation; //轮岗列表 原来岗位
-//    private String counterImpPostRotation;//轮岗列表 轮岗之后的岗位
 
 
 

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

 import com.lyg.framework.accesslimit.AccessLimit;
 import com.lyg.framework.log.OpLog;
 import com.lyg.system.controller.BaseController;
+import com.lyg.system.entity.SysOrg;
+import com.lyg.system.mapper.SysOrgMapper;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
     
     @Autowired
     private TaMandatoryLeaveService taMandatoryLeaveService;
-    
-    /** 
+     @Autowired
+     private SysOrgMapper sysOrgMapper;
+
+
+     /**
      * 通过ID查询单条数据 
      *
      * @param id 主键
     @PutMapping("/taMandatoryLeave/{id}")
     public SaResult edit(@ApiParam("对象实体") @Validated @RequestBody TaMandatoryLeave taMandatoryLeave,
                             @ApiParam("对象ID") @PathVariable String id ) throws Exception {
-        taMandatoryLeave.setLeaveId(id);
         taMandatoryLeaveService.updateById(taMandatoryLeave);
         return SaResult.data(taMandatoryLeave);
     }

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

+package com.lyg.application.controller;
+
+import cn.dev33.satoken.util.SaResult;
+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.entity.TaMessage;
+import com.lyg.application.service.TaMessageService;
+import com.lyg.common.util.StringUtil;
+import com.lyg.framework.accesslimit.AccessLimit;
+import com.lyg.framework.log.OpLog;
+import com.lyg.system.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * 消息表;(ta_massage)表控制层
+ *
+ * @author : http://njyunzhi.com
+ * @date : 2024-3-14
+ */
+@Api(tags = "消息表对象功能接口")
+@RestController
+@RequestMapping("/")
+public class TaMessageController extends BaseController {
+
+    @Autowired
+    private TaMessageService taMessageService;
+
+    /**
+     * 通过ID查询单条数据
+     *
+     * @param id 主键
+     * @return 实例对象
+     */
+    @OpLog(module = "消息表", action = "查询单条数据", desc = "ID：{{#id}}")
+    @AccessLimit()
+    @ApiOperation("通过ID查询单条数据")
+    @GetMapping("/taMessage/{id}")
+    public SaResult queryById(@ApiParam("对象ID") @PathVariable String id) throws Exception {
+        return SaResult.data(taMessageService.getById(id));
+    }
+
+    /**
+     * 分页查询
+     *
+     * @param pageNum  当前页码
+     * @param pageSize 每页条数
+     * @return 查询结果
+     */
+    @OpLog(module = "消息表", action = "分页列表查询")
+    @AccessLimit()
+    @ApiOperation("分页查询")
+    @GetMapping("/taMessage")
+    public SaResult list(@ApiParam("页码") @RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum,
+                         @ApiParam("单页数据量") @RequestParam(value = "pageSize", defaultValue = "10") Integer pageSize,
+                         @ApiParam("正序排列") @RequestParam(value = "sortAsc", required = false) String sortAsc,
+                         @ApiParam("倒序排列") @RequestParam(value = "sortDesc", defaultValue = "create_date") String sortDesc) throws Exception {
+
+        IPage<TaMessage> pg = new Page<>(pageNum, pageSize);
+        QueryWrapper<TaMessage> queryWrapper = new QueryWrapper<>();
+        queryWrapper.orderByAsc(StringUtil.isNotEmpty(sortAsc), StringUtil.humpToLine(sortAsc));
+        queryWrapper.orderByDesc(StringUtil.isNotEmpty(sortDesc), StringUtil.humpToLine(sortDesc));
+        IPage<TaMessage> result = taMessageService.page(pg, queryWrapper);
+
+        return SaResult.data(result);
+    }
+
+    /**
+     * 新增数据
+     *
+     * @param taMessage 实例对象
+     * @return 实例对象
+     */
+    @OpLog(module = "消息表", action = "新增数据")
+    @AccessLimit()
+    @ApiOperation("新增数据")
+    @PostMapping("/taMessage")
+    public SaResult add(@ApiParam("对象实体") @Validated @RequestBody TaMessage taMessage) throws Exception {
+        taMessageService.save(taMessage);
+        return SaResult.data(taMessage);
+    }
+
+    /**
+     * 更新数据
+     *
+     * @param taMessage 实例对象
+     * @return 实例对象
+     */
+    @OpLog(module = "消息表", action = "更新数据")
+    @AccessLimit()
+    @ApiOperation("更新数据")
+    @PutMapping("/taMessage/{id}")
+    public SaResult edit(@ApiParam("对象实体") @Validated @RequestBody TaMessage taMessage,
+                         @ApiParam("对象ID") @PathVariable String id) throws Exception {
+        taMessage.setMessageId(id);
+        taMessageService.updateById(taMessage);
+        return SaResult.data(taMessage);
+    }
+
+    /**
+     * 通过主键删除数据
+     *
+     * @param id 主键
+     * @return 是否成功
+     */
+    @OpLog(module = "消息表", action = "删除数据", desc = "ID：{{#id}}")
+    @AccessLimit()
+    @ApiOperation("通过主键删除数据")
+    @DeleteMapping("/taMessage/{id}")
+    public SaResult deleteById(@ApiParam("对象ID") @PathVariable String id) {
+        taMessageService.removeById(id);
+        return SaResult.data("success");
+    }
+}

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

     @ApiOperation("新增数据")
     @PostMapping("/taRotation")
     public SaResult add(@ApiParam("对象实体") @Validated @RequestBody TaRotation taRotation) throws Exception {
-
-
-        String specificOrgNum = taRotation.getSpecificOrgName();//轮岗前具体单位名称 传来的是orgId
-//        String specificOrgNum = taRotation.getSpecificOrgNum();//轮岗前单位号
-        String OrgRotationId = taRotation.getSpecificNameOrgRotation();//轮岗后具体单位名称 传来的是orgId
-//        String orgNumJobRotation = taRotation.getOrgNumJobRotation();//轮岗后单位号
-
-        String specificOrgName = sysOrgMapper.getOrgId(specificOrgNum);
-        taRotation.setSpecificOrgNum(specificOrgNum);
-        taRotation.setSpecificOrgName(specificOrgName);
-
-        String orgNameJobRotation = sysOrgMapper.getOrgId(OrgRotationId);
-        taRotation.setOrgNumJobRotation(OrgRotationId);
-        taRotation.setSpecificNameOrgRotation(orgNameJobRotation);
-
-
         taRotationService.save(taRotation);
         Object result = rule.taRotationRule(taRotation);
-
         return SaResult.data(result);
     }
 
     @PutMapping("/taRotation/{id}")
     public SaResult edit(@ApiParam("对象实体") @Validated @RequestBody TaRotation taRotation,
                          @ApiParam("对象ID") @PathVariable String id) throws Exception {
-        String specificOrgNum = taRotation.getSpecificOrgName();//轮岗前具体单位名称 传来的是orgId
-//        String specificOrgNum = taRotation.getSpecificOrgNum();//轮岗前单位号
-        String OrgRotationId = taRotation.getSpecificNameOrgRotation();//轮岗后具体单位名称 传来的是orgId
-//        String orgNumJobRotation = taRotation.getOrgNumJobRotation();//轮岗后单位号
-
-        String specificOrgName = sysOrgMapper.getOrgId(specificOrgNum);
-        taRotation.setSpecificOrgNum(specificOrgNum);
-        taRotation.setSpecificOrgName(specificOrgName);
-
-        String orgNameJobRotation = sysOrgMapper.getOrgId(OrgRotationId);
-        taRotation.setOrgNumJobRotation(OrgRotationId);
-        taRotation.setSpecificNameOrgRotation(orgNameJobRotation);
 
         taRotation.setRotationId(id);
         taRotationService.updateById(taRotation);

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

+package com.lyg.application.controller;
+
+import cn.dev33.satoken.util.SaResult;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import java.util.List;
+import com.lyg.common.Constants;
+import com.lyg.common.util.StringUtil;
+import com.lyg.framework.log.OpLog;
+import com.lyg.system.controller.BaseController;
+import com.lyg.framework.accesslimit.AccessLimit;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+import com.lyg.application.entity.TaSending;
+import com.lyg.application.service.TaSendingService;
+
+ /**
+ * 发送消息;(ta_sending)表控制层
+ * @author : http://njyunzhi.com
+ * @date : 2024-3-14
+ */
+@Api(tags = "发送消息对象功能接口")
+@RestController
+@RequestMapping("/")
+public class TaSendingController extends BaseController {
+    
+    @Autowired
+    private TaSendingService taSendingService;
+    
+    /** 
+     * 通过ID查询单条数据 
+     *
+     * @param id 主键
+     * @return 实例对象
+     */
+    @OpLog(module = "发送消息", action = "查询单条数据", desc = "ID：{{#id}}")
+    @AccessLimit()
+    @ApiOperation("通过ID查询单条数据")
+    @GetMapping("/taSending/{id}")
+    public SaResult queryById(@ApiParam("对象ID") @PathVariable String id) throws Exception {
+        return SaResult.data(taSendingService.getById(id));
+    }
+    
+    /** 
+     * 分页查询
+     *
+     * @param pageNum 当前页码
+     * @param pageSize 每页条数
+     * @return 查询结果
+     */
+    @OpLog(module = "发送消息", action = "分页列表查询")
+    @AccessLimit()
+    @ApiOperation("分页查询")
+    @GetMapping("/taSending")
+    public SaResult list(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                            @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                            @ApiParam("正序排列") @RequestParam(value ="sortAsc", required = false) String sortAsc,
+                         @ApiParam("倒序排列") @RequestParam(value ="sortDesc", defaultValue = "create_date") String sortDesc) throws Exception {
+        IPage<TaSending> pg = new Page<>(pageNum, pageSize);
+        QueryWrapper<TaSending> queryWrapper = new QueryWrapper<>();
+        queryWrapper.orderByAsc(StringUtil.isNotEmpty(sortAsc), StringUtil.humpToLine(sortAsc));
+        queryWrapper.orderByDesc(StringUtil.isNotEmpty(sortDesc), StringUtil.humpToLine(sortDesc));
+        IPage<TaSending> result = taSendingService.page(pg, queryWrapper);
+        
+        return SaResult.data(result);
+    }
+    
+    /** 
+     * 新增数据
+     *
+     * @param taSending 实例对象
+     * @return 实例对象
+     */
+    @OpLog(module = "发送消息", action = "新增数据")
+    @AccessLimit()
+    @ApiOperation("新增数据")
+    @PostMapping("/taSending")
+    public SaResult add(@ApiParam("对象实体") @Validated @RequestBody TaSending taSending) throws Exception {
+        taSendingService.save(taSending);
+        return SaResult.data(taSending);
+    }
+    
+    /** 
+     * 更新数据
+     *
+     * @param taSending 实例对象
+     * @return 实例对象
+     */
+    @OpLog(module = "发送消息", action = "更新数据")
+    @AccessLimit()
+    @ApiOperation("更新数据")
+    @PutMapping("/taSending/{id}")
+    public SaResult edit(@ApiParam("对象实体") @Validated @RequestBody TaSending taSending,
+                            @ApiParam("对象ID") @PathVariable String id ) throws Exception {
+        taSending.setSendingId(id);
+        taSendingService.updateById(taSending);
+        return SaResult.data(taSending);
+    }
+    
+    /** 
+     * 通过主键删除数据
+     *
+     * @param id 主键
+     * @return 是否成功
+     */
+    @OpLog(module = "发送消息", action = "删除数据", desc = "ID：{{#id}}")
+    @AccessLimit()
+    @ApiOperation("通过主键删除数据")
+    @DeleteMapping("/taSending/{id}")
+    public SaResult deleteById(@ApiParam("对象ID") @PathVariable String id){
+        taSendingService.removeById(id);
+        return SaResult.data("success");
+    }
+}

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

 
 import cn.dev33.satoken.util.SaResult;
 import com.alibaba.excel.EasyExcel;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.lyg.application.Listener.TaMandatoryLeaveListener;
 import com.lyg.application.Listener.TaRotationListener;
 import com.lyg.application.entity.TaMandatoryLeave;
 import com.lyg.application.entity.TaRotation;
+import com.lyg.application.mapper.TaRotationMapper;
 import com.lyg.application.service.TaMandatoryLeaveService;
 import com.lyg.application.service.TaRotationService;
 import com.lyg.application.service.impl.TaMandatoryLeaveServiceImpl;
     @Autowired
     private TaRotationService taRotationService;
 
+
+
     @Autowired
     private TaRotationServiceImpl taRotationServiceImpl;
     @Autowired
     }
 
 
-//
-//    @AccessLimit()
-//    @ApiOperation("提示/预警")
+    @AccessLimit()
+    @ApiOperation("提示/预警")
 //    @Scheduled(cron = "0 45 2 1 1,4,7,10 ?")
-//    @GetMapping("/prompt/warning")
-//    public SaResult promptWarning() throws Exception {
-//
-//
-//return  SaResult.data("");
-//
-//
-//    }
+    @GetMapping("/prompt/warning")
+    public SaResult promptWarning() throws Exception {
+
+        taRotationService.selectGetWaring();
+
+
+
+
+        return SaResult.data("");
+
+
+    }
 
 
 }

application/src/main/java/com/lyg/application/entity/TaMessage.java

+package com.lyg.application.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import com.baomidou.mybatisplus.annotation.*;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import javax.validation.constraints.NotBlank;
+
+/**
+ * 消息表;
+ * @author : http://www.chiner.pro
+ * @date : 2024-3-14
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value = "消息表",description = "")
+@TableName("ta_message")
+public class TaMessage implements Serializable,Cloneable{
+
+    @ApiModelProperty(name = "预警Id",notes = "")
+    @TableId(value = "message_id", type = IdType.ASSIGN_UUID)
+    private String messageId ;
+
+    @ApiModelProperty(name = "来源Id",notes = "")
+    private String sourceId ;
+
+    @NotBlank(message = "来源表名称不能为空")
+    @ApiModelProperty(name = "来源表名称",notes = "")
+    private String sourceName ;
+
+    @ApiModelProperty(name = "内容",notes = "")
+    private String contentSent ;
+
+    @ApiModelProperty(name = "核查反馈",notes = "")
+    private String remark ;
+
+    @ApiModelProperty(name = "预警 waring  提示 prompt",notes = "预警 超过轮岗截止日期  提示提前一个月提醒")
+    private String waringStatus ;
+
+    @ApiModelProperty(name = "状态 1正常 0不正常",notes = "")
+    private Integer status ;
+
+    @ApiModelProperty(name = "创建人",notes = "")
+    @TableField(fill = FieldFill.INSERT)
+    private String createUser ;
+
+    @ApiModelProperty(name = "创建时间",notes = "")
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createDate ;
+
+    @ApiModelProperty(name = "更新人",notes = "")
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private String updateUser ;
+
+    @ApiModelProperty(name = "更新时间",notes = "")
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updateDate ;
+
+    @ApiModelProperty(name = "删除标志",notes = "1删除")
+    @TableField(fill = FieldFill.INSERT)
+    private Integer deleted ;
+
+}

application/src/main/java/com/lyg/application/entity/TaSending.java

+package com.lyg.application.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import com.baomidou.mybatisplus.annotation.*;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import javax.validation.constraints.NotBlank;
+
+ /**
+ * 发送消息;
+ * @author : http://www.chiner.pro
+ * @date : 2024-3-14
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value = "发送消息",description = "")
+@TableName("ta_sending")
+public class TaSending implements Serializable,Cloneable{
+    
+    @ApiModelProperty(name = "发送消息id",notes = "")
+    @TableId(value = "sending_id", type = IdType.ASSIGN_UUID)
+    private String sendingId ;
+    
+    @ApiModelProperty(name = "消息id",notes = "")
+    private String messageId ;
+    
+    @ApiModelProperty(name = "接收人id",notes = "")
+    private String recipientId ;
+    
+    @ApiModelProperty(name = "1 已读 0未读",notes = "")
+    private Integer isRead ;
+    
+    @ApiModelProperty(name = "1 已处理 0未处理",notes = "")
+    private Integer isHandle ;
+    
+    @ApiModelProperty(name = "状态 1正常 0不正常",notes = "")
+    private Integer status ;
+    
+    @ApiModelProperty(name = "创建人",notes = "")
+    @TableField(fill = FieldFill.INSERT)
+    private String createUser ;
+    
+    @ApiModelProperty(name = "创建时间",notes = "")
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createDate ;
+    
+    @ApiModelProperty(name = "更新人",notes = "")
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private String updateUser ;
+    
+    @ApiModelProperty(name = "更新时间",notes = "")
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updateDate ;
+    
+    @ApiModelProperty(name = "删除标志",notes = "1删除")
+    @TableField(fill = FieldFill.INSERT)
+    private Integer deleted ;
+
+}

application/src/main/java/com/lyg/application/mapper/TaMessageMapper.java

+package com.lyg.application.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.lyg.application.entity.TaMessage;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 消息表;(ta_massage)表数据库访问层
+ *
+ * @author : http://njyunzhi.com
+ * @date : 2024-3-14
+ */
+@Mapper
+public interface TaMessageMapper extends BaseMapper<TaMessage> {
+
+}

application/src/main/java/com/lyg/application/mapper/TaRotationMapper.java

 public interface TaRotationMapper extends BaseMapper<TaRotation> {
 
     List<TaRotation> selectRepel(@Param("orgList") List<String> orgList, @Param("targetList") List<String> targetList, @Param("newDate") LocalDate newDate, @Param("params") Map<String, String> params);
+
+    List<TaRotation> waring(@Param("localDate") LocalDate localDate);
+
+    List<TaRotation> prompt(@Param("localDate") LocalDate localDate);
 }

application/src/main/java/com/lyg/application/mapper/TaSendingMapper.java

+package com.lyg.application.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import com.lyg.application.entity.TaSending;
+
+ /**
+ * 发送消息;(ta_sending)表数据库访问层
+ * @author : http://njyunzhi.com
+ * @date : 2024-3-14
+ */
+@Mapper
+public interface TaSendingMapper  extends BaseMapper<TaSending>{
+    
+}

application/src/main/java/com/lyg/application/service/TaMessageService.java

+package com.lyg.application.service;
+
+import com.lyg.application.entity.TaMessage;
+import com.lyg.system.service.IBaseService;
+
+/**
+ * 消息表;(ta_massage)表服务接口
+ *
+ * @author : http://njyunzhi.com
+ * @date : 2024-3-14
+ */
+public interface TaMessageService extends IBaseService<TaMessage> {
+
+}

application/src/main/java/com/lyg/application/service/TaRotationService.java

     TaRotation handleEntity(TaRotation entity,Integer index) throws Exception;
     void saveEntityBatch(List<TaRotation> entityList);
 
+    void selectGetWaring();
+
 //
 //    void handleEntity(List<T> entityList) throws Exception;
 //

application/src/main/java/com/lyg/application/service/TaSendingService.java

+package com.lyg.application.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.lyg.application.entity.TaSending;
+import com.lyg.system.service.IBaseService;
+
+ /**
+ * 发送消息;(ta_sending)表服务接口
+ * @author : http://njyunzhi.com
+ * @date : 2024-3-14
+ */
+public interface TaSendingService extends IBaseService<TaSending> {
+    
+}

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

+package com.lyg.application.service.impl;
+
+import com.lyg.application.entity.TaMessage;
+import com.lyg.application.mapper.TaMessageMapper;
+import com.lyg.application.service.TaMessageService;
+import com.lyg.system.service.impl.BaseServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * 消息表;(ta_massage)表服务实现类
+ *
+ * @author : http://www.chiner.pro
+ * @date : 2024-3-14
+ */
+@Service
+public class TaMessageServiceImpl extends BaseServiceImpl<TaMessageMapper, TaMessage> implements TaMessageService {
+
+}

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

 package com.lyg.application.service.impl;
 
+import com.lyg.application.entity.TaMessage;
 import com.lyg.application.entity.TaRotation;
+import com.lyg.application.entity.TaSending;
+import com.lyg.application.mapper.TaMessageMapper;
 import com.lyg.application.mapper.TaRotationMapper;
+import com.lyg.application.mapper.TaSendingMapper;
 import com.lyg.application.service.TaRotationService;
 import com.lyg.application.util.Rule;
+import com.lyg.common.util.StringUtil;
+import com.lyg.system.entity.SysUser;
 import com.lyg.system.mapper.SysPositionMapper;
+import com.lyg.system.mapper.SysUserMapper;
 import com.lyg.system.service.SysOrgService;
 import com.lyg.system.service.SysPositionService;
+import com.lyg.system.service.SysUserService;
 import com.lyg.system.service.impl.BaseServiceImpl;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
     private SysPositionService sysPositionService;
     @Autowired
     private SysPositionMapper sysPositionMapper;
+    @Autowired
+    private TaMessageMapper taMessageMapper;
+    @Autowired
+    private TaSendingMapper taSendingMapper;
+
+    @Autowired
+    private SysUserService sysUserService;
+    @Autowired
+    private SysUserMapper sysUserMapper;
 
     public TaRotation handleEntity(TaRotation entity, Integer index) throws Exception {
 //校验验证
 //        轮岗之前岗位名  获取id
         String rotationId = sysPositionMapper.getPostId(rotationName);
         entity.setCounterImpPositions(rotationId);
-        if(impPostRotation!=null){
-        //   轮岗之后岗位名  获取id
-        String impPostRotationId = sysPositionMapper.getPostId(impPostRotation);
-        entity.setCounterImpPostRotation(impPostRotationId);
+        if (impPostRotation != null) {
+            //   轮岗之后岗位名  获取id
+            String impPostRotationId = sysPositionMapper.getPostId(impPostRotation);
+            entity.setCounterImpPostRotation(impPostRotationId);
         }
 
 
         System.out.println("******************************entityList**************************************");
         System.out.println(entityList);
         for (TaRotation taRotation : entityList) {
-
-
             baseMapper.insert(taRotation);
 
         }
     }
 
+    @Override
+    public void selectGetWaring() {
+        LocalDate localDate = LocalDate.now();
+
+//预警 消息
+        List<TaRotation> earlyWaringList = baseMapper.waring(localDate);
+        if (earlyWaringList.size() != 0) {
+            for (TaRotation item : earlyWaringList) {
+                TaMessage taMessage = new TaMessage();
+                String uuid = StringUtil.UUID();
+                taMessage.setMessageId(uuid);
+                taMessage.setSourceId(item.getRotationId());
+                String contentSent = "工号：" + item.getEmployeeNum() + ", 名字：" + item.getEmployeeName() + ", 业务条线：" + item.getCounterHeadOfficeLine() + ", 超过轮岗截止日期, 请及时处理";
+                taMessage.setContentSent(contentSent);
+                taMessage.setSourceName("taRotation");
+                taMessage.setWaringStatus("waring");
+                taMessageMapper.insert(taMessage);
+
+
+//                item.getCreateUser()  就是新增这个数据的人
+                //现在需要去重 创建人和管理员  是一个人只能往  Tasending插入一条数据否则是两条数据
+                SysUser sysUserAdmin = sysUserMapper.getAdmin(item.getCreateUser());
+//                如果为空 就不是管理员创建的;
+                List<String> userIdList = new ArrayList<>();
+
+                if (sysUserAdmin == null) {
+                    userIdList = sysUserMapper.allAdmin();
+                    userIdList.add(sysUserAdmin.getUserId());
+                }
+                for (String it : userIdList) {
+                    TaSending taSending = new TaSending();
+                    taSending.setMessageId(uuid);
+                    taSending.setRecipientId(it);
+                    taSendingMapper.insert(taSending);
+                }
+
+
+            }
+        }
+//提示消息
+        List<TaRotation> earlyPromptList = baseMapper.prompt(localDate);
+        if (earlyPromptList.size() != 0) {
+            for (TaRotation item : earlyPromptList) {
+                TaMessage taMessage = new TaMessage();
+                taMessage.setSourceId(item.getRotationId());
+                String contentSent = "工号：" + item.getEmployeeNum() + ", 名字：" + item.getEmployeeName() + ", 业务条线：" + item.getCounterHeadOfficeLine() + ",即将轮岗, 请及时处理";
+                taMessage.setContentSent(contentSent);
+                taMessage.setSourceName("taRotation");
+                taMessage.setWaringStatus("prompt");
+                taMessageMapper.insert(taMessage);
+            }
+        }
+
+
+        return;
+    }
+
 
     public List<Object> getErrorMessages() {
         return errorMessages;

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

+package com.lyg.application.service.impl;
+
+import com.lyg.system.service.impl.BaseServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.lyg.application.entity.TaSending;
+import com.lyg.application.mapper.TaSendingMapper;
+import com.lyg.application.service.TaSendingService;
+
+ /**
+ * 发送消息;(ta_sending)表服务实现类
+ * @author : http://www.chiner.pro
+ * @date : 2024-3-14
+ */
+@Service
+public class TaSendingServiceImpl extends BaseServiceImpl<TaSendingMapper, TaSending> implements TaSendingService {
+    
+}

application/src/main/resources/mapper/TaMessageMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.lyg.application.mapper.TaMessageMapper">
+    
+</mapper>

application/src/main/resources/mapper/TaRotationMapper.xml

             #{item}
         </foreach>
     </select>
+    <select id="waring" resultType="com.lyg.application.entity.TaRotation">
+        SELECT * FROM TA_ROTATION r
+        WHERE r.rotation_deadline &lt; #{localDate}
+    </select>
+    <select id="prompt" resultType="com.lyg.application.entity.TaRotation">
+        SELECT * FROM TA_ROTATION r
+        WHERE r.rotation_deadline>=ADD_MONTHS(#{localDate} , -1)
+        AND r.rotation_deadline &lt; #{localDate}
+    </select>
 </mapper>

application/src/main/resources/mapper/TaSendingMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.lyg.application.mapper.TaSendingMapper">
+    
+</mapper>

system/src/main/java/com/lyg/system/controller/BaseController.java

         Integer isAdmin = sysUser.getIsAdmin();
         if (isAdmin.equals(1)) {
             //是超级管理员
+
         } else {
 //            不是管理员
             String userId = sysUser.getUserId();

system/src/main/java/com/lyg/system/mapper/SysUserMapper.java

 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.lyg.system.entity.SysUser;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
 
 /**
  * 用户表;(sys_user)表数据库访问层
  */
 @Mapper
 public interface SysUserMapper  extends BaseMapper<SysUser>{
+    SysUser getAdmin(@Param("createUser") String createUser);
+
+    List<String> allAdmin();
 }

system/src/main/resources/mapper/SysUserMapper.xml

 
 <mapper namespace="com.lyg.system.mapper.SysUserMapper">
 
+    <select id="getAdmin" resultType="com.lyg.system.entity.SysUser">
+        SELECT
+        *
+        FROM
+        SYS_USER u
+        WHERE
+        u.is_admin = 1
+        AND u.user_id = #{createUser}
+        AND u.DELETED = 0
+    </select>
+    <select id="allAdmin" resultType="java.lang.String">
+        SELECT
+        u.user_id
+        FROM
+        SYS_USER u
+        WHERE
+        u.is_admin = 1
+        AND u.DELETED = 0
+    </select>
 </mapper>