123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194 |
- package com.fjhx.purchase.flow;
- import com.alibaba.fastjson.JSONObject;
- import com.baomidou.dynamic.datasource.annotation.DS;
- import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
- import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
- import com.fjhx.account.entity.account.enums.PaymentStatusEnum;
- import com.fjhx.account.entity.account.enums.PaymentTypeEnum;
- import com.fjhx.account.entity.account.po.AccountPayment;
- import com.fjhx.account.service.account.AccountPaymentService;
- import com.fjhx.common.constant.SourceConstant;
- import com.fjhx.file.utils.ObsFileUtil;
- import com.fjhx.flow.core.FlowDelegate;
- import com.fjhx.purchase.entity.pay.enums.PayStatusEnum;
- import com.fjhx.purchase.entity.pay.po.Pay;
- import com.fjhx.purchase.entity.pay.po.PayDetail;
- import com.fjhx.purchase.entity.purchase.po.Purchase;
- import com.fjhx.purchase.service.pay.PayDetailService;
- import com.fjhx.purchase.service.pay.PayService;
- import com.fjhx.purchase.service.purchase.PurchaseService;
- import com.ruoyi.common.core.domain.entity.SysUser;
- import com.ruoyi.common.exception.ServiceException;
- import com.ruoyi.common.utils.wrapper.IWrapper;
- import com.ruoyi.system.service.ISysUserService;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.stereotype.Component;
- import java.math.BigDecimal;
- import java.util.Date;
- import java.util.List;
- import java.util.Map;
- import java.util.Objects;
- import java.util.stream.Collectors;
- /**
- * 采购付款流程
- *
- * @Author:caozj
- * @DATE:2023/4/3 17:38
- */
- @DS(SourceConstant.PURCHASE)
- @Component
- public class PayFlow extends FlowDelegate {
- @Autowired
- private PayService payService;
- @Autowired
- private AccountPaymentService accountPaymentService;
- @Autowired
- private PayDetailService payDetailService;
- @Autowired
- private PurchaseService purchaseService;
- @Autowired
- private ISysUserService userService;
- @Override
- public String getFlowKey() {
- return "pay_flow";
- }
- /**
- * 发起流程
- * @param flowId 流程ID
- * @param submitData 采购付款数据
- * @return
- */
- @Override
- public Long start(Long flowId, JSONObject submitData) {
- Pay pay = submitData.toJavaObject(Pay.class);
- pay.setStatus(PayStatusEnum.UNDER_REVIEW.getKey());
- pay.setCurrency("CNY");//默认币种人民币
- payService.save(pay);
- List<PayDetail> payDetailList = pay.getPayDetailList();
- if (CollectionUtils.isNotEmpty(payDetailList)) {
- payDetailList.forEach(item -> item.setPayId(pay.getId()));
- payDetailService.saveBatch(payDetailList);
- }
- ObsFileUtil.saveFile(pay.getFileList(), pay.getId());
- return pay.getId();
- }
- /**
- * 结束流程
- * @param flowId 流程ID
- * @param businessId 业务ID
- * @param submitData 数据
- */
- @Override
- public void end(Long flowId, Long businessId, JSONObject submitData) {
- // 通过业务ID查询申购数据
- Pay pay = payService.getById(businessId);
- if (ObjectUtils.isEmpty(pay)) {
- throw new ServiceException("采购付款单不存在");
- }
- // 修改采购状态为审批通过
- pay.setStatus(PayStatusEnum.PASS.getKey());
- pay.setApprovedDate(new Date());
- payService.updateById(pay);
- // 添加一条付款流水
- AccountPayment payment = new AccountPayment();
- payment.setAccountManagementId(pay.getAccountManagementId());
- payment.setBusinessId(pay.getId());
- payment.setCurrency(pay.getCurrency());
- SysUser sysUser = userService.getOne(IWrapper.<SysUser>getWrapper().eq(SysUser::getUserId, pay.getCreateUser()));
- if (ObjectUtils.isNotEmpty(sysUser)) {
- payment.setDepartmentId(sysUser.getDeptId());
- }
- // todo 暂时写死人民币
- payment.setPaymentRemark(pay.getRemark());
- payment.setType(PaymentTypeEnum.REJECT.getKey());
- payment.setStatus(PaymentStatusEnum.UNDER_REVIEW.getKey());
- payment.setCorporationId(pay.getCorporationId());
- payment.setAmount(pay.getAmount());
- payment.setIncomeAmount(pay.getAmount());
- payment.setName(pay.getName());
- payment.setDataUser(pay.getCreateUser());
- payment.setBusinessManagementId(pay.getAccountManagementId());
- payment.setOpeningBank(pay.getOpeningBank());
- payment.setBusinessCurrency(pay.getCurrency());
- payment.setAccountOpening(pay.getAccountOpening());
- payment.setInterbankNumber(pay.getInterbankNumber());
- payment.setPaymentMethod(pay.getPayType());
- payment.setApplyForTime(pay.getCreateTime());//申请时间
- accountPaymentService.save(payment);
- // 修改合同付款状态
- updatePurchasePayStatus(businessId);
- }
- /**
- * 修改合同付款状态
- *
- * @param payId 付款id
- */
- private void updatePurchasePayStatus(Long payId) {
- // 获取支付明细
- List<PayDetail> list = payDetailService.list(q -> q.eq(PayDetail::getPayId, payId));
- // 获取合同id
- List<Long> purchaseIdList = list.stream().map(PayDetail::getPurchaseId).filter(Objects::nonNull).distinct().collect(Collectors.toList());
- if (purchaseIdList.size() == 0) {
- return;
- }
- // 通过合同id获取指定合同所有付款记录
- Map<Long, BigDecimal> map = payDetailService.getPayMoneyCountByPurchaseId(purchaseIdList);
- // 获取合同列表
- List<Purchase> purchaseList = purchaseService.listByIds(purchaseIdList);
- for (Purchase purchase : purchaseList) {
- Integer payStatus = purchase.getPayStatus();
- // 已经是已付款,跳过
- if (Objects.equals(20, payStatus)) {
- continue;
- }
- // 获取合同付款金额
- BigDecimal payMoney = map.getOrDefault(purchase.getId(), BigDecimal.ZERO);
- // 获取合同金额
- BigDecimal amount = purchase.getAmount();
- // 合同付款金额大于等于合同金额,已付款
- if (payMoney.compareTo(amount) >= 0) {
- purchase.setPayStatus(20);
- }
- // 否则进行中
- else {
- purchase.setPayStatus(10);
- }
- }
- // 修改合同付款状态
- purchaseService.updateBatchById(purchaseList);
- }
- }
|