diff --git a/src/main/java/com/qs/serve/modules/tbs/common/TbsSeeYonConst.java b/src/main/java/com/qs/serve/modules/tbs/common/TbsSeeYonConst.java index fc73df52..3a7c150d 100644 --- a/src/main/java/com/qs/serve/modules/tbs/common/TbsSeeYonConst.java +++ b/src/main/java/com/qs/serve/modules/tbs/common/TbsSeeYonConst.java @@ -36,10 +36,12 @@ public interface TbsSeeYonConst { public static String Code(){ return DevEnvironmentConfig.isDev()?"CheckCost_Test":"CheckCost"; } + //public static String Id(){return DevEnvironmentConfig.isDev()?"8370474123848467567":"5117622466085866816";} } /** 核销 */ class BatchCostCheckConf{ + //public static String Id(){return DevEnvironmentConfig.isDev()?"6989459208782694349":"7718060534670183779";} public static String Code(){ return DevEnvironmentConfig.isDev()?"BatchCheckCost_Test":"BatchCheckCost"; } diff --git a/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchOperationServiceImpl.java b/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchOperationServiceImpl.java index b83bd8a4..d176226a 100644 --- a/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchOperationServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchOperationServiceImpl.java @@ -11,9 +11,12 @@ import com.qs.serve.modules.seeyon.entity.bo.CtpAddNodeParam; import com.qs.serve.modules.seeyon.service.SeeYonOperationService; import com.qs.serve.modules.sys.entity.SysUser; import com.qs.serve.modules.sys.service.SysUserService; +import com.qs.serve.modules.tbs.common.TbsActivityState; import com.qs.serve.modules.tbs.common.TbsSeeYonConst; +import com.qs.serve.modules.tbs.entity.TbsActivity; import com.qs.serve.modules.tbs.entity.bo.TbsAffairCommitBo; import com.qs.serve.modules.tbs.entity.vo.CtpAffairVo; +import com.qs.serve.modules.tbs.mapper.TbsActivityMapper; import com.qs.serve.modules.vtb.common.VtbVerificationState; import com.qs.serve.modules.vtb.entity.*; import com.qs.serve.modules.vtb.entity.vo.VtbVerificationActReleaseVo; @@ -25,10 +28,7 @@ import org.springframework.stereotype.Service; import java.math.BigDecimal; import java.time.LocalDateTime; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.List; -import java.util.Map; +import java.util.*; import java.util.stream.Collectors; /** @@ -50,6 +50,7 @@ public class VtbVerificationBatchOperationServiceImpl implements VtbVerification private final VtbVerificationYardItemService yardItemService; private final VtbVerificationYardCenterItemService yardCenterItemService; private final VtbVerificationSubjectService vtbVerificationSubjectService; + private final TbsActivityMapper tbsActivityMapper; @Override public String getTemplateCode() { @@ -74,6 +75,14 @@ public class VtbVerificationBatchOperationServiceImpl implements VtbVerification verification.setVerificationState(VtbVerificationState.Rollback.getCode()); vtbVerificationService.updateById(verification); } + Set actIdList = verificationList.stream().map(VtbVerification::getActivityId).collect(Collectors.toSet()); + List activityList = tbsActivityMapper.selectList(new LambdaQueryWrapper().eq(TbsActivity::getId,actIdList)); + for (TbsActivity activity : activityList) { + TbsActivity activity1 = new TbsActivity(); + activity1.setId(activity.getId()); + activity1.setActivityState(TbsActivityState.STATE_0_Todo); + tbsActivityMapper.updateById(activity1); + } return null; } @@ -87,6 +96,12 @@ public class VtbVerificationBatchOperationServiceImpl implements VtbVerification for (VtbVerification verification : verificationList) { //循环调用每个核销 vtbVerificationService.successCommit(verification.getId()); + //更新核销状态 + VtbVerification updateVerification = new VtbVerification(); + updateVerification.setId(verification.getId()); + updateVerification.setFinishedTime(LocalDateTime.now()); + updateVerification.setVerificationState(VtbVerificationState.Finished.getCode()); + vtbVerificationService.updateById(updateVerification); } BigDecimal totalAmt = vtbVerificationMapper.totalVtbAmtByBatchId(batch.getId()); batch.setResultCheckAmount(totalAmt); @@ -257,14 +272,15 @@ public class VtbVerificationBatchOperationServiceImpl implements VtbVerification boolean isStop = "backed".equals(flag)||"refuse".equals(flag); //释放费用 boolean isRelease = itemCommit.getReleaseFlag()!=null&&itemCommit.getReleaseFlag().equals(1); - if (isStop){ - log.warn("单据[{}]状态:{},中止审批",verification.getVerificationCode(),flag); - verificationApplication.backCommitAndStop(verification, "backed".equals(flag)); - if(isRelease){ - log.warn("单据[{}]状态:{},中止审批并释放费用",verification.getVerificationCode(),flag); - vtbVerificationService.release(verification.getActivityId(),sysUser.getCode(),false); - } - }else if (!isFinish && !isNext){ +// if (isStop){ +// log.warn("单据[{}]状态:{},中止审批",verification.getVerificationCode(),flag); +// verificationApplication.backCommitAndStop(verification, "backed".equals(flag)); +// if(isRelease){ +// log.warn("单据[{}]状态:{},中止审批并释放费用",verification.getVerificationCode(),flag); +// vtbVerificationService.release(verification.getActivityId(),sysUser.getCode(),false); +// } +// }else + if (!isFinish && !isNext){ log.error("远程调用返回,非指定状态:{}",JsonUtil.objectToJson(commitParam)); continue; } @@ -405,20 +421,20 @@ public class VtbVerificationBatchOperationServiceImpl implements VtbVerification if(subjectCenterUpdateList.size()>0){ vtbVerificationSubjectCenterService.updateBatchById(subjectCenterUpdateList); } - //重新计算合计 - if(isFinish){ - verificationApplication.finishCallBack(verification, totalAmount); - if(isRelease){ - log.warn("核销"+verification.getVerificationCode()+"释放金额"); - vtbVerificationService.release(verification.getActivityId(),sysUser.getCode(),false); - } - }else { - //更新金额 - VtbVerification vtbVer = new VtbVerification(); - vtbVer.setId(verification.getId()); - vtbVer.setAmount(totalAmount); - vtbVerificationService.updateById(vtbVer); - } +// //重新计算合计 +// if(isFinish){ +// verificationApplication.finishCallBack(verification, totalAmount); +// if(isRelease){ +// log.warn("核销"+verification.getVerificationCode()+"释放金额"); +// vtbVerificationService.release(verification.getActivityId(),sysUser.getCode(),false); +// } +// }else { +// //更新金额 +// VtbVerification vtbVer = new VtbVerification(); +// vtbVer.setId(verification.getId()); +// vtbVer.setAmount(totalAmount); +// vtbVerificationService.updateById(vtbVer); +// } } } } diff --git a/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchServiceImpl.java b/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchServiceImpl.java index 771b0632..86e4be57 100644 --- a/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationBatchServiceImpl.java @@ -306,6 +306,9 @@ public class VtbVerificationBatchServiceImpl extends ServiceImpl tags = tagInfoMapper.lisTagsBySupplierCode(supplier.getCode()); data.put("tags",tags); diff --git a/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationServiceImpl.java b/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationServiceImpl.java index 54aa9388..b435417f 100644 --- a/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationServiceImpl.java @@ -479,9 +479,8 @@ public class VtbVerificationServiceImpl extends ServiceImpl() - .eq(VtbFundFlow::getFundType,VtbFundFlowType.Release) + .eq(VtbFundFlow::getFundType,VtbFundFlowType.Release) .eq(VtbFundFlow::getCostApplyId,activity.getCostApplyId()) .eq(VtbFundFlow::getActivityId,activity.getId()) ); @@ -613,6 +620,12 @@ public class VtbVerificationServiceImpl extends ServiceImpl fundFlowList = fundFlowService.listByActivity(activity.getId(),VtbFundFlowType.Verification); BigDecimal totalFunFlow = BigDecimal.ZERO; for (VtbFundFlow fundFlow : fundFlowList) { @@ -1248,7 +1270,7 @@ public class VtbVerificationServiceImpl extends ServiceImpl