| 
						
						
							
								
							
						
						
					 | 
					@ -34,12 +34,14 @@ import com.epmet.dto.PaCustomerDTO; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.dto.PaUserDTO; | 
					 | 
					 | 
					import com.epmet.dto.PaUserDTO; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.dto.PaUserVisitedDTO; | 
					 | 
					 | 
					import com.epmet.dto.PaUserVisitedDTO; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.dto.PaUserWechatDTO; | 
					 | 
					 | 
					import com.epmet.dto.PaUserWechatDTO; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					 | 
					 | 
					 | 
					import com.epmet.dto.form.SaveUserVisitedFormDTO; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.dto.result.CustomerUserResultDTO; | 
					 | 
					 | 
					import com.epmet.dto.result.CustomerUserResultDTO; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.dto.result.SaveUserResultDTO; | 
					 | 
					 | 
					import com.epmet.dto.result.SaveUserResultDTO; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.entity.PaUserEntity; | 
					 | 
					 | 
					import com.epmet.entity.PaUserEntity; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.entity.PaUserWechatEntity; | 
					 | 
					 | 
					import com.epmet.entity.PaUserWechatEntity; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.redis.PaUserRedis; | 
					 | 
					 | 
					import com.epmet.redis.PaUserRedis; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.service.PaUserService; | 
					 | 
					 | 
					import com.epmet.service.PaUserService; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					 | 
					 | 
					 | 
					import com.epmet.service.PaUserVisitedService; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.service.PaUserWechatService; | 
					 | 
					 | 
					import com.epmet.service.PaUserWechatService; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import me.chanjar.weixin.mp.bean.result.WxMpUser; | 
					 | 
					 | 
					import me.chanjar.weixin.mp.bean.result.WxMpUser; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import org.apache.commons.lang3.StringUtils; | 
					 | 
					 | 
					import org.apache.commons.lang3.StringUtils; | 
				
			
			
		
	
	
		
		
			
				
					| 
						
							
								
							
						
						
							
								
							
						
						
					 | 
					@ -72,6 +74,8 @@ public class PaUserServiceImpl extends BaseServiceImpl<PaUserDao, PaUserEntity> | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					    private PaUserWechatDao paUserWechatDao; | 
					 | 
					 | 
					    private PaUserWechatDao paUserWechatDao; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					    @Autowired | 
					 | 
					 | 
					    @Autowired | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					    private PaUserVisitedDao paUserVisitedDao; | 
					 | 
					 | 
					    private PaUserVisitedDao paUserVisitedDao; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					 | 
					 | 
					 | 
					    @Autowired | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					 | 
					 | 
					 | 
					    private PaUserVisitedService paUserVisitedService; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					
 | 
					 | 
					 | 
					
 | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					    @Override | 
					 | 
					 | 
					    @Override | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					    public PageData<PaUserDTO> page(Map<String, Object> params) { | 
					 | 
					 | 
					    public PageData<PaUserDTO> page(Map<String, Object> params) { | 
				
			
			
		
	
	
		
		
			
				
					| 
						
							
								
							
						
						
							
								
							
						
						
					 | 
					@ -156,10 +160,15 @@ public class PaUserServiceImpl extends BaseServiceImpl<PaUserDao, PaUserEntity> | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            wechatEntity.setCity(null == wxMpUser.getCity() ? "" : wxMpUser.getCity()); | 
					 | 
					 | 
					            wechatEntity.setCity(null == wxMpUser.getCity() ? "" : wxMpUser.getCity()); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            wechatEntity.setLanguage(null == wxMpUser.getLanguage() ? "" : wxMpUser.getLanguage()); | 
					 | 
					 | 
					            wechatEntity.setLanguage(null == wxMpUser.getLanguage() ? "" : wxMpUser.getLanguage()); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            paUserWechatService.insert(wechatEntity); | 
					 | 
					 | 
					            paUserWechatService.insert(wechatEntity); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					 | 
					 | 
					 | 
					            //2.3、pa_user_visited表新增访问记录数据
 | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					 | 
					 | 
					 | 
					            SaveUserVisitedFormDTO visited = new SaveUserVisitedFormDTO(); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					 | 
					 | 
					 | 
					            visited.setUserId(userEntity.getId()); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					 | 
					 | 
					 | 
					            visited.setLogonUserId(userEntity.getId()); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					 | 
					 | 
					 | 
					            paUserVisitedService.saveUserVisited(visited); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					
 | 
					 | 
					 | 
					
 | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            resultDTO.setUserId(userEntity.getId()); | 
					 | 
					 | 
					            resultDTO.setUserId(userEntity.getId()); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					        } else { | 
					 | 
					 | 
					        } else { | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					            //2.3、批量更新user_wechat表数据
 | 
					 | 
					 | 
					            //2.4、批量更新user_wechat表数据
 | 
				
			
			
				
				
			
		
	
		
		
	
		
		
			
				
					 | 
					 | 
					            List<PaUserWechatEntity> wechatEntity = ConvertUtils.sourceToTarget(wechatDTO, PaUserWechatEntity.class); | 
					 | 
					 | 
					            List<PaUserWechatEntity> wechatEntity = ConvertUtils.sourceToTarget(wechatDTO, PaUserWechatEntity.class); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            for(PaUserWechatEntity entity : wechatEntity){ | 
					 | 
					 | 
					            for(PaUserWechatEntity entity : wechatEntity){ | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					                entity.setGender(wxMpUser.getSex().toString()); | 
					 | 
					 | 
					                entity.setGender(wxMpUser.getSex().toString()); | 
				
			
			
		
	
	
		
		
			
				
					| 
						
						
						
							
								
							
						
					 | 
					@ -172,7 +181,7 @@ public class PaUserServiceImpl extends BaseServiceImpl<PaUserDao, PaUserEntity> | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            } | 
					 | 
					 | 
					            } | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            paUserWechatService.updateBatchById(wechatEntity); | 
					 | 
					 | 
					            paUserWechatService.updateBatchById(wechatEntity); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					
 | 
					 | 
					 | 
					
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					            //2.4、根据openid查询用户登陆访问记录表数据,按登陆时间倒序
 | 
					 | 
					 | 
					            //2.5、根据openid查询用户登陆访问记录表数据,按登陆时间倒序
 | 
				
			
			
				
				
			
		
	
		
		
	
		
		
			
				
					 | 
					 | 
					            PaUserVisitedDTO visitedDTO = paUserVisitedDao.selectByOpenId(wxMpUser.getOpenId()); | 
					 | 
					 | 
					            PaUserVisitedDTO visitedDTO = paUserVisitedDao.selectByOpenId(wxMpUser.getOpenId()); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            if (null == visitedDTO || "".equals(visitedDTO.getUserId())) { | 
					 | 
					 | 
					            if (null == visitedDTO || "".equals(visitedDTO.getUserId())) { | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					                logger.error("根据openid查询用户访问记录表数据失败,openid->"+wxMpUser.getOpenId()); | 
					 | 
					 | 
					                logger.error("根据openid查询用户访问记录表数据失败,openid->"+wxMpUser.getOpenId()); | 
				
			
			
		
	
	
		
		
			
				
					| 
						
							
								
							
						
						
						
					 | 
					
  |