lims-ruoyi-after.git

			@@ -1,6 +1,8 @@
			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;
			@@ -8,14 +10,11 @@
			import com.alibaba.excel.ExcelWriter;
			import com.alibaba.excel.write.metadata.WriteSheet;
			import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy;
			import com.alibaba.excel.write.style.column.SimpleColumnWidthStyleStrategy;
			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.ObjectUtils;
			import com.baomidou.mybatisplus.core.toolkit.Wrappers;
			import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.ruoyi.basic.mapper.IfsInventoryQuantityMapper;
			import com.ruoyi.basic.mapper.StandardProductListMapper;
			@@ -26,16 +25,18 @@
			import com.ruoyi.common.core.domain.entity.User;
			import com.ruoyi.common.numgen.NumberGenerator;
			import com.ruoyi.common.utils.*;
			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.InsOrderPrintingVo;
			import com.ruoyi.inspect.vo.SampleDefectsFatherVo;
			import com.ruoyi.system.mapper.CustomMapper;
			import com.ruoyi.performance.pojo.AuxiliaryOutputWorkingHoursTemporary;
			import com.ruoyi.performance.service.AuxiliaryOutputWorkingHoursTemporaryService;
			import com.ruoyi.system.mapper.UserMapper;
			import lombok.AllArgsConstructor;
			import org.apache.commons.lang3.StringUtils;
			@@ -47,6 +48,7 @@
			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;
			@@ -70,18 +72,17 @@
			private InsSampleMapper insSampleMapper;
			private InsProductService insProductService;
			private InsProductMapper insProductMapper;
			private InsProductUserMapper insProductUserMapper;
			private InsSampleUserMapper insSampleUserMapper;
			private InsOrderStateMapper insOrderStateMapper;
			private InsOrderStateService insOrderStateService;
			private UserMapper userMapper;
			private IfsInventoryQuantityMapper ifsInventoryQuantityMapper;
			private CustomMapper customMapper;
			private final NumberGenerator<InsOrder> numberGenerator;
			private InsReportMapper insReportMapper;
			private InsUnqualifiedRetestProductMapper insUnqualifiedRetestProductMapper;
			private IfsApiUtils ifsApiUtils;
			private SpotCheckQuarterItemMapper spotCheckQuarterItemMapper;
			private StandardProductListMapper standardProductListMapper;
			private AuxiliaryOutputWorkingHoursTemporaryService auxiliaryOutputWorkingHoursTemporaryService;



			@@ -100,6 +101,11 @@
			}


			/**
			* 分配检验人
			*
			* @return
			*/
			@Override
			@Transactional(rollbackFor = Exception.class)
			public int upInsOrder(Integer orderId, Integer sampleId, String appointed, Integer userId, String sonLaboratory) {
			@@ -108,13 +114,15 @@
			insOrder.setAppointed(StringUtils.isNotEmpty(appointed) ? LocalDate.parse(appointed) : null);
			insOrder.setSendTime(LocalDateTime.now());
			insOrderMapper.updateById(insOrder);
			List<InsSample> insSamples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery().eq(InsSample::getInsOrderId, orderId).select(InsSample::getId));
			List<Integer> ids = insSamples.stream().map(a -> a.getId()).collect(Collectors.toList());
			List<InsSample> insSamples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery().eq(InsSample::getInsOrderId, orderId));
			List<Integer> ids = insSamples.stream().map(InsSample::getId).collect(Collectors.toList());
			List<InsProduct> insProducts = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery()
			.in(InsProduct::getInsSampleId, ids)
			.eq(InsProduct::getState, 1)
			.select(InsProduct::getSonLaboratory).groupBy(InsProduct::getSonLaboratory));
			for (InsProduct insProduct : insProducts) {

			// 批量添加检验任务状态表
			List<InsOrderState> insOrderStateList = insProducts.stream().map(insProduct -> {
			InsOrderState insOrderState = new InsOrderState();
			insOrderState.setInsOrderId(orderId);
			try {
			@@ -123,8 +131,10 @@
			throw new ErrorException("该检验单有未维护实验室的检验项目");
			}
			insOrderState.setInsState(0);
			insOrderStateMapper.insert(insOrderState);
			}
			return insOrderState;
			}).collect(Collectors.toList());
			insOrderStateService.saveBatch(insOrderStateList);

			if (userId != null) {
			InsSampleUser insSampleUser = new InsSampleUser();
			insSampleUser.setState(0);
			@@ -144,7 +154,89 @@
			spotCheckQuarterItem.setSamplingUser(user.getName());
			spotCheckQuarterItemMapper.updateById(spotCheckQuarterItem);
			}

			// 创建工时暂存
			// 缓存样品id, 编号map
			// addWorkingHoursTemporary(userId, insSamples, ids, order);

			return 1;
			}

			/**
			* 创建工时暂存
			* @param userId
			* @param insSamples
			* @param ids
			* @param order
			*/
			private void addWorkingHoursTemporary(Integer userId, List<InsSample> insSamples, List<Integer> ids, InsOrder order) {
			Map<Integer, String> sampleMap = insSamples.stream().collect(Collectors.toMap(InsSample::getId, InsSample::getSampleCode));
			List<InsProduct> insProductList = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery()
			.in(InsProduct::getInsSampleId, ids)
			.eq(InsProduct::getState, 1));
			List<AuxiliaryOutputWorkingHoursTemporary> outputWorkingHours = insProductList.stream().map(insProduct -> {
			AuxiliaryOutputWorkingHoursTemporary auxiliaryOutputWorkingHours = new AuxiliaryOutputWorkingHoursTemporary();
			auxiliaryOutputWorkingHours.setInspectionItemClass(insProduct.getInspectionItemClass());//检测项分类
			auxiliaryOutputWorkingHours.setInspectionItem(insProduct.getInspectionItem());//检测父项
			auxiliaryOutputWorkingHours.setInspectionItemSubclass(insProduct.getInspectionItemSubclass());//检测子项
			auxiliaryOutputWorkingHours.setSample(sampleMap.get(insProduct.getInsSampleId()));//样品编号
			auxiliaryOutputWorkingHours.setOrderId(order.getId());//订单id
			auxiliaryOutputWorkingHours.setOrderNo(order.getEntrustCode());//非加班委托单号
			auxiliaryOutputWorkingHours.setWorkTime(insProduct.getManHour());//非加班工时
			auxiliaryOutputWorkingHours.setAmount(1);//非加班数量
			auxiliaryOutputWorkingHours.setOutputWorkTime((ObjectUtils.isNotEmpty(auxiliaryOutputWorkingHours.getOvertimeWorkTime()) ? auxiliaryOutputWorkingHours.getOvertimeWorkTime() : BigDecimal.ZERO).add(ObjectUtils.isNotEmpty(auxiliaryOutputWorkingHours.getWorkTime()) ? auxiliaryOutputWorkingHours.getWorkTime() : BigDecimal.ZERO));//产量工时
			auxiliaryOutputWorkingHours.setManHourGroup(insProduct.getManHourGroup());//工时分组
			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(userId);//检测人
			auxiliaryOutputWorkingHours.setPrice(insProduct.getPrice());//单价
			auxiliaryOutputWorkingHours.setSampleId(insProduct.getInsSampleId());//样品id
			auxiliaryOutputWorkingHours.setInsProductId(insProduct.getId());//检验项id

			return auxiliaryOutputWorkingHours;
			}).collect(Collectors.toList());
			auxiliaryOutputWorkingHoursTemporaryService.saveBatch(outputWorkingHours);
			}

			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 "未知";
			}
			}

			@Override
			@@ -284,9 +376,11 @@
			.set(IfsInventoryQuantity::getInspectStatus, 0));
			}

			// 审核检验单
			upInsOrderOfState(insOrder);
			upInsOrder(insOrder.getId(), null, appointed != null ? appointed.toString() : null, SecurityUtils.getUserId().intValue(), "原材料");

			// 分配检验人
			upInsOrder(insOrder.getId(), null, appointed != null ? appointed.toString() : null, SecurityUtils.getUserId().intValue(), "原材料");

			// 根据零件号判断是否是辅材
			boolean isRaw = false;
			@@ -353,6 +447,9 @@
			if (StringUtils.isBlank(product.getAsk()) \|\| StringUtils.isBlank(product.getTell())) {
			throw new ErrorException("有检验项的要求值或要求描述为空, 请先去标准库配置要求值或要求描述");
			}
			if (StringUtils.isBlank(product.getSonLaboratory())) {
			throw new ErrorException("有检验项的的子实验室为绑定, 请先绑定子实验室");
			}
			insProductMapper.insert(product);
			}
			}
			@@ -377,6 +474,11 @@
			return map;
			}

			/**
			* 审核检验单
			* @param insOrder
			* @return
			*/
			@Override
			public int upInsOrderOfState(InsOrder insOrder) {
			insOrder.setExamineTime(LocalDateTime.now());
			@@ -399,7 +501,7 @@
			}
			// 生成编号
			String no = numberGenerator.generateNumberWithPrefix(3,
			"JCZX/ZB-" + code + LimsDateUtil.resetDate(LocalDateTime.now()),
			"JCZX/NS-" + code + LimsDateUtil.resetDate(LocalDateTime.now()),
			InsOrder::getEntrustCode);
			// 判断是否是季度检验, 是季度检验取消原材料季度检验下单
			if (InsOrderTypeConstants.QUARTERLY_TEST.equals(order.getOrderType())) {
			@@ -463,112 +565,12 @@
			return productDto2IPage;
			}

			@Override
			public IPage<CostStatisticsDto> costStatistics(IPage<CostStatisticsDto> page, CostStatisticsDto costStatisticsDto) {
			String dates = costStatisticsDto.getDates();
			String[] split = dates.replaceAll("\\[", "").replaceAll("]", "").replaceAll("\"", "").split(",");
			costStatisticsDto.setDates(null);

			//todo:仅看自己

			IPage<CostStatisticsDto> dtoIPage = insOrderMapper.selectCostStatistics(page, QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59"));
			List<CostStatisticsDto> collect = dtoIPage.getRecords().stream().map(dto -> {
			Set<String> uniqueTags = new HashSet<>();
			if (dto.getInspectionItem().contains(",")) {
			for (String s : dto.getInspectionItem().split(",")) {
			uniqueTags.add(s.split("@")[0]);
			}
			} else {
			uniqueTags.add(dto.getInspectionItem().split("@")[0]);
			}
			dto.setInspectionItem(uniqueTags.toString());
			return dto;
			}).collect(Collectors.toList());
			dtoIPage.setRecords(collect);
			return dtoIPage;
			}

			@Override
			public Map<String, Object> costStatistics2(CostStatisticsDto costStatisticsDto) {
			Map<String, Object> map = new HashMap<>();
			String dates = costStatisticsDto.getDates();
			String[] split = dates.replaceAll("\\[", "").replaceAll("]", "").replaceAll("\"", "").split(",");
			costStatisticsDto.setDates(null);
			List<CostStatisticsDto> costStatisticsDtos = insOrderMapper.selectCostStatistics2(QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59"));
			double totalPrice = costStatisticsDtos.stream()
			.filter(dto -> dto.getPrice() != null) // 过滤掉价格为 null 的对象
			.mapToDouble(value -> value.getPrice().doubleValue() * value.getNum())
			.sum();
			map.put("total", totalPrice);
			return map;
			}

			@Override
			public Map<String, Object> selectSampleDefects(Page page, String inspectionItems, String orderNumber) {
			List<SampleDefectsFatherVo> sampleDefectsFatherVos = insOrderMapper.selectSampleDefects(page, inspectionItems, orderNumber);
			Map<String, Object> map = new HashMap<>();
			map.put("records", sampleDefectsFatherVos);
			Long aLong = insOrderMapper.getCount(inspectionItems, orderNumber);
			map.put("total", aLong);
			return map;
			}

			@Override
			public int updateStatus(Integer id) {
			return insOrderMapper.updateStatus(id);
			}


			@Override
			public void export(CostStatisticsDto costStatisticsDto, HttpServletResponse response) throws IOException {
			//查询导出的费用统计数据
			String dates = costStatisticsDto.getDates();
			String[] split = dates.replaceAll("\\[", "").replaceAll("]", "").replaceAll("\"", "").split(",");
			costStatisticsDto.setDates(null);
			List<CostStatisticsDto> costStatisticsDtos = insOrderMapper.selectCostStatistics2(QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59"));
			costStatisticsDtos = costStatisticsDtos.stream().map(dto -> {
			Set<String> uniqueTags = new HashSet<>();
			if (dto.getInspectionItem().contains(",")) {
			for (String s : dto.getInspectionItem().split(",")) {
			uniqueTags.add(s.split("@")[0]);
			}
			} else {
			uniqueTags.add(dto.getInspectionItem().split("@")[0]);
			}
			dto.setInspectionItem(uniqueTags.toString());
			return dto;
			}).collect(Collectors.toList());

			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");
			Map<String, List<CostStatisticsDto>> groupByCompany =
			costStatisticsDtos.stream().filter(e -> StrUtil.isNotEmpty(e.getCompany()))
			.collect(Collectors.groupingBy(CostStatisticsDto::getCompany));
			try {
			// 新建ExcelWriter
			// 新建ExcelWriter
			ExcelWriter excelWriter =
			EasyExcel.write(response.getOutputStream())
			.registerWriteHandler(new SimpleColumnWidthStyleStrategy(25))
			.build();
			for (Map.Entry<String, List<CostStatisticsDto>> companyDataEntry : groupByCompany.entrySet()) {
			String sheetName = companyDataEntry.getKey();
			List<CostStatisticsDto> dataList = companyDataEntry.getValue();
			WriteSheet mainSheet = EasyExcel.writerSheet(sheetName)
			.head(CostStatisticsDto.class)
			.registerWriteHandler(new SimpleColumnWidthStyleStrategy(25))
			.build();
			excelWriter.write(dataList, mainSheet);
			}
			// 关闭流
			excelWriter.finish();
			} catch (IOException e) {
			throw new RuntimeException("导出失败");
			}
			}

			/**
			* 获取ifs库存信息
			@@ -652,7 +654,7 @@
			ifsInventoryQuantity.setIsSource(1);
			ifsInventoryQuantity.setState(0);

			IfsInventoryQuantity one = ifsInventoryQuantityMapper.selectOne(new LambdaQueryWrapper<IfsInventoryQuantity>()
			Long count = ifsInventoryQuantityMapper.selectCount(new LambdaQueryWrapper<IfsInventoryQuantity>()
			.eq(IfsInventoryQuantity::getOrderNo, ifsInventoryQuantity.getOrderNo())
			.eq(IfsInventoryQuantity::getLineNo, ifsInventoryQuantity.getLineNo())
			.eq(IfsInventoryQuantity::getReleaseNo, ifsInventoryQuantity.getReleaseNo())
			@@ -664,8 +666,7 @@
			.eq(IfsInventoryQuantity::getWaivDevRejNo, ifsInventoryQuantity.getWaivDevRejNo())
			.eq(IfsInventoryQuantity::getActivitySeq, ifsInventoryQuantity.getActivitySeq())
			);
			if(Objects.isNull(one)) {

			if(count == 0) {
			ifsInventoryQuantity.setIsFirst(0);
			// 查询产业链检测数据
			String industryChainAttrFields = IndustryChainUtils.getIndustryChainAttrFields(ifsInventoryQuantity.getOrderNo(),
			@@ -940,7 +941,8 @@
			// 查询标准树
			List<StandardProductList> standardProductLists = standardProductListMapper.selectList(Wrappers.<StandardProductList>lambdaQuery()
			.eq(StandardProductList::getStandardMethodListId, insProduct.getStandardMethodListId())
			.eq(StandardProductList::getTree, tree));
			.eq(StandardProductList::getTree, tree)
			.orderByAsc(StandardProductList::getSort));
			for (StandardProductList standardProductList : standardProductLists) {
			standardProductList.setId(null);
			}
			@@ -965,6 +967,7 @@
			product.setCreateUser(null);
			product.setUpdateTime(null);
			product.setUpdateUser(null);
			product.setSection(null);
			product.setInsSampleId(omitOrderProductDto.getInsSampleId());
			if (StringUtils.isBlank(product.getCableTag())) {
			product.setCableTag(null);
			@@ -1031,6 +1034,24 @@
			}
			}

			/**
			* 修改样品型号
			* @param insSample
			*/
			@Override
			public void updateSampleModel(InsSample insSample) {
			// 判断当前订单是否生成了报告, 生成了报告不能修改单号
			Long count = insReportMapper.selectCount(Wrappers.<InsReport>lambdaQuery()
			.eq(InsReport::getInsOrderId, insSample.getInsOrderId()));
			if (count > 0 ) {
			throw new ErrorException("当前订单已经生成了报告不能修改编号");
			}

			insSampleService.update(Wrappers.<InsSample>lambdaUpdate()
			.eq(InsSample::getId, insSample.getId())
			.set(InsSample::getModel, insSample.getModel()));
			}

			}