Browse Source

预算修改的申请审批

v1.0
Yen 2 years ago
parent
commit
7e0d0ddac8
  1. 29
      src/main/java/com/qs/serve/common/framework/manager/AsyncFactory.java
  2. 27
      src/main/java/com/qs/serve/modules/seeyon/service/SeeYonOperationService.java
  3. 77
      src/main/java/com/qs/serve/modules/tbs/controller/TbsBudgetChangeController.java
  4. 35
      src/main/java/com/qs/serve/modules/tbs/controller/TbsBudgetCheckController.java
  5. 11
      src/main/java/com/qs/serve/modules/tbs/controller/TbsBudgetController.java
  6. 10
      src/main/java/com/qs/serve/modules/tbs/entity/TbsBudgetChange.java
  7. 3
      src/main/java/com/qs/serve/modules/tbs/entity/vo/TbsBudgetVo.java
  8. 3
      src/main/java/com/qs/serve/modules/tbs/service/TbsBudgetChangeConditionService.java
  9. 3
      src/main/java/com/qs/serve/modules/tbs/service/TbsBudgetChangeScheduleItemService.java
  10. 2
      src/main/java/com/qs/serve/modules/tbs/service/TbsBudgetChangeService.java
  11. 22
      src/main/java/com/qs/serve/modules/tbs/service/impl/TbsBudgetApplyOperationServiceImpl.java
  12. 10
      src/main/java/com/qs/serve/modules/tbs/service/impl/TbsBudgetChangeConditionServiceImpl.java
  13. 81
      src/main/java/com/qs/serve/modules/tbs/service/impl/TbsBudgetChangeOperationServiceImpl.java
  14. 9
      src/main/java/com/qs/serve/modules/tbs/service/impl/TbsBudgetChangeScheduleItemServiceImpl.java
  15. 6
      src/main/java/com/qs/serve/modules/tbs/service/impl/TbsBudgetChangeServiceImpl.java
  16. 5
      src/main/java/com/qs/serve/modules/tbs/service/impl/TbsCostApplyOperationServiceImpl.java
  17. 4
      src/main/java/com/qs/serve/modules/tzc/service/impl/TzcPolicyOperationServiceImpl.java
  18. 8
      src/main/java/com/qs/serve/modules/vtb/service/VtbVerificationApplication.java
  19. 5
      src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationOperationServiceImpl.java

29
src/main/java/com/qs/serve/common/framework/manager/AsyncFactory.java

