package com.ruoyi.inspect.service.impl; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; import cn.hutool.core.io.IoUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.excel.EasyExcel; import com.alibaba.excel.ExcelWriter; import com.alibaba.excel.support.ExcelTypeEnum; import com.alibaba.excel.write.metadata.WriteSheet; import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.ruoyi.basic.dto.*; import com.ruoyi.basic.pojo.IfsInventoryQuantity; 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.config.WechatProperty; import com.ruoyi.common.utils.LimsDateUtil; import com.ruoyi.common.utils.QueryWrappers; import com.ruoyi.common.utils.SecurityUtils; import com.ruoyi.common.utils.WxCpUtils; import com.ruoyi.common.utils.api.IfsApiUtils; import com.ruoyi.common.utils.api.MesApiUtils; import com.ruoyi.inspect.dto.CopperInsOrderDto; import com.ruoyi.inspect.dto.OrderSplitDTO; import com.ruoyi.inspect.dto.RawMaterialStandardTreeDto; import com.ruoyi.basic.mapper.IfsInventoryQuantityMapper; import com.ruoyi.basic.mapper.StandardTreeMapper; import com.ruoyi.inspect.dto.SampleProductDto; import com.ruoyi.inspect.excel.OrderSplitExcelData; import com.ruoyi.inspect.excel.OrderSplitExcelListener; import com.ruoyi.inspect.mapper.InsOrderMapper; import com.ruoyi.inspect.mapper.InsProductMapper; import com.ruoyi.inspect.mapper.InsSampleMapper; import com.ruoyi.inspect.pojo.IfsSplitOrderRecord; import com.ruoyi.inspect.pojo.InsOrder; import com.ruoyi.inspect.pojo.InsReport; import com.ruoyi.inspect.service.IfsSplitOrderRecordService; import com.ruoyi.inspect.service.InsOrderService; import com.ruoyi.inspect.service.InsReportService; import com.ruoyi.inspect.service.RawMaterialOrderService; import com.ruoyi.common.numgen.NumberGenerator; import com.ruoyi.framework.exception.ErrorException; import com.ruoyi.performance.mapper.AuxiliaryOutputWorkingHoursMapper; import com.ruoyi.performance.pojo.AuxiliaryOutputWorkingHours; import com.ruoyi.system.mapper.UserMapper; import lombok.AllArgsConstructor; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Isolation; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.io.InputStream; import java.io.UnsupportedEncodingException; import java.math.BigDecimal; import java.net.URLEncoder; import java.nio.charset.StandardCharsets; import java.text.SimpleDateFormat; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.concurrent.atomic.AtomicInteger; import java.util.stream.Collectors; /** * @Author zhuo * @Date 2024/7/31 */ @Service @AllArgsConstructor public class RawMaterialOrderServiceImpl implements RawMaterialOrderService { private StandardTreeMapper standardTreeMapper; private IfsInventoryQuantityMapper ifsInventoryQuantityMapper; private UserMapper userMapper; private InsOrderService insOrderService; private InsOrderMapper insOrderMapper; private InsSampleMapper insSampleMapper; private final NumberGenerator numberGenerator; private InsReportService insReportService; private WechatProperty wechatProperty; private ThreadPoolTaskExecutor threadPoolTaskExecutor; private InsProductMapper insProductMapper; private AuxiliaryOutputWorkingHoursMapper auxiliaryOutputWorkingHoursMapper; private IfsApiUtils ifsApiUtils; private IfsSplitOrderRecordService ifsSplitOrderRecordService; @Override public Result selectStandardTreeListByPartNo(String partNo) { List factoryDtos = standardTreeMapper.selectStandardTreeListByPartNo(partNo); if (CollectionUtil.isEmpty(factoryDtos)) { return Result.success(null, "零件号为" + partNo + "的原材料没有对应的标准库配置"); } RawMaterialStandardTreeDto rawMaterialStandardTreeDto = new RawMaterialStandardTreeDto(); for (FactoryDto factoryDto : factoryDtos) { for (LaboratoryDto laboratoryDto : factoryDto.getChildren()) { for (SampleTypeDto sampleTypeDto : laboratoryDto.getChildren()) { if (sampleTypeDto.getChildren().size() == 0) { sampleTypeDto.setChildren(standardTreeMapper.getStandardTree3(sampleTypeDto.getValue())); } // 判断绑定的是否是当前零件号 if (sampleTypeDto.getPartNo() != null && sampleTypeDto.getPartNo().equals(partNo)) { // 添加对象 rawMaterialStandardTreeDto.setTreeName(factoryDto.getValue() + " - " + laboratoryDto.getValue() + " - " + sampleTypeDto.getValue()); rawMaterialStandardTreeDto.setCode(sampleTypeDto.getCode()); rawMaterialStandardTreeDto.setLabel(sampleTypeDto.getLabel()); rawMaterialStandardTreeDto.setValue(sampleTypeDto.getValue()); rawMaterialStandardTreeDto.setChildren1(sampleTypeDto.getChildren()); } else { for (SampleDto sampleDto : sampleTypeDto.getChildren()) { if (sampleDto.getPartNo() != null && sampleDto.getPartNo().equals(partNo)) { // 添加对象 rawMaterialStandardTreeDto.setTreeName(factoryDto.getValue() + " - " + laboratoryDto.getValue() + " - " + sampleTypeDto.getValue() + " - " + sampleDto.getValue()); rawMaterialStandardTreeDto.setCode(sampleDto.getCode()); rawMaterialStandardTreeDto.setLabel(sampleDto.getLabel()); rawMaterialStandardTreeDto.setValue(sampleDto.getValue()); rawMaterialStandardTreeDto.setChildren2(sampleDto.getChildren()); } } } } } } return Result.success(rawMaterialStandardTreeDto); } @Override public IPage getWarehouseSubmit(IPage page, IfsInventoryQuantity ifsInventoryQuantity) { return standardTreeMapper.selectIfsPage(page, QueryWrappers.queryWrappers(ifsInventoryQuantity)); } @Override public IPage getIfsByStateOne(IPage page, IfsInventoryQuantityDto ifsInventoryQuantityDto) { return standardTreeMapper.getIfsByStateOne(page, QueryWrappers.queryWrappers(ifsInventoryQuantityDto)); } /** * 报检 * @param ids * @return */ @Override public int inspectionReport(List ids) { Integer userId = SecurityUtils.getUserId().intValue(); ifsInventoryQuantityMapper.update(null, Wrappers.lambdaUpdate() .in(IfsInventoryQuantity::getId, ids) .set(IfsInventoryQuantity::getDeclareUser, userMapper.selectById(userId).getName()) .set(IfsInventoryQuantity::getDeclareUserId, userId) .set(IfsInventoryQuantity::getIsInspect, 1) .set(IfsInventoryQuantity::getDeclareDate, LocalDateTime.now()) ); threadPoolTaskExecutor.execute(() -> { List quantityList = ifsInventoryQuantityMapper.selectList(Wrappers.lambdaQuery() .in(IfsInventoryQuantity::getId, ids)); // 企业微信通知 String message = ""; message += "新增报检通知"; for (IfsInventoryQuantity inventoryQuantity : quantityList) { message += "\n批次号: " + inventoryQuantity.getUpdateBatchNo(); message += "\n零件描述: " + inventoryQuantity.getPartDesc(); message += "\n抵达数量: " + inventoryQuantity.getQtyArrived().stripTrailingZeros().toPlainString() + inventoryQuantity.getBuyUnitMeas(); // 判断有没有到20吨. 或者能否免检 int result = notificationRawOrder(inventoryQuantity.getId()); switch (result) { case 1: message += "\n当前样品已检验过, 可以免检"; break; case 2: message += "\n当前样品已超过20吨"; break; } message += "\n"; } WxCpUtils.informWebHook(wechatProperty.getExaminingUrl(), message); }); return 1; } /** * 撤销报检 * @param id * @return */ @Override public int revokeInspectionReport(Long id) { return ifsInventoryQuantityMapper.update(null, Wrappers.lambdaUpdate() .eq(IfsInventoryQuantity::getId, id) .set(IfsInventoryQuantity::getIsInspect, 0) ); } /** * 打印标签查询 * @param ids * @return */ @Override public List printLabel(List ids) { return ifsInventoryQuantityMapper.printLabel(ids); } /** * 报检 * @param ifsInventoryQuantity * @return */ @Override public int inspectionReportOne(IfsInventoryQuantity ifsInventoryQuantity) { Integer userId = SecurityUtils.getUserId().intValue(); ifsInventoryQuantityMapper.update(null, Wrappers.lambdaUpdate() .eq(IfsInventoryQuantity::getId, ifsInventoryQuantity.getId()) .set(IfsInventoryQuantity::getDeclareUser, userMapper.selectById(userId).getName()) .set(IfsInventoryQuantity::getDeclareUserId, userId) .set(IfsInventoryQuantity::getIsInspect, 1) .set(IfsInventoryQuantity::getDeclareDate, LocalDateTime.now()) .set(IfsInventoryQuantity::getUpdateBatchNo, ifsInventoryQuantity.getUpdateBatchNo()) ); threadPoolTaskExecutor.execute(() -> { IfsInventoryQuantity inventoryQuantity = ifsInventoryQuantityMapper.selectById(ifsInventoryQuantity.getId()); // 企业微信通知 String message = ""; message += "新增报检通知"; message += "\n批次号: " + inventoryQuantity.getUpdateBatchNo(); message += "\n零件描述: " + inventoryQuantity.getPartDesc(); message += "\n抵达数量: " + inventoryQuantity.getQtyArrived().stripTrailingZeros().toPlainString() + inventoryQuantity.getBuyUnitMeas(); WxCpUtils.informWebHook(wechatProperty.getExaminingUrl(), message); }); return 1; } /** * 获取铜产业链检测数据 * @param id * @return */ @Override public String getIndustryChain(Integer id) { return ifsInventoryQuantityMapper.selectById(id).getIndustryChain(); } /** * 原材料撤销接口 * @param ifsInventoryId * @return */ @Override public boolean repealRawOrder(Long ifsInventoryId) { // 查询判断是否是铜单丝 IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(ifsInventoryId); if (ifsInventoryQuantity.getIsCopper() != null && ifsInventoryQuantity.getIsCopper().equals(1)) { // 铜单丝直接删除就行 ifsInventoryQuantityMapper.deleteById(ifsInventoryId); } else { ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper() .set(IfsInventoryQuantity::getState, 0) .set(IfsInventoryQuantity::getIsQuarter, 1) .eq(IfsInventoryQuantity::getId, ifsInventoryId)); } insOrderService.update(Wrappers.lambdaUpdate() .eq(InsOrder::getIfsInventoryId, ifsInventoryId) .set(InsOrder::getState, -1) .set(InsOrder::getEntrustCode, ""));// 撤销 return true; } /** * 原材料免检下单 * @param list * @param insOrder * @return */ @Override @Transactional(rollbackFor = Exception.class) public int addExemptionOrder(List list, InsOrder insOrder) { if (!insOrder.getOrderType().equals(InsOrderTypeConstants.ENTER_THE_FACTORY)) { throw new ErrorException("只有进厂检验才能免检"); } insOrder.setSendTime(LocalDateTime.now()); // 修改订单表直接为已检验 insOrder.setState(4); insOrder.setTypeSource(1); String code = "Y"; // 生成编号 String no = numberGenerator.generateNumberWithPrefix(3, "JCZX/NS-" + code + LimsDateUtil.resetDate(LocalDateTime.now()), InsOrder::getEntrustCode); insOrderMapper.insert(insOrder); // 主表 AtomicInteger count = new AtomicInteger(); list.forEach(a -> { count.getAndIncrement(); a.setId(null); a.setInsOrderId(insOrder.getId()); if (StrUtil.isEmpty(a.getSampleCode())) { // 如果只有一个样品就不需要拼接数字 if (list.size() != 1) { a.setSampleCode(no + "-" + count.get()); } else { a.setSampleCode(no); } } insSampleMapper.insert(a); if (!CollectionUtil.isEmpty(a.getInsProduct())) { throw new ErrorException("免检不需要填写检验项"); } }); // 原材料下单: 委托人就是报检人, 生产单位就是供应商单位 IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(insOrder.getIfsInventoryId()); Integer declareUserId = ifsInventoryQuantity.getDeclareUserId(); User user = userMapper.selectById(declareUserId); // 供应商名称 insOrder.setProduction(ifsInventoryQuantity.getSupplierName()); // 委托人名称 insOrder.setPrepareUser(user.getName()); insOrder.setPhone(user.getPhone()); // 修改原材料数据直接为已检验 ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper().set(IfsInventoryQuantity::getState, 2) .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId())); insOrder.setExamineTime(LocalDateTime.now()); insOrder.setEntrustCode(no); insOrder.setIsExemption(1); insOrderMapper.updateById(insOrder); // 添加工时 addAuxiliary(insOrder, ifsInventoryQuantity); // todo: ifs直接移库 insReportService.isRawMaterial(insOrder,true,true); return insOrder.getId(); } /** * 查询待下单 * @param page * @param ifsInventoryQuantity * @return */ @Override public IPage selectIfsInventoryQuantity(Page page, IfsInventoryQuantityCheckDto ifsInventoryQuantity) { return standardTreeMapper.selectIfsInventoryQuantity(page, QueryWrappers.queryWrappers(ifsInventoryQuantity)); } /** * 查询已检验 * @param page * @param ifsInventoryQuantityDto * @return */ @Override public IPage getIfsByOver(Page page, IfsInventoryQuantitySupplierDto ifsInventoryQuantityDto) { // todo: 只看我 String beginDeclareDate = ifsInventoryQuantityDto.getBeginDeclareDate(); String endDeclareDate = ifsInventoryQuantityDto.getEndDeclareDate(); ifsInventoryQuantityDto.setBeginDeclareDate(null); ifsInventoryQuantityDto.setEndDeclareDate(null); IPage ifsByOver = standardTreeMapper.getIfsByOver(page, QueryWrappers.queryWrappers(ifsInventoryQuantityDto), beginDeclareDate, endDeclareDate); return ifsByOver; } /** * 删除原材料报检信息 * @param id * @return */ @Override public int delIfsInventory(Integer id) { return ifsInventoryQuantityMapper.deleteById(id); } /** * 原材料放行免检 * @param ifsInventoryId * @return */ @Override @Transactional(rollbackFor = Exception.class) public boolean rawOrderRelease(Long ifsInventoryId, String partDetail) { // 修改原材料数据直接为已检验 ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper() .set(IfsInventoryQuantity::getState, 2) .set(IfsInventoryQuantity::getIsQuarter, 0) .eq(IfsInventoryQuantity::getId, ifsInventoryId)); // 查询原材料信息 IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(ifsInventoryId); // 委托人就是报检人, 生产单位就是供应商单位 Integer declareUserId = ifsInventoryQuantity.getDeclareUserId(); User user = userMapper.selectById(declareUserId); InsOrder insOrder = new InsOrder(); insOrder.setState(4); insOrder.setTypeSource(1); String code = "Y"; // 生成编号 String no = numberGenerator.generateNumberWithPrefix(3, "JCZX/NS-" + code + LimsDateUtil.resetDate(LocalDateTime.now()), InsOrder::getEntrustCode); insOrder.setExamineTime(LocalDateTime.now()); insOrder.setEntrustCode(no); insOrder.setIsExemption(1); // 供应商名称 insOrder.setProduction(ifsInventoryQuantity.getSupplierName()); // 委托人名称 insOrder.setPrepareUser(user.getName()); insOrder.setPhone(user.getPhone()); insOrder.setIfsInventoryId(ifsInventoryId); insOrder.setPartDetail(partDetail); insOrder.setSendTime(LocalDateTime.now()); insOrder.setSample(ifsInventoryQuantity.getPartDesc()); // 进厂检验 insOrder.setOrderType(InsOrderTypeConstants.ENTER_THE_FACTORY); insOrderMapper.insert(insOrder); // 添加工时 addAuxiliary(insOrder, ifsInventoryQuantity); // todo: ifs直接移库 insReportService.isRawMaterial(insOrder,true,true); return true; } /** * 0, 无提示, 1提示 当前批次的样品已检验过, 可以免检, 2 提示 当前批次的样品已超20吨, 需要多级多次检验 * * 原材料下单通知免检或者多次检验 * @param ifsInventoryId * @return */ @Override public int notificationRawOrder(Long ifsInventoryId) { IfsInventoryQuantity ifsInventory = ifsInventoryQuantityMapper.selectById(ifsInventoryId); // 查询当前批次, 供应商, 零件号的原材料是否超过了20吨, 超过了20吨需要进行多次检验提醒 List quantityList = ifsInventoryQuantityMapper.selectList(Wrappers.lambdaQuery() .eq(IfsInventoryQuantity::getPartNo, ifsInventory.getPartNo()) .eq(IfsInventoryQuantity::getUpdateBatchNo, ifsInventory.getUpdateBatchNo()) .eq(IfsInventoryQuantity::getSupplierId, ifsInventory.getSupplierId()) .eq(IfsInventoryQuantity::getSupplierName, ifsInventory.getSupplierName())); // 判断是否大于20吨 BigDecimal bigDecimal = new BigDecimal("20000"); BigDecimal count = BigDecimal.ZERO; for (IfsInventoryQuantity inventoryQuantity : quantityList) { // 判断单位是kg或者t if (inventoryQuantity.getBuyUnitMeas().equalsIgnoreCase("t")) { count = count.add(inventoryQuantity.getQtyArrived().multiply(new BigDecimal("1000"))); } else if (inventoryQuantity.getBuyUnitMeas().equalsIgnoreCase("kg")) { count = count.add(inventoryQuantity.getQtyArrived()); } } if (count.compareTo(bigDecimal) >= 0) { return 2; } else { // 判断之前是否出过报告, 出过报告可以免检 int reportCount = ifsInventoryQuantityMapper.selectReportCountById(ifsInventoryId); if (reportCount > 0) { return 1; } } return 0; } /** * 报检可以新增报检信息 * @param ifsInventoryQuantity */ @Override public void addIfsInventoryQuantity(IfsInventoryQuantity ifsInventoryQuantity) { ifsInventoryQuantity.setIsSource(0); ifsInventoryQuantity.setState(0); ifsInventoryQuantity.setIsFinish(0); ifsInventoryQuantityMapper.insert(ifsInventoryQuantity); } /** * 铜单丝下单免检 * @param list * @param insOrder */ @Override @Transactional(rollbackFor = Exception.class) public int addRawCopperOrderExemptionOrder(List list, CopperInsOrderDto insOrder) { if (!insOrder.getOrderType().equals(InsOrderTypeConstants.ENTER_THE_FACTORY)) { throw new ErrorException("只有进厂检验才能免检"); } insOrder.setSendTime(LocalDateTime.now()); // 修改订单表直接为已检验 insOrder.setState(4); insOrder.setTypeSource(1); String code = "Y"; // 生成编号 String no = numberGenerator.generateNumberWithPrefix(3, "JCZX/NS-" + code + LimsDateUtil.resetDate(LocalDateTime.now()), InsOrder::getEntrustCode); insOrderMapper.insert(insOrder); // 主表 AtomicInteger count = new AtomicInteger(); list.forEach(a -> { count.getAndIncrement(); a.setId(null); a.setInsOrderId(insOrder.getId()); if (StrUtil.isEmpty(a.getSampleCode())) { // 如果只有一个样品就不需要拼接数字 if (list.size() != 1) { a.setSampleCode(no + "-" + count.get()); } else { a.setSampleCode(no); } } insSampleMapper.insert(a); if (!CollectionUtil.isEmpty(a.getInsProduct())) { throw new ErrorException("免检不需要填写检验项"); } }); // 添加原材料信息 IfsInventoryQuantity ifsInventoryQuantity = new IfsInventoryQuantity(); // 基本信息 ifsInventoryQuantity.setIsSource(0); ifsInventoryQuantity.setState(2); ifsInventoryQuantity.setIsInspect(1); ifsInventoryQuantity.setIsFinish(1); ifsInventoryQuantity.setIsCopper(1); ifsInventoryQuantity.setInspectStatus(1); ifsInventoryQuantity.setIsQuarter(0); 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.setExamineTime(LocalDateTime.now()); insOrder.setEntrustCode(no); insOrder.setIsExemption(1); insOrderMapper.updateById(insOrder); // 添加工时 addAuxiliary(insOrder, ifsInventoryQuantity); return insOrder.getId(); } @Override @Transactional(rollbackFor = Exception.class) public boolean concessionRelease(Long ifsInventoryId) { // 查询原材料信息 IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(ifsInventoryId); if (!ifsInventoryQuantity.getInspectStatus().equals(2)) { throw new ErrorException("不合格的原材料才能让步放行"); } // todo:需要判断oa流程是否是让步放行 String toLocation = insOrderService.moveRawMaterial(ifsInventoryQuantity); ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper() .set(IfsInventoryQuantity::getInspectStatus, 4) .set(IfsInventoryQuantity::getToLocation, toLocation) .eq(IfsInventoryQuantity::getId, ifsInventoryId)); return true; } /** * 原材料进厂撤销下单 * @param enterOrderId * @return */ @Override @Transactional(rollbackFor = Exception.class) public boolean repealEnterRawOrder(Integer enterOrderId) { // 查询订单 InsOrder order = insOrderMapper.selectById(enterOrderId); // 查询判断是否是铜单丝 IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(order.getIfsInventoryId()); if (ifsInventoryQuantity.getIsCopper() != null && ifsInventoryQuantity.getIsCopper().equals(1)) { // 铜单丝直接删除就行 ifsInventoryQuantityMapper.deleteById(order.getIfsInventoryId()); } else { ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper() .set(IfsInventoryQuantity::getState, 0) .set(IfsInventoryQuantity::getIsQuarter, 1) .eq(IfsInventoryQuantity::getId, order.getIfsInventoryId())); } insOrderService.update(Wrappers.lambdaUpdate() .eq(InsOrder::getId, enterOrderId) .set(InsOrder::getState, -1) .set(InsOrder::getEntrustCode, ""));// 撤销 // 清除之前的工时 auxiliaryOutputWorkingHoursMapper.delete(Wrappers.lambdaQuery() .eq(AuxiliaryOutputWorkingHours::getOrderId, enterOrderId)); // 清除之前报告 insReportService.remove(Wrappers.lambdaQuery() .eq(InsReport::getInsOrderId, enterOrderId)); return true; } /** * 原材料季度撤销下单 * @param quarterOrderId * @return */ @Override @Transactional(rollbackFor = Exception.class) public boolean repealQuarterRawOrder(Integer quarterOrderId) { // 查询订单 InsOrder order = insOrderMapper.selectById(quarterOrderId); Long count = insOrderMapper.selectCount(Wrappers.lambdaQuery() .eq(InsOrder::getIfsInventoryId, order.getIfsInventoryId()) .ne(InsOrder::getState, -1) .eq(InsOrder::getOrderType, InsOrderTypeConstants.ENTER_THE_FACTORY) .ne(InsOrder::getId, order.getId())); // 判断之前是否有进厂检验, 没有需要修改原材料信息 if (count == 0) { ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper() .set(IfsInventoryQuantity::getState, 0) .set(IfsInventoryQuantity::getIsQuarter, 1) .eq(IfsInventoryQuantity::getId, order.getIfsInventoryId())); } else { ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper() .set(IfsInventoryQuantity::getIsQuarter, 1) .eq(IfsInventoryQuantity::getId, order.getIfsInventoryId())); } insOrderService.update(Wrappers.lambdaUpdate() .eq(InsOrder::getId, quarterOrderId) .set(InsOrder::getState, -1) .set(InsOrder::getEntrustCode, ""));// 撤销 auxiliaryOutputWorkingHoursMapper.delete(Wrappers.lambdaQuery() .eq(AuxiliaryOutputWorkingHours::getOrderId, quarterOrderId)); // 清除之前报告 insReportService.remove(Wrappers.lambdaQuery() .eq(InsReport::getInsOrderId, quarterOrderId)); return true; } /** * 原材料报检全部信息导出 * @param ifsInventoryQuantityDto * @param response */ @Override public void rawAllExport(IfsInventoryQuantitySupplierDto ifsInventoryQuantityDto, HttpServletResponse response) throws UnsupportedEncodingException { // 判断是否是根据选择的导出 List ifsByOverList = new ArrayList<>(); if (StringUtils.isNotBlank(ifsInventoryQuantityDto.getIds())) { List ifsIds = StrUtil.split(ifsInventoryQuantityDto.getIds(), ","); ifsByOverList = standardTreeMapper.getIfsByIds(ifsIds); } else { String beginDeclareDate = ifsInventoryQuantityDto.getBeginDeclareDate(); String endDeclareDate = ifsInventoryQuantityDto.getEndDeclareDate(); ifsInventoryQuantityDto.setBeginDeclareDate(null); ifsInventoryQuantityDto.setEndDeclareDate(null); ifsInventoryQuantityDto.setIds(null); ifsByOverList = standardTreeMapper.getIfsByOverList(QueryWrappers.queryWrappers(ifsInventoryQuantityDto), beginDeclareDate, endDeclareDate); } for (IfsInventoryQuantitySupplierDto dto : ifsByOverList) { dto.setSendTimeString(dto.getSendTime() == null ? "" : dto.getSendTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); dto.setReceiverDateString(dto.getReceiverDate() == null ? "" : dto.getReceiverDate().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); dto.setDeclareDateString(dto.getDeclareDate() == null ? "" : dto.getDeclareDate().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); switch (dto.getInspectStatus()) { case 1: dto.setInspectStatusString("合格"); break; case 2: dto.setInspectStatusString("不合格"); // 查询不合格项 List unqualifiedList = insProductMapper.selectUnqualifiedList(dto.getEnterOrderId() == null ? dto.getQuarterOrderId() : dto.getEnterOrderId()); dto.setUnqualifiedItem(CollUtil.join(unqualifiedList, ",")); break; case 3: dto.setInspectStatusString("未下单"); break; case 4: dto.setInspectStatusString("让步放行"); break; case 0: dto.setInspectStatusString("检验中"); break; } } response.setContentType("application/vnd.ms-excel"); response.setCharacterEncoding("UTF-8"); // 这里URLEncoder.encode可以防止中文乱码 当然和easyexcel没有关系 String fileName = URLEncoder.encode("原材料检测信息导出", "UTF-8"); response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".xlsx"); try { //新建ExcelWriter ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream()).registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()).build(); //获取sheet0对象 WriteSheet mainSheet = EasyExcel.writerSheet(0, "原材料检测信息导出").head(IfsInventoryQuantitySupplierDto.class).build(); //向sheet0写入数据 传入空list这样只导出表头 excelWriter.write(ifsByOverList, mainSheet); //关闭流 excelWriter.finish(); } catch (IOException e) { throw new RuntimeException("导出失败"); } } /** * 原材料查询可以季度检验的内容 * @param page * @param ifsInventoryQuantityDto * @return */ @Override public IPage getIfsByQuarter(Page page, IfsInventoryQuantitySupplierDto ifsInventoryQuantityDto) { // todo: 只看我 String beginDeclareDate = ifsInventoryQuantityDto.getBeginDeclareDate(); String endDeclareDate = ifsInventoryQuantityDto.getEndDeclareDate(); ifsInventoryQuantityDto.setBeginDeclareDate(null); ifsInventoryQuantityDto.setEndDeclareDate(null); return standardTreeMapper.getIfsByQuarter(page, QueryWrappers.queryWrappers(ifsInventoryQuantityDto), beginDeclareDate, endDeclareDate); } /** * 提前入库 * @param ifsInventoryId * @return */ @Override public boolean advancedGodown(Long ifsInventoryId) { // 查询原材料信息 IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(ifsInventoryId); if (!ifsInventoryQuantity.getInspectStatus().equals(0) && !ifsInventoryQuantity.getInspectStatus().equals(3)) { throw new ErrorException("未检测完成数据才能提前入库"); } // todo:需要判断oa流程是否是让步放行 String toLocation = insOrderService.moveRawMaterial(ifsInventoryQuantity); ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper() .set(IfsInventoryQuantity::getInspectStatus, 1) .set(IfsInventoryQuantity::getIsFinish, 1) .set(IfsInventoryQuantity::getToLocation, toLocation) .eq(IfsInventoryQuantity::getId, ifsInventoryId)); return true; } @Override public void downloadTemplate(HttpServletResponse response) { response.reset(); try{ String fileName = "订单拆分导入模板" + ExcelTypeEnum.XLSX.getValue(); fileName = URLEncoder.encode(fileName, StandardCharsets.UTF_8.toString()); response.setContentType("application/vnd.ms-excel"); response.setHeader("Cache-Control", "no-cache"); response.setHeader("Content-Disposition", "attachment;filename=" + fileName); response.setHeader("Access-Control-Expose-Headers", "Content-Disposition"); //订单拆分导入模板文件 InputStream inputStream = this.getClass().getResourceAsStream("/static/split_order_import_template.xlsx"); IoUtil.copy(inputStream,response.getOutputStream()); inputStream.close(); }catch (Exception e){ e.printStackTrace(); throw new RuntimeException("模板下载失败"); } } @Override public Result importSplitOrderData(MultipartFile file,Long ifsId, HttpServletRequest request) { try { IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(ifsId); OrderSplitExcelListener listener = new OrderSplitExcelListener(ifsInventoryQuantity); EasyExcel.read(file.getInputStream(), listener).sheet().headRowNumber(2).doRead(); if(StringUtils.isNotBlank(listener.errorMsg)){ return Result.fail(201,listener.errorMsg); } return Result.success(listener.getDataList()); } catch (IOException e) { e.printStackTrace(); throw new RuntimeException("导入失败:"+e.getMessage()); } } @Override @Transactional(rollbackFor = Exception.class,isolation = Isolation.READ_COMMITTED) public boolean confirmSplitOrder(OrderSplitDTO orderSplitDTO) { //1.查询ifs订单信息 IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(orderSplitDTO.getIfsId()); if(Objects.isNull(ifsInventoryQuantity)){ throw new RuntimeException("未查询到该IFS订单信息"); } //2.对接ifs采购接收更改批号接口 //组装请求参数inAttr List newLotBathNo = new ArrayList<>();//新批号列表 Map inAttrMap = new HashMap<>(); inAttrMap.put("RECORD_ID",UUID.randomUUID().toString()); inAttrMap.put("SYSCODE","LIMS_NS"); inAttrMap.put("SYSMODEL","耐丝LIMS订单拆分"); List> batchInfoData = new ArrayList<>(); if(Objects.nonNull(orderSplitDTO.getSplitDetailList()) && !orderSplitDTO.getSplitDetailList().isEmpty()){ for (OrderSplitExcelData data : orderSplitDTO.getSplitDetailList()) { Map infoMap = new HashMap<>(); infoMap.put("ORDER_NO",ifsInventoryQuantity.getOrderNo()); infoMap.put("LINE_NO",ifsInventoryQuantity.getLineNo()); infoMap.put("RELEASE_NO",ifsInventoryQuantity.getReleaseNo()); infoMap.put("RECEIPT_NO",ifsInventoryQuantity.getReceiptNo()); infoMap.put("PART_NO",ifsInventoryQuantity.getPartNo()); infoMap.put("CONFIGURATION_ID",ifsInventoryQuantity.getConfigurationId()); infoMap.put("LOCATION_NO",ifsInventoryQuantity.getLocationNo()); infoMap.put("LOT_BATCH_NO",ifsInventoryQuantity.getLotBatchNo()); infoMap.put("NEW_LOT_BATCH_NO",data.getLotBatchNo()); newLotBathNo.add(data.getLotBatchNo()); infoMap.put("SERIAL_NO",ifsInventoryQuantity.getSerialNo()); infoMap.put("ENG_CHG_LEVEL",ifsInventoryQuantity.getEngChgLevel()); infoMap.put("WAIV_DEV_REJ_NO",ifsInventoryQuantity.getWaivDevRejNo()); infoMap.put("ACTIVITY_SEQ",ifsInventoryQuantity.getActivitySeq()); infoMap.put("QTY_TO_CHANGE",data.getQtyStock()); batchInfoData.add(infoMap); } } inAttrMap.put("BATCH_INFO", batchInfoData); String inAttr = JSONObject.toJSONString(inAttrMap); //调用ifs接口 Result result = ifsApiUtils.updateMoveReceiptLot(inAttr); if(result.getCode()!=200){ throw new RuntimeException("IFS采购接收更改批号请求异常："+result.getMessage()); } //更新主订单的抵达采购数量 BigDecimal purQtyInStore = orderSplitDTO.getSplitDetailList() .stream() .map(OrderSplitExcelData::getQtyStock) .reduce(BigDecimal::add).orElse(BigDecimal.ZERO); BigDecimal newPurQtyInStore = ifsInventoryQuantity.getPurQtyInStore().subtract(purQtyInStore); //如果拆分后，剩余的库存数量为0，则删除批号为*的订单信息 if(newPurQtyInStore.compareTo(BigDecimal.ZERO)==0){ ifsInventoryQuantityMapper.deleteById(ifsInventoryQuantity.getId()); }else{ ifsInventoryQuantityMapper.update(null,Wrappers.lambdaUpdate() .set(IfsInventoryQuantity::getPurQtyInStore,newPurQtyInStore) .set(IfsInventoryQuantity::getInvQtyInStore,newPurQtyInStore) .eq(IfsInventoryQuantity::getId,ifsInventoryQuantity.getId()) ); } //ifs更改批号接口调用成功，拉取新拆分的ifs订单并报检 Map map = new HashMap<>(); map.put("LOCATION_NO","1302"); map.put("STATE_DB","To be Inspected"); map.put("PART_NO",ifsInventoryQuantity.getPartNo()); map.put("ORDER_NO",ifsInventoryQuantity.getOrderNo()); map.put("LINE_NO",ifsInventoryQuantity.getLineNo()); map.put("RELEASE_NO",ifsInventoryQuantity.getReleaseNo()); map.put("RECEIPT_NO",ifsInventoryQuantity.getReceiptNo()); map.put("LOT_BATCH_NO",String.join(";",newLotBathNo)); insOrderService.getIfsOrder(map,true); //查询新拆分的订单信息 List splitOrderList = ifsInventoryQuantityMapper.selectList(Wrappers.lambdaQuery() .eq(IfsInventoryQuantity::getLocationNo, "1302") .eq(IfsInventoryQuantity::getStatusDb, "To be Inspected") .eq(IfsInventoryQuantity::getPartNo, ifsInventoryQuantity.getPartNo()) .eq(IfsInventoryQuantity::getOrderNo, ifsInventoryQuantity.getOrderNo()) .eq(IfsInventoryQuantity::getLineNo, ifsInventoryQuantity.getLineNo()) .eq(IfsInventoryQuantity::getReleaseNo, ifsInventoryQuantity.getReleaseNo()) .eq(IfsInventoryQuantity::getReceiptNo, ifsInventoryQuantity.getReceiptNo()) .in(IfsInventoryQuantity::getLotBatchNo, newLotBathNo) ); //执行报检操作 if(Objects.nonNull(splitOrderList) && !splitOrderList.isEmpty()){ List ids = splitOrderList.stream().map(IfsInventoryQuantity::getId).collect(Collectors.toList()); ids.add(ifsInventoryQuantity.getId()); this.inspectionReport(ids); } //勾选同步到MES，保存订单拆分记录 if(orderSplitDTO.getPushToMes()){ List collect = orderSplitDTO.getSplitDetailList().stream().map(m -> { IfsSplitOrderRecord record = new IfsSplitOrderRecord(); BeanUtil.copyProperties(m, record); record.setOrderNo(ifsInventoryQuantity.getOrderNo()); record.setLineNo(ifsInventoryQuantity.getLineNo()); record.setReleaseNo(ifsInventoryQuantity.getReleaseNo()); record.setReceiptNo(ifsInventoryQuantity.getReceiptNo()); return record; }).collect(Collectors.toList()); return ifsSplitOrderRecordService.saveBatch(collect); } return false; } /** * 添加工时 * @param insOrder * @param ifsInventoryQuantity */ private void addAuxiliary(InsOrder insOrder, IfsInventoryQuantity ifsInventoryQuantity) { AuxiliaryOutputWorkingHours auxiliaryOutputWorkingHours = new AuxiliaryOutputWorkingHours(); auxiliaryOutputWorkingHours.setInspectionItemClass(ifsInventoryQuantity.getUpdateBatchNo() + "免检");//检测项分类 auxiliaryOutputWorkingHours.setSample(insOrder.getEntrustCode());//样品编号 auxiliaryOutputWorkingHours.setOrderId(insOrder.getId());//订单id auxiliaryOutputWorkingHours.setOrderNo(insOrder.getEntrustCode());//非加班委托单号 // 免检默认2 auxiliaryOutputWorkingHours.setWorkTime(new BigDecimal("2"));//非加班工时 auxiliaryOutputWorkingHours.setAmount(1);//非加班数量 auxiliaryOutputWorkingHours.setOutputWorkTime((ObjectUtils.isNotEmpty(auxiliaryOutputWorkingHours.getOvertimeWorkTime()) ? auxiliaryOutputWorkingHours.getOvertimeWorkTime() : BigDecimal.ZERO).add(ObjectUtils.isNotEmpty(auxiliaryOutputWorkingHours.getWorkTime()) ? auxiliaryOutputWorkingHours.getWorkTime() : BigDecimal.ZERO));//产量工时 DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); DateTimeFormatter formatters = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); auxiliaryOutputWorkingHours.setDateTime(LocalDateTime.now().toLocalDate().atStartOfDay().format(formatters));//日期 LocalDateTime localDateTime = LocalDateTime.now(); DateTime parse = DateUtil.parse(localDateTime.format(formatter)); auxiliaryOutputWorkingHours.setWeekDay(getWeek(localDateTime.format(formatters)));//星期 auxiliaryOutputWorkingHours.setWeek(String.valueOf(DateUtil.weekOfYear(DateUtil.offsetDay(parse, 1))));//周次 auxiliaryOutputWorkingHours.setCheck(SecurityUtils.getUserId().intValue());//检测人 auxiliaryOutputWorkingHours.setPrice(new BigDecimal("1"));//单价 auxiliaryOutputWorkingHoursMapper.insert(auxiliaryOutputWorkingHours); } 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 "未知"; } } }