| 
						
						
							
								
							
						
						
					 | 
				
				 | 
				
					@ -245,6 +245,7 @@ public class DataSyncRecordDisabilityServiceImpl extends BaseServiceImpl<DataSyn | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					        String customerId = tokenDto.getCustomerId(); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					        String userId = tokenDto.getUserId(); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					        List<String> all = Arrays.asList(ids); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					        // 根据IDs查询烟台拉取的残疾信息
 | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					        List<DataSyncRecordDisabilityEntity> entities = baseDao.selectBatchIds(all); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					        IcFormOptionsQueryFormDTO formDTO = new IcFormOptionsQueryFormDTO(); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					        formDTO.setCustomerId(customerId); | 
				
			
			
		
	
	
		
			
				
					| 
						
							
								
							
						
						
							
								
							
						
						
					 | 
				
				 | 
				
					@ -273,7 +274,8 @@ public class DataSyncRecordDisabilityServiceImpl extends BaseServiceImpl<DataSyn | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					                } | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					            }); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					        }); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					        entities.stream().filter(e -> StringUtils.isBlank(e.getCjzk()) || StringUtils.isBlank(e.getCjlb())).forEach(e -> e.setUpdateStatus(true)); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					        // cjzk,cjlb为空的,处理结果赋值 处理失败
 | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					//        entities.stream().filter(e -> StringUtils.isBlank(e.getCjzk()) || StringUtils.isBlank(e.getCjlb())).forEach(e -> e.setUpdateStatus(true));
 | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					        // 变更记录
 | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					        List<CategoryStatusAndIdDTO> collect = entities.stream().map(m -> { | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					            CategoryStatusAndIdDTO dto = new CategoryStatusAndIdDTO(); | 
				
			
			
		
	
	
		
			
				
					| 
						
							
								
							
						
						
						
					 | 
				
				 | 
				
					
  |