添加登陆后写入账号信息

whepi-web/src/main/java/com/bofeng/dao/UserOpenMapper.java

@@ -17,4 +17,6 @@ public interface UserOpenMapper extends BaseMapper<UserOpen> {
     User getUserByHigherId(Long higherId);
 
     UserOpen selectByUserId(@Param("userId") Long userId);
+
+    UserOpen selectByOpenId(@Param("openId") String openId);
 }

whepi-web/src/main/java/com/bofeng/service/HomeService.java

@@ -0,0 +1,54 @@
+package com.bofeng.service;
+
+import com.baomidou.mybatisplus.toolkit.IdWorker;
+import com.bofeng.JwtHelper;
+import com.bofeng.dao.UserOpenMapper;
+import com.bofeng.entity.ParseCurrentOpenId;
+import com.bofeng.entity.UserOpen;
+import me.chanjar.weixin.mp.bean.result.WxMpUser;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+import static com.bofeng.JwtHelper.getAuthHeader;
+
+@Service
+@Transactional(readOnly = true)
+public class HomeService {
+
+    @Autowired
+    private UserService userService;
+    @Autowired
+    private UserOpenMapper userOpenMapper;
+
+    @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
+    public void getUserOpen() {
+        ParseCurrentOpenId wxToken = userService.currentWxUser();
+        WxMpUser wxMpUser = wxToken.getWxMpUser();
+        UserOpen user = userOpenMapper.selectByOpenId(wxMpUser.getOpenId());
+        if (user == null) {
+            // 账户没有注册,需要注册
+            UserOpen userOpen = new UserOpen();
+            userOpen.setUserId(IdWorker.getId());
+            userOpen.setOpenId(wxMpUser.getOpenId());
+            userOpen.setNickName(wxMpUser.getNickname());
+            userOpen.setSexDesc(wxMpUser.getSexDesc());
+            userOpen.setSex(wxMpUser.getSex());
+            userOpen.setCity(wxMpUser.getCity());
+            userOpen.setProvince(wxMpUser.getProvince());
+            userOpen.setCountry(wxMpUser.getCountry());
+            userOpen.setHeadImgUrl(wxMpUser.getHeadImgUrl());
+            userOpen.setBeActive("Y");
+            userOpenMapper.insert(userOpen);
+        } else {
+            Long userId = user.getUserId();
+//            String userId = JwtHelper.getUserId();
+            System.out.println(userId);
+        }
+    }
+
+//    public void setUserInfo(UserOpen userOpen) {
+//        JwtHelper.setU
+//    }
+}

whepi-web/src/main/java/com/bofeng/service/SecurityService.java

@@ -9,7 +9,6 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Service;
-import sun.reflect.generics.reflectiveObjects.NotImplementedException;
 
 @Service
 public class SecurityService {

whepi-web/src/main/java/com/bofeng/service/UserService.java

@@ -189,26 +189,26 @@ public class UserService {
             return r;
         }
 
-        val user = getUserById(userOpen.getUserId());
-        if (user == null) {
-            model.put("message", "user 不存在 " + userOpen.getUserId());
-            model.put("isError", true);
-            r.setErrorResult(new ModelAndView("/prompt/prompt.ftl", model));
-            r.setError(true);
-            log.error("user 不存在 " + userOpen.getUserId());
-            return r;
-        }
-        if (!Consts.ACT_ENABLE.equals(user.getBeActive())) {
-            model.put("message", "user 被禁用 " + userOpen.getUserId());
-            model.put("isError", true);
-            r.setErrorResult(new ModelAndView("/prompt/prompt.ftl", model));
-            r.setError(true);
-            log.error("user 被禁用 " + userOpen.getUserId());
-            return r;
-        }
+//        val user = getUserById(userOpen.getUserId());
+//        if (user == null) {
+//            model.put("message", "user 不存在 " + userOpen.getUserId());
+//            model.put("isError", true);
+//            r.setErrorResult(new ModelAndView("/prompt/prompt.ftl", model));
+//            r.setError(true);
+//            log.error("user 不存在 " + userOpen.getUserId());
+//            return r;
+//        }
+//        if (!Consts.ACT_ENABLE.equals(user.getBeActive())) {
+//            model.put("message", "user 被禁用 " + userOpen.getUserId());
+//            model.put("isError", true);
+//            r.setErrorResult(new ModelAndView("/prompt/prompt.ftl", model));
+//            r.setError(true);
+//            log.error("user 被禁用 " + userOpen.getUserId());
+//            return r;
+//        }
 
         r.setUserOpen(userOpen);
-        r.setUser(user);
+//        r.setUser(user);
         r.setError(false);
         return r;
     }

whepi-web/src/main/java/com/bofeng/wx/controller/HomeController.java

@@ -1,14 +1,18 @@
 package com.bofeng.wx.controller;
 
+import com.baomidou.mybatisplus.toolkit.IdWorker;
 import com.bofeng.Consts;
-import com.bofeng.entity.ParseCurrentOpenId;
-import com.bofeng.entity.StatisticsOrder;
-import com.bofeng.entity.SubUser;
-import com.bofeng.entity.User;
+import com.bofeng.dao.UserOpenMapper;
+import com.bofeng.entity.*;
+import com.bofeng.service.HomeService;
+import com.bofeng.service.UserOpenService;
+import com.bofeng.service.UserService;
 import com.google.common.collect.Maps;
 import com.yvan.platform.JsonWapper;
 import com.yvan.platform.YvanUtil;
 import lombok.val;
+import me.chanjar.weixin.mp.bean.result.WxMpUser;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.ui.ModelMap;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
@@ -20,13 +24,12 @@ import java.util.Map;
 @RestController
 public class HomeController {
 
+    @Autowired
+    private HomeService homeService;
+
     @GetMapping("/home/home.html")
     public ModelAndView home(ModelMap model) {
-
-//        Map<String, Object> queryParam = Maps.newLinkedHashMap();
-//        queryParam.put("userId", "12345677");
-//        queryParam.put("statistics", "M");
-
+        homeService.getUserOpen();
         model.put("user", new JsonWapper("{\"www\": \"er\"}"));
         return new ModelAndView("/home/home.ftl", model);
     }

whepi-web/src/main/resources/mapper/UserOpen.xml

@@ -10,4 +10,9 @@
         select * from sys_user_open
         where user_id=#{userId}
     </select>
+
+    <select id="selectByOpenId" resultType="com.bofeng.entity.UserOpen">
+        select * from sys_user_open
+        where open_id=#{openId}
+    </select>
 </mapper>