package com.ruoyi.basic.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.basic.dto.BusinessDescriptionDto;
|
import com.ruoyi.basic.dto.BusinessOpportunityDto;
|
import com.ruoyi.basic.dto.StorageBlobDTO;
|
import com.ruoyi.basic.dto.StorageBlobVO;
|
import com.ruoyi.basic.enums.ApplicationTypeEnum;
|
import com.ruoyi.basic.enums.RecordTypeEnum;
|
import com.ruoyi.basic.mapper.AreaMapper;
|
import com.ruoyi.basic.mapper.BusinessDescriptionMapper;
|
import com.ruoyi.basic.mapper.BusinessOpportunityMapper;
|
import com.ruoyi.basic.pojo.Area;
|
import com.ruoyi.basic.pojo.BusinessDescription;
|
import com.ruoyi.basic.pojo.BusinessOpportunity;
|
import com.ruoyi.basic.service.BusinessOpportunityService;
|
import com.ruoyi.basic.utils.FileUtil;
|
import com.ruoyi.common.utils.SecurityUtils;
|
import com.ruoyi.framework.security.LoginUser;
|
import com.ruoyi.framework.web.domain.R;
|
import com.ruoyi.project.system.domain.SysNotice;
|
import com.ruoyi.project.system.mapper.SysNoticeMapper;
|
import com.ruoyi.project.system.service.impl.UnipushService;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* <p>
|
* 商机管理 服务实现类
|
* </p>
|
*
|
* @author 芯导软件（江苏）有限公司
|
* @since 2026-05-07 04:46:10
|
*/
|
@Service
|
@RequiredArgsConstructor
|
public class BusinessOpportunityServiceImpl extends ServiceImpl<BusinessOpportunityMapper, BusinessOpportunity> implements BusinessOpportunityService {
|
|
private final BusinessOpportunityMapper businessOpportunityMapper;
|
private final AreaMapper areaMapper;
|
private final BusinessDescriptionMapper businessDescriptionMapper;
|
private final UnipushService unipushService;
|
private final SysNoticeMapper sysNoticeMapper;
|
private final FileUtil fileUtil;
|
|
@Override
|
public IPage<BusinessOpportunityDto> listPage(Page page, BusinessOpportunityDto businessOpportunityDto) {
|
LoginUser loginUser = SecurityUtils.getLoginUser();
|
IPage<BusinessOpportunityDto> businessOpportunityDtoIPage = businessOpportunityMapper.listPage(page, businessOpportunityDto);
|
|
businessOpportunityDtoIPage.getRecords().forEach(opportunity -> {
|
ArrayList<StorageBlobVO> storageBlobVOS = new ArrayList<>();
|
// 查询业务描述列表
|
List<BusinessDescription> businessDescriptions = businessDescriptionMapper.selectList(
|
new LambdaQueryWrapper<BusinessDescription>()
|
.eq(BusinessDescription::getBusinessOpportunityId, opportunity.getId())
|
.orderByDesc(BusinessDescription::getCreateTime)
|
);
|
|
// 收集每个业务描述的文件
|
if (businessDescriptions != null && !businessDescriptions.isEmpty()) {
|
businessDescriptions.forEach(description -> {
|
List<StorageBlobVO> files = fileUtil.getStorageBlobVOsByApplicationAndRecordTypeAndRecordId(
|
ApplicationTypeEnum.FILE,
|
RecordTypeEnum.BUSINESS_DESCRIPTION,
|
Long.valueOf(description.getId())
|
);
|
if (files != null && !files.isEmpty()) {
|
storageBlobVOS.addAll(files);
|
}
|
});
|
}
|
|
// 查询商机主表的文件
|
List<StorageBlobVO> opportunityFiles = fileUtil.getStorageBlobVOsByApplicationAndRecordTypeAndRecordId(
|
ApplicationTypeEnum.FILE,
|
RecordTypeEnum.BUSINESS_OPPORTUNITY,
|
opportunity.getId()
|
);
|
if (opportunityFiles != null && !opportunityFiles.isEmpty()) {
|
storageBlobVOS.addAll(opportunityFiles);
|
}
|
|
opportunity.setBusinessCommonFiles(storageBlobVOS);
|
opportunity.setBusinessDescription(businessDescriptions);
|
});
|
return businessOpportunityDtoIPage;
|
|
}
|
|
@Override
|
public List<Area> getProvinceList() {
|
return areaMapper.selectList(new LambdaQueryWrapper<Area>().eq(Area::getLevel,1).eq(Area::getParentId,0));
|
}
|
|
@Override
|
public List<Area> getCityList(Integer provinceId) {
|
return areaMapper.selectList(new LambdaQueryWrapper<Area>().eq(Area::getLevel,2).eq(Area::getParentId,provinceId));
|
}
|
|
@Override
|
public R add(BusinessOpportunityDto businessOpportunity) {
|
this.save(businessOpportunity);
|
BusinessDescription businessDescription = new BusinessDescription();
|
BeanUtils.copyProperties(businessOpportunity, businessDescription);
|
businessDescription.setBusinessOpportunityId(businessOpportunity.getId());
|
// 迁移临时文件到正式文件
|
// commonFileService.migrateTempFilesToFormal(businessOpportunity.getId(), businessOpportunity.getTempFileIds());
|
ArrayList<StorageBlobDTO> storageBlobDTOS = new ArrayList<>();
|
for (StorageBlobVO businessCommonFile : businessOpportunity.getBusinessCommonFiles()) {
|
StorageBlobDTO storageBlobDTO = new StorageBlobDTO();
|
BeanUtils.copyProperties(businessCommonFile, storageBlobDTO);
|
storageBlobDTOS.add(storageBlobDTO);
|
}
|
fileUtil.saveStorageAttachment(ApplicationTypeEnum.FILE, RecordTypeEnum.BUSINESS_OPPORTUNITY, businessOpportunity.getId(), storageBlobDTOS);
|
// 推送消息
|
List<SysNotice> sysNoticeList = new ArrayList<>();
|
SysNotice sysNotice = new SysNotice();
|
sysNotice.setNoticeTitle("业务员 "+ businessOpportunity.getEntryPerson());
|
sysNotice.setNoticeContent("新增客户 " + businessOpportunity.getCustomerName() + " 金额 "+ businessOpportunity.getContractAmount());
|
sysNotice.setNoticeType("1");
|
sysNotice.setStatus("0");
|
sysNotice.setSenderId(SecurityUtils.getUserId());
|
// 推送给谁 需要待定
|
sysNotice.setConsigneeId(105L);
|
sysNotice.setAppJumpPath("pages/opportunityManagement/index");
|
sysNoticeMapper.insert(sysNotice);
|
sysNoticeList.add(sysNotice);
|
unipushService.sendClientMessage(sysNoticeList);
|
return businessDescriptionMapper.insert(businessDescription) > 0 ? R.ok() : R.fail();
|
}
|
|
@Override
|
public R addDescription(BusinessDescriptionDto businessDescription) {
|
// 迁移临时文件到正式文件
|
BusinessOpportunity byId = this.getById(businessDescription.getBusinessOpportunityId());
|
if(byId != null){
|
byId.setStatus(businessDescription.getStatus());
|
this.updateById(byId);
|
// 推送消息
|
List<SysNotice> sysNoticeList = new ArrayList<>();
|
SysNotice sysNotice = new SysNotice();
|
sysNotice.setNoticeTitle("业务员 "+ businessDescription.getEntryPerson());
|
sysNotice.setNoticeContent("客户 " + byId.getCustomerName() + " 金额 "+ byId.getContractAmount() + " 状态 " + businessDescription.getStatus());
|
sysNotice.setNoticeType("1");
|
sysNotice.setStatus("0");
|
sysNotice.setSenderId(SecurityUtils.getUserId());
|
sysNotice.setConsigneeId(105L);
|
sysNotice.setAppJumpPath("pages/opportunityManagement/index");
|
sysNoticeMapper.insert(sysNotice);
|
sysNoticeList.add(sysNotice);
|
unipushService.sendClientMessage(sysNoticeList);
|
}
|
int insert = businessDescriptionMapper.insert(businessDescription);
|
|
fileUtil.saveStorageAttachment(ApplicationTypeEnum.FILE, RecordTypeEnum.BUSINESS_DESCRIPTION, Long.valueOf(businessDescription.getId()), businessDescription.getBusinessCommonFiles());
|
|
return insert > 0 ? R.ok() : R.fail();
|
}
|
|
@Override
|
public boolean updateBusinessOpportunityById(BusinessOpportunityDto businessOpportunity) {
|
ArrayList<StorageBlobDTO> storageBlobDTOS = new ArrayList<>();
|
for (StorageBlobVO businessCommonFile : businessOpportunity.getBusinessCommonFiles()) {
|
StorageBlobDTO storageBlobDTO = new StorageBlobDTO();
|
BeanUtils.copyProperties(businessCommonFile, storageBlobDTO);
|
storageBlobDTOS.add(storageBlobDTO);
|
}
|
fileUtil.saveStorageAttachment(ApplicationTypeEnum.FILE, RecordTypeEnum.BUSINESS_OPPORTUNITY, businessOpportunity.getId(), storageBlobDTOS);
|
return this.updateById(businessOpportunity);
|
}
|
|
@Override
|
public boolean delete(List<Long> ids) {
|
for (Long id : ids) {
|
fileUtil.deleteStorageAttachmentsByApplicationAndRecordTypeAndRecordId(ApplicationTypeEnum.FILE, RecordTypeEnum.BUSINESS_OPPORTUNITY, id);
|
}
|
return this.removeBatchByIds(ids);
|
}
|
}
|
