修改

fhKeeper/formulahousekeeper/management-crm/src/main/java/com/management/platform/controller/TaskController.java

@@ -55,6 +55,10 @@ public class TaskController {
     private HttpServletRequest request;
     @Resource
     private TaskService taskService;
+    @Resource
+    private InformationService informationService;
+    @Resource
+    private TaskInformationService taskInformationService;
 
 
 
@@ -134,5 +138,55 @@ public class TaskController {
 
     }
 
+    /**
+     * 消息提醒
+     */
+    @Scheduled(cron = "0 8 * * * ?")
+    public void InfoMationAlerts(){
+        log.info("定时执行了===========>");
+        QueryWrapper<Task> taskQueryWrapper = new QueryWrapper<>();
+        //应该不用考虑任务的状态
+        taskQueryWrapper.eq("is_delete",0).eq("is_repeat",1);
+        List<Task> list = taskService.list(taskQueryWrapper);
+        if (!list.isEmpty()){
+            for (Task task : list) {
+                List<String> executorIdList=new ArrayList<>();
+                String executorId = task.getExecutorId();
+                if (!StringUtils.isEmpty(executorId)){
+                    String[] split = executorId.split(",");
+                    executorIdList = Arrays.asList(split);
+                }
+
+//                重复类型 :每天:0、每周:1、每月:2、自定义周期:3、自定义日期:4
+                if (task.getRepeatType()!=null&&task.getRepeatType()==0){
+                    //获取任务重复结束 重复永不结束   1:勾选
+                    if (task.getRepeatEndNever()!=null&&task.getRepeatEndNever()==1){
+                        if (!executorIdList.isEmpty()){
+                            ArrayList<Information> informationArrayList = new ArrayList<>();
+                            for (String userId : executorIdList) {
+                                Information information = new Information();
+                                information.setUserId(userId).setMsg("任务提醒")
+                                        .setTime(LocalDateTime.now()).setChecked(0);
+                                informationArrayList.add(information);
+                            }
+                            informationService.saveBatch(informationArrayList);
+                        }
+                    }else if (task.getRepeatEndCount()!=null&&task.getRepeatEndCount()>0){
+                        LambdaQueryWrapper<TaskInformation> lqw = new LambdaQueryWrapper<>();
+                        lqw.eq(TaskInformation::getTaskId,task.getId()).eq(TaskInformation::getCompanyId,task.getCompanyId());
+                        TaskInformation taskInformation = taskInformationService.getOne(lqw);
+
+                        if (taskInformation==null){
+
+                        }
+
+                    }
+
+
+                }
+            }
+        }
+    }
+
 }
 

fhKeeper/formulahousekeeper/management-crm/src/main/java/com/management/platform/controller/TaskInformationController.java

@@ -0,0 +1,21 @@
+package com.management.platform.controller;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+ * 提示消息 前端控制器
+ * </p>
+ *
+ * @author Seyason
+ * @since 2024-07-04
+ */
+@RestController
+@RequestMapping("/task-information")
+public class TaskInformationController {
+
+}
+

fhKeeper/formulahousekeeper/management-crm/src/main/java/com/management/platform/entity/TaskInformation.java

@@ -0,0 +1,57 @@
+package com.management.platform.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableField;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 提示消息
+ * </p>
+ *
+ * @author Seyason
+ * @since 2024-07-04
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class TaskInformation extends Model<TaskInformation> {
+
+    private static final long serialVersionUID=1L;
+
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 任务id
+     */
+    @TableField("task_id")
+    private Integer taskId;
+
+    /**
+     * 公司id
+     */
+    @TableField("company_id")
+    private Integer companyId;
+
+    /**
+     * 还要重复多少次:-1代表结束了
+     */
+    @TableField("count")
+    private Integer count;
+
+
+    @Override
+    protected Serializable pkVal() {
+        return this.id;
+    }
+
+}

fhKeeper/formulahousekeeper/management-crm/src/main/java/com/management/platform/mapper/TaskInformationMapper.java

@@ -0,0 +1,16 @@
+package com.management.platform.mapper;
+
+import com.management.platform.entity.TaskInformation;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 提示消息 Mapper 接口
+ * </p>
+ *
+ * @author Seyason
+ * @since 2024-07-04
+ */
+public interface TaskInformationMapper extends BaseMapper<TaskInformation> {
+
+}

fhKeeper/formulahousekeeper/management-crm/src/main/java/com/management/platform/service/TaskInformationService.java

@@ -0,0 +1,16 @@
+package com.management.platform.service;
+
+import com.management.platform.entity.TaskInformation;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 提示消息 服务类
+ * </p>
+ *
+ * @author Seyason
+ * @since 2024-07-04
+ */
+public interface TaskInformationService extends IService<TaskInformation> {
+
+}

fhKeeper/formulahousekeeper/management-crm/src/main/java/com/management/platform/service/impl/TaskInformationServiceImpl.java

@@ -0,0 +1,20 @@
+package com.management.platform.service.impl;
+
+import com.management.platform.entity.TaskInformation;
+import com.management.platform.mapper.TaskInformationMapper;
+import com.management.platform.service.TaskInformationService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 提示消息 服务实现类
+ * </p>
+ *
+ * @author Seyason
+ * @since 2024-07-04
+ */
+@Service
+public class TaskInformationServiceImpl extends ServiceImpl<TaskInformationMapper, TaskInformation> implements TaskInformationService {
+
+}

fhKeeper/formulahousekeeper/management-crm/src/main/resources/mapper/TaskInformationMapper.xml

@@ -0,0 +1,18 @@
+<?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.management.platform.mapper.TaskInformationMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.management.platform.entity.TaskInformation">
+        <id column="id" property="id" />
+        <result column="task_id" property="taskId" />
+        <result column="company_id" property="companyId" />
+        <result column="count" property="count" />
+    </resultMap>
+
+    <!-- 通用查询结果列 -->
+    <sql id="Base_Column_List">
+        id, task_id, company_id, count
+    </sql>
+
+</mapper>