Compare commits
No commits in common. "837af9a7c843e8f3aa7f507ef9dbf063eed18a91" and "6ef1fe3f1ab58c0e1de7085c561bce7ea0eabe3c" have entirely different histories.
837af9a7c8
...
6ef1fe3f1a
@ -1,35 +0,0 @@
|
|||||||
package cn.iocoder.yudao.module.bpm.controller.admin.oa.vo.attachment;
|
|
||||||
|
|
||||||
import cn.iocoder.yudao.framework.common.pojo.UploadUserFile;
|
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
|
||||||
import lombok.Data;
|
|
||||||
import lombok.EqualsAndHashCode;
|
|
||||||
import lombok.ToString;
|
|
||||||
|
|
||||||
import javax.validation.constraints.NotNull;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 功能描述 补充附件请求类
|
|
||||||
*
|
|
||||||
* @author: yj
|
|
||||||
* @date: 2025年06月26日 14:41
|
|
||||||
*/
|
|
||||||
@Schema(description = "管理后台 - 补充附件 Request VO")
|
|
||||||
@Data
|
|
||||||
@EqualsAndHashCode()
|
|
||||||
@ToString(callSuper = true)
|
|
||||||
public class BpmOAAttachmentReqVO {
|
|
||||||
|
|
||||||
@Schema(description = "流程业务ID", requiredMode = Schema.RequiredMode.REQUIRED)
|
|
||||||
@NotNull(message = "流程业务ID")
|
|
||||||
private Long processBusinessId ;
|
|
||||||
|
|
||||||
@Schema(description = "流程类型", requiredMode = Schema.RequiredMode.REQUIRED)
|
|
||||||
private String processType;
|
|
||||||
|
|
||||||
@Schema(description = "上传文件(包括历史的附件)", requiredMode = Schema.RequiredMode.REQUIRED)
|
|
||||||
private List<UploadUserFile> fileItems;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
@ -1,30 +1,18 @@
|
|||||||
package cn.iocoder.yudao.module.bpm.controller.admin.task;
|
package cn.iocoder.yudao.module.bpm.controller.admin.task;
|
||||||
|
|
||||||
import cn.iocoder.yudao.framework.common.exception.ServiceException;
|
|
||||||
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
|
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
|
||||||
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
||||||
import cn.iocoder.yudao.framework.datapermission.core.annotation.DataPermission;
|
import cn.iocoder.yudao.framework.datapermission.core.annotation.DataPermission;
|
||||||
import cn.iocoder.yudao.module.bpm.controller.admin.oa.BpmOALeaveController;
|
|
||||||
import cn.iocoder.yudao.module.bpm.controller.admin.oa.vo.attachment.BpmOAAttachmentReqVO;
|
|
||||||
import cn.iocoder.yudao.module.bpm.controller.admin.oa.vo.print.BpmProcessInstancePrintDataReqVO;
|
import cn.iocoder.yudao.module.bpm.controller.admin.oa.vo.print.BpmProcessInstancePrintDataReqVO;
|
||||||
import cn.iocoder.yudao.module.bpm.controller.admin.oa.vo.print.BpmProcessInstancePrintDataRespVO;
|
import cn.iocoder.yudao.module.bpm.controller.admin.oa.vo.print.BpmProcessInstancePrintDataRespVO;
|
||||||
import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.instance.*;
|
import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.instance.*;
|
||||||
import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task.BpmTaskRespVO;
|
import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task.BpmTaskRespVO;
|
||||||
import cn.iocoder.yudao.module.bpm.convert.task.BpmTaskConvert;
|
import cn.iocoder.yudao.module.bpm.convert.task.BpmTaskConvert;
|
||||||
import cn.iocoder.yudao.module.bpm.dal.dataobject.financialpayment.FinancialPaymentDO;
|
import cn.iocoder.yudao.module.bpm.dal.dataobject.financialpayment.FinancialPaymentDO;
|
||||||
import cn.iocoder.yudao.module.bpm.dal.dataobject.oa.BpmOALeaveDO;
|
|
||||||
import cn.iocoder.yudao.module.bpm.dal.dataobject.oa.BpmOAPetitionDO;
|
|
||||||
import cn.iocoder.yudao.module.bpm.dal.dataobject.oa.BpmOAReimbursementDO;
|
|
||||||
import cn.iocoder.yudao.module.bpm.dal.dataobject.oa.BpmOASealDO;
|
|
||||||
import cn.iocoder.yudao.module.bpm.dal.mysql.oa.BpmOALeaveMapper;
|
|
||||||
import cn.iocoder.yudao.module.bpm.dal.mysql.oa.BpmOAPetitionMapper;
|
|
||||||
import cn.iocoder.yudao.module.bpm.dal.mysql.oa.BpmOAReimbursementMapper;
|
|
||||||
import cn.iocoder.yudao.module.bpm.dal.mysql.oa.BpmOASealMapper;
|
|
||||||
import cn.iocoder.yudao.module.bpm.enums.task.BpmProcessInstanceResultEnum;
|
import cn.iocoder.yudao.module.bpm.enums.task.BpmProcessInstanceResultEnum;
|
||||||
import cn.iocoder.yudao.module.bpm.enums.task.BpmProcessInstanceStatusEnum;
|
import cn.iocoder.yudao.module.bpm.enums.task.BpmProcessInstanceStatusEnum;
|
||||||
import cn.iocoder.yudao.module.bpm.service.financialpayment.FinancialPaymentService;
|
import cn.iocoder.yudao.module.bpm.service.financialpayment.FinancialPaymentService;
|
||||||
import cn.iocoder.yudao.module.bpm.service.message.BpmMessageService;
|
import cn.iocoder.yudao.module.bpm.service.message.BpmMessageService;
|
||||||
import cn.iocoder.yudao.module.bpm.service.oa.BpmOAAttachmentService;
|
|
||||||
import cn.iocoder.yudao.module.bpm.service.task.BpmProcessInstanceService;
|
import cn.iocoder.yudao.module.bpm.service.task.BpmProcessInstanceService;
|
||||||
import cn.iocoder.yudao.module.bpm.service.task.BpmTaskService;
|
import cn.iocoder.yudao.module.bpm.service.task.BpmTaskService;
|
||||||
import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
|
import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
|
||||||
@ -34,19 +22,14 @@ import io.swagger.v3.oas.annotations.Parameter;
|
|||||||
import io.swagger.v3.oas.annotations.tags.Tag;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
||||||
import org.flowable.engine.runtime.ProcessInstance;
|
import org.flowable.engine.runtime.ProcessInstance;
|
||||||
import org.flowable.task.api.Task;
|
import org.flowable.task.api.Task;
|
||||||
import org.springframework.http.ResponseEntity;
|
|
||||||
import org.springframework.security.access.prepost.PreAuthorize;
|
import org.springframework.security.access.prepost.PreAuthorize;
|
||||||
import org.springframework.validation.annotation.Validated;
|
import org.springframework.validation.annotation.Validated;
|
||||||
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.bind.annotation.*;
|
||||||
|
|
||||||
import javax.annotation.PostConstruct;
|
|
||||||
import javax.annotation.Resource;
|
import javax.annotation.Resource;
|
||||||
import javax.validation.Valid;
|
import javax.validation.Valid;
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Arrays;
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.concurrent.ConcurrentHashMap;
|
|
||||||
import java.util.stream.Collectors;
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
|
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
|
||||||
@ -206,34 +189,4 @@ public class BpmProcessInstanceController {
|
|||||||
return success(processInstanceService.getOAReportPrintData(reqVO));
|
return success(processInstanceService.getOAReportPrintData(reqVO));
|
||||||
}
|
}
|
||||||
|
|
||||||
private final Map<String, List> entityTypeMap = new ConcurrentHashMap<>();
|
|
||||||
|
|
||||||
@PostConstruct
|
|
||||||
public void init() {
|
|
||||||
// 注册支持的实体类型
|
|
||||||
entityTypeMap.put("leave", new ArrayList<Class<?>>(Arrays.asList(BpmOALeaveDO.class, BpmOALeaveMapper.class)));
|
|
||||||
entityTypeMap.put("petition", new ArrayList<Class<?>>(Arrays.asList(BpmOAPetitionDO.class, BpmOAPetitionMapper.class)));
|
|
||||||
entityTypeMap.put("reimbursement", new ArrayList<Class<?>>(Arrays.asList(BpmOAReimbursementDO.class, BpmOAReimbursementMapper.class)));
|
|
||||||
entityTypeMap.put("seal", new ArrayList<Class<?>>(Arrays.asList(BpmOASealDO.class, BpmOASealMapper.class)));
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
@Resource
|
|
||||||
private BpmOAAttachmentService bpmOAAttachmentService;
|
|
||||||
@PostMapping("/uploadAttachment")
|
|
||||||
public CommonResult<?> uploadAttachment(@Valid @RequestBody BpmOAAttachmentReqVO reqVO) {
|
|
||||||
// 解析实体类型
|
|
||||||
List<Class<?>> entityClazzs = resolveEntityType(reqVO.getProcessType());
|
|
||||||
// 调用通用服务
|
|
||||||
bpmOAAttachmentService.updateAttachment(entityClazzs, reqVO.getProcessBusinessId(), reqVO.getFileItems());
|
|
||||||
return success("附件更新成功");
|
|
||||||
}
|
|
||||||
|
|
||||||
private List<Class<?>> resolveEntityType(String typeName) {
|
|
||||||
List<Class<?>> entityClazzs = entityTypeMap.get(typeName);
|
|
||||||
if (entityClazzs == null) {
|
|
||||||
throw new ServiceException(500, "不支持的流程类型");
|
|
||||||
}
|
|
||||||
return entityClazzs;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
@ -1,18 +0,0 @@
|
|||||||
package cn.iocoder.yudao.module.bpm.service.oa;
|
|
||||||
|
|
||||||
import cn.iocoder.yudao.framework.common.pojo.UploadUserFile;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
public interface BpmOAAttachmentService {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 更新业务实体的附件信息
|
|
||||||
* @param entityClazzs 业务实体
|
|
||||||
* @param entityId 业务ID
|
|
||||||
* @param fileItems 附件数据
|
|
||||||
*/
|
|
||||||
void updateAttachment(List<Class<?>> entityClazzs, Long entityId, List<UploadUserFile> fileItems);
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
@ -1,47 +0,0 @@
|
|||||||
package cn.iocoder.yudao.module.bpm.service.oa;
|
|
||||||
|
|
||||||
import cn.hutool.extra.spring.SpringUtil;
|
|
||||||
import cn.iocoder.yudao.framework.common.exception.ServiceException;
|
|
||||||
import cn.iocoder.yudao.framework.common.pojo.UploadUserFile;
|
|
||||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|
||||||
import liquibase.pro.packaged.T;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.flowable.common.engine.impl.persistence.entity.EntityManager;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
import org.springframework.validation.annotation.Validated;
|
|
||||||
|
|
||||||
import javax.annotation.Resource;
|
|
||||||
import java.lang.reflect.Method;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
@Service
|
|
||||||
@Validated
|
|
||||||
@Slf4j
|
|
||||||
public class BpmOAAttachmentServiceImpl implements BpmOAAttachmentService {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 更新业务实体的附件信息
|
|
||||||
* @param entityClazzs 业务实体
|
|
||||||
* @param entityId 业务ID
|
|
||||||
* @param fileItems 附件数据
|
|
||||||
*/
|
|
||||||
public void updateAttachment(List<Class<?>> entityClazzs, Long entityId, List<UploadUserFile> fileItems) {
|
|
||||||
try {
|
|
||||||
// 1. 获取实体, 赋值实体类
|
|
||||||
Class doClass = entityClazzs.get(0) ;
|
|
||||||
Object entity = doClass.getDeclaredConstructor().newInstance();
|
|
||||||
Method setIdMethod = doClass.getMethod("setId", Long.class) ;
|
|
||||||
setIdMethod.invoke(entity, entityId);
|
|
||||||
Method setFileItems = doClass.getMethod("setFileItems", List.class) ;
|
|
||||||
setFileItems.invoke(entity, fileItems);
|
|
||||||
//获取MyBatist的操作类实体
|
|
||||||
Class mapperClass = entityClazzs.get(1) ;
|
|
||||||
BaseMapper mapper = (BaseMapper) SpringUtil.getBean(mapperClass);
|
|
||||||
mapper.updateById(entity);
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.error(e.getMessage());
|
|
||||||
throw new ServiceException(500, "系统异常,请联系管理员");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
@ -81,13 +81,8 @@
|
|||||||
<if test="req.level != null">
|
<if test="req.level != null">
|
||||||
AND w.level = #{req.level}
|
AND w.level = #{req.level}
|
||||||
</if>
|
</if>
|
||||||
<if test="req.createTime != null and req.createTime.length > 0">
|
<if test="req.createTime != null and req.createTime.length() > 0">
|
||||||
<if test="req.createTime[0] != null">
|
AND w.create_time BETWEEN #{req.createTime[0]} AND #{req.createTime[1]}
|
||||||
AND w.create_time >= #{req.createTime[0]}
|
|
||||||
</if>
|
|
||||||
<if test="req.createTime[1] != null">
|
|
||||||
AND w.create_time <= #{req.createTime[1]}
|
|
||||||
</if>
|
|
||||||
</if>
|
</if>
|
||||||
</where>
|
</where>
|
||||||
ORDER BY w.id DESC
|
ORDER BY w.id DESC
|
||||||
@ -133,13 +128,8 @@
|
|||||||
<if test="req.status != null">
|
<if test="req.status != null">
|
||||||
AND w.status = #{req.status}
|
AND w.status = #{req.status}
|
||||||
</if>
|
</if>
|
||||||
<if test="req.createTime != null and req.createTime.length > 0">
|
<if test="req.createTime != null and req.createTime.size() == 2">
|
||||||
<if test="req.createTime[0] != null">
|
AND w.create_time BETWEEN #{req.createTime[0]} AND #{req.createTime[1]}
|
||||||
AND w.create_time >= #{req.createTime[0]}
|
|
||||||
</if>
|
|
||||||
<if test="req.createTime[1] != null">
|
|
||||||
AND w.create_time <= #{req.createTime[1]}
|
|
||||||
</if>
|
|
||||||
</if>
|
</if>
|
||||||
</where>
|
</where>
|
||||||
ORDER BY w.id DESC
|
ORDER BY w.id DESC
|
||||||
@ -185,13 +175,8 @@
|
|||||||
<if test="req.status != null">
|
<if test="req.status != null">
|
||||||
AND w.status = #{req.status}
|
AND w.status = #{req.status}
|
||||||
</if>
|
</if>
|
||||||
<if test="req.createTime != null and req.createTime.length > 0">
|
<if test="req.createTime != null and req.createTime.size() == 2">
|
||||||
<if test="req.createTime[0] != null">
|
AND w.create_time BETWEEN #{req.createTime[0]} AND #{req.createTime[1]}
|
||||||
AND w.create_time >= #{req.createTime[0]}
|
|
||||||
</if>
|
|
||||||
<if test="req.createTime[1] != null">
|
|
||||||
AND w.create_time <= #{req.createTime[1]}
|
|
||||||
</if>
|
|
||||||
</if>
|
</if>
|
||||||
</where>
|
</where>
|
||||||
ORDER BY w.id DESC
|
ORDER BY w.id DESC
|
||||||
|
@ -49,6 +49,14 @@ public class AttendanceAddressGroupController {
|
|||||||
return success(attendanceAddressGroupService.createAttendanceAddressGroup(createReqVO));
|
return success(attendanceAddressGroupService.createAttendanceAddressGroup(createReqVO));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// @PutMapping("/update")
|
||||||
|
// @Operation(summary = "更新考勤地址组")
|
||||||
|
// @PreAuthorize("@ss.hasPermission('system:attendance-address-group:update')")
|
||||||
|
// public CommonResult<Boolean> updateAttendanceAddressGroup(@Valid @RequestBody AttendanceAddressGroupSaveReqVO updateReqVO) {
|
||||||
|
// attendanceAddressGroupService.updateAttendanceAddressGroup(updateReqVO);
|
||||||
|
// return success(true);
|
||||||
|
// }
|
||||||
|
|
||||||
@DeleteMapping("/delete")
|
@DeleteMapping("/delete")
|
||||||
@Operation(summary = "删除考勤地址组")
|
@Operation(summary = "删除考勤地址组")
|
||||||
@Parameter(name = "id", description = "编号", required = true)
|
@Parameter(name = "id", description = "编号", required = true)
|
||||||
|
Loading…
Reference in New Issue
Block a user