政府履职清单过期未履行预警

inventory-dao/src/main/java/com/rzyc/mapper/user/SysUserMapper.java

@@ -193,4 +193,7 @@ public interface SysUserMapper {
     //查询流转人
     List<UserVo> selectTransferor();
 
+    /*岗位用户*/
+    List<SysUser> findBySysTitle(@Param("sysTitle") String sysTitle);
+
 }

inventory-dao/src/main/resources/mapper/OATaskMapper.xml

@@ -656,7 +656,9 @@
   <!--未完成履职任务-->
   <select id="notCompleteTask" resultMap="BaseResultMap">
     SELECT * FROM `oatask` ot
+        LEFT JOIN `listfactor` lt ON ot.`OTCId` = lt.`ListFactorId`
     WHERE ot.`IsFinish` = '否'
+      AND lt.`del_state` = 1
     AND ot.`PlanEndDate` &lt; NOW()
     AND YEAR(ot.`StartDate`) =YEAR(NOW())
     AND ot.`TaskType` = '履职任务'

inventory-dao/src/main/resources/mapper/user/SysUserMapper.xml

@@ -1428,4 +1428,9 @@
   <select id="selectTransferor" resultType="com.rzyc.bean.task.vo.UserVo">
     select su.SysUserId ,su.SysDeptName ,su.ChinaName   FROM SysUser su
   </select>
+
+  <!--通过岗位id查询用户-->
+  <select id="findBySysTitle" resultMap="BaseResultMap">
+    select * from sysuser su where su.SysTitle = #{sysTitle}
+  </select>
 </mapper>

inventory-gov/src/main/java/com/rzyc/service/TaskService.java

@@ -12,6 +12,7 @@ import com.rzyc.model.check.BookEntHT;
 import com.rzyc.model.check.BookenthtCompany;
 import com.rzyc.model.check.ChkPerson;
 import com.rzyc.model.ent.SysEnterprise;
+import com.rzyc.model.user.ListFactor;
 import com.rzyc.model.user.SysUser;
 import org.springframework.stereotype.Service;
 
@@ -40,6 +41,8 @@ public class TaskService extends BaseController {
             performTask();
             //隐患超时
             configureTasksEditDanger();
+            //未完成履职任务提醒
+            addTaskWarn();
         }catch (Exception e){
             e.printStackTrace();
         }
@@ -217,7 +220,7 @@ public class TaskService extends BaseController {
                 if(null != sysEnterprise){
                     warnInfo = sysEnterprise.getEntname();
                 }
-                warnInfo = warnInfo + "的隐患<" + entHT.getHiddenarea() + ">超期未整改";
+                warnInfo = warnInfo + "的隐患<" + entHT.getHiddenarea() + ">超期未整改。";
 
                 SysWarning warning = new SysWarning();
                 warning.setWarningId(RandomNumber.getUUid());
@@ -246,6 +249,12 @@ public class TaskService extends BaseController {
         }
     }
 
+    /**
+     * 政府履职清单过期未履行
+     * @version v1.0
+     * @author dong
+     * @date 2023/3/31 9:48
+     */
     public void addTaskWarn()throws Exception{
 
         //未完成履职任务
@@ -254,6 +263,50 @@ public class TaskService extends BaseController {
             for (OATask oaTask : oaTasks){
                 //查询是否预警
                 Integer warnNum = sysWarningMapper.countByTargetId(oaTask.getOataskid());
+                if(0 == warnNum){
+
+                    ListFactor listFactor = listFactorMapper.selectByPrimaryKey(oaTask.getOtcid());
+                    if(null != listFactor){
+
+                        //查询任务用户
+                        List<SysUser> sysUsers = sysUserMapper.findBySysTitle(listFactor.getListperformid());
+                        if(null != sysUsers && sysUsers.size() > 0){
+
+                            String warnInfo = "您的履职任务：<"+oaTask.getSubject()+">超期未完成。";
+                            SysWarning warning = new SysWarning();
+                            warning.setWarningId(RandomNumber.getUUid());
+                            warning.setTargetId(oaTask.getOataskid());
+                            warning.setWarningInfo(warnInfo);
+                            warning.setWarningTime(new Date());
+                            warning.setTypeId(WarnTypeEnum.GOV_LIST.getType());
+                            warning.setDelState(DelState.NOT_DEL.getState());
+                            warning.setCreateTime(new Date());
+                            warning.setModifyTime(new Date());
+                            sysWarningMapper.insert(warning);
+
+                            for (SysUser sysUser : sysUsers){
+                                SysWarningUser warningUser = new SysWarningUser();
+                                warningUser.setWarningUserId(RandomNumber.getUUid());
+                                warningUser.setWarningId(warning.getWarningId());
+                                warningUser.setUserId(sysUser.getSysuserid());
+                                warningUser.setTypeId(WarnTypeEnum.GOV_LIST.getType());
+                                warningUser.setState(1);
+                                warningUser.setDelState(DelState.NOT_DEL.getState());
+                                warningUser.setCreateTime(new Date());
+                                warningUser.setModifyTime(new Date());
+                                sysWarningUserMapper.insert(warningUser);
+                            }
+
+                        }
+                    }
+
+
+
+
+                }
+
+
+
             }
         }
     }