报价：业务员报价-审核流程

@@ -22,6 +22,7 @@ import com.lframework.xingyun.sc.procurement.entity.ProcurementDomesticCustomerC
 import com.lframework.xingyun.sc.procurement.entity.ProcurementForeignTradeCredit;
 import com.lframework.xingyun.sc.procurement.service.credit.ProcurementDomesticCustomerCreditService;
 import com.lframework.xingyun.sc.procurement.service.credit.ProcurementForeignTradeCreditService;
+import com.lframework.xingyun.sc.procurement.service.quotation.SalesmanQuotationService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorLineService;
 import com.lframework.xingyun.sc.service.contract.ContractChangeApplicationService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorStandardService;
@@ -154,6 +155,8 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
     private ProcurementDomesticCustomerCreditService procurementDomesticCustomerCreditService;
     @Resource
     private ProcurementForeignTradeCreditService procurementForeignTradeCreditService;
+    @Resource
+    private SalesmanQuotationService salesmanQuotationService;
 
 
 
@@ -241,6 +244,9 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
             case "IN_CHANGE_REVIEW":
                 handleResultDomesticCustomerCreditChangeReviewData(flowStatus, businessId);
                 break;
+            case "SALESMAN_QUOTATION":
+                handleSalesmanQuotationData(flowStatus, businessId);
+                break;
             default:
                 break;
         }
@@ -1100,4 +1106,21 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
             }
         }
     }
+
+    /**
+     * 业务员报价审核业务数据处理
+     *
+     * @param flowStatus 审核结果
+     * @param businessId 业务ID
+     */
+    private void handleSalesmanQuotationData(String flowStatus, String businessId) {
+        if (FlowInstanceStatus.APPROVE_PASS.getCode().equals(flowStatus)
+                || FlowInstanceStatus.FINISH.getCode().equals(flowStatus)) {
+            salesmanQuotationService.updateApprovalStatus(businessId, "PASS");
+        } else if (FlowInstanceStatus.REVOKE.getCode().equals(flowStatus)
+                || FlowInstanceStatus.REFUSE.getCode().equals(flowStatus)
+                || FlowInstanceStatus.TERMINATION.getCode().equals(flowStatus)) {
+            salesmanQuotationService.updateApprovalStatus(businessId, "REFUSE");
+        }
+    }
 }

