Merge remote-tracking branch 'origin/main'

common/src/main/java/com/sdm/common/entity/enums/MessageTemplateEnum.java

@@ -10,7 +10,8 @@ public enum MessageTemplateEnum {
     DATA_ALERT_MANAGER("数据通知", "%s的数据存储空间已达阈值"),
     APPROVE_ALERT("审批通知", "收到一条%s消息"),
     HPC_START("作业通知", "HPC任务作业：%s，已发起%s"),
-    HPC_END("作业通知", "HPC任务作业：%s，已结束，执行结果：%s")
+    HPC_END("作业通知", "HPC任务作业：%s，已结束，执行结果：%s"),
+    TASK_OVERDUE("任务逾期通知", "任务：%s，已逾期")
     ;
 
     private final String title;

common/src/main/java/com/sdm/common/service/TaskProgressService.java

@@ -0,0 +1,35 @@
+package com.sdm.common.service;
+
+import com.sdm.common.common.SdmResponse;
+import com.sdm.common.entity.bo.DataDictionary;
+import com.sdm.common.entity.constants.TagConstant;
+import com.sdm.common.feign.impl.system.SysConfigFeignClientImpl;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import static java.util.Collections.emptyMap;
+
+@Service
+@Slf4j
+public class TaskProgressService {
+
+    @Autowired
+    private SysConfigFeignClientImpl sysConfigFeignClient;
+
+    private static final String TASK_PROGRESS_STATUS = "TASK_PROGRESS_STATUS";
+
+    public Map<String, String> getMapName() {
+        SdmResponse<List<DataDictionary>> taskProgressStatusList = sysConfigFeignClient.getDictionaryData(TASK_PROGRESS_STATUS);
+        if (!taskProgressStatusList.isSuccess() || ObjectUtils.isEmpty(taskProgressStatusList.getData())) {
+            log.error("字典信息查询失败");
+            return emptyMap();
+        }
+        return taskProgressStatusList.getData().stream().collect(Collectors.toMap(DataDictionary::getDictName, DataDictionary::getDictValue));
+    }
+}