陈裕财
2 years ago
51 changed files with 261 additions and 367 deletions
-
4xm-core/src/main/java/com/xm/core/mapper/XmBranchStateHisMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmBranchTaskTypeStateMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmBudgetLaborMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmBudgetNlaborMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmCostNlaborMapper.java
-
8xm-core/src/main/java/com/xm/core/mapper/XmEnvListMapper.java
-
6xm-core/src/main/java/com/xm/core/mapper/XmIterationMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmIterationStateMapper.java
-
8xm-core/src/main/java/com/xm/core/mapper/XmMenuCommentMapper.java
-
18xm-core/src/main/java/com/xm/core/mapper/XmMenuMapper.java
-
10xm-core/src/main/java/com/xm/core/mapper/XmMenuStateMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmMyFocusMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmProductMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmProductProjectLinkMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmProductStateMapper.java
-
8xm-core/src/main/java/com/xm/core/mapper/XmProjectStateMapper.java
-
16xm-core/src/main/java/com/xm/core/mapper/XmQuestionMapper.java
-
10xm-core/src/main/java/com/xm/core/mapper/XmRecordMapper.java
-
8xm-core/src/main/java/com/xm/core/mapper/XmTaskEvalMapper.java
-
6xm-core/src/main/java/com/xm/core/mapper/XmTaskExecuserMapper.java
-
35xm-core/src/main/java/com/xm/core/mapper/XmTaskMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmTaskSbillMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmTaskSkillMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmTestCaseMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmTestCasedbMapper.java
-
12xm-core/src/main/java/com/xm/core/mapper/XmTestPlanCaseMapper.java
-
4xm-core/src/main/java/com/xm/core/mapper/XmTestPlanMapper.java
-
21xm-core/src/main/java/com/xm/core/mapper/XmWorkloadMapper.java
-
34xm-core/src/main/java/com/xm/core/service/XmAttachmentService.java
-
2xm-core/src/main/java/com/xm/core/service/XmEnvListService.java
-
171xm-core/src/main/java/com/xm/core/service/XmFileService.java
-
4xm-core/src/main/java/com/xm/core/service/XmIterationService.java
-
4xm-core/src/main/java/com/xm/core/service/XmMenuCommentService.java
-
11xm-core/src/main/java/com/xm/core/service/XmMenuOperQxService.java
-
4xm-core/src/main/java/com/xm/core/service/XmMenuService.java
-
6xm-core/src/main/java/com/xm/core/service/XmMenuStateService.java
-
2xm-core/src/main/java/com/xm/core/service/XmProductProjectLinkService.java
-
38xm-core/src/main/java/com/xm/core/service/XmProductQxService.java
-
3xm-core/src/main/java/com/xm/core/service/XmProjectContractService.java
-
38xm-core/src/main/java/com/xm/core/service/XmProjectQxService.java
-
15xm-core/src/main/java/com/xm/core/service/XmProjectService.java
-
1xm-core/src/main/java/com/xm/core/service/XmProjectTaskTypeStateService.java
-
12xm-core/src/main/java/com/xm/core/service/XmQuestionService.java
-
8xm-core/src/main/java/com/xm/core/service/XmRecordService.java
-
4xm-core/src/main/java/com/xm/core/service/XmTaskEvalService.java
-
10xm-core/src/main/java/com/xm/core/service/XmTaskExecuserService.java
-
1xm-core/src/main/java/com/xm/core/service/XmTaskSbillDetailService.java
-
29xm-core/src/main/java/com/xm/core/service/XmTaskService.java
-
1xm-core/src/main/java/com/xm/core/service/XmTestCaseService.java
-
2xm-core/src/main/java/com/xm/core/service/XmTestPlanCaseService.java
-
2xm-core/src/main/java/com/xm/core/service/XmWorkloadService.java
@ -1,34 +0,0 @@ |
|||
package com.xm.core.service; |
|||
|
|||
import com.mdp.core.service.BaseService; |
|||
import com.xm.core.entity.XmAttachment; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import java.util.List; |
|||
|
|||
/** |
|||
* 父类已经支持增删改查操作,因此,即使本类什么也不写,也已经可以满足一般的增删改查操作了.<br> |
|||
* 组织 com.qqkj 顶级模块 oa 大模块 xm 小模块 <br> |
|||
* 实体 XmAttachment 表 XM.xm_attachment 当前主键(包括多主键): id; |
|||
***/ |
|||
@Service("xm.core.xmAttachmentService") |
|||
public class XmAttachmentService extends BaseService<XmAttachmentMapper,XmAttachment> { |
|||
|
|||
public void insertOrUpdate(String originId,String originType, List<XmAttachment> attachmentList) { |
|||
XmAttachment del = new XmAttachment(); |
|||
del.setOriginId(originId); |
|||
del.setOriginType(originType); |
|||
this.baseMapper.deleteByOrigin(del); |
|||
if(attachmentList.size() > 0) { |
|||
attachmentList.forEach(attach->{ |
|||
attach.setOriginId(originId); |
|||
attach.setOriginType(originType); |
|||
this.insert(attach); |
|||
}); |
|||
} |
|||
} |
|||
|
|||
/** 请在此类添加自定义函数 */ |
|||
|
|||
} |
|||
|
|||
@ -1,171 +0,0 @@ |
|||
package com.xm.core.service; |
|||
|
|||
import com.mdp.core.entity.Tips; |
|||
import com.mdp.core.err.BizException; |
|||
import com.mdp.core.service.BaseService; |
|||
import com.mdp.safe.client.entity.User; |
|||
import com.mdp.safe.client.utils.LoginUtils; |
|||
import com.xm.core.entity.XmFile; |
|||
import com.xm.core.vo.XmFileVo; |
|||
import org.springframework.beans.BeanUtils; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
import org.springframework.util.StringUtils; |
|||
|
|||
import java.util.Date; |
|||
import java.util.HashMap; |
|||
import java.util.List; |
|||
import java.util.Map; |
|||
|
|||
/** |
|||
* 父类已经支持增删改查操作,因此,即使本类什么也不写,也已经可以满足一般的增删改查操作了.<br> |
|||
* 组织 com.qqkj 顶级模块 oa 大模块 xm 小模块 <br> |
|||
* 实体 XmFile 表 XM.xm_file 当前主键(包括多主键): id; |
|||
***/ |
|||
@Service("xm.core.xmFileService") |
|||
public class XmFileService extends BaseService<XmFileMapper,XmFile> { |
|||
|
|||
final String Type = "文档"; |
|||
|
|||
@Autowired |
|||
XmAttachmentService xmAttachmentService; |
|||
|
|||
@Autowired |
|||
XmRecordService xmRecordService; |
|||
|
|||
|
|||
/** 请在此类添加自定义函数 */ |
|||
|
|||
public List<Map<String,Object>> getFile(Map<String,Object> params) { |
|||
List<Map<String,Object>> fs = this.selectListMapByWhere(params); |
|||
return fs; |
|||
} |
|||
|
|||
public Map<String,Object> updateFile(XmFileVo xmFileVo){ |
|||
XmFile xmFile = new XmFile(); |
|||
BeanUtils.copyProperties(xmFileVo,xmFile); |
|||
this.updateSomeFieldByPk(xmFile); |
|||
if(xmFileVo.getAttachment()!=null && xmFileVo.getAttachment().size()>0){ |
|||
xmAttachmentService.insertOrUpdate(xmFileVo.getId(),Type,xmFileVo.getAttachment()); |
|||
} |
|||
return null; |
|||
} |
|||
|
|||
|
|||
public XmFileVo addFile(XmFileVo xmFileVo){ |
|||
Tips tips = new Tips(); |
|||
if(StringUtils.isEmpty(xmFileVo.getId())) { |
|||
xmFileVo.setId(this.createKey("id")); |
|||
}else{ |
|||
XmFile xmFileQuery = new XmFile(xmFileVo.getId()); |
|||
if(this.countByWhere(xmFileQuery)>0){ |
|||
tips.setFailureMsg("编号重复，请修改编号再提交"); |
|||
throw new BizException(tips); |
|||
} |
|||
} |
|||
|
|||
User user = LoginUtils.getCurrentUserInfo(); |
|||
xmFileVo.setCreateUserid(user.getUserid()); |
|||
xmFileVo.setCreateUsername(user.getUsername()); |
|||
xmFileVo.setCreateTime(new Date()); |
|||
|
|||
XmFile xmFile = new XmFile(); |
|||
BeanUtils.copyProperties(xmFileVo,xmFile); |
|||
this.insert(xmFile); |
|||
if(xmFileVo.getAttachment()!=null && xmFileVo.getAttachment().size()>0){ |
|||
xmAttachmentService.insertOrUpdate(xmFileVo.getId(),Type,xmFileVo.getAttachment()); |
|||
} |
|||
xmRecordService.addXmProjectRecord(xmFileVo.getProjectId(), "项目-增加文档", "增加文档"+xmFile.getName()); |
|||
return xmFileVo; |
|||
} |
|||
|
|||
public void deleteFile(XmFile xmFile) { |
|||
this.deleteByPk(xmFile); |
|||
xmRecordService.addXmProjectRecord(xmFile.getProjectId(), "项目-删除文档", "删除文档"+xmFile.getName(),xmFile.getId(),null); |
|||
} |
|||
|
|||
|
|||
/** |
|||
* 流程审批过程中回调该接口，更新业务数据 |
|||
* 如果发起流程时上送了restUrl，则无论流程中是否配置了监听器都会在流程发生以下事件时推送数据过来 |
|||
* eventName: PROCESS_STARTED 流程启动完成 全局 |
|||
* PROCESS_COMPLETED 流程正常结束 全局 |
|||
* PROCESS_CANCELLED 流程删除 全局 |
|||
* create 人工任务启动 |
|||
* complete 人工任务完成 |
|||
* assignment 人工任务分配给了具体的人 |
|||
* delete 人工任务被删除 |
|||
* TASK_COMPLETED_FORM_DATA_UPDATE 人工任务提交完成后，智能表单数据更新 |
|||
* |
|||
* 其中 create/complete/assignment/delete事件是需要在模型中人工节点上配置了委托代理表达式 ${taskBizCallListener}才会推送过来。 |
|||
* 在人工任务节点上配置 任务监听器 建议事件为 complete,其它assignment/create/complete/delete也可以，一般建议在complete,委托代理表达式 ${taskBizCallListener} |
|||
* |
|||
* @param flowVars {flowBranchId,agree,procInstId,startUserid,assignee,actId,taskName,mainTitle,branchId,bizKey,commentMsg,eventName,modelKey} 等 |
|||
* @return 如果tips.isOk==false，将影响流程提交 |
|||
**/ |
|||
public void processApprova(Map<String, Object> flowVars) { |
|||
String eventName=(String) flowVars.get("eventName"); |
|||
String agree=(String) flowVars.get("agree"); |
|||
String branchId=(String) flowVars.get("branchId"); |
|||
String fileId=(String) flowVars.get("fileId"); |
|||
String bizKey=(String) flowVars.get("bizKey"); |
|||
if("xm_file_approva".equals(bizKey) ) { |
|||
}else { |
|||
throw new BizException("不支持的业务,请上送业务编码【bizKey】参数"); |
|||
} |
|||
if("complete".equals(eventName)) { |
|||
if("1".equals(agree)) { |
|||
this.updateFlowStateByProcInst("", flowVars); |
|||
}else { |
|||
this.updateFlowStateByProcInst("", flowVars); |
|||
} |
|||
}else { |
|||
if("PROCESS_STARTED".equals(eventName)) { |
|||
Map<String,Object> bizQuery=new HashMap<>(); |
|||
bizQuery.put("fileId", fileId); |
|||
if(StringUtils.isEmpty(fileId)) { |
|||
throw new BizException("请上送fileId"); |
|||
} |
|||
if(StringUtils.isEmpty(branchId)) { |
|||
throw new BizException("请上送branchId"); |
|||
} |
|||
List<Map<String,Object>> bizList=this.selectListMapByWhere(bizQuery); |
|||
if(bizList==null || bizList.size()==0) { |
|||
throw new BizException("没有找到对应文档,文档为【"+fileId+"】"); |
|||
}else { |
|||
Map<String,Object> bizObject=bizList.get(0); |
|||
if("1".equals(bizObject.get("bizFlowState"))) { |
|||
throw new BizException("该文档正在审批中，不能再发起审批"); |
|||
} |
|||
} |
|||
flowVars.put("id", this.createKey("id")); |
|||
this.insert("insertProcessApprova", flowVars); |
|||
this.updateFlowStateByProcInst("1", flowVars); |
|||
}else if("PROCESS_COMPLETED".equals(eventName)) { |
|||
if("1".equals(agree)) { |
|||
this.updateFlowStateByProcInst("2", flowVars); |
|||
|
|||
}else { |
|||
this.updateFlowStateByProcInst("3", flowVars); |
|||
} |
|||
}else if("PROCESS_CANCELLED".equals(eventName)) { |
|||
this.updateFlowStateByProcInst("4", flowVars); |
|||
} |
|||
} |
|||
} |
|||
|
|||
private void updateFlowStateByProcInstForDeleteSuccess(Map<String, Object> flowVars) { |
|||
baseMapper.updateFlowStateByProcInstForDeleteSuccess( flowVars); |
|||
|
|||
} |
|||
|
|||
public void updateFlowStateByProcInst(String flowState,Map<String, Object> flowVars) { |
|||
flowVars.put("flowState", flowState); |
|||
flowVars.put("bizFlowState", flowState); |
|||
if("1".equals(flowState)) { |
|||
flowVars.put("bizProcInstId", flowVars.get("procInstId")); |
|||
} |
|||
baseMapper.updateProcessApprova( flowVars); |
|||
} |
|||
|
|||
} |
|||
Write
Preview
Loading…
Cancel
Save
Reference in new issue