@ -74,6 +74,35 @@ public class AsyncFactory {
}; };
} }
/**
* 异步保存费用申请状态
* @param budgetId
* @return
*/
public static TimerTask submitBudgetChange(String budgetId) {
return new TimerTask() {
@Override
public void run() {
try {
AuthContextUtils.setTenant("001");
log.debug("--------------------------SubmitBudgetApply CallbackTimer Sleep Start------------------------------");
Thread.sleep(7*1000);
TbsBudgetApplyOperationServiceImpl applyOperationService = SpringUtils.getBean(TbsBudgetApplyOperationServiceImpl.class);
String summeryResult = applyOperationService.checkAffairSummery(budgetId);
if(summeryResult.equals(TbsCostApplyOperationServiceImpl.SummeryState_Success)){
//调用成功回调方法
TbsAffairCommitBo finishedParam = new TbsAffairCommitBo();
finishedParam.setTargetId(budgetId);
applyOperationService.doFinished(finishedParam);
}
log.debug("--------------------------SubmitBudgetApply CallbackTimer summeryResult:{} ------------------------------",summeryResult);
} catch (Exception e) {
e.printStackTrace();
}
}
};
}
/** /**
* 异步保存费用申请状态 * 异步保存费用申请状态
* @param budgetId * @param budgetId

27
src/main/java/com/qs/serve/modules/seeyon/service/SeeYonOperationService.java

@ -44,7 +44,9 @@ public interface SeeYonOperationService extends SeeYonBaseService{
* @param affairCommit * @param affairCommit
* @return * @return
*/ */
String getTargetId(TbsAffairCommitBo affairCommit); default String getTargetId(TbsAffairCommitBo affairCommit){
return affairCommit.getTargetId();
}
/** /**
* 检查提交审批是否允许,并返回syFormId * 检查提交审批是否允许,并返回syFormId
@ -316,9 +318,7 @@ public interface SeeYonOperationService extends SeeYonBaseService{
} }
}else if ("next".equals(flag)){ }else if ("next".equals(flag)){
this.doNext(affairCommit); this.doNext(affairCommit);
doCommitBacked(getTargetId(affairCommit));
//请求校验是否成功
AsyncManager.me().execute(AsyncFactory.submitBudgetApply(affairCommit.getTargetId()));
return R.ok(); return R.ok();
} }
}else if (result.getStatus()==500){ }else if (result.getStatus()==500){
@ -327,6 +327,13 @@ public interface SeeYonOperationService extends SeeYonBaseService{
return R.ok(); return R.ok();
} }
/**
* 用于回调OA的状态
* @param targetId
*/
void doCommitBacked(String targetId);
/** /**
* 补偿:审批中 * 补偿:审批中
@ -342,21 +349,27 @@ public interface SeeYonOperationService extends SeeYonBaseService{
* @param targetId * @param targetId
* @return * @return
*/ */
Object compensateBacked(String targetId); default Object compensateBacked(String targetId){
return null;
}
/** /**
* 补偿:审批完成 * 补偿:审批完成
* @param targetId * @param targetId
* @return * @return
*/ */
Object compensateFinished(String targetId); default Object compensateFinished(String targetId){
return null;
}
/** /**
* 补偿:审批拒绝 * 补偿:审批拒绝
* @param targetId * @param targetId
* @return * @return
*/ */
Object compensateRefuse(String targetId); default Object compensateRefuse(String targetId){
return null;
}
/** /**
* 执行的主要方法 * 执行的主要方法

77
src/main/java/com/qs/serve/modules/tbs/controller/TbsBudgetChangeController.java

@ -0,0 +1,77 @@
package com.qs.serve.modules.tbs.controller;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.qs.serve.common.model.annotation.SysLog;
import com.qs.serve.common.model.dto.PageVo;
import com.qs.serve.common.model.dto.R;
import com.qs.serve.common.model.enums.BizType;
import com.qs.serve.common.model.enums.SystemModule;
import com.qs.serve.common.util.PageUtil;
import com.qs.serve.common.util.CopierUtil;
import com.qs.serve.common.util.StringUtils;
import com.qs.serve.modules.tbs.entity.TbsBudgetChangeCondition;
import com.qs.serve.modules.tbs.entity.TbsBudgetChangeScheduleItem;
import com.qs.serve.modules.tbs.service.TbsBudgetChangeConditionService;
import com.qs.serve.modules.tbs.service.TbsBudgetChangeScheduleItemService;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;
import com.qs.serve.modules.tbs.entity.TbsBudgetChange;
import com.qs.serve.modules.tbs.service.TbsBudgetChangeService;
import javax.validation.Valid;
import java.util.List;
/**
* 预算 预算更变记录
* @author YenHex
* @since 2023-08-09
*/
@Slf4j
@AllArgsConstructor
@RestController
@RequestMapping("tbs/budgetChange")
public class TbsBudgetChangeController {
private TbsBudgetChangeService tbsBudgetChangeService;
private TbsBudgetChangeScheduleItemService tbsBudgetChangeScheduleItemService;
private TbsBudgetChangeConditionService tbsBudgetChangeConditionService;
/**
* 列表
* @param param
* @return
*/
@GetMapping("/list")
public R<List<TbsBudgetChange>> getList(TbsBudgetChange param){
if(param.getBudgetId()==null){
return R.error("BudgetId不能为空");
}
LambdaQueryWrapper<TbsBudgetChange> lqw = new LambdaQueryWrapper<>(param);
List<TbsBudgetChange> list = tbsBudgetChangeService.list(lqw);
for (TbsBudgetChange budgetChange : list) {
List<TbsBudgetChangeScheduleItem> changeScheduleItemList = tbsBudgetChangeScheduleItemService.listByChangeId(budgetChange.getId());
List<TbsBudgetChangeCondition> changeConditionList = tbsBudgetChangeConditionService.listByChangeId(budgetChange.getId());
budgetChange.setChangeScheduleItemList(changeScheduleItemList);
budgetChange.setChangeConditionList(changeConditionList);
}
return R.ok(list);
}
/**
* 翻页
* @param param
* @return
*/
//@GetMapping("/page")
public R<PageVo<TbsBudgetChange>> getPage(TbsBudgetChange param){
LambdaQueryWrapper<TbsBudgetChange> lqw = new LambdaQueryWrapper<>(param);
PageUtil.startPage();
List<TbsBudgetChange> list = tbsBudgetChangeService.list(lqw);
return R.byPageHelperList(list);
}
}

