|
|
|
|
@ -1,9 +1,13 @@
|
|
|
|
|
package com.ruoyi.jjh.declaration.service.impl;
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
|
|
import com.ruoyi.common.utils.DateUtils;
|
|
|
|
|
import com.ruoyi.common.exception.ServiceException;
|
|
|
|
|
import com.ruoyi.jjh.declaration.entity.BmsDeclarationRecords;
|
|
|
|
|
import com.ruoyi.jjh.declaration.entity.BmsEnterpriseBasicInfo;
|
|
|
|
|
import com.ruoyi.jjh.declaration.entity.BmsEnterpriseDirectory;
|
|
|
|
|
import com.ruoyi.jjh.declaration.entity.BmsTemplateRecord;
|
|
|
|
|
@ -13,7 +17,10 @@ import com.ruoyi.jjh.declaration.entity.dto.BmsTemplateRecordQueryDto;
|
|
|
|
|
import com.ruoyi.jjh.declaration.entity.dto.BmsTemplateRecordUpdateDto;
|
|
|
|
|
import com.ruoyi.jjh.declaration.entity.vo.BmsTemplateRecordQueryVo;
|
|
|
|
|
import com.ruoyi.jjh.declaration.entity.vo.BmsTemplateRecordVo;
|
|
|
|
|
import com.ruoyi.jjh.declaration.mapper.BmsDeclarationRecordsMapper;
|
|
|
|
|
import com.ruoyi.jjh.declaration.mapper.BmsTemplateRecordMapper;
|
|
|
|
|
import com.ruoyi.jjh.declaration.regular.TimeChange;
|
|
|
|
|
import com.ruoyi.jjh.declaration.service.IBmsDeclarationRecordsService;
|
|
|
|
|
import com.ruoyi.jjh.declaration.service.IBmsEnterpriseBasicInfoService;
|
|
|
|
|
import com.ruoyi.jjh.declaration.service.IBmsEnterpriseDirectoryService;
|
|
|
|
|
import com.ruoyi.jjh.declaration.service.IBmsTemplateRecordService;
|
|
|
|
|
@ -21,10 +28,12 @@ import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
|
|
import java.time.Year;
|
|
|
|
|
import java.util.ArrayList;
|
|
|
|
|
import java.util.Collection;
|
|
|
|
|
import java.util.HashMap;
|
|
|
|
|
import java.util.List;
|
|
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
import java.util.Map;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 在线模板Service业务层处理
|
|
|
|
|
@ -41,6 +50,11 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
|
|
|
|
|
@Autowired
|
|
|
|
|
private IBmsEnterpriseBasicInfoService iBmsEnterpriseBasicInfoService;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private IBmsDeclarationRecordsService iBmsDeclarationRecordsService;
|
|
|
|
|
@Resource
|
|
|
|
|
private TimeChange tiTimeChange;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 查询在线模板
|
|
|
|
|
*
|
|
|
|
|
@ -56,6 +70,7 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
|
|
|
|
|
return bmsTemplateRecordVo;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 查询在线模板列表
|
|
|
|
|
*
|
|
|
|
|
@ -67,6 +82,11 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
|
|
|
|
|
return baseMapper.selectTemplateRecordVo(bmsTemplateRecordQueryDto);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public Page<BmsTemplateRecordQueryVo> selectBmsTemplateRecordList(Page<BmsTemplateRecordQueryVo> page, BmsTemplateRecordQueryDto bmsTemplateRecordQueryDto) {
|
|
|
|
|
return baseMapper.selectTemplateRecordVo(page, bmsTemplateRecordQueryDto);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public List<BmsTemplateRecordQueryVo> selectTemplateRecordList(String creditCode) {
|
|
|
|
|
return baseMapper.selectTemplateRecordList(creditCode);
|
|
|
|
|
@ -93,34 +113,106 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
|
|
public int insertBmsTemplateRecord(BmsTemplateRecordAddDto bmsTemplateRecordAddDto) {
|
|
|
|
|
int num = 0;
|
|
|
|
|
try {
|
|
|
|
|
bmsTemplateRecordAddDto.setCreateTime(DateUtils.getNowDate());
|
|
|
|
|
num = baseMapper.insertBmsTemplateRecord(bmsTemplateRecordAddDto);
|
|
|
|
|
List<BmsEnterpriseDirectory> enterpriseDirectoryList = bmsTemplateRecordAddDto
|
|
|
|
|
.getEnterpriseDirectoryList();
|
|
|
|
|
if (null != enterpriseDirectoryList && enterpriseDirectoryList.size() > 0) {
|
|
|
|
|
enterpriseDirectoryList.forEach(x -> {
|
|
|
|
|
x.setTemplateRecordId(bmsTemplateRecordAddDto.getId());
|
|
|
|
|
});
|
|
|
|
|
enterpriseDirectoryService.saveOrUpdateBatch(enterpriseDirectoryList);
|
|
|
|
|
//新增的时候根据当前时间判断状态是否有效
|
|
|
|
|
tiTimeChange.getTime(bmsTemplateRecordAddDto);
|
|
|
|
|
//添加在线模板
|
|
|
|
|
num = baseMapper.insert(bmsTemplateRecordAddDto);
|
|
|
|
|
//前端excel企业名录集合
|
|
|
|
|
List<BmsEnterpriseDirectory> enterpriseDirectoryList = bmsTemplateRecordAddDto
|
|
|
|
|
.getEnterpriseDirectoryList();
|
|
|
|
|
//要添加的在线申报记录
|
|
|
|
|
List<BmsDeclarationRecords> drlist = new ArrayList<>();
|
|
|
|
|
//如果前端部分企业名录集合为空
|
|
|
|
|
if (null != enterpriseDirectoryList && enterpriseDirectoryList.size() > 0) {
|
|
|
|
|
// //保存所有的信用代码
|
|
|
|
|
// List<String> codeList = new ArrayList<>();
|
|
|
|
|
// for (BmsEnterpriseDirectory x : enterpriseDirectoryList) {
|
|
|
|
|
// codeList.add(x.getCreditCode());
|
|
|
|
|
// }
|
|
|
|
|
// //根据信用代码去企业信息表里查找该企业，如果能找到并且该企业未填报过该模板 就添加企业id
|
|
|
|
|
// LambdaQueryWrapper<BmsEnterpriseBasicInfo> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
|
|
// lambdaQueryWrapper.in(BmsEnterpriseBasicInfo::getCreditCode, codeList);
|
|
|
|
|
// List<BmsEnterpriseBasicInfo> list = iBmsEnterpriseBasicInfoService.list(lambdaQueryWrapper);
|
|
|
|
|
//如果能找到该企业就是集合不为空的话,并且长度和excel企业名录长度一致的话
|
|
|
|
|
// if (!list.isEmpty() & list.size() == enterpriseDirectoryList.size()) {
|
|
|
|
|
//保存所有能在企业基础信息里面找的企业id
|
|
|
|
|
// List<Long> idList = new ArrayList<>();
|
|
|
|
|
// list.forEach(a1 -> {
|
|
|
|
|
// idList.add(a1.getId());
|
|
|
|
|
//保存在在线申报模板集合里面
|
|
|
|
|
// });
|
|
|
|
|
List<String> codeList = new ArrayList<>();
|
|
|
|
|
enterpriseDirectoryList.forEach(x -> {
|
|
|
|
|
codeList.add(x.getCreditCode());
|
|
|
|
|
getDeclarationRecordsList(bmsTemplateRecordAddDto, drlist, x.getCreditCode(), bmsTemplateRecordAddDto.getTemplateId());
|
|
|
|
|
x.setTemplateRecordId(bmsTemplateRecordAddDto.getId());
|
|
|
|
|
});
|
|
|
|
|
//在在线申报记录里面找到对于该模板和该企业的在线申报记录
|
|
|
|
|
List<BmsDeclarationRecords> bm = iBmsDeclarationRecordsService.selectET(bmsTemplateRecordAddDto.getTemplateId(), codeList);
|
|
|
|
|
//如果一条也没有找到就添加到企业名录表里呢
|
|
|
|
|
if (bm.isEmpty()) {
|
|
|
|
|
enterpriseDirectoryService.saveBatch(enterpriseDirectoryList);
|
|
|
|
|
} else {
|
|
|
|
|
List<BmsEnterpriseBasicInfo> list = iBmsEnterpriseBasicInfoService.list();
|
|
|
|
|
Collection<BmsEnterpriseDirectory> copyList = new ArrayList<>();
|
|
|
|
|
for (BmsEnterpriseBasicInfo items : list) {
|
|
|
|
|
BmsEnterpriseDirectory bms = new BmsEnterpriseDirectory();
|
|
|
|
|
bms.setTemplateRecordId(bmsTemplateRecordAddDto.getId());
|
|
|
|
|
bms.setEnterpriseName(items.getEnterpriseName());
|
|
|
|
|
bms.setCreditCode(items.getCreditCode());
|
|
|
|
|
copyList.add(bms);
|
|
|
|
|
}
|
|
|
|
|
//如果有的企业已经对该模板分配过申请任务的话就报错
|
|
|
|
|
throw new ServiceException("某企业已经分配该模板任务");
|
|
|
|
|
}
|
|
|
|
|
// }else {
|
|
|
|
|
// throw new ServiceException("某企业不在企业信息库");
|
|
|
|
|
// }
|
|
|
|
|
} else {
|
|
|
|
|
List<BmsEnterpriseBasicInfo> list = iBmsEnterpriseBasicInfoService.list();
|
|
|
|
|
List<BmsEnterpriseDirectory> copyList = new ArrayList<>();
|
|
|
|
|
//保存所有的企业信用代码
|
|
|
|
|
List<String> idList = new ArrayList<>();
|
|
|
|
|
for (BmsEnterpriseBasicInfo items : list) {
|
|
|
|
|
BmsEnterpriseDirectory bms = new BmsEnterpriseDirectory();
|
|
|
|
|
bms.setTemplateRecordId(bmsTemplateRecordAddDto.getId());
|
|
|
|
|
bms.setEnterpriseName(items.getEnterpriseName());
|
|
|
|
|
bms.setCreditCode(items.getCreditCode());
|
|
|
|
|
idList.add(items.getCreditCode());
|
|
|
|
|
copyList.add(bms);
|
|
|
|
|
getDeclarationRecordsList(bmsTemplateRecordAddDto, drlist, items.getCreditCode(), bmsTemplateRecordAddDto.getTemplateId());
|
|
|
|
|
}
|
|
|
|
|
List<BmsDeclarationRecords> bm = iBmsDeclarationRecordsService.selectET(bmsTemplateRecordAddDto.getTemplateId(), idList);
|
|
|
|
|
if (bm.isEmpty()) {
|
|
|
|
|
enterpriseDirectoryService.saveBatch(copyList);
|
|
|
|
|
} else {
|
|
|
|
|
throw new ServiceException("某企业已经分配该模板任务");
|
|
|
|
|
}
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
}
|
|
|
|
|
iBmsDeclarationRecordsService.saveBatch(drlist);
|
|
|
|
|
return num;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// /**
|
|
|
|
|
// * 假如给该企业已经加了申报任务指定申报模板，就不能再给这个企业加该申报模板的申报任务（所有的企业）
|
|
|
|
|
// *
|
|
|
|
|
// * @param list
|
|
|
|
|
// */
|
|
|
|
|
// private void judgement(List<BmsDeclarationRecords> bm, List<BmsEnterpriseDirectory> list) {
|
|
|
|
|
// List<String> str1 = new ArrayList<>();
|
|
|
|
|
// bm.forEach(x -> {
|
|
|
|
|
// list.forEach(y -> {
|
|
|
|
|
// if (Objects.equals(x.getEnterpriseId(), y.getId())) {
|
|
|
|
|
// str1.add(y.getEnterpriseName());
|
|
|
|
|
// }
|
|
|
|
|
// });
|
|
|
|
|
// });
|
|
|
|
|
// throw new ServiceException(StringUtils.join(str1, ",") + "已经分配该模板任务");
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
private void getDeclarationRecordsList(BmsTemplateRecord bmsTemplateRecordAddDto, List<BmsDeclarationRecords> drlist, String creditCode, Long items) {
|
|
|
|
|
BmsDeclarationRecords drItems = new BmsDeclarationRecords();
|
|
|
|
|
drItems.setProjectName(bmsTemplateRecordAddDto.getEnterpriseDirectory());
|
|
|
|
|
drItems.setYear(String.valueOf(Year.now().getValue()));
|
|
|
|
|
drItems.setCreditCode(creditCode);
|
|
|
|
|
drItems.setTemplateRecordId(bmsTemplateRecordAddDto.getId());
|
|
|
|
|
drItems.setStatus(0L);
|
|
|
|
|
drItems.setTemplateId(Math.toIntExact(items));
|
|
|
|
|
drItems.setIsDeleted(0L);
|
|
|
|
|
drlist.add(drItems);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 修改在线模板
|
|
|
|
|
*
|
|
|
|
|
@ -130,8 +222,8 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
|
|
|
|
|
@Override
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
|
|
public int updateBmsTemplateRecord(BmsTemplateRecordUpdateDto bmsTemplateRecordUpdateDto) {
|
|
|
|
|
bmsTemplateRecordUpdateDto.setUpdateTime(DateUtils.getNowDate());
|
|
|
|
|
int num = baseMapper.updateBmsTemplateRecord(bmsTemplateRecordUpdateDto);
|
|
|
|
|
tiTimeChange.getTime(bmsTemplateRecordUpdateDto);
|
|
|
|
|
int num = baseMapper.updateById(bmsTemplateRecordUpdateDto);
|
|
|
|
|
// 删除企业相关列表
|
|
|
|
|
QueryWrapper<BmsEnterpriseDirectory> queryWrapper = new QueryWrapper<>();
|
|
|
|
|
queryWrapper.eq("template_record_id", bmsTemplateRecordUpdateDto.getId());
|
|
|
|
|
@ -169,4 +261,130 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
|
|
|
|
|
public int deleteBmsTemplateRecordById(Long id) {
|
|
|
|
|
return baseMapper.deleteBmsTemplateRecordById(id);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 补录
|
|
|
|
|
*
|
|
|
|
|
* @param bmsTemplateRecordUpdateDto
|
|
|
|
|
* @return
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
|
|
public int supplementation(BmsTemplateRecordUpdateDto bmsTemplateRecordUpdateDto) {
|
|
|
|
|
//只有未修改之前是过期的才能补录
|
|
|
|
|
if (bmsTemplateRecordUpdateDto.getStatus() != 1) {
|
|
|
|
|
throw new ServiceException("未过期不可以补录");
|
|
|
|
|
}
|
|
|
|
|
tiTimeChange.getTime(bmsTemplateRecordUpdateDto);
|
|
|
|
|
if (bmsTemplateRecordUpdateDto.getStatus() != 2) {
|
|
|
|
|
throw new ServiceException("请修改时间范围为有效区间");
|
|
|
|
|
}
|
|
|
|
|
int num = baseMapper.updateById(bmsTemplateRecordUpdateDto);
|
|
|
|
|
//要添加的在线申报记录
|
|
|
|
|
List<BmsDeclarationRecords> drlist = new ArrayList<>();
|
|
|
|
|
//获取前端传递的企业名录列表
|
|
|
|
|
List<BmsEnterpriseDirectory> enterpriseDirectoryList = bmsTemplateRecordUpdateDto
|
|
|
|
|
.getEnterpriseDirectoryList();
|
|
|
|
|
//先去查找企业名录中对应该在线模板的相关企业
|
|
|
|
|
List<BmsEnterpriseDirectory> list = enterpriseDirectoryService.lambdaQuery()
|
|
|
|
|
.eq(BmsEnterpriseDirectory::getTemplateRecordId, bmsTemplateRecordUpdateDto.getId()).list();
|
|
|
|
|
//首先部分企业和所有企业去区分
|
|
|
|
|
if (bmsTemplateRecordUpdateDto.getIsFrame() == 0) {
|
|
|
|
|
enterpriseDirectoryList = new ArrayList<>();
|
|
|
|
|
//企业信息表里所有企业
|
|
|
|
|
List<BmsEnterpriseBasicInfo> allList = iBmsEnterpriseBasicInfoService.list();
|
|
|
|
|
//将信息表的所有企业添加到名录表
|
|
|
|
|
for (BmsEnterpriseBasicInfo x : allList) {
|
|
|
|
|
BmsEnterpriseDirectory bmsEnterpriseDirectory = new BmsEnterpriseDirectory();
|
|
|
|
|
bmsEnterpriseDirectory.setCreditCode(x.getCreditCode());
|
|
|
|
|
bmsEnterpriseDirectory.setEnterpriseName(x.getEnterpriseName());
|
|
|
|
|
enterpriseDirectoryList.add(bmsEnterpriseDirectory);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
//java有两个list实体类集合 如果a集合某条数据里面的name和b里面某条数据的name相等 就去除a的该条数据
|
|
|
|
|
enterpriseDirectoryList.removeIf(entityA -> list.stream().anyMatch(entityB -> entityB.getCreditCode().equals(entityA.getCreditCode())));
|
|
|
|
|
enterpriseDirectoryList.forEach(x->{
|
|
|
|
|
x.setTemplateRecordId(bmsTemplateRecordUpdateDto.getId());
|
|
|
|
|
getDeclarationRecordsList(bmsTemplateRecordUpdateDto, drlist, x.getCreditCode(), bmsTemplateRecordUpdateDto.getTemplateId());
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
//去在线申报记录找已经填报过的企业
|
|
|
|
|
// QueryWrapper<BmsDeclarationRecords> query = new QueryWrapper<>();
|
|
|
|
|
// query.eq("template_record_id", bmsTemplateRecordUpdateDto.getId())
|
|
|
|
|
// .ne("status", 0)
|
|
|
|
|
// .isNotNull("detail_id");
|
|
|
|
|
// List<BmsDeclarationRecords> deRList = iBmsDeclarationRecordsService.list(query);
|
|
|
|
|
//存储已经填报过的所有企业信用代码
|
|
|
|
|
// List<BmsEnterpriseDirectory> deIdList = new ArrayList<>();
|
|
|
|
|
// for (BmsDeclarationRecords items : deRList) {
|
|
|
|
|
// BmsEnterpriseDirectory bmsEnterpriseDirectory = new BmsEnterpriseDirectory();
|
|
|
|
|
// bmsEnterpriseDirectory.setCreditCode(items.getCreditCode());
|
|
|
|
|
// deIdList.add(bmsEnterpriseDirectory);
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 创建存放所有数据的map
|
|
|
|
|
// Map<String, BmsEnterpriseDirectory> map = new HashMap<>();
|
|
|
|
|
// // 合并俩个集合
|
|
|
|
|
// list.addAll(enterpriseDirectoryList);
|
|
|
|
|
// // 遍历合并后的集合存放到map里
|
|
|
|
|
// list.forEach(t -> {
|
|
|
|
|
// map.putIfAbsent(t.getCreditCode(), t);
|
|
|
|
|
// });
|
|
|
|
|
// // 这是将excel和企业名录去重之后的企业
|
|
|
|
|
// List<BmsEnterpriseDirectory> mergeList = new ArrayList<>(map.values());
|
|
|
|
|
//
|
|
|
|
|
// List<String> code = new ArrayList<>();
|
|
|
|
|
// mergeList.forEach(x->{
|
|
|
|
|
// code.add(x.getCreditCode());
|
|
|
|
|
// x.setTemplateRecordId(bmsTemplateRecordUpdateDto.getId());
|
|
|
|
|
// getDeclarationRecordsList(bmsTemplateRecordUpdateDto, drlist, x.getCreditCode(), bmsTemplateRecordUpdateDto.getTemplateId());
|
|
|
|
|
// });
|
|
|
|
|
|
|
|
|
|
// QueryWrapper<BmsDeclarationRecords> queryWrapper = new QueryWrapper<>();
|
|
|
|
|
// queryWrapper.in("credit_code", code);
|
|
|
|
|
// queryWrapper.eq("template_record_id", bmsTemplateRecordUpdateDto.getId());
|
|
|
|
|
// queryWrapper.eq("status", 0);
|
|
|
|
|
// queryWrapper.isNull("detail_id");
|
|
|
|
|
// iBmsDeclarationRecordsService.remove(queryWrapper);
|
|
|
|
|
//新增到企业名录
|
|
|
|
|
enterpriseDirectoryService.saveBatch(enterpriseDirectoryList);
|
|
|
|
|
//最后新添加进在线申报记录
|
|
|
|
|
iBmsDeclarationRecordsService.saveBatch(drlist);
|
|
|
|
|
|
|
|
|
|
// //再去在线申报记录里面查找相关企业的在线申报记录
|
|
|
|
|
// List<BmsDeclarationRecords> bm = iBmsDeclarationRecordsService.selectET(bmsTemplateRecordUpdateDto.getId(), idList);
|
|
|
|
|
// //保存要删除的在线申报记录id集合
|
|
|
|
|
// List<Long> deIdList = new ArrayList<>();
|
|
|
|
|
// //去查看这些申报记录里面未填报的企业
|
|
|
|
|
// bm.forEach(x->{
|
|
|
|
|
// if(x.getStatus() == 0){
|
|
|
|
|
// getDeclarationRecordsList(bmsTemplateRecordUpdateDto, drlist, x.getCreditCode(), bmsTemplateRecordUpdateDto.getId());
|
|
|
|
|
// deIdList.add(x.getId());
|
|
|
|
|
// }
|
|
|
|
|
// });
|
|
|
|
|
// //删除这些分配的在线申报记录
|
|
|
|
|
// iBmsDeclarationRecordsService.removeBatchByIds(deIdList);
|
|
|
|
|
|
|
|
|
|
return num;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 暂省略（和企业信息表做对比）
|
|
|
|
|
*
|
|
|
|
|
* @param enterpriseDirectoryList
|
|
|
|
|
* @return
|
|
|
|
|
*/
|
|
|
|
|
private List<BmsEnterpriseBasicInfo> filterEnterprise(List<BmsEnterpriseDirectory> enterpriseDirectoryList) {
|
|
|
|
|
//保存所有的信用代码
|
|
|
|
|
List<String> codeList = new ArrayList<>();
|
|
|
|
|
for (BmsEnterpriseDirectory x : enterpriseDirectoryList) {
|
|
|
|
|
codeList.add(x.getCreditCode());
|
|
|
|
|
}
|
|
|
|
|
//根据信用代码去企业信息表里查找该企业，如果能找到并且该企业未填报过该模板 就添加企业id
|
|
|
|
|
LambdaQueryWrapper<BmsEnterpriseBasicInfo> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
|
|
lambdaQueryWrapper.in(BmsEnterpriseBasicInfo::getCreditCode, codeList);
|
|
|
|
|
return iBmsEnterpriseBasicInfoService.list(lambdaQueryWrapper);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
