feats

pom.xml

@@ -72,6 +72,14 @@
         </dependency>
         <!--mybatis-plus end-->
 
+        <!--weixin-miniapp start-->
+        <dependency>
+            <groupId>com.github.binarywang</groupId>
+            <artifactId>weixin-java-miniapp</artifactId>
+            <version>4.4.0</version>
+        </dependency>
+        <!--weixin-miniapp start-->
+
         <!--swagger start-->
         <dependency>
             <groupId>io.springfox</groupId>
@@ -81,6 +89,30 @@
         <!--swagger end-->
     </dependencies>
 
+
+    <profiles>
+        <profile>
+            <id>dev</id>
+            <properties>
+                <profileActive>dev</profileActive>
+            </properties>
+            <activation>
+                <activeByDefault>true</activeByDefault>
+            </activation>
+        </profile>
+        <profile>
+            <id>prod</id>
+            <properties>
+                <profileActive>prod</profileActive>
+            </properties>
+            <activation>
+                <activeByDefault>false</activeByDefault>
+            </activation>
+            <build>
+            </build>
+        </profile>
+    </profiles>
+
     <build>
         <plugins>
             <plugin>
@@ -96,6 +128,16 @@
                 </configuration>
             </plugin>
         </plugins>
+        <resources>
+            <resource>
+                <directory>src/main/resources</directory>
+                <filtering>true</filtering>
+                <includes>
+                    <include>**/*.xml</include>
+                    <include>application.yml</include>
+                    <include>application-${profileActive}.yml</include>
+                </includes>
+            </resource>
+        </resources>
     </build>
-
 </project>

src/main/java/com/example/civilizedcity/common/BaseController.java

@@ -1,9 +1,47 @@
 package com.example.civilizedcity.common;
 
+import cn.dev33.satoken.stp.StpUtil;
+import com.example.civilizedcity.entity.SysUser;
+import com.example.civilizedcity.entity.TaPerson;
+import com.example.civilizedcity.service.SysUserService;
+import com.example.civilizedcity.service.TaPersonService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 @Component
 public class BaseController {
 
+    @Autowired
+    protected SysUserService sysUserService;
 
+    @Autowired
+    protected TaPersonService taPersonService;
+
+    public SysUser currentUser() throws Exception {
+        String loginId = StpUtil.getLoginIdAsString();
+        if (StringUtils.isEmpty(loginId)) {
+            throw new Exception("请先登录");
+        }
+
+        SysUser user = sysUserService.getById(loginId);
+        if (user == null || user.getStatus() == Constants.STATUS_DELETE) {
+            throw new Exception("人员不存在");
+        }
+
+        return user;
+    }
+
+    public TaPerson currentPerson() throws Exception {
+        String loginId = StpUtil.getLoginIdAsString();
+        if (StringUtils.isEmpty(loginId)) {
+            throw new Exception("请先登录");
+        }
+
+        TaPerson taPerson = taPersonService.getById(loginId);
+        if (taPerson == null || taPerson.getStatus() == Constants.STATUS_DELETE) {
+            throw new Exception("人员不存在");
+        }
+
+        return taPerson;
+    }
 }

src/main/java/com/example/civilizedcity/config/WxMaConfig.java

@@ -0,0 +1,10 @@
+package com.example.civilizedcity.config;
+
+import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Component
+@ConfigurationProperties(prefix = "wx.miniapp")
+public class WxMaConfig extends WxMaDefaultConfigImpl {
+}

src/main/java/com/example/civilizedcity/config/WxMaUitl.java

@@ -0,0 +1,52 @@
+package com.example.civilizedcity.config;
+
+import cn.binarywang.wx.miniapp.api.WxMaService;
+import cn.binarywang.wx.miniapp.api.impl.WxMaServiceImpl;
+import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
+import cn.binarywang.wx.miniapp.bean.WxMaPhoneNumberInfo;
+import cn.binarywang.wx.miniapp.bean.WxMaUserInfo;
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import me.chanjar.weixin.common.error.WxErrorException;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class WxMaUitl {
+    WxMaConfig wxMaConfig;
+    WxMaService service;
+
+    @Autowired
+    public WxMaUitl(WxMaConfig wxMaConfig) {
+        this.wxMaConfig = wxMaConfig;
+        this.wxMaConfig.setMsgDataFormat("JSON");
+
+        service = new WxMaServiceImpl();
+        service.setWxMaConfig(this.wxMaConfig);
+    }
+
+    public WxMaService getService() {
+        return service;
+    }
+
+    public WxMaJscode2SessionResult getOpenid(String code) throws WxErrorException {
+        return service.getUserService().getSessionInfo(code);
+    }
+
+    public WxMaUserInfo getUserInfo(AuthParam param) {
+        return service.getUserService().getUserInfo(param.getSessionKey(), param.getEncryptedData(), param.getIv());
+    }
+
+    public WxMaPhoneNumberInfo getPhoneNoInfo(AuthParam param) {
+        return service.getUserService().getPhoneNoInfo(param.getSessionKey(), param.getEncryptedData(), param.getIv());
+    }
+
+    @Data
+    public static class AuthParam {
+        String signature;
+        String rawData;
+        String encryptedData;
+        String iv;
+        String sessionKey;
+    }
+}

src/main/java/com/example/civilizedcity/controller/LoginController.java

@@ -0,0 +1,69 @@
+package com.example.civilizedcity.controller;
+
+import cn.dev33.satoken.stp.StpUtil;
+import com.example.civilizedcity.common.BaseController;
+import com.example.civilizedcity.common.ResponseBean;
+import com.example.civilizedcity.common.StringUtils;
+import com.example.civilizedcity.entity.SysUser;
+import com.example.civilizedcity.vo.ChangePassword;
+import com.example.civilizedcity.vo.LoginParam;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.HashMap;
+import java.util.Map;
+
+
+@Api(tags ="登录")
+@RestController
+@RequestMapping("/admin")
+public class LoginController extends BaseController {
+
+    @PostMapping("/login")
+    @ApiOperation(value="后台登录", notes = "后台登录", httpMethod = "POST", response = ResponseBean.class)
+    public ResponseBean login(@ApiParam("登录参数") @RequestBody LoginParam loginParm) throws Exception {
+
+        if (StringUtils.isEmpty(loginParm.getAccount()) || StringUtils.isEmpty(loginParm.getPassword())) {
+            return ResponseBean.error("登录用户或者密码不能为空");
+        }
+
+        SysUser sysUser = sysUserService.login(loginParm);
+
+        StpUtil.login(sysUser.getUserId(), "admin");
+        String tokenValue = StpUtil.getTokenValue();
+
+        Map<String, Object> result = new HashMap<>();
+        result.put("user", sysUser);
+        result.put("token", tokenValue);
+
+        return ResponseBean.success(result);
+    }
+
+    @PostMapping("/logout")
+    @ApiOperation(value="登出", notes = "登出", httpMethod = "POST", response = ResponseBean.class)
+    public ResponseBean logout() throws Exception {
+        SysUser sysUser = currentUser();
+        StpUtil.logout(sysUser.getUserId(), "admin");
+        return ResponseBean.success("success");
+    }
+
+
+    @PutMapping("/change-password")
+    @ApiOperation(value="修改密码", notes = "修改密码", httpMethod = "PUT", response = ResponseBean.class)
+    public ResponseBean changePassword(@ApiParam("修改密码参数") @RequestBody ChangePassword param) throws Exception {
+        if (StringUtils.isEmpty(param.getOriginPassword()) || StringUtils.isEmpty(param.getNewPassword())) {
+            return ResponseBean.error("原始密码或新密码不能为空", ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+
+        SysUser user = currentUser();
+
+        boolean isOk = sysUserService.changePassword(user, param);
+        if (!isOk) {
+            ResponseBean.error("修改失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
+        }
+
+        return ResponseBean.success("密码修改成功");
+    }
+}

src/main/java/com/example/civilizedcity/controller/WxMaController.java

@@ -0,0 +1,174 @@
+package com.example.civilizedcity.controller;
+
+import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
+import cn.binarywang.wx.miniapp.bean.WxMaPhoneNumberInfo;
+import cn.binarywang.wx.miniapp.bean.WxMaUserInfo;
+import cn.dev33.satoken.stp.StpUtil;
+import com.example.civilizedcity.common.BaseController;
+import com.example.civilizedcity.common.Constants;
+import com.example.civilizedcity.common.ResponseBean;
+import com.example.civilizedcity.common.StringUtils;
+import com.example.civilizedcity.config.WxMaUitl;
+import com.example.civilizedcity.entity.SysUser;
+import com.example.civilizedcity.entity.TaPerson;
+import com.example.civilizedcity.entity.TaPersonReflect;
+import com.example.civilizedcity.service.TaPersonReflectService;
+import com.example.civilizedcity.vo.LoginParam;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.Map;
+
+@Api(tags = "小程序登入/登出")
+@RestController
+@RequestMapping("/ma")
+public class WxMaController extends BaseController {
+
+    @Autowired
+    WxMaUitl wxMaUitl;
+
+    @Autowired
+    TaPersonReflectService taPersonReflectService;
+
+
+//    private boolean checkLoginParam(LoginParam loginParam) {
+//        return !StringUtils.isEmpty(loginParam.getCode())
+//                && !StringUtils.isEmpty(loginParam.getUserName())
+//                && !StringUtils.isEmpty(loginParam.getPassword());
+//    }
+
+//    @GetMapping("/preload")
+//    @ApiOperation(value="小程序登录", notes = "小程序登录", httpMethod = "POST", response = ResponseBean.class)
+//    public ResponseBean preload(@ApiParam("客户端ID") @PathVariable String clientId,
+//                                @ApiParam("小程序预加载参数") @RequestParam(required = false) WxMaPreload wxMaPreload) throws Exception {
+//
+//        if (Constants.CLIENT_WORKER.equals(clientId)) {
+//            List<TaMessageTemplate> list = iTaMessageTemplateService.getByTplType(Constants.MESSAGE_MINIAPP);
+//            return ResponseBean.success(new HashMap<String, Object>(){{
+//                put("tpls", list);
+//            }});
+//        }
+//
+//        return ResponseBean.success(null);
+//    }
+
+    /**
+     * 小程序
+     * @param code
+     * @return
+     * @throws Exception
+     */
+    @PostMapping("/login")
+    @ApiOperation(value="小程序登录", notes = "小程序登录", httpMethod = "POST", response = ResponseBean.class)
+    public ResponseBean login(@ApiParam("登录参数") @RequestParam String code) throws Exception {
+
+        if (StringUtils.isEmpty(code)) {
+            return ResponseBean.error("CODE 不能为空");
+        }
+
+        WxMaJscode2SessionResult sessionInfo = wxMaUitl.getOpenid(code);
+        String openid = sessionInfo.getOpenid();
+        String sessionKey = sessionInfo.getSessionKey();
+
+        TaPerson taPerson = taPersonService.getByOpenId(openid);
+        if (null == taPerson) {
+            taPerson = new TaPerson();
+            taPerson.setOpenid(openid);
+            taPerson.setStatus(Constants.STATUS_NORMAL);
+            taPerson.setCreateDate(LocalDateTime.now());
+            taPersonService.save(taPerson);
+        }
+
+//        SysUser user = taPersonService.getReflectUser(taPerson);
+
+        StpUtil.login(taPerson.getPersonId(), "miniapp");
+        Map<String, Object> res = new HashMap<>();
+        res.put("person", taPerson);
+//        res.put("user", user);
+        res.put("token", StpUtil.getTokenValue());
+        res.put("sessionKey", sessionKey);
+
+        return ResponseBean.success(res);
+    }
+
+    /**
+     * 系统人员登录
+     * @param param
+     * @return
+     * @throws Exception
+     */
+    public ResponseBean signin(@ApiParam("登录参数") LoginParam param) throws Exception {
+
+        if (StringUtils.isEmpty(param.getAccount()) || StringUtils.isEmpty(param.getPassword())) {
+            return ResponseBean.error("登录用户或者密码不能为空");
+        }
+
+        SysUser user = sysUserService.login(param);
+
+        TaPerson taPerson = currentPerson();
+        TaPerson reflectd = taPersonService.getByUser(user);
+
+        // 如果未绑定
+        if (null == reflectd) {
+            TaPersonReflect personReflect = new TaPersonReflect();
+            taPersonReflectService.save(personReflect);
+            reflectd = taPerson;
+        }
+
+        // 退出原用户
+        StpUtil.logout(taPerson.getPersonId(), "miniapp");
+        // 登录新用户
+        StpUtil.login(reflectd.getPersonId(), "miniapp");
+
+        Map<String, Object> res = new HashMap<>();
+        res.put("person", reflectd);
+        res.put("user", user);
+        res.put("token", StpUtil.getTokenValue());
+
+        return ResponseBean.success(res);
+    }
+
+    @PutMapping("/auth-user")
+    @ApiOperation(value="授权头像", notes = "授权头像", httpMethod = "PUT", response = TaPerson.class)
+    public ResponseBean updateUserInfo(@ApiParam("授权头像的参数") @RequestBody WxMaUitl.AuthParam param) throws Exception {
+        // 解密用户信息
+        WxMaUserInfo userInfo = wxMaUitl.getUserInfo(param);
+
+        TaPerson taPerson = currentPerson();
+        if (null == taPerson) {
+            throw new Exception("校验当前人员失败, 请重试");
+        }
+
+        taPerson.setAvatar(userInfo.getAvatarUrl());
+        taPerson.setName(userInfo.getNickName());
+//        taPerson.setSex(Integer.parseInt(userInfo.getGender()));
+
+        taPersonService.updateById(taPerson);
+
+        return ResponseBean.success(taPerson);
+    }
+
+    @ApiOperation(value="授权手机", notes = "授权手机", httpMethod = "PUT", response = TaPerson.class)
+    @PutMapping("/auth-phone")
+    public ResponseBean updateUserPhone(@ApiParam("授权手机的参数") @RequestBody WxMaUitl.AuthParam param) throws Exception {
+
+        // 解密
+        WxMaPhoneNumberInfo phoneNoInfo = wxMaUitl.getPhoneNoInfo(param);
+
+        TaPerson taPerson = currentPerson();
+        if (null == taPerson) {
+            throw new Exception("校验当前人员失败, 请重试");
+        }
+
+        taPerson.setPhone(phoneNoInfo.getPhoneNumber());
+        taPersonService.updateById(taPerson);
+
+        return ResponseBean.success(taPerson);
+    }
+
+}

