添加错误日志

epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/constant/PaConstant.java

@@ -70,4 +70,8 @@ public interface PaConstant {
      * 获取客户信息失败
      */
     String SELECT_CUSTOMER_EXCEPTION = "获取客户信息失败";
+    /**
+     * 获取访问记录表数据失败失败
+     */
+    String SELECT_VISITED_EXCEPTION = "获取访问记录表数据失败";
 }

epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/service/impl/PaUserServiceImpl.java

@@ -20,10 +20,12 @@ package com.epmet.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
+import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.commons.tools.constant.NumConstant;
+import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.ConvertUtils;
-import com.epmet.commons.tools.constant.FieldConstant;
+import com.epmet.constant.PaConstant;
 import com.epmet.dao.PaCustomerDao;
 import com.epmet.dao.PaUserDao;
 import com.epmet.dao.PaUserVisitedDao;
@@ -41,6 +43,8 @@ import com.epmet.service.PaUserService;
 import com.epmet.service.PaUserWechatService;
 import me.chanjar.weixin.mp.bean.result.WxMpUser;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -57,7 +61,7 @@ import java.util.Map;
  */
 @Service
 public class PaUserServiceImpl extends BaseServiceImpl<PaUserDao, PaUserEntity> implements PaUserService {
-
+    private Logger logger = LogManager.getLogger(PaUserServiceImpl.class);
     @Autowired
     private PaUserRedis paUserRedis;
     @Autowired
@@ -170,6 +174,10 @@ public class PaUserServiceImpl extends BaseServiceImpl<PaUserDao, PaUserEntity>
 
             //2.4、根据openid查询用户登陆访问记录表数据，按登陆时间倒序
             PaUserVisitedDTO visitedDTO = paUserVisitedDao.selectByOpenId(wxMpUser.getOpenId());
+            if (null == visitedDTO || "".equals(visitedDTO.getUserId())) {
+                logger.error("根据openid查询用户访问记录表数据失败，openid->"+wxMpUser.getOpenId());
+                throw new RenException(PaConstant.SELECT_VISITED_EXCEPTION);
+            }
 
             resultDTO.setUserId(visitedDTO.getUserId());
         }