package org.jeecg.modules.dnc.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.apache.shiro.SecurityUtils;
|
import org.flowable.common.engine.api.FlowableException;
|
import org.flowable.engine.TaskService;
|
import org.flowable.identitylink.api.IdentityLink;
|
import org.flowable.task.api.Task;
|
import org.jeecg.common.api.vo.Result;
|
import org.jeecg.common.system.vo.LoginUser;
|
import org.jeecg.common.util.DateUtils;
|
import org.jeecg.modules.dnc.constant.DocAttributionTypeEnum;
|
import org.jeecg.modules.dnc.entity.*;
|
import org.jeecg.modules.dnc.mapper.GuideCardBatchMapper;
|
import org.jeecg.modules.dnc.response.ActivitiCode;
|
import org.jeecg.modules.dnc.response.CommonCode;
|
import org.jeecg.modules.dnc.response.UcenterCode;
|
import org.jeecg.modules.dnc.service.*;
|
import org.jeecg.modules.dnc.utils.ValidateUtil;
|
import org.jeecg.modules.dncFlow.constant.GuideCardBatchEnum;
|
import org.jeecg.modules.dncFlow.entity.DispatchFile;
|
import org.jeecg.modules.dncFlow.vo.AssignEquipmentFileStreamVo;
|
import org.jeecg.modules.dncFlow.vo.GuideCardBatchFlowTaskVo;
|
import org.jeecg.modules.flowable.apithird.business.entity.FlowMyBusiness;
|
import org.jeecg.modules.flowable.apithird.business.service.IFlowMyBusinessService;
|
import org.jeecg.modules.flowable.apithird.service.FlowCallBackServiceI;
|
import org.jeecg.modules.flowable.apithird.service.FlowCommonService;
|
import org.jeecg.modules.flowable.service.IFlowDefinitionService;
|
import org.jeecg.modules.flowable.service.IFlowTaskService;
|
import org.jeecg.modules.system.service.ISysDictService;
|
import org.jeecg.modules.system.service.ISysUserRoleService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.interceptor.TransactionAspectSupport;
|
|
import javax.annotation.Resource;
|
import java.util.*;
|
|
/**
|
* @Description: nc文件对应数控程序加工确认表
|
* @Author: jeecg-boot
|
* @Date: 2025-05-27
|
* @Version: V1.0
|
*/
|
@Service("IGuideCardBatchService")
|
public class GuideCardBatchServiceImpl extends ServiceImpl<GuideCardBatchMapper, GuideCardBatch> implements IGuideCardBatchService , FlowCallBackServiceI {
|
|
@Autowired
|
private ISysDictService sysDictService;
|
|
@Autowired
|
private IDocInfoService docInfoService;
|
|
@Autowired
|
private IPartsInfoService partsInfoService;
|
|
@Autowired
|
private IProcessStreamService processStreamService;
|
|
@Autowired
|
private IWorkStepService workStepService;
|
|
@Autowired
|
private IDeviceTypeService deviceTypeService;
|
|
@Resource
|
private FlowCommonService flowCommonService;
|
@Resource
|
private IFlowDefinitionService flowDefinitionService;
|
@Autowired
|
private IFlowTaskService flowTaskService;
|
@Autowired
|
private TaskService taskService;
|
@Autowired
|
private IFlowMyBusinessService flowMyBusinessService;
|
@Autowired
|
private ISysUserRoleService sysUserRoleService;
|
/**
|
* 生成流水号
|
* @param code
|
* @return
|
*/
|
@Override
|
public String getSerialNumber(String code) {
|
// 事件编号格式：年份后两位 + 单位编码 + 操作工账号 + 流水号（4位）
|
LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
// 获取当前年份后两位
|
String yearSuffix = DateUtils.formatDate(new Date(), "yy");
|
|
// 查询当年所有记录
|
QueryWrapper<GuideCardBatch> wrapper = new QueryWrapper<>();
|
wrapper.apply("YEAR(create_time) = YEAR(GETDATE())");
|
wrapper.isNotNull("serial_number");
|
wrapper.orderByDesc("SUBSTRING(serial_number, LEN(serial_number)-3, 4)");
|
|
List<GuideCardBatch> list = this.list(wrapper);
|
|
// 生成流水号逻辑
|
String serialSuffix;
|
if (!list.isEmpty()) {
|
// 提取最新流水号的后四位
|
String lastSerial = list.get(0).getSerialNumber();
|
String lastSuffix = lastSerial.substring(lastSerial.length() - 4);
|
|
// 流水号自增（处理9999溢出）
|
int nextNum = Integer.parseInt(lastSuffix) + 1;
|
serialSuffix = String.format("%04d", nextNum > 9999 ? 1 : nextNum); // 超过9999则重置为0001
|
} else {
|
serialSuffix = "0001"; // 当年无记录则初始化
|
}
|
|
// 拼接完整编号
|
return yearSuffix+"-"+ code+"-"+ user.getUsername()+"-"+ serialSuffix;
|
}
|
|
/**
|
* 导入NC文件默认产生nc文件对应数控程序加工确认表
|
* @param docId
|
* @return
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public boolean importGuideCardBatch(String docId,String attributionId,Integer attributionType){
|
LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
DocInfo docInfo=docInfoService.getById(docId);
|
if (docInfo==null){
|
return false;
|
}
|
PartsInfo partsInfo=new PartsInfo();
|
ProcessStream processStream;
|
WorkStep workStep;
|
DeviceType deviceType;
|
GuideCardBatch guideCardBatch=new GuideCardBatch();
|
if (DocAttributionTypeEnum.PROCESS.getCode().equals(attributionType)){
|
//工序设备类
|
deviceType=deviceTypeService.getById(attributionId);
|
if (deviceType==null){
|
return false;
|
}
|
processStream=processStreamService.getById(deviceType.getAttributionId());
|
if (processStream==null){
|
return false;
|
}
|
guideCardBatch.setProcessWorkCode(processStream.getProcessCode());
|
partsInfo=partsInfoService.getById(processStream.getPartsId());
|
}else if (DocAttributionTypeEnum.WORKSITE.getCode().equals(attributionType)){
|
//工步设备类
|
deviceType=deviceTypeService.getById(attributionId);
|
if (deviceType==null){
|
return false;
|
}
|
workStep=workStepService.getById(deviceType.getAttributionId());
|
if (workStep==null){
|
return false;
|
}
|
guideCardBatch.setProcessWorkCode(workStep.getStepCode());
|
partsInfo=partsInfoService.getById(workStep.getPartsId());
|
}
|
if (partsInfo==null){
|
return false;
|
}
|
guideCardBatch.setDocId(docId);
|
guideCardBatch.setSerialNumber(getSerialNumber("C140"));
|
guideCardBatch.setUnit(sysDictService.queryDictTextByKey("unit_code", "C140"));
|
guideCardBatch.setDocName(docInfo.getDocName());
|
guideCardBatch.setPartsCode(partsInfo.getPartsCode());
|
guideCardBatch.setPartsName(partsInfo.getPartsName());
|
guideCardBatch.setMaterielDesp(partsInfo.getMaterielDesp());
|
guideCardBatch.setCompiler(user.getUsername());
|
guideCardBatch.setCreateTime(new Date());
|
return this.save(guideCardBatch);
|
}
|
|
/**
|
* 发起确认流程
|
* @param id
|
* @return
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Result<?> startGuideCardBatch(String id){
|
LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
//获取程序加工确认表
|
GuideCardBatch guideCardBatch=this.getById(id);
|
if (guideCardBatch==null) {
|
return Result.ok("未找到对应的程序加工确认表");
|
}
|
Result result=reStartDispatchFile(id);
|
if (result==null) {
|
//填充数据
|
guideCardBatch.setCompiler(user.getUsername());
|
guideCardBatch.setCompilerTime(new Date());
|
guideCardBatch.setFlowStatus(GuideCardBatchEnum.VERIFY.getCode());
|
this.updateById(guideCardBatch);
|
System.out.println("程序加工确认表 确认流程：" + guideCardBatch.getId());
|
flowCommonService.initActBusiness("流水号："+guideCardBatch.getSerialNumber()+" 程序加工确认表进行确认流程",
|
guideCardBatch.getId(), "IGuideCardBatchService", "nc_guide_card_batch", null);
|
Map<String, Object> variables = new HashMap<>();
|
variables.put("dataId", guideCardBatch.getId());
|
variables.put("organization", "用户"+user.getRealname()+"发起流程");
|
variables.put("comment", "用户"+user.getRealname()+"发起流程");
|
variables.put("proofreading",true);
|
Result flowResult= flowDefinitionService.startProcessInstanceByKey("nc_guide_card_batch", variables);
|
if (!flowResult.isSuccess()) {
|
guideCardBatch.setCompiler(null);
|
guideCardBatch.setCompilerTime(null);
|
this.updateById(guideCardBatch);
|
}
|
return flowResult;
|
}else {
|
return result;
|
}
|
}
|
|
|
/**
|
* 重新启动
|
* @param id
|
*/
|
@Override
|
@Transactional(rollbackFor = {Exception.class})
|
public Result<?> reStartDispatchFile(String id) {
|
GuideCardBatch guideCardBatch=this.getById(id);
|
if (guideCardBatch!=null){
|
if (!guideCardBatch.getFlowStatus().equals(GuideCardBatchEnum.VERIFY.getCode())){
|
//重新启动流程
|
try {
|
// 1. 获取当前用户并校验登录状态
|
LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
if (user == null) {
|
return Result.error("用户未登录");
|
}
|
|
// 2. 查询流程业务记录（处理空结果）
|
List<FlowMyBusiness> businessList = flowMyBusinessService.list(
|
new QueryWrapper<FlowMyBusiness>()
|
.eq("data_id", guideCardBatch.getId())
|
);
|
if (businessList.isEmpty()) {
|
return Result.error("流程记录不存在");
|
}
|
FlowMyBusiness flowMyBusiness = businessList.get(0);
|
|
// 3. 校验用户是否为候选处理人
|
List<String> todoUsers = JSON.parseArray(flowMyBusiness.getTodoUsers(), String.class);
|
if (todoUsers == null || !todoUsers.contains(user.getUsername())) {
|
return Result.error("用户无权操作此任务");
|
}
|
|
// 4. 认领任务（处理已被认领的情况）
|
String taskId = flowMyBusiness.getTaskId();
|
Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
|
if (task == null) {
|
return Result.error("任务不存在或已完成");
|
}
|
if (task.getAssignee() != null && !task.getAssignee().equals(user.getUsername())) {
|
return Result.error("任务已被他人认领");
|
}
|
taskService.claim(taskId, user.getUsername());
|
|
// 5. 完成任务并传递变量
|
Map<String, Object> variables = new HashMap<>();
|
variables.put("dataId", flowMyBusiness.getDataId());
|
variables.put("organization","重新发起流程");
|
variables.put("assignee", user.getUsername());
|
variables.put("comment", "重新发起流程");
|
taskService.complete(taskId, variables);
|
|
// 6. 获取下一任务并更新业务记录
|
List<Task> nextTasks = taskService.createTaskQuery()
|
.processInstanceId(flowMyBusiness.getProcessInstanceId())
|
.list();
|
if (!nextTasks.isEmpty()) {
|
Task nextTask = nextTasks.get(0); // 假设取第一个任务
|
flowMyBusiness.setTaskId(nextTask.getId());
|
flowMyBusiness.setTaskName(nextTask.getName());
|
|
// 动态获取下一节点候选人（示例）
|
List<String> nextTodoUsers = getNextTaskCandidates(nextTask.getId());
|
flowMyBusiness.setTodoUsers(JSON.toJSONString(nextTodoUsers));
|
} else {
|
// 流程已结束，清空任务信息
|
flowMyBusiness.setTaskId(null);
|
flowMyBusiness.setTaskName(null);
|
flowMyBusiness.setTodoUsers(null);
|
}
|
flowMyBusinessService.updateById(flowMyBusiness);
|
guideCardBatch.setFlowStatus(GuideCardBatchEnum.VERIFY.getCode());
|
this.updateById(guideCardBatch);
|
return Result.ok("流程重启成功");
|
} catch (FlowableException e) {
|
return Result.error("流程操作失败: " + e.getMessage());
|
} catch (Exception e) {
|
return Result.error("系统错误: " + e.getMessage());
|
}
|
}else {
|
return null;
|
}
|
}
|
return Result.error("数据不存在");
|
}
|
|
// 辅助方法：获取下一任务的所有候选信息（处理人、候选用户、候选组）
|
private List<String> getNextTaskCandidates(String taskId) {
|
List<IdentityLink> links = taskService.getIdentityLinksForTask(taskId);
|
List<String> candidates = new ArrayList<>();
|
|
// 1. 获取直接处理人（assignee）
|
links.stream()
|
.filter(link -> "assignee".equals(link.getType()))
|
.map(IdentityLink::getUserId)
|
.filter(Objects::nonNull)
|
.forEach(candidates::add);
|
|
// 2. 获取候选用户和候选组
|
links.stream()
|
.filter(link -> "candidate".equals(link.getType()))
|
.forEach(link -> {
|
if (link.getUserId() != null) {
|
// 候选用户直接添加
|
candidates.add(link.getUserId());
|
} else if (link.getGroupId() != null) {
|
// 候选组转换为实际用户（示例逻辑，需根据业务实现）
|
List<String> groupUsers = convertGroupToUsers(link.getGroupId());
|
candidates.addAll(groupUsers);
|
}
|
});
|
|
return candidates;
|
}
|
|
// 示例方法：将候选组ID转换为用户列表（需自定义实现）
|
private List<String> convertGroupToUsers(String groupId) {
|
// 实际业务中调用服务接口获取组成员
|
return sysUserRoleService.getUserNameByRoleId(groupId);
|
}
|
|
|
/**
|
* 流程节点审核
|
* @param guideCardBatchFlowTaskVo
|
* @return
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Result<?> auditGuideCardBatch(GuideCardBatchFlowTaskVo guideCardBatchFlowTaskVo){
|
LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
try {
|
// 参数校验
|
if (!ValidateUtil.validateString(guideCardBatchFlowTaskVo.getTaskId()) || !ValidateUtil.validateString(guideCardBatchFlowTaskVo.getDataId())) {
|
return Result.error(CommonCode.INVALID_PARAM.toString());
|
}
|
String userId = user.getId();
|
guideCardBatchFlowTaskVo.setAssignee(user.getUsername());
|
if (!ValidateUtil.validateString(userId)) {
|
return Result.error(UcenterCode.UCENTER_ACCOUNT_NOT_EXIST.toString());
|
}
|
|
// 数据查询
|
GuideCardBatch guideCardBatch = this.getById(guideCardBatchFlowTaskVo.getDataId());
|
if (guideCardBatch == null) {
|
return Result.error(CommonCode.INVALID_PARAM.toString());
|
}
|
DocInfo docInfo = docInfoService.getById(guideCardBatch.getDocId());
|
if (docInfo == null) {
|
return Result.error(ActivitiCode.ACT_DOC_ERROR.toString());
|
}
|
|
// 2. 查询流程业务记录（处理空结果）
|
List<FlowMyBusiness> businessList = flowMyBusinessService.list(
|
new QueryWrapper<FlowMyBusiness>()
|
.eq("process_instance_id", guideCardBatchFlowTaskVo.getInstanceId())
|
);
|
if (businessList.isEmpty()) {
|
return Result.error("流程记录不存在");
|
}
|
FlowMyBusiness flowMyBusiness = businessList.get(0);
|
|
// 3. 校验用户是否为候选处理人
|
List<String> todoUsers = JSON.parseArray(flowMyBusiness.getTodoUsers(), String.class);
|
if (todoUsers == null || !todoUsers.contains(user.getUsername())) {
|
return Result.error("用户无权操作此任务");
|
}
|
|
// 4. 认领任务（处理已被认领的情况）
|
String taskId = flowMyBusiness.getTaskId();
|
Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
|
if (task == null) {
|
return Result.error("任务不存在或已完成");
|
}
|
if (task.getAssignee() != null && !task.getAssignee().equals(user.getUsername())) {
|
return Result.error("任务已被他人认领");
|
}
|
taskService.claim(taskId, user.getUsername());
|
|
// 设置流程变量
|
Map<String, Object> values = new HashMap<>();
|
values.put("dataId", guideCardBatch.getId());
|
values.put("assignee", userId);
|
values.put("comment", guideCardBatchFlowTaskVo.getComment());
|
values.put("organization", guideCardBatchFlowTaskVo.getComment());
|
if (guideCardBatchFlowTaskVo.getCheckType() != null) {
|
values.put("checkType", guideCardBatchFlowTaskVo.getCheckType());
|
}
|
if (guideCardBatchFlowTaskVo.getConfirmType() != null) {
|
values.put("confirmType", guideCardBatchFlowTaskVo.getConfirmType());
|
}
|
if (guideCardBatchFlowTaskVo.getApproveType() != null) {
|
values.put("approveType", guideCardBatchFlowTaskVo.getApproveType());
|
}
|
guideCardBatchFlowTaskVo.setValues(values);
|
// 完成流程任务
|
Result result = flowTaskService.complete(guideCardBatchFlowTaskVo);
|
if (result.isSuccess()) {
|
if (guideCardBatchFlowTaskVo.getCheckType() != null) {
|
if (guideCardBatchFlowTaskVo.getCheckType()){
|
guideCardBatch.setFlowStatus(GuideCardBatchEnum.CONFIRM.getCode());
|
guideCardBatch.setProofreader(user.getUsername());
|
guideCardBatch.setProofreaderTime(new Date());
|
}else {
|
guideCardBatch.setFlowStatus(GuideCardBatchEnum.PREPARE.getCode());
|
}
|
}
|
if (guideCardBatchFlowTaskVo.getConfirmType() != null) {
|
if (guideCardBatchFlowTaskVo.getConfirmType()){
|
guideCardBatch.setFlowStatus(GuideCardBatchEnum.APPROVE.getCode());
|
guideCardBatch.setOperator(user.getUsername());
|
guideCardBatch.setInspectionTime(new Date());
|
guideCardBatch.setInspectionOpinion(guideCardBatchFlowTaskVo.getInspectionOpinion());
|
}else {
|
guideCardBatch.setFlowStatus(GuideCardBatchEnum.PREPARE.getCode());
|
}
|
}
|
if (guideCardBatchFlowTaskVo.getApproveType() != null) {
|
if (guideCardBatchFlowTaskVo.getApproveType()){
|
guideCardBatch.setFlowStatus(GuideCardBatchEnum.COMPLETE.getCode());
|
guideCardBatch.setApprover(user.getUsername());
|
guideCardBatch.setApproverTime(new Date());
|
}else {
|
guideCardBatch.setFlowStatus(GuideCardBatchEnum.PREPARE.getCode());
|
}
|
}
|
this.updateById(guideCardBatch);
|
} else {
|
return result;
|
}
|
return Result.OK("操作成功");
|
} catch (Exception e) {
|
// 设置事务回滚
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
return Result.error("操作失败：" + e.getMessage());
|
}
|
}
|
|
@Override
|
public void afterFlowHandle(FlowMyBusiness business) {
|
business.getTaskNameId();//接下来审批的节点
|
business.getValues();//前端传进来的参数
|
business.getActStatus();
|
}
|
|
@Override
|
public Object getBusinessDataById(String dataId) {
|
return this.getById(dataId);
|
}
|
|
@Override
|
public Map<String, Object> flowValuesOfTask(String taskNameId, Map<String, Object> values) {
|
return null;
|
}
|
|
@Override
|
public List<String> flowCandidateUsernamesOfTask(String taskNameId, Map<String, Object> values) {
|
//业务是否干预流程，业务干预，流程干预，指定人员进行处理
|
return null;
|
}
|
}
|
