Browse Source

协议类;预算异常补偿

v1.0
Yen 2 years ago
parent
commit
f2fa90f644
  1. 14
      src/main/java/com/qs/serve/modules/tbs/controller/TbsBudgetController.java
  2. 1
      src/main/java/com/qs/serve/modules/tbs/mapper/TbsBudgetLogMapper.java
  3. 10
      src/main/java/com/qs/serve/modules/tbs/mapper/TbsScheduleItemBudgetMapper.java
  4. 31
      src/main/java/com/qs/serve/modules/third/PortalOfCostController.java
  5. 20
      src/main/java/com/qs/serve/modules/third/entity/ProcessReleaseContractBo.java
  6. 13
      src/main/java/com/qs/serve/modules/third/service/PortalOfCostApplication.java

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

@ -16,6 +16,7 @@ import com.qs.serve.modules.tbs.common.util.TbsBudgetLogBuildUtil;
import com.qs.serve.modules.tbs.entity.*; import com.qs.serve.modules.tbs.entity.*;
import com.qs.serve.modules.tbs.entity.bo.*; import com.qs.serve.modules.tbs.entity.bo.*;
import com.qs.serve.modules.tbs.entity.dto.TbsBudgetLogWithAmount; import com.qs.serve.modules.tbs.entity.dto.TbsBudgetLogWithAmount;
import com.qs.serve.modules.tbs.entity.dto.TbsScheduleItemBudgetAmount;
import com.qs.serve.modules.tbs.entity.vo.TbsBudgetVo; import com.qs.serve.modules.tbs.entity.vo.TbsBudgetVo;
import com.qs.serve.modules.tbs.mapper.TbsBudgetMapper; import com.qs.serve.modules.tbs.mapper.TbsBudgetMapper;
import com.qs.serve.modules.tbs.mapper.TbsScheduleItemBudgetMapper; import com.qs.serve.modules.tbs.mapper.TbsScheduleItemBudgetMapper;
@ -435,5 +436,18 @@ public class TbsBudgetController {
tbsBudgetService.updateBudgetAfterStart(param); tbsBudgetService.updateBudgetAfterStart(param);
return R.ok(); return R.ok();
} }
@GetMapping("/syncNotExitLog")
public R<?> syncNotExitLog(){
List<TbsScheduleItemBudget> items = tbsScheduleItemBudgetMapper.listNotCreateLogBudget();
for (TbsScheduleItemBudget item : items) {
TbsBudget budget = tbsBudgetService.getById(item.getBudgetId());
TbsBudgetLog budgetLog = TbsBudgetLogBuildUtil.toTbsBudgetLog(new SysUser(),budget,item,BudgetLogOptFlag.State_0,item.getBudgetAmount());
budgetLog.setRemark("sync");
tbsBudgetLogService.save(budgetLog);
}
return R.ok();
}
} }

1
src/main/java/com/qs/serve/modules/tbs/mapper/TbsBudgetLogMapper.java

@ -37,5 +37,6 @@ public interface TbsBudgetLogMapper extends BaseMapper<TbsBudgetLog> {
@Update("update tbs_budget_log set del_flag = #{delState} WHERE cost_apply_id = #{costApplyId}") @Update("update tbs_budget_log set del_flag = #{delState} WHERE cost_apply_id = #{costApplyId}")
void updateLogDelFlagByCostApply(@Param("costApplyId")Long costApplyId,@Param("delState")Integer delState); void updateLogDelFlagByCostApply(@Param("costApplyId")Long costApplyId,@Param("delState")Integer delState);
} }

10
src/main/java/com/qs/serve/modules/tbs/mapper/TbsScheduleItemBudgetMapper.java

@ -1,5 +1,6 @@
package com.qs.serve.modules.tbs.mapper; package com.qs.serve.modules.tbs.mapper;
import com.baomidou.mybatisplus.annotation.InterceptorIgnore;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.qs.serve.modules.tbs.entity.TbsScheduleItemBudget; import com.qs.serve.modules.tbs.entity.TbsScheduleItemBudget;
import com.qs.serve.modules.tbs.entity.dto.TbsBudgetLogPreAmount; import com.qs.serve.modules.tbs.entity.dto.TbsBudgetLogPreAmount;
@ -152,5 +153,14 @@ public interface TbsScheduleItemBudgetMapper extends BaseMapper<TbsScheduleItemB
*/ */
List<TbsBudgetLogWithAmount> getAllByScheduleItemIdList(@Param("selectIds") List<Long> ids); List<TbsBudgetLogWithAmount> getAllByScheduleItemIdList(@Param("selectIds") List<Long> ids);
@InterceptorIgnore(tenantLine = "true")
@Select(" SELECT tsib.* FROM `tbs_schedule_item_budget` tsib " +
" LEFT JOIN tbs_budget ON tsib.budget_id = tbs_budget.id " +
" LEFT JOIN tbs_budget_log ON (tsib.budget_id = tbs_budget_log.budget_id " +
" and tsib.schedule_item_id = tbs_budget_log.schedule_item_id and tbs_budget_log.opt_type = 0) " +
" where tbs_budget.del_flag = 0 and tbs_budget.budget_state = 1 and tbs_budget_log.id is null and budget_amount > 0")
List<TbsScheduleItemBudget> listNotCreateLogBudget();
} }

