diff --git a/src/main/java/com/lz/modules/job/task/ResultTaskNoticJob.java b/src/main/java/com/lz/modules/job/task/ResultTaskNoticJob.java
new file mode 100644
index 00000000..ab160bab
--- /dev/null
+++ b/src/main/java/com/lz/modules/job/task/ResultTaskNoticJob.java
@@ -0,0 +1,46 @@
+package com.lz.modules.job.task;
+
+import com.google.common.collect.Lists;
+import com.lz.modules.app.entity.StaffEntity;
+import com.lz.modules.app.service.StaffService;
+import com.lz.modules.job.business.DingtalkBusiness;
+import com.lz.modules.performance.enums.ResultFlowProcessEnum;
+import com.lz.modules.sys.service.app.ResultRecordService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @Author: djc
+ * @Desc:
+ * @Date: 2020/12/10 10:26
+ */
+
+@Component("resultTaskNoticJob")
+public class ResultTaskNoticJob implements ITask {
+    private Logger logger = LoggerFactory.getLogger(getClass());
+
+    @Autowired
+    DingtalkBusiness dingtalkBusiness;
+    @Autowired
+    private ResultRecordService resultRecordService;
+    @Autowired
+    private StaffService staffService;
+
+    static final List<Integer> process = Lists.newArrayList(ResultFlowProcessEnum.TARGET.getStatus(), ResultFlowProcessEnum.CONFIRM.getStatus(),
+            ResultFlowProcessEnum.DO.getStatus(), ResultFlowProcessEnum.WRITE.getStatus());
+
+    @Override
+    public void run(String params) {
+
+        List<Long> ids = resultRecordService.selectStaffIdsByFlowProcess(process);
+        List<StaffEntity> staffEntities = staffService.selectByIds(ids);
+        String res = dingtalkBusiness.sendTaskInputMsg(staffEntities);
+        logger.info("绩效任务填写通知响应：" + res);
+
+    }
+}
diff --git a/src/main/java/com/lz/modules/sys/dao/app/ResultRecordMapper.java b/src/main/java/com/lz/modules/sys/dao/app/ResultRecordMapper.java
index 316791c8..ea4c2003 100644
--- a/src/main/java/com/lz/modules/sys/dao/app/ResultRecordMapper.java
+++ b/src/main/java/com/lz/modules/sys/dao/app/ResultRecordMapper.java
@@ -112,5 +112,6 @@ public interface ResultRecordMapper extends BaseMapper<ResultRecord> {
 
     List<LevelDetailExportDto> selectLevelDetailList(@Param("departmentIds") List<String> departmentIds, @Param("startId")Long startId, @Param("scoreLevel")String scoreLevel);
 
+    List<Long> selectStaffIdsByFlowProcess(@Param("flowProcess") List<Integer> flowProcess);
 
 }
\ No newline at end of file
diff --git a/src/main/java/com/lz/modules/sys/service/app/ResultRecordService.java b/src/main/java/com/lz/modules/sys/service/app/ResultRecordService.java
index 5b568912..b0700c9a 100644
--- a/src/main/java/com/lz/modules/sys/service/app/ResultRecordService.java
+++ b/src/main/java/com/lz/modules/sys/service/app/ResultRecordService.java
@@ -131,4 +131,6 @@ public interface ResultRecordService extends IService<ResultRecord> {
 
 	R resetData(Long recordId, int clearFlag);
 
+	List<Long> selectStaffIdsByFlowProcess(List<Integer> flowProcess);
+
 }
\ No newline at end of file
diff --git a/src/main/java/com/lz/modules/sys/service/app/impl/ResultRecordServiceImpl.java b/src/main/java/com/lz/modules/sys/service/app/impl/ResultRecordServiceImpl.java
index 972a107c..67472279 100644
--- a/src/main/java/com/lz/modules/sys/service/app/impl/ResultRecordServiceImpl.java
+++ b/src/main/java/com/lz/modules/sys/service/app/impl/ResultRecordServiceImpl.java
@@ -1506,4 +1506,10 @@ public class ResultRecordServiceImpl extends ServiceImpl<ResultRecordMapper, Res
         return R.error("无数据删除");
 
     }
+
+
+    @Override
+    public List<Long> selectStaffIdsByFlowProcess(List<Integer> flowProcess) {
+        return resultRecordMapper.selectStaffIdsByFlowProcess(flowProcess);
+    }
 }
diff --git a/src/main/resources/mapper/app/ResultRecordMapper.xml b/src/main/resources/mapper/app/ResultRecordMapper.xml
index 0f15ce89..9f6dbab2 100644
--- a/src/main/resources/mapper/app/ResultRecordMapper.xml
+++ b/src/main/resources/mapper/app/ResultRecordMapper.xml
@@ -643,5 +643,15 @@
         ORDER BY all_score desc
     </select>
 
+
+    <select id="selectStaffIdsByFlowProcess" resultType="long">
+        select staff_id from lz_result_record  where is_delete = 0
+        and flow_process in (
+        <foreach collection="flowProcess" item="process" separator=",">
+            #{process}
+        </foreach>
+        )
+    </select>
+
 </mapper>