|
|
|
|
@ -1,5 +1,10 @@
|
|
|
|
|
package org.dromara.oa.erp.service.impl;
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.convert.Convert;
|
|
|
|
|
import cn.hutool.core.map.MapUtil;
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
import org.dromara.common.core.enums.BusinessStatusEnum;
|
|
|
|
|
import org.dromara.common.core.enums.OAStatusEnum;
|
|
|
|
|
import org.dromara.common.core.utils.MapstructUtils;
|
|
|
|
|
import org.dromara.common.core.utils.StringUtils;
|
|
|
|
|
import org.dromara.common.mybatis.core.page.TableDataInfo;
|
|
|
|
|
@ -8,6 +13,9 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
|
import com.github.yulichang.toolkit.JoinWrappers;
|
|
|
|
|
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
|
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
|
|
import org.dromara.common.tenant.helper.TenantHelper;
|
|
|
|
|
import org.dromara.workflow.api.event.ProcessEvent;
|
|
|
|
|
import org.springframework.context.event.EventListener;
|
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
import org.dromara.oa.erp.domain.bo.ErpProjectInfoBo;
|
|
|
|
|
import org.dromara.oa.erp.domain.vo.ErpProjectInfoVo;
|
|
|
|
|
@ -23,6 +31,7 @@ import org.dromara.workflow.api.domain.RemoteStartProcess;
|
|
|
|
|
import java.util.List;
|
|
|
|
|
import java.util.Map;
|
|
|
|
|
import java.util.Collection;
|
|
|
|
|
import java.util.Objects;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 项目信息Service业务层处理
|
|
|
|
|
@ -32,6 +41,7 @@ import java.util.Collection;
|
|
|
|
|
*/
|
|
|
|
|
@RequiredArgsConstructor
|
|
|
|
|
@Service
|
|
|
|
|
@Slf4j
|
|
|
|
|
public class ErpProjectInfoServiceImpl implements IErpProjectInfoService {
|
|
|
|
|
|
|
|
|
|
private final ErpProjectInfoMapper baseMapper;
|
|
|
|
|
@ -185,4 +195,30 @@ public class ErpProjectInfoServiceImpl implements IErpProjectInfoService {
|
|
|
|
|
}
|
|
|
|
|
return MapstructUtils.convert(add, ErpProjectInfoVo.class);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 总体流程监听(例如: 草稿,撤销,退回,作废,终止,已完成等)
|
|
|
|
|
*
|
|
|
|
|
* @param processEvent 参数
|
|
|
|
|
*/
|
|
|
|
|
@EventListener(condition = "#processEvent.flowCode =='xmsq'")
|
|
|
|
|
public void processHandler(ProcessEvent processEvent) {
|
|
|
|
|
TenantHelper.dynamic(processEvent.getTenantId(), () -> {
|
|
|
|
|
log.info("当前任务执行了{}", processEvent.toString());
|
|
|
|
|
ErpProjectInfo projectInfo = baseMapper.selectById(Convert.toLong(processEvent.getBusinessId()));
|
|
|
|
|
projectInfo.setFlowStatus(processEvent.getStatus());
|
|
|
|
|
Map<String, Object> params = processEvent.getParams();
|
|
|
|
|
if (MapUtil.isNotEmpty(params)) {
|
|
|
|
|
// 办理人
|
|
|
|
|
String handler = Convert.toStr(params.get("handler"));
|
|
|
|
|
}
|
|
|
|
|
if (Objects.equals(processEvent.getStatus(), BusinessStatusEnum.FINISH.getStatus())) {
|
|
|
|
|
projectInfo.setProjectStatus(OAStatusEnum.COMPLETED.getStatus());
|
|
|
|
|
} else if (Objects.equals(processEvent.getStatus(), BusinessStatusEnum.INVALID.getStatus())) {
|
|
|
|
|
projectInfo.setProjectStatus(OAStatusEnum.INVALID.getStatus());
|
|
|
|
|
}
|
|
|
|
|
baseMapper.updateById(projectInfo);
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|