|  |  |  | @ -195,12 +195,13 @@ public class CtqyyClient extends CommonHttpClient { | 
			
		
	
		
			
				
					|  |  |  |  |     /** | 
			
		
	
		
			
				
					|  |  |  |  |      * 器械从三方拉取 | 
			
		
	
		
			
				
					|  |  |  |  |      * 药品从视图拉取 | 
			
		
	
		
			
				
					|  |  |  |  |      * | 
			
		
	
		
			
				
					|  |  |  |  |      * @param udiwmsProductRequest | 
			
		
	
		
			
				
					|  |  |  |  |      * @return | 
			
		
	
		
			
				
					|  |  |  |  |      */ | 
			
		
	
		
			
				
					|  |  |  |  |     @Override | 
			
		
	
		
			
				
					|  |  |  |  |     public BaseResponse getProducts(UdiwmsProductRequest udiwmsProductRequest) { | 
			
		
	
		
			
				
					|  |  |  |  |         if(udiwmsProductRequest.getProductType().equals(Constants.PRODUCT_TYPE_DEVICE)){ | 
			
		
	
		
			
				
					|  |  |  |  |         if (udiwmsProductRequest.getProductType().equals(Constants.PRODUCT_TYPE_DEVICE)) { | 
			
		
	
		
			
				
					|  |  |  |  |             CtqyyRequest ctqyyRequest = new CtqyyRequest(); | 
			
		
	
		
			
				
					|  |  |  |  |             ctqyyRequest.setMsgHeader(getMsgHeader("getMaterialDict")); | 
			
		
	
		
			
				
					|  |  |  |  |             ctqyyRequest.setMsgBody(JSONUtil.toJsonStr(udiwmsProductRequest)); | 
			
		
	
	
		
			
				
					|  |  |  | @ -231,16 +232,16 @@ public class CtqyyClient extends CommonHttpClient { | 
			
		
	
		
			
				
					|  |  |  |  |                 log.error("异常信息:{}", e); | 
			
		
	
		
			
				
					|  |  |  |  |                 return ResultVOUtils.error(500, "网络错误,或远程服务器异常无法返回正确结果(" + response + ")"); | 
			
		
	
		
			
				
					|  |  |  |  |             } | 
			
		
	
		
			
				
					|  |  |  |  |         }else if(udiwmsProductRequest.getProductType().equals(Constants.PRODUCT_TYPE_DRUG)){ | 
			
		
	
		
			
				
					|  |  |  |  |         } else if (udiwmsProductRequest.getProductType().equals(Constants.PRODUCT_TYPE_DRUG)) { | 
			
		
	
		
			
				
					|  |  |  |  |             LambdaQueryWrapper<PhysicDictEntity> wrapper = new LambdaQueryWrapper(); | 
			
		
	
		
			
				
					|  |  |  |  |             //补充其他查询条件
 | 
			
		
	
		
			
				
					|  |  |  |  |             wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getCode()),PhysicDictEntity::getPhysicCode,udiwmsProductRequest.getCode()); | 
			
		
	
		
			
				
					|  |  |  |  |             wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getName()),PhysicDictEntity::getPhysicName,udiwmsProductRequest.getName()); | 
			
		
	
		
			
				
					|  |  |  |  |             wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getRegisterNo()),PhysicDictEntity::getPhysicNo,udiwmsProductRequest.getRegisterNo()); | 
			
		
	
		
			
				
					|  |  |  |  |             IPage<PhysicDictEntity> page = physicDictMapper.selectPage(new Page<PhysicDictEntity>(udiwmsProductRequest.getPage(),udiwmsProductRequest.getLimit()),wrapper); | 
			
		
	
		
			
				
					|  |  |  |  |             wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getCode()), PhysicDictEntity::getPhysicCode, udiwmsProductRequest.getCode()); | 
			
		
	
		
			
				
					|  |  |  |  |             wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getName()), PhysicDictEntity::getPhysicName, udiwmsProductRequest.getName()); | 
			
		
	
		
			
				
					|  |  |  |  |             wrapper.eq(StrUtil.isNotBlank(udiwmsProductRequest.getRegisterNo()), PhysicDictEntity::getPhysicNo, udiwmsProductRequest.getRegisterNo()); | 
			
		
	
		
			
				
					|  |  |  |  |             IPage<PhysicDictEntity> page = physicDictMapper.selectPage(new Page<PhysicDictEntity>(udiwmsProductRequest.getPage(), udiwmsProductRequest.getLimit()), wrapper); | 
			
		
	
		
			
				
					|  |  |  |  |             List<PhysicDictEntity> physicDictEntities = page.getRecords(); | 
			
		
	
		
			
				
					|  |  |  |  |             List<ThrProductsEntity> thrProductsEntityList = null; | 
			
		
	
		
			
				
					|  |  |  |  |             if(CollUtil.isNotEmpty(physicDictEntities)){ | 
			
		
	
		
			
				
					|  |  |  |  |             if (CollUtil.isNotEmpty(physicDictEntities)) { | 
			
		
	
		
			
				
					|  |  |  |  |                 //数据处理以thr_products 返回
 | 
			
		
	
		
			
				
					|  |  |  |  |                 thrProductsEntityList = physicDictEntities.stream().map(dict -> { | 
			
		
	
		
			
				
					|  |  |  |  |                     ThrProductsEntity products = new ThrProductsEntity(); | 
			
		
	
	
		
			
				
					|  |  |  | @ -258,7 +259,7 @@ public class CtqyyClient extends CommonHttpClient { | 
			
		
	
		
			
				
					|  |  |  |  |             return ResultVOUtils.success(pageSimpleResponse); | 
			
		
	
		
			
				
					|  |  |  |  |         } | 
			
		
	
		
			
				
					|  |  |  |  |         log.error("解析长泰区医院医疗类型,返回结果:{}", udiwmsProductRequest.getProductType()); | 
			
		
	
		
			
				
					|  |  |  |  |         return ResultVOUtils.error(500,"医疗类型不正确,medicalType:"+udiwmsProductRequest.getProductType()); | 
			
		
	
		
			
				
					|  |  |  |  |         return ResultVOUtils.error(500, "医疗类型不正确,medicalType:" + udiwmsProductRequest.getProductType()); | 
			
		
	
		
			
				
					|  |  |  |  |     } | 
			
		
	
		
			
				
					|  |  |  |  | 
 | 
			
		
	
		
			
				
					|  |  |  |  |     @Override | 
			
		
	
	
		
			
				
					|  |  |  | @ -1325,6 +1326,7 @@ public class CtqyyClient extends CommonHttpClient { | 
			
		
	
		
			
				
					|  |  |  |  |                                 code = code.substring(1, code.length() - 1); | 
			
		
	
		
			
				
					|  |  |  |  |                             } | 
			
		
	
		
			
				
					|  |  |  |  |                             itemDTO.setCode(code); | 
			
		
	
		
			
				
					|  |  |  |  |                             if (StrUtil.isNotEmpty(code) && code.length() > 16) | 
			
		
	
		
			
				
					|  |  |  |  |                                 itemDTO.setNameCode(code.substring(0, 16)); | 
			
		
	
		
			
				
					|  |  |  |  | 
 | 
			
		
	
		
			
				
					|  |  |  |  |                             if (IntUtil.value(codeDetaiEntity.getCount()) > 1) { | 
			
		
	
	
		
			
				
					|  |  |  | @ -1350,6 +1352,7 @@ public class CtqyyClient extends CommonHttpClient { | 
			
		
	
		
			
				
					|  |  |  |  | 
 | 
			
		
	
		
			
				
					|  |  |  |  |     /** | 
			
		
	
		
			
				
					|  |  |  |  |      * 处方拉取视图 | 
			
		
	
		
			
				
					|  |  |  |  |      * | 
			
		
	
		
			
				
					|  |  |  |  |      * @param udiwmsBasicSkPrescribeRequest | 
			
		
	
		
			
				
					|  |  |  |  |      * @return | 
			
		
	
		
			
				
					|  |  |  |  |      */ | 
			
		
	
	
		
			
				
					|  |  |  | @ -1357,10 +1360,10 @@ public class CtqyyClient extends CommonHttpClient { | 
			
		
	
		
			
				
					|  |  |  |  |     public BaseResponse getPrescribes(UdiwmsBasicSkPrescribeRequest udiwmsBasicSkPrescribeRequest) { | 
			
		
	
		
			
				
					|  |  |  |  |         LambdaQueryWrapper<PresInfoEntity> wrapper = new LambdaQueryWrapper(); | 
			
		
	
		
			
				
					|  |  |  |  |         //补充其他查询条件
 | 
			
		
	
		
			
				
					|  |  |  |  |         IPage<PresInfoEntity> page = presInfoMapper.selectPage(new Page<PresInfoEntity>(udiwmsBasicSkPrescribeRequest.getPage(),udiwmsBasicSkPrescribeRequest.getLimit()),wrapper); | 
			
		
	
		
			
				
					|  |  |  |  |         IPage<PresInfoEntity> page = presInfoMapper.selectPage(new Page<PresInfoEntity>(udiwmsBasicSkPrescribeRequest.getPage(), udiwmsBasicSkPrescribeRequest.getLimit()), wrapper); | 
			
		
	
		
			
				
					|  |  |  |  |         List<PresInfoEntity> presInfoEntities = page.getRecords(); | 
			
		
	
		
			
				
					|  |  |  |  |         List<BasicSkPrescribeResponse> basicSkPrescribeResponses = null; | 
			
		
	
		
			
				
					|  |  |  |  |         if(CollUtil.isNotEmpty(presInfoEntities)){ | 
			
		
	
		
			
				
					|  |  |  |  |         if (CollUtil.isNotEmpty(presInfoEntities)) { | 
			
		
	
		
			
				
					|  |  |  |  |             //数据处理以basic_sk_prescribe,basic_sk_prescribe_item 主子返回
 | 
			
		
	
		
			
				
					|  |  |  |  |             basicSkPrescribeResponses = presInfoEntities.stream().map(pres -> { | 
			
		
	
		
			
				
					|  |  |  |  |                 BasicSkPrescribeResponse basicSkPrescribeResponse = new BasicSkPrescribeResponse(); | 
			
		
	
	
		
			
				
					|  |  |  | @ -1383,6 +1386,7 @@ public class CtqyyClient extends CommonHttpClient { | 
			
		
	
		
			
				
					|  |  |  |  | 
 | 
			
		
	
		
			
				
					|  |  |  |  |     /** | 
			
		
	
		
			
				
					|  |  |  |  |      * 采购计划拉取视图 | 
			
		
	
		
			
				
					|  |  |  |  |      * | 
			
		
	
		
			
				
					|  |  |  |  |      * @param udiwmsThrOrderRequest | 
			
		
	
		
			
				
					|  |  |  |  |      * @return | 
			
		
	
		
			
				
					|  |  |  |  |      */ | 
			
		
	
	
		
			
				
					|  |  |  | @ -1390,12 +1394,12 @@ public class CtqyyClient extends CommonHttpClient { | 
			
		
	
		
			
				
					|  |  |  |  |     public BaseResponse getThrOrders(UdiwmsThrOrderRequest udiwmsThrOrderRequest) { | 
			
		
	
		
			
				
					|  |  |  |  |         LambdaQueryWrapper<PlanInfoEntity> wrapper = new LambdaQueryWrapper<>(); | 
			
		
	
		
			
				
					|  |  |  |  |         //补充其他查询条件
 | 
			
		
	
		
			
				
					|  |  |  |  |         IPage<PlanInfoEntity> page = planInfoMapper.selectPage(new Page<PlanInfoEntity>(udiwmsThrOrderRequest.getPage(),udiwmsThrOrderRequest.getLimit()),wrapper); | 
			
		
	
		
			
				
					|  |  |  |  |         IPage<PlanInfoEntity> page = planInfoMapper.selectPage(new Page<PlanInfoEntity>(udiwmsThrOrderRequest.getPage(), udiwmsThrOrderRequest.getLimit()), wrapper); | 
			
		
	
		
			
				
					|  |  |  |  |         List<PlanInfoEntity> planInfoEntities = page.getRecords(); | 
			
		
	
		
			
				
					|  |  |  |  |         List<ThrOrderResponse> thrOrderResponses = null; | 
			
		
	
		
			
				
					|  |  |  |  |         if(CollUtil.isNotEmpty(planInfoEntities)){ | 
			
		
	
		
			
				
					|  |  |  |  |         if (CollUtil.isNotEmpty(planInfoEntities)) { | 
			
		
	
		
			
				
					|  |  |  |  |             //数据处理以thr_order,thr_order_detail 主子返回
 | 
			
		
	
		
			
				
					|  |  |  |  |             thrOrderResponses = planInfoEntities.stream().map(plan->{ | 
			
		
	
		
			
				
					|  |  |  |  |             thrOrderResponses = planInfoEntities.stream().map(plan -> { | 
			
		
	
		
			
				
					|  |  |  |  |                 ThrOrderResponse thrOrderResponse = new ThrOrderResponse(); | 
			
		
	
		
			
				
					|  |  |  |  |                 List<ThrOrderDetailEntity> detailList = new ArrayList<>(); | 
			
		
	
		
			
				
					|  |  |  |  |                 ThrOrderDetailEntity detail = new ThrOrderDetailEntity(); | 
			
		
	
	
		
			
				
					|  |  |  | 
 |