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