src/main/java/com/example/civilizedcity/mapper/SysLoginMapper.java

@@ -12,5 +12,7 @@ import com.example.civilizedcity.entity.SysLogin;
  */
 @Mapper
 public interface SysLoginMapper  extends BaseMapper<SysLogin>{
-    
-}
+    SysLogin getByAccount(@Param("account") String account);
+
+     SysLogin getByUserAndPassword(@Param("userId") String userId, @Param("password") String password);
+ }

src/main/java/com/example/civilizedcity/mapper/SysUserMapper.java

@@ -12,5 +12,4 @@ import com.example.civilizedcity.entity.SysUser;
  */
 @Mapper
 public interface SysUserMapper  extends BaseMapper<SysUser>{
-    
-}
+ }

src/main/java/com/example/civilizedcity/mapper/TaPersonMapper.java

@@ -1,6 +1,7 @@
 package com.example.civilizedcity.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.example.civilizedcity.entity.SysUser;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 import com.example.civilizedcity.entity.TaPerson;
@@ -12,5 +13,10 @@ import com.example.civilizedcity.entity.TaPerson;
  */
 @Mapper
 public interface TaPersonMapper  extends BaseMapper<TaPerson>{
-    
-}
+
+     SysUser getReflectUser(@Param("personId") String personId);
+
+     TaPerson getByUser(@Param("userId") String userId);
+
+     TaPerson getByUserAndPerson(@Param("userId") String userId, @Param("personId") String personId);
+ }

