资金协调手续-审核

@@ -216,6 +216,17 @@ public class FundCoordination extends BaseEntity implements BaseDto {
     private String generalManagerOpinion;
 
     /**
+     * 审核状态
+     */
+    private String status;
+
+    /**
+     * 办事处code
+     */
+    @TableField(exist = false)
+    private String deptCode;
+
+    /**
      * 创建人ID
      */
     @TableField(fill = FieldFill.INSERT)

@@ -22,6 +22,7 @@ import com.lframework.xingyun.sc.service.customer.CorePersonnelHistoryService;
 import com.lframework.xingyun.sc.service.customer.CustomerCreditHistoryService;
 import com.lframework.xingyun.sc.service.customer.CustomerCreditService;
 import com.lframework.xingyun.sc.service.customer.CustomerDevelopPlanService;
+import com.lframework.xingyun.sc.service.ledger.FundCoordinationService;
 import com.lframework.xingyun.sc.service.order.*;
 import com.lframework.xingyun.sc.service.purchase.ReplenishmentOrderService;
 import com.lframework.xingyun.sc.service.shipments.ShipmentsPlanDetailService;
@@ -111,6 +112,8 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
     private ShipmentsPlanDetailService shipmentsPlanDetailService;
     @Resource
     private SysUserRoleService sysUserRoleService;
+    @Resource
+    private FundCoordinationService fundCoordinationService;
 
 
 
@@ -176,6 +179,9 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
             case "DELAYED_SHIPMENT":
                 handleDelayedShipmentData(flowStatus, businessId);
                 break;
+            case "FUND_COORDINATION":
+                handleFundCoordinationData(flowStatus, businessId);
+                break;
             default:
                 break;
         }
@@ -619,6 +625,17 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
         }
     }
 
