Commit cade189a authored by huyuchen's avatar huyuchen

huych-含风险项目商险不购买申请提交

parent 45d93699
......@@ -10,7 +10,6 @@ import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
import com.yifu.cloud.plus.v1.yifu.common.core.vo.YifuUser;
import com.yifu.cloud.plus.v1.yifu.insurances.entity.TApprovalRecord;
import com.yifu.cloud.plus.v1.yifu.insurances.entity.TAuditNodeProocess;
import com.yifu.cloud.plus.v1.yifu.insurances.entity.TInsuranceUnpurchaseApply;
import com.yifu.cloud.plus.v1.yifu.insurances.service.insurance.TApprovalRecordService;
import com.yifu.cloud.plus.v1.yifu.insurances.service.insurance.TAuditNodeProocessService;
import com.yifu.cloud.plus.v1.yifu.process.constant.ProcessConstants;
......
package com.yifu.cloud.plus.v1.yifu.insurances.service.insurance.impl.process;
import cn.hutool.core.date.DatePattern;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.yifu.cloud.plus.v1.yifu.admin.api.entity.SysUser;
import com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants;
......@@ -12,12 +9,8 @@ import com.yifu.cloud.plus.v1.yifu.common.core.util.Common;
import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
import com.yifu.cloud.plus.v1.yifu.common.core.vo.YifuUser;
import com.yifu.cloud.plus.v1.yifu.insurances.entity.TApprovalRecord;
import com.yifu.cloud.plus.v1.yifu.insurances.entity.TAuditCopyInfo;
import com.yifu.cloud.plus.v1.yifu.insurances.entity.TAuditNodeProocess;
import com.yifu.cloud.plus.v1.yifu.insurances.entity.TInsuranceUnpurchaseApply;
import com.yifu.cloud.plus.v1.yifu.insurances.service.insurance.TInsuranceUnpurchaseApplyService;
import com.yifu.cloud.plus.v1.yifu.insurances.service.insurance.impl.AbastractAuditProcess;
import com.yifu.cloud.plus.v1.yifu.insurances.vo.TInsuranceUnpurchaseApplySearchVo;
import com.yifu.cloud.plus.v1.yifu.process.constant.ProcessConstants;
import com.yifu.cloud.plus.v1.yifu.process.entity.TNodePrimission;
import com.yifu.cloud.plus.v1.yifu.process.entity.TNodeRoute;
......@@ -25,12 +18,12 @@ import com.yifu.cloud.plus.v1.yifu.process.entity.TNodeRouteCondition;
import com.yifu.cloud.plus.v1.yifu.process.entity.TProcessNode;
import com.yifu.cloud.plus.v1.yifu.process.util.ProcessAuditUtil;
import com.yifu.cloud.plus.v1.yifu.process.vo.ProcessVo;
import com.yifu.cloud.plus.v1.yifu.salary.entity.TInsuranceUnpurchaseApply;
import com.yifu.cloud.plus.v1.yifu.salary.vo.TInsuranceUnpurchaseApplySearchVo;
import org.apache.commons.lang.StringUtils;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
......@@ -44,29 +37,29 @@ import java.util.Map;
@Component
public class TInsuranceUnpurchaseApplyAuditProcess extends AbastractAuditProcess<TInsuranceUnpurchaseApply, TInsuranceUnpurchaseApplySearchVo> {
@Resource
private TInsuranceUnpurchaseApplyService tInsuranceUnpurchaseApplyService;
// @Resource
// private TInsuranceUnpurchaseApplyService tInsuranceUnpurchaseApplyService;
@Override
public R<String> auditSuccess(TInsuranceUnpurchaseApply entity, TApprovalRecord approvalRecord, YifuUser loginUser) {
// 改实体审核状态为审核通过
entity.setAuditFlag(CommonConstants.THREE_STRING);
boolean res = tInsuranceUnpurchaseApplyService.updateById(entity);
if (res) {
// todo 删除当前实体所有的流程节点,数据量太大影响审批效率
// 防止死锁,先查询再删除
TAuditNodeProocess auditNodeProocessInfo = auditNodeProocessService.getOne(Wrappers.<TAuditNodeProocess>query().lambda()
.eq(TAuditNodeProocess::getDomainId, entity.getId())
.in(TAuditNodeProocess::getType, approvalRecord.getAuditType())
.last(CommonConstants.SQL_LIMIT_ONE));
if(Common.isNotKong(auditNodeProocessInfo)) {
auditNodeProocessService.remove(Wrappers.<TAuditNodeProocess>query().lambda().eq(TAuditNodeProocess::getDomainId, entity.getId())
.in(TAuditNodeProocess::getType, approvalRecord.getAuditType()));
}
//记录末尾节点审核
//sysMessageInfoService.saveApprovalLastAgree(CrmConstants.OPPORTUNITY_MODUL_TYPE, approvalRecord);
}
// boolean res = tInsuranceUnpurchaseApplyService.updateById(entity);
// if (res) {
// // todo 删除当前实体所有的流程节点,数据量太大影响审批效率
// // 防止死锁,先查询再删除
// TAuditNodeProocess auditNodeProocessInfo = auditNodeProocessService.getOne(Wrappers.<TAuditNodeProocess>query().lambda()
// .eq(TAuditNodeProocess::getDomainId, entity.getId())
// .in(TAuditNodeProocess::getType, approvalRecord.getAuditType())
// .last(CommonConstants.SQL_LIMIT_ONE));
// if(Common.isNotKong(auditNodeProocessInfo)) {
// auditNodeProocessService.remove(Wrappers.<TAuditNodeProocess>query().lambda().eq(TAuditNodeProocess::getDomainId, entity.getId())
// .in(TAuditNodeProocess::getType, approvalRecord.getAuditType()));
// }
// //记录末尾节点审核
// //sysMessageInfoService.saveApprovalLastAgree(CrmConstants.OPPORTUNITY_MODUL_TYPE, approvalRecord);
//
// }
return R.ok("审核通过");
}
......@@ -81,7 +74,7 @@ public class TInsuranceUnpurchaseApplyAuditProcess extends AbastractAuditProcess
// 以后有抄送再加逻辑:参照crm-更改之前抄送记录状态为0
// 改实体审核状态为审核不通过
entity.setAuditFlag(CommonConstants.FOUR_STRING);
tInsuranceUnpurchaseApplyService.updateById(entity);
// tInsuranceUnpurchaseApplyService.updateById(entity);
// todo 删除当前实体所有的流程节点,数据量太大影响审批效率
// 防止死锁,先查询再删除
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment