|
@@ -14,9 +14,7 @@ import lombok.AllArgsConstructor;
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
import org.apache.commons.lang.time.DateUtils;
|
|
|
import org.springblade.common.utils.SnowFlakeUtil;
|
|
|
-import org.springblade.control.dto.TaskPlanDTO;
|
|
|
-import org.springblade.control.dto.TaskPlanStatusUpdateDTO;
|
|
|
-import org.springblade.control.dto.TaskProcessInfoDTO;
|
|
|
+import org.springblade.control.dto.*;
|
|
|
import org.springblade.control.entity.*;
|
|
|
import org.springblade.control.mapper.TaskProcessMapper;
|
|
|
import org.springblade.control.service.TaskProcessService;
|
|
@@ -538,6 +536,56 @@ public class TaskProcessServiceImpl extends BaseServiceImpl<TaskProcessMapper, T
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public boolean dataDictSubmit(TaskDataDictDTO dto) {
|
|
|
+ if (ObjectUtil.isNotEmpty(dto.getDictId())) {
|
|
|
+ //删除当前类型的审批流程
|
|
|
+ jdbcTemplate.execute("delete from c_task_process_record_dict_info where dict_id =" + dto.getDictId());
|
|
|
+
|
|
|
+ //新增审批流程
|
|
|
+ if (dto.getApproveRoleList().size() > 0) {
|
|
|
+ List<RoleUser> approveRoleList = dto.getApproveRoleList();
|
|
|
+ int sort = 1;
|
|
|
+ for (RoleUser roleUser : approveRoleList) {
|
|
|
+ jdbcTemplate.execute("insert into c_task_process_record_dict_info(id,dict_id,type,role_id,role_name,sort) values (" + SnowFlakeUtil.getId() + "," + dto.getDictId() + ",1," + roleUser.getRoleId() + ",'" + roleUser.getRoleName() + "'," + sort + ")");
|
|
|
+ sort++;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //新增抄送流程
|
|
|
+ if (dto.getCcRoleList().size() > 0) {
|
|
|
+ List<RoleUser> ccRoleList = dto.getCcRoleList();
|
|
|
+ int sort = 1;
|
|
|
+ for (RoleUser roleUser : ccRoleList) {
|
|
|
+ jdbcTemplate.execute("insert into c_task_process_record_dict_info(id,dict_id,type,role_id,role_name,sort) values (" + SnowFlakeUtil.getId() + "," + dto.getDictId() + ",2," + roleUser.getRoleId() + ",'" + roleUser.getRoleName() + "'," + sort + ")");
|
|
|
+ sort++;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Map<String, List<TaskProcessRecordDictInfo>> dataDictList(String id) {
|
|
|
+ Map<String, List<TaskProcessRecordDictInfo>> resultMap = new LinkedHashMap<>();
|
|
|
+ if (StringUtils.isNotEmpty(id)) {
|
|
|
+ List<TaskProcessRecordDictInfo> taskProcessRecordDictInfos = jdbcTemplate.query("select * from c_task_process_record_dict_info where dict_id = " + id, new BeanPropertyRowMapper<>(TaskProcessRecordDictInfo.class));
|
|
|
+ if (taskProcessRecordDictInfos.size() > 0) {
|
|
|
+ Map<Integer, List<TaskProcessRecordDictInfo>> maps = taskProcessRecordDictInfos.stream().filter(Objects::nonNull).collect(Collectors.groupingBy(TaskProcessRecordDictInfo::getType));
|
|
|
+ List<TaskProcessRecordDictInfo> taskProcessRecordDictInfos1 = maps.get(1);
|
|
|
+ if (taskProcessRecordDictInfos1 != null) {
|
|
|
+ resultMap.put("审批岗位", taskProcessRecordDictInfos1);
|
|
|
+ }
|
|
|
+ List<TaskProcessRecordDictInfo> taskProcessRecordDictInfos2 = maps.get(2);
|
|
|
+ if (taskProcessRecordDictInfos2 != null) {
|
|
|
+ resultMap.put("抄送信息", taskProcessRecordDictInfos2);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return resultMap;
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* 修改业务审批状态
|
|
|
*
|