package com.ruoyi.inspect.service.impl; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONUtil; import com.alibaba.excel.EasyExcel; import com.alibaba.excel.ExcelWriter; import com.alibaba.excel.write.metadata.WriteSheet; import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.basic.dto.InventoryDetailDTO; import com.ruoyi.basic.dto.StandardTreeTemplateBindingVo; import com.ruoyi.basic.dto.TemplateInspectionItemDto; import com.ruoyi.basic.mapper.IfsInventoryQuantityMapper; import com.ruoyi.basic.mapper.StandardProductListMapper; import com.ruoyi.basic.mapper.StructureItemParameterMapper; import com.ruoyi.basic.pojo.IfsInventoryQuantity; import com.ruoyi.basic.pojo.StandardProductList; import com.ruoyi.basic.pojo.StandardMethod; import com.ruoyi.basic.pojo.StructureItemParameter; import com.ruoyi.basic.pojo.StructureTestObject; import com.ruoyi.basic.pojo.StandardTree; import com.ruoyi.basic.pojo.StandardTemplate; import com.ruoyi.basic.service.StandardTemplateService; import com.ruoyi.basic.service.StandardMethodService; import com.ruoyi.basic.service.StandardTreeService; import com.ruoyi.basic.utils.StandardTreePathParser; import com.ruoyi.common.constant.InsOrderTypeConstants; import com.ruoyi.common.core.domain.Result; import com.ruoyi.common.core.domain.entity.User; import com.ruoyi.common.enums.OrderType; import com.ruoyi.common.numgen.NumberGenerator; import com.ruoyi.common.utils.QueryWrappers; import com.ruoyi.common.utils.SecurityUtils; import com.ruoyi.common.utils.api.IfsApiUtils; import com.ruoyi.framework.exception.ErrorException; import com.ruoyi.inspect.dto.*; import com.ruoyi.inspect.mapper.*; import com.ruoyi.inspect.pojo.*; import com.ruoyi.inspect.service.InsOrderService; import com.ruoyi.inspect.service.InsOrderStateService; import com.ruoyi.inspect.service.InsProductService; import com.ruoyi.inspect.service.InsSampleService; import com.ruoyi.inspect.vo.IfsOrderVO; import com.ruoyi.inspect.vo.InsOrderPrintingVo; import com.ruoyi.inspect.vo.OrderTemplateSummaryVo; import com.ruoyi.inspect.vo.TemplateConditionVo; import com.ruoyi.system.mapper.UserMapper; import lombok.AllArgsConstructor; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Isolation; import org.springframework.transaction.annotation.Transactional; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.math.BigDecimal; import java.net.URLEncoder; import java.text.SimpleDateFormat; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.Month; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.concurrent.atomic.AtomicInteger; import java.util.stream.Collectors; /** * @author gaoaoy * @description 针对表【ins_order(检验下单)】的数据库操作Service实现 * @createDate 2024-03-12 16:17:55 */ @Service @AllArgsConstructor public class InsOrderServiceImpl extends ServiceImpl implements InsOrderService { private static final String DIRECT_TEMPLATE_LABORATORY = "新聚"; private InsOrderMapper insOrderMapper; private InsSampleService insSampleService; private InsSampleMapper insSampleMapper; private InsProductService insProductService; private InsProductMapper insProductMapper; private InsSampleUserMapper insSampleUserMapper; private InsOrderStateService insOrderStateService; private UserMapper userMapper; private IfsInventoryQuantityMapper ifsInventoryQuantityMapper; private final NumberGenerator numberGenerator; private InsReportMapper insReportMapper; private InsUnqualifiedRetestProductMapper insUnqualifiedRetestProductMapper; private IfsApiUtils ifsApiUtils; private SpotCheckQuarterItemMapper spotCheckQuarterItemMapper; private StandardProductListMapper standardProductListMapper; private StructureItemParameterMapper structureItemParameterMapper; private StandardTreeService standardTreeService; private StandardMethodService standardMethodService; private StandardTemplateService standardTemplateService; private InsOrderStandardTemplateMapper insOrderStandardTemplateMapper; private InsOrderTemplateDeviceMapper insOrderTemplateDeviceMapper; //获取检验下单数据 @Override public IPage selectInsOrderParameter(IPage page, SampleOrderDto sampleOrderDto) { String laboratory = null; // 判断是否是全部 String isOrderAll = null; if (sampleOrderDto.getState() != null && sampleOrderDto.getState() == -2) { isOrderAll = "1"; sampleOrderDto.setState(null); } return insOrderMapper.selectInsOrderPage(page, QueryWrappers.queryWrappers(sampleOrderDto), laboratory, isOrderAll); } /** * 分配检验人 * * @return */ @Override @Transactional(rollbackFor = Exception.class) public int upInsOrder(Integer orderId, Integer sampleId, String appointed, Integer userId, String sonLaboratory) { InsOrder insOrder = new InsOrder(); insOrder.setId(orderId); insOrder.setAppointed(StringUtils.isNotEmpty(appointed) ? LocalDate.parse(appointed) : null); insOrder.setSendTime(LocalDateTime.now()); insOrderMapper.updateById(insOrder); List insSamples = insSampleMapper.selectList(Wrappers.lambdaQuery().eq(InsSample::getInsOrderId, orderId)); List ids = insSamples.stream().map(InsSample::getId).collect(Collectors.toList()); List insProducts = ids.isEmpty() ? Collections.emptyList() : insProductMapper.selectList(Wrappers.lambdaQuery() .in(InsProduct::getInsSampleId, ids) .eq(InsProduct::getState, 1) .select(InsProduct::getSonLaboratory).groupBy(InsProduct::getSonLaboratory)); InsOrder order = insOrderMapper.selectById(orderId); boolean directTemplateOrder = isDirectTemplateOrder(order, insSamples); Set taskLaboratories = directTemplateOrder ? Collections.singleton(DIRECT_TEMPLATE_LABORATORY) : insProducts.stream() .map(InsProduct::getSonLaboratory) .filter(StringUtils::isNotBlank) .collect(Collectors.toCollection(LinkedHashSet::new)); if (!directTemplateOrder && taskLaboratories.size() != insProducts.size()) { throw new ErrorException("该检验单有未维护实验室的检验项目"); } // 批量添加检验任务状态表 List insOrderStateList = taskLaboratories.stream() .filter(laboratory -> insOrderStateService.count(Wrappers.lambdaQuery() .eq(InsOrderState::getInsOrderId, orderId) .eq(InsOrderState::getLaboratory, laboratory)) == 0) .map(laboratory -> { InsOrderState insOrderState = new InsOrderState(); insOrderState.setInsOrderId(orderId); insOrderState.setLaboratory(laboratory); insOrderState.setInsState(0); return insOrderState; }).collect(Collectors.toList()); if (!insOrderStateList.isEmpty()) { insOrderStateService.saveBatch(insOrderStateList); } if (userId != null) { InsSampleUser insSampleUser = new InsSampleUser(); insSampleUser.setState(0); insSampleUser.setUserId(userId); insSampleUser.setInsSampleId(orderId); insSampleUser.setSonLaboratory(directTemplateOrder ? DIRECT_TEMPLATE_LABORATORY : sonLaboratory); insSampleUserMapper.insert(insSampleUser); } // 判断订单有没有绑定抽样计划 if (order.getQuarterItemId() != null) { // 需要添加下发时间到抽样时间, 取样人员就是检测人 SpotCheckQuarterItem spotCheckQuarterItem = spotCheckQuarterItemMapper.selectById(order.getQuarterItemId()); spotCheckQuarterItem.setSpotCheckTime(order.getSendTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))); User user = userMapper.selectById(userId); spotCheckQuarterItem.setSamplingUser(user.getName()); spotCheckQuarterItemMapper.updateById(spotCheckQuarterItem); } return 1; } private boolean isDirectTemplateOrder(InsOrder order, List samples) { if (order == null || CollectionUtils.isEmpty(samples)) { return false; } Long snapshotCount = insOrderStandardTemplateMapper.selectCount( Wrappers.lambdaQuery() .eq(InsOrderStandardTemplate::getInsOrderId, order.getId())); return snapshotCount > 0 && samples.stream().anyMatch(sample -> sample.getStandardMethodListId() == null && StringUtils.isBlank(sample.getFactory()) && StringUtils.isBlank(sample.getSampleType()) && StringUtils.isBlank(sample.getModel()) && StringUtils.isBlank(order.getFactory()) && StringUtils.isBlank(order.getSampleType())); } public static String getWeek(String dayStr) { SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); try { Date date = sdf.parse(dayStr); Calendar calendar = Calendar.getInstance(); calendar.setTime(date); int dayOfWeek = calendar.get(Calendar.DAY_OF_WEEK); int day = calendar.get(Calendar.DAY_OF_MONTH); return getWeekDay(dayOfWeek); } catch (Exception e) { e.printStackTrace(); } return null; } public static String getWeekDay(int dayOfWeek) { switch (dayOfWeek) { case Calendar.MONDAY: return "周一"; case Calendar.TUESDAY: return "周二"; case Calendar.WEDNESDAY: return "周三"; case Calendar.THURSDAY: return "周四"; case Calendar.FRIDAY: return "周五"; case Calendar.SATURDAY: return "周六"; case Calendar.SUNDAY: return "周日"; default: return "未知"; } } // 如果你使用 Java 8+，也可以用 Stream API 简化代码： public List findMissingItemsWithStream(List standardList, List insList) { Set insIds = insList.stream() .map(InsProduct::getStructureItemParameterId) .collect(Collectors.toSet()); return standardList.stream() .filter(product -> !insIds.contains(product.getStructureItemParameterId())) .collect(Collectors.toList()); } @Override @Transactional(rollbackFor = Exception.class) public int addInsOrder(List list, InsOrder insOrder) { // todo: 下单判断抽样计划的唯一性 if (insOrder.getQuarterItemId() != null) { Long quarterItemCount = insOrderMapper.selectCount(Wrappers.lambdaQuery() .eq(InsOrder::getQuarterItemId, insOrder.getQuarterItemId()) .notIn(InsOrder::getState, -1 ,2 ,3)); if (quarterItemCount > 0) { throw new ErrorException("该抽样计划已被绑定过"); } } insOrder.setState(0); LocalDate appointed = insOrder.getAppointed(); insOrderMapper.insert(insOrder); // 主表 list.forEach(a -> { a.setId(null); a.setInsOrderId(insOrder.getId()); insSampleMapper.insert(a); if (ObjectUtil.isNotEmpty(a.getInsProduct())) { // 判断是否填写待检项数量 if (a.getQuantity() != null) { List ip2 = new ArrayList<>(); for (Integer i = 1; i <= a.getQuantity(); i++) { // 重新拷贝 创建新对象 AtomicInteger atomicInteger = new AtomicInteger(i); List insProducts = a.getInsProduct().stream().map(insProduct -> { insProduct.setRawMaterialTag(String.valueOf(atomicInteger.get())); InsProduct product = new InsProduct(); BeanUtils.copyProperties(insProduct, product); return product; }).collect(Collectors.toList()); ip2.addAll(insProducts); } addInsProductMethod(a.getId(), ip2); } else { addInsProductMethod(a.getId(), a.getInsProduct()); } } // 判断是否有电缆配置 if (ObjectUtil.isNotEmpty(a.getInsulating())) { // 判断是否有辅助线芯 if (ObjectUtil.isNotEmpty(a.getAuxiliaryWireCore())) { if (a.getAuxiliaryWireCore().getInsProduct().stream().filter(insProduct -> insProduct.getState() == 1).count() != a.getInsulating().getInsProduct().stream().filter(insProduct -> insProduct.getState() == 1).count()) { throw new ErrorException("电缆配置辅助线芯检验项数量不统一, 请检查"); } } List ip2 = new ArrayList<>(); for (String s : a.getInsulating().getNum()) { // 重新拷贝 创建新对象 List insProducts = a.getInsulating().getInsProduct().stream().map(insProduct -> { insProduct.setCableTag(s); InsProduct product = new InsProduct(); BeanUtils.copyProperties(insProduct, product); return product; }).collect(Collectors.toList()); ip2.addAll(insProducts); } for (InsProduct product : ip2) { product.setStandardMethodListId(a.getInsulating().getStandardMethodListId()); } addInsProductMethod(a.getId(), ip2); } // 判断是否有辅助线芯 if (ObjectUtil.isNotEmpty(a.getAuxiliaryWireCore())) { List ip2 = new ArrayList<>(); for (String s : a.getAuxiliaryWireCore().getNum()) { // 重新拷贝 创建新对象 List insProducts = a.getAuxiliaryWireCore().getInsProduct().stream().map(insProduct -> { insProduct.setCableTag(s); InsProduct product = new InsProduct(); BeanUtils.copyProperties(insProduct, product); return product; }).collect(Collectors.toList()); ip2.addAll(insProducts); } for (InsProduct product : ip2) { product.setStandardMethodListId(a.getAuxiliaryWireCore().getStandardMethodListId()); } addInsProductMethod(a.getId(), ip2); } // 子样品配置 if (ObjectUtil.isNotEmpty(a.getChildSampleList())) { for (SampleProductDto b : a.getChildSampleList()) { for (int i = 0; i < b.getNum(); i++) { b.setId(null); b.setInsOrderId(insOrder.getId()); b.setParentId(a.getId()); insSampleMapper.insert(b); if (ObjectUtil.isNotEmpty(b.getInsProduct())) { addInsProductMethod(b.getId(), b.getInsProduct()); } } } } }); //原材料下单或外购成品下单 if (Objects.nonNull(insOrder.getTypeSource())&&Objects.nonNull(insOrder.getIfsInventoryId())) { // 委托人就是报检人, 生产单位就是供应商单位 IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(insOrder.getIfsInventoryId()); Integer declareUserId = ifsInventoryQuantity.getDeclareUserId(); User user = userMapper.selectById(declareUserId); if (user == null) { throw new ErrorException("缺少报检人信息"); } // 供应商名称 insOrder.setProduction(ifsInventoryQuantity.getSupplierName()); insOrder.setProductionEn(""); // 委托人名称 insOrder.setPrepareUserId(user.getId()); insOrder.setPrepareUser(user.getName()); insOrder.setPrepareUserEn(user.getNameEn()); insOrder.setPhone(user.getPhone()); insOrder.setState(1); Long count1 = insOrderMapper.selectCount(Wrappers.lambdaQuery() .eq(InsOrder::getIfsInventoryId, insOrder.getIfsInventoryId()) .ne(InsOrder::getState, -1) .eq(InsOrder::getOrderType, InsOrderTypeConstants.ENTER_THE_FACTORY) .ne(InsOrder::getId, insOrder.getId())); // 判断之前是否有进厂检验 if (count1 == 0) { ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper().set(IfsInventoryQuantity::getState, 1) .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId())); } // 判断结束状态修改合格状态 if (ifsInventoryQuantity.getIsFinish().equals(0)) { ifsInventoryQuantityMapper.update(null, Wrappers.lambdaUpdate() .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId()) .set(IfsInventoryQuantity::getInspectStatus, 0)); } // 审核检验单 upInsOrderOfState(insOrder); // 分配检验人 String sonLaboratory = insOrder.getTypeSource().equals(1)?"原材料":"成品实验室"; upInsOrder(insOrder.getId(), null, appointed != null ? appointed.toString() : null, SecurityUtils.getUserId().intValue(), sonLaboratory); //是否为原材料下单 if(insOrder.getTypeSource().equals(1)){ // 根据零件号判断是否是辅材 boolean isRaw = false; StructureTestObject productObject = insOrderMapper.selectProductByPartNo(ifsInventoryQuantity.getPartNo()); // 查询产品 if (productObject != null && StrUtil.isNotBlank(productObject.getObjectType()) && productObject.getObjectType().equals("1")) { isRaw = true; } else { // 查询对象 StructureTestObject testObject = insOrderMapper.selectByPartNo(ifsInventoryQuantity.getPartNo()); if (testObject != null && StrUtil.isNotBlank(testObject.getObjectType()) && testObject.getObjectType().equals("1")) { isRaw = true; } } if (isRaw) { // 获取当前季度的开始时间和结束时间 LocalDateTime now = LocalDateTime.now(); // 获取当前月份 int month = now.getMonthValue(); // 确定当前季度的开始月份 int startMonth = (month - 1) / 3 * 3 + 1; // 构造季度的开始时间 LocalDateTime startOfQuarter = LocalDateTime.of(now.getYear(), Month.of(startMonth), 1, 0, 0); // 计算下一个季度的开始时间 LocalDateTime startOfNextQuarter = startOfQuarter.plusMonths(3); // 计算当前季度的结束时间 LocalDateTime endOfQuarter = startOfNextQuarter.minusSeconds(1); // 根据下单的规格型号判断是否为季度首次出现 Integer count = ifsInventoryQuantityMapper.selectIsFirst(insOrder.getPartDetail(), ifsInventoryQuantity.getSupplierName(), startOfNextQuarter, endOfQuarter); if (count == 0) { ifsInventoryQuantity.setIsFirst(1); ifsInventoryQuantityMapper.update(null, Wrappers.lambdaUpdate() .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId()) .set(IfsInventoryQuantity::getIsFirst, 1)); } } } } return insOrder.getId(); } /** * 新聚标准库直绑模板的下单流程：一个订单、一个样品，检验记录完全由模板标记生成。 */ @Override @Transactional(rollbackFor = Exception.class) public int addNewJuInsOrder(InsPlaceOrderDto dto) { if (dto == null || dto.getInsOrder() == null || dto.getStandardTreeId() == null) { throw new ErrorException("下单信息或标准不能为空"); } String sampleCode = StringUtils.trim(dto.getSampleCode()); if (StringUtils.isBlank(sampleCode) || sampleCode.length() < 2) { throw new ErrorException("样品编号不能为空且不能少于2位"); } StandardTree standard = standardTreeService.getById(dto.getStandardTreeId()); if (standard == null || StringUtils.isBlank(standard.getSample()) || standard.getSampleType() != null || standard.getModel() != null) { throw new ErrorException("请选择标准库二级标准"); } List bindings = standardTreeService.selectTemplateBindings(dto.getStandardTreeId()); if (bindings.isEmpty()) { throw new ErrorException("该标准尚未绑定可用的原始记录模板"); } Map bindingMap = bindings.stream() .collect(Collectors.toMap(StandardTreeTemplateBindingVo::getTemplateId, binding -> binding, (first, ignored) -> first)); List selections = dto.getTemplateList(); if (selections == null) { selections = bindings.stream().map(binding -> { OrderTemplateSelectionDto selection = new OrderTemplateSelectionDto(); selection.setTemplateId(binding.getTemplateId()); selection.setSort(binding.getSort()); return selection; }).collect(Collectors.toList()); } if (selections.isEmpty()) { throw new ErrorException("请至少保留一个原始记录模板"); } Set selectedTemplateIds = new HashSet<>(); for (int index = 0; index < selections.size(); index++) { OrderTemplateSelectionDto selection = selections.get(index); if (selection == null || selection.getTemplateId() == null || !bindingMap.containsKey(selection.getTemplateId())) { throw new ErrorException("所选原始记录模板不属于当前标准"); } if (!selectedTemplateIds.add(selection.getTemplateId())) { throw new ErrorException("原始记录模板不能重复选择"); } if (selection.getSort() == null) { selection.setSort(index); } } selections.sort(Comparator.comparing(OrderTemplateSelectionDto::getSort) .thenComparing(OrderTemplateSelectionDto::getTemplateId)); Map templateSortMap = selections.stream() .collect(Collectors.toMap(OrderTemplateSelectionDto::getTemplateId, OrderTemplateSelectionDto::getSort)); List templateItems = standardTreeService .selectTemplateInspectionItems(dto.getStandardTreeId()).stream() .filter(item -> selectedTemplateIds.contains(item.getTemplateId())) .sorted(Comparator .comparing((TemplateInspectionItemDto item) -> templateSortMap.get(item.getTemplateId())) .thenComparing(item -> item.getTemplateRowIndex() == null ? Integer.MAX_VALUE : item.getTemplateRowIndex())) .collect(Collectors.toList()); StandardMethod standardMethod = standardMethodService.getById(standard.getStandardMethodId()); if (standardMethod == null || StringUtils.isBlank(standardMethod.getCode())) { throw new ErrorException("标准编号不存在"); } String standardCode = standardMethod.getCode().trim(); InsOrder order = dto.getInsOrder(); order.setId(null); order.setState(0); order.setIsExemption(0); order.setFactory(null); order.setLaboratory(standard.getLaboratory()); order.setSampleType(null); order.setSample(standardCode); order.setPrepareUserEn(null); order.setPrepareCode(null); order.setRemarkEn(null); // 新聚订单的环境条件由检验任务填写，避免下单模板或浏览器缓存带入旧值。 order.setTemperature(null); order.setHumidity(null); insOrderMapper.insert(order); InsSample sample = new InsSample(); sample.setInsOrderId(order.getId()); sample.setSampleCode(sampleCode); sample.setFactory(null); sample.setLaboratory(standard.getLaboratory()); sample.setSampleType(null); sample.setSample(standardCode); sample.setModel(null); sample.setQuantity(1); sample.setStandardMethodListId(null); insSampleMapper.insert(sample); int productSort = 0; for (TemplateInspectionItemDto item : templateItems) { InsProduct product = new InsProduct(); product.setInsSampleId(sample.getId()); product.setInspectionItem(item.getInspectionItem()); product.setInspectionItemClass(""); product.setInspectionItemSubclass(""); product.setFactory(null); product.setLaboratory(standard.getLaboratory()); product.setSampleType(null); product.setSample(standardCode); product.setModel(null); product.setTemplateId(item.getTemplateId()); product.setTemplateRowIndex(item.getTemplateRowIndex()); product.setSonLaboratory(DIRECT_TEMPLATE_LABORATORY); product.setState(1); product.setSort(productSort++); insProductMapper.insert(product); } saveTemplateSnapshots(order.getId(), selections); return order.getId(); } private void saveTemplateSnapshots(Integer orderId, List selections) { for (OrderTemplateSelectionDto selection : selections) { StandardTemplate template = standardTemplateService.getById(selection.getTemplateId()); if (template == null) { throw new ErrorException("原始记录模板不存在"); } InsOrderStandardTemplate snapshot = new InsOrderStandardTemplate(); snapshot.setInsOrderId(orderId); snapshot.setTemplateId(template.getId()); snapshot.setName(template.getName()); snapshot.setNumber(template.getNumber()); snapshot.setRemark(template.getRemark()); snapshot.setThing(template.getThing()); snapshot.setSort(selection.getSort()); insOrderStandardTemplateMapper.insert(snapshot); } } /** * 添加检验项 * @param sampleId * @param productList */ private void addInsProductMethod(Integer sampleId, List productList) { for (InsProduct product : productList) { if (product.getState() == 1) { product.setId(null); product.setCreateTime(null); product.setCreateUser(null); product.setUpdateTime(null); product.setUpdateUser(null); product.setInsSampleId(sampleId); if (product.getInspectionItemSubclass() == null) { product.setInspectionItemSubclass(""); } if (StringUtils.isBlank(product.getAsk()) || StringUtils.isBlank(product.getTell())) { throw new ErrorException("有检验项的要求值或要求描述为空, 请先去标准库配置要求值或要求描述"); } if (StringUtils.isBlank(product.getSonLaboratory())) { throw new ErrorException("有检验项的的子实验室为绑定, 请先绑定子实验室"); } insProductMapper.insert(product); } } } @Override public Map getInsOrder(Integer id) { Map map = new HashMap<>(); InsOrder insOrder = insOrderMapper.selectById(id); List list; // 判断是否是进厂报告免检 if (insOrder.getIsExemption().equals(1)) { list = insSampleMapper.selectExemptionByOrderId(id); } else { list = insSampleMapper.selectSampleProductListByOrderId2(id); } Map map1 = insSampleMapper.selectInsOrder(id); List orderSamples = insSampleMapper.selectList( Wrappers.lambdaQuery() .eq(InsSample::getInsOrderId, id) .select(InsSample::getSampleCode) .orderByAsc(InsSample::getId)); List templateList = insOrderStandardTemplateMapper.selectList( Wrappers.lambdaQuery() .eq(InsOrderStandardTemplate::getInsOrderId, id) .orderByAsc(InsOrderStandardTemplate::getSort, InsOrderStandardTemplate::getId)) .stream() .map(template -> { OrderTemplateSummaryVo summary = new OrderTemplateSummaryVo(); summary.setTemplateId(template.getTemplateId()); summary.setName(template.getName()); summary.setNumber(template.getNumber()); summary.setRemark(template.getRemark()); summary.setSort(template.getSort()); return summary; }) .collect(Collectors.toList()); map.put("insOrder", insOrder); map.put("sampleProduct", list); // 样品编号直接从样品表读取，不依赖检验项目关联查询是否有结果。 map.put("sampleCode", orderSamples.isEmpty() ? null : orderSamples.get(0).getSampleCode()); map.put("insOrderTemplate", map1); map.put("templateList", templateList); return map; } /** * 审核检验单 * @param insOrder * @return */ @Override public int upInsOrderOfState(InsOrder insOrder) { insOrder.setExamineTime(LocalDateTime.now()); if (insOrder.getState() == 1) { //审核通过才会生成委托编号 InsOrder order = this.getById(insOrder.getId()); List insSamples = insSampleMapper.selectList(Wrappers.lambdaQuery() .eq(InsSample::getInsOrderId, insOrder.getId()) .orderByAsc(InsSample::getId)); // 委托编号按送样日期生成；新聚单样品订单的末两位取样品编号末两位。 // 历史/外部订单未填写送样日期时回退到当天，避免影响原有流程。 LocalDate entrustDate = order.getSampleDate() == null ? LocalDate.now() : order.getSampleDate(); String entrustCodePrefix = "LMSY-" + entrustDate.format(DateTimeFormatter.BASIC_ISO_DATE) + "-"; String no; if (isDirectTemplateOrder(order, insSamples)) { String sampleCode = insSamples.get(0).getSampleCode(); if (StringUtils.isBlank(sampleCode) || sampleCode.trim().length() < 2) { throw new ErrorException("样品编号不能为空且不能少于2位"); } sampleCode = sampleCode.trim(); no = entrustCodePrefix + sampleCode.substring(sampleCode.length() - 2); } else { no = numberGenerator.generateNumberWithPrefix(2, entrustCodePrefix, InsOrder::getEntrustCode); } // 判断是否是季度检验, 是季度检验取消原材料季度检验下单 if (InsOrderTypeConstants.QUARTERLY_TEST.equals(order.getOrderType())) { ifsInventoryQuantityMapper.update(null, Wrappers.lambdaUpdate() .eq(IfsInventoryQuantity::getId, order.getIfsInventoryId()) .set(IfsInventoryQuantity::getIsQuarter, 0)); // 查询是否有过进厂检验, 有获取里面的编号 InsOrder order1 = insOrderMapper.selectOne(Wrappers.lambdaQuery() .eq(InsOrder::getIfsInventoryId, order.getIfsInventoryId()) .ne(InsOrder::getState, -1) .eq(InsOrder::getOrderType, InsOrderTypeConstants.ENTER_THE_FACTORY)); if (order1 != null) { no = order1.getEntrustCode(); } } int count = 1; for (InsSample insSample : insSamples) { if (StringUtils.isBlank(insSample.getSampleCode())) { // 如果只有一个样品就不需要拼接数字 if (insSamples.size() != 1) { insSample.setSampleCode(no + "-" + count); count++; } else { insSample.setSampleCode(no); } } } insSampleService.updateBatchById(insSamples); insOrder.setEntrustCode(no); } return insOrderMapper.updateById(insOrder); } @Override public Map getInsOrderAndSample(Integer id, String laboratory) { Map map = new HashMap<>(); // InsOrder insOrder = insOrderMapper.selectById(id); IfsOrderVO ifsOrderVO = insOrderMapper.selectOrderInfoById(id); Map> templateDeviceIds = insOrderTemplateDeviceMapper.selectList( Wrappers.lambdaQuery() .eq(InsOrderTemplateDevice::getInsOrderId, id) .orderByAsc(InsOrderTemplateDevice::getSort, InsOrderTemplateDevice::getId)) .stream().collect(Collectors.groupingBy( InsOrderTemplateDevice::getTemplateId, LinkedHashMap::new, Collectors.mapping(InsOrderTemplateDevice::getDeviceId, Collectors.toList()))); List templateConditions = insOrderStandardTemplateMapper.selectList( Wrappers.lambdaQuery() .eq(InsOrderStandardTemplate::getInsOrderId, id) .select(InsOrderStandardTemplate::getTemplateId, InsOrderStandardTemplate::getTemperature, InsOrderStandardTemplate::getHumidity, InsOrderStandardTemplate::getDetectionTime, InsOrderStandardTemplate::getDetectionPlace, InsOrderStandardTemplate::getInsResult) .orderByAsc(InsOrderStandardTemplate::getSort, InsOrderStandardTemplate::getId)) .stream().map(snapshot -> { TemplateConditionVo condition = new TemplateConditionVo(); condition.setTemplateId(snapshot.getTemplateId()); condition.setTemperature(snapshot.getTemperature()); condition.setHumidity(snapshot.getHumidity()); condition.setDetectionTime(snapshot.getDetectionTime()); condition.setDetectionPlace(snapshot.getDetectionPlace()); condition.setInsResult(snapshot.getInsResult()); condition.setDeviceIds(templateDeviceIds.getOrDefault( snapshot.getTemplateId(), Collections.emptyList())); return condition; }).collect(Collectors.toList()); ifsOrderVO.setTemplateConditions(templateConditions); List list = insSampleMapper.getInsOrderAndSample(id, laboratory); map.put("insOrder", ifsOrderVO); map.put("sampleProduct", list); //查询所有记录模版去重 List> list2 = insOrderMapper.selectReportModelByOrderId(id, laboratory); map.put("reportModel", list2); return map; } @Override public IPage selectSampleAndProductByOrderId(IPage page, SampleProductDto2 sampleProductDto) { IPage productDto2IPage = insOrderMapper.selectSampleAndProductByOrderId(page, QueryWrappers.queryWrappers(sampleProductDto) .orderByAsc("sample_code") .orderByAsc("cable_tag") .orderByAsc("sort"), sampleProductDto.getId()); return productDto2IPage; } @Override public int updateStatus(Integer id) { return insOrderMapper.updateStatus(id); } /** * 获取ifs库存信息 * @param * @return */ @Override public void getIfsOrder(Map map,Boolean isSplitOrder) { List> inventory = ifsApiUtils.getInventory(JSONUtil.toJsonStr(map)); if(inventory.isEmpty()) { return; } // 进行保存 for (Map map1 : inventory) { DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); // 时间格式化 IfsInventoryQuantity ifsInventoryQuantity = new IfsInventoryQuantity(); ifsInventoryQuantity.setContract(map1.get("CONTRACT") == null ? "" : map1.get("CONTRACT").toString()); // 域 ifsInventoryQuantity.setPartNo(map1.get("PART_NO") == null ? "" : map1.get("PART_NO").toString() ); // 零件号 ifsInventoryQuantity.setPartDesc(map1.get("PART_DESC") == null ? "" : map1.get("PART_DESC").toString()); // 零件描述 ifsInventoryQuantity.setOrderNo(map1.get("ORDER_NO") == null ? "" : map1.get("ORDER_NO").toString()); // 订单号 ifsInventoryQuantity.setLineNo(map1.get("LINE_NO") == null ? "" : map1.get("LINE_NO").toString()); // 行号 ifsInventoryQuantity.setReleaseNo(map1.get("RELEASE_NO") == null ? "" : map1.get("RELEASE_NO").toString()); // 下达号 ifsInventoryQuantity.setReceiptNo(Integer.parseInt(map1.get("RECEIPT_NO") == null ? "" : map1.get("RECEIPT_NO").toString())); // 接收号 ifsInventoryQuantity.setStatus(map1.get("STATE") == null ? "" : map1.get("STATE").toString()); // 状态描述 ifsInventoryQuantity.setStatusDb(map1.get("STATE_DB") == null ? "" : map1.get("STATE_DB").toString()); // 状态 if(map1.get("QTY_ARRIVED") != null) { ifsInventoryQuantity.setQtyArrived(new BigDecimal(map1.get("QTY_ARRIVED").toString())); // 抵达的采购数量 } if(map1.get("QTY_INSPECTED") != null) { ifsInventoryQuantity.setQtyInspected(new BigDecimal(map1.get("QTY_INSPECTED").toString())); // 已检验的购买数量 } if(map1.get("QTY_TO_INSPECT") != null) { ifsInventoryQuantity.setQtyToInspect(new BigDecimal(map1.get("QTY_TO_INSPECT").toString())); // 要检验的采购数量 } if(map1.get("INV_QTY_IN_STORE") != null) { ifsInventoryQuantity.setInvQtyInStore(new BigDecimal(map1.get("INV_QTY_IN_STORE").toString())); // 抵达的库存数量 } if(map1.get("PUR_QTY_IN_STORE") != null) { ifsInventoryQuantity.setPurQtyInStore(new BigDecimal( map1.get("PUR_QTY_IN_STORE").toString())); // 抵达的采购数量 } ifsInventoryQuantity.setSupplierId(map1.get("SUPPLIER_ID") == null ? "" : map1.get("SUPPLIER_ID").toString()); // 供应商ID ifsInventoryQuantity.setSupplierName(map1.get("SUPPLIER_NAME") == null ? "" : map1.get("SUPPLIER_NAME").toString()); // 供应商名称 ifsInventoryQuantity.setConfigurationId(map1.get("CONFIGURATION_ID") == null ? "" : map1.get("CONFIGURATION_ID").toString()); // 配置标识 ifsInventoryQuantity.setLotBatchNo(map1.get("LOT_BATCH_NO") == null ? "" : map1.get("LOT_BATCH_NO").toString()); // 批次号 ifsInventoryQuantity.setUpdateBatchNo(map1.get("LOT_BATCH_NO") == null ? "" : map1.get("LOT_BATCH_NO").toString()); // 批次号 ifsInventoryQuantity.setWaivDevRejNo(map1.get("WAIV_DEV_REJ_NO") == null ? "" : map1.get("WAIV_DEV_REJ_NO").toString()); // WDR号 ifsInventoryQuantity.setActivitySeq(map1.get("ACTIVITY_SEQ") == null ? null : Integer.parseInt(map1.get("ACTIVITY_SEQ").toString())); // 活动序列 ifsInventoryQuantity.setSerialNo(map1.get("SERIAL_NO") == null ? "" : map1.get("SERIAL_NO").toString()); // 序列号 ifsInventoryQuantity.setLocationNo(map1.get("LOCATION_NO") == null ? "" : map1.get("LOCATION_NO").toString()); // 库位号 ifsInventoryQuantity.setEngChgLevel(map1.get("ENG_CHG_LEVEL") == null ? "" : map1.get("ENG_CHG_LEVEL").toString()); // 版本号 ifsInventoryQuantity.setReceiver(map1.get("RECEIVER") == null ? "" : map1.get("RECEIVER").toString()); // 接收人 ifsInventoryQuantity.setReceiverName(map1.get("RECEIVER_NAME") == null ? "" : map1.get("RECEIVER_NAME").toString()); // 接收人名称 ifsInventoryQuantity.setBuyerCode(map1.get("BUYER_CODE") == null ? "" : map1.get("BUYER_CODE").toString()); // 采购员 ifsInventoryQuantity.setBuyerName(map1.get("BUYER_NAME") == null ? "" : map1.get("BUYER_NAME").toString()); // 采购员名称 if(map1.get("ARRIVE_DATE") != null) { ifsInventoryQuantity.setArriveDate(LocalDateTime.parse(map1.get("ARRIVE_DATE").toString(),dateTimeFormatter)); // 实际到货日期 } if(map1.get("DELIVERY_DATE") != null) { ifsInventoryQuantity.setDeliveryDate(LocalDateTime.parse(map1.get("DELIVERY_DATE").toString(),dateTimeFormatter)); // 实际交货日期 } if(map1.get("PRODUCT_DATE") != null) { ifsInventoryQuantity.setProductDate(LocalDateTime.parse(map1.get("PRODUCT_DATE").toString(),dateTimeFormatter)); // 生产日期 } if(map1.get("INVALID_DATE") != null) { ifsInventoryQuantity.setInvalidDate(LocalDateTime.parse(map1.get("INVALID_DATE").toString(),dateTimeFormatter)); // 失效日期 } if(map1.get("APPROVED_DATE") != null) { ifsInventoryQuantity.setApprovedDate(LocalDateTime.parse(map1.get("APPROVED_DATE").toString(),dateTimeFormatter)); // 审批日期 } ifsInventoryQuantity.setReqCeater(map1.get("REQ_CEATER") == null ? "" : map1.get("REQ_CEATER").toString()); // 采购申请创建人 ifsInventoryQuantity.setReqCeaterName(map1.get("REQ_CEATER_NAME") == null ? "" : map1.get("REQ_CEATER_NAME").toString()); // 采购申请创建人名称 ifsInventoryQuantity.setLineRemarks(map1.get("LINE_REMARKS") == null ? "" : map1.get("LINE_REMARKS").toString()); // 采购订单行备注 ifsInventoryQuantity.setBuyUnitMeas(map1.get("BUY_UNIT_MEAS") == null ? "" : map1.get("BUY_UNIT_MEAS").toString()); // 采购单位 ifsInventoryQuantity.setReceiverDate(LocalDateTime.now()); // 接收日期 ifsInventoryQuantity.setIsSource(1); ifsInventoryQuantity.setState(0); Long count = ifsInventoryQuantityMapper.selectCount(new LambdaQueryWrapper() .eq(IfsInventoryQuantity::getOrderNo, ifsInventoryQuantity.getOrderNo()) .eq(IfsInventoryQuantity::getLineNo, ifsInventoryQuantity.getLineNo()) .eq(IfsInventoryQuantity::getReleaseNo, ifsInventoryQuantity.getReleaseNo()) .eq(IfsInventoryQuantity::getReceiptNo, ifsInventoryQuantity.getReceiptNo()) .eq(IfsInventoryQuantity::getLocationNo, ifsInventoryQuantity.getLocationNo()) .eq(IfsInventoryQuantity::getLotBatchNo, ifsInventoryQuantity.getLotBatchNo()) .eq(IfsInventoryQuantity::getSerialNo, ifsInventoryQuantity.getSerialNo()) .eq(IfsInventoryQuantity::getEngChgLevel, ifsInventoryQuantity.getEngChgLevel()) .eq(IfsInventoryQuantity::getWaivDevRejNo, ifsInventoryQuantity.getWaivDevRejNo()) .eq(IfsInventoryQuantity::getActivitySeq, ifsInventoryQuantity.getActivitySeq()) ); if(count == 0) { ifsInventoryQuantity.setIsFirst(0); if(isSplitOrder){ ifsInventoryQuantity.setIsSplitOrder(1); } ifsInventoryQuantityMapper.insert(ifsInventoryQuantity); } } } /** * id是原材料的id * * 修改订单单号 * @param insOrder */ @Override @Transactional(rollbackFor = Exception.class) public void updateEntrustCode(InsOrder insOrder) { // 判断当前订单是否生成了报告, 生成了报告不能修改单号 List insOrders = insOrderMapper.selectList(Wrappers.lambdaQuery() .eq(InsOrder::getIfsInventoryId, insOrder.getId()) .ne(InsOrder::getState, -1)); List insOrderIds = insOrders.stream().map(InsOrder::getId).collect(Collectors.toList()); Long count = insReportMapper.selectCount(Wrappers.lambdaQuery() .in(InsReport::getInsOrderId, insOrderIds)); if (count > 0 ) { throw new ErrorException("当前订单已经生成了报告不能修改编号"); } Long count1 = insOrderMapper.selectCount(Wrappers.lambdaQuery() .eq(InsOrder::getEntrustCode, insOrder.getEntrustCode()) .ne(InsOrder::getIfsInventoryId, insOrder.getId()) .ne(InsOrder::getInsState, -1)); if (count1 > 0) { throw new ErrorException("该编号重复"); } //修改报告的编号 insOrderMapper.update(null, Wrappers.lambdaUpdate() .eq(InsOrder::getIfsInventoryId, insOrder.getId()) .set(InsOrder::getEntrustCode, insOrder.getEntrustCode())); // 修改样品的编号 // 查询所有的样品 List insSamples = insSampleMapper.selectList(Wrappers.lambdaQuery() .in(InsSample::getInsOrderId, insOrderIds)); for (InsSample insSample : insSamples) { String sampleCode = insSample.getSampleCode(); String updateCode = insOrder.getEntrustCode(); // 查找最后一个'-'的位置 int lastDashIndex = sampleCode.lastIndexOf('-'); if (lastDashIndex != -1) { int secondLastDashIndex = sampleCode.lastIndexOf('-', lastDashIndex - 1); // 处理最后一个'-'前的部分 if (secondLastDashIndex != -1) { // 处理最后一个'-'及之后的部分 String afterLastDash = sampleCode.substring(lastDashIndex); updateCode = updateCode + afterLastDash; } } insSampleMapper.update(null, Wrappers.lambdaUpdate() .eq(InsSample::getId, insSample.getId()) .set(InsSample::getSampleCode, updateCode)); } } @Override public List getRetestResult(Integer insProductId) { return insUnqualifiedRetestProductMapper.selectList(Wrappers.lambdaQuery() .eq(InsUnqualifiedRetestProduct::getInsProductId, insProductId)); } /** * 修改采购订单接收状态, 避免回滚 * @param id */ @Transactional public void updateIfsInventoryQuantity(Long id) { ifsInventoryQuantityMapper.update(null, Wrappers.lambdaUpdate() .set(IfsInventoryQuantity::getIsRegister, 1) .eq(IfsInventoryQuantity::getId, id)); } /** * 新增铜单丝下单 * @param list * @param insOrder * @return */ @Override public int addRawCopperOrder(List list, CopperInsOrderDto insOrder) { insOrder.setState(1); insOrder.setTypeSource(1); LocalDate appointed = insOrder.getAppointed(); insOrderMapper.insert(insOrder); // 主表 list.forEach(a -> { a.setId(null); a.setInsOrderId(insOrder.getId()); insSampleMapper.insert(a); if (ObjectUtil.isNotEmpty(a.getInsProduct())) { // 判断是否填写待检项数量 if (a.getQuantity() != null) { List ip2 = new ArrayList<>(); for (Integer i = 1; i <= a.getQuantity(); i++) { // 重新拷贝 创建新对象 AtomicInteger atomicInteger = new AtomicInteger(i); List insProducts = a.getInsProduct().stream().map(insProduct -> { insProduct.setRawMaterialTag(String.valueOf(atomicInteger.get())); InsProduct product = new InsProduct(); BeanUtils.copyProperties(insProduct, product); return product; }).collect(Collectors.toList()); ip2.addAll(insProducts); } addInsProductMethod(a.getId(), ip2); } else { addInsProductMethod(a.getId(), a.getInsProduct()); } } if (ObjectUtil.isNotEmpty(a.getChildSampleList())) { for (SampleProductDto b : a.getChildSampleList()) { for (int i = 0; i < b.getNum(); i++) { b.setId(null); b.setInsOrderId(insOrder.getId()); b.setParentId(a.getId()); insSampleMapper.insert(b); if (ObjectUtil.isNotEmpty(b.getInsProduct())) { addInsProductMethod(b.getId(), b.getInsProduct()); } } } } }); // 添加原材料信息 IfsInventoryQuantity ifsInventoryQuantity = new IfsInventoryQuantity(); // 基本信息 ifsInventoryQuantity.setIsSource(0); ifsInventoryQuantity.setIsInspect(1); ifsInventoryQuantity.setState(1); ifsInventoryQuantity.setIsFinish(0); ifsInventoryQuantity.setIsCopper(1); ifsInventoryQuantity.setIsQuarter(0); ifsInventoryQuantity.setInspectStatus(0); //铜材料下单默认值 ifsInventoryQuantity.setOrderType(OrderType.RAW.getValue()); ifsInventoryQuantity.setMaterialProp("01Cu"); ifsInventoryQuantity.setQtyArrived(insOrder.getQtyArrived()); ifsInventoryQuantity.setBuyUnitMeas(insOrder.getBuyUnitMeas()); ifsInventoryQuantity.setSupplierName(insOrder.getSupplierName()); ifsInventoryQuantity.setUpdateBatchNo(insOrder.getUpdateBatchNo()); ifsInventoryQuantity.setDeclareDate(insOrder.getDeclareDate()); ifsInventoryQuantityMapper.insert(ifsInventoryQuantity); insOrder.setIfsInventoryId(ifsInventoryQuantity.getId()); insOrder.setState(1); upInsOrderOfState(insOrder); upInsOrder(insOrder.getId(), null, appointed != null ? appointed.toString() : null, SecurityUtils.getUserId().intValue(), "原材料"); return insOrder.getId(); } /** * 修改委托下单编号 * @param insOrder */ @Override public void updateOrderEntrustCode(InsOrder insOrder) { // 判断当前订单是否生成了报告, 生成了报告不能修改单号 Long count = insReportMapper.selectCount(Wrappers.lambdaQuery() .eq(InsReport::getInsOrderId, insOrder.getId())); if (count > 0 ) { throw new ErrorException("当前订单已经生成了报告不能修改编号"); } Long count1 = insOrderMapper.selectCount(Wrappers.lambdaQuery() .eq(InsOrder::getEntrustCode, insOrder.getEntrustCode())); if (count1 > 0) { throw new ErrorException("该编号重复"); } //修改报告的编号 insOrderMapper.update(null, Wrappers.lambdaUpdate() .eq(InsOrder::getId, insOrder.getId()) .set(InsOrder::getEntrustCode, insOrder.getEntrustCode())); // 修改样品的编号 // 查询所有的样品 List insSamples = insSampleMapper.selectList(Wrappers.lambdaQuery() .eq(InsSample::getInsOrderId, insOrder.getId())); for (InsSample insSample : insSamples) { String sampleCode = insSample.getSampleCode(); String updateCode = insOrder.getEntrustCode(); // 查找最后一个'-'的位置 int lastDashIndex = sampleCode.lastIndexOf('-'); if (lastDashIndex != -1) { int secondLastDashIndex = sampleCode.lastIndexOf('-', lastDashIndex - 1); // 处理最后一个'-'前的部分 if (secondLastDashIndex != -1) { // 处理最后一个'-'及之后的部分 String afterLastDash = sampleCode.substring(lastDashIndex); updateCode = updateCode + afterLastDash; } } insSampleMapper.update(null, Wrappers.lambdaUpdate() .eq(InsSample::getId, insSample.getId()) .set(InsSample::getSampleCode, updateCode)); } } /** * 修改检验下单内容 * @param insOrderUpdateDto * @return */ @Override @Transactional(rollbackFor = Exception.class) public Boolean updateInsOrder(InsOrderUpdateDto insOrderUpdateDto) { InsOrder currentOrder = insOrderMapper.selectById(insOrderUpdateDto.getInsOrder().getId()); if (currentOrder == null || !Objects.equals(currentOrder.getState(), 2)) { throw new ErrorException("只有退回的检验单可以修改"); } boolean hasSelectedProduct = CollectionUtils.isNotEmpty(insOrderUpdateDto.getSampleProduct()) && insOrderUpdateDto.getSampleProduct().stream() .filter(sample -> CollectionUtils.isNotEmpty(sample.getInsProduct())) .flatMap(sample -> sample.getInsProduct().stream()) .anyMatch(product -> Objects.equals(product.getState(), 1)); if (!hasSelectedProduct) { throw new ErrorException("请至少选择一个检验项"); } // 修改订单 insOrderUpdateDto.getInsOrder().setState(0); insOrderUpdateDto.getInsOrder().setTell(""); insOrderMapper.updateById(insOrderUpdateDto.getInsOrder()); // 修改检验项 for (SampleProductDto sampleProductDto : insOrderUpdateDto.getSampleProduct()) { Long sampleCount = insSampleMapper.selectCount(Wrappers.lambdaQuery() .eq(InsSample::getId, sampleProductDto.getId()) .eq(InsSample::getInsOrderId, insOrderUpdateDto.getInsOrder().getId())); if (sampleCount == 0) { throw new ErrorException("检验样品数据异常"); } insSampleService.update(Wrappers.lambdaUpdate() .eq(InsSample::getId, sampleProductDto.getId()) .set(InsSample::getSpecialStandardMethod, sampleProductDto.getSpecialStandardMethod())); List products = sampleProductDto.getInsProduct(); if (CollectionUtils.isEmpty(products)) { continue; } Set productIds = insProductMapper.selectList(Wrappers.lambdaQuery() .eq(InsProduct::getInsSampleId, sampleProductDto.getId())) .stream() .map(InsProduct::getId) .collect(Collectors.toSet()); if (products.stream().anyMatch(product -> product.getId() != null && !productIds.contains(product.getId()))) { throw new ErrorException("检验项数据异常"); } List removedIds = products.stream() .filter(product -> product.getId() != null && !Objects.equals(product.getState(), 1)) .map(InsProduct::getId) .collect(Collectors.toList()); if (CollectionUtils.isNotEmpty(removedIds)) { insProductService.removeByIds(removedIds); } List existingProducts = products.stream() .filter(product -> product.getId() != null && Objects.equals(product.getState(), 1)) .collect(Collectors.toList()); if (CollectionUtils.isNotEmpty(existingProducts)) { insProductService.updateBatchById(existingProducts); } List newProducts = products.stream() .filter(product -> product.getId() == null && Objects.equals(product.getState(), 1)) .collect(Collectors.toList()); addInsProductMethod(sampleProductDto.getId(), newProducts); } return true; } /** * 成品标签打印 * @param ids * @return */ @Override public List labelOrderPrinting(List ids) { return insOrderMapper.labelOrderPrinting(ids); } @Override public List labelOutsideOrderPrinting(List ids) { return insOrderMapper.labelOutsideOrderPrinting(ids); } /** * 根据样品id查询检验项树 * @param insSampleId * @return */ @Override public List getProductTreeBySampleId(Integer insSampleId) { // 查询第一个检验项获取检验项树 InsProduct insProduct = insProductMapper.selectOne(Wrappers.lambdaQuery() .eq(InsProduct::getInsSampleId, insSampleId) .last("limit 1")); String tree; if (insProduct.getSampleType() == null && insProduct.getModel() == null && StringUtils.isNotBlank(insProduct.getLaboratory()) && StringUtils.isNotBlank(insProduct.getSample())) { tree = StandardTreePathParser.canonical(insProduct.getLaboratory(), insProduct.getSample()); } else { tree = insProduct.getFactory() + " - " + insProduct.getLaboratory() + " - " + insProduct.getSampleType() + " - " + insProduct.getSample() + " - " + insProduct.getModel(); } // 查询标准树 List standardProductLists = standardProductListMapper.selectList(Wrappers.lambdaQuery() .eq(StandardProductList::getStandardMethodListId, insProduct.getStandardMethodListId()) .eq(StandardProductList::getTree, tree) .orderByAsc(StandardProductList::getSort)); for (StandardProductList standardProductList : standardProductLists) { standardProductList.setId(null); } return standardProductLists; } /** * 添加遗漏的检验项 * @param omitOrderProductDto * @return */ @Override public boolean addOmitOrderProduct(OmitOrderProductDto omitOrderProductDto) { if (omitOrderProductDto.getInsSampleId() == null) { throw new ErrorException("缺少样品Id"); } for (InsProduct product : omitOrderProductDto.getInsProductBindingList()) { if (product.getState() == 1) { product.setId(null); product.setCreateTime(null); product.setCreateUser(null); product.setUpdateTime(null); product.setUpdateUser(null); product.setSection(null); product.setInsSampleId(omitOrderProductDto.getInsSampleId()); if (StringUtils.isBlank(product.getCableTag())) { product.setCableTag(null); } if (product.getInspectionItemSubclass() == null) { product.setInspectionItemSubclass(""); } if (StringUtils.isBlank(product.getAsk()) || StringUtils.isBlank(product.getTell())) { throw new ErrorException("有检验项的要求值或要求描述为空, 请填写要求值或要求描述"); } insProductMapper.insert(product); } } return true; } /** * 成品检验单导出 * @param sampleOrderDto * @param response */ @Override public void rawAllInsOrderExport(SampleOrderDto sampleOrderDto, HttpServletResponse response) { List sampleOrderDtoList = new ArrayList<>(); if (StringUtils.isNotBlank(sampleOrderDto.getIds())) { List orderIds = StrUtil.split(sampleOrderDto.getIds(), ","); sampleOrderDtoList = insOrderMapper.getInsOrderExportByIds(orderIds); } else { String laboratory = null; // 判断是否是全部 String isOrderAll = null; if (sampleOrderDto.getState() != null && sampleOrderDto.getState() == -2) { isOrderAll = "1"; sampleOrderDto.setState(null); } sampleOrderDto.setIds(null); sampleOrderDtoList = insOrderMapper.rawAllInsOrderExport(QueryWrappers.queryWrappers(sampleOrderDto), laboratory, isOrderAll); } // 判断是否是不合格, 不合格查询不合格项 for (SampleOrderDto orderDto : sampleOrderDtoList) { if (orderDto.getInsResult() != null && orderDto.getInsResult() == 0){ // 查询不合格项 List unqualifiedList = insProductMapper.selectUnqualifiedList(orderDto.getId()); orderDto.setUnqualifiedItem(CollUtil.join(unqualifiedList, ",")); } orderDto.setCreateTimeString(orderDto.getCreateTime() == null ? "" : orderDto.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); } response.setContentType("application/vnd.ms-excel"); response.setCharacterEncoding("UTF-8"); try { // 这里URLEncoder.encode可以防止中文乱码 当然和easyexcel没有关系 String fileName = URLEncoder.encode("委托检测信息导出", "UTF-8"); response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".xlsx"); //新建ExcelWriter ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream()).registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()).build(); //获取sheet0对象 WriteSheet mainSheet = EasyExcel.writerSheet(0, "委托检测信息导出").head(SampleOrderDto.class).build(); //向sheet0写入数据 传入空list这样只导出表头 excelWriter.write(sampleOrderDtoList, mainSheet); //关闭流 excelWriter.finish(); } catch (IOException e) { throw new RuntimeException("导出失败"); } } /** * 修改样品型号 * @param insSample */ @Override public void updateSampleModel(InsSample insSample) { // 判断当前订单是否生成了报告, 生成了报告不能修改单号 Long count = insReportMapper.selectCount(Wrappers.lambdaQuery() .eq(InsReport::getInsOrderId, insSample.getInsOrderId())); if (count > 0 ) { throw new ErrorException("当前订单已经生成了报告不能修改编号"); } insSampleService.update(Wrappers.lambdaUpdate() .eq(InsSample::getId, insSample.getId()) .set(InsSample::getModel, insSample.getModel())); } /** * 查询当前时间是否没有该检测项的抽样计划 * @param sampleList * @param insOrder * @return */ @Override public Result judgeNotSpotCheckOrder(List sampleList, InsOrder insOrder) { // todo: 下单判断抽样计划的唯一性 if (insOrder.getQuarterItemId() != null) { Long quarterItemCount = insOrderMapper.selectCount(Wrappers.lambdaQuery() .eq(InsOrder::getQuarterItemId, insOrder.getQuarterItemId()) .notIn(InsOrder::getState, -1 ,2 ,3)); if (quarterItemCount > 0) { throw new ErrorException("该抽样计划已被绑定过"); } } // 判断是否是抽样检测 if (insOrder.getOrderType().equals(InsOrderTypeConstants.SPOT_CHECK)) { Set monthMessageSet = new HashSet<>(); Set quarterMessageSet = new HashSet<>(); Set yearMessageSet = new HashSet<>(); String formatTime = "yyyy-MM-dd HH:mm:ss"; // 查询当前所有样品的检验项 for (SampleProductDto sampleProductDto : sampleList) { List standardProductList = getProductTreeBySampleId(sampleProductDto.getId()); Set insIds = sampleProductDto.getInsProduct().stream() .map(InsProduct::getStructureItemParameterId) .collect(Collectors.toSet()); List productLists = standardProductList.stream() .filter(product -> !insIds.contains(product.getStructureItemParameterId())) .collect(Collectors.toList()); // 查询检验项基础表, 查询是否有月度, 季度, 年度的检验项 List itemParameterList = structureItemParameterMapper.selectList(Wrappers.lambdaQuery() .in(StructureItemParameter::getId, productLists.stream().map(StandardProductList::getStructureItemParameterId).collect(Collectors.toList()))); for (StructureItemParameter item : itemParameterList) { if (StringUtils.isNotBlank(item.getSpotCheckType())) { switch (item.getSpotCheckType()) { case "1": // 月度 // 查询当月是否有该检测项的抽样计划 // 当月开始时间 DateTime monthStart = DateUtil.beginOfMonth(DateUtil.date()); String monthStartTime = monthStart.toString(formatTime); // 当月结束时间 DateTime monthEnd = DateUtil.endOfMonth(DateUtil.date()); String monthEndTime = monthEnd.toString(formatTime); Integer count = insOrderMapper.selectNotSpotCheckOrder(item.getId(), monthStartTime, monthEndTime); if (count == 0) { String monthMessage = item.getInspectionItemClass() + item.getInspectionItem() + item.getInspectionItemSubclass(); monthMessageSet.add(monthMessage); } break; case "2": // 季度 DateTime quarterStart = DateUtil.beginOfQuarter(DateUtil.date()); String quarterStartTime = quarterStart.toString(formatTime); // 当月结束时间 DateTime quarterEnd = DateUtil.endOfQuarter(DateUtil.date()); String quarterEndTime = quarterEnd.toString(formatTime); Integer quarterCount = insOrderMapper.selectNotSpotCheckOrder(item.getId(), quarterStartTime, quarterEndTime); if (quarterCount == 0) { String quarterMessage = item.getInspectionItemClass() + item.getInspectionItem() + item.getInspectionItemSubclass(); quarterMessageSet.add(quarterMessage); } break; case "3": // 年度 DateTime yearStart = DateUtil.beginOfQuarter(DateUtil.date()); String yearStartTime = yearStart.toString(formatTime); // 当月结束时间 DateTime yearEnd = DateUtil.endOfQuarter(DateUtil.date()); String yearEndTime = yearEnd.toString(formatTime); Integer yearCount = insOrderMapper.selectNotSpotCheckOrder(item.getId(), yearStartTime, yearEndTime); if (yearCount == 0) { String yearMessage = item.getInspectionItemClass() + item.getInspectionItem() + item.getInspectionItemSubclass(); yearMessageSet.add(yearMessage); } break; } } } } String message = ""; if (CollectionUtils.isNotEmpty(monthMessageSet)) { message += StrUtil.format("

检验项{}当月还未进行抽样检测, 请查看是否需要添加当前检验项

", CollUtil.join(monthMessageSet, ", ")); } if (CollectionUtils.isNotEmpty(quarterMessageSet)) { message += StrUtil.format("

检验项{}当前季度还未进行抽样检测, 请看是否需要添加当前检验项

", CollUtil.join(quarterMessageSet, ", ")); } if (CollectionUtils.isNotEmpty(yearMessageSet)) { message += StrUtil.format("

检验项{}今年还未进行抽样检测, 请看是否需要添加当前检验项

", CollUtil.join(yearMessageSet, ", ")); } if (StringUtils.isNotBlank(message)) { return Result.success(false, message); } } return Result.success(true); } /** * ifs移库操作 * @param inventoryQuantity * @return */ @Override @Transactional(rollbackFor = Exception.class,isolation = Isolation.READ_COMMITTED) public String moveRawMaterial(IfsInventoryQuantity inventoryQuantity) { //查询ifs订单详情 IfsInventoryQuantity one = ifsInventoryQuantityMapper.selectById(inventoryQuantity.getId()); String toLocation; // 登记采购检验结果STD if (one.getIsRegister().equals(0)) { Map resultMap = new HashMap<>(); List> resultList = new ArrayList<>(); Map map = new HashMap<>(); map.put("ORDER_NO", one.getOrderNo()); // 采购订单号 map.put("LINE_NO", one.getLineNo()); // 行号 map.put("RELEASE_NO", one.getReleaseNo()); // 下达号 map.put("RECEIPT_NO", one.getReceiptNo()); // 接收号 map.put("PURCH_QTY", one.getQtyToInspect()); // 要检验的采购数量 resultList.add(map); resultMap.put("RECORD_ID", UUID.randomUUID().toString()); resultMap.put("SYSCODE", "LIMS"); resultMap.put("SYSMODEL", "登记采购检验结果"); resultMap.put("BATCH_INFO", resultList); Result result = ifsApiUtils.getProcurementResults(JSONUtil.toJsonStr(resultMap)); if (result.getCode() != 200) { throw new ErrorException("IFS登记采购检验结果失败: " + result.getMessage()); } //如果是拆分订单，则将同一接收号的订单标记已登记校验 if(one.getIsSplitOrder()==1){ //查询其余拆分的订单 List quantityList = ifsInventoryQuantityMapper.selectList(Wrappers.lambdaQuery() .eq(IfsInventoryQuantity::getOrderNo, one.getOrderNo()) .eq(IfsInventoryQuantity::getPartNo, one.getPartNo()) .eq(IfsInventoryQuantity::getLineNo, one.getLineNo()) .eq(IfsInventoryQuantity::getReleaseNo, one.getReleaseNo()) .eq(IfsInventoryQuantity::getReceiptNo, one.getReceiptNo()) .eq(IfsInventoryQuantity::getIsSplitOrder, 1) ); if(Objects.nonNull(quantityList) && !quantityList.isEmpty()){ //修改采购订单登记状态 List ids = quantityList.stream().map(IfsInventoryQuantity::getId).collect(Collectors.toList()); ifsInventoryQuantityMapper.update(null,Wrappers.lambdaUpdate() .set(IfsInventoryQuantity::getIsRegister,1) .in(IfsInventoryQuantity::getId, ids) ); } }else{ this.updateIfsInventoryQuantity(one.getId()); } } /** * TODO 后续需要调用IFS的接口 移入的库位号 toLocation */ // 检验后移库 //1301:原材料合格库，CP-02-001:成品库 if(StringUtils.equals(inventoryQuantity.getOrderType(), OrderType.RAW.getValue())){ toLocation = "1301"; }else if(StringUtils.equals(inventoryQuantity.getOrderType(), OrderType.WG.getValue())){ toLocation = "CP-02-001"; }else{ toLocation = "1301"; } Map moveResultMap = new HashMap<>(); List> moveResultList = new ArrayList<>(); Map moveMap = new HashMap<>(); moveMap.put("ORDER_NO", one.getOrderNo()); // 采购订单号 moveMap.put("LINE_NO", one.getLineNo()); moveMap.put("RELEASE_NO", one.getReleaseNo()); moveMap.put("RECEIPT_NO", one.getReceiptNo()); moveMap.put("PART_NO", one.getPartNo()); moveMap.put("QTY", one.getPurQtyInStore()); moveMap.put("LOCATION_NO", one.getLocationNo()); moveMap.put("TO_LOCATION_NO", toLocation); moveMap.put("LOT_BATCH_NO", one.getLotBatchNo()); moveMap.put("SERIAL_NO", one.getSerialNo()); moveMap.put("WAIV_DEV_REJ_NO", one.getWaivDevRejNo()); moveMap.put("ENG_CHG_LEVEL", one.getEngChgLevel()); moveMap.put("ACTIVITY_SEQ", one.getActivitySeq()); moveResultList.add(moveMap); moveResultMap.put("RECORD_ID", UUID.randomUUID().toString()); moveResultMap.put("SYSCODE", "LIMS"); moveResultMap.put("SYSMODEL", "检验后移库"); moveResultMap.put("BATCH_INFO", moveResultList); Result result1 = ifsApiUtils.moveReceipt(JSONUtil.toJsonStr(moveResultMap)); // 如果有必须为零件指定批号报错需要重新提交移库信息去指定批号 if (result1.getCode() != 200) { String message = result1.getMessage(); if (message.contains("必须为零件") && message.contains("指定批号")) { updaeBatch(one, toLocation); } else { throw new ErrorException("IFS检验后移库失败: " + result1.getMessage()); } } return toLocation; } /** * 先修改采购订单批次号, 后进行移库操作 * @param one * @param toLocation */ private void updaeBatch(IfsInventoryQuantity one, String toLocation) { if (one.getIsUpdateBatch().equals(0)) { // 先修改批次号后进行移库 Map resultMap = new HashMap<>(); List> resultList = new ArrayList<>(); Map map = new HashMap<>(); map.put("ORDER_NO", one.getOrderNo()); // 采购订单号 map.put("LINE_NO", one.getLineNo()); // 行号 map.put("RELEASE_NO", one.getReleaseNo()); // 下达号 map.put("RECEIPT_NO", one.getReceiptNo()); // 接收号 map.put("PART_NO", one.getPartNo()); //零件号 map.put("CONFIGURATION_ID", one.getConfigurationId()); // 配置标识 map.put("LOCATION_NO", one.getLocationNo()); // 库位号 map.put("LOT_BATCH_NO", one.getLotBatchNo());// 批次号 map.put("NEW_LOT_BATCH_NO", one.getUpdateBatchNo()); // 目标批次号 map.put("SERIAL_NO", one.getSerialNo()); // 序列号 map.put("ENG_CHG_LEVEL", one.getEngChgLevel()); // 版本号 map.put("WAIV_DEV_REJ_NO", one.getWaivDevRejNo()); // wdr号 map.put("ACTIVITY_SEQ", one.getActivitySeq()); // 活动序号 map.put("QTY_TO_CHANGE", one.getQtyArrived()); // 变更数量 resultList.add(map); resultMap.put("RECORD_ID", UUID.randomUUID().toString()); resultMap.put("SYSCODE", "LIMS"); resultMap.put("SYSMODEL", "修改采购订单批次号"); resultMap.put("BATCH_INFO", resultList); Result result = ifsApiUtils.updateMoveReceiptLot(JSONUtil.toJsonStr(resultMap)); if (result.getCode() != 200) { throw new ErrorException("IFS修改批次号失败: " + result.getMessage()); } ifsInventoryQuantityMapper.update(null, Wrappers.lambdaUpdate() .set(IfsInventoryQuantity::getIsUpdateBatch, 1) .eq(IfsInventoryQuantity::getId, one.getId())); } Map moveResultMap = new HashMap<>(); List> moveResultList = new ArrayList<>(); Map moveMap = new HashMap<>(); moveMap.put("ORDER_NO", one.getOrderNo()); // 采购订单号 moveMap.put("LINE_NO", one.getLineNo()); moveMap.put("RELEASE_NO", one.getReleaseNo()); moveMap.put("RECEIPT_NO", one.getReceiptNo()); moveMap.put("PART_NO", one.getPartNo()); moveMap.put("QTY", one.getQtyArrived()); moveMap.put("LOCATION_NO", one.getLocationNo()); moveMap.put("TO_LOCATION_NO", toLocation); moveMap.put("LOT_BATCH_NO", one.getUpdateBatchNo()); moveMap.put("SERIAL_NO", one.getSerialNo()); moveMap.put("WAIV_DEV_REJ_NO", one.getWaivDevRejNo()); moveMap.put("ENG_CHG_LEVEL", one.getEngChgLevel()); moveMap.put("ACTIVITY_SEQ", one.getActivitySeq()); moveResultList.add(moveMap); moveResultMap.put("RECORD_ID", UUID.randomUUID().toString()); moveResultMap.put("SYSCODE", "LIMS"); moveResultMap.put("SYSMODEL", "检验后移库"); moveResultMap.put("BATCH_INFO", moveResultList); Result result1 = ifsApiUtils.moveReceipt(JSONUtil.toJsonStr(moveResultMap)); if (result1.getCode() != 200) { throw new ErrorException("IFS检验后移库失败: " + result1.getMessage()); } } }