src/main/java/com/example/civilizedcity/service/SysUserService.java

@@ -1,13 +1,18 @@
 package com.example.civilizedcity.service;
 
-import com.baomidou.mybatisplus.extension.service.IService;
 import com.example.civilizedcity.entity.SysUser;
+import com.example.civilizedcity.vo.ChangePassword;
+import com.example.civilizedcity.vo.LoginParam;
 
- /**
+/**
  * 用户表;(sys_user)表服务接口
+ *
  * @author : http://njyunzhi.com
  * @date : 2022-12-12
  */
 public interface SysUserService extends IBaseService<SysUser> {
-    
+
+    SysUser login(LoginParam loginParm) throws Exception;
+
+    boolean changePassword(SysUser user, ChangePassword param) throws Exception;
 }

src/main/java/com/example/civilizedcity/service/TaPersonService.java

@@ -1,6 +1,7 @@
 package com.example.civilizedcity.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.example.civilizedcity.entity.SysUser;
 import com.example.civilizedcity.entity.TaPerson;
 
  /**
@@ -9,5 +10,12 @@ import com.example.civilizedcity.entity.TaPerson;
  * @date : 2022-12-12
  */
 public interface TaPersonService extends IBaseService<TaPerson> {
-    
-}
+
+     TaPerson getByOpenId(String openid);
+
+     SysUser getReflectUser(TaPerson taPerson);
+
+     TaPerson getByUser(SysUser sysUser);
+
+     TaPerson getByUserAndPerson(SysUser user, String personId);
+ }

