采购-供应商报价：成交数据

@@ -1828,3 +1828,32 @@ CREATE TABLE `procurement_supplier_quotation_project_quote`
     KEY `idx_psqpjq_quote_time` (`quote_time`),
     KEY `idx_psqpjq_create_time` (`create_time`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci COMMENT='供应商报价项目报价';
+
+CREATE TABLE `procurement_supplier_quotation_deal`
+(
+    `id`                  varchar(32)    NOT NULL COMMENT 'ID',
+    `project_id`          varchar(32)    NOT NULL COMMENT '报价项目ID',
+    `project_code`        varchar(20)    NOT NULL COMMENT '项目编号',
+    `project_name`        varchar(200)   NOT NULL COMMENT '项目名称',
+    `quote_time`          datetime       NOT NULL COMMENT '报价开始时间',
+    `supplier_id`         varchar(32)    NOT NULL COMMENT '供应商ID',
+    `supplier_name`       varchar(200)   NOT NULL COMMENT '供应商名称',
+    `product_id`          varchar(32)    NOT NULL COMMENT '品种ID',
+    `quantity`            decimal(18, 5) NOT NULL COMMENT '数量',
+    `price`               decimal(18, 10) NOT NULL COMMENT '价格',
+    `purchase_department` varchar(32)             DEFAULT NULL COMMENT '采购处',
+    `principal_id`        varchar(32)             DEFAULT NULL COMMENT '负责人ID',
+    `principal_name`      varchar(64)             DEFAULT NULL COMMENT '负责人',
+    `assign_time`         datetime                DEFAULT NULL COMMENT '分配时间',
+    `create_by_id`        varchar(32)             DEFAULT NULL COMMENT '创建人ID',
+    `create_by`           varchar(64)             DEFAULT NULL COMMENT '创建人',
+    `update_by_id`        varchar(32)             DEFAULT NULL COMMENT '更新人ID',
+    `update_by`           varchar(64)             DEFAULT NULL COMMENT '更新人',
+    `create_time`         datetime                DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `update_time`         datetime                DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
+    PRIMARY KEY (`id`),
+    UNIQUE KEY `uk_psqd_project_supplier` (`project_id`, `supplier_id`),
+    KEY `idx_psqd_purchase_department` (`purchase_department`),
+    KEY `idx_psqd_principal_id` (`principal_id`),
+    KEY `idx_psqd_create_time` (`create_time`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci COMMENT='供应商报价成交表';

@@ -130,7 +130,7 @@ public class SalesmanQuotationController extends DefaultBaseController {
     /**
      * 成交/终止
      */
-    @ApiOperation("成交/终止")
+    @ApiOperation("完成/终止")
     @PostMapping("/updateStatus")
     public InvokeResult<Void> updateStatus(@NotBlank(message = "id不能为空！") String id,
                                            @NotBlank(message = "状态不能为空！") String status) {

+package com.lframework.xingyun.sc.procurement.controller.quotation;
+
+import com.lframework.starter.common.exceptions.impl.DefaultClientException;
+import com.lframework.starter.web.core.annotations.security.HasPermission;
+import com.lframework.starter.web.core.components.resp.InvokeResult;
+import com.lframework.starter.web.core.components.resp.InvokeResultBuilder;
+import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.starter.web.core.controller.DefaultBaseController;
+import com.lframework.starter.web.inner.bo.system.user.QuerySysUserBo;
+import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationDeal;
+import com.lframework.xingyun.sc.procurement.service.quotation.SupplierQuotationDealService;
+import com.lframework.xingyun.sc.procurement.vo.quotation.AssignSupplierQuotationDealVo;
+import com.lframework.xingyun.sc.procurement.vo.quotation.QuerySupplierQuotationDealVo;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import java.util.List;
+import javax.annotation.Resource;
+import javax.validation.Valid;
+import javax.validation.constraints.NotBlank;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@Api(tags = "供应商报价成交表")
+@Validated
+@RestController
+@RequestMapping("/procurement/supplierQuotationDeal")
+public class SupplierQuotationDealController extends DefaultBaseController {
+
+    @Resource
+    private SupplierQuotationDealService supplierQuotationDealService;
+
+    @ApiOperation("分页查询")
+    @HasPermission({"procure-manage:quote-manage:query"})
+    @GetMapping("/query")
+    public InvokeResult<PageResult<SupplierQuotationDeal>> query(@Valid QuerySupplierQuotationDealVo vo) {
+        return InvokeResultBuilder.success(
+                supplierQuotationDealService.query(getPageIndex(vo), getPageSize(vo), vo));
+    }
+
+    @ApiOperation("详情")
+    @HasPermission({"procure-manage:quote-manage:query"})
+    @ApiImplicitParam(value = "id", name = "id", paramType = "query", required = true)
+    @GetMapping("")
+    public InvokeResult<SupplierQuotationDeal> get(@NotBlank(message = "id不能为空！") String id) {
+        SupplierQuotationDeal data = supplierQuotationDealService.findById(id);
+        if (data == null) {
+            throw new DefaultClientException("成交数据不存在！");
+        }
+        return InvokeResultBuilder.success(data);
+    }
+
+    @ApiOperation("分配负责人")
+    @HasPermission({"procure-manage:quote-manage:assign"})
+    @PutMapping("/assign")
+    public InvokeResult<Void> assign(@Valid @RequestBody AssignSupplierQuotationDealVo vo) {
+        supplierQuotationDealService.assign(vo);
+        return InvokeResultBuilder.success();
+    }
+
+    @ApiOperation("获取当前采购处可分配人员")
+    @GetMapping("/assignUsers")
+    public InvokeResult<List<QuerySysUserBo>> getCurrentPurchaseDeptUsers(@NotBlank(message = "采购处不能为空！") String purchaseDepartment) {
+        return InvokeResultBuilder.success(supplierQuotationDealService.getDeptUsersWithChildren(purchaseDepartment));
+    }
+}

+package com.lframework.xingyun.sc.procurement.entity;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.lframework.starter.web.core.dto.BaseDto;
+import com.lframework.starter.web.core.entity.BaseEntity;
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+import lombok.Data;
+
+@Data
+@TableName("procurement_supplier_quotation_deal")
+public class SupplierQuotationDeal extends BaseEntity implements BaseDto {
+
+    private static final long serialVersionUID = 1L;
+
+    public static final String CACHE_NAME = "SupplierQuotationDeal";
+
+    /**
+     * ID
+     */
+    private String id;
+
+    /**
+     * 报价项目ID
+     */
+    private String projectId;
+
+    /**
+     * 项目编号
+     */
+    private String projectCode;
+
+    /**
+     * 项目名称
+     */
+    private String projectName;
+
+    /**
+     * 报价开始时间
+     */
+    private LocalDateTime quoteTime;
+
+    /**
+     * 供应商ID
+     */
+    private String supplierId;
+
+    /**
+     * 供应商名称
+     */
+    private String supplierName;
+
+    /**
+     * 品种ID
+     */
+    private String productId;
+
+    /**
+     * 品种名称
+     */
+    @TableField(exist = false)
+    private String productName;
+
+    /**
+     * 品种代号
+     */
+    @TableField(exist = false)
+    private String productCode;
+
+    /**
+     * 数量
+     */
+    private BigDecimal quantity;
+
+    /**
+     * 价格
+     */
+    private BigDecimal price;
+
+    /**
+     * 采购处
+     */
+    private String purchaseDepartment;
+
+    /**
+     * 采购处名称
+     */
+    @TableField(exist = false)
+    private String purchaseDepartmentName;
+
+    /**
+     * 负责人ID
+     */
+    private String principalId;
+
+    /**
+     * 负责人
+     */
+    private String principalName;
+
+    /**
+     * 分配时间
+     */
+    private LocalDateTime assignTime;
+
+    /**
+     * 创建人ID
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private String createById;
+
+    /**
+     * 创建人
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private String createBy;
+
+    /**
+     * 更新人ID
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private String updateById;
+
+    /**
+     * 更新人
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private String updateBy;
+
+    /**
+     * 创建时间
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updateTime;
+}
+

@@ -318,7 +318,7 @@ public class SalesmanQuotationServiceImpl
     }
 
     /**
-     * 成交/中止
+     * 完成/中止
      *
      * @param id     主键ID
      * @param status 状态

+package com.lframework.xingyun.sc.procurement.impl.quotation;
+
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.github.pagehelper.PageInfo;
+import com.lframework.starter.common.exceptions.impl.DefaultClientException;
+import com.lframework.starter.common.utils.CollectionUtil;
+import com.lframework.starter.web.core.annotations.oplog.OpLog;
+import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.starter.web.core.components.security.SecurityUtil;
+import com.lframework.starter.web.core.impl.BaseMpServiceImpl;
+import com.lframework.starter.web.core.utils.IdUtil;
+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.bo.system.user.QuerySysUserBo;
+import com.lframework.starter.web.inner.components.oplog.OtherOpLogType;
+import com.lframework.starter.web.inner.entity.SysDept;
+import com.lframework.starter.web.inner.entity.SysUser;
+import com.lframework.starter.web.inner.entity.SysUserDept;
+import com.lframework.starter.web.inner.service.system.SysDeptService;
+import com.lframework.starter.web.inner.service.system.SysUserDeptService;
+import com.lframework.starter.web.inner.service.system.SysUserService;
+import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationDeal;
+import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProject;
+import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProjectQuote;
+import com.lframework.xingyun.sc.procurement.mappers.quotation.SupplierQuotationDealMapper;
+import com.lframework.xingyun.sc.procurement.mappers.quotation.SupplierQuotationProjectMapper;
+import com.lframework.xingyun.sc.procurement.mappers.quotation.SupplierQuotationProjectQuoteMapper;
+import com.lframework.xingyun.sc.procurement.service.quotation.SupplierQuotationDealService;
+import com.lframework.xingyun.sc.procurement.vo.quotation.AssignSupplierQuotationDealVo;
+import com.lframework.xingyun.sc.procurement.vo.quotation.QuerySupplierQuotationDealVo;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+import javax.annotation.Resource;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+public class SupplierQuotationDealServiceImpl
+        extends BaseMpServiceImpl<SupplierQuotationDealMapper, SupplierQuotationDeal>
+        implements SupplierQuotationDealService {
+    @Resource
+    private SupplierQuotationProjectMapper supplierQuotationProjectMapper;
+    @Resource
+    private SupplierQuotationProjectQuoteMapper supplierQuotationProjectQuoteMapper;
+    @Resource
+    private SysDeptService sysDeptService;
+    @Resource
+    private SysUserDeptService sysUserDeptService;
+    @Resource
+    private SysUserService sysUserService;
+
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void syncDealByBidStatus(String projectId, String supplierId) {
+        if (StringUtils.isBlank(projectId) || StringUtils.isBlank(supplierId)) {
+            return;
+        }
+        SupplierQuotationProject project = supplierQuotationProjectMapper.selectById(projectId);
+        SupplierQuotationProjectQuote quote = supplierQuotationProjectQuoteMapper.findByProjectAndSupplier(projectId, supplierId);
+        if (project == null || quote == null) {
+            throw new DefaultClientException("成交数据同步失败，报价项目或报价记录不存在！");
+        }
+
+        List<SysDept> purchaseDept = sysDeptService.getPurchaseDept(quote.getSupplierId());
+        String purchaseDepartment = CollectionUtil.isNotEmpty(purchaseDept) ? purchaseDept.get(0).getId() : null;
+        SupplierQuotationDeal exist = getBaseMapper().findByProjectAndSupplier(projectId, supplierId);
+        if (exist == null) {
+            SupplierQuotationDeal data = new SupplierQuotationDeal();
+            data.setId(IdUtil.getId());
+            data.setProjectId(project.getId());
+            data.setProjectCode(project.getCode());
+            data.setProjectName(project.getName());
+            data.setQuoteTime(project.getStartTime());
+            data.setSupplierId(quote.getSupplierId());
+            data.setSupplierName(quote.getSupplierName());
+            data.setProductId(project.getProductId());
+            data.setQuantity(quote.getQuantity());
+            data.setPrice(quote.getPrice());
+            data.setPurchaseDepartment(purchaseDepartment);
+            getBaseMapper().insert(data);
+        } else {
+            LambdaUpdateWrapper<SupplierQuotationDeal> updateWrapper = Wrappers.lambdaUpdate(SupplierQuotationDeal.class)
+                    .set(SupplierQuotationDeal::getProjectCode, project.getCode())
+                    .set(SupplierQuotationDeal::getProjectName, project.getName())
+                    .set(SupplierQuotationDeal::getQuoteTime, project.getStartTime())
+                    .set(SupplierQuotationDeal::getSupplierName, quote.getSupplierName())
+                    .set(SupplierQuotationDeal::getProductId, project.getProductId())
+                    .set(SupplierQuotationDeal::getQuantity, quote.getQuantity())
+                    .set(SupplierQuotationDeal::getPrice, quote.getPrice())
+                    .set(SupplierQuotationDeal::getPurchaseDepartment, purchaseDepartment)
+                    .eq(SupplierQuotationDeal::getId, exist.getId());
+            getBaseMapper().update(updateWrapper);
+        }
+    }
+
+    @Override
+    public PageResult<SupplierQuotationDeal> query(Integer pageIndex, Integer pageSize, QuerySupplierQuotationDealVo vo) {
+        PageHelperUtil.startPage(pageIndex, pageSize);
+        List<SupplierQuotationDeal> datas = query(vo);
+        return PageResultUtil.convert(new PageInfo<>(datas));
+    }
+
+    @Override
+    public SupplierQuotationDeal findById(String id) {
+        SupplierQuotationDeal data = getBaseMapper().findById(id);
+        if (data == null) {
+            return null;
+        }
+        return data;
+    }
+
+    @OpLog(type = OtherOpLogType.class, name = "分配供应商报价成交数据，ID：{}", params = {"#vo.id"})
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void assign(AssignSupplierQuotationDealVo vo) {
+        SupplierQuotationDeal data = getBaseMapper().findById(vo.getId());
+        if (data == null) {
+            throw new DefaultClientException("成交数据不存在！");
+        }
+        validateCurrentUserCanManage(data);
+
+        SysUser principal = sysUserService.findById(vo.getPrincipalId());
+        if (principal == null) {
+            throw new DefaultClientException("负责人不存在！");
+        }
+
+        LambdaUpdateWrapper<SupplierQuotationDeal> updateWrapper = Wrappers.lambdaUpdate(SupplierQuotationDeal.class)
+                .set(SupplierQuotationDeal::getPrincipalId, principal.getId())
+                .set(SupplierQuotationDeal::getPrincipalName, principal.getName())
+                .set(SupplierQuotationDeal::getAssignTime, LocalDateTime.now())
+                .eq(SupplierQuotationDeal::getId, data.getId());
+        getBaseMapper().update(updateWrapper);
+
+        OpLogUtil.setExtra(vo);
+    }
+
+    @Override
+    public List<QuerySysUserBo> getDeptUsersWithChildren(String purchaseDepartment) {
+        if (StringUtils.isBlank(purchaseDepartment)) {
+            return Collections.emptyList();
+        }
+
+        Map<String, List<String>> deptChildIdMap = sysDeptService.getDeptChildIdMap(Collections.singletonList(purchaseDepartment));
+        List<String> deptIdList = deptChildIdMap.get(purchaseDepartment);
+        if (CollectionUtil.isEmpty(deptIdList)) {
+            deptIdList = new ArrayList<>();
+            deptIdList.add(purchaseDepartment);
+        } else if (!deptIdList.contains(purchaseDepartment)) {
+            deptIdList = new ArrayList<>(deptIdList);
+            deptIdList.add(purchaseDepartment);
+        }
+
+        Set<String> userIdSet = deptIdList.stream()
+                .flatMap(deptId -> {
+                    List<SysUserDept> userDeptList = sysUserDeptService.getByDeptId(deptId);
+                    if (CollectionUtil.isEmpty(userDeptList)) {
+                        return Stream.empty();
+                    }
+                    return userDeptList.stream();
+                })
+                .map(SysUserDept::getUserId)
+                .filter(StringUtils::isNotBlank)
+                .collect(Collectors.toSet());
+        if (userIdSet.isEmpty()) {
+            return Collections.emptyList();
+        }
+
+        List<SysUser> userList = sysUserService.listByIds(new ArrayList<>(userIdSet));
+        if (CollectionUtil.isEmpty(userList)) {
+            return Collections.emptyList();
+        }
+        return userList.stream()
+                .map(QuerySysUserBo::new)
+                .collect(Collectors.toList());
+    }
+
+
+    @Override
+    public void cleanCacheByKey(Serializable key) {
+    }
+
+    private List<SupplierQuotationDeal> query(QuerySupplierQuotationDealVo vo) {
+        String currentUserId = SecurityUtil.getCurrentUser().getId();
+        List<String> purchaseDepartmentList = resolveUserPurchaseDepartments(currentUserId);
+        return getBaseMapper().query(vo, purchaseDepartmentList, currentUserId);
+    }
+
+    private void validateCurrentUserCanManage(SupplierQuotationDeal data) {
+        List<String> purchaseDepartmentList = resolveUserPurchaseDepartments(SecurityUtil.getCurrentUser().getId());
+        if (CollectionUtil.isEmpty(purchaseDepartmentList) || !purchaseDepartmentList.contains(data.getPurchaseDepartment())) {
+            throw new DefaultClientException("当前用户无权分配该成交数据！");
+        }
+    }
+
+    private List<String> resolveUserPurchaseDepartments(String userId) {
+        List<SysUserDept> userDeptList = sysUserDeptService.getByUserId(userId);
+        if (CollectionUtil.isEmpty(userDeptList)) {
+            return Collections.emptyList();
+        }
+        return userDeptList.stream()
+                .map(SysUserDept::getDeptId)
+                .filter(StringUtils::isNotBlank)
+                .distinct()
+                .collect(Collectors.toList());
+    }
+}

@@ -24,6 +24,7 @@ import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProject;
 import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationProjectQuote;
 import com.lframework.xingyun.sc.procurement.mappers.quotation.SupplierQuotationProjectMapper;
 import com.lframework.xingyun.sc.procurement.mappers.quotation.SupplierQuotationProjectQuoteMapper;
+import com.lframework.xingyun.sc.procurement.service.quotation.SupplierQuotationDealService;
 import com.lframework.xingyun.sc.procurement.service.quotation.SupplierQuotationProjectQuoteService;
 import com.lframework.xingyun.sc.procurement.vo.quotation.SupplierQuotationProjectQuoteVo;
 import com.lframework.xingyun.sc.procurement.vo.quotation.UpdateSupplierQuotationProjectQuoteBidStatusVo;
@@ -44,9 +45,9 @@ public class SupplierQuotationProjectQuoteServiceImpl
         extends BaseMpServiceImpl<SupplierQuotationProjectQuoteMapper, SupplierQuotationProjectQuote>
         implements SupplierQuotationProjectQuoteService {
 
-    private static final String BID_STATUS_WIN = "中标";
-    private static final String BID_STATUS_LOSE = "未中标";
-    private static final String BID_STATUS_ABORT = "废标";
+    private static final String BID_STATUS_WIN = "WIN";
+    private static final String BID_STATUS_LOSE = "LOSE";
+    private static final String BID_STATUS_ABORT = "ABORT";
 
     private static final String PROJECT_STATUS_COMPLETED = "COMPLETED";
     private static final String PROJECT_STATUS_ABORTED = "ABORTED";
@@ -71,6 +72,8 @@ public class SupplierQuotationProjectQuoteServiceImpl
     private BreedRelationshipService breedRelationshipService;
     @Resource
     private ApplicationEventPublisher applicationEventPublisher;
+    @Resource
+    private SupplierQuotationDealService supplierQuotationDealService;
 
     @OpLog(type = OtherOpLogType.class, name = "供应商报价项目报价，项目ID：{}", params = {"#vo.projectId"})
     @Transactional(rollbackFor = Exception.class)
@@ -185,6 +188,9 @@ public class SupplierQuotationProjectQuoteServiceImpl
                 .set(SupplierQuotationProjectQuote::getBidStatus, bidStatus)
                 .eq(SupplierQuotationProjectQuote::getId, exist.getId());
         getBaseMapper().update(updateWrapper);
+        if (BID_STATUS_WIN.equals(bidStatus)) {
+            supplierQuotationDealService.syncDealByBidStatus(vo.getProjectId(), vo.getSupplierId());
+        }
         publishChangedEvent(vo.getProjectId(), "BID_STATUS_UPDATE");
 
         OpLogUtil.setExtra(vo);

+package com.lframework.xingyun.sc.procurement.mappers.quotation;
+
+import com.lframework.starter.web.core.mapper.BaseMapper;
+import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationDeal;
+import com.lframework.xingyun.sc.procurement.vo.quotation.QuerySupplierQuotationDealVo;
+import java.time.LocalDate;
+import java.util.List;
+import org.apache.ibatis.annotations.Param;
+
+public interface SupplierQuotationDealMapper extends BaseMapper<SupplierQuotationDeal> {
+
+    SupplierQuotationDeal findById(@Param("id") String id);
+
+    SupplierQuotationDeal findByProjectAndSupplier(@Param("projectId") String projectId,
+                                                   @Param("supplierId") String supplierId);
+
+    List<SupplierQuotationDeal> query(@Param("vo") QuerySupplierQuotationDealVo vo,
+                                      @Param("purchaseDepartmentList") List<String> purchaseDepartmentList,
+                                      @Param("userId") String userId);
+}
+

+package com.lframework.xingyun.sc.procurement.service.quotation;
+
+import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.starter.web.core.service.BaseMpService;
+import com.lframework.starter.web.inner.bo.system.user.QuerySysUserBo;
+import com.lframework.xingyun.sc.procurement.entity.SupplierQuotationDeal;
+import com.lframework.xingyun.sc.procurement.vo.quotation.AssignSupplierQuotationDealVo;
+import com.lframework.xingyun.sc.procurement.vo.quotation.QuerySupplierQuotationDealVo;
+import java.util.List;
+
+public interface SupplierQuotationDealService extends BaseMpService<SupplierQuotationDeal> {
+
+    /**
+     * 成交数据
+     *
+     * @param projectId  项目主键
+     * @param supplierId 供应商主键
+     */
+    void syncDealByBidStatus(String projectId, String supplierId);
+
+    PageResult<SupplierQuotationDeal> query(Integer pageIndex, Integer pageSize, QuerySupplierQuotationDealVo vo);
+
+    SupplierQuotationDeal findById(String id);
+
+    /**
+     * 分配人员
+     *
+     * @param vo 数据
+     */
+    void assign(AssignSupplierQuotationDealVo vo);
+
+    /**
+     * 获取当前部门及其子部门下人员
+     *
+     * @param purchaseDepartment 部门主键
+     */
+    List<QuerySysUserBo> getDeptUsersWithChildren(String purchaseDepartment);
+}

+package com.lframework.xingyun.sc.procurement.vo.quotation;
+
+import com.lframework.starter.web.core.vo.BaseVo;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import javax.validation.constraints.NotBlank;
+import lombok.Data;
+
+@Data
+public class AssignSupplierQuotationDealVo implements BaseVo, Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "成交表ID", required = true)
+    @NotBlank(message = "成交表ID不能为空！")
+    private String id;
+
+    @ApiModelProperty(value = "负责人ID", required = true)
+    @NotBlank(message = "负责人ID不能为空！")
+    private String principalId;
+}
+

+package com.lframework.xingyun.sc.procurement.vo.quotation;
+
+import com.lframework.starter.web.core.vo.BaseVo;
+import com.lframework.starter.web.core.vo.PageVo;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import lombok.Data;
+
+@Data
+public class QuerySupplierQuotationDealVo extends PageVo implements BaseVo, Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty("项目名称")
+    private String projectName;
+
+    @ApiModelProperty("项目编号")
+    private String projectCode;
+
+    @ApiModelProperty("供应商名称")
+    private String supplierName;
+
+    @ApiModelProperty("负责人ID")
+    private String principalId;
+}
+

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.lframework.xingyun.sc.procurement.mappers.quotation.SupplierQuotationDealMapper">
+
+    <resultMap id="SupplierQuotationDeal" type="com.lframework.xingyun.sc.procurement.entity.SupplierQuotationDeal">
+        <id column="id" property="id"/>
+        <result column="project_id" property="projectId"/>
+        <result column="project_code" property="projectCode"/>
+        <result column="project_name" property="projectName"/>
+        <result column="quote_time" property="quoteTime"/>
+        <result column="supplier_id" property="supplierId"/>
+        <result column="supplier_name" property="supplierName"/>
+        <result column="product_id" property="productId"/>
+        <result column="product_name" property="productName"/>
+        <result column="product_code" property="productCode"/>
+        <result column="quantity" property="quantity"/>
+        <result column="price" property="price"/>
+        <result column="purchase_department" property="purchaseDepartment"/>
+        <result column="purchase_department_name" property="purchaseDepartmentName"/>
+        <result column="principal_id" property="principalId"/>
+        <result column="principal_name" property="principalName"/>
+        <result column="assign_time" property="assignTime"/>
+        <result column="create_by_id" property="createById"/>
+        <result column="create_by" property="createBy"/>
+        <result column="update_by_id" property="updateById"/>
+        <result column="update_by" property="updateBy"/>
+        <result column="create_time" property="createTime"/>
+        <result column="update_time" property="updateTime"/>
+    </resultMap>
+
+    <sql id="SupplierQuotationDealSql">
+        SELECT
+            tb.id,
+            tb.project_id,
+            tb.project_code,
+            tb.project_name,
+            tb.quote_time,
+            tb.supplier_id,
+            tb.supplier_name,
+            tb.product_id,
+            br.product_name,
+            br.code AS product_code,
+            tb.quantity,
+            tb.price,
+            tb.purchase_department,
+            sd.name AS purchase_department_name,
+            tb.principal_id,
+            tb.principal_name,
+            tb.assign_time,
+            tb.create_by_id,
+            tb.create_by,
+            tb.update_by_id,
+            tb.update_by,
+            tb.create_time,
+            tb.update_time
+        FROM procurement_supplier_quotation_deal tb
+        LEFT JOIN base_data_breed_relationship br ON br.id = tb.product_id
+        LEFT JOIN sys_dept sd ON sd.id = tb.purchase_department
+    </sql>
+
+    <select id="findById" resultMap="SupplierQuotationDeal">
+        <include refid="SupplierQuotationDealSql"/>
+        WHERE tb.id = #{id}
+    </select>
+
+    <select id="findByProjectAndSupplier" resultMap="SupplierQuotationDeal">
+        <include refid="SupplierQuotationDealSql"/>
+        WHERE tb.project_id = #{projectId}
+          AND tb.supplier_id = #{supplierId}
+    </select>
+
+    <select id="query" resultMap="SupplierQuotationDeal">
+        <include refid="SupplierQuotationDealSql"/>
+        <where>
+            <if test="vo.projectName != null and vo.projectName != ''">
+                AND tb.project_name LIKE CONCAT('%', #{vo.projectName}, '%')
+            </if>
+            <if test="vo.projectCode != null and vo.projectCode != ''">
+                AND tb.project_code LIKE CONCAT('%', #{vo.projectCode}, '%')
+            </if>
+            <if test="vo.supplierName != null and vo.supplierName != ''">
+                AND tb.supplier_name LIKE CONCAT('%', #{vo.supplierName}, '%')
+            </if>
+            <if test="vo.principalId != null and vo.principalId != ''">
+                AND tb.principal_id = #{vo.principalId}
+            </if>
+            <choose>
+                <when test="purchaseDepartmentList != null and purchaseDepartmentList.size() > 0">
+                    AND tb.purchase_department IN
+                    <foreach collection="purchaseDepartmentList" item="item" open="(" separator="," close=")">
+                        #{item}
+                    </foreach>
+                </when>
+                <otherwise>
+                    AND tb.principal_id = #{userId}
+                </otherwise>
+            </choose>
+        </where>
+        ORDER BY tb.create_time DESC, tb.id DESC
+    </select>
+</mapper>
+