[add]添加domain dao service层

Author: DougLee

spring-boot-shiro/pom.xml

@@ -25,21 +25,27 @@
 	</properties>
 
 	<dependencies>
+		<!--<dependency>-->
+			<!--<groupId>org.springframework.boot</groupId>-->
+			<!--<artifactId>spring-boot-starter-data-jpa</artifactId>-->
+		<!--</dependency>-->
+		<!--<dependency>-->
+			<!--<groupId>org.springframework.boot</groupId>-->
+			<!--<artifactId>spring-boot-starter-jdbc</artifactId>-->
+		<!--</dependency>-->
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
-			<artifactId>spring-boot-starter-data-jpa</artifactId>
-		</dependency>
-		<dependency>
-			<groupId>org.springframework.boot</groupId>
-			<artifactId>spring-boot-starter-jdbc</artifactId>
+			<artifactId>spring-boot-starter-thymeleaf</artifactId>
 		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
-			<artifactId>spring-boot-starter-thymeleaf</artifactId>
+			<artifactId>spring-boot-starter-web</artifactId>
 		</dependency>
+
+		<!-- aop依赖 -->
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
-			<artifactId>spring-boot-starter-web</artifactId>
+			<artifactId>spring-boot-starter-aop</artifactId>
 		</dependency>
 
 		<dependency>

spring-boot-shiro/src/main/java/com/example/springbootshiro/SpringBootShiroApplication.java

@@ -1,9 +1,13 @@
 package com.example.springbootshiro;
 
+import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
 
 @SpringBootApplication