src/main/java/com/example/civilizedcity/service/impl/SysUserServiceImpl.java

@@ -1,16 +1,76 @@
 package com.example.civilizedcity.service.impl;
 
+import com.example.civilizedcity.common.Constants;
+import com.example.civilizedcity.common.EncryptUtils;
+import com.example.civilizedcity.common.StringUtils;
+import com.example.civilizedcity.entity.SysLogin;
+import com.example.civilizedcity.mapper.SysLoginMapper;
+import com.example.civilizedcity.vo.ChangePassword;
+import com.example.civilizedcity.vo.LoginParam;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.example.civilizedcity.entity.SysUser;
 import com.example.civilizedcity.mapper.SysUserMapper;
 import com.example.civilizedcity.service.SysUserService;
- /**
+
+/**
  * 用户表;(sys_user)表服务实现类
+ *
  * @author : http://www.chiner.pro
  * @date : 2022-12-12
  */
 @Service
 public class SysUserServiceImpl extends BaseServiceImpl<SysUserMapper, SysUser> implements SysUserService {
-    
+
+    @Autowired
+    SysLoginMapper sysLoginMapper;
+
+    @Override
+    public SysUser login(LoginParam loginParm) throws Exception {
+        SysLogin sysLogin = sysLoginMapper.getByAccount(loginParm.getAccount());
+        if (null == sysLogin) {
+            throw new Exception("用户名或者密码不正确");
+        }
+
+        String userId = sysLogin.getUserId();
+        if (StringUtils.isEmpty(userId)) {
+            throw new Exception("用户名或者密码不正确");
+        }
+
+        boolean isRight = checkPassword(loginParm.getPassword(), sysLogin.getPassword(), userId);
+        if (!isRight) {
+            throw new Exception("用户名或者密码不正确");
+        }
+
+        SysUser sysUser = getById(userId);
+        if (Constants.STATUS_DELETE == sysUser.getStatus()) {
+            throw new Exception("用户账户已删除");
+        }
+
+        if (Constants.STATUS_NORMAL != sysUser.getStatus()) {
+            throw new Exception("用户已停用");
+        }
+
+        return sysUser;
+    }
+
+    @Override
+    public boolean changePassword(SysUser user, ChangePassword param) throws Exception {
+        String passwordEncrypted = EncryptUtils.md5(param.getOriginPassword(), user.getUserId());
+        SysLogin sysLogin = sysLoginMapper.getByUserAndPassword(user.getUserId(), passwordEncrypted);
+
+        if (null == sysLogin) {
+            throw new Exception("原始密码不正确");
+        }
+
+        String newPassword = EncryptUtils.md5(param.getNewPassword(), user.getUserId());
+        sysLogin.setPassword(newPassword);
+
+        return sysLoginMapper.updateById(sysLogin) > 0;
+    }
+
+    boolean checkPassword(String src, String targ, String salt) {
+        String newPass = EncryptUtils.md5(src, salt);
+        return targ.equals(newPass);
+    }
 }

