From 054381d20e23e30cfb3fe962e00be6a3ded3ee2b Mon Sep 17 00:00:00 2001
From: gongchunyi <deslre0381@gmail.com>
Date: 星期五, 15 五月 2026 15:51:03 +0800
Subject: [PATCH] feat: 质检数量区分合格/不合格数量
---
src/main/java/com/ruoyi/quality/service/impl/QualityInspectServiceImpl.java | 547 +++++++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 498 insertions(+), 49 deletions(-)
diff --git a/src/main/java/com/ruoyi/quality/service/impl/QualityInspectServiceImpl.java b/src/main/java/com/ruoyi/quality/service/impl/QualityInspectServiceImpl.java
index 22055fc..f9a1d42 100644
--- a/src/main/java/com/ruoyi/quality/service/impl/QualityInspectServiceImpl.java
+++ b/src/main/java/com/ruoyi/quality/service/impl/QualityInspectServiceImpl.java
@@ -2,102 +2,441 @@
import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+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.ruoyi.common.exception.base.BaseException;
+import com.deepoove.poi.XWPFTemplate;
+import com.deepoove.poi.config.Configure;
+import com.ruoyi.common.enums.StockInQualifiedRecordTypeEnum;
+import com.ruoyi.common.utils.HackLoopTableRenderPolicy;
+import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.poi.ExcelUtil;
+import com.ruoyi.approve.pojo.ApproveProcess;
+import com.ruoyi.approve.service.IApproveProcessService;
+import com.ruoyi.approve.vo.ApproveProcessVO;
+import com.ruoyi.common.enums.ApproveTypeEnum;
+import com.ruoyi.procurementrecord.service.ProcurementRecordService;
+import com.ruoyi.procurementrecord.utils.StockUtils;
+import com.ruoyi.quality.dto.QualityInspectDto;
import com.ruoyi.quality.mapper.QualityInspectMapper;
-import com.ruoyi.quality.mapper.QualityInspectParamMapper;
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.QualityTestStandard;
+import com.ruoyi.quality.pojo.QualityUnqualified;
import com.ruoyi.quality.service.IQualityInspectParamService;
import com.ruoyi.quality.service.IQualityInspectService;
-import com.ruoyi.staff.mapper.StaffJoinLeaveRecordMapper;
-import com.ruoyi.staff.mapper.StaffOnJobMapper;
-import com.ruoyi.staff.pojo.StaffJoinLeaveRecord;
-import com.ruoyi.staff.pojo.StaffOnJob;
-import com.ruoyi.staff.service.IStaffOnJobService;
+import com.ruoyi.purchase.mapper.PurchaseLedgerMapper;
+import com.ruoyi.purchase.pojo.PurchaseLedger;
+import com.ruoyi.sales.mapper.SalesLedgerProductMapper;
+import com.ruoyi.sales.pojo.SalesLedgerProduct;
+import com.ruoyi.framework.security.LoginUser;
import lombok.AllArgsConstructor;
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.math.RoundingMode;
+import java.net.URLEncoder;
+import java.util.HashMap;
import java.util.List;
+import java.util.Objects;
import java.util.stream.Collectors;
@AllArgsConstructor
@Service
@Transactional(rollbackFor = Exception.class)
-public class QualityInspectServiceImpl extends ServiceImpl<QualityInspectMapper, QualityInspect> implements IQualityInspectService {
+public class QualityInspectServiceImpl extends ServiceImpl<QualityInspectMapper, QualityInspect> implements IQualityInspectService {
+ private final StockUtils stockUtils;
private QualityInspectMapper qualityInspectMapper;
private IQualityInspectParamService qualityInspectParamService;
private QualityTestStandardMapper qualityTestStandardMapper;
+ private QualityUnqualifiedMapper qualityUnqualifiedMapper;
+
+ private SalesLedgerProductMapper salesLedgerProductMapper;
+
+ private PurchaseLedgerMapper purchaseLedgerMapper;
+
+ private ProcurementRecordService procurementRecordService;
+ private IApproveProcessService approveProcessService;
+
@Override
- public int add(QualityInspect qualityInspect) {
- String[] ignoreProperties = {"id"};//鎺掗櫎id灞炴��
- //鏍规嵁浜у搧id鏌ヨ鎸囨爣缁存姢瀵瑰簲鏂板妫�楠屽弬鏁�
- List<QualityTestStandard> qualityTestStandards = qualityTestStandardMapper.selectList(Wrappers.<QualityTestStandard>lambdaQuery()
- .eq(QualityTestStandard::getProductId, qualityInspect.getProductId()));
- if (qualityTestStandards.size()>0){
- qualityInspectMapper.insert(qualityInspect);
- List<QualityInspectParam> qualityInspectParams = qualityTestStandards.stream().map(qualityTestStandard -> {
- QualityInspectParam qualityInspectParam = new QualityInspectParam();
- BeanUtils.copyProperties(qualityTestStandard, qualityInspectParam,ignoreProperties);
- qualityInspectParam.setInspectId(qualityInspect.getId());
- return qualityInspectParam;
- }).collect(Collectors.toList());
- qualityInspectParamService.saveBatch(qualityInspectParams);
- }else{
- throw new BaseException("璇ヤ骇鍝佹病鏈夌淮鎶ゆ楠屾寚鏍�,璇锋鏌�!!!!!!!!");
+ public int add(QualityInspectDto qualityInspectDto) {
+ QualityInspect qualityInspect = new QualityInspect();
+ BeanUtils.copyProperties(qualityInspectDto, qualityInspect);
+ qualityInspect.setInspectState(0);//榛樿鏈彁浜�
+ ensureQualifiedSplitDefaults(qualityInspect);
+ // 鍓嶇鑻ュ凡浼犲悎鏍�/涓嶅悎鏍兼暟閲忥紝defaults 涓嶄細鍐� pass_rate锛岃繖閲岃ˉ绠楀垪琛ㄥ睍绀虹敤鍚堟牸鐜�
+ refreshPassRateFromQuantities(qualityInspect);
+ qualityInspectMapper.insert(qualityInspect);
+ for (QualityInspectParam qualityInspectParam : qualityInspectDto.getQualityInspectParams()) {
+ qualityInspectParam.setInspectId(qualityInspect.getId());
}
+ qualityInspectParamService.saveBatch(qualityInspectDto.getQualityInspectParams());
return 0;
}
@Override
- public int updateQualityInspect(QualityInspect qualityInspect) {
- String[] ignoreProperties = {"id"};//鎺掗櫎id灞炴��
- //鍏堝垹闄ゆ墍鏈夋楠屽弬鏁板啀鏂板
- qualityInspectParamService.remove(Wrappers.<QualityInspectParam>lambdaQuery()
- .eq(QualityInspectParam::getInspectId,qualityInspect.getId()));
- //鏍规嵁浜у搧id鏌ヨ鎸囨爣缁存姢瀵瑰簲鏂板妫�楠屽弬鏁�
- List<QualityTestStandard> qualityTestStandards = qualityTestStandardMapper.selectList(Wrappers.<QualityTestStandard>lambdaQuery()
- .eq(QualityTestStandard::getProductId, qualityInspect.getProductId()));
- if (qualityTestStandards.size()>0){
- List<QualityInspectParam> qualityInspectParams = qualityTestStandards.stream().map(qualityTestStandard -> {
- QualityInspectParam qualityInspectParam = new QualityInspectParam();
- BeanUtils.copyProperties(qualityTestStandard, qualityInspectParam,ignoreProperties);
- qualityInspectParam.setInspectId(qualityInspect.getId());
- return qualityInspectParam;
- }).collect(Collectors.toList());
- qualityInspectParamService.saveBatch(qualityInspectParams);
- }else{
- throw new BaseException("璇ヤ骇鍝佹病鏈夌淮鎶ゆ楠屾寚鏍�,璇锋鏌�!!!!!!!!");
+ public QualityInspectDto getDetailById(Integer id) {
+ QualityInspect qualityInspect = qualityInspectMapper.selectById(id);
+ 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) {
+ QualityInspect qualityInspect = qualityInspectMapper.selectById(inspect.getId());
+ if (qualityInspect == null) {
+ throw new RuntimeException("璐ㄦ鍗曚笉瀛樺湪");
}
- return qualityInspectMapper.updateById(qualityInspect);
+ if (Objects.equals(qualityInspect.getInspectState(), 1)) {
+ throw new RuntimeException("璇ヨ川妫�鍗曞凡鎻愪氦锛屼笉鑳介噸澶嶆彁浜�");
+ }
+ if (inspect != null) {
+ if (inspect.getQualifiedQuantity() != null) {
+ qualityInspect.setQualifiedQuantity(inspect.getQualifiedQuantity());
+ }
+ if (inspect.getUnqualifiedQuantity() != null) {
+ qualityInspect.setUnqualifiedQuantity(inspect.getUnqualifiedQuantity());
+ }
+ }
+ validateAndCalculateQuantities(qualityInspect);
+
+ BigDecimal qualifiedQty = qualityInspect.getQualifiedQuantity();
+ BigDecimal unqualifiedQty = qualityInspect.getUnqualifiedQuantity();
+
+ if (unqualifiedQty.compareTo(BigDecimal.ZERO) > 0) {
+ QualityUnqualified qualityUnqualified = new QualityUnqualified();
+ BeanUtils.copyProperties(qualityInspect, qualityUnqualified);
+ qualityUnqualified.setId(null);
+ qualityUnqualified.setQuantity(unqualifiedQty);
+ qualityUnqualified.setInspectState(0);
+ qualityUnqualified.setDefectivePhenomena(buildDefectivePhenomena(qualityInspect));
+ qualityUnqualified.setInspectId(qualityInspect.getId());
+ qualityUnqualifiedMapper.insert(qualityUnqualified);
+ }
+
+ if (qualifiedQty.compareTo(BigDecimal.ZERO) > 0) {
+ if (Objects.equals(qualityInspect.getInspectType(), 0)) {
+ Long ledgerId = qualityInspect.getPurchaseLedgerId();
+ PurchaseLedger purchaseLedger = ledgerId == null ? null : purchaseLedgerMapper.selectById(ledgerId);
+ if (purchaseLedger != null) {
+ submitQualifiedInboundApprove(qualityInspect);
+ } else {
+ // 鎵嬪姩鏂板鐨勫師鏉愭枡妫�楠岋細鏃犻噰璐彴璐︼紝涓嶈蛋閲囪喘鍏ュ簱瀹℃壒锛岀洿鎺ュ叆鍚堟牸搴撳瓨锛堜笌杩囩▼/鍑哄巶妫�楠屼竴鑷达級
+ stockUtils.addStock(
+ null,
+ null,
+ qualityInspect.getProductModelId(),
+ qualifiedQty,
+ StockInQualifiedRecordTypeEnum.QUALITYINSPECT_STOCK_IN.getCode(),
+ qualityInspect.getId()
+ );
+ syncQualifiedInboundToPurchaseProducts(qualityInspect, qualifiedQty);
+ }
+ } else {
+ stockUtils.addStock(
+ qualityInspect.getPurchaseLedgerId() == null ? null : qualityInspect.getPurchaseLedgerId(),
+ null,
+ qualityInspect.getProductModelId(),
+ qualifiedQty,
+ StockInQualifiedRecordTypeEnum.QUALITYINSPECT_STOCK_IN.getCode(),
+ qualityInspect.getId()
+ );
+ syncQualifiedInboundToPurchaseProducts(qualityInspect, qualifiedQty);
+ }
+ }
+
+ qualityInspect.setCheckResult(resolveCheckResult(qualifiedQty, unqualifiedQty));
+ qualityInspect.setInspectState(1);
+ int updated = qualityInspectMapper.updateById(qualityInspect);
+ refreshPurchaseLedgerStockStatusByInspect(qualityInspect.getPurchaseLedgerId());
+ return updated;
+ }
+
+ private void validateAndCalculateQuantities(QualityInspect qualityInspect) {
+ if (qualityInspect.getQualifiedQuantity() == null || qualityInspect.getUnqualifiedQuantity() == null) {
+ throw new RuntimeException("璇峰～鍐欏悎鏍兼暟閲忓拰涓嶅悎鏍兼暟閲�");
+ }
+ if (qualityInspect.getQualifiedQuantity().compareTo(BigDecimal.ZERO) < 0
+ || qualityInspect.getUnqualifiedQuantity().compareTo(BigDecimal.ZERO) < 0) {
+ throw new RuntimeException("鍚堟牸鏁伴噺鍜屼笉鍚堟牸鏁伴噺涓嶈兘涓鸿礋鏁�");
+ }
+ if (qualityInspect.getQuantity() == null) {
+ throw new RuntimeException("璐ㄦ鍗曟�绘暟閲忓紓甯�");
+ }
+ BigDecimal total = qualityInspect.getQualifiedQuantity().add(qualityInspect.getUnqualifiedQuantity());
+ BigDecimal qtyScaled = qualityInspect.getQuantity().setScale(4, RoundingMode.HALF_UP);
+ BigDecimal sumScaled = total.setScale(4, RoundingMode.HALF_UP);
+ if (sumScaled.compareTo(qtyScaled) > 0) {
+ throw new RuntimeException("鍚堟牸鏁伴噺涓庝笉鍚堟牸鏁伴噺涔嬪拰涓嶈兘瓒呰繃鎬绘暟閲�");
+ }
+ qualityInspect.setPassRate(calculatePassRate(qualityInspect.getQualifiedQuantity(), qualityInspect.getQuantity()));
+ }
+
+ /**
+ * 鏂板鏃惰嫢鏈媶鍒嗗悎鏍�/涓嶅悎鏍硷紝榛樿鍏ㄩ儴涓哄緟妫�鍚堟牸鏁�
+ */
+ private void ensureQualifiedSplitDefaults(QualityInspect q) {
+ if (q.getQuantity() == null) {
+ return;
+ }
+ if (q.getQualifiedQuantity() == null && q.getUnqualifiedQuantity() == null) {
+ q.setQualifiedQuantity(q.getQuantity());
+ q.setUnqualifiedQuantity(BigDecimal.ZERO);
+ q.setPassRate(calculatePassRate(q.getQualifiedQuantity(), q.getQuantity()));
+ if (q.getCheckResult() == null || q.getCheckResult().isEmpty()) {
+ q.setCheckResult("鍚堟牸");
+ }
+ }
+ }
+
+ private BigDecimal calculatePassRate(BigDecimal qualifiedQty, BigDecimal totalQty) {
+ if (totalQty == null || totalQty.compareTo(BigDecimal.ZERO) <= 0 || qualifiedQty == null) {
+ return BigDecimal.ZERO;
+ }
+ return qualifiedQty.multiply(BigDecimal.valueOf(100))
+ .divide(totalQty, 2, RoundingMode.HALF_UP);
+ }
+
+ private void refreshPassRateFromQuantities(QualityInspect q) {
+ if (q.getQuantity() == null || q.getQualifiedQuantity() == null) {
+ return;
+ }
+ q.setPassRate(calculatePassRate(q.getQualifiedQuantity(), q.getQuantity()));
+ }
+
+ private String resolveCheckResult(BigDecimal qualifiedQty, BigDecimal unqualifiedQty) {
+ if (unqualifiedQty.compareTo(BigDecimal.ZERO) <= 0) {
+ return "鍚堟牸";
+ }
+ if (qualifiedQty.compareTo(BigDecimal.ZERO) <= 0) {
+ return "涓嶅悎鏍�";
+ }
+ return "閮ㄥ垎鍚堟牸";
+ }
+
+ private String buildDefectivePhenomena(QualityInspect qualityInspect) {
+ if (ObjectUtils.isNotEmpty(qualityInspect.getDefectivePhenomena())) {
+ return qualityInspect.getDefectivePhenomena();
+ }
+ List<QualityInspectParam> inspectParams = qualityInspectParamService.list(
+ Wrappers.<QualityInspectParam>lambdaQuery().eq(QualityInspectParam::getInspectId, qualityInspect.getId()));
+ if (inspectParams.isEmpty()) {
+ return "璐ㄦ涓嶅悎鏍兼暟閲忥細" + qualityInspect.getUnqualifiedQuantity();
+ }
+ String text = inspectParams.stream().map(QualityInspectParam::getParameterItem).collect(Collectors.joining(","));
+ return text + "绛夋寚鏍囨楠屼笉鍚堟牸锛屼笉鍚堟牸鏁伴噺锛�" + qualityInspect.getUnqualifiedQuantity();
+ }
+
+ private void submitQualifiedInboundApprove(QualityInspect qualityInspect) {
+ PurchaseLedger purchaseLedger = purchaseLedgerMapper.selectById(qualityInspect.getPurchaseLedgerId());
+ if (purchaseLedger == null) {
+ throw new RuntimeException("鎻愪氦澶辫触锛岄噰璐彴璐︿笉瀛樺湪");
+ }
+ String approveUserIds = ObjectUtils.isNotEmpty(qualityInspect.getApproveUserIds())
+ ? qualityInspect.getApproveUserIds()
+ : purchaseLedger.getApproveUserIds();
+ if (ObjectUtils.isEmpty(approveUserIds)) {
+ throw new RuntimeException("鎻愪氦澶辫触锛岃鍏堢淮鎶よ川妫�鍗曞鎵逛汉锛堟垨閲囪喘鍙拌处瀹℃壒浜猴級");
+ }
+
+ String approveReason = "鍘熸潗鏂欒川妫�鍏ュ簱瀹℃壒:" + purchaseLedger.getPurchaseContractNumber();
+ String approveRemark = "qualityQualifiedInbound:" + qualityInspect.getId() + ":" + purchaseLedger.getId();
+ ApproveProcess exist = approveProcessService.getOne(new LambdaQueryWrapper<ApproveProcess>()
+ .eq(ApproveProcess::getApproveType, ApproveTypeEnum.STOCK_IN.getCode())
+ .eq(ApproveProcess::getApproveRemark, approveRemark)
+ .eq(ApproveProcess::getApproveDelete, 0)
+ .orderByDesc(ApproveProcess::getCreateTime)
+ .last("limit 1"));
+ if (exist != null && !Objects.equals(exist.getApproveStatus(), 3)) {
+ throw new RuntimeException("鎻愪氦澶辫触锛岃璐ㄦ鍗曞凡鍙戣捣鍏ュ簱瀹℃壒锛屽鎵瑰畬鎴愬墠涓嶈兘閲嶅鎻愪氦");
+ }
+
+ LoginUser loginUser = SecurityUtils.getLoginUser();
+ ApproveProcessVO approveProcessVO = new ApproveProcessVO();
+ approveProcessVO.setApproveType(ApproveTypeEnum.STOCK_IN.getCode());
+ approveProcessVO.setApproveDeptId(loginUser.getCurrentDeptId());
+ approveProcessVO.setApproveReason(approveReason);
+ approveProcessVO.setApproveRemark(approveRemark);
+ approveProcessVO.setApproveUserIds(approveUserIds);
+ approveProcessVO.setApproveUser(loginUser.getUserId());
+ approveProcessVO.setApproveTime(java.time.LocalDate.now().toString());
+ try {
+ approveProcessService.addApprove(approveProcessVO);
+ } catch (Exception e) {
+ throw new RuntimeException("鎻愪氦澶辫触锛屽叆搴撳鎵瑰彂璧峰紓甯�:" + e.getMessage());
+ }
+ qualityInspect.setApprovalStatus(2);
+ qualityInspect.setApproveUserIds(approveUserIds);
+ qualityInspectMapper.updateById(qualityInspect);
}
@Override
- public IPage<QualityInspect> qualityInspectListPage(Page page, QualityInspect qualityInspect) {
- return qualityInspectMapper.qualityInspectListPage(page,qualityInspect);
+ public void executeQualifiedInboundApproval(Integer inspectId) {
+ if (inspectId == null) {
+ throw new RuntimeException("瀹℃壒澶辫触锛岃川妫�鍗旾D涓嶈兘涓虹┖");
+ }
+ QualityInspect qualityInspect = qualityInspectMapper.selectById(inspectId);
+ if (qualityInspect == null) {
+ throw new RuntimeException("瀹℃壒澶辫触锛岃川妫�鍗曚笉瀛樺湪");
+ }
+ if (!Objects.equals(qualityInspect.getInspectType(), 0)) {
+ throw new RuntimeException("瀹℃壒澶辫触锛屼粎鍘熸潗鏂欐楠屾敮鎸佸叆搴撳鎵�");
+ }
+ if (!Objects.equals(qualityInspect.getInspectState(), 1)) {
+ throw new RuntimeException("瀹℃壒澶辫触锛屽綋鍓嶈川妫�鍗曠姸鎬佷笉鍏佽鍏ュ簱");
+ }
+ BigDecimal qualifiedQty = qualityInspect.getQualifiedQuantity();
+ if (qualifiedQty == null || qualifiedQty.compareTo(BigDecimal.ZERO) <= 0) {
+ throw new RuntimeException("瀹℃壒澶辫触锛屾棤鍚堟牸鏁伴噺鍙叆搴�");
+ }
+ stockUtils.addStock(
+ qualityInspect.getPurchaseLedgerId() == null ? null : qualityInspect.getPurchaseLedgerId().longValue(),
+ null,
+ qualityInspect.getProductModelId(),
+ qualifiedQty,
+ StockInQualifiedRecordTypeEnum.QUALITYINSPECT_STOCK_IN.getCode(),
+ qualityInspect.getId()
+ );
+ syncQualifiedInboundToPurchaseProducts(qualityInspect, qualifiedQty);
+ refreshPurchaseLedgerStockStatusByInspect(qualityInspect.getPurchaseLedgerId());
+ qualityInspect.setApprovalStatus(3);
+ qualityInspectMapper.updateById(qualityInspect);
+ }
+
+ @Override
+ public void markQualifiedInboundApprovalStatus(Integer inspectId, Integer approvalStatus) {
+ if (inspectId == null || approvalStatus == null) {
+ return;
+ }
+ QualityInspect qualityInspect = qualityInspectMapper.selectById(inspectId);
+ if (qualityInspect == null) {
+ return;
+ }
+ qualityInspect.setApprovalStatus(approvalStatus);
+ 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) {
+ QualityInspect existing = qualityInspectMapper.selectById(qualityInspectDto.getId());
+ if (existing == null) {
+ throw new RuntimeException("璐ㄦ鍗曚笉瀛樺湪");
+ }
+ if (Objects.equals(existing.getInspectState(), 1)) {
+ throw new RuntimeException("宸叉彁浜ょ殑鏁版嵁涓嶅厑璁镐慨鏀�");
+ }
+ 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);
+ qualityInspect.setQuantity(existing.getQuantity());
+
+ BigDecimal qf = qualityInspect.getQualifiedQuantity() != null ? qualityInspect.getQualifiedQuantity() : existing.getQualifiedQuantity();
+ BigDecimal uqf = qualityInspect.getUnqualifiedQuantity() != null ? qualityInspect.getUnqualifiedQuantity() : existing.getUnqualifiedQuantity();
+ if (qf == null || uqf == null) {
+ BigDecimal qty = existing.getQuantity() != null ? existing.getQuantity() : BigDecimal.ZERO;
+ if ("涓嶅悎鏍�".equals(existing.getCheckResult())) {
+ qf = BigDecimal.ZERO;
+ uqf = qty;
+ } else {
+ qf = qty;
+ uqf = BigDecimal.ZERO;
+ }
+ }
+ qualityInspect.setQualifiedQuantity(qf);
+ qualityInspect.setUnqualifiedQuantity(uqf);
+ validateAndCalculateQuantities(qualityInspect);
+ qualityInspect.setCheckResult(resolveCheckResult(qf, uqf));
+ 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);
+ List<QualityInspect> qualityInspects = qualityInspectMapper.qualityInspectExport(qualityInspect);
ExcelUtil<QualityInspect> util = new ExcelUtil<QualityInspect>(QualityInspect.class);
- switch (qualityInspect.getInspectType()){
+ switch (qualityInspect.getInspectType()) {
case 0:
util.exportExcel(response, qualityInspects, "鍘熸潗鏂欐楠屽鍑�");
break;
- case 1:
+ case 1:
util.exportExcel(response, qualityInspects, "杩囩▼妫�楠屽鍑�");
break;
case 2:
@@ -106,4 +445,114 @@
}
}
+
+ private void refreshPurchaseLedgerStockStatusByInspect(Long purchaseLedgerId) {
+ if (purchaseLedgerId == null) {
+ return;
+ }
+ List<SalesLedgerProduct> products = salesLedgerProductMapper.selectList(new LambdaQueryWrapper<SalesLedgerProduct>()
+ .eq(SalesLedgerProduct::getSalesLedgerId, purchaseLedgerId)
+ .eq(SalesLedgerProduct::getType, 2));
+ if (products == null || products.isEmpty()) {
+ return;
+ }
+ boolean allInbound = true;
+ boolean anyInbound = false;
+ for (SalesLedgerProduct product : products) {
+ BigDecimal orderQty = product.getQuantity() == null ? BigDecimal.ZERO : product.getQuantity();
+ BigDecimal totalInboundQty = product.getStockedQuantity() == null ? BigDecimal.ZERO : product.getStockedQuantity();
+ if (totalInboundQty.compareTo(BigDecimal.ZERO) > 0) {
+ anyInbound = true;
+ }
+ if (totalInboundQty.compareTo(orderQty) < 0) {
+ allInbound = false;
+ }
+ }
+ PurchaseLedger purchaseLedger = purchaseLedgerMapper.selectById(purchaseLedgerId);
+ if (purchaseLedger == null) {
+ return;
+ }
+ int targetStockStatus = allInbound ? 2 : (anyInbound ? 1 : 0);
+ if (!Objects.equals(purchaseLedger.getStockStatus(), targetStockStatus)) {
+ purchaseLedger.setStockStatus(targetStockStatus);
+ purchaseLedgerMapper.updateById(purchaseLedger);
+ }
+ }
+
+ private void syncQualifiedInboundToPurchaseProducts(QualityInspect qualityInspect, BigDecimal inboundQty) {
+ if (qualityInspect == null) {
+ return;
+ }
+ if (!Objects.equals(qualityInspect.getInspectType(), 0) || qualityInspect.getPurchaseLedgerId() == null) {
+ return;
+ }
+ if (qualityInspect.getProductModelId() == null || inboundQty == null) {
+ return;
+ }
+ if (inboundQty.compareTo(BigDecimal.ZERO) <= 0) {
+ return;
+ }
+
+ List<SalesLedgerProduct> lines = salesLedgerProductMapper.selectList(new LambdaQueryWrapper<SalesLedgerProduct>()
+ .eq(SalesLedgerProduct::getSalesLedgerId, qualityInspect.getPurchaseLedgerId())
+ .eq(SalesLedgerProduct::getType, 2)
+ .eq(SalesLedgerProduct::getProductModelId, qualityInspect.getProductModelId())
+ .eq(SalesLedgerProduct::getIsChecked, true)
+ .orderByAsc(SalesLedgerProduct::getId));
+ if (lines == null || lines.isEmpty()) {
+ return;
+ }
+
+ BigDecimal remaining = inboundQty;
+ SalesLedgerProduct fallbackLine = null;
+ for (SalesLedgerProduct line : lines) {
+ if (remaining.compareTo(BigDecimal.ZERO) <= 0) {
+ break;
+ }
+ BigDecimal orderQty = line.getQuantity() == null ? BigDecimal.ZERO : line.getQuantity();
+ BigDecimal stocked = line.getStockedQuantity() == null ? BigDecimal.ZERO : line.getStockedQuantity();
+ BigDecimal canFill = orderQty.subtract(stocked);
+ if (canFill.compareTo(BigDecimal.ZERO) <= 0) {
+ fallbackLine = line;
+ continue;
+ }
+ BigDecimal add = canFill.min(remaining);
+ BigDecimal newStocked = stocked.add(add);
+ int status;
+ if (newStocked.compareTo(BigDecimal.ZERO) <= 0) {
+ status = 0;
+ } else if (orderQty.compareTo(BigDecimal.ZERO) > 0 && newStocked.compareTo(orderQty) < 0) {
+ status = 1;
+ } else {
+ status = 2;
+ }
+ line.setStockedQuantity(newStocked);
+ line.setProductStockStatus(status);
+ line.fillRemainingQuantity();
+ salesLedgerProductMapper.updateById(line);
+ remaining = remaining.subtract(add);
+ fallbackLine = line;
+ }
+
+ // 鍏佽澶氬叆搴擄細鑻ヤ粛鏈夊墿浣欙紝绱鍒版渶鍚庝竴琛岋紝纭繚 remaining_shipped_quantity 鑳藉悓姝ュ闀�
+ if (remaining.compareTo(BigDecimal.ZERO) > 0 && fallbackLine != null) {
+ BigDecimal orderQty = fallbackLine.getQuantity() == null ? BigDecimal.ZERO : fallbackLine.getQuantity();
+ BigDecimal stocked = fallbackLine.getStockedQuantity() == null ? BigDecimal.ZERO : fallbackLine.getStockedQuantity();
+ BigDecimal newStocked = stocked.add(remaining);
+ int status;
+ if (newStocked.compareTo(BigDecimal.ZERO) <= 0) {
+ status = 0;
+ } else if (orderQty.compareTo(BigDecimal.ZERO) > 0 && newStocked.compareTo(orderQty) < 0) {
+ status = 1;
+ } else {
+ status = 2;
+ }
+ fallbackLine.setStockedQuantity(newStocked);
+ fallbackLine.setProductStockStatus(status);
+ fallbackLine.fillRemainingQuantity();
+ salesLedgerProductMapper.updateById(fallbackLine);
+ }
+ }
+
+
}
--
Gitblit v1.9.3