31
src/main/java/com/qs/serve/modules/third/PortalOfCostController.java

@ -11,6 +11,7 @@ import com.qs.serve.modules.third.consts.ThirtyConst;
import com.qs.serve.modules.third.entity.ProcessCreateContractCheckBo; import com.qs.serve.modules.third.entity.ProcessCreateContractCheckBo;
import com.qs.serve.modules.third.entity.ProcessCreateCostApplyBo; import com.qs.serve.modules.third.entity.ProcessCreateCostApplyBo;
import com.qs.serve.modules.third.entity.ProcessCreatePolicyCostBo; import com.qs.serve.modules.third.entity.ProcessCreatePolicyCostBo;
import com.qs.serve.modules.third.entity.ProcessReleaseContractBo;
import com.qs.serve.modules.third.service.PortalOfCostApplication; import com.qs.serve.modules.third.service.PortalOfCostApplication;
import com.qs.serve.modules.tzc.service.TzcPolicyGoodsSyncService; import com.qs.serve.modules.tzc.service.TzcPolicyGoodsSyncService;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@ -69,7 +70,7 @@ public class PortalOfCostController {
/** /**
* 协议类费用 核销支付记录添加释放接口释放合同不再支付的金额 * 协议类费用 核销支付记录
* @param createBo * @param createBo
* @return * @return
*/ */
@ -96,7 +97,33 @@ public class PortalOfCostController {
return R.error("支付异常"); return R.error("支付异常");
} }
/**
* 协议类费用 释放接口释放合同不再支付的金额
* @param contractBo
* @return
*/
@PostMapping("releaseContractCost")
public R<?> releaseContractCost(@Valid @RequestBody ProcessReleaseContractBo contractBo, HttpServletRequest request){
SysSyncLog syncLog = new SysSyncLog();
syncLog.setFromPlat("协议类释放");
syncLog.setUrl(request.getRequestURI());
syncLog.setRequestJson(JsonUtil.objectToJson(contractBo));
syncLog.setEntityClass(ProcessCreateCostApplyBo.class.getName());
try {
ThirdTokenUtil.checkToken(request);
portalOfCostApplication.releaseContractCost(contractBo);
syncLog.setSuccessStatus(1);
} catch (Exception e) {
log.error("协议类核销支付(费用申请)===>{}", JsonUtil.objectToJson(contractBo));
syncLog.setFailReason(e.getMessage());
return R.error(e.getMessage());
}
sysSyncLogService.save(syncLog);
if(syncLog.getSuccessStatus()!=null&&syncLog.getSuccessStatus().equals(1)){
return R.ok();
}
return R.error("支付异常");
}
/** /**
* 一站式创建费用(政策) * 一站式创建费用(政策)

20
src/main/java/com/qs/serve/modules/third/entity/ProcessReleaseContractBo.java

@ -0,0 +1,20 @@
package com.qs.serve.modules.third.entity;
import lombok.Data;
import java.math.BigDecimal;
/**
* @author YenHex
* @since 2023/11/13
*/
@Data
public class ProcessReleaseContractBo {
/** 费用编码 */
private String costCode;
/** 核销与支付备注 */
private String remark;
}

13
src/main/java/com/qs/serve/modules/third/service/PortalOfCostApplication.java

@ -940,6 +940,10 @@ public class PortalOfCostApplication {
} }
/**
* 协议类费用 核销支付记录
* @param createBo
*/
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void createByContractCheck(ProcessCreateContractCheckBo createBo){ public void createByContractCheck(ProcessCreateContractCheckBo createBo){
TbsCostApply costApply = costApplyService.getByCode(createBo.getCostCode()); TbsCostApply costApply = costApplyService.getByCode(createBo.getCostCode());
@ -1055,10 +1059,13 @@ public class PortalOfCostApplication {
verificationSubjectService.save(verificationSubject); verificationSubjectService.save(verificationSubject);
} }
}
/**
* 协议类费用 释放接口释放合同不再支付的金额
* @param contractBo
*/
public void releaseContractCost(ProcessReleaseContractBo contractBo){
} }

Loading…
Cancel
Save