+@EnableTransactionManagement
+@MapperScan("com.example.springbootshiro.dao")
 public class SpringBootShiroApplication {
 
 	public static void main(String[] args) {

spring-boot-shiro/src/main/java/com/example/springbootshiro/dao/CommonMapper.java renamed to spring-boot-shiro/src/main/java/com/example/springbootshiro/config/MyMapper.java

@@ -1,10 +1,10 @@
-package com.example.springbootshiro.dao;
+package com.example.springbootshiro.config;
 
 import tk.mybatis.mapper.common.Mapper;
 import tk.mybatis.mapper.common.MySqlMapper;
 
 /**
  * Created by Douglee on 2018/3/29.
  */
-public interface CommonMapper<T> extends Mapper<T>, MySqlMapper<T> {
+public interface MyMapper<T> extends Mapper<T>, MySqlMapper<T> {
 }

spring-boot-shiro/src/main/java/com/example/springbootshiro/controller/BaseController.java

@@ -0,0 +1,44 @@
+package com.example.springbootshiro.controller;
+
+import com.example.springbootshiro.domain.UserInfo;
+import com.github.pagehelper.PageInfo;
+import org.apache.shiro.SecurityUtils;
+import org.apache.shiro.authc.AuthenticationToken;
+import org.apache.shiro.session.Session;
+import org.apache.shiro.subject.Subject;
+import org.springframework.stereotype.Controller;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Created by Douglee on 2018/3/30.
+ */
+public class BaseController {
+
+    protected Map<String, Object> getDataTable(PageInfo<?> pageInfo){
+        Map<String, Object> rspData = new HashMap<>();
+        rspData.put("rows", pageInfo.getList());
+        rspData.put("total", pageInfo.getTotal());
+        return rspData;
+    }
+    public static Subject getSubject() {
+        return SecurityUtils.getSubject();
+    }
+
+    protected UserInfo getCurrentUser() {
+        return (UserInfo) getSubject().getPrincipal();
+    }
+
+    protected Session getSession() {
+        return getSubject().getSession();
+    }
+
+    protected Session getSession(Boolean flag) {
+        return getSubject().getSession(flag);
+    }
+
+    protected void login(AuthenticationToken token) {
+        getSubject().login(token);
+    }
+}

spring-boot-shiro/src/main/java/com/example/springbootshiro/controller/LoginController.java

@@ -0,0 +1,74 @@
+package com.example.springbootshiro.controller;
+
+import com.example.springbootshiro.domain.ResponseResult;
+import com.example.springbootshiro.domain.UserInfo;
+import com.example.springbootshiro.service.UserService;
+import com.example.springbootshiro.util.MD5Utils;
+import com.example.springbootshiro.util.StringUtils;
+import org.apache.shiro.authc.*;
+import org.apache.shiro.session.Session;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.Model;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+/**
+ * Created by Douglee on 2018/3/30.
+ */
+@Controller
+public class LoginController extends BaseController {
+
+    @Autowired
+    private UserService userService;
+
+    @GetMapping("/login")
+    public String login() {
+        return "login";
+    }
+
+    @PostMapping("/login")
+    @ResponseBody
+    public ResponseResult login(String username, String password, String code, Boolean rememberMe) {
+        if (StringUtils.isNullorEmpty(code)) {
+            return ResponseResult.warn("验证码不能为空!");
+        }
+//        Session session = super.getSession();
+//        String sessionCode = (String) session.getAttribute("_code");
+//        if (!code.toLowerCase().equals(sessionCode)) {
+//            return ResponseResult.warn("验证码错误！");
+//        }
+
+        password = MD5Utils.encrypt(username.toLowerCase(), password);
+        UsernamePasswordToken token = new UsernamePasswordToken(username, password, rememberMe);
+
+        try {
+            super.login(token);
+            this.userService.updateLoginTime(username);
+            return ResponseResult.ok();
+        } catch (AuthenticationException e) {
+            return ResponseResult.error("认证失败！");
+        } catch (Exception e) {
+            return ResponseResult.error(e.getMessage());
+        }
+    }
+    @RequestMapping("/")
+    public String redirectIndex() {
+        return "redirect:/index";
+    }
+
+    @GetMapping("/403")
+    public String forbid() {
+        return "403";
+    }
+
+    @RequestMapping("/index")
+    public String index(Model model) {
+        UserInfo user = super.getCurrentUser();
+        model.addAttribute("user", user);
+        return "index";
+    }
+
+}

spring-boot-shiro/src/main/java/com/example/springbootshiro/dao/MenuMapper.java

@@ -1,13 +1,14 @@
 package com.example.springbootshiro.dao;
 
+import com.example.springbootshiro.config.MyMapper;
 import com.example.springbootshiro.domain.MenuInfo;
 
 import java.util.List;
 
 /**
  * Created by Douglee on 2018/3/29.
  */
-public interface MenuMapper extends CommonMapper<MenuMapper>  {
+public interface MenuMapper extends MyMapper<MenuInfo> {
 
     List<MenuInfo> findUserPermissions(String userName);
 

spring-boot-shiro/src/main/java/com/example/springbootshiro/dao/RoleMapper.java

@@ -1,13 +1,14 @@
 package com.example.springbootshiro.dao;
 
+import com.example.springbootshiro.config.MyMapper;
 import com.example.springbootshiro.domain.RoleInfo;
 
 import java.util.List;
 
 /**
  * Created by Douglee on 2018/3/29.
  */
-public interface RoleMapper extends CommonMapper<RoleInfo> {
+public interface RoleMapper extends MyMapper<RoleInfo> {
 
     List<RoleInfo> findUserRole(String userName);
 

spring-boot-shiro/src/main/java/com/example/springbootshiro/dao/RoleMenuMapper.java

@@ -1,9 +1,10 @@
 package com.example.springbootshiro.dao;
 
+import com.example.springbootshiro.config.MyMapper;
 import com.example.springbootshiro.domain.RoleMenu;
 
 /**
  * Created by Douglee on 2018/3/29.
  */
-public interface RoleMenuMapper extends CommonMapper<RoleMenu> {
+public interface RoleMenuMapper extends MyMapper<RoleMenu> {
 }

spring-boot-shiro/src/main/java/com/example/springbootshiro/dao/UserMapper.java

@@ -1,13 +1,12 @@
 package com.example.springbootshiro.dao;
 
+import com.example.springbootshiro.config.MyMapper;
 import com.example.springbootshiro.domain.UserInfo;
 
-import java.util.List;
-
 /**
  * Created by Douglee on 2018/3/29.
  */
-public interface UserMapper extends CommonMapper<UserInfo> {
+public interface UserMapper extends MyMapper<UserInfo> {
 
     UserInfo findUserProfile(UserInfo user);
 }

spring-boot-shiro/src/main/java/com/example/springbootshiro/dao/UserRoleMapper.java

@@ -1,9 +1,10 @@
 package com.example.springbootshiro.dao;
 
+import com.example.springbootshiro.config.MyMapper;
 import com.example.springbootshiro.domain.UserRole;
 
 /**
  * Created by Douglee on 2018/3/29.
  */
-public interface UserRoleMapper extends CommonMapper<UserRole> {
+public interface UserRoleMapper extends MyMapper<UserRole> {
 }

spring-boot-shiro/src/main/java/com/example/springbootshiro/domain/ResponseResult.java

@@ -0,0 +1,54 @@
+package com.example.springbootshiro.domain;
+
+import java.util.HashMap;
+
+/**
+ * Created by Douglee on 2018/3/30.
+ */
+public class ResponseResult extends HashMap<String, Object> {
+
+    private static final long serialVersionUID = -556622754874885339L;
+
+    private static final Integer SUCCESS = 0;
+    private static final Integer WARN = 0;
+    private static final Integer FAIL = 500;
+
+    public ResponseResult() {
+        put("code", SUCCESS);
+        put("msg", "操作成功");
+    }
+
+    public static ResponseResult error(Object msg) {
+        ResponseResult responseResult = new ResponseResult();
+        responseResult.put("msg", msg);
+        responseResult.put("code", FAIL);
+
+        return responseResult;
+    }
+
+    public static ResponseResult warn(Object msg) {
+        ResponseResult responseResult = new ResponseResult();
+        responseResult.put("msg", msg);
+        responseResult.put("code", WARN);
+
+        return responseResult;
+    }
+
+    public static ResponseResult ok(Object msg) {
+        ResponseResult responseResult = new ResponseResult();
+        responseResult.put("msg", msg);
+        responseResult.put("code", SUCCESS);
+
+        return responseResult;
+    }
+
+    public static ResponseResult ok() {
+        return new ResponseResult();
+    }
+
+    @Override
+    public ResponseResult put(String key, Object value) {
+        super.put(key, value);
+        return this;
+    }
+}

spring-boot-shiro/src/main/java/com/example/springbootshiro/domain/UserInfo.java

@@ -20,7 +20,7 @@ public class UserInfo implements Serializable {
     @Id
     @GeneratedValue(generator = "JDBC")
     @Column(name = "USER_ID")
-    private Integer userId;
+    private Long userId;
 
     @Column(name = "USERNAME")
     private String username;
@@ -43,11 +43,11 @@ public class UserInfo implements Serializable {
     @Transient
     private String roleName;
 
-    public Integer getUserId() {
+    public Long getUserId() {
         return userId;
     }
 
-    public void setUserId(Integer userId) {
+    public void setUserId(Long userId) {
         this.userId = userId;
     }
 

spring-boot-shiro/src/main/java/com/example/springbootshiro/service/BaseService.java

@@ -0,0 +1,64 @@
+package com.example.springbootshiro.service;
+
+import com.example.springbootshiro.service.IService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+import tk.mybatis.mapper.common.Mapper;
+import tk.mybatis.mapper.entity.Example;
+
+import java.util.List;
+
+/**
+ * Created by Douglee on 2018/3/30.
+ */
+@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
+public abstract class BaseService<T> implements IService<T> {
+
+    @Autowired
+    protected Mapper<T> mapper;
+
+    public Mapper<T> getMapper() {
+        return mapper;
+    }
+
+    public List<T> selectAll() {
+        return mapper.selectAll();
+    }
+
+    public T selectByKey(Object key) {
+        return mapper.selectByPrimaryKey(key);
+    }
+
+    @Transactional(propagation = Propagation.REQUIRED, readOnly = false)
+    public int save(T entity) {
+        return mapper.insert(entity);
+    }
+
+    @Transactional(propagation = Propagation.REQUIRED, readOnly = false)
+    public int delete(Object key) {
+        return mapper.deleteByPrimaryKey(key);
+    }
+
+    @Transactional(propagation = Propagation.REQUIRED, readOnly = false)
+    public int batchDelete(List<String> list, String property, Class<T> clazz) {
+        Example example = new Example(clazz);
+        example.createCriteria().andIn(property, list);
+
+        return this.mapper.deleteByExample(example);
+    }
+
+    @Transactional(propagation = Propagation.REQUIRED, readOnly = false)
+    public int updateAll(T entity) {
+        return mapper.updateByPrimaryKey(entity);
+    }
+
+    @Transactional(propagation = Propagation.REQUIRED, readOnly = false)
+    public int updateNotNull(T entity) {
+        return mapper.updateByPrimaryKeySelective(entity);
+    }
+
+    public List<T> selectByExample(Object example) {
+        return mapper.selectByExample(example);
+    }
+}