tx-lims-after.git

			@@ -3,7 +3,6 @@
			import cn.hutool.core.bean.BeanUtil;
			import cn.hutool.core.date.DateTime;
			import cn.hutool.core.date.DateUtil;
			import cn.hutool.core.lang.Console;
			import cn.hutool.core.lang.UUID;
			import cn.hutool.core.util.ObjectUtil;
			import cn.hutool.core.util.StrUtil;
			@@ -22,10 +21,11 @@
			import com.deepoove.poi.data.*;
			import com.deepoove.poi.data.style.*;
			import com.deepoove.poi.util.TableTools;
			import com.deepoove.poi.xwpf.WidthScalePattern;
			import com.yuanchu.mom.common.GetLook;
			import com.yuanchu.mom.common.PrintChina;
			import com.yuanchu.mom.dto.*;
			import com.yuanchu.mom.dto.ExcelDto;
			import com.yuanchu.mom.dto.InsOrderPlanDTO;
			import com.yuanchu.mom.dto.SampleProductDto;
			import com.yuanchu.mom.exception.ErrorException;
			import com.yuanchu.mom.mapper.*;
			import com.yuanchu.mom.pojo.*;
			@@ -34,27 +34,23 @@
			import com.yuanchu.mom.utils.MatrixToImageWriter;
			import com.yuanchu.mom.utils.QueryWrappers;
			import com.yuanchu.mom.utils.RedisUtil;
			import com.yuanchu.mom.vo.InsOrderPlanTaskSwitchVo;
			import com.yuanchu.mom.vo.InsOrderPlanVO;
			import com.yuanchu.mom.vo.ProductVo;
			import com.yuanchu.mom.vo.SampleVo;
			import com.yuanchu.mom.vo.*;
			import org.apache.commons.io.IOUtils;
			import org.apache.poi.xwpf.usermodel.*;
			import org.openxmlformats.schemas.wordprocessingml.x2006.main.CTTblWidth;
			import org.openxmlformats.schemas.wordprocessingml.x2006.main.STTblWidth;
			import org.springframework.beans.factory.annotation.Value;
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.annotation.Transactional;
			import org.springframework.web.multipart.MultipartFile;

			import javax.annotation.Resource;
			import javax.servlet.http.HttpServletRequest;
			import java.io.*;
			import java.math.BigInteger;
			import java.nio.file.Files;
			import java.nio.file.Paths;
			import java.text.SimpleDateFormat;
			import java.time.LocalDate;
			import java.time.LocalDateTime;
			import java.time.LocalTime;
			import java.time.format.DateTimeFormatter;
			import java.util.*;
			import java.util.concurrent.CompletableFuture;
			@@ -84,6 +80,10 @@
			private InsOrderStateMapper insOrderStateMapper;
			@Resource
			private InsProductMapper insProductMapper;
			@Resource
			private ShiftTimeMapper shiftTimeMapper;
			@Resource
			private PerformanceShiftMapper performanceShiftMapper;

			@Value("${wordUrl}")
			private String wordUrl;
			@@ -105,6 +105,9 @@

			@Resource
			AuxiliaryOutputWorkingHoursMapper auxiliaryOutputWorkingHoursMapper;

			@Resource
			AuxiliaryOutputWorkingHoursService auxiliaryOutputWorkingHoursService;

			@Resource
			private InformationNotificationService informationNotificationService;
			@@ -132,7 +135,6 @@

			@Resource
			private InsOrderFileMapper insOrderFileMapper;

			@Override
			public Map<String, Object> selectInsOrderPlanList(Page page, InsOrderPlanDTO insOrderPlanDTO) {
			Map<String, Object> map = new HashMap<>();
			@@ -158,7 +160,8 @@
			if (ObjectUtil.isNotEmpty(insOrderPlanDTO.getUserId())) {
			insOrderPlanDTO.setUserId(userId.longValue());
			}
			IPage<InsOrderPlanTaskSwitchVo> insOrderPage = insSampleMapper.inspectionOrderDetailsTaskSwitching(page, QueryWrappers.queryWrappers(insOrderPlanDTO), userId);
			String sonLaboratory = insOrderPlanDTO.getSonLaboratory();//试验室
			IPage<InsOrderPlanTaskSwitchVo> insOrderPage = insSampleMapper.inspectionOrderDetailsTaskSwitching(page, QueryWrappers.queryWrappers(insOrderPlanDTO), userId,sonLaboratory);
			map.put("body", insOrderPage);
			return map;
			}
			@@ -196,7 +199,7 @@
			}

			@Override
			public List<InsProduct> getInsProduct(Integer id, Integer type, String laboratory) {
			public List<InsProduct> getInsProduct(Integer id, Integer type, String laboratory, HttpServletRequest request) {
			List<InsProduct> insProducts = new ArrayList<>();
			switch (type) {
			case 0:
			@@ -209,6 +212,9 @@
			insProducts = insSampleMapper.getInsProduct3(id);
			break;
			}
			// 数采新增
			getDeviceMessage(insProducts, request);

			Set<Integer> set = new HashSet<>();
			Map<Integer, String> map2 = new HashMap<>();
			if (BeanUtil.isEmpty(insProducts)) return null;
			@@ -216,6 +222,33 @@
			return insProducts;
			}

			private List<InsProduct> getDeviceMessage(List<InsProduct> insProducts, HttpServletRequest request) {
			String ipAddress = request.getRemoteAddr();
			// 防止回环地址变为IPv6
			String ip = ipAddress.equals("0:0:0:0:0:0:0:1") ? "127.0.0.1" : ipAddress;
			insProducts.forEach(i -> {
			Map<String, Object> devices = baseMapper.getDeviceMessage(ip, i.getInspectionItem(), i.getInspectionItemSubclass(), i.getSampleType());
			if (ObjectUtils.isNotEmpty(devices) && ObjectUtils.isNotEmpty(devices.get("file_type")) && ObjectUtils.isNotEmpty(devices.get("collect_url"))) {
			InsProductResult insProductResult = i.getInsProductResult();
			if (ObjectUtils.isEmpty(insProductResult)) {
			insProductResult = new InsProductResult();
			}
			List<Object> list = new ArrayList<>();
			Map<Object, Object> hashMap = new HashMap<>();
			hashMap.put("v", devices.get("device_name"));
			list.add(hashMap);
			insProductResult.setEquipName(JSON.toJSON(list).toString());
			List<Object> listValue = new ArrayList<>();
			Map<Object, Object> hashMapValue = new HashMap<>();
			hashMapValue.put("v", devices.get("management_number"));
			listValue.add(hashMapValue);
			insProductResult.setEquipName(JSON.toJSON(list).toString());
			insProductResult.setEquipValue(JSON.toJSON(listValue).toString());
			i.setInsProductResult(insProductResult);
			}
			});
			return insProducts;
			}
			@Override
			public List<String> checkSubmitPlan(Integer orderId, String laboratory) {
			List<String> collect = new ArrayList<>();
			@@ -361,7 +394,8 @@
			.eq(InsProduct::getInspectionItemSubclass, inspectionItemSubclass)
			.eq(InsProduct::getInsFiberId, fiber.getId()));
			for (InsProduct insProduct : insProducts) {
			InsProductResult insProductResult = insProductResultMapper.selectOne(Wrappers.<InsProductResult>lambdaQuery().eq(InsProductResult::getInsProductId, insProduct.getId()));
			InsProductResult insProductResult = insProductResultMapper.selectOne(Wrappers.<InsProductResult>lambdaQuery()
			.eq(InsProductResult::getInsProductId, insProduct.getId()));
			ProductVo productVo = new ProductVo();
			productVo.setCode(insFiber.getCode());
			productVo.setColor(fiber.getColor());
			@@ -376,7 +410,7 @@
			.eq(InsProduct::getInspectionItemSubclass, "20℃(常温)")
			.eq(InsProduct::getInspectionItemClass, insProduct.getInspectionItemClass())
			.eq(InsProduct::getInsFiberId, fiber.getId())).getId() ));
			if (!insProductResult1.getComValue().equals("[]")) {
			if (ObjectUtils.isNotEmpty(insProductResult1) &&!insProductResult1.getComValue().equals("[]")) {
			insProduct.setComplue(insProductResult1.getComValue().split(":")[1].split("\"")[1]);
			}
			productVo.setInsProduct(insProduct);
			@@ -384,7 +418,8 @@
			}
			}
			}
			} else {
			}
			else {
			//如果套管下没有光纤带就只有光纤了
			List<InsFiber> insFiberList = insFiberMapper.selectList(Wrappers.<InsFiber>lambdaQuery().eq(InsFiber::getInsBushingId, insBushing.getId()));
			for (InsFiber fiber : insFiberList) {
			@@ -408,7 +443,7 @@
			.eq(InsProduct::getInspectionItemSubclass, "20℃(常温)")
			.eq(InsProduct::getInspectionItemClass, insProduct.getInspectionItemClass())
			.eq(InsProduct::getInsFiberId, fiber.getId())).getId() ));
			if (!insProductResult1.getComValue().equals("[]")) {
			if (ObjectUtils.isNotEmpty(insProductResult1) && !insProductResult1.getComValue().equals("[]")) {
			insProduct.setComplue(insProductResult1.getComValue().split(":")[1].split("\"")[1]);
			}
			productVo.setInsProduct(insProduct);
			@@ -438,6 +473,13 @@
			return map;
			}

			@Override
			public List<String> upPlanUser2(Integer orderId) {
			List<Integer> sampleId = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery().eq(InsSample::getInsOrderId, orderId)).stream().map(InsSample::getId).collect(Collectors.toList());
			List<String> sonLaboratory = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery().eq(InsProduct::getState, 1).in(InsProduct::getInsSampleId, sampleId)).stream().map(InsProduct::getSonLaboratory).distinct().collect(Collectors.toList());
			return sonLaboratory;
			}


			@Override
			public void saveInsContext(Map<String, Object> insContext) {
			@@ -455,6 +497,7 @@
			result = results.get(0);
			}
			result.setInsProductId(Integer.parseInt(k));
			InsProductResult insProductResult = insProductResultMapper.selectOne(Wrappers.<InsProductResult>lambdaQuery().eq(InsProductResult::getInsProductId, Integer.parseInt(k)));
			if (jo.get("insValue") != null) {
			JSONArray jsonArray = JSON.parseArray(JSON.toJSONString(jo.get("insValue")));
			List<Map<String, Object>> iv = new ArrayList<>();
			@@ -464,6 +507,7 @@
			map.put("v", JSON.parseObject(JSON.toJSONString(insValue.get("v"))).get("v"));
			map.put("r", JSON.toJSONString(insValue.get("r")));
			map.put("c", JSON.toJSONString(insValue.get("c")));
			map.put("w", insValue.get("w"));
			try {
			if ((insValue.get("u") == null \|\| insValue.get("u").equals("")) && StrUtil.isNotEmpty(JSON.parseObject(JSON.toJSONString(insValue.get("v"))).get("v").toString())) {
			map.put("u", userId + "");
			@@ -541,31 +585,76 @@
			//查询检验单信息
			InsOrder insOrder = insOrderMapper.selectById(insSampleMapper.selectById(insProduct.getInsSampleId()).getInsOrderId());
			//校验如果这个人这个检测项目已经添加过了则不需要再新增
			Long count = auxiliaryOutputWorkingHoursMapper.selectCount(Wrappers.<AuxiliaryOutputWorkingHours>lambdaQuery()
			.eq(AuxiliaryOutputWorkingHours::getCheck, userId)
			.eq(AuxiliaryOutputWorkingHours::getInspectionItem, insProduct.getInspectionItem())
			.eq(AuxiliaryOutputWorkingHours::getInspectionItemSubclass, insProduct.getInspectionItemSubclass())
			.eq(AuxiliaryOutputWorkingHours::getOrderNo, insOrder.getEntrustCode()));
			if (count == 0 && ObjectUtils.isNotEmpty(insProduct.getManHour())) {
			//添加每个人的产量工时,要判断当前时间是否是这个人的排班时间,如果不是则是加班
			AuxiliaryOutputWorkingHours auxiliaryOutputWorkingHours = new AuxiliaryOutputWorkingHours();
			auxiliaryOutputWorkingHours.setInspectionItem(insProduct.getInspectionItem());//检测父项
			auxiliaryOutputWorkingHours.setInspectionItemSubclass(insProduct.getInspectionItemSubclass());//检测子项
			auxiliaryOutputWorkingHours.setSample(insSampleMapper.selectById(insProduct.getInsSampleId()).getSampleCode());//样品编号
			auxiliaryOutputWorkingHours.setOrderNo(insOrder.getEntrustCode());//非加班委托单号
			auxiliaryOutputWorkingHours.setWorkTime(insProduct.getManHour());//非加班工时
			auxiliaryOutputWorkingHours.setAmount(1);//非加班数量
			auxiliaryOutputWorkingHours.setOutputWorkTime(insProduct.getManHour());//产量工时
			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);//检测人
			auxiliaryOutputWorkingHoursMapper.insert(auxiliaryOutputWorkingHours);
			//首先判断当前人的当前时间是否是排班时间内,如果不是就是加班
			LocalDateTime today = LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT);
			PerformanceShift performanceShift = performanceShiftMapper.selectOne(Wrappers.<PerformanceShift>lambdaQuery()
			.eq(PerformanceShift::getUserId, userId)
			.eq(PerformanceShift::getWorkTime, today));
			if (ObjectUtils.isNotEmpty(performanceShift)){
			ShiftTime shiftTime = shiftTimeMapper.selectOne(Wrappers.<ShiftTime>lambdaQuery().eq(ShiftTime::getShift, performanceShift.getShift()));
			if (ObjectUtils.isNotEmpty(shiftTime)){
			DateTimeFormatter forma = DateTimeFormatter.ofPattern("HH:mm");
			LocalTime now = LocalTime.now();
			LocalTime startTime = LocalTime.parse(shiftTime.getStartTime(), forma);
			LocalTime endTime = LocalTime.parse(shiftTime.getEndTime(), forma);
			// 检查当前时间是否在范围内（包括边界）
			boolean isWithinRange = !now.isBefore(startTime) && !now.isAfter(endTime);
			//加班
			AuxiliaryOutputWorkingHours count1 = auxiliaryOutputWorkingHoursMapper.selectOne(Wrappers.<AuxiliaryOutputWorkingHours>lambdaQuery()
			.eq(AuxiliaryOutputWorkingHours::getCheck, userId)
			.eq(AuxiliaryOutputWorkingHours::getInspectionItem, insProduct.getInspectionItem())
			.eq(AuxiliaryOutputWorkingHours::getInspectionItemSubclass, insProduct.getInspectionItemSubclass())
			.eq(AuxiliaryOutputWorkingHours::getOvertimeOrderNo, insOrder.getEntrustCode()));
			//非加班
			AuxiliaryOutputWorkingHours count2 = auxiliaryOutputWorkingHoursMapper.selectOne(Wrappers.<AuxiliaryOutputWorkingHours>lambdaQuery()
			.eq(AuxiliaryOutputWorkingHours::getCheck, userId)
			.eq(AuxiliaryOutputWorkingHours::getInspectionItem, insProduct.getInspectionItem())
			.eq(AuxiliaryOutputWorkingHours::getInspectionItemSubclass, insProduct.getInspectionItemSubclass())
			.eq(AuxiliaryOutputWorkingHours::getOrderNo, insOrder.getEntrustCode()));
			if (ObjectUtils.isNotEmpty(insProduct.getManHour())&& ObjectUtils.isEmpty(count2) && ObjectUtils.isEmpty(count1)) {
			AuxiliaryOutputWorkingHours auxiliaryOutputWorkingHours = new AuxiliaryOutputWorkingHours();
			if (isWithinRange) {
			//在时间内就是正常上班
			auxiliaryOutputWorkingHours.setInspectionItem(insProduct.getInspectionItem());//检测父项
			auxiliaryOutputWorkingHours.setInspectionItemSubclass(insProduct.getInspectionItemSubclass());//检测子项
			auxiliaryOutputWorkingHours.setSample(insSampleMapper.selectById(insProduct.getInsSampleId()).getSampleCode());//样品编号
			auxiliaryOutputWorkingHours.setOrderNo(insOrder.getEntrustCode());//非加班委托单号
			auxiliaryOutputWorkingHours.setWorkTime(insProduct.getManHour());//非加班工时
			auxiliaryOutputWorkingHours.setAmount(1);//非加班数量
			auxiliaryOutputWorkingHours.setOutputWorkTime((ObjectUtils.isNotEmpty(auxiliaryOutputWorkingHours.getOvertimeWorkTime())?auxiliaryOutputWorkingHours.getOvertimeWorkTime():0)+(ObjectUtils.isNotEmpty(auxiliaryOutputWorkingHours.getWorkTime())?auxiliaryOutputWorkingHours.getWorkTime():0));//产量工时
			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);//检测人
			} else {
			//加班
			auxiliaryOutputWorkingHours.setInspectionItem(insProduct.getInspectionItem());//检测父项
			auxiliaryOutputWorkingHours.setInspectionItemSubclass(insProduct.getInspectionItemSubclass());//检测子项
			auxiliaryOutputWorkingHours.setSample(insSampleMapper.selectById(insProduct.getInsSampleId()).getSampleCode());//样品编号
			auxiliaryOutputWorkingHours.setOvertimeOrderNo(insOrder.getEntrustCode());//加班委托单号
			auxiliaryOutputWorkingHours.setOvertimeWorkTime(insProduct.getManHour());//加班工时
			auxiliaryOutputWorkingHours.setOvertimeAmount(1);//加班数量
			auxiliaryOutputWorkingHours.setOutputWorkTime((ObjectUtils.isNotEmpty(auxiliaryOutputWorkingHours.getOvertimeWorkTime())?auxiliaryOutputWorkingHours.getOvertimeWorkTime():0)+(ObjectUtils.isNotEmpty(auxiliaryOutputWorkingHours.getWorkTime())?auxiliaryOutputWorkingHours.getWorkTime():0));//产量工时
			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);//检测人
			}
			if (ObjectUtils.isEmpty(insProductResult) && !result.getInsValue().equals("[]") \|\| (ObjectUtils.isNotEmpty(insProductResult) && !insProductResult.getInsValue().equals(result.getInsValue()) && !insProductResult.getInsValue().equals("[]"))) {
			auxiliaryOutputWorkingHoursMapper.insert(auxiliaryOutputWorkingHours);
			}
			}
			}
			}

			InsSample insSample = insSampleMapper.selectById(insProductMapper.selectById(insProduct.getId()).getInsSampleId());
			@@ -3465,7 +3554,7 @@
			insSampleUser.setInsSampleId(orderId);
			insSampleUser.setState(0);
			insSampleUser.setSonLaboratory(laboratory);
			insSampleUserMapper.insert(insSampleUser);
			insSampleUserMapper.insert(insSampleUser);
			/校验一下result表/
			CompletableFuture.supplyAsync(() -> {
			List<Integer> ips = insProducts.stream().map(InsProduct::getId).distinct().collect(Collectors.toList());