package com.gkhy.hazmat.system.service.impl;
|
|
import cn.hutool.core.util.ObjectUtil;
|
import com.alibaba.excel.EasyExcel;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.gkhy.hazmat.common.api.CommonPage;
|
import com.gkhy.hazmat.common.domain.entity.SysUser;
|
import com.gkhy.hazmat.common.excel.ProductBasicExcelData;
|
import com.gkhy.hazmat.common.excel.ProductBasicExcelDataListener;
|
import com.gkhy.hazmat.common.excel.SecientificExcelData;
|
import com.gkhy.hazmat.common.excel.SecientificExcelDataListener;
|
import com.gkhy.hazmat.common.exception.ApiException;
|
import com.gkhy.hazmat.common.utils.PageUtils;
|
import com.gkhy.hazmat.common.utils.SecurityUtils;
|
import com.gkhy.hazmat.common.utils.StringUtils;
|
import com.gkhy.hazmat.system.domain.HzProductBasic;
|
import com.gkhy.hazmat.system.domain.HzSecientific;
|
import com.gkhy.hazmat.system.domain.vo.HzSecientificVo;
|
import com.gkhy.hazmat.system.mapper.HzSecientificMapper;
|
import com.gkhy.hazmat.system.service.HzSecientificService;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import java.io.IOException;
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Service
|
public class HzSecientificServiceImpl extends ServiceImpl<HzSecientificMapper, HzSecientific> implements HzSecientificService {
|
|
@Override
|
public CommonPage selectSecientific(HzSecientific hzSecientific) {
|
SysUser user = SecurityUtils.getLoginUser().getUser();
|
PageUtils.startPage();
|
List<HzSecientificVo> hzSecientificVos = baseMapper.selectSecientificBatch(hzSecientific);
|
return CommonPage.restPage(hzSecientificVos);
|
}
|
|
@Override
|
public int insertSecientific(HzSecientific hzSecientific) {
|
SysUser user = SecurityUtils.getLoginUser().getUser();
|
hzSecientific.setCreateBy(user.getUsername());
|
hzSecientific.setCreateTime(LocalDateTime.now());
|
int insert = baseMapper.insert(hzSecientific);
|
if (insert<0){
|
throw new ApiException("新增失败");
|
}
|
return insert;
|
}
|
|
@Override
|
public int updateSecientific(HzSecientific hzSecientific) {
|
SysUser user = SecurityUtils.getLoginUser().getUser();
|
hzSecientific.setUpdateBy(user.getUsername());
|
hzSecientific.setUpdateTime(LocalDateTime.now());
|
int row = baseMapper.updateById(hzSecientific);
|
if (row<0){
|
throw new ApiException("修改失败");
|
}
|
return row;
|
}
|
|
@Override
|
public int deleteSecientific(Long secientificId) {
|
int row = baseMapper.deleteById(secientificId);
|
if (row<0){
|
throw new ApiException("删除失败");
|
}
|
return row;
|
}
|
|
@Override
|
public Integer importExcel(MultipartFile file) throws IOException {
|
if(ObjectUtil.isEmpty(file)){
|
throw new ApiException("上传对象不能为空");
|
}
|
List<SecientificExcelData> secientificExcelData = EasyExcel.read(file.getInputStream(), SecientificExcelData.class, new SecientificExcelDataListener()).sheet().doReadSync();
|
List<HzSecientific> hzSecientifics = new ArrayList<>();
|
|
SysUser user = SecurityUtils.getLoginUser().getUser();
|
|
for (SecientificExcelData secientificExcelDatum : secientificExcelData) {
|
checkData(secientificExcelDatum);
|
HzSecientific hzSecientific = new HzSecientific();
|
BeanUtils.copyProperties(secientificExcelDatum,hzSecientific);
|
hzSecientific.setCreateBy(user.getUsername());
|
hzSecientific.setCreateTime(LocalDateTime.now());
|
hzSecientifics.add(hzSecientific);
|
}
|
|
if(!hzSecientifics.isEmpty()){
|
if(hzSecientifics.size()>100){
|
int pageSize=100;
|
while (true){
|
List<HzSecientific> secientifics = hzSecientifics.subList(0, Math.min(hzSecientifics.size(), pageSize));
|
saveBatch(secientifics);
|
if(secientifics.size()<pageSize){
|
break;
|
}
|
hzSecientifics=hzSecientifics.subList(pageSize,hzSecientifics.size());
|
if(hzSecientifics.isEmpty()){
|
break;
|
}
|
}
|
}else{
|
saveBatch(hzSecientifics);
|
}
|
}
|
return hzSecientifics.size();
|
}
|
|
private void checkData(SecientificExcelData secientificExcelDatum) {
|
if(StringUtils.isBlank(secientificExcelDatum.getSecientificName())){
|
throw new ApiException("序号"+secientificExcelDatum.getIndex()+"品名为空"+"危险性类别:"+secientificExcelDatum.getRiskType());
|
}
|
// if(StringUtils.isBlank(secientificExcelDatum.getCas())){
|
// throw new ApiException("序号"+secientificExcelDatum.getIndex()+"CAS码为空");
|
// }
|
// if(StringUtils.isBlank(secientificExcelDatum.getRiskType())){
|
// throw new ApiException("序号"+secientificExcelDatum.getIndex()+"危险性类别为空");
|
// }
|
// if(secientificExcelDatum.getPeculiarityNumber() == null){
|
// throw new ApiException("序号"+secientificExcelDatum.getIndex()+"危化品特性编码为空");
|
// }
|
}
|
}
|