+    private void handleFundCoordinationData(String flowStatus, String businessId) {
+        if (FlowInstanceStatus.APPROVE_PASS.getCode().equals(flowStatus)
+                || FlowInstanceStatus.FINISH.getCode().equals(flowStatus)) {
+            fundCoordinationService.reviewPass(businessId);
+        } else if (FlowInstanceStatus.REVOKE.getCode().equals(flowStatus)
+                || FlowInstanceStatus.REFUSE.getCode().equals(flowStatus)
+                || FlowInstanceStatus.TERMINATION.getCode().equals(flowStatus)) {
+            fundCoordinationService.updateStatus(businessId, "REFUSE");
+        }
+    }
+
 
     /**
      * 通知生产科计划员

@@ -3,7 +3,10 @@ package com.lframework.xingyun.sc.impl.ledger;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.github.pagehelper.PageInfo;
+import com.lframework.starter.bpm.mappers.FlowTaskWrapperMapper;
+import com.lframework.starter.bpm.service.FlowInstanceWrapperService;
 import com.lframework.starter.common.utils.CollectionUtil;
+import com.lframework.starter.web.core.components.security.SecurityUtil;
 import com.lframework.starter.web.core.impl.BaseMpServiceImpl;
 import com.lframework.starter.web.core.utils.PageResultUtil;
 import com.lframework.starter.web.core.utils.OpLogUtil;
@@ -18,15 +21,22 @@ import com.lframework.starter.common.utils.StringUtil;
 import com.lframework.starter.common.utils.ObjectUtil;
 import com.lframework.starter.common.utils.Assert;
 import com.lframework.xingyun.sc.entity.FundCoordination;
+import com.lframework.xingyun.sc.entity.FundOrderingUnit;
+import com.lframework.xingyun.sc.entity.FundOrderingUnitDetail;
+import com.lframework.xingyun.sc.handlers.TransactorHandler;
 import com.lframework.xingyun.sc.mappers.FundCoordinationMapper;
 import com.lframework.xingyun.sc.service.ledger.FundCoordinationService;
+import com.lframework.xingyun.sc.service.ledger.FundOrderingUnitDetailService;
 import com.lframework.xingyun.sc.service.ledger.FundOrderingUnitService;
 import com.lframework.xingyun.sc.service.ledger.PendingDeliveryOrderService;
+import com.lframework.xingyun.sc.vo.ledger.detail.QueryFundOrderingUnitDetailVo;
 import com.lframework.xingyun.sc.vo.ledger.fund.CreateFundCoordinationVo;
 import com.lframework.xingyun.sc.vo.ledger.fund.QueryFundCoordinationVo;
 import com.lframework.xingyun.sc.vo.ledger.fund.UpdateFundCoordinationVo;
 import com.lframework.xingyun.sc.vo.ledger.pending.CreatePendingDeliveryOrderVo;
 import com.lframework.xingyun.sc.vo.ledger.rel.CreateFundOrderingUnitVo;
+import com.lframework.xingyun.sc.vo.ledger.rel.QueryFundOrderingUnitVo;
+import org.apache.commons.collections.CollectionUtils;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.stereotype.Service;
 import javax.annotation.Resource;
@@ -34,11 +44,19 @@ import java.util.List;
 
 @Service
 public class FundCoordinationServiceImpl extends BaseMpServiceImpl<FundCoordinationMapper, FundCoordination> implements FundCoordinationService {
+    private static final String BPM_FLAG = "FUND_COORDINATION";
 
     @Resource
     private FundOrderingUnitService fundOrderingUnitService;
     @Resource
     private PendingDeliveryOrderService pendingDeliveryOrderService;
+    @Resource
+    private TransactorHandler transactorHandler;
+    @Resource
+    private FlowInstanceWrapperService flowInstanceWrapperService;
+    @Resource
+    private FundOrderingUnitDetailService fundOrderingUnitDetailService;
+
 
     @Override
     public PageResult<FundCoordination> query(Integer pageIndex, Integer pageSize, QueryFundCoordinationVo vo) {
@@ -110,6 +128,7 @@ public class FundCoordinationServiceImpl extends BaseMpServiceImpl<FundCoordinat
         if (!StringUtil.isBlank(vo.getType())) {
             data.setType(vo.getType());
         }
+        data.setStatus("AUDIT");
 
         getBaseMapper().insert(data);
 
@@ -131,6 +150,10 @@ public class FundCoordinationServiceImpl extends BaseMpServiceImpl<FundCoordinat
         }
         OpLogUtil.setVariable("id", data.getId());
         OpLogUtil.setExtra(vo);
+        //审核
+        String deptCode = transactorHandler.returnDeptCode(SecurityUtil.getCurrentUser().getId());
+        data.setDeptCode(deptCode);
+        flowInstanceWrapperService.startInstance(BPM_FLAG, data.getId(), BPM_FLAG, data);
 
         return data.getId();
     }
@@ -178,6 +201,57 @@ public class FundCoordinationServiceImpl extends BaseMpServiceImpl<FundCoordinat
         getBaseMapper().deleteById(id);
     }
 
+    @OpLog(type = OtherOpLogType.class, name = "修改资金协调手续，ID：{}", params = {"#id"})
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void updateStatus(String id, String status) {
+
+        FundCoordination data = getBaseMapper().findById(id);
+        if (ObjectUtil.isNull(data)) {
+            throw new DefaultClientException("资金协调手续不存在！");
+        }
+
+        LambdaUpdateWrapper<FundCoordination> updateWrapper = Wrappers.lambdaUpdate(FundCoordination.class)
+                .set(FundCoordination::getStatus, StringUtil.isBlank(status) ? null : status)
+                .eq(FundCoordination::getId, id);
+
+        getBaseMapper().update(updateWrapper);
+
+        OpLogUtil.setVariable("id", data.getId());
+        OpLogUtil.setExtra(id);
+    }
+
+    @OpLog(type = OtherOpLogType.class, name = "修改资金协调手续，ID：{}", params = {"#id"})
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void reviewPass(String id) {
+
+        FundCoordination data = getBaseMapper().findById(id);
+        if (ObjectUtil.isNull(data)) {
+            throw new DefaultClientException("资金协调手续不存在！");
+        }
+        //更新状态
+        updateStatus(id, "PASS");
+        //更新应收款台账的协调办理日期
+        QueryFundOrderingUnitVo vo = new QueryFundOrderingUnitVo();
+        vo.setFundId(id);
+        List<FundOrderingUnit> fundOrderingUnitList = fundOrderingUnitService.query(vo);
+        if (CollectionUtil.isNotEmpty(fundOrderingUnitList)){
+            for (FundOrderingUnit fundOrderingUnit : fundOrderingUnitList) {
+                //资金协调手续订货单位应收款明细
+                QueryFundOrderingUnitDetailVo vo1 = new QueryFundOrderingUnitDetailVo();
+                vo1.setFundOrderingUnitId(fundOrderingUnit.getId());
+                List<FundOrderingUnitDetail> fundOrderingUnitDetailList = fundOrderingUnitDetailService.query(vo1);
+                if (CollectionUtils.isNotEmpty(fundOrderingUnitDetailList)) {
+                   //更新应收款台账的协调办理日期
+
+                }
+            }
+        }
+        //解封订货单
+    }
+
+
     @Override
     public void cleanCacheByKey(Serializable key) {
 

@@ -52,4 +52,19 @@ public interface FundCoordinationService extends BaseMpService<FundCoordination>
      * @return
      */
     void deleteById(String id);
+
+    /**
+     * 更新审核状态
+     *
+     * @param id     主键
+     * @param status 审核状态
+     */
+    void updateStatus(String id, String status);
+
+    /**
+     * 审核通过
+     *
+     * @param id 主键
+     */
+    void reviewPass(String id);
 }