package com.ruoyi.quality.service.impl;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
|
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.deepoove.poi.XWPFTemplate;
|
import com.deepoove.poi.config.Configure;
|
import com.ruoyi.common.exception.base.BaseException;
|
import com.ruoyi.common.exception.ServiceException;
|
import com.ruoyi.common.utils.HackLoopTableRenderPolicy;
|
import com.ruoyi.common.utils.SecurityUtils;
|
import com.ruoyi.common.utils.poi.ExcelUtil;
|
import com.ruoyi.framework.security.LoginUser;
|
import com.ruoyi.procurementrecord.dto.Details;
|
import com.ruoyi.procurementrecord.dto.ProcurementAddDto;
|
import com.ruoyi.procurementrecord.pojo.ProcurementRecordStorage;
|
import com.ruoyi.procurementrecord.service.ProcurementRecordService;
|
import com.ruoyi.quality.dto.QualityInspectDto;
|
import com.ruoyi.quality.mapper.QualityInspectMapper;
|
import com.ruoyi.quality.mapper.QualityTestStandardMapper;
|
import com.ruoyi.quality.mapper.QualityUnqualifiedMapper;
|
import com.ruoyi.quality.pojo.QualityInspect;
|
import com.ruoyi.quality.pojo.QualityInspectParam;
|
import com.ruoyi.quality.pojo.QualityUnqualified;
|
import com.ruoyi.quality.service.IQualityInspectParamService;
|
import com.ruoyi.quality.service.IQualityInspectService;
|
import com.ruoyi.sales.mapper.SalesLedgerProductMapper;
|
import com.ruoyi.sales.pojo.SalesLedgerProduct;
|
import lombok.AllArgsConstructor;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.InputStream;
|
import java.io.OutputStream;
|
import java.math.BigDecimal;
|
import java.net.URLEncoder;
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
@AllArgsConstructor
|
@Service
|
@Transactional(rollbackFor = Exception.class)
|
public class QualityInspectServiceImpl extends ServiceImpl<QualityInspectMapper, QualityInspect> implements IQualityInspectService {
|
|
private QualityInspectMapper qualityInspectMapper;
|
|
private IQualityInspectParamService qualityInspectParamService;
|
|
private QualityTestStandardMapper qualityTestStandardMapper;
|
|
private QualityUnqualifiedMapper qualityUnqualifiedMapper;
|
|
private SalesLedgerProductMapper salesLedgerProductMapper;
|
|
private ProcurementRecordService procurementRecordService;
|
|
@Override
|
public int add(QualityInspectDto qualityInspectDto) {
|
QualityInspect qualityInspect = new QualityInspect();
|
BeanUtils.copyProperties(qualityInspectDto,qualityInspect);
|
qualityInspect.setInspectState(0);//默认未提交
|
int inserted = qualityInspectMapper.insert(qualityInspect);
|
if (inserted <= 0 || qualityInspect.getId() == null) {
|
throw new ServiceException("新增检验记录失败");
|
}
|
for (QualityInspectParam qualityInspectParam : qualityInspectDto.getQualityInspectParams()) {
|
qualityInspectParam.setInspectId(qualityInspect.getId());
|
}
|
if (!qualityInspectParamService.saveBatch(qualityInspectDto.getQualityInspectParams())) {
|
throw new ServiceException("保存检验项目失败");
|
}
|
return inserted;
|
}
|
|
@Override
|
public QualityInspectDto getDetailById(Integer id) {
|
QualityInspect qualityInspect = qualityInspectMapper.selectById(id);
|
if (qualityInspect == null) {
|
throw new ServiceException("检验记录不存在");
|
}
|
List<QualityInspectParam> qualityInspectParams = qualityInspectParamService.list(Wrappers.<QualityInspectParam>lambdaQuery().eq(QualityInspectParam::getInspectId, id));
|
QualityInspectDto qualityInspectDto = new QualityInspectDto();
|
BeanUtils.copyProperties(qualityInspect,qualityInspectDto);
|
qualityInspectDto.setQualityInspectParams(qualityInspectParams);
|
return qualityInspectDto;
|
}
|
|
//提交
|
@Override
|
public int submit(QualityInspect inspect) {
|
if (inspect == null || inspect.getId() == null) {
|
throw new ServiceException("检验记录ID不能为空");
|
}
|
QualityInspect qualityInspect = qualityInspectMapper.selectById(inspect.getId());
|
if (qualityInspect == null) {
|
throw new ServiceException("检验记录不存在");
|
}
|
if (Integer.valueOf(1).equals(qualityInspect.getInspectState())) {
|
throw new ServiceException("检验记录已提交，请勿重复操作");
|
}
|
if (!"合格".equals(qualityInspect.getCheckResult())
|
&& !"不合格".equals(qualityInspect.getCheckResult())) {
|
throw new ServiceException("请先完成检验结果判定");
|
}
|
List<QualityInspectParam> inspectParams = qualityInspectParamService.list(
|
Wrappers.<QualityInspectParam>lambdaQuery()
|
.eq(QualityInspectParam::getInspectId, inspect.getId()));
|
if (inspectParams.isEmpty()) {
|
throw new ServiceException("检验项目为空，不能提交");
|
}
|
for (QualityInspectParam parameter : inspectParams) {
|
if (StringUtils.isBlank(parameter.getTestValue())) {
|
throw new ServiceException("检验项目“" + parameter.getParameterItem() + "”尚未填写检验值");
|
}
|
}
|
/*判断不合格*/
|
if (ObjectUtils.isNotNull(qualityInspect.getCheckResult()) && qualityInspect.getCheckResult().equals("不合格")){
|
QualityUnqualified qualityUnqualified = new QualityUnqualified();
|
BeanUtils.copyProperties(qualityInspect,qualityUnqualified);
|
qualityUnqualified.setInspectState(0);//待处理
|
String text = inspectParams.stream().map(QualityInspectParam::getParameterItem).collect(Collectors.joining(","));
|
qualityUnqualified.setDefectivePhenomena(text+"这些指标中存在不合格");//不合格现象
|
qualityUnqualifiedMapper.insert(qualityUnqualified);
|
}
|
|
LoginUser loginUser = SecurityUtils.getLoginUser();
|
if (qualityInspect.getInspectType() == 0) {
|
// 合格且关联了采购单/产品信息时才自动入库，信息不全时跳过入库但正常提交
|
if ("合格".equals(qualityInspect.getCheckResult())
|
&& qualityInspect.getPurchaseLedgerId() != null) {
|
SalesLedgerProduct salesLedgerProduct = salesLedgerProductMapper.selectById(qualityInspect.getProductId());
|
if (salesLedgerProduct != null) {
|
ProcurementAddDto procurementRecordOutAdd = new ProcurementAddDto();
|
procurementRecordOutAdd.setType(1);
|
procurementRecordOutAdd.setTypeName("采购原材料检验合格入库");
|
procurementRecordOutAdd.setNickName(loginUser.getNickName());
|
procurementRecordOutAdd.setPurchaseLedgerId(Math.toIntExact(qualityInspect.getPurchaseLedgerId()));
|
|
ArrayList<Details> detailss = new ArrayList<>();
|
Details details = new Details();
|
details.setId(Math.toIntExact(salesLedgerProduct.getId()));
|
details.setInboundQuantity(qualityInspect.getQuantity());
|
details.setWarnNum(salesLedgerProduct.getWarnNum());
|
details.setUnitPrice(salesLedgerProduct.getTaxInclusiveUnitPrice());
|
details.setTotalPrice(salesLedgerProduct.getTaxInclusiveTotalPrice());
|
details.setProductModelId(qualityInspect.getProductModelId());
|
detailss.add( details);
|
procurementRecordOutAdd.setDetails(detailss);
|
procurementRecordOutAdd.setQualityInspectId(qualityInspect.getId());
|
procurementRecordService.add(procurementRecordOutAdd);
|
}
|
}
|
}else if (qualityInspect.getInspectType() == 1) {
|
// 过程检验仅合格时入库，不合格品由上面的不合格管理流程处理
|
if ("合格".equals(qualityInspect.getCheckResult())) {
|
ProcurementAddDto procurementRecordOutAdd = new ProcurementAddDto();
|
procurementRecordOutAdd.setType(2);
|
procurementRecordOutAdd.setTypeName("生产过程检验合格入库");
|
procurementRecordOutAdd.setNickName(loginUser.getNickName());
|
List<Details> details = new ArrayList<>();
|
Details details1 = new Details();
|
details1.setInboundQuantity(qualityInspect.getQuantity());
|
details1.setProductModelId(qualityInspect.getProductModelId());
|
procurementRecordOutAdd.setDetails(details);
|
|
ProcurementRecordStorage.ProcurementRecordStorageBuilder procurementRecordBuilder = ProcurementRecordStorage.builder()
|
.salesLedgerProductId(0)
|
.inboundBatches( "生产半成品入库")
|
.inboundNum(details1.getInboundQuantity())
|
.type(2)
|
.warnNum(new BigDecimal(0))
|
.unitPrice(new BigDecimal(0))
|
.totalPrice(new BigDecimal(0))
|
.createTime(LocalDateTime.now())
|
.createUser(loginUser.getUserId())
|
.updateTime(LocalDateTime.now())
|
.updateUser(loginUser.getUserId())
|
.createBy(procurementRecordOutAdd.getNickName())
|
.productModelId(details1.getProductModelId())
|
.qualityInspectId(qualityInspect.getId());
|
procurementRecordService.save(procurementRecordBuilder.build());
|
}
|
}else if (qualityInspect.getInspectType() == 2) {
|
// 出厂检验仅合格时入库，缺少产品信息时跳过入库但正常提交
|
if ("合格".equals(qualityInspect.getCheckResult())) {
|
SalesLedgerProduct salesLedgerProduct = salesLedgerProductMapper.selectSalesLedgerProductByMainId(qualityInspect.getProductMainId());
|
if (salesLedgerProduct != null) {
|
ProcurementAddDto procurementRecordOutAdd = new ProcurementAddDto();
|
procurementRecordOutAdd.setType(2);
|
procurementRecordOutAdd.setTypeName("生产出厂检验合格入库");
|
procurementRecordOutAdd.setNickName(loginUser.getNickName());
|
List<Details> details = new ArrayList<>();
|
Details details1 = new Details();
|
details1.setInboundQuantity(qualityInspect.getQuantity());
|
details1.setId(Math.toIntExact(salesLedgerProduct.getId()));
|
details1.setUnitPrice(salesLedgerProduct.getTaxInclusiveUnitPrice());
|
details1.setTotalPrice(salesLedgerProduct.getTaxInclusiveTotalPrice());
|
details1.setProductModelId(salesLedgerProduct.getProductModelId());
|
details.add(details1);
|
procurementRecordOutAdd.setDetails(details);
|
procurementRecordOutAdd.setQualityInspectId(qualityInspect.getId());
|
procurementRecordService.add(procurementRecordOutAdd);
|
}
|
}
|
}
|
qualityInspect.setInspectState(1);//已提交
|
return qualityInspectMapper.updateById(qualityInspect);
|
}
|
|
/*生成检验报告*/
|
@Override
|
public void down(HttpServletResponse response, QualityInspect qualityInspect) {
|
QualityInspect inspect = qualityInspectMapper.selectById(qualityInspect.getId());
|
String inspectType="";
|
switch (inspect.getInspectType()){
|
case 0:
|
inspectType="原材料检验";
|
break;
|
case 1:
|
inspectType="过程检验";
|
break;
|
case 2:
|
inspectType="出厂检验";
|
break;
|
}
|
List<QualityInspectParam> paramList = qualityInspectParamService.list(Wrappers.<QualityInspectParam>lambdaQuery().eq(QualityInspectParam::getInspectId, inspect.getId()));
|
int index = 1;
|
for (QualityInspectParam detail : paramList) {
|
detail.setIndex(index);
|
index++;
|
}
|
InputStream inputStream = this.getClass().getResourceAsStream("/static/report-template.docx");
|
Configure configure = Configure.builder()
|
.bind("paramList", new HackLoopTableRenderPolicy())
|
.build();
|
String finalInspectType = inspectType;
|
XWPFTemplate template = XWPFTemplate.compile(inputStream, configure).render(
|
new HashMap<String, Object>() {{
|
put("inspect", inspect);
|
put("inspectType", finalInspectType);
|
put("paramList", paramList);
|
}});
|
|
try {
|
response.setContentType("application/msword");
|
String fileName = URLEncoder.encode(
|
"检验报告", "UTF-8");
|
response.setHeader("Access-Control-Expose-Headers", "Content-Disposition");
|
response.setHeader("Content-disposition",
|
"attachment;filename=" + fileName + ".docx");
|
OutputStream os = response.getOutputStream();
|
template.write(os);
|
os.flush();
|
os.close();
|
inputStream.close();
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new RuntimeException("导出失败");
|
}
|
}
|
|
@Override
|
public int updateQualityInspect(QualityInspectDto qualityInspectDto) {
|
if (ObjectUtils.isNotNull(qualityInspectDto.getQualityInspectParams())) {
|
qualityInspectParamService.remove(Wrappers.<QualityInspectParam>lambdaQuery().eq(QualityInspectParam::getInspectId,qualityInspectDto.getId()));
|
for (QualityInspectParam qualityInspectParam : qualityInspectDto.getQualityInspectParams()) {
|
qualityInspectParam.setInspectId(qualityInspectDto.getId());
|
}
|
qualityInspectParamService.saveBatch(qualityInspectDto.getQualityInspectParams());
|
}
|
QualityInspect qualityInspect = new QualityInspect();
|
BeanUtils.copyProperties(qualityInspectDto,qualityInspect);
|
return qualityInspectMapper.updateById(qualityInspect);
|
}
|
|
@Override
|
public IPage<QualityInspect> qualityInspectListPage(Page page, QualityInspect qualityInspect) {
|
return qualityInspectMapper.qualityInspectListPage(page,qualityInspect);
|
}
|
|
@Override
|
public void qualityInspectExport(HttpServletResponse response, QualityInspect qualityInspect) {
|
List<QualityInspect> qualityInspects =qualityInspectMapper.qualityInspectExport(qualityInspect);
|
ExcelUtil<QualityInspect> util = new ExcelUtil<QualityInspect>(QualityInspect.class);
|
switch (qualityInspect.getInspectType()){
|
case 0:
|
util.exportExcel(response, qualityInspects, "原材料检验导出");
|
break;
|
case 1:
|
util.exportExcel(response, qualityInspects, "过程检验导出");
|
break;
|
case 2:
|
util.exportExcel(response, qualityInspects, "出厂检验导出");
|
break;
|
}
|
|
}
|
|
|
}
|