src/main/java/com/example/civilizedcity/service/impl/TaPersonServiceImpl.java

@@ -1,16 +1,38 @@
 package com.example.civilizedcity.service.impl;
 
+import com.example.civilizedcity.entity.SysUser;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.example.civilizedcity.entity.TaPerson;
 import com.example.civilizedcity.mapper.TaPersonMapper;
 import com.example.civilizedcity.service.TaPersonService;
- /**
+
+/**
  * 人员表;(ta_person)表服务实现类
+ *
  * @author : http://www.chiner.pro
  * @date : 2022-12-12
  */
 @Service
 public class TaPersonServiceImpl extends BaseServiceImpl<TaPersonMapper, TaPerson> implements TaPersonService {
-    
+
+    @Override
+    public TaPerson getByOpenId(String openid) {
+        return getExistBy("openid", openid, false, true);
+    }
+
+    @Override
+    public SysUser getReflectUser(TaPerson taPerson) {
+        return baseMapper.getReflectUser(taPerson.getPersonId());
+    }
+
+    @Override
+    public TaPerson getByUser(SysUser sysUser) {
+        return baseMapper.getByUser(sysUser.getUserId());
+    }
+
+    @Override
+    public TaPerson getByUserAndPerson(SysUser user, String personId) {
+        return baseMapper.getByUserAndPerson(user.getUserId(), personId);
+    }
 }