@@ -81,7 +81,8 @@ public class SalesmanQuotationController extends DefaultBaseController {
      * @return 详情
      */
     @ApiOperation("详情")
-    @HasPermission({"procure-manage:sales-price:query"})
+    @HasPermission({"procure-manage:sales-price:query", "procure-manage:sales-price:review",
+            "procure-manage:sales-price:approve"})
     @ApiImplicitParam(value = "id", name = "id", paramType = "query", required = true)
     @GetMapping("")
     public InvokeResult<SalesmanQuotation> get(@NotBlank(message = "id不能为空！") String id) {

@@ -237,6 +237,24 @@ public class SalesmanQuotation extends BaseEntity implements BaseDto {
     private String status;
 
     /**
+     * 是否展示审核按钮(非持久化字段)
+     */
+    @TableField(exist = false)
+    private Boolean showExamine = false;
+
+    /**
+     * 是否展示审核详情按钮(非持久化字段)
+     */
+    @TableField(exist = false)
+    private Boolean showExamineDetail;
+
+    /**
+     * 角色code(非持久化字段)
+     */
+    @TableField(exist = false)
+    private String roleCode;
+
+    /**
      * 报价明细列表
      */
     @TableField(exist = false)

@@ -4,6 +4,11 @@ import com.baomidou.mybatisplus.core.conditions.Wrapper;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.github.pagehelper.PageInfo;
+import com.lframework.starter.bpm.dto.FlowTaskDto;
+import com.lframework.starter.bpm.entity.FlowInstanceWrapper;
+import com.lframework.starter.bpm.mappers.FlowTaskWrapperMapper;
+import com.lframework.starter.bpm.service.FlowInstanceWrapperService;
+import com.lframework.starter.bpm.vo.flow.task.QueryTodoTaskListVo;
 import com.lframework.starter.common.exceptions.impl.DefaultClientException;
 import com.lframework.starter.common.utils.Assert;
 import com.lframework.starter.common.utils.CollectionUtil;
@@ -17,7 +22,9 @@ import com.lframework.starter.web.core.utils.OpLogUtil;
 import com.lframework.starter.web.core.utils.PageHelperUtil;
 import com.lframework.starter.web.core.utils.PageResultUtil;
 import com.lframework.starter.web.inner.components.oplog.OtherOpLogType;
+import com.lframework.starter.web.inner.entity.SysRole;
 import com.lframework.starter.web.inner.entity.SysUser;
+import com.lframework.starter.web.inner.service.system.SysRoleService;
 import com.lframework.starter.web.inner.service.system.SysUserService;
 import com.lframework.xingyun.basedata.entity.BreedRelationship;
 import com.lframework.xingyun.basedata.service.breed.BreedRelationshipService;
@@ -43,8 +50,11 @@ import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.Collections;
+import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
+import java.util.Set;
 import java.util.stream.Collectors;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
@@ -58,14 +68,26 @@ import javax.annotation.Resource;
 public class SalesmanQuotationServiceImpl
         extends BaseMpServiceImpl<SalesmanQuotationMapper, SalesmanQuotation>
         implements SalesmanQuotationService {
+
+    /**
+     * 流程标识
+     */
+    private static final String BPM_FLAG = "SALESMAN_QUOTATION";
+
     @Resource
     private SysUserService sysUserService;
     @Resource
+    private FlowInstanceWrapperService flowInstanceWrapperService;
+    @Resource
+    private FlowTaskWrapperMapper flowTaskWrapperMapper;
+    @Resource
     private ProcurementDomesticCustomerCreditService procurementDomesticCustomerCreditService;
     @Resource
     private BreedRelationshipService breedRelationshipService;
     @Resource
     private SalesmanQuotationLineService salesmanQuotationLineService;
+    @Resource
+    private SysRoleService sysRoleService;
 
     /**
      * 编号前缀
@@ -97,6 +119,7 @@ public class SalesmanQuotationServiceImpl
 
         PageHelperUtil.startPage(pageIndex, pageSize);
         List<SalesmanQuotation> datas = this.query(vo);
+        fillShowExamineInfo(datas);
         return PageResultUtil.convert(new PageInfo<>(datas));
     }
 
@@ -127,6 +150,7 @@ public class SalesmanQuotationServiceImpl
         QuerySalesmanQuotationLineVo lineQueryVo = new QuerySalesmanQuotationLineVo();
         lineQueryVo.setQuotationId(id);
         data.setQuotationLineList(salesmanQuotationLineService.query(lineQueryVo));
+        fillShowExamineInfo(Collections.singletonList(data));
 
         return data;
     }
@@ -153,6 +177,33 @@ public class SalesmanQuotationServiceImpl
         getBaseMapper().insert(data);
 
         saveCreateLines(data.getId(), vo.getQuotationLineList(), quotationBreedMap, vo.getPriced());
+        SalesmanQuotation salesmanQuotation = getBaseMapper().findById(data.getId());
+        List<SysRole> sysRoleList = sysRoleService.getByUserId(SecurityUtil.getCurrentUser().getId());
+        String roleCode = null;
+        if (CollectionUtil.isNotEmpty(sysRoleList)) {
+            // 1. 提取角色列表中的所有 code，转换为 Set 集合，提升后续判断效率
+            Set<String> roleCodeSet = sysRoleList.stream()
+                    .map(SysRole::getCode)
+                    .collect(Collectors.toSet());
+
+            // 2. 判断是否包含采购主管相关的角色
+            if (roleCodeSet.contains("htcgeczg") || roleCodeSet.contains("htcgyczg")
+                    || roleCodeSet.contains("ltcgczg") || roleCodeSet.contains("ztcgczg")) {
+                roleCode = "cgczg";
+            } else if (roleCodeSet.contains("qyjl")) {
+                // 3. 如果没有，继续判断是否包含区域经理
+                roleCode = "qyjl";
+            } else if (roleCodeSet.contains("nmcgkywy")) {
+                // 4. 如果还没有，继续判断是否包含内贸采购科业务员
+                roleCode = "nmcgkywy";
+            } else {
+                throw new DefaultClientException("当前角色无法发起报价！");
+            }
+        } else {
+            throw new DefaultClientException("当前角色无法发起报价！");
+        }
+        salesmanQuotation.setRoleCode(roleCode);
+        flowInstanceWrapperService.startInstance(BPM_FLAG, data.getId(), BPM_FLAG, salesmanQuotation);
 
         OpLogUtil.setVariable("id", data.getId());
         OpLogUtil.setExtra(vo);
@@ -183,6 +234,33 @@ public class SalesmanQuotationServiceImpl
         getBaseMapper().updateById(data);
 
         saveOrUpdateLines(data.getId(), vo.getQuotationLineList(), quotationBreedMap, vo.getPriced());
+        SalesmanQuotation salesmanQuotation = getBaseMapper().findById(data.getId());
+        List<SysRole> sysRoleList = sysRoleService.getByUserId(SecurityUtil.getCurrentUser().getId());
+        String roleCode = null;
+        if (CollectionUtil.isNotEmpty(sysRoleList)) {
+            // 1. 提取角色列表中的所有 code，转换为 Set 集合，提升后续判断效率
+            Set<String> roleCodeSet = sysRoleList.stream()
+                    .map(SysRole::getCode)
+                    .collect(Collectors.toSet());
+
+            // 2. 判断是否包含采购主管相关的角色
+            if (roleCodeSet.contains("htcgeczg") || roleCodeSet.contains("htcgyczg")
+                    || roleCodeSet.contains("ltcgczg") || roleCodeSet.contains("ztcgczg")) {
+                roleCode = "cgczg";
+            } else if (roleCodeSet.contains("qyjl")) {
+                // 3. 如果没有，继续判断是否包含区域经理
+                roleCode = "qyjl";
+            } else if (roleCodeSet.contains("nmcgkywy")) {
+                // 4. 如果还没有，继续判断是否包含内贸采购科业务员
+                roleCode = "nmcgkywy";
+            } else {
+                throw new DefaultClientException("当前角色无法发起报价！");
+            }
+        } else {
+            throw new DefaultClientException("当前角色无法发起报价！");
+        }
+        salesmanQuotation.setRoleCode(roleCode);
+        flowInstanceWrapperService.startInstance(BPM_FLAG, data.getId(), BPM_FLAG, salesmanQuotation);
 
         OpLogUtil.setVariable("id", data.getId());
         OpLogUtil.setExtra(vo);
@@ -209,6 +287,24 @@ public class SalesmanQuotationServiceImpl
         OpLogUtil.setExtra(data);
     }
 
+    /**
+     * 更新审核状态
+     *
+     * @param id 主键ID
+     * @param approvalStatus 审核状态
+     */
+    @Override
+    public void updateApprovalStatus(String id, String approvalStatus) {
+        if (StringUtils.isBlank(id) || StringUtils.isBlank(approvalStatus)) {
+            throw new DefaultClientException("业务员报价ID、审核状态不能为空！");
+        }
+
+        Wrapper<SalesmanQuotation> wrapper = Wrappers.lambdaUpdate(SalesmanQuotation.class)
+                .set(SalesmanQuotation::getApprovalStatus, approvalStatus)
+                .eq(SalesmanQuotation::getId, id);
+        getBaseMapper().update(wrapper);
+    }
+
 
     /**
      * 构建新增实体
@@ -242,6 +338,7 @@ public class SalesmanQuotationServiceImpl
         data.setSupplierId(supplier.getId());
         data.setPurchaseDepartment(supplier.getPurchaseDepartment());
         data.setRegion(supplier.getRegion());
+        data.setApprovalStatus(CustomerDevelopStatus.AUDIT.name());
         data.setValidityPeriod(vo.getValidityPeriod());
         data.setLongTermOperation(vo.getLongTermOperation());
         data.setTerminalCustomer(vo.getTerminalCustomer());
@@ -284,6 +381,7 @@ public class SalesmanQuotationServiceImpl
         data.setSupplierId(supplier.getId());
         data.setPurchaseDepartment(supplier.getPurchaseDepartment());
         data.setRegion(supplier.getRegion());
+        data.setApprovalStatus(CustomerDevelopStatus.AUDIT.name());
         data.setValidityPeriod(vo.getValidityPeriod());
         data.setLongTermOperation(vo.getLongTermOperation());
         data.setTerminalCustomer(vo.getTerminalCustomer());
@@ -587,6 +685,43 @@ public class SalesmanQuotationServiceImpl
     }
 
     /**
+     * 回填审核按钮展示信息
+     *
+     * @param datas 数据列表
+     */
+    private void fillShowExamineInfo(List<SalesmanQuotation> datas) {
+        if (CollectionUtil.isEmpty(datas)) {
+            return;
+        }
+
+        List<SalesmanQuotation> validDatas = datas.stream()
+                .filter(Objects::nonNull)
+                .collect(Collectors.toList());
+        if (CollectionUtil.isEmpty(validDatas)) {
+            return;
+        }
+
+        List<String> businessIds = validDatas.stream().map(SalesmanQuotation::getId).collect(Collectors.toList());
+        List<FlowInstanceWrapper> flowList = flowInstanceWrapperService.getFlowByBusinessIdList(businessIds);
+        Set<String> flowBusinessIdSet = CollectionUtil.isNotEmpty(flowList)
+                ? flowList.stream().map(FlowInstanceWrapper::getBusinessId).collect(Collectors.toSet())
+                : new HashSet<>();
+
+        List<FlowTaskDto> todoFlowTaskList = flowTaskWrapperMapper.queryTodoList(
+                new QueryTodoTaskListVo(), SecurityUtil.getCurrentUser().getId());
+        Set<String> todoBusinessIdSet = CollectionUtil.isNotEmpty(todoFlowTaskList)
+                ? todoFlowTaskList.stream().map(FlowTaskDto::getBusinessId).collect(Collectors.toSet())
+                : new HashSet<>();
+
+        for (SalesmanQuotation data : validDatas) {
+            boolean hasFlow = flowBusinessIdSet.contains(data.getId());
+            boolean hasTodo = todoBusinessIdSet.contains(data.getId());
+            data.setShowExamineDetail(hasFlow && StringUtils.isNotBlank(data.getApprovalStatus()));
+            data.setShowExamine(hasTodo && CustomerDevelopStatus.AUDIT.name().equals(data.getApprovalStatus()));
+        }
+    }
+
+    /**
      * 清理缓存
      *
      * @param key 缓存键

@@ -60,6 +60,14 @@ public interface SalesmanQuotationService extends BaseMpService<SalesmanQuotatio
     void cancel(String id);
 
     /**
+     * 更新审核状态
+     *
+     * @param id 主键ID
+     * @param approvalStatus 审核状态
+     */
+    void updateApprovalStatus(String id, String approvalStatus);
+
+    /**
      * 生成编号
      *
      * @return 编号