diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/esAnnualReport/service/impl/ProcessEsAnnualReportServiceImpl.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/esAnnualReport/service/impl/ProcessEsAnnualReportServiceImpl.java
index fd0425a7..ea8e98c8 100644
--- a/laws-modules/src/main/java/com/jero/modules/activiti/process/esAnnualReport/service/impl/ProcessEsAnnualReportServiceImpl.java
+++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/esAnnualReport/service/impl/ProcessEsAnnualReportServiceImpl.java
@@ -4,6 +4,8 @@ import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.jero.common.api.CommonAPI;
+import com.jero.common.api.dto.message.SendMessageDTO;
+import com.jero.common.api.vo.SendMessageAPI;
 import com.jero.common.aspect.TranslationAspect;
 import com.jero.common.constant.enums.YesOrNoEnum;
 import com.jero.common.exception.JeroBootException;
@@ -19,12 +21,14 @@ import com.jero.modules.activiti.process.esAnnualReport.mapper.ProcessEsAnnualRe
 import com.jero.modules.activiti.process.esAnnualReport.service.ProcessEsAnnualReportService;
 import com.jero.modules.activiti.process.esInitChange.entity.enums.ESPChangeType;
 import com.jero.modules.activiti.process.esInitChange.entity.enums.ESPProjectType;
+import com.jero.modules.activiti.process.esRevision.entity.HandleAdviceEnum;
 import com.jero.modules.activiti.process.fb.dto.BasicProcessInfoDTO;
 import com.jero.modules.activiti.process.fb.service.IProcessHandleService;
 import com.jero.modules.activiti.process.fb.vo.ProcessInfoVO;
 import com.jero.modules.activiti.service.ProcessAllService;
 import com.jero.modules.activiti.service.ProcessNodeLinkService;
 import com.jero.modules.activiti.util.ExcelUtils;
+import com.jero.modules.laws.common.constant.MessageTemplateCodeCommon;
 import com.jero.modules.laws.common.util.ImportUtil;
 import com.jero.modules.laws.standard.entity.LawsEnterpriseStandard;
 import com.jero.modules.laws.standard.service.ILawsEnterpriseStandardService;
@@ -91,6 +95,9 @@ public class ProcessEsAnnualReportServiceImpl extends ServiceImpl<ProcessEsAnnua
     @Resource
     private TranslationAspect translationAspect;
 
+    @Resource
+    private SendMessageAPI sendMessageAPI;
+
     @Override
     public void startProcess(AnnualReportDataVO annualReportData) {
         // 流程Key
@@ -130,7 +137,7 @@ public class ProcessEsAnnualReportServiceImpl extends ServiceImpl<ProcessEsAnnua
         Integer prcType = ProcessTypeEnum.ES_ANNUAL_REPORT.getValue();
         actFlowCommonService.updateProcessAll(processInstanceId, userId, prcName, prcMes, prcType, dueTime);
         // 执行流程发起前的操作
-        this.startRunTask(annualReportData);
+        this.startRunTask(annualReportData, processInstanceId);
     }
 
     public Map<String, Object> setVariables(AnnualReportDataVO annualReportData) {
@@ -152,8 +159,26 @@ public class ProcessEsAnnualReportServiceImpl extends ServiceImpl<ProcessEsAnnua
         return variables;
     }
 
-    public void startRunTask(AnnualReportDataVO annualReportDataVO) {
-        // TODO info部长
+    public void startRunTask(AnnualReportDataVO annualReportDataVO, String processInstanceId) {
+        ProcessAll processAll = processAllService.getByProcessInstanceId(processInstanceId);
+        // 发消息
+        CommonVO commonVO = annualReportDataVO.getCommonVO();
+        Map<String, Object> flowUser = annualReportDataVO.getFlowUser();
+        String contactUsers = (String) flowUser.get("contactUserList");
+        String processDescription = commonVO.getProcessDescription();
+        String[] contactUserList = contactUsers.split(",");
+        for (String contactUser : contactUserList) {
+            SendMessageDTO sendMessageDTO = new SendMessageDTO();
+            sendMessageDTO.setTemplateCode(MessageTemplateCodeCommon.ES_ANNUAL_REPORT_CONTACT_USER);
+            sendMessageDTO.setToUserId(contactUser);
+            Map<String, String> sendMap = new HashMap<>();
+            sendMap.put("prcNum", processAll.getPrcNum());
+            sendMap.put("prcName", processAll.getPrcName());
+            sendMap.put("description", processDescription);
+            sendMessageDTO.setMap(sendMap);
+            sendMessageAPI.sendMessage(sendMessageDTO);
+        }
+
     }
 
     @Override
diff --git a/laws-modules/src/main/java/com/jero/modules/laws/common/constant/MessageTemplateCodeCommon.java b/laws-modules/src/main/java/com/jero/modules/laws/common/constant/MessageTemplateCodeCommon.java
index cc53d148..14a950b3 100644
--- a/laws-modules/src/main/java/com/jero/modules/laws/common/constant/MessageTemplateCodeCommon.java
+++ b/laws-modules/src/main/java/com/jero/modules/laws/common/constant/MessageTemplateCodeCommon.java
@@ -27,5 +27,6 @@ public class MessageTemplateCodeCommon {
     public static final String ES_INIT_CHANGE_MAIN_DRAFT_USER_COPY = "es_init_change_main_draft_user_copy"; // 【企标立项变更】抄送主起草人
     public static final String ES_REVISION_STANDARD_RELEASE = "es_revision_standard_release"; // 【企标修订】标准发布
     public static final String ES_REVISION_ADVICE = "es_revision_advice"; // 【企标修订】征求意见
+    public static final String ES_ANNUAL_REPORT_CONTACT_USER = "es_annual_report_contact_user"; // 【企标年度制修订-各部门主动上报】部门联络人下发
 
 }