1330 lines
56 KiB
Java
1330 lines
56 KiB
Java
package org.dromara.crm.service.impl;
|
||
|
||
import cn.hutool.core.date.DateUtil;
|
||
import cn.hutool.core.util.IdUtil;
|
||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||
import lombok.RequiredArgsConstructor;
|
||
import lombok.extern.slf4j.Slf4j;
|
||
import org.dromara.common.core.exception.ServiceException;
|
||
import org.dromara.common.core.utils.MapstructUtils;
|
||
import org.dromara.common.core.utils.StringUtils;
|
||
import org.dromara.common.mybatis.core.page.PageQuery;
|
||
import org.dromara.common.mybatis.core.page.TableDataInfo;
|
||
import org.dromara.common.satoken.utils.LoginHelper;
|
||
import org.dromara.crm.domain.CrmQuote;
|
||
import org.dromara.crm.domain.CrmContract;
|
||
import org.dromara.crm.domain.bo.CrmContractBo;
|
||
import org.dromara.crm.domain.bo.CrmContractProductBo;
|
||
import org.dromara.crm.domain.bo.CrmQuoteBo;
|
||
import org.dromara.crm.domain.bo.CrmQuoteProductBo;
|
||
import org.dromara.crm.domain.vo.CrmQuoteProductVo;
|
||
import org.dromara.crm.domain.vo.CrmQuoteVo;
|
||
import org.dromara.crm.mapper.CrmContractMapper;
|
||
import org.dromara.crm.mapper.CrmQuoteMapper;
|
||
import org.dromara.crm.mapper.CrmCustomerMapper;
|
||
import org.dromara.crm.domain.CrmCustomer;
|
||
import org.dromara.crm.service.*;
|
||
import org.dromara.crm.service.ICrmQuoteApprovalService;
|
||
import org.dromara.crm.service.ICrmQuotePdfService;
|
||
import org.dromara.crm.service.ICrmQuoteProductService;
|
||
import org.dromara.crm.service.ICrmQuoteService;
|
||
import org.dromara.system.service.ISysUserService;
|
||
import org.dromara.system.domain.vo.SysUserVo;
|
||
import org.springframework.stereotype.Service;
|
||
import org.springframework.transaction.annotation.Transactional;
|
||
|
||
import java.math.BigDecimal;
|
||
import java.time.LocalDate;
|
||
import java.time.LocalDateTime;
|
||
import java.time.format.DateTimeFormatter;
|
||
import java.util.Collection;
|
||
import java.util.List;
|
||
import java.util.Map;
|
||
import java.util.Set;
|
||
import java.util.stream.Collectors;
|
||
|
||
/**
|
||
* 报价单Service实现
|
||
*
|
||
* @author 系统管理员
|
||
* @date 2025-01-03
|
||
*/
|
||
@Slf4j
|
||
@RequiredArgsConstructor
|
||
@Service
|
||
public class CrmQuoteServiceImpl implements ICrmQuoteService {
|
||
|
||
private final CrmQuoteMapper baseMapper;
|
||
private final ICrmQuoteProductService quoteProductService;
|
||
private final ICrmQuoteApprovalService quoteApprovalService;
|
||
private final ICrmQuotePdfService quotePdfService;
|
||
private final ICrmQuoteShareLogService quoteShareLogService;
|
||
private final ICrmContractService contractService;
|
||
private final CrmContractMapper contractMapper;
|
||
private final ICrmOpportunityService opportunityService;
|
||
private final ICrmContactService contactService;
|
||
private final ISysUserService userService;
|
||
private final CrmCustomerMapper customerMapper;
|
||
private final ICrmSupplierInfoService supplierInfoService;
|
||
private final ICrmProductService productService;
|
||
|
||
/**
|
||
* 构建查询条件
|
||
*/
|
||
private LambdaQueryWrapper<CrmQuote> buildQueryWrapper(CrmQuoteBo bo) {
|
||
LambdaQueryWrapper<CrmQuote> lqw = Wrappers.lambdaQuery();
|
||
lqw.like(StringUtils.isNotBlank(bo.getQuoteNo()), CrmQuote::getQuoteNo, bo.getQuoteNo());
|
||
|
||
// 快速检索关键字（报价主题/客户名称 OR 模糊）
|
||
if (StringUtils.isNotBlank(bo.getKeyword())) {
|
||
String keyword = bo.getKeyword();
|
||
lqw.and(wrapper -> wrapper
|
||
.like(CrmQuote::getQuoteTitle, keyword)
|
||
.or()
|
||
.like(CrmQuote::getCustomerName, keyword));
|
||
} else {
|
||
// 高级筛选：报价主题和客户名称
|
||
// 若两个字段都传入且值相同，按 OR 处理；否则各自模糊匹配（AND）
|
||
if (StringUtils.isNotBlank(bo.getQuoteTitle()) && StringUtils.isNotBlank(bo.getCustomerName())
|
||
&& bo.getQuoteTitle().equals(bo.getCustomerName())) {
|
||
String keyword = bo.getQuoteTitle();
|
||
lqw.and(wrapper -> wrapper
|
||
.like(CrmQuote::getQuoteTitle, keyword)
|
||
.or()
|
||
.like(CrmQuote::getCustomerName, keyword));
|
||
} else {
|
||
lqw.like(StringUtils.isNotBlank(bo.getQuoteTitle()), CrmQuote::getQuoteTitle, bo.getQuoteTitle());
|
||
lqw.like(StringUtils.isNotBlank(bo.getCustomerName()), CrmQuote::getCustomerName, bo.getCustomerName());
|
||
}
|
||
}
|
||
|
||
lqw.eq(bo.getCustomerId() != null, CrmQuote::getCustomerId, bo.getCustomerId());
|
||
lqw.eq(bo.getOpportunityId() != null, CrmQuote::getOpportunityId, bo.getOpportunityId());
|
||
lqw.eq(StringUtils.isNotBlank(bo.getStatus()), CrmQuote::getStatus, bo.getStatus());
|
||
// 排除指定状态（如默认排除已作废的记录）
|
||
lqw.ne(StringUtils.isNotBlank(bo.getExcludeStatus()), CrmQuote::getStatus, bo.getExcludeStatus());
|
||
lqw.eq(StringUtils.isNotBlank(bo.getQuoteType()), CrmQuote::getQuoteType, bo.getQuoteType());
|
||
lqw.eq(bo.getOwnerUserId() != null, CrmQuote::getOwnerUserId, bo.getOwnerUserId());
|
||
lqw.eq(bo.getIsLatest() != null, CrmQuote::getIsLatest, bo.getIsLatest());
|
||
lqw.ge(bo.getParams().get("minAmount") != null, CrmQuote::getFinalAmount, bo.getParams().get("minAmount"));
|
||
lqw.le(bo.getParams().get("maxAmount") != null, CrmQuote::getFinalAmount, bo.getParams().get("maxAmount"));
|
||
// 报价日期范围查询
|
||
if (bo.getQuoteDateBegin() != null && !bo.getQuoteDateBegin().isEmpty()) {
|
||
lqw.ge(CrmQuote::getQuoteDate, LocalDate.parse(bo.getQuoteDateBegin()));
|
||
}
|
||
if (bo.getQuoteDateEnd() != null && !bo.getQuoteDateEnd().isEmpty()) {
|
||
lqw.le(CrmQuote::getQuoteDate, LocalDate.parse(bo.getQuoteDateEnd()));
|
||
}
|
||
lqw.between(bo.getParams().get("beginTime") != null && bo.getParams().get("endTime") != null,
|
||
CrmQuote::getCreateTime, bo.getParams().get("beginTime"), bo.getParams().get("endTime"));
|
||
|
||
// 查询某个用户已审批过的报价单
|
||
if (bo.getApprovedByUserId() != null) {
|
||
lqw.inSql(CrmQuote::getId,
|
||
"SELECT DISTINCT quote_id FROM crm_quote_approval " +
|
||
"WHERE approver_id = " + bo.getApprovedByUserId() +
|
||
" AND approval_result IN ('approved', 'rejected') " +
|
||
" AND del_flag = 0");
|
||
}
|
||
|
||
lqw.orderByDesc(CrmQuote::getCreateTime);
|
||
return lqw;
|
||
}
|
||
|
||
@Override
|
||
public TableDataInfo<CrmQuoteVo> queryPageList(CrmQuoteBo bo, PageQuery pageQuery) {
|
||
LambdaQueryWrapper<CrmQuote> lqw = buildQueryWrapper(bo);
|
||
Page<CrmQuoteVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw);
|
||
|
||
// 填充canApprove字段（当前用户是否可以审批）
|
||
Long currentUserId = LoginHelper.getUserId();
|
||
for (CrmQuoteVo vo : result.getRecords()) {
|
||
// 只有待审批状态的报价单才需要检查
|
||
if ("submitted".equals(vo.getStatus()) && currentUserId != null) {
|
||
vo.setCanApprove(quoteApprovalService.canUserApprove(vo.getId(), currentUserId));
|
||
} else {
|
||
vo.setCanApprove(false);
|
||
}
|
||
}
|
||
fillContractLinkedCount(result.getRecords());
|
||
|
||
return TableDataInfo.build(result);
|
||
}
|
||
|
||
@Override
|
||
public List<CrmQuoteVo> queryList(CrmQuoteBo bo) {
|
||
LambdaQueryWrapper<CrmQuote> lqw = buildQueryWrapper(bo);
|
||
List<CrmQuoteVo> list = baseMapper.selectVoList(lqw);
|
||
|
||
// 填充canApprove字段（当前用户是否可以审批）
|
||
Long currentUserId = LoginHelper.getUserId();
|
||
for (CrmQuoteVo vo : list) {
|
||
// 只有待审批状态的报价单才需要检查
|
||
if ("submitted".equals(vo.getStatus()) && currentUserId != null) {
|
||
vo.setCanApprove(quoteApprovalService.canUserApprove(vo.getId(), currentUserId));
|
||
} else {
|
||
vo.setCanApprove(false);
|
||
}
|
||
}
|
||
fillContractLinkedCount(list);
|
||
|
||
return list;
|
||
}
|
||
|
||
@Override
|
||
public CrmQuoteVo queryById(Long id) {
|
||
CrmQuoteVo vo = baseMapper.selectVoById(id);
|
||
if (vo != null) {
|
||
// 查询产品列表
|
||
vo.setProductList(quoteProductService.queryListByQuoteId(id));
|
||
|
||
// 填充商机名称
|
||
if (vo.getOpportunityId() != null) {
|
||
try {
|
||
var opportunityVo = opportunityService.queryById(vo.getOpportunityId());
|
||
if (opportunityVo != null) {
|
||
vo.setOpportunityName(opportunityVo.getOpportunityName());
|
||
}
|
||
} catch (Exception e) {
|
||
log.warn("查询商机名称失败, opportunityId: {}", vo.getOpportunityId(), e);
|
||
}
|
||
}
|
||
|
||
// 自动补全联系人手机和邮箱（如果为空但有联系人ID）
|
||
if (vo.getContactId() != null &&
|
||
(StringUtils.isBlank(vo.getContactMobile()) || StringUtils.isBlank(vo.getContactEmail()))) {
|
||
try {
|
||
var contact = contactService.queryById(vo.getContactId());
|
||
if (contact != null) {
|
||
if (StringUtils.isBlank(vo.getContactMobile())) {
|
||
vo.setContactMobile(contact.getMobile());
|
||
}
|
||
if (StringUtils.isBlank(vo.getContactEmail())) {
|
||
vo.setContactEmail(contact.getEmail());
|
||
}
|
||
}
|
||
} catch (Exception e) {
|
||
log.warn("查询联系人信息失败, contactId: {}", vo.getContactId(), e);
|
||
}
|
||
}
|
||
|
||
// 填充负责人手机号
|
||
if (vo.getOwnerUserId() != null && StringUtils.isBlank(vo.getOwnerUserMobile())) {
|
||
try {
|
||
SysUserVo user = userService.selectUserById(vo.getOwnerUserId());
|
||
if (user != null && StringUtils.isNotBlank(user.getPhonenumber())) {
|
||
vo.setOwnerUserMobile(user.getPhonenumber());
|
||
}
|
||
} catch (Exception e) {
|
||
log.warn("查询负责人手机号失败, ownerUserId: {}", vo.getOwnerUserId(), e);
|
||
}
|
||
}
|
||
|
||
// 填充报价主体名称
|
||
if (vo.getSupplierId() != null && StringUtils.isBlank(vo.getSupplierName())) {
|
||
try {
|
||
var supplierInfo = supplierInfoService.queryById(vo.getSupplierId());
|
||
if (supplierInfo != null) {
|
||
vo.setSupplierName(supplierInfo.getSupplierName());
|
||
}
|
||
} catch (Exception e) {
|
||
log.warn("查询报价主体信息失败, supplierId: {}", vo.getSupplierId(), e);
|
||
}
|
||
}
|
||
}
|
||
return vo;
|
||
}
|
||
|
||
@Override
|
||
@Transactional(rollbackFor = Exception.class)
|
||
public Boolean insertByBo(CrmQuoteBo bo) {
|
||
CrmQuote entity = MapstructUtils.convert(bo, CrmQuote.class);
|
||
|
||
// 查询客户信息
|
||
CrmCustomer customer = null;
|
||
if (entity.getCustomerId() != null) {
|
||
customer = customerMapper.selectById(entity.getCustomerId());
|
||
}
|
||
|
||
// 查询供方信息
|
||
String supplierShortName = "山峡";
|
||
if (entity.getSupplierId() != null) {
|
||
try {
|
||
var supplierInfo = supplierInfoService.queryById(entity.getSupplierId());
|
||
if (supplierInfo != null && StringUtils.isNotBlank(supplierInfo.getShortName())) {
|
||
supplierShortName = supplierInfo.getShortName();
|
||
} else if (supplierInfo != null && StringUtils.isNotBlank(supplierInfo.getSupplierName())) {
|
||
supplierShortName = supplierInfo.getSupplierName();
|
||
}
|
||
} catch (Exception e) {
|
||
log.warn("查询供方信息失败，使用默认简称，供方ID: {}", entity.getSupplierId(), e);
|
||
}
|
||
}
|
||
|
||
// 设置默认值（需要在生成编号之前设置报价日期）
|
||
if (entity.getVersion() == null) {
|
||
entity.setVersion("V1.0");
|
||
}
|
||
if (entity.getParentId() == null) {
|
||
entity.setParentId(0L);
|
||
}
|
||
if (entity.getIsLatest() == null) {
|
||
entity.setIsLatest(1);
|
||
}
|
||
if (entity.getStatus() == null) {
|
||
entity.setStatus("draft");
|
||
}
|
||
if (StringUtils.isBlank(entity.getQuoteType())) {
|
||
entity.setQuoteType("sales");
|
||
}
|
||
if (entity.getValidityDays() == null) {
|
||
entity.setValidityDays(30);
|
||
}
|
||
if (entity.getQuoteDate() == null) {
|
||
entity.setQuoteDate(LocalDate.now());
|
||
}
|
||
|
||
// 生成报价单编号（根据供方编码和报价日期）
|
||
// 如果报价单号为空或包含预览标记（***），则重新生成
|
||
if (StringUtils.isBlank(entity.getQuoteNo()) ||
|
||
(StringUtils.isNotBlank(entity.getQuoteNo()) && entity.getQuoteNo().contains("***"))) {
|
||
entity.setQuoteNo(generateQuoteNo(entity.getSupplierId(), entity.getQuoteDate()));
|
||
}
|
||
|
||
// 自动生成报价主题
|
||
String quoteNo = entity.getQuoteNo();
|
||
String customerShortName = customer != null && StringUtils.isNotBlank(customer.getShortName())
|
||
? customer.getShortName()
|
||
: "";
|
||
|
||
if (StringUtils.isBlank(entity.getQuoteTitle())) {
|
||
// 用户未填写报价主题，根据报价类型自动生成
|
||
// 销售：供方简称-客户简称（报价单编号）
|
||
// 采购：客户简称-供方简称（报价单编号）
|
||
String quoteTitle;
|
||
if ("purchase".equals(entity.getQuoteType())) {
|
||
// 采购：客户简称-供方简称（报价单编号）
|
||
quoteTitle = customerShortName + "-" + supplierShortName + "（" + quoteNo + "）";
|
||
} else {
|
||
// 销售：供方简称-客户简称（报价单编号）
|
||
quoteTitle = supplierShortName + "-" + customerShortName + "（" + quoteNo + "）";
|
||
}
|
||
entity.setQuoteTitle(quoteTitle);
|
||
}
|
||
if (entity.getOwnerUserId() == null) {
|
||
entity.setOwnerUserId(LoginHelper.getUserId());
|
||
entity.setOwnerUserName(LoginHelper.getNickname());
|
||
}
|
||
|
||
// 填充联系人手机和邮箱
|
||
if (entity.getContactId() != null) {
|
||
try {
|
||
var contact = contactService.queryById(entity.getContactId());
|
||
if (contact != null) {
|
||
entity.setContactMobile(contact.getMobile());
|
||
entity.setContactEmail(contact.getEmail());
|
||
}
|
||
} catch (Exception e) {
|
||
log.warn("查询联系人信息失败, contactId: {}", entity.getContactId(), e);
|
||
}
|
||
}
|
||
|
||
// 填充报价主体名称
|
||
if (entity.getSupplierId() != null && StringUtils.isBlank(entity.getSupplierName())) {
|
||
try {
|
||
var supplierInfo = supplierInfoService.queryById(entity.getSupplierId());
|
||
if (supplierInfo != null) {
|
||
entity.setSupplierName(supplierInfo.getSupplierName());
|
||
}
|
||
} catch (Exception e) {
|
||
log.warn("查询报价主体信息失败, supplierId: {}", entity.getSupplierId(), e);
|
||
}
|
||
}
|
||
|
||
// 计算到期日期
|
||
if (entity.getValidityDays() != null && entity.getQuoteDate() != null) {
|
||
entity.setExpireDate(entity.getQuoteDate().plusDays(entity.getValidityDays()));
|
||
}
|
||
|
||
// 计算金额
|
||
resolveQuoteProductIds(bo.getProducts());
|
||
calculateAmount(entity, bo.getProducts());
|
||
|
||
// 保存报价单
|
||
boolean flag = baseMapper.insert(entity) > 0;
|
||
if (flag) {
|
||
bo.setId(entity.getId());
|
||
// 保存产品明细
|
||
if (bo.getProducts() != null && !bo.getProducts().isEmpty()) {
|
||
quoteProductService.batchInsert(entity.getId(), bo.getProducts());
|
||
}
|
||
}
|
||
return flag;
|
||
}
|
||
|
||
@Override
|
||
@Transactional(rollbackFor = Exception.class)
|
||
public Boolean updateByBo(CrmQuoteBo bo) {
|
||
CrmQuote entity = MapstructUtils.convert(bo, CrmQuote.class);
|
||
|
||
// 只有草稿状态才能修改
|
||
CrmQuote oldEntity = baseMapper.selectById(bo.getId());
|
||
if (oldEntity == null) {
|
||
throw new ServiceException("报价单不存在");
|
||
}
|
||
if (!"draft".equals(oldEntity.getStatus())) {
|
||
throw new ServiceException("只有草稿状态的报价单才能修改");
|
||
}
|
||
|
||
if (StringUtils.isBlank(entity.getQuoteType())) {
|
||
entity.setQuoteType(StringUtils.isNotBlank(oldEntity.getQuoteType()) ? oldEntity.getQuoteType() : "sales");
|
||
}
|
||
|
||
// 填充联系人手机和邮箱
|
||
if (entity.getContactId() != null) {
|
||
try {
|
||
var contact = contactService.queryById(entity.getContactId());
|
||
if (contact != null) {
|
||
entity.setContactMobile(contact.getMobile());
|
||
entity.setContactEmail(contact.getEmail());
|
||
}
|
||
} catch (Exception e) {
|
||
log.warn("查询联系人信息失败, contactId: {}", entity.getContactId(), e);
|
||
}
|
||
}
|
||
|
||
// 检查客户、供方或报价日期是否发生变化
|
||
boolean customerChanged = !java.util.Objects.equals(oldEntity.getCustomerId(), entity.getCustomerId());
|
||
boolean supplierChanged = !java.util.Objects.equals(oldEntity.getSupplierId(), entity.getSupplierId());
|
||
boolean quoteDateChanged = !java.util.Objects.equals(oldEntity.getQuoteDate(), entity.getQuoteDate());
|
||
|
||
// 查询客户信息
|
||
CrmCustomer customer = null;
|
||
if (entity.getCustomerId() != null) {
|
||
customer = customerMapper.selectById(entity.getCustomerId());
|
||
}
|
||
|
||
// 查询供方信息
|
||
String supplierShortName = "山峡";
|
||
if (entity.getSupplierId() != null) {
|
||
try {
|
||
var supplierInfo = supplierInfoService.queryById(entity.getSupplierId());
|
||
if (supplierInfo != null) {
|
||
entity.setSupplierName(supplierInfo.getSupplierName());
|
||
if (StringUtils.isNotBlank(supplierInfo.getShortName())) {
|
||
supplierShortName = supplierInfo.getShortName();
|
||
} else if (StringUtils.isNotBlank(supplierInfo.getSupplierName())) {
|
||
supplierShortName = supplierInfo.getSupplierName();
|
||
}
|
||
}
|
||
} catch (Exception e) {
|
||
log.warn("查询报价主体信息失败, supplierId: {}", entity.getSupplierId(), e);
|
||
}
|
||
}
|
||
|
||
// 如果报价日期发生变化，需要重新生成编号（根据新的报价日期生成）
|
||
if (quoteDateChanged && entity.getQuoteDate() != null) {
|
||
entity.setQuoteNo(generateQuoteNo(entity.getSupplierId(), entity.getQuoteDate()));
|
||
// 报价单号变化了，需要更新报价主题
|
||
String customerShortName = "";
|
||
if (customer != null && StringUtils.isNotBlank(customer.getShortName())) {
|
||
customerShortName = customer.getShortName();
|
||
} else if (entity.getCustomerName() != null) {
|
||
customerShortName = entity.getCustomerName();
|
||
} else if (oldEntity.getCustomerName() != null) {
|
||
customerShortName = oldEntity.getCustomerName();
|
||
}
|
||
String currentQuoteNo = entity.getQuoteNo();
|
||
// 根据报价类型生成报价主题
|
||
// 销售：供方简称-客户简称（报价单编号）
|
||
// 采购：客户简称-供方简称（报价单编号）
|
||
String quoteTitle;
|
||
if ("purchase".equals(entity.getQuoteType())) {
|
||
// 采购：客户简称-供方简称（报价单编号）
|
||
quoteTitle = customerShortName + "-" + supplierShortName + "（" + currentQuoteNo + "）";
|
||
} else {
|
||
// 销售：供方简称-客户简称（报价单编号）
|
||
quoteTitle = supplierShortName + "-" + customerShortName + "（" + currentQuoteNo + "）";
|
||
}
|
||
entity.setQuoteTitle(quoteTitle);
|
||
}
|
||
// 如果客户或供方发生变化，更新报价主题和报价单号（只更新编码和简称，不改变日期和序列号）
|
||
else if (customerChanged || supplierChanged) {
|
||
String quoteNo = oldEntity.getQuoteNo(); // 保持原报价单号不变
|
||
|
||
// 如果供方发生变化，只更新报价单号中的供方编码部分，保持日期和序列号不变
|
||
if (supplierChanged && StringUtils.isNotBlank(quoteNo)) {
|
||
// 报价单号格式：{供方编码}DD-YYYYMMDD001
|
||
// 提取日期和序列号部分（DD-YYYYMMDD001）
|
||
String dateAndSeq = null;
|
||
if (quoteNo.contains("DD-") && quoteNo.length() > 3) {
|
||
int ddIndex = quoteNo.indexOf("DD-");
|
||
if (ddIndex >= 0 && ddIndex + 3 < quoteNo.length()) {
|
||
dateAndSeq = quoteNo.substring(ddIndex);
|
||
}
|
||
}
|
||
|
||
// 获取新的供方编码
|
||
String newSupplierCode = "SX";
|
||
if (entity.getSupplierId() != null) {
|
||
try {
|
||
var supplierInfo = supplierInfoService.queryById(entity.getSupplierId());
|
||
if (supplierInfo != null && StringUtils.isNotBlank(supplierInfo.getSupplierCode())) {
|
||
newSupplierCode = supplierInfo.getSupplierCode();
|
||
}
|
||
} catch (Exception e) {
|
||
log.warn("查询供方信息失败，使用默认编码，供方ID: {}", entity.getSupplierId(), e);
|
||
}
|
||
}
|
||
|
||
// 如果成功提取了日期和序列号，则用新编码替换
|
||
if (dateAndSeq != null) {
|
||
quoteNo = newSupplierCode + dateAndSeq;
|
||
entity.setQuoteNo(quoteNo);
|
||
}
|
||
// 如果提取失败，保持原报价单号不变
|
||
}
|
||
|
||
// 更新报价主题（只更新简称部分，报价单号使用当前数据的报价单号，确保与entity.getQuoteNo()保持一致）
|
||
String customerShortName = customer != null && StringUtils.isNotBlank(customer.getShortName())
|
||
? customer.getShortName()
|
||
: "";
|
||
// 使用entity.getQuoteNo()确保报价主题中的报价单号与当前数据的报价单号保持一致
|
||
// 如果供方变化且成功更新了报价单号，entity.getQuoteNo()就是更新后的值
|
||
// 如果供方没变化或提取失败，entity.getQuoteNo()就是原值
|
||
String currentQuoteNo = entity.getQuoteNo() != null ? entity.getQuoteNo() : oldEntity.getQuoteNo();
|
||
// 根据报价类型生成报价主题
|
||
// 销售：供方简称-客户简称（报价单编号）
|
||
// 采购：客户简称-供方简称（报价单编号）
|
||
String quoteTitle;
|
||
if ("purchase".equals(entity.getQuoteType())) {
|
||
// 采购：客户简称-供方简称（报价单编号）
|
||
quoteTitle = customerShortName + "-" + supplierShortName + "（" + currentQuoteNo + "）";
|
||
} else {
|
||
// 销售：供方简称-客户简称（报价单编号）
|
||
quoteTitle = supplierShortName + "-" + customerShortName + "（" + currentQuoteNo + "）";
|
||
}
|
||
entity.setQuoteTitle(quoteTitle);
|
||
}
|
||
|
||
// 计算到期日期
|
||
if (entity.getValidityDays() != null && entity.getQuoteDate() != null) {
|
||
entity.setExpireDate(entity.getQuoteDate().plusDays(entity.getValidityDays()));
|
||
}
|
||
|
||
// 计算金额
|
||
resolveQuoteProductIds(bo.getProducts());
|
||
calculateAmount(entity, bo.getProducts());
|
||
|
||
boolean flag = baseMapper.updateById(entity) > 0;
|
||
if (flag && bo.getProducts() != null) {
|
||
// 删除旧产品明细
|
||
quoteProductService.deleteByQuoteId(bo.getId());
|
||
// 插入新产品明细
|
||
quoteProductService.batchInsert(bo.getId(), bo.getProducts());
|
||
}
|
||
return flag;
|
||
}
|
||
|
||
@Override
|
||
@Transactional(rollbackFor = Exception.class)
|
||
public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
|
||
if (isValid) {
|
||
// 校验是否可以删除
|
||
for (Long id : ids) {
|
||
CrmQuote entity = baseMapper.selectById(id);
|
||
if (entity == null) {
|
||
continue;
|
||
}
|
||
if (!"draft".equals(entity.getStatus())) {
|
||
throw new ServiceException("只能删除草稿状态的报价单");
|
||
}
|
||
if (entity.getContractId() != null) {
|
||
throw new ServiceException("已转合同的报价单不能删除");
|
||
}
|
||
}
|
||
}
|
||
return baseMapper.deleteByIds(ids) > 0;
|
||
}
|
||
|
||
@Override
|
||
@Transactional(rollbackFor = Exception.class)
|
||
public Boolean submitQuote(Long id, List<Long> approverIds, String remark) {
|
||
CrmQuote entity = baseMapper.selectById(id);
|
||
if (entity == null) {
|
||
throw new ServiceException("报价单不存在");
|
||
}
|
||
if (!"draft".equals(entity.getStatus())) {
|
||
throw new ServiceException("只有草稿状态的报价单才能提交");
|
||
}
|
||
|
||
// 更新状态
|
||
entity.setStatus("submitted");
|
||
baseMapper.updateById(entity);
|
||
|
||
// 创建审批记录
|
||
if (approverIds != null && !approverIds.isEmpty()) {
|
||
quoteApprovalService.createApprovalRecords(id, approverIds);
|
||
}
|
||
|
||
// 自动生成PDF
|
||
try {
|
||
String pdfUrl = quotePdfService.generateQuotePdf(id);
|
||
entity.setPdfUrl(pdfUrl);
|
||
entity.setPdfGenerated(1);
|
||
baseMapper.updateById(entity);
|
||
} catch (Exception e) {
|
||
log.warn("报价单提交时自动生成PDF失败: quoteId={}", id, e);
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
@Override
|
||
public Boolean saveTemplate(Long id, String templateContent) {
|
||
// 检查报价单是否存在
|
||
CrmQuote entity = baseMapper.selectById(id);
|
||
if (entity == null) {
|
||
throw new ServiceException("报价单不存在");
|
||
}
|
||
|
||
log.info("========== 开始保存报价单模板内容 ==========");
|
||
log.info("quoteId={}", id);
|
||
log.info("contentLength={}", templateContent != null ? templateContent.length() : 0);
|
||
log.info("content前200字符={}", templateContent != null && templateContent.length() > 200
|
||
? templateContent.substring(0, 200)
|
||
: templateContent);
|
||
log.info("包含HTML标签={}", templateContent != null && templateContent.contains("<"));
|
||
|
||
// 使用 LambdaUpdateWrapper 只更新 template_content 字段，避免乐观锁问题
|
||
int result = baseMapper.update(null,
|
||
Wrappers.<CrmQuote>lambdaUpdate()
|
||
.eq(CrmQuote::getId, id)
|
||
.set(CrmQuote::getTemplateContent, templateContent));
|
||
|
||
log.info("保存报价单模板内容完成: quoteId={}, success={}, affectedRows={}",
|
||
id, result > 0, result);
|
||
|
||
// 验证保存结果
|
||
CrmQuote savedEntity = baseMapper.selectById(id);
|
||
if (savedEntity != null && savedEntity.getTemplateContent() != null) {
|
||
log.info("验证保存结果: 数据库中的内容长度={}", savedEntity.getTemplateContent().length());
|
||
log.info("验证保存结果: 数据库中的内容前200字符={}",
|
||
savedEntity.getTemplateContent().length() > 200
|
||
? savedEntity.getTemplateContent().substring(0, 200)
|
||
: savedEntity.getTemplateContent());
|
||
} else {
|
||
log.warn("验证保存结果: 数据库中未找到模板内容！");
|
||
}
|
||
|
||
return result > 0;
|
||
}
|
||
|
||
@Override
|
||
public String getTemplate(Long id) {
|
||
log.info("========== 开始获取报价单模板内容 ==========");
|
||
log.info("quoteId={}", id);
|
||
|
||
// 直接查询，确保获取最新数据
|
||
CrmQuote entity = baseMapper.selectById(id);
|
||
if (entity == null) {
|
||
throw new ServiceException("报价单不存在");
|
||
}
|
||
|
||
String templateContent = entity.getTemplateContent();
|
||
log.info("获取报价单模板内容完成:");
|
||
log.info("- hasTemplate={}", templateContent != null);
|
||
log.info("- contentLength={}", templateContent != null ? templateContent.length() : 0);
|
||
log.info("- content前200字符={}", templateContent != null && templateContent.length() > 200
|
||
? templateContent.substring(0, 200)
|
||
: templateContent);
|
||
log.info("- 包含HTML标签={}", templateContent != null && templateContent.contains("<"));
|
||
|
||
return templateContent;
|
||
}
|
||
|
||
@Override
|
||
public String generatePdf(Long id) {
|
||
CrmQuote entity = baseMapper.selectById(id);
|
||
if (entity == null) {
|
||
throw new ServiceException("报价单不存在");
|
||
}
|
||
|
||
// 调用PDF生成服务
|
||
String pdfUrl = quotePdfService.generateQuotePdf(id);
|
||
|
||
// 更新PDF信息
|
||
entity.setPdfUrl(pdfUrl);
|
||
entity.setPdfGenerated(1);
|
||
baseMapper.updateById(entity);
|
||
|
||
return pdfUrl;
|
||
}
|
||
|
||
@Override
|
||
public String generateShare(Long id, Integer validityDays, String password) {
|
||
CrmQuote entity = baseMapper.selectById(id);
|
||
if (entity == null) {
|
||
throw new ServiceException("报价单不存在");
|
||
}
|
||
|
||
// 生成分享码(8位随机码)
|
||
String shareCode = IdUtil.fastSimpleUUID().substring(0, 8);
|
||
|
||
// 计算分享链接过期时间
|
||
LocalDateTime shareExpireTime = null;
|
||
if (validityDays != null && validityDays > 0) {
|
||
shareExpireTime = LocalDateTime.now().plusDays(validityDays);
|
||
}
|
||
|
||
// 生成分享链接
|
||
// TODO: 这里应该从配置文件读取域名
|
||
String shareLink = "http://localhost:8080/share/" + shareCode;
|
||
|
||
// 更新分享信息
|
||
entity.setShareCode(shareCode);
|
||
entity.setShareLink(shareLink);
|
||
entity.setSharePassword(password); // 设置密码(可为空)
|
||
entity.setShareExpireTime(shareExpireTime);
|
||
baseMapper.updateById(entity);
|
||
|
||
log.info("生成分享链接成功: quoteId={}, shareCode={}, hasPassword={}, expireTime={}",
|
||
id, shareCode, (password != null && !password.isEmpty()), shareExpireTime);
|
||
|
||
return shareLink;
|
||
}
|
||
|
||
@Override
|
||
public CrmQuoteVo viewByShareCode(String shareCode, String password, String ipAddress, String userAgent) {
|
||
LambdaQueryWrapper<CrmQuote> lqw = Wrappers.lambdaQuery();
|
||
lqw.eq(CrmQuote::getShareCode, shareCode);
|
||
CrmQuote entity = baseMapper.selectOne(lqw);
|
||
|
||
if (entity == null) {
|
||
throw new ServiceException("分享链接无效");
|
||
}
|
||
|
||
// 检查分享链接是否过期
|
||
if (entity.getShareExpireTime() != null && LocalDateTime.now().isAfter(entity.getShareExpireTime())) {
|
||
throw new ServiceException("分享链接已过期");
|
||
}
|
||
|
||
// 验证密码(如果设置了密码)
|
||
if (StringUtils.isNotBlank(entity.getSharePassword())) {
|
||
if (StringUtils.isBlank(password) || !entity.getSharePassword().equals(password)) {
|
||
throw new ServiceException("分享密码错误");
|
||
}
|
||
}
|
||
|
||
// 检查报价单是否已过期
|
||
if (entity.getExpireDate() != null && LocalDate.now().isAfter(entity.getExpireDate())) {
|
||
// 更新报价单状态为已过期
|
||
if (!"expired".equals(entity.getStatus())) {
|
||
entity.setStatus("expired");
|
||
baseMapper.updateById(entity);
|
||
}
|
||
}
|
||
|
||
// 增加查看次数
|
||
entity.setViewCount((entity.getViewCount() == null ? 0 : entity.getViewCount()) + 1);
|
||
entity.setLastViewTime(LocalDateTime.now());
|
||
// 更新状态：如果是已提交或已审批，改为已查看
|
||
if ("submitted".equals(entity.getStatus()) || "approved".equals(entity.getStatus())) {
|
||
entity.setStatus("viewed");
|
||
}
|
||
baseMapper.updateById(entity);
|
||
|
||
// 记录访问日志
|
||
try {
|
||
quoteShareLogService.recordVisit(entity.getId(), shareCode, ipAddress, userAgent);
|
||
} catch (Exception e) {
|
||
log.warn("记录访问日志失败: quoteId={}, shareCode={}", entity.getId(), shareCode, e);
|
||
}
|
||
|
||
log.info("通过分享码查看报价单: shareCode={}, quoteId={}, viewCount={}, ip={}",
|
||
shareCode, entity.getId(), entity.getViewCount(), ipAddress);
|
||
|
||
CrmQuoteVo vo = MapstructUtils.convert(entity, CrmQuoteVo.class);
|
||
vo.setProductList(quoteProductService.queryListByQuoteId(entity.getId()));
|
||
return vo;
|
||
}
|
||
|
||
@Override
|
||
public Boolean acceptQuote(Long id, String remark) {
|
||
CrmQuote entity = baseMapper.selectById(id);
|
||
if (entity == null) {
|
||
throw new ServiceException("报价单不存在");
|
||
}
|
||
|
||
entity.setStatus("accepted");
|
||
return baseMapper.updateById(entity) > 0;
|
||
}
|
||
|
||
@Override
|
||
public Boolean rejectQuote(Long id, String rejectReason, String remark) {
|
||
CrmQuote entity = baseMapper.selectById(id);
|
||
if (entity == null) {
|
||
throw new ServiceException("报价单不存在");
|
||
}
|
||
|
||
entity.setStatus("rejected");
|
||
entity.setRejectReason(rejectReason);
|
||
return baseMapper.updateById(entity) > 0;
|
||
}
|
||
|
||
@Override
|
||
@Transactional(rollbackFor = Exception.class)
|
||
public Long toContract(Long id, String contractNo, String contractTitle, LocalDate signDate, LocalDate startDate,
|
||
LocalDate endDate) {
|
||
// 1. 查询报价单信息
|
||
CrmQuote quote = baseMapper.selectById(id);
|
||
if (quote == null) {
|
||
throw new ServiceException("报价单不存在");
|
||
}
|
||
if (!"accepted".equals(quote.getStatus())) {
|
||
throw new ServiceException("只有已接受的报价单才能转合同");
|
||
}
|
||
if (quote.getContractId() != null) {
|
||
throw new ServiceException("该报价单已转为合同,不能重复转换");
|
||
}
|
||
|
||
// 2. 查询报价单产品明细
|
||
List<CrmQuoteProductVo> quoteProducts = quoteProductService.queryListByQuoteId(id);
|
||
if (quoteProducts == null || quoteProducts.isEmpty()) {
|
||
throw new ServiceException("报价单没有产品明细,无法转合同");
|
||
}
|
||
|
||
// 3. 构建合同Bo对象
|
||
CrmContractBo contractBo = new CrmContractBo();
|
||
contractBo.setContractNo(contractNo);
|
||
contractBo.setContractName(contractTitle);
|
||
contractBo.setCustomerId(quote.getCustomerId());
|
||
contractBo.setOpportunityId(quote.getOpportunityId());
|
||
contractBo.setQuoteId(quote.getId());
|
||
contractBo.setContactId(quote.getContactId());
|
||
contractBo.setContractType("sale"); // 默认销售合同
|
||
contractBo.setAmount(quote.getFinalAmount());
|
||
contractBo.setSignDate(signDate != null ? signDate : LocalDate.now());
|
||
contractBo.setStartDate(startDate != null ? startDate : LocalDate.now());
|
||
contractBo.setEndDate(endDate); // 可为空
|
||
contractBo.setOwnerUserId(quote.getOwnerUserId());
|
||
contractBo.setPaymentTerms(quote.getPaymentTerms());
|
||
contractBo.setDeliveryTerms(quote.getDeliveryTerms());
|
||
contractBo.setRemark("由报价单" + quote.getQuoteNo() + "转换生成");
|
||
|
||
// 4. 复制产品明细(只设置Bo中存在的字段)
|
||
List<CrmContractProductBo> contractProducts = new java.util.ArrayList<>();
|
||
for (CrmQuoteProductVo quoteProduct : quoteProducts) {
|
||
CrmContractProductBo contractProduct = new CrmContractProductBo();
|
||
contractProduct.setProductId(quoteProduct.getProductId());
|
||
contractProduct.setQuantity(quoteProduct.getQuantity());
|
||
contractProduct.setPrice(quoteProduct.getPrice());
|
||
contractProduct.setDiscount(quoteProduct.getDiscount());
|
||
contractProduct.setDescription(quoteProduct.getDescription());
|
||
contractProduct.setSort(quoteProduct.getSort());
|
||
contractProduct.setDeliveryStatus("pending");
|
||
contractProduct.setDeliveredQuantity(0);
|
||
contractProducts.add(contractProduct);
|
||
}
|
||
contractBo.setProducts(contractProducts);
|
||
|
||
// 5. 调用合同服务创建合同
|
||
Boolean success = contractService.insertByBo(contractBo);
|
||
if (!success) {
|
||
throw new ServiceException("创建合同失败");
|
||
}
|
||
|
||
Long contractId = contractBo.getId();
|
||
|
||
// 6. 更新报价单状态
|
||
quote.setStatus("contract");
|
||
quote.setContractId(contractId);
|
||
baseMapper.updateById(quote);
|
||
|
||
log.info("报价单转合同成功: quoteId={}, quoteNo={}, contractId={}, contractNo={}",
|
||
id, quote.getQuoteNo(), contractId, contractNo);
|
||
|
||
return contractId;
|
||
}
|
||
|
||
@Override
|
||
@Transactional(rollbackFor = Exception.class)
|
||
public Long createNewVersion(Long id, String version, String remark) {
|
||
CrmQuote oldEntity = baseMapper.selectById(id);
|
||
if (oldEntity == null) {
|
||
throw new ServiceException("报价单不存在");
|
||
}
|
||
|
||
// 创建新版本
|
||
CrmQuote newEntity = new CrmQuote();
|
||
newEntity.setQuoteNo(oldEntity.getQuoteNo());
|
||
newEntity.setQuoteTitle(oldEntity.getQuoteTitle());
|
||
newEntity.setCustomerId(oldEntity.getCustomerId());
|
||
newEntity.setCustomerName(oldEntity.getCustomerName());
|
||
newEntity.setOpportunityId(oldEntity.getOpportunityId());
|
||
newEntity.setContactId(oldEntity.getContactId());
|
||
newEntity.setContactName(oldEntity.getContactName());
|
||
newEntity.setContactMobile(oldEntity.getContactMobile());
|
||
newEntity.setContactEmail(oldEntity.getContactEmail());
|
||
newEntity.setVersion(version);
|
||
newEntity.setParentId(id);
|
||
newEntity.setIsLatest(1);
|
||
newEntity.setStatus("draft");
|
||
newEntity.setValidityDays(oldEntity.getValidityDays());
|
||
newEntity.setQuoteDate(LocalDate.now());
|
||
newEntity.setExpireDate(LocalDate.now().plusDays(oldEntity.getValidityDays()));
|
||
newEntity.setOwnerUserId(oldEntity.getOwnerUserId());
|
||
newEntity.setOwnerUserName(oldEntity.getOwnerUserName());
|
||
newEntity.setQuoteType(StringUtils.isNotBlank(oldEntity.getQuoteType()) ? oldEntity.getQuoteType() : "sales");
|
||
newEntity.setPaymentTerms(oldEntity.getPaymentTerms());
|
||
newEntity.setDeliveryTerms(oldEntity.getDeliveryTerms());
|
||
newEntity.setRemark(remark);
|
||
|
||
// 旧版本设为非最新
|
||
oldEntity.setIsLatest(0);
|
||
baseMapper.updateById(oldEntity);
|
||
|
||
// 保存新版本
|
||
baseMapper.insert(newEntity);
|
||
|
||
// 复制产品明细
|
||
List<CrmQuoteProductVo> oldProducts = quoteProductService.queryListByQuoteId(id);
|
||
if (oldProducts != null && !oldProducts.isEmpty()) {
|
||
List<CrmQuoteProductBo> newProducts = oldProducts.stream()
|
||
.map(vo -> MapstructUtils.convert(vo, CrmQuoteProductBo.class))
|
||
.toList();
|
||
quoteProductService.batchInsert(newEntity.getId(), newProducts);
|
||
}
|
||
|
||
return newEntity.getId();
|
||
}
|
||
|
||
@Override
|
||
public List<CrmQuoteVo> queryVersions(String quoteNo) {
|
||
LambdaQueryWrapper<CrmQuote> lqw = Wrappers.lambdaQuery();
|
||
lqw.eq(CrmQuote::getQuoteNo, quoteNo);
|
||
lqw.orderByDesc(CrmQuote::getCreateTime);
|
||
return baseMapper.selectVoList(lqw);
|
||
}
|
||
|
||
/**
|
||
* 生成报价单编号
|
||
* 格式：{供方编码}DD-YYYYMMDD001（供方编码DD- + 报价日期年月日 + 3位序号）
|
||
*
|
||
* @param supplierId 供方主体ID，如果为null则使用默认编码"SX"
|
||
* @param quoteDate 报价日期，如果为null则使用当前日期
|
||
*/
|
||
private String generateQuoteNo(Long supplierId, LocalDate quoteDate) {
|
||
// 获取供方编码，如果没有则使用默认值"SX"
|
||
String supplierCode = "SX";
|
||
if (supplierId != null) {
|
||
try {
|
||
var supplierInfo = supplierInfoService.queryById(supplierId);
|
||
if (supplierInfo != null && StringUtils.isNotBlank(supplierInfo.getSupplierCode())) {
|
||
supplierCode = supplierInfo.getSupplierCode();
|
||
}
|
||
} catch (Exception e) {
|
||
log.warn("查询供方信息失败，使用默认编码，供方ID: {}", supplierId, e);
|
||
}
|
||
}
|
||
|
||
// 使用报价日期生成日期部分，如果报价日期为空则使用当前日期
|
||
LocalDate date = quoteDate != null ? quoteDate : LocalDate.now();
|
||
String dateStr = DateTimeFormatter.ofPattern("yyyyMMdd").format(date);
|
||
String prefix = supplierCode + "DD-" + dateStr;
|
||
|
||
// 查询该报价日期下的最大编号（只查询未删除的记录）
|
||
// 同时需要匹配报价日期，确保序号按报价日期统计
|
||
LambdaQueryWrapper<CrmQuote> wrapper = Wrappers.lambdaQuery();
|
||
wrapper.likeRight(CrmQuote::getQuoteNo, prefix);
|
||
wrapper.eq(CrmQuote::getQuoteDate, date); // 按报价日期查询
|
||
wrapper.orderByDesc(CrmQuote::getQuoteNo);
|
||
wrapper.last("LIMIT 1");
|
||
CrmQuote lastQuote = baseMapper.selectOne(wrapper);
|
||
|
||
int sequence = 1;
|
||
if (lastQuote != null && StringUtils.isNotBlank(lastQuote.getQuoteNo())) {
|
||
String lastNo = lastQuote.getQuoteNo();
|
||
// {供方编码}DD-20251017001，前缀长度是{供方编码长度}+5（DD-yyyyMMdd），序号长度是3位
|
||
if (lastNo.length() >= prefix.length() + 3) {
|
||
String seqStr = lastNo.substring(prefix.length());
|
||
try {
|
||
sequence = Integer.parseInt(seqStr) + 1;
|
||
} catch (NumberFormatException e) {
|
||
sequence = 1;
|
||
}
|
||
}
|
||
}
|
||
|
||
// 最多尝试10次，避免无限循环
|
||
for (int retry = 0; retry < 10; retry++) {
|
||
String quoteNo = prefix + String.format("%03d", sequence + retry);
|
||
|
||
// 检查编号是否已存在（只检查未删除的记录）
|
||
Long count = baseMapper.selectCount(
|
||
Wrappers.lambdaQuery(CrmQuote.class)
|
||
.eq(CrmQuote::getQuoteNo, quoteNo));
|
||
|
||
if (count == 0) {
|
||
return quoteNo;
|
||
}
|
||
|
||
// 如果编号已存在，继续尝试下一个序号
|
||
log.warn("报价单编号 {} 已存在，尝试生成下一个编号（第{}次重试）", quoteNo, retry + 1);
|
||
}
|
||
|
||
// 如果重试10次都失败，抛出异常
|
||
throw new ServiceException("生成报价单编号失败，请稍后重试");
|
||
}
|
||
|
||
/**
|
||
* 填充报价单被合同关联次数
|
||
*/
|
||
private void fillContractLinkedCount(List<CrmQuoteVo> quoteList) {
|
||
if (quoteList == null || quoteList.isEmpty()) {
|
||
return;
|
||
}
|
||
Set<Long> quoteIds = quoteList.stream()
|
||
.map(CrmQuoteVo::getId)
|
||
.filter(java.util.Objects::nonNull)
|
||
.collect(Collectors.toSet());
|
||
if (quoteIds.isEmpty()) {
|
||
return;
|
||
}
|
||
List<CrmContract> contracts = contractMapper.selectList(
|
||
Wrappers.<CrmContract>lambdaQuery()
|
||
.in(CrmContract::getQuoteId, quoteIds)
|
||
.select(CrmContract::getQuoteId));
|
||
Map<Long, Long> contractCountMap = contracts.stream()
|
||
.map(CrmContract::getQuoteId)
|
||
.filter(java.util.Objects::nonNull)
|
||
.collect(Collectors.groupingBy(id -> id, Collectors.counting()));
|
||
for (CrmQuoteVo vo : quoteList) {
|
||
Long count = contractCountMap.getOrDefault(vo.getId(), 0L);
|
||
vo.setContractLinkedCount(count.intValue());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 计算金额
|
||
*/
|
||
private void calculateAmount(CrmQuote entity, List<CrmQuoteProductBo> products) {
|
||
if (products == null || products.isEmpty()) {
|
||
entity.setTotalAmount(BigDecimal.ZERO);
|
||
entity.setDiscountAmount(BigDecimal.ZERO);
|
||
entity.setFinalAmount(BigDecimal.ZERO);
|
||
return;
|
||
}
|
||
|
||
// 计算总金额(未折扣前)
|
||
BigDecimal totalAmount = BigDecimal.ZERO;
|
||
for (CrmQuoteProductBo product : products) {
|
||
BigDecimal subtotal = product.getPrice()
|
||
.multiply(product.getQuantity())
|
||
.multiply(BigDecimal.ONE.subtract(
|
||
product.getDiscount() == null ? BigDecimal.ZERO
|
||
: product.getDiscount().divide(BigDecimal.valueOf(100))));
|
||
totalAmount = totalAmount.add(subtotal);
|
||
}
|
||
|
||
entity.setTotalAmount(totalAmount);
|
||
|
||
// 计算整单折扣
|
||
BigDecimal discountRate = entity.getDiscountRate() == null ? BigDecimal.ZERO : entity.getDiscountRate();
|
||
BigDecimal discountAmount = totalAmount.multiply(discountRate.divide(BigDecimal.valueOf(100)));
|
||
entity.setDiscountAmount(discountAmount);
|
||
|
||
// 计算最终金额
|
||
entity.setFinalAmount(totalAmount.subtract(discountAmount));
|
||
}
|
||
|
||
/**
|
||
* 解析报价产品ID（按名称/规格/分类/单位/税率匹配，未命中自动新增）
|
||
*/
|
||
private void resolveQuoteProductIds(List<CrmQuoteProductBo> products) {
|
||
if (products == null || products.isEmpty()) {
|
||
return;
|
||
}
|
||
for (CrmQuoteProductBo product : products) {
|
||
Long productId = productService.resolveProductIdForQuoteItem(product);
|
||
product.setProductId(productId);
|
||
}
|
||
}
|
||
|
||
@Override
|
||
public java.util.Map<String, Object> statisticsOverview(Long ownerUserId, String beginTime, String endTime) {
|
||
java.util.Map<String, Object> result = new java.util.HashMap<>();
|
||
|
||
LambdaQueryWrapper<CrmQuote> lqw = Wrappers.lambdaQuery();
|
||
if (ownerUserId != null) {
|
||
lqw.eq(CrmQuote::getOwnerUserId, ownerUserId);
|
||
}
|
||
if (StringUtils.isNotBlank(beginTime)) {
|
||
lqw.ge(CrmQuote::getCreateTime, beginTime);
|
||
}
|
||
if (StringUtils.isNotBlank(endTime)) {
|
||
lqw.le(CrmQuote::getCreateTime, endTime);
|
||
}
|
||
|
||
// 总数量
|
||
Long totalCount = baseMapper.selectCount(lqw);
|
||
result.put("totalCount", totalCount);
|
||
|
||
// 各状态数量
|
||
LambdaQueryWrapper<CrmQuote> draftLqw = lqw.clone().eq(CrmQuote::getStatus, "draft");
|
||
result.put("draftCount", baseMapper.selectCount(draftLqw));
|
||
|
||
LambdaQueryWrapper<CrmQuote> submittedLqw = lqw.clone().eq(CrmQuote::getStatus, "submitted");
|
||
result.put("submittedCount", baseMapper.selectCount(submittedLqw));
|
||
|
||
LambdaQueryWrapper<CrmQuote> acceptedLqw = lqw.clone().eq(CrmQuote::getStatus, "accepted");
|
||
Long acceptedCount = baseMapper.selectCount(acceptedLqw);
|
||
result.put("acceptedCount", acceptedCount);
|
||
|
||
LambdaQueryWrapper<CrmQuote> rejectedLqw = lqw.clone().eq(CrmQuote::getStatus, "rejected");
|
||
result.put("rejectedCount", baseMapper.selectCount(rejectedLqw));
|
||
|
||
LambdaQueryWrapper<CrmQuote> expiredLqw = lqw.clone().eq(CrmQuote::getStatus, "expired");
|
||
result.put("expiredCount", baseMapper.selectCount(expiredLqw));
|
||
|
||
// 总金额和已接受金额
|
||
List<CrmQuote> allQuotes = baseMapper.selectList(lqw);
|
||
BigDecimal totalAmount = allQuotes.stream()
|
||
.map(CrmQuote::getFinalAmount)
|
||
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
||
result.put("totalAmount", totalAmount);
|
||
|
||
List<CrmQuote> acceptedQuotes = baseMapper.selectList(acceptedLqw);
|
||
BigDecimal acceptedAmount = acceptedQuotes.stream()
|
||
.map(CrmQuote::getFinalAmount)
|
||
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
||
result.put("acceptedAmount", acceptedAmount);
|
||
|
||
// 接受率
|
||
double acceptRate = totalCount > 0 ? (acceptedCount * 100.0 / totalCount) : 0.0;
|
||
result.put("acceptRate", String.format("%.2f", acceptRate));
|
||
|
||
// 平均金额
|
||
BigDecimal avgAmount = totalCount > 0 ? totalAmount.divide(BigDecimal.valueOf(totalCount), 2,
|
||
java.math.RoundingMode.HALF_UP) : BigDecimal.ZERO;
|
||
result.put("avgAmount", avgAmount);
|
||
|
||
return result;
|
||
}
|
||
|
||
@Override
|
||
public List<java.util.Map<String, Object>> statisticsStatus() {
|
||
List<java.util.Map<String, Object>> result = new java.util.ArrayList<>();
|
||
|
||
String[] statusArray = { "draft", "submitted", "accepted", "rejected", "expired", "contract" };
|
||
String[] statusNameArray = { "草稿", "已提交", "已接受", "已拒绝", "已过期", "已转合同" };
|
||
|
||
Long total = baseMapper.selectCount(Wrappers.lambdaQuery());
|
||
|
||
for (int i = 0; i < statusArray.length; i++) {
|
||
java.util.Map<String, Object> item = new java.util.HashMap<>();
|
||
String status = statusArray[i];
|
||
String statusName = statusNameArray[i];
|
||
|
||
LambdaQueryWrapper<CrmQuote> lqw = Wrappers.lambdaQuery();
|
||
lqw.eq(CrmQuote::getStatus, status);
|
||
|
||
Long count = baseMapper.selectCount(lqw);
|
||
List<CrmQuote> quotes = baseMapper.selectList(lqw);
|
||
BigDecimal amount = quotes.stream()
|
||
.map(CrmQuote::getFinalAmount)
|
||
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
||
|
||
double percent = total > 0 ? (count * 100.0 / total) : 0.0;
|
||
|
||
item.put("status", status);
|
||
item.put("statusName", statusName);
|
||
item.put("count", count);
|
||
item.put("amount", amount);
|
||
item.put("percent", String.format("%.2f", percent));
|
||
|
||
result.add(item);
|
||
}
|
||
|
||
return result;
|
||
}
|
||
|
||
@Override
|
||
public List<java.util.Map<String, Object>> statisticsTrend(String type, String beginTime, String endTime) {
|
||
List<java.util.Map<String, Object>> result = new java.util.ArrayList<>();
|
||
|
||
// 1. 构建查询条件
|
||
LambdaQueryWrapper<CrmQuote> lqw = Wrappers.lambdaQuery();
|
||
if (StringUtils.isNotBlank(beginTime)) {
|
||
lqw.ge(CrmQuote::getCreateTime, beginTime);
|
||
}
|
||
if (StringUtils.isNotBlank(endTime)) {
|
||
lqw.le(CrmQuote::getCreateTime, endTime);
|
||
}
|
||
|
||
// 2. 查询所有数据
|
||
List<CrmQuote> allQuotes = baseMapper.selectList(lqw);
|
||
if (allQuotes.isEmpty()) {
|
||
return result;
|
||
}
|
||
|
||
// 3. 按时间类型分组统计
|
||
java.util.Map<String, List<CrmQuote>> groupedQuotes = new java.util.LinkedHashMap<>();
|
||
|
||
for (CrmQuote quote : allQuotes) {
|
||
// createTime继承自BaseEntity,是Date类型,需要转换为LocalDateTime
|
||
java.util.Date createTimeDate = quote.getCreateTime();
|
||
LocalDateTime createTime;
|
||
if (createTimeDate != null) {
|
||
createTime = DateUtil.toLocalDateTime(createTimeDate);
|
||
} else if (quote.getQuoteDate() != null) {
|
||
// 如果createTime为空,使用quoteDate
|
||
createTime = quote.getQuoteDate().atStartOfDay();
|
||
} else {
|
||
createTime = LocalDateTime.now();
|
||
}
|
||
String period = getPeriodKey(createTime, type);
|
||
groupedQuotes.computeIfAbsent(period, k -> new java.util.ArrayList<>()).add(quote);
|
||
}
|
||
|
||
// 4. 计算每个周期的统计数据
|
||
for (java.util.Map.Entry<String, List<CrmQuote>> entry : groupedQuotes.entrySet()) {
|
||
String period = entry.getKey();
|
||
List<CrmQuote> periodQuotes = entry.getValue();
|
||
|
||
java.util.Map<String, Object> item = new java.util.HashMap<>();
|
||
item.put("period", period);
|
||
|
||
// 总数量
|
||
item.put("totalCount", periodQuotes.size());
|
||
|
||
// 已接受数量
|
||
long acceptedCount = periodQuotes.stream()
|
||
.filter(q -> "accepted".equals(q.getStatus()) || "contract".equals(q.getStatus()))
|
||
.count();
|
||
item.put("acceptedCount", acceptedCount);
|
||
|
||
// 总金额
|
||
BigDecimal totalAmount = periodQuotes.stream()
|
||
.map(CrmQuote::getFinalAmount)
|
||
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
||
item.put("totalAmount", totalAmount);
|
||
|
||
// 已接受金额
|
||
BigDecimal acceptedAmount = periodQuotes.stream()
|
||
.filter(q -> "accepted".equals(q.getStatus()) || "contract".equals(q.getStatus()))
|
||
.map(CrmQuote::getFinalAmount)
|
||
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
||
item.put("acceptedAmount", acceptedAmount);
|
||
|
||
// 接受率
|
||
double acceptRate = periodQuotes.size() > 0
|
||
? (acceptedCount * 100.0 / periodQuotes.size())
|
||
: 0.0;
|
||
item.put("acceptRate", String.format("%.2f", acceptRate));
|
||
|
||
result.add(item);
|
||
}
|
||
|
||
log.info("报价单趋势分析: type={}, periods={}, totalRecords={}",
|
||
type, result.size(), allQuotes.size());
|
||
|
||
return result;
|
||
}
|
||
|
||
/**
|
||
* 根据时间类型获取周期标识
|
||
*/
|
||
private String getPeriodKey(LocalDateTime dateTime, String type) {
|
||
if (dateTime == null) {
|
||
return "未知";
|
||
}
|
||
|
||
DateTimeFormatter formatter;
|
||
switch (type.toLowerCase()) {
|
||
case "year":
|
||
formatter = DateTimeFormatter.ofPattern("yyyy年");
|
||
break;
|
||
case "quarter":
|
||
int quarter = (dateTime.getMonthValue() - 1) / 3 + 1;
|
||
return dateTime.getYear() + "年Q" + quarter;
|
||
case "month":
|
||
default:
|
||
formatter = DateTimeFormatter.ofPattern("yyyy年MM月");
|
||
break;
|
||
}
|
||
|
||
return dateTime.format(formatter);
|
||
}
|
||
|
||
@Override
|
||
@Transactional(rollbackFor = Exception.class)
|
||
public Boolean withdrawApproval(Long id, String remark) {
|
||
CrmQuote entity = baseMapper.selectById(id);
|
||
if (entity == null) {
|
||
throw new ServiceException("报价单不存在");
|
||
}
|
||
|
||
// 只能撤回已提交未审批的报价单
|
||
if (!"submitted".equals(entity.getStatus())) {
|
||
throw new ServiceException("只能撤回已提交的报价单");
|
||
}
|
||
|
||
// 检查是否为创建人
|
||
if (!entity.getCreateBy().equals(LoginHelper.getUserId())) {
|
||
throw new ServiceException("只有创建人才能撤回审批");
|
||
}
|
||
|
||
// 更新状态为草稿
|
||
entity.setStatus("draft");
|
||
boolean flag = baseMapper.updateById(entity) > 0;
|
||
|
||
if (flag) {
|
||
// 删除所有pending状态的审批记录
|
||
quoteApprovalService.deletePendingApprovals(id);
|
||
|
||
log.info("撤回审批成功: quoteId={}, quoteNo={}, remark={}",
|
||
id, entity.getQuoteNo(), remark);
|
||
}
|
||
|
||
return flag;
|
||
}
|
||
|
||
@Override
|
||
@Transactional(rollbackFor = Exception.class)
|
||
public Boolean invalidQuote(Long id, String remark) {
|
||
CrmQuote entity = baseMapper.selectById(id);
|
||
if (entity == null) {
|
||
throw new ServiceException("报价单不存在");
|
||
}
|
||
|
||
// 任何状态都可以作废，但已作废的不能重复作废
|
||
if ("invalid".equals(entity.getStatus())) {
|
||
throw new ServiceException("报价单已作废，不能重复作废");
|
||
}
|
||
|
||
// 更新状态为已作废
|
||
entity.setStatus("invalid");
|
||
if (StringUtils.isNotBlank(remark)) {
|
||
String currentRemark = entity.getRemark();
|
||
if (StringUtils.isNotBlank(currentRemark)) {
|
||
entity.setRemark(currentRemark + "\n【作废原因】" + remark);
|
||
} else {
|
||
entity.setRemark("【作废原因】" + remark);
|
||
}
|
||
}
|
||
|
||
boolean flag = baseMapper.updateById(entity) > 0;
|
||
|
||
if (flag) {
|
||
log.info("作废报价单成功: quoteId={}, quoteNo={}, remark={}",
|
||
id, entity.getQuoteNo(), remark);
|
||
}
|
||
|
||
return flag;
|
||
}
|
||
|
||
}
|