src/main/java/com/example/civilizedcity/vo/ChangePassword.java

@@ -0,0 +1,17 @@
+package com.example.civilizedcity.vo;
+
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@ApiModel(description = "登录参数")
+@Data
+public class ChangePassword {
+
+    @ApiModelProperty("原始密码")
+    String originPassword;
+
+    @ApiModelProperty("新密码")
+    String newPassword;
+}

src/main/java/com/example/civilizedcity/vo/LoginParam.java

@@ -0,0 +1,17 @@
+package com.example.civilizedcity.vo;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+@ApiModel("登录参数")
+public class LoginParam {
+
+    @ApiModelProperty("用户名")
+    String account;
+
+    @ApiModelProperty("密码")
+    String password;
+
+}

src/main/resources/application.yml

@@ -15,6 +15,8 @@ spring:
     multipart:
       max-file-size: 1024MB
       max-request-size: 1024MB
+  profiles:
+    active: @profileActive@
 
 ###
 yz:
@@ -23,8 +25,16 @@ yz:
       - "/swagger-ui/**"
       - "/swagger-resources/**"
       - "/v2/**"
-      - "/login"
       - "/static/**"
+      - "/**/login"
+
+wx:
+  miniapp:
+    appid:
+    secret:
+    token:
+    aesKey:
+
 
 sa-token:
   # jwt秘钥

src/main/resources/mapper/SysLoginMapper.xml

@@ -2,5 +2,22 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 
 <mapper namespace="com.example.civilizedcity.mapper.SysLoginMapper">
-    
+
+    <select id="getByAccount" resultType="com.example.civilizedcity.entity.SysLogin">
+        SELECT
+            *
+        FROM
+            sys_login t
+        WHERE
+            t.account = #{account}
+    </select>
+    <select id="getByUserAndPassword" resultType="com.example.civilizedcity.entity.SysLogin">
+        SELECT
+            *
+        FROM
+            sys_login t
+        WHERE
+            t.user_id = #{userId}
+          AND t.`password` = #{password}
+    </select>
 </mapper>

src/main/resources/mapper/TaPersonMapper.xml

@@ -2,5 +2,33 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 
 <mapper namespace="com.example.civilizedcity.mapper.TaPersonMapper">
-    
+
+    <select id="getReflectUser" resultType="com.example.civilizedcity.entity.SysUser">
+        SELECT
+            m.*
+        FROM
+            ta_person_reflect t
+                INNER JOIN sys_user m ON m.user_id = t.user_id
+        WHERE
+            t.person_id = #{personId}
+    </select>
+    <select id="getByUser" resultType="com.example.civilizedcity.entity.TaPerson">
+        SELECT
+            m.*
+        FROM
+            ta_person_reflect t
+                INNER JOIN ta_person m ON m.person_id = t.person_id
+        WHERE
+            t.user_id = #{userId}
+    </select>
+    <select id="getByUserAndPerson" resultType="com.example.civilizedcity.entity.TaPerson">
+        SELECT
+            m.*
+        FROM
+            ta_person_reflect t
+                INNER JOIN ta_person m ON m.person_id = t.person_id
+        WHERE
+            t.person_id = #{personId}
+            AND t.user_id = #{userId}
+    </select>
 </mapper>