35
src/main/java/com/qs/serve/modules/tbs/controller/TbsBudgetCheckController.java

@ -4,12 +4,17 @@ import com.qs.serve.common.model.dto.R;
import com.qs.serve.modules.tbs.entity.TbsBudget; import com.qs.serve.modules.tbs.entity.TbsBudget;
import com.qs.serve.modules.tbs.entity.TbsBudgetChange; import com.qs.serve.modules.tbs.entity.TbsBudgetChange;
import com.qs.serve.modules.tbs.entity.bo.TbsBudgetUpdateAfterStartBo; import com.qs.serve.modules.tbs.entity.bo.TbsBudgetUpdateAfterStartBo;
import com.qs.serve.modules.tbs.entity.vo.CtpAffairVo;
import com.qs.serve.modules.tbs.service.TbsBudgetChangeService; import com.qs.serve.modules.tbs.service.TbsBudgetChangeService;
import com.qs.serve.modules.tbs.service.TbsBudgetService; import com.qs.serve.modules.tbs.service.TbsBudgetService;
import com.qs.serve.modules.tbs.service.impl.TbsBudgetApplyOperationServiceImpl;
import com.qs.serve.modules.tbs.service.impl.TbsBudgetChangeOperationServiceImpl;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import java.util.List;
/** /**
* 预算 预算审批 * 预算 预算审批
* @author YenHex * @author YenHex
@ -23,6 +28,8 @@ public class TbsBudgetCheckController {
private final TbsBudgetService tbsBudgetService; private final TbsBudgetService tbsBudgetService;
private final TbsBudgetChangeService tbsBudgetChangeService; private final TbsBudgetChangeService tbsBudgetChangeService;
private final TbsBudgetApplyOperationServiceImpl tbsBudgetApplyOperationService;
private final TbsBudgetChangeOperationServiceImpl tbsBudgetChangeOperationService;
/** /**
* 提交申请 * 提交申请
@ -40,9 +47,31 @@ public class TbsBudgetCheckController {
* @return * @return
*/ */
@PostMapping("commitChangeApply") @PostMapping("commitChangeApply")
public R<?> commitApply(@RequestBody TbsBudgetUpdateAfterStartBo param){ public R<TbsBudgetChange> commitApply(@RequestBody TbsBudgetUpdateAfterStartBo param){
tbsBudgetChangeService.commitApply(param); TbsBudgetChange budgetChange = tbsBudgetChangeService.commitApply(param);
return R.ok(); return R.ok(budgetChange);
}
/**
* 审批列表-预算申请
* @param budgetId
* @return
*/
@GetMapping("/ListAffairs")
public R<List<CtpAffairVo>> ListBudgetAffairs(String budgetId){
return tbsBudgetApplyOperationService.pageAffair(budgetId);
} }
/**
* 审批列表-预算修改
* @param changeId
* @return
*/
@GetMapping("/ListChangeAffairs")
public R<List<CtpAffairVo>> pageAffair(String changeId){
return tbsBudgetChangeOperationService.pageAffair(changeId);
}
} }

11
src/main/java/com/qs/serve/modules/tbs/controller/TbsBudgetController.java

