tx-lims-after.git

			@@ -47,10 +47,13 @@
			*/
			@Service
			@AllArgsConstructor
			@Transactional(rollbackFor = Exception.class)
			public class InsOrderServiceImpl extends ServiceImpl<InsOrderMapper, InsOrder>
			implements InsOrderService {

			private GetLook getLook;

			private RoleMapper roleMapper;

			private InsOrderMapper insOrderMapper;

			@@ -89,9 +92,9 @@
			Map<String, Integer> map1 = getLook.selectPowerByMethodAndUserId("selectInsOrderParameter");
			User user = userMapper.selectById(map1.get("userId"));//当前登录的人
			Integer roleId = user.getRoleId();
			//获取当前人所属实验室id
			String departLimsId = user.getDepartLimsId();
			String laboratory = null;
			//获取当前人所属实验室id
			/*String departLimsId = user.getDepartLimsId();
			if (ObjectUtils.isNotEmpty(departLimsId) && !departLimsId.equals("")) {
			String[] split = departLimsId.split(",");
			//查询对应架构名称(通信实验室,电力实验室,检测办)
			@@ -99,7 +102,7 @@
			if (departLims.contains("实验室")) {
			laboratory = departLims;
			}
			}
			}*/
			//判断是否是全部权限
			Power power = powerMapper.selectOne(Wrappers.<Power>lambdaQuery().eq(Power::getRoleId, roleId).eq(Power::getMenuMethod, "selectAllInsOrderParameter"));
			if (ObjectUtils.isEmpty(power)) {
			@@ -134,25 +137,13 @@
			insOrder.setAppointed(LocalDate.parse(appointed));
			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<InsProduct> insProducts = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery()
			.in(InsProduct::getInsSampleId, ids)
			.eq(InsProduct::getState, 1)
			// .isNull(InsProduct::getInsFibersId)
			// .isNull(InsProduct::getInsFiberId)
			.select(InsProduct::getSonLaboratory).groupBy(InsProduct::getSonLaboratory));
			for (InsProduct insProduct : insProducts) {
			InsOrderState insOrderState = new InsOrderState();
			insOrderState.setInsOrderId(orderId);
			try {
			insOrderState.setLaboratory(insProduct.getSonLaboratory());
			} catch (NullPointerException e) {
			throw new ErrorException("该检验单有未维护实验室的检验项目");
			}
			insOrderState.setInsState(0);
			insOrderStateMapper.insert(insOrderState);
			}
			//修改成只给当前选择的试验室下发单子
			InsOrderState insOrderState = new InsOrderState();
			insOrderState.setInsOrderId(orderId);
			insOrderState.setLaboratory(sonLaboratory);
			insOrderState.setInsState(0);
			insOrderStateMapper.insert(insOrderState);
			//这里是在给分配的指定的人和试验室下发检验人
			if (userId != null) {
			InsSampleUser insSampleUser = new InsSampleUser();
			insSampleUser.setState(0);
			@@ -171,22 +162,22 @@
			//判断选择的委托单位与制单人的委托单位是否一致
			Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId");
			String company = userMapper.selectById(userId).getCompany();
			if (!company.equals(insOrder.getCompanyId()+"")) {
			if (!company.equals(insOrder.getCompanyId() + "")) {
			//如果不一致那么委托人字段必填
			if (ObjectUtils.isEmpty(insOrder.getPrepareUser())){
			if (ObjectUtils.isEmpty(insOrder.getPrepareUser())) {
			throw new ErrorException("委托人不能为空");
			}
			}else {
			} else {
			//如果一致,那么制单人就是委托人
			insOrder.setPrepareUser(insOrder.getCustom());
			}
			//客户代号
			Custom custom = customMapper.selectById(insOrder.getCompanyId());
			String code = custom.getCode2();
			if (!custom.getCompany().equals(insOrder.getCompany())){
			if (!custom.getCompany().equals(insOrder.getCompany())) {
			Custom one = customMapper.selectOne(Wrappers.<Custom>lambdaQuery().eq(Custom::getCompany, insOrder.getCompany()));
			insOrder.setCompanyId(one.getId());
			code=one.getCode2();
			code = one.getCode2();
			}
			//实验室编号
			String code2 = baseMapper.selLaboratoryCode(insOrder.getLaboratory());
			@@ -203,65 +194,11 @@
			a.setId(null);
			a.setInsOrderId(insOrder.getId());
			if (StrUtil.isEmpty(a.getSampleCode())) {
			a.setSampleCode(giveCode.split("-")[2] + "-" + count.get());
			a.setSampleCode("TX(WYQJ)-" + giveCode.split("-")[2] + "-" + count.get());
			}
			insSampleMapper.insert(a);
			if (ObjectUtil.isNotEmpty(a.getInsProduct())) {
			addInsProductMethod(a.getId(), a.getInsProduct(), null, 0, false);
			if (ObjectUtil.isNotEmpty(a.getBushing())) {
			for (BushingDto bushingDto : a.getBushing()) {
			bushingDto.setInsSampleId(a.getId());
			insBushingMapper.insert(bushingDto);
			//光纤不为空
			if (bushingDto.getFiber().size() != 0) {
			for (FiberDto fiberDto : bushingDto.getFiber()) {
			fiberDto.setInsBushingId(bushingDto.getId());
			insFiberMapper.insert(fiberDto);
			addInsProductMethod(a.getId(), a.getInsProduct(), fiberDto.getId(), 2, true);
			addInsProductMethod(a.getId(), fiberDto.getProductList(), fiberDto.getId(), 2, false);
			}
			}
			//光纤带不为空
			else if ( bushingDto.getFibers().size()!=0){
			for (FibersDto fibersDto : bushingDto.getFibers()) {
			fibersDto.setInsBushingId(bushingDto.getId());
			fibersDto.setCode(this.giveCode.giveCode("", "ins_fibers", "", "yyMMdd"));
			insFibersMapper.insert(fibersDto);
			for (FiberDto fiberDto : fibersDto.getFiber()) {
			fiberDto.setInsFibersId(fibersDto.getId());
			insFiberMapper.insert(fiberDto);
			addInsProductMethod(a.getId(), a.getInsProduct(), fiberDto.getId(), 2, true);
			addInsProductMethod(a.getId(), fiberDto.getProductList(), fiberDto.getId(), 2, false);
			}
			//addInsProductMethod(a.getId(), a.getInsProduct(), fibersDto.getId(), 1);
			addInsProductMethod(a.getId(), fibersDto.getProductList(), fibersDto.getId(), 1, false);
			}
			}
			//都为空只配置了套管这种情况只限于项目是含有松套管的
			else {
			String collect = a.getInsProduct().stream().map(InsProduct::getInspectionItem).distinct().collect(Collectors.joining(","));
			if (collect.contains("松套管")){
			//获取检验项目中包含松套管的检验项目
			List<InsProduct> products = a.getInsProduct().stream().filter(insProduct -> insProduct.getInspectionItem().contains("松套管")).collect(Collectors.toList());
			for (InsProduct product : products) {
			product.setInsBushId(bushingDto.getId());
			product.setId(null);
			product.setCreateTime(null);
			product.setCreateUser(null);
			product.setUpdateTime(null);
			product.setUpdateUser(null);
			product.setInsSampleId(a.getId());
			if (product.getInspectionItemSubclass() == null) {
			product.setInspectionItemSubclass("");
			}
			insProductMapper.insert(product);
			}
			}else {
			throw new ErrorException("样品的光纤配置信息里面没有配置光纤带信息也没有光纤信息,请重新配置保存再提交下单!!!");
			}
			}
			}
			}
			}
			if (ObjectUtil.isNotEmpty(a.getInsulating())) {
			List<InsProduct> ip2 = new ArrayList<>();
			@@ -336,6 +273,11 @@
			} catch (Exception e) {
			}
			}
			//通信:如果是C类订单无需审核直接通过
			if (insOrder.getOrderType().equals("C")) {
			insOrder.setState(1);
			upInsOrderOfState(insOrder);
			}
			return insOrder.getId();
			}

			@@ -343,150 +285,33 @@
			InsOrder insOrder = insOrderMapper.selectById(insSampleMapper.selectById(sampleId).getInsOrderId());
			String name = insSampleMapper.selMethodById(sampleId);
			for (InsProduct product : productList) {
			if (product.getInspectionItem().contains("松套管")){
			continue;
			}
			if (product.getState() == 1 && !product.getInspectionItem().equals("光纤接头损耗")) {
			//判断光缆的温度循环项目添加
			if (insOrder.getSampleType().equals("光缆") && product.getInspectionItem().equals("温度循环") && type != 0) {
			//判断选择的标准方法是委托要求还是其他标准方法
			if (!name.equals("委托要求")) {
			//判断标准方法的温度循环的要求描述是否有填写
			if (ObjectUtils.isEmpty(product.getTell()) \|\| product.getTell().equals("")) {
			throw new ErrorException("光缆的温度循环的要求描述为空,需要在标准库配置要求描述!!!");
			} else {
			//解析(温度范围：20℃，-40℃，65℃；保温时间：12h；循环次数：2次；光纤（1310nm，1550nm）附加衰减不大于0.03dB/km)
			String tell = product.getTell().replace("）", ")")
			.replace("(", "（")
			.replace(")", "）")
			.replace("，", ",")
			.replace("：", ":")
			.replace("；", ";")
			.replace("不大于", "≤")
			.replace("不小于", "≥")
			.replace("大于", ">")
			.replace("小于", "<")
			.replace("等于", "=");
			String[] message=null;
			String[] nm=null;
			String ask=null;
			String count=null;
			try {
			String[] strings = tell.split(";");
			//温度
			String temperature = strings[0];
			String[] split = temperature.split(":");
			message = split[1].split(",");
			//循环次数
			count = strings[2].split(":")[1].split("次")[0];
			//光纤项目和要求值
			String string = strings[3];
			nm = string.split("（")[1].split("）")[0].split(",");
			ask = string.split("衰减")[1].split("dB")[0];
			}catch (Exception e){
			throw new ErrorException("温度循环的要求描述格式异常,请参照温度范围：20℃，-40℃，65℃；保温时间：12h；循环次数：2次；光纤（1310nm，1550nm）附加衰减不大于0.03dB/km");
			}
			//拼接
			String s="";
			for (int i = 0; i < nm.length; i++) {
			s+= "20℃(常温)," + nm[i] + ",null;";
			for (int j = 0; j < message.length; j++) {
			s+= message[j] + "," + nm[i] + "," + ask + ";" ;
			}
			}
			s+=count;
			product.setAsk(s);
			insProductMapper.updateById(product);
			dealWithTemperatureLoop(type,id,sampleId,product);
			}
			if (!is) {
			switch (type) {
			case 1:
			product.setInsFibersId(id);
			break;
			case 2:
			product.setInsFiberId(id);
			break;
			}
			else {
			//20℃(常温),1310nm,null;-40℃,1310nm,≤0.2;75℃,1310nm,<0.3;20℃,1310nm,≤0.1;20℃(常温),1550nm,null;-40℃,1550nm,≤0.2;75℃,1550nm,<0.3;20℃,1550nm,≤0.1;3
			dealWithTemperatureLoop(type,id,sampleId,product);
			}
			}
			//判断热循环项目的添加和温升试验项目的添加
			else if (product.getInspectionItem().equals("热循环") \|\| product.getInspectionItem().equals("温升试验")) {
			List<InsProduct> insProductess = new ArrayList<>();
			product.setId(null);
			product.setCreateTime(null);
			product.setCreateUser(null);
			product.setUpdateTime(null);
			product.setUpdateUser(null);
			product.setInsSampleId(sampleId);
			insProductess.add(product);
			List<InsProduct> insProductes = new ArrayList<>();
			List<InsProduct> insProducts = new ArrayList<>();
			String[] strings = product.getAsk().split(";");
			//循环次数
			int count = Integer.parseInt(strings[strings.length - 1]);
			for (int i = 0; i < strings.length - 1; i++) {
			String[] split = strings[i].split(",");
			InsProduct insProduct = new InsProduct();
			insProduct.setInspectionItem("1");//检验父项--循环次数
			insProduct.setInspectionItemSubclass(split[0]);//检验子项--环境温度/导线温度/耐张温度/接续温度
			insProduct.setInspectionItemSubclassEn(split[1]);//检验子项英文--环境温度/导线温度/耐张温度/接续温度
			insProduct.setAsk(null);//检验要求
			insProduct.setTell(null);//检验描述
			insProduct.setInsSampleId(sampleId);
			insProduct.setState(1);
			insProduct.setFactory(product.getFactory());
			insProduct.setLaboratory(product.getLaboratory());
			insProduct.setSampleType(product.getSampleType());
			insProduct.setSample(product.getSample());
			insProduct.setModel(product.getModel());
			insProduct.setSonLaboratory(product.getSonLaboratory());
			insProduct.setUnit("℃");//单位
			insProduct.setManHourGroup(product.getManHourGroup());
			insProduct.setInspectionItemType("0");
			insProduct.setInspectionValueType("1");
			if (product.getInspectionItem().equals("热循环")) {
			insProduct.setInspectionItemClass("直流电阻");//检验子子项--直流电阻
			insProduct.setInspectionItemClassEn("DC resistance");//检验子子项英文--直流电阻
			insProduct.setUnit("Ω/km");//单位
			}
			insProducts.add(insProduct);
			insProductes.add(insProduct);
			insProductess.add(insProduct);
			if (product.getInspectionItemSubclass() == null) {
			product.setInspectionItemSubclass("");
			}
			//热循环才有多次循环次数
			if (count > 1) {
			//循环超过1次
			for (int j = 2; j <= count; j++) {
			for (InsProduct insProduct : insProductes) {
			InsProduct insProduct1 = new InsProduct();
			BeanUtils.copyProperties(insProduct, insProduct1);
			insProduct1.setInspectionItem(j + "");//循环次数
			insProductess.add(insProduct1);
			}
			}
			}
			insProductService.saveBatch(insProductess);
			}
			else {
			if (!is) {
			switch (type) {
			case 1:
			product.setInsFibersId(id);
			break;
			case 2:
			product.setInsFiberId(id);
			break;
			}
			product.setId(null);
			product.setCreateTime(null);
			product.setCreateUser(null);
			product.setUpdateTime(null);
			product.setUpdateUser(null);
			product.setInsSampleId(sampleId);
			if (product.getInspectionItemSubclass() == null) {
			product.setInspectionItemSubclass("");
			}
			insProductMapper.insert(product);
			}
			insProductMapper.insert(product);
			}
			}
			}
			}

			//温度循环的处理
			private void dealWithTemperatureLoop(Integer type, Integer id,Integer sampleId,InsProduct product) {
			private void dealWithTemperatureLoop(Integer type, Integer id, Integer sampleId, InsProduct product) {
			List<InsProduct> insProductes = new ArrayList<>();
			List<InsProduct> insProducts = new ArrayList<>();
			String[] strings = product.getAsk().split(";");
			@@ -568,23 +393,102 @@
			code = "";
			}
			Custom custom = customMapper.selectById(order.getCompanyId());
			System.out.println("============="+custom.getCompany());
			System.out.println("-------------"+order.getCompany());
			System.out.println("=============" + custom.getCompany());
			System.out.println("-------------" + order.getCompany());
			String code2 = custom.getCode2();
			if (!custom.getCompany().equals(order.getCompany())){
			if (!custom.getCompany().equals(order.getCompany())) {
			Custom one = customMapper.selectOne(Wrappers.<Custom>lambdaQuery().eq(Custom::getCompany, order.getCompany()));
			insOrder.setCompanyId(one.getId());
			code2=one.getCode2();
			code2 = one.getCode2();
			}
			insOrder.setEntrustCode(giveCode.giveCode2("JCZX/" + code + "-" + code2 + "-", insOrder.getCompanyId(), insOrder.getLaboratory(), "ins_order", "", "yyMM"));
			/审核通过之后还需要判断该样品是否在库/
			//如果在库,系统查询站点任务分布情况,将检验任务下发至最少的站台
			List<InsSample> insSamples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery()
			.eq(InsSample::getInsOrderId, insOrder.getId()).select(InsSample::getId));
			List<Integer> ids = insSamples.stream().map(a -> a.getId()).collect(Collectors.toList());
			List<InsProduct> insProducts = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery()
			.eq(InsProduct::getState, 1)
			.in(InsProduct::getInsSampleId, ids));
			List<String> collect = insProducts.stream().map(InsProduct::getSonLaboratory).distinct().collect(Collectors.toList());
			//要判断剩余试验室中哪个最空闲就安排给哪个
			Map<String, Long> dataCounts = new HashMap<>();
			for (String sonLaboratory : collect) {
			Long count = insOrderStateMapper.selectCount(Wrappers.<InsOrderState>lambdaQuery()
			.eq(InsOrderState::getLaboratory, sonLaboratory)
			.ne(InsOrderState::getInsState, 4)
			.ne(InsOrderState::getInsState, 5)
			.ne(InsOrderState::getInsState, 6));
			dataCounts.put(sonLaboratory, count);
			}
			// 查找数据量最少的元素
			String minElement = null;
			Long minCount = Long.MAX_VALUE;
			for (Map.Entry<String, Long> entry : dataCounts.entrySet()) {
			if (entry.getValue() < minCount) {
			minCount = entry.getValue();
			minElement = entry.getKey();
			}
			}
			int day = insProductService.selectOrderManDay(insOrder.getId());//预计完成时间
			upInsOrder(insOrder.getId(),null,LocalDateTime.now().plusHours(day).format(DateTimeFormatter.ofPattern("yyyy-MM-dd")),null,minElement);
			//如果不在库,暂不下发
			}
			return insOrderMapper.updateById(insOrder);
			}

			@Override
			public int upInsOrderOfState2(InsOrder insOrder) {
			InsOrder order = insOrderMapper.selectById(insOrder.getId());
			//获取当前人
			Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId");
			//获取当前人的角色
			String roleName = roleMapper.selectById(userMapper.selectById(userId).getRoleId()).getName();
			//判断是检测中心主任/研发部经理/技术负责人
			switch (roleName) {
			case "检测中心主任":
			order.setCheckState1(insOrder.getState());
			order.setCheckState1User(userId);
			break;
			case "研发部经理":
			order.setCheckState2(insOrder.getState());
			order.setCheckState2User(userId);
			break;
			case "技术负责人":
			order.setCheckState3(insOrder.getState());
			order.setCheckState3User(userId);
			break;
			default:
			throw new ErrorException("当前登录用户的角色不是检测中心主任/研发部经理/技术负责人,无法进行审核");
			}
			insOrderMapper.updateById(order);
			//查询该订单是A类还是B类
			if (order.getOrderType().equals("A")) {
			//如果是A类,1和2和3都审核通过这个单子就审核通过
			if (order.getCheckState1() == 1 && order.getCheckState2() == 1 && order.getCheckState3() == 1) {
			order.setState(1);
			upInsOrderOfState(order);
			} else if (order.getCheckState1() == 2 \|\| order.getCheckState2() == 2 \|\| order.getCheckState3() == 2){
			order.setState(2);
			upInsOrderOfState(order);
			}
			} else if (order.getOrderType().equals("B")) {
			//如果是B类,1和2审核通过后这个单子就审核通过
			if (order.getCheckState1() == 1 && order.getCheckState2() == 1 ) {
			order.setState(1);
			upInsOrderOfState(order);
			} else if (order.getCheckState1() == 2 \|\| order.getCheckState2() == 2 ){
			order.setState(2);
			upInsOrderOfState(order);
			}
			}
			return 1;
			}

			@Override
			public Map<String, Object> getInsOrderAndSample(Integer id, String laboratory) {
			Map<String, Object> map = new HashMap<>();
			InsOrder insOrder = insOrderMapper.selectById(id);
			InsOrder insOrder = insOrderMapper.selectById2(id);
			List<SampleProductDto> list = insSampleMapper.getInsOrderAndSample(id, laboratory);
			for (SampleProductDto sampleProductDto : list) {
			List<Integer> ids = sampleProductDto.getInsProduct().stream().map(InsProduct::getId).collect(Collectors.toList());
			@@ -608,19 +512,19 @@
			public Map<String, Object> selectSampleAndProductByOrderId(IPage<SampleProductDto2> page, SampleProductDto2 sampleProductDto) {
			Map<String, Object> map = new HashMap<>();
			map.put("head", PrintChina.printChina(SampleProductDto2.class));
			IPage<SampleProductDto2> productDto2IPage = insOrderMapper.selectSampleAndProductByOrderId(page, QueryWrappers.queryWrappers(sampleProductDto).orderByAsc("inspection_item"),sampleProductDto.getId());
			IPage<SampleProductDto2> productDto2IPage = insOrderMapper.selectSampleAndProductByOrderId(page, QueryWrappers.queryWrappers(sampleProductDto).orderByAsc("inspection_item"), sampleProductDto.getId());
			for (SampleProductDto2 record : productDto2IPage.getRecords()) {
			InsProductUser insProductUser = insProductUserMapper.selectOne(Wrappers.<InsProductUser>lambdaQuery()
			.eq(InsProductUser::getInsProductId, record.getInsProductId())
			.orderByDesc(InsProductUser::getCreateTime)
			.last("limit 1"));
			if (ObjectUtils.isNotEmpty(insProductUser)){
			if (ObjectUtils.isNotEmpty(insProductUser)) {
			record.setCheckName(userMapper.selectById(insProductUser.getCreateUser()).getName());
			DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
			record.setCheckTime(insProductUser.getCreateTime().format(formatter));
			}
			}
			map.put("body",productDto2IPage);
			map.put("body", productDto2IPage);
			return map;
			}