Default Changelist

src/main/java/com/shigongli/common/BaseController.java

 package com.shigongli.common;
 
+import com.shigongli.entity.TaPerson;
+import com.shigongli.service.ITaPersonService;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.Map;
+
 public class BaseController {
+    @Autowired
+    ITaPersonService iTaPersonService;
+
+    public TaPerson getPerson(HttpServletRequest request) {
+        String token = JWTUtils.getToken(request);
+        try {
+            Map<String, Object> params = JWTUtils.decode(token);
+            String personId = params.get("personId").toString();
+            return iTaPersonService.getById(personId);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
 }

src/main/java/com/shigongli/common/JWTUtils.java

             Claims claims = parse(token);
             return encode(claims);
         } catch (Exception e) {
-            log.error("解析 JWT Token 失败: {}", e.getMessage());
+//            log.error("解析 JWT Token 失败: {}", e.getMessage());
         }
         return null;
     }

src/main/java/com/shigongli/controller/LoginController.java

 //    @Autowired
 //    ISysUserService iSysUserService;
 
-    @PostMapping("/login")
+    @PostMapping("/mp/login")
     @ApiOperation(value="登录", notes = "登录", httpMethod = "POST", response = ResponseBean.class)
     public ResponseBean login(@ApiParam("登录参数") @RequestBody LoginParam loginParam) throws Exception {
 //        if (null == loginParam) {

src/main/java/com/shigongli/controller/TaPersonController.java

 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.shigongli.common.BaseController;
+import com.shigongli.common.JWTUtils;
 import com.shigongli.common.ResponseBean;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.*;
 import com.shigongli.service.ITaPersonService;
 import com.shigongli.entity.TaPerson;
-import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.HashMap;
+import java.util.Map;
 
 /**
  * <p>
     @Autowired
     public ITaPersonService iTaPersonService;
 
+    @PostMapping("/ma/login")
+    public ResponseBean login(String code) {
+        // 用 code 去换 openid
+        String openid = "";
+
+        // 先查询人员是否存在
+        TaPerson taPerson = iTaPersonService.getByOpenId(openid);
+
+        // 如果人员不存在, 则新增
+        if (null == taPerson) {
+            taPerson = new TaPerson();
+            taPerson.setOpenid(openid);
+            iTaPersonService.save(taPerson);
+//            taPerson = iTaPersonService.getById(taPerson.getPersonId());
+        }
+
+        // 生成 token
+        Map<String, Object> claims = new HashMap<>();
+        claims.put("personId", taPerson.getPersonId());
+        String token = JWTUtils.encode(claims);
+        taPerson.setToken(token);
+
+        return ResponseBean.success(taPerson);
+    }
+
 
     /**
      * 分页查询列表
     @RequestMapping(value="/taPerson",method= RequestMethod.GET)
     @ApiOperation(value="列表", notes = "列表", httpMethod = "GET", response = ResponseBean.class)
     public ResponseBean taPersonList(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
-									 @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception{
+                                     @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                     HttpServletRequest request) throws Exception{
 
 		    IPage<TaPerson> pg = new Page<>(pageNum, pageSize);
             QueryWrapper<TaPerson> queryWrapper = new QueryWrapper<>();

src/main/java/com/shigongli/entity/TaPerson.java

 
 import com.baomidou.mybatisplus.annotation.IdType;
 import java.time.LocalDateTime;
+
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import java.io.Serializable;
 import io.swagger.annotations.ApiModel;
     private static final long serialVersionUID = 1L;
 
     @ApiModelProperty(value = "人员ID")
-    @TableId(value = "person_id", type = IdType.INPUT)
+    @TableId(value = "person_id", type = IdType.UUID)
     private String personId;
 
     @ApiModelProperty(value = "手机")
     @ApiModelProperty(value = "创建时间")
     private LocalDateTime createDate;
 
-
+    @TableField(exist = false)
+    private String token;
 }

src/main/java/com/shigongli/interceptor/PermissionInterceptor.java

 
         // JWT
         String jws = JWTUtils.getToken(request);
-        if (StringUtils.isEmpty(jws)) {
-            responseTokenError(response, "鉴权失败, 请先进行登录操作");
-            return false;
-        }
-
-        try {
-            JWTUtils.verify(jws);
-        } catch (Exception e) {
-            log.error("鉴权失败: {}", e.getMessage());
-            responseTokenError(response, "鉴权失败, 请重新登录");
-            return false;
-        }
+//        if (StringUtils.isEmpty(jws)) {
+//            responseTokenError(response, "鉴权失败, 请先进行登录操作");
+//            return false;
+//        }
+
+//        try {
+//            JWTUtils.verify(jws);
+//        } catch (Exception e) {
+//            log.error("鉴权失败: {}", e.getMessage());
+//            responseTokenError(response, "鉴权失败, 请重新登录");
+//            return false;
+//        }
 
         return true;
     }

src/main/java/com/shigongli/mapper/TaPersonMapper.java

 import com.shigongli.entity.TaPerson;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 /**
  * <p>
 @Mapper
 public interface TaPersonMapper extends BaseMapper<TaPerson> {
 
+    TaPerson getByOpenId(@Param("openid") String openid);
 }

src/main/java/com/shigongli/service/ITaPersonService.java

  */
 public interface ITaPersonService extends IService<TaPerson> {
 
+    TaPerson getByOpenId(String openid);
 }

src/main/java/com/shigongli/service/impl/TaPersonServiceImpl.java

 import com.shigongli.mapper.TaPersonMapper;
 import com.shigongli.service.ITaPersonService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 /**
 @Service
 public class TaPersonServiceImpl extends ServiceImpl<TaPersonMapper, TaPerson> implements ITaPersonService {
 
+    @Autowired
+    TaPersonMapper taPersonMapper;
+
+    @Override
+    public TaPerson getByOpenId(String openid) {
+        return taPersonMapper.getByOpenId(openid);
+    }
 }

src/main/resources/mapper/TaPersonMapper.xml

 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.shigongli.mapper.TaPersonMapper">
 
+    <select id="getByOpenId" resultType="com.shigongli.entity.TaPerson">
+        select * from ta_person where openid = #{openid}
+    </select>
 </mapper>