@ -48,6 +48,7 @@ public class TbsBudgetController {
private final TbsBudgetCostItemService tbsBudgetCostItemService; private final TbsBudgetCostItemService tbsBudgetCostItemService;
private final TbsBudgetLogService tbsBudgetLogService; private final TbsBudgetLogService tbsBudgetLogService;
private final TbsScheduleItemBudgetService tbsScheduleItemBudgetService; private final TbsScheduleItemBudgetService tbsScheduleItemBudgetService;
private final TbsBudgetChangeService tbsBudgetChangeService;
private final SysUserService sysUserService; private final SysUserService sysUserService;
/** /**
@ -111,14 +112,22 @@ public class TbsBudgetController {
/** /**
* ID查询 * ID查询
* @param id * @param id
* @param changeId
* @return * @return
*/ */
@GetMapping("/getById/{id}") @GetMapping("/getById/{id}")
@SysLog(module = SystemModule.Budget, title = "预算", biz = BizType.QUERY) @SysLog(module = SystemModule.Budget, title = "预算", biz = BizType.QUERY)
@PreAuthorize("hasRole('tbs:budget:query')") @PreAuthorize("hasRole('tbs:budget:query')")
public R<TbsBudgetVo> getById(@PathVariable("id") String id){ public R<TbsBudgetVo> getById(@PathVariable("id") String id,String changeId){
TbsBudget budget = tbsBudgetService.getById(id); TbsBudget budget = tbsBudgetService.getById(id);
TbsBudgetVo vo = tbsBudgetService.toVoEntity(budget); TbsBudgetVo vo = tbsBudgetService.toVoEntity(budget);
LambdaQueryWrapper<TbsBudgetChange> changeLqw = new LambdaQueryWrapper<>();
List<TbsBudgetChange> changeList = tbsBudgetChangeService.list(changeLqw);
for (TbsBudgetChange budgetChange : changeList) {
//审批data
//条件
//金额
}
// TbsBudgetVo vo2 = tbsBudgetService.getEntityForExcel(budget); // TbsBudgetVo vo2 = tbsBudgetService.getEntityForExcel(budget);
// vo.setScheduleItemBudgets(vo2.getScheduleItemBudgets()); // vo.setScheduleItemBudgets(vo2.getScheduleItemBudgets());
return R.ok(vo); return R.ok(vo);

10
src/main/java/com/qs/serve/modules/tbs/entity/TbsBudgetChange.java

@ -4,6 +4,7 @@ import java.time.LocalDate;
import java.io.Serializable; import java.io.Serializable;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.List;
import com.baomidou.mybatisplus.annotation.*; import com.baomidou.mybatisplus.annotation.*;
import com.fasterxml.jackson.annotation.JsonFormat; import com.fasterxml.jackson.annotation.JsonFormat;
@ -31,6 +32,9 @@ public class TbsBudgetChange implements Serializable {
@TableId(type = IdType.AUTO) @TableId(type = IdType.AUTO)
private Long id; private Long id;
/** 预算id */
private Long budgetId;
/** 更变记录编码 */ /** 更变记录编码 */
@Length(max = 30,message = "更变记录编码长度不能超过30字") @Length(max = 30,message = "更变记录编码长度不能超过30字")
private String changeCode; private String changeCode;
@ -140,10 +144,16 @@ public class TbsBudgetChange implements Serializable {
@JsonProperty @JsonProperty
private String delFlag; private String delFlag;
@TableField(exist = false)
private List<?> changeScheduleItemList;
@TableField(exist = false)
private List<?> changeConditionList;
public static TbsBudgetChange toNewObject(TbsBudget source){ public static TbsBudgetChange toNewObject(TbsBudget source){
TbsBudgetChange budgetChange = new TbsBudgetChange(); TbsBudgetChange budgetChange = new TbsBudgetChange();
budgetChange.setId(source.getId()); budgetChange.setId(source.getId());
budgetChange.setBudgetId(source.getId());
//budgetChange.setChangeCode(source.getChangeCode()); //budgetChange.setChangeCode(source.getChangeCode());
//budgetChange.setBudgetTitle(source.getBudgetTitle()); //budgetChange.setBudgetTitle(source.getBudgetTitle());
budgetChange.setBudgetNumber(source.getBudgetNumber()); budgetChange.setBudgetNumber(source.getBudgetNumber());

3
src/main/java/com/qs/serve/modules/tbs/entity/vo/TbsBudgetVo.java

@ -77,5 +77,8 @@ public class TbsBudgetVo implements Serializable {
private List<TbsScheduleItemBudget> scheduleItemBudgets; private List<TbsScheduleItemBudget> scheduleItemBudgets;
private List<?> attachList; private List<?> attachList;
/** 变更列表 */
private List<?> changeList;
} }

3
src/main/java/com/qs/serve/modules/tbs/service/TbsBudgetChangeConditionService.java

@ -2,6 +2,7 @@ package com.qs.serve.modules.tbs.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.qs.serve.modules.tbs.entity.TbsBudgetChangeCondition; import com.qs.serve.modules.tbs.entity.TbsBudgetChangeCondition;
import java.util.List;
/** /**
* 预算更变记录条件 服务接口 * 预算更变记录条件 服务接口
@ -10,5 +11,7 @@ import com.qs.serve.modules.tbs.entity.TbsBudgetChangeCondition;
*/ */
public interface TbsBudgetChangeConditionService extends IService<TbsBudgetChangeCondition> { public interface TbsBudgetChangeConditionService extends IService<TbsBudgetChangeCondition> {
List<TbsBudgetChangeCondition> listByChangeId(Long id);
} }

3
src/main/java/com/qs/serve/modules/tbs/service/TbsBudgetChangeScheduleItemService.java

@ -2,6 +2,7 @@ package com.qs.serve.modules.tbs.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.qs.serve.modules.tbs.entity.TbsBudgetChangeScheduleItem; import com.qs.serve.modules.tbs.entity.TbsBudgetChangeScheduleItem;
import java.util.List;
/** /**
* 考核期更变记录 服务接口 * 考核期更变记录 服务接口
@ -10,5 +11,7 @@ import com.qs.serve.modules.tbs.entity.TbsBudgetChangeScheduleItem;
*/ */
public interface TbsBudgetChangeScheduleItemService extends IService<TbsBudgetChangeScheduleItem> { public interface TbsBudgetChangeScheduleItemService extends IService<TbsBudgetChangeScheduleItem> {
List<TbsBudgetChangeScheduleItem> listByChangeId(Long id);
} }

2
src/main/java/com/qs/serve/modules/tbs/service/TbsBudgetChangeService.java

@ -16,7 +16,7 @@ public interface TbsBudgetChangeService extends IService<TbsBudgetChange> {
* 提交修改 * 提交修改
* @param param * @param param
*/ */
void commitApply(TbsBudgetUpdateAfterStartBo param); TbsBudgetChange commitApply(TbsBudgetUpdateAfterStartBo param);
} }

22
src/main/java/com/qs/serve/modules/tbs/service/impl/TbsBudgetApplyOperationServiceImpl.java

@ -1,5 +1,7 @@
package com.qs.serve.modules.tbs.service.impl; package com.qs.serve.modules.tbs.service.impl;
import com.qs.serve.common.framework.manager.AsyncFactory;
import com.qs.serve.common.framework.manager.AsyncManager;
import com.qs.serve.common.util.Assert; import com.qs.serve.common.util.Assert;
import com.qs.serve.modules.seeyon.service.SeeYonOperationService; import com.qs.serve.modules.seeyon.service.SeeYonOperationService;
import com.qs.serve.modules.tbs.common.TbsBudgetCheckState; import com.qs.serve.modules.tbs.common.TbsBudgetCheckState;
@ -23,6 +25,11 @@ public class TbsBudgetApplyOperationServiceImpl implements SeeYonOperationServic
private TbsBudgetMapper budgetMapper; private TbsBudgetMapper budgetMapper;
@Override
public void doCommitBacked(String targetId) {
AsyncManager.me().execute(AsyncFactory.submitBudgetApply(targetId));
}
@Override @Override
public String getTargetId(TbsAffairCommitBo affairCommit) { public String getTargetId(TbsAffairCommitBo affairCommit) {
return affairCommit.getTargetId(); return affairCommit.getTargetId();
@ -69,21 +76,6 @@ public class TbsBudgetApplyOperationServiceImpl implements SeeYonOperationServic
return null; return null;
} }
@Override
public Object compensateBacked(String targetId) {
return null;
}
@Override
public Object compensateFinished(String targetId) {
return null;
}
@Override
public Object compensateRefuse(String targetId) {
return null;
}
@Override @Override
public String getTemplateCode() { public String getTemplateCode() {
return TbsSeeYonConst.BudgetApplyConf.Code(); return TbsSeeYonConst.BudgetApplyConf.Code();

10
src/main/java/com/qs/serve/modules/tbs/service/impl/TbsBudgetChangeConditionServiceImpl.java

@ -1,6 +1,8 @@
package com.qs.serve.modules.tbs.service.impl; package com.qs.serve.modules.tbs.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.qs.serve.modules.tbs.entity.TbsBudgetChangeScheduleItem;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@ -8,6 +10,8 @@ import com.qs.serve.modules.tbs.entity.TbsBudgetChangeCondition;
import com.qs.serve.modules.tbs.service.TbsBudgetChangeConditionService; import com.qs.serve.modules.tbs.service.TbsBudgetChangeConditionService;
import com.qs.serve.modules.tbs.mapper.TbsBudgetChangeConditionMapper; import com.qs.serve.modules.tbs.mapper.TbsBudgetChangeConditionMapper;
import java.util.List;
/** /**
* 预算更变记录条件 服务实现类 * 预算更变记录条件 服务实现类
* @author YenHex * @author YenHex
@ -18,5 +22,11 @@ import com.qs.serve.modules.tbs.mapper.TbsBudgetChangeConditionMapper;
@AllArgsConstructor @AllArgsConstructor
public class TbsBudgetChangeConditionServiceImpl extends ServiceImpl<TbsBudgetChangeConditionMapper,TbsBudgetChangeCondition> implements TbsBudgetChangeConditionService { public class TbsBudgetChangeConditionServiceImpl extends ServiceImpl<TbsBudgetChangeConditionMapper,TbsBudgetChangeCondition> implements TbsBudgetChangeConditionService {
@Override
public List<TbsBudgetChangeCondition> listByChangeId(Long id) {
LambdaQueryWrapper<TbsBudgetChangeCondition> lqw = new LambdaQueryWrapper<>();
lqw.eq(TbsBudgetChangeCondition::getChangeId,id);
return this.list(lqw);
}
} }

81
src/main/java/com/qs/serve/modules/tbs/service/impl/TbsBudgetChangeOperationServiceImpl.java

@ -0,0 +1,81 @@
package com.qs.serve.modules.tbs.service.impl;
import com.qs.serve.common.framework.manager.AsyncFactory;
import com.qs.serve.common.framework.manager.AsyncManager;
import com.qs.serve.common.util.Assert;
import com.qs.serve.modules.seeyon.service.SeeYonOperationService;
import com.qs.serve.modules.tbs.common.TbsBudgetCheckState;
import com.qs.serve.modules.tbs.common.TbsSeeYonConst;
import com.qs.serve.modules.tbs.entity.TbsBudget;
import com.qs.serve.modules.tbs.entity.TbsBudgetChange;
import com.qs.serve.modules.tbs.entity.bo.TbsAffairCommitBo;
import com.qs.serve.modules.tbs.mapper.TbsBudgetChangeMapper;
import com.qs.serve.modules.tbs.mapper.TbsBudgetMapper;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
/**
* 预算改动的申请
* @author YenHex
* @since 2023/8/8
*/
@Slf4j
@Service
@AllArgsConstructor
public class TbsBudgetChangeOperationServiceImpl implements SeeYonOperationService {
private TbsBudgetChangeMapper budgetChangeMapper;
@Override
public void doCommitBacked(String targetId) {
AsyncManager.me().execute(AsyncFactory.submitBudgetChange(targetId));
}
@Override
public String getSyFormIdByTargetInfo(TbsAffairCommitBo affairCommit) {
TbsBudgetChange budgetChange = budgetChangeMapper.selectById(affairCommit.getTargetId());
if(!budgetChange.getBudgetCheckState().equals(TbsBudgetCheckState.State_1_apply)){
Assert.throwEx("操作失败,预算处于非审批状态");
}
return budgetChange.getSyFormId();
}
@Override
public Object doBacked(TbsAffairCommitBo param) {
TbsBudgetChange budgetChange = budgetChangeMapper.selectById(param.getTargetId());
if(budgetChange.getBudgetCheckState().equals(TbsBudgetCheckState.State_1_apply)){
budgetChange.setBudgetCheckState(TbsBudgetCheckState.State_3_setback);
budgetChangeMapper.updateById(budgetChange);
}
return null;
}
@Override
public Object doFinished(TbsAffairCommitBo param) {
TbsBudgetChange budgetChange = budgetChangeMapper.selectById(param.getTargetId());
if(budgetChange.getBudgetCheckState().equals(TbsBudgetCheckState.State_1_apply)){
budgetChange.setBudgetCheckState(TbsBudgetCheckState.State_2_finished);
budgetChangeMapper.updateById(budgetChange);
}
//TODO 更新到主表
return null;
}
@Override
public Object doRefuse(TbsAffairCommitBo param) {
TbsBudgetChange budgetChange = budgetChangeMapper.selectById(param.getTargetId());
if(budgetChange.getBudgetCheckState().equals(TbsBudgetCheckState.State_1_apply)){
budgetChange.setBudgetCheckState(TbsBudgetCheckState.State_4_stop);
budgetChangeMapper.updateById(budgetChange);
}
return null;
}
@Override
public String getTemplateCode() {
return TbsSeeYonConst.BudgetApplyConf.Code();
}
}

9
src/main/java/com/qs/serve/modules/tbs/service/impl/TbsBudgetChangeScheduleItemServiceImpl.java

@ -1,5 +1,6 @@
package com.qs.serve.modules.tbs.service.impl; package com.qs.serve.modules.tbs.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@ -8,6 +9,8 @@ import com.qs.serve.modules.tbs.entity.TbsBudgetChangeScheduleItem;
import com.qs.serve.modules.tbs.service.TbsBudgetChangeScheduleItemService; import com.qs.serve.modules.tbs.service.TbsBudgetChangeScheduleItemService;
import com.qs.serve.modules.tbs.mapper.TbsBudgetChangeScheduleItemMapper; import com.qs.serve.modules.tbs.mapper.TbsBudgetChangeScheduleItemMapper;
import java.util.List;
/** /**
* 考核期更变记录 服务实现类 * 考核期更变记录 服务实现类
* @author YenHex * @author YenHex
@ -18,5 +21,11 @@ import com.qs.serve.modules.tbs.mapper.TbsBudgetChangeScheduleItemMapper;
@AllArgsConstructor @AllArgsConstructor
public class TbsBudgetChangeScheduleItemServiceImpl extends ServiceImpl<TbsBudgetChangeScheduleItemMapper,TbsBudgetChangeScheduleItem> implements TbsBudgetChangeScheduleItemService { public class TbsBudgetChangeScheduleItemServiceImpl extends ServiceImpl<TbsBudgetChangeScheduleItemMapper,TbsBudgetChangeScheduleItem> implements TbsBudgetChangeScheduleItemService {
@Override
public List<TbsBudgetChangeScheduleItem> listByChangeId(Long id) {
LambdaQueryWrapper<TbsBudgetChangeScheduleItem> lqw = new LambdaQueryWrapper<>();
lqw.eq(TbsBudgetChangeScheduleItem::getChangeId,id);
return this.list(lqw);
}
} }

6
src/main/java/com/qs/serve/modules/tbs/service/impl/TbsBudgetChangeServiceImpl.java

@ -51,7 +51,7 @@ public class TbsBudgetChangeServiceImpl extends ServiceImpl<TbsBudgetChangeMappe
private final ProjectProperties projectProperties; private final ProjectProperties projectProperties;
@Override @Override
public void commitApply(TbsBudgetUpdateAfterStartBo param) { public TbsBudgetChange commitApply(TbsBudgetUpdateAfterStartBo param) {
seeYonService.testConnection(); seeYonService.testConnection();
TbsBudget budget = tbsBudgetMapper.selectById(param.getId()); TbsBudget budget = tbsBudgetMapper.selectById(param.getId());
TbsBudgetChange budgetChange = buildBudgetChange(param, budget); TbsBudgetChange budgetChange = buildBudgetChange(param, budget);
@ -95,7 +95,9 @@ public class TbsBudgetChangeServiceImpl extends ServiceImpl<TbsBudgetChangeMappe
seeYonService.createCallbackStatus(callbackBo); seeYonService.createCallbackStatus(callbackBo);
//请求校验是否成功 //请求校验是否成功
AsyncManager.me().execute(AsyncFactory.submitBudgetApply(budgetChange.getId()+"")); AsyncManager.me().execute(AsyncFactory.submitBudgetChange(budgetChange.getId()+""));
return budgetChange;
} }

5
src/main/java/com/qs/serve/modules/tbs/service/impl/TbsCostApplyOperationServiceImpl.java

@ -72,6 +72,11 @@ public class TbsCostApplyOperationServiceImpl implements SeeYonOperationService
private final DataAffairCommitMapper dataAffairCommitMapper; private final DataAffairCommitMapper dataAffairCommitMapper;
@Override
public void doCommitBacked(String targetId) {
}
@Override @Override
public SysUserService getSysUserService() { public SysUserService getSysUserService() {
return sysUserService; return sysUserService;

4
src/main/java/com/qs/serve/modules/tzc/service/impl/TzcPolicyOperationServiceImpl.java

@ -145,6 +145,10 @@ public class TzcPolicyOperationServiceImpl implements SeeYonOperationService {
return TbsSeeYonConst.PolicyConf.Code(); return TbsSeeYonConst.PolicyConf.Code();
} }
@Override
public void doCommitBacked(String targetId) {
}
@Override @Override
public Object compensateBacked(String targetId) { public Object compensateBacked(String targetId) {

8
src/main/java/com/qs/serve/modules/vtb/service/VtbVerificationApplication.java

@ -1,6 +1,8 @@
package com.qs.serve.modules.vtb.service; package com.qs.serve.modules.vtb.service;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.qs.serve.common.framework.manager.AsyncFactory;
import com.qs.serve.common.framework.manager.AsyncManager;
import com.qs.serve.common.model.dto.R; import com.qs.serve.common.model.dto.R;
import com.qs.serve.common.util.AuthContextUtils; import com.qs.serve.common.util.AuthContextUtils;
import com.qs.serve.common.util.CollectionUtil; import com.qs.serve.common.util.CollectionUtil;
@ -177,11 +179,11 @@ public class VtbVerificationApplication {
} }
yardService.save(yard); yardService.save(yard);
//非终止或者驳回,保存审批线金额明细 //非终止或者驳回,保存审批线金额明细
BigDecimal totalAmount = BigDecimal.ZERO;
if(!isStop){ if(!isStop){
List<VtbVerificationSubject> verificationSubjects = vtbVerificationSubjectService.listByVerificationId(verification.getId()); List<VtbVerificationSubject> verificationSubjects = vtbVerificationSubjectService.listByVerificationId(verification.getId());
List<VtbVerificationYardItem> yardItemList = new ArrayList<>(); List<VtbVerificationYardItem> yardItemList = new ArrayList<>();
List<VtbVerificationSubject> verSubject4Update = new ArrayList<>(); List<VtbVerificationSubject> verSubject4Update = new ArrayList<>();
BigDecimal totalAmount = BigDecimal.ZERO;
for (VtbVerificationSubject currVs : verificationSubjects) { for (VtbVerificationSubject currVs : verificationSubjects) {
BigDecimal changeAmount = null; BigDecimal changeAmount = null;
Integer countSession = null; Integer countSession = null;
@ -280,6 +282,10 @@ public class VtbVerificationApplication {
if( isRelease &&(isFinish||isStop)){ if( isRelease &&(isFinish||isStop)){
this.vtbVerificationService.release(verification.getActivityId()); this.vtbVerificationService.release(verification.getActivityId());
} }
if(isNext){
//判断是否直接跳过审批的申请
AsyncManager.me().execute(AsyncFactory.saveVtbSubmit(verification, totalAmount));
}
return R.ok(); return R.ok();
} }

5
src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationOperationServiceImpl.java

@ -73,6 +73,11 @@ public class VtbVerificationOperationServiceImpl implements SeeYonOperationServi
return null; return null;
} }
@Override
public void doCommitBacked(String targetId) {
}
@Override @Override
public Object compensateBacked(String targetId) { public Object compensateBacked(String targetId) {
VtbVerification verification = vtbVerificationMapper.selectById(targetId); VtbVerification verification = vtbVerificationMapper.selectById(targetId);

Loading…
Cancel
Save