feaets

pom.xml

@@ -38,15 +38,9 @@
 			<version>2.0.1</version>
 		</dependency>
 		<dependency>
-			<groupId>p6spy</groupId>
-			<artifactId>p6spy</artifactId>
-			<version>3.8.7</version>
-		</dependency>
-		<!-- sqlite3驱动包 -->
-		<dependency>
-			<groupId>org.xerial</groupId>
-			<artifactId>sqlite-jdbc</artifactId>
-			<version>3.27.2.1</version>
+			<groupId>mysql</groupId>
+			<artifactId>mysql-connector-java</artifactId>
+			<scope>runtime</scope>
 		</dependency>
 		<dependency>
 			<groupId>com.baomidou</groupId>
@@ -75,6 +69,20 @@
 			<scope>test</scope>
 		</dependency>
 
+		<!-- Sa-Token 权限认证, 在线文档：http://sa-token.dev33.cn/ -->
+		<dependency>
+			<groupId>cn.dev33</groupId>
+			<artifactId>sa-token-spring-boot-starter</artifactId>
+			<version>1.29.0</version>
+		</dependency>
+
+		<!-- Sa-Token 整合 jwt -->
+		<dependency>
+			<groupId>cn.dev33</groupId>
+			<artifactId>sa-token-jwt</artifactId>
+			<version>1.29.0</version>
+		</dependency>
+
 		<!--excel start-->
 		<dependency>
 			<groupId>com.alibaba</groupId>

src/main/java/com/yunzhi/inte/InteApplication.java

@@ -1,10 +1,11 @@
 package com.yunzhi.inte;
 
-import com.yunzhi.inte.rtsp.MonitorServer;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.scheduling.annotation.EnableAsync;
 
+@EnableAsync
 @SpringBootApplication
 public class InteApplication {
 	public static ConfigurableApplicationContext ac;

src/main/java/com/yunzhi/inte/common/BaseController.java

@@ -1,8 +1,26 @@
 package com.yunzhi.inte.common;
 
+import cn.dev33.satoken.stp.StpUtil;
+import com.yunzhi.inte.entity.Users;
+import com.yunzhi.inte.service.UsersService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 @Component
 public class BaseController {
 
+    @Autowired
+    protected UsersService usersService;
+
+    public Users currentUser() throws Exception {
+        int userId = StpUtil.getLoginIdAsInt();
+
+        Users user = usersService.getById(userId);
+        if (user == null) {
+            throw new Exception("人员不存在");
+        }
+
+        return user;
+    }
+
 }

src/main/java/com/yunzhi/inte/common/EncryptUtils.java

@@ -0,0 +1,17 @@
+package com.yunzhi.inte.common;
+
+import org.springframework.util.DigestUtils;
+
+public class EncryptUtils {
+
+    public static String md5(String str, String ...slats) {
+        String slat = "";
+        if (null != slats && slats.length > 0) {
+            slat = slats[0];
+        }
+
+        String base = str + slat;
+        String md5 = DigestUtils.md5DigestAsHex(base.getBytes());
+        return md5;
+    }
+}

src/main/java/com/yunzhi/inte/config/FilterConfig.java

@@ -0,0 +1,14 @@
+package com.yunzhi.inte.config;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Data
+@Component
+@ConfigurationProperties(prefix = "yz.filter")
+public class FilterConfig {
+    List<String> annList;
+}

src/main/java/com/yunzhi/inte/config/SaTokenConfigure.java

@@ -0,0 +1,48 @@
+package com.yunzhi.inte.config;
+
+import cn.dev33.satoken.context.SaHolder;
+import cn.dev33.satoken.filter.SaServletFilter;
+import cn.dev33.satoken.jwt.StpLogicJwtForStateless;
+import cn.dev33.satoken.router.SaHttpMethod;
+import cn.dev33.satoken.router.SaRouter;
+import cn.dev33.satoken.stp.StpLogic;
+import cn.dev33.satoken.stp.StpUtil;
+import com.alibaba.fastjson.JSONObject;
+import com.yunzhi.inte.common.ResponseBean;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class SaTokenConfigure {
+
+    @Autowired
+    FilterConfig filterConfig;
+
+    @Bean
+    public SaServletFilter getSaServletFilter() {
+        SaServletFilter saServletFilter = new SaServletFilter();
+        saServletFilter.addInclude("/**");
+        saServletFilter.addExclude(filterConfig.getAnnList().toArray(new String[0]));
+        saServletFilter.setAuth(auth -> {
+            // OPTIONS 请求不校验, 主要是为了解决跨域问题
+            SaRouter.notMatch(SaHttpMethod.OPTIONS).check(r -> StpUtil.checkLogin());
+        });
+
+        saServletFilter.setError(err -> {
+            SaHolder.getResponse().setHeader("Content-Type", "application/json;charset=UTF-8");
+            SaHolder.getResponse().setStatus(200);
+            String jsonStr = JSONObject.toJSONString(ResponseBean.error(err.getMessage(), ResponseBean.ERROR_AUTH_FAIL));
+            return jsonStr;
+        });
+
+        return saServletFilter;
+    }
+
+
+    // Sa-Token 整合 jwt (Style模式)
+    @Bean
+    public StpLogic getStpLogicJwt() {
+        return new StpLogicJwtForStateless();
+    }
+}

src/main/java/com/yunzhi/inte/controller/BannerController.java

@@ -34,7 +34,7 @@ public class BannerController {
 
         IPage<Banner> pg = new Page<>(pageNum, pageSize);
         QueryWrapper<Banner> queryWrapper = new QueryWrapper<>();
-        queryWrapper.eq(null != state && !"".equals(state), "state", state);
+        queryWrapper.eq(null != state && !"".equals(state), "status", state);
         queryWrapper.orderByDesc("qz");
 
         IPage<Banner> result = bannerService.page(pg, queryWrapper);

src/main/java/com/yunzhi/inte/controller/EvaluateController.java

@@ -0,0 +1,101 @@
+package com.yunzhi.inte.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yunzhi.inte.common.BaseController;
+import com.yunzhi.inte.common.ResponseBean;
+import java.util.List;
+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 com.yunzhi.inte.entity.Evaluate;
+import com.yunzhi.inte.service.EvaluateService;
+
+ /**
+ * 评价表;(evaluate)表控制层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-13
+ */
+@Api(tags = "评价表对象功能接口")
+@RestController
+@RequestMapping("/")
+public class EvaluateController extends BaseController {
+    
+    @Autowired
+    private EvaluateService evaluateService;
+    
+    /** 
+     * 通过ID查询单条数据 
+     *
+     * @param id 主键
+     * @return 实例对象
+     */
+    @ApiOperation("通过ID查询单条数据")
+    @GetMapping("/evaluate/{id}")
+    public ResponseBean queryById(@ApiParam("对象ID") @PathVariable Integer id) throws Exception {
+        return ResponseBean.success(evaluateService.getById(id));
+    }
+    
+    /** 
+     * 分页查询
+     *
+     * @param pageNum 当前页码
+     * @param pageSize 每页条数
+     * @return 查询结果
+     */
+    @ApiOperation("分页查询")
+    @GetMapping("/evaluate")
+    public ResponseBean list(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                            @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception {
+        
+        IPage<Evaluate> pg = new Page<>(pageNum, pageSize);
+        // QueryWrapper<Evaluate> queryWrapper = new QueryWrapper<>();
+        // queryWrapper.orderByDesc("create_date");
+        IPage<Evaluate> result = evaluateService.page(pg);
+        
+        return ResponseBean.success(result);
+    }
+    
+    /** 
+     * 新增数据
+     *
+     * @param evaluate 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("新增数据")
+    @PostMapping("/evaluate")
+    public ResponseBean add(@ApiParam("对象实体") @RequestBody Evaluate evaluate) throws Exception {
+        evaluateService.save(evaluate);
+        return ResponseBean.success(evaluate);
+    }
+    
+    /** 
+     * 更新数据
+     *
+     * @param evaluate 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("更新数据")
+    @PutMapping("/evaluate/{id}")
+    public ResponseBean edit(@ApiParam("对象实体") @RequestBody Evaluate evaluate,
+                            @ApiParam("对象ID") @PathVariable Integer id ) throws Exception {
+        evaluateService.updateById(evaluate);
+        return ResponseBean.success(evaluate);
+    }
+    
+    /** 
+     * 通过主键删除数据
+     *
+     * @param id 主键
+     * @return 是否成功
+     */
+    @ApiOperation("通过主键删除数据")
+    @DeleteMapping("/evaluate/{id}")
+    public ResponseBean deleteById(@ApiParam("对象ID") @PathVariable Integer id){
+        evaluateService.removeLogicById(id);
+        return ResponseBean.success("success");
+    }
+}

src/main/java/com/yunzhi/inte/controller/LoginController.java

@@ -0,0 +1,80 @@
+package com.yunzhi.inte.controller;
+
+import cn.dev33.satoken.stp.StpUtil;
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.yunzhi.inte.common.BaseController;
+import com.yunzhi.inte.common.EncryptUtils;
+import com.yunzhi.inte.common.ResponseBean;
+import com.yunzhi.inte.common.StringUtils;
+import com.yunzhi.inte.entity.Users;
+import com.yunzhi.inte.vo.ChangePassword;
+import com.yunzhi.inte.vo.LoginParm;
+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.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.HashMap;
+import java.util.Map;
+
+
+@Api(tags ="登录")
+@RestController
+@RequestMapping("/")
+public class LoginController extends BaseController {
+
+
+    @PostMapping("/login")
+    @ApiOperation(value="后台登录", notes = "后台登录", httpMethod = "POST", response = ResponseBean.class)
+    public ResponseBean login(@ApiParam("登录参数") @RequestBody LoginParm loginParm) throws Exception {
+
+        if (StringUtils.isEmpty(loginParm.getUserName()) || StringUtils.isEmpty(loginParm.getPassword())) {
+            return ResponseBean.error("登录用户或者密码不能为空");
+        }
+
+        Users sysUser = usersService.login(loginParm);
+
+        StpUtil.login(sysUser.getId(), "admin");
+        String tokenValue = StpUtil.getTokenValue();
+
+        Map<String, Object> result = new HashMap<>();
+        result.put("user", sysUser);
+        result.put("token", tokenValue);
+
+        return ResponseBean.success(result);
+    }
+
+    @PostMapping("/admin/logout")
+    @ApiOperation(value="登出", notes = "登出", httpMethod = "POST", response = ResponseBean.class)
+    public ResponseBean logout() throws Exception {
+        StpUtil.logout();
+        return ResponseBean.success("success");
+    }
+
+    @PutMapping("/admin/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);
+        }
+
+        Users currentUser = currentUser();
+        String userId = currentUser.getId().toString();
+
+        if (!checkPassword(param.getOriginPassword(), currentUser.getPassword(), userId)) {
+            return ResponseBean.error("原始密码不正确", ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+
+        currentUser.setPassword(EncryptUtils.md5(param.getNewPassword(), userId));
+        usersService.updateById(currentUser);
+
+        return ResponseBean.success("密码修改成功");
+    }
+
+    private boolean checkPassword(String src, String targ, String salt) {
+        return EncryptUtils.md5(src, salt).equals(targ);
+    }
+}

src/main/java/com/yunzhi/inte/controller/NoticeMessageController.java

@@ -0,0 +1,101 @@
+package com.yunzhi.inte.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yunzhi.inte.common.BaseController;
+import com.yunzhi.inte.common.ResponseBean;
+import java.util.List;
+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 com.yunzhi.inte.entity.NoticeMessage;
+import com.yunzhi.inte.service.NoticeMessageService;
+
+ /**
+ * 消息表;(notice_message)表控制层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-13
+ */
+@Api(tags = "消息表对象功能接口")
+@RestController
+@RequestMapping("/")
+public class NoticeMessageController extends BaseController {
+    
+    @Autowired
+    private NoticeMessageService noticeMessageService;
+    
+    /** 
+     * 通过ID查询单条数据 
+     *
+     * @param id 主键
+     * @return 实例对象
+     */
+    @ApiOperation("通过ID查询单条数据")
+    @GetMapping("/noticeMessage/{id}")
+    public ResponseBean queryById(@ApiParam("对象ID") @PathVariable Integer id) throws Exception {
+        return ResponseBean.success(noticeMessageService.getById(id));
+    }
+    
+    /** 
+     * 分页查询
+     *
+     * @param pageNum 当前页码
+     * @param pageSize 每页条数
+     * @return 查询结果
+     */
+    @ApiOperation("分页查询")
+    @GetMapping("/noticeMessage")
+    public ResponseBean list(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                            @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception {
+        
+        IPage<NoticeMessage> pg = new Page<>(pageNum, pageSize);
+        // QueryWrapper<NoticeMessage> queryWrapper = new QueryWrapper<>();
+        // queryWrapper.orderByDesc("create_date");
+        IPage<NoticeMessage> result = noticeMessageService.page(pg);
+        
+        return ResponseBean.success(result);
+    }
+    
+    /** 
+     * 新增数据
+     *
+     * @param noticeMessage 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("新增数据")
+    @PostMapping("/noticeMessage")
+    public ResponseBean add(@ApiParam("对象实体") @RequestBody NoticeMessage noticeMessage) throws Exception {
+        noticeMessageService.save(noticeMessage);
+        return ResponseBean.success(noticeMessage);
+    }
+    
+    /** 
+     * 更新数据
+     *
+     * @param noticeMessage 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("更新数据")
+    @PutMapping("/noticeMessage/{id}")
+    public ResponseBean edit(@ApiParam("对象实体") @RequestBody NoticeMessage noticeMessage,
+                            @ApiParam("对象ID") @PathVariable Integer id ) throws Exception {
+        noticeMessageService.updateById(noticeMessage);
+        return ResponseBean.success(noticeMessage);
+    }
+    
+    /** 
+     * 通过主键删除数据
+     *
+     * @param id 主键
+     * @return 是否成功
+     */
+    @ApiOperation("通过主键删除数据")
+    @DeleteMapping("/noticeMessage/{id}")
+    public ResponseBean deleteById(@ApiParam("对象ID") @PathVariable Integer id){
+        noticeMessageService.removeLogicById(id);
+        return ResponseBean.success("success");
+    }
+}

src/main/java/com/yunzhi/inte/controller/PostsFilesController.java

@@ -0,0 +1,101 @@
+package com.yunzhi.inte.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yunzhi.inte.common.BaseController;
+import com.yunzhi.inte.common.ResponseBean;
+import java.util.List;
+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 com.yunzhi.inte.entity.PostsFiles;
+import com.yunzhi.inte.service.PostsFilesService;
+
+ /**
+ * 关联文件;(posts_files)表控制层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-13
+ */
+@Api(tags = "关联文件对象功能接口")
+@RestController
+@RequestMapping("/")
+public class PostsFilesController extends BaseController {
+    
+    @Autowired
+    private PostsFilesService postsFilesService;
+    
+    /** 
+     * 通过ID查询单条数据 
+     *
+     * @param id 主键
+     * @return 实例对象
+     */
+    @ApiOperation("通过ID查询单条数据")
+    @GetMapping("/postsFiles/{id}")
+    public ResponseBean queryById(@ApiParam("对象ID") @PathVariable Integer id) throws Exception {
+        return ResponseBean.success(postsFilesService.getById(id));
+    }
+    
+    /** 
+     * 分页查询
+     *
+     * @param pageNum 当前页码
+     * @param pageSize 每页条数
+     * @return 查询结果
+     */
+    @ApiOperation("分页查询")
+    @GetMapping("/postsFiles")
+    public ResponseBean list(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                            @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception {
+        
+        IPage<PostsFiles> pg = new Page<>(pageNum, pageSize);
+        // QueryWrapper<PostsFiles> queryWrapper = new QueryWrapper<>();
+        // queryWrapper.orderByDesc("create_date");
+        IPage<PostsFiles> result = postsFilesService.page(pg);
+        
+        return ResponseBean.success(result);
+    }
+    
+    /** 
+     * 新增数据
+     *
+     * @param postsFiles 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("新增数据")
+    @PostMapping("/postsFiles")
+    public ResponseBean add(@ApiParam("对象实体") @RequestBody PostsFiles postsFiles) throws Exception {
+        postsFilesService.save(postsFiles);
+        return ResponseBean.success(postsFiles);
+    }
+    
+    /** 
+     * 更新数据
+     *
+     * @param postsFiles 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("更新数据")
+    @PutMapping("/postsFiles/{id}")
+    public ResponseBean edit(@ApiParam("对象实体") @RequestBody PostsFiles postsFiles,
+                            @ApiParam("对象ID") @PathVariable Integer id ) throws Exception {
+        postsFilesService.updateById(postsFiles);
+        return ResponseBean.success(postsFiles);
+    }
+    
+    /** 
+     * 通过主键删除数据
+     *
+     * @param id 主键
+     * @return 是否成功
+     */
+    @ApiOperation("通过主键删除数据")
+    @DeleteMapping("/postsFiles/{id}")
+    public ResponseBean deleteById(@ApiParam("对象ID") @PathVariable Integer id){
+        postsFilesService.removeLogicById(id);
+        return ResponseBean.success("success");
+    }
+}

src/main/java/com/yunzhi/inte/controller/ResourcesController.java

@@ -0,0 +1,101 @@
+package com.yunzhi.inte.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yunzhi.inte.common.BaseController;
+import com.yunzhi.inte.common.ResponseBean;
+import java.util.List;
+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 com.yunzhi.inte.entity.Resources;
+import com.yunzhi.inte.service.ResourcesService;
+
+ /**
+ * 资源;(resources)表控制层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+@Api(tags = "资源对象功能接口")
+@RestController
+@RequestMapping("/")
+public class ResourcesController extends BaseController {
+    
+    @Autowired
+    private ResourcesService resourcesService;
+    
+    /** 
+     * 通过ID查询单条数据 
+     *
+     * @param id 主键
+     * @return 实例对象
+     */
+    @ApiOperation("通过ID查询单条数据")
+    @GetMapping("/resources/{id}")
+    public ResponseBean queryById(@ApiParam("对象ID") @PathVariable Integer id) throws Exception {
+        return ResponseBean.success(resourcesService.getById(id));
+    }
+    
+    /** 
+     * 分页查询
+     *
+     * @param pageNum 当前页码
+     * @param pageSize 每页条数
+     * @return 查询结果
+     */
+    @ApiOperation("分页查询")
+    @GetMapping("/resources")
+    public ResponseBean list(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                            @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception {
+        
+        IPage<Resources> pg = new Page<>(pageNum, pageSize);
+        // QueryWrapper<Resources> queryWrapper = new QueryWrapper<>();
+        // queryWrapper.orderByDesc("create_date");
+        IPage<Resources> result = resourcesService.page(pg);
+        
+        return ResponseBean.success(result);
+    }
+    
+    /** 
+     * 新增数据
+     *
+     * @param resources 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("新增数据")
+    @PostMapping("/resources")
+    public ResponseBean add(@ApiParam("对象实体") @RequestBody Resources resources) throws Exception {
+        resourcesService.save(resources);
+        return ResponseBean.success(resources);
+    }
+    
+    /** 
+     * 更新数据
+     *
+     * @param resources 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("更新数据")
+    @PutMapping("/resources/{id}")
+    public ResponseBean edit(@ApiParam("对象实体") @RequestBody Resources resources,
+                            @ApiParam("对象ID") @PathVariable Integer id ) throws Exception {
+        resourcesService.updateById(resources);
+        return ResponseBean.success(resources);
+    }
+    
+    /** 
+     * 通过主键删除数据
+     *
+     * @param id 主键
+     * @return 是否成功
+     */
+    @ApiOperation("通过主键删除数据")
+    @DeleteMapping("/resources/{id}")
+    public ResponseBean deleteById(@ApiParam("对象ID") @PathVariable Integer id){
+        resourcesService.removeLogicById(id);
+        return ResponseBean.success("success");
+    }
+}

src/main/java/com/yunzhi/inte/controller/RoleResourcesController.java

@@ -0,0 +1,101 @@
+package com.yunzhi.inte.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yunzhi.inte.common.BaseController;
+import com.yunzhi.inte.common.ResponseBean;
+import java.util.List;
+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 com.yunzhi.inte.entity.RoleResources;
+import com.yunzhi.inte.service.RoleResourcesService;
+
+ /**
+ * 角色资源;(role_resources)表控制层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+@Api(tags = "角色资源对象功能接口")
+@RestController
+@RequestMapping("/")
+public class RoleResourcesController extends BaseController {
+    
+    @Autowired
+    private RoleResourcesService roleResourcesService;
+    
+    /** 
+     * 通过ID查询单条数据 
+     *
+     * @param id 主键
+     * @return 实例对象
+     */
+    @ApiOperation("通过ID查询单条数据")
+    @GetMapping("/roleResources/{id}")
+    public ResponseBean queryById(@ApiParam("对象ID") @PathVariable Integer id) throws Exception {
+        return ResponseBean.success(roleResourcesService.getById(id));
+    }
+    
+    /** 
+     * 分页查询
+     *
+     * @param pageNum 当前页码
+     * @param pageSize 每页条数
+     * @return 查询结果
+     */
+    @ApiOperation("分页查询")
+    @GetMapping("/roleResources")
+    public ResponseBean list(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                            @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception {
+        
+        IPage<RoleResources> pg = new Page<>(pageNum, pageSize);
+        // QueryWrapper<RoleResources> queryWrapper = new QueryWrapper<>();
+        // queryWrapper.orderByDesc("create_date");
+        IPage<RoleResources> result = roleResourcesService.page(pg);
+        
+        return ResponseBean.success(result);
+    }
+    
+    /** 
+     * 新增数据
+     *
+     * @param roleResources 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("新增数据")
+    @PostMapping("/roleResources")
+    public ResponseBean add(@ApiParam("对象实体") @RequestBody RoleResources roleResources) throws Exception {
+        roleResourcesService.save(roleResources);
+        return ResponseBean.success(roleResources);
+    }
+    
+    /** 
+     * 更新数据
+     *
+     * @param roleResources 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("更新数据")
+    @PutMapping("/roleResources/{id}")
+    public ResponseBean edit(@ApiParam("对象实体") @RequestBody RoleResources roleResources,
+                            @ApiParam("对象ID") @PathVariable Integer id ) throws Exception {
+        roleResourcesService.updateById(roleResources);
+        return ResponseBean.success(roleResources);
+    }
+    
+    /** 
+     * 通过主键删除数据
+     *
+     * @param id 主键
+     * @return 是否成功
+     */
+    @ApiOperation("通过主键删除数据")
+    @DeleteMapping("/roleResources/{id}")
+    public ResponseBean deleteById(@ApiParam("对象ID") @PathVariable Integer id){
+        roleResourcesService.removeLogicById(id);
+        return ResponseBean.success("success");
+    }
+}

src/main/java/com/yunzhi/inte/controller/RolesController.java

@@ -0,0 +1,101 @@
+package com.yunzhi.inte.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yunzhi.inte.common.BaseController;
+import com.yunzhi.inte.common.ResponseBean;
+import java.util.List;
+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 com.yunzhi.inte.entity.Roles;
+import com.yunzhi.inte.service.RolesService;
+
+ /**
+ * 角色;(roles)表控制层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+@Api(tags = "角色对象功能接口")
+@RestController
+@RequestMapping("/")
+public class RolesController extends BaseController {
+    
+    @Autowired
+    private RolesService rolesService;
+    
+    /** 
+     * 通过ID查询单条数据 
+     *
+     * @param id 主键
+     * @return 实例对象
+     */
+    @ApiOperation("通过ID查询单条数据")
+    @GetMapping("/roles/{id}")
+    public ResponseBean queryById(@ApiParam("对象ID") @PathVariable Integer id) throws Exception {
+        return ResponseBean.success(rolesService.getById(id));
+    }
+    
+    /** 
+     * 分页查询
+     *
+     * @param pageNum 当前页码
+     * @param pageSize 每页条数
+     * @return 查询结果
+     */
+    @ApiOperation("分页查询")
+    @GetMapping("/roles")
+    public ResponseBean list(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                            @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception {
+        
+        IPage<Roles> pg = new Page<>(pageNum, pageSize);
+        // QueryWrapper<Roles> queryWrapper = new QueryWrapper<>();
+        // queryWrapper.orderByDesc("create_date");
+        IPage<Roles> result = rolesService.page(pg);
+        
+        return ResponseBean.success(result);
+    }
+    
+    /** 
+     * 新增数据
+     *
+     * @param roles 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("新增数据")
+    @PostMapping("/roles")
+    public ResponseBean add(@ApiParam("对象实体") @RequestBody Roles roles) throws Exception {
+        rolesService.save(roles);
+        return ResponseBean.success(roles);
+    }
+    
+    /** 
+     * 更新数据
+     *
+     * @param roles 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("更新数据")
+    @PutMapping("/roles/{id}")
+    public ResponseBean edit(@ApiParam("对象实体") @RequestBody Roles roles,
+                            @ApiParam("对象ID") @PathVariable Integer id ) throws Exception {
+        rolesService.updateById(roles);
+        return ResponseBean.success(roles);
+    }
+    
+    /** 
+     * 通过主键删除数据
+     *
+     * @param id 主键
+     * @return 是否成功
+     */
+    @ApiOperation("通过主键删除数据")
+    @DeleteMapping("/roles/{id}")
+    public ResponseBean deleteById(@ApiParam("对象ID") @PathVariable Integer id){
+        rolesService.removeLogicById(id);
+        return ResponseBean.success("success");
+    }
+}

src/main/java/com/yunzhi/inte/controller/UserRolesController.java

@@ -0,0 +1,101 @@
+package com.yunzhi.inte.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yunzhi.inte.common.BaseController;
+import com.yunzhi.inte.common.ResponseBean;
+import java.util.List;
+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 com.yunzhi.inte.entity.UserRoles;
+import com.yunzhi.inte.service.UserRolesService;
+
+ /**
+ * 授权角色;(user_roles)表控制层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+@Api(tags = "授权角色对象功能接口")
+@RestController
+@RequestMapping("/")
+public class UserRolesController extends BaseController {
+    
+    @Autowired
+    private UserRolesService userRolesService;
+    
+    /** 
+     * 通过ID查询单条数据 
+     *
+     * @param id 主键
+     * @return 实例对象
+     */
+    @ApiOperation("通过ID查询单条数据")
+    @GetMapping("/userRoles/{id}")
+    public ResponseBean queryById(@ApiParam("对象ID") @PathVariable Integer id) throws Exception {
+        return ResponseBean.success(userRolesService.getById(id));
+    }
+    
+    /** 
+     * 分页查询
+     *
+     * @param pageNum 当前页码
+     * @param pageSize 每页条数
+     * @return 查询结果
+     */
+    @ApiOperation("分页查询")
+    @GetMapping("/userRoles")
+    public ResponseBean list(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                            @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception {
+        
+        IPage<UserRoles> pg = new Page<>(pageNum, pageSize);
+        // QueryWrapper<UserRoles> queryWrapper = new QueryWrapper<>();
+        // queryWrapper.orderByDesc("create_date");
+        IPage<UserRoles> result = userRolesService.page(pg);
+        
+        return ResponseBean.success(result);
+    }
+    
+    /** 
+     * 新增数据
+     *
+     * @param userRoles 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("新增数据")
+    @PostMapping("/userRoles")
+    public ResponseBean add(@ApiParam("对象实体") @RequestBody UserRoles userRoles) throws Exception {
+        userRolesService.save(userRoles);
+        return ResponseBean.success(userRoles);
+    }
+    
+    /** 
+     * 更新数据
+     *
+     * @param userRoles 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("更新数据")
+    @PutMapping("/userRoles/{id}")
+    public ResponseBean edit(@ApiParam("对象实体") @RequestBody UserRoles userRoles,
+                            @ApiParam("对象ID") @PathVariable Integer id ) throws Exception {
+        userRolesService.updateById(userRoles);
+        return ResponseBean.success(userRoles);
+    }
+    
+    /** 
+     * 通过主键删除数据
+     *
+     * @param id 主键
+     * @return 是否成功
+     */
+    @ApiOperation("通过主键删除数据")
+    @DeleteMapping("/userRoles/{id}")
+    public ResponseBean deleteById(@ApiParam("对象ID") @PathVariable Integer id){
+        userRolesService.removeLogicById(id);
+        return ResponseBean.success("success");
+    }
+}

src/main/java/com/yunzhi/inte/controller/UsersController.java

@@ -0,0 +1,100 @@
+package com.yunzhi.inte.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yunzhi.inte.common.BaseController;
+import com.yunzhi.inte.common.ResponseBean;
+import java.util.List;
+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 com.yunzhi.inte.entity.Users;
+import com.yunzhi.inte.service.UsersService;
+
+ /**
+ * 用户表;(users)表控制层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+@Api(tags = "用户表对象功能接口")
+@RestController
+@RequestMapping("/")
+public class UsersController extends BaseController {
+    
+    @Autowired
+    private UsersService usersService;
+    
+    /** 
+     * 通过ID查询单条数据 
+     *
+     * @return 实例对象
+     */
+    @ApiOperation("通过ID查询单条数据")
+    @GetMapping("/users/current")
+    public ResponseBean queryById() throws Exception {
+        return ResponseBean.success(currentUser());
+    }
+    
+    /** 
+     * 分页查询
+     *
+     * @param pageNum 当前页码
+     * @param pageSize 每页条数
+     * @return 查询结果
+     */
+    @ApiOperation("分页查询")
+    @GetMapping("/users")
+    public ResponseBean list(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                            @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception {
+        
+        IPage<Users> pg = new Page<>(pageNum, pageSize);
+        // QueryWrapper<Users> queryWrapper = new QueryWrapper<>();
+        // queryWrapper.orderByDesc("create_date");
+        IPage<Users> result = usersService.page(pg);
+        
+        return ResponseBean.success(result);
+    }
+    
+    /** 
+     * 新增数据
+     *
+     * @param users 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("新增数据")
+    @PostMapping("/users")
+    public ResponseBean add(@ApiParam("对象实体") @RequestBody Users users) throws Exception {
+        usersService.save(users);
+        return ResponseBean.success(users);
+    }
+    
+    /** 
+     * 更新数据
+     *
+     * @param users 实例对象
+     * @return 实例对象
+     */
+    @ApiOperation("更新数据")
+    @PutMapping("/users/{id}")
+    public ResponseBean edit(@ApiParam("对象实体") @RequestBody Users users,
+                            @ApiParam("对象ID") @PathVariable Integer id ) throws Exception {
+        usersService.updateById(users);
+        return ResponseBean.success(users);
+    }
+    
+    /** 
+     * 通过主键删除数据
+     *
+     * @param id 主键
+     * @return 是否成功
+     */
+    @ApiOperation("通过主键删除数据")
+    @DeleteMapping("/users/{id}")
+    public ResponseBean deleteById(@ApiParam("对象ID") @PathVariable Integer id){
+        usersService.removeLogicById(id);
+        return ResponseBean.success("success");
+    }
+}

src/main/java/com/yunzhi/inte/entity/Banner.java

@@ -1,6 +1,7 @@
 package com.yunzhi.inte.entity;
 
 import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
@@ -19,6 +20,7 @@ public class Banner implements Serializable {
     @TableId(value = "id",type = IdType.AUTO)
     private  int id;
 
+    @TableField("`desc`")
     private String desc;
 
     private String type;
@@ -29,5 +31,5 @@ public class Banner implements Serializable {
 
     private String qz;
 
-    private String state;
+    private Integer status;
 }

src/main/java/com/yunzhi/inte/entity/Evaluate.java

@@ -0,0 +1,57 @@
+package com.yunzhi.inte.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+ /**
+ * 评价表;
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-13
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value = "评价表",description = "")
+@TableName("evaluate")
+public class Evaluate implements Serializable,Cloneable{
+    /** 评价ID */
+    @ApiModelProperty(name = "评价ID",notes = "")
+    @TableId(value = "id", type = IdType.INPUT)
+    private Integer id ;
+    /** 任务ID */
+    @ApiModelProperty(name = "任务ID",notes = "")
+    private Integer taskId ;
+    /** 服务质量;2优,1良,0差 */
+    @ApiModelProperty(name = "服务质量",notes = "2优,1良,0差")
+    private Integer item1 ;
+    /** 供应住宿;2优,1良,0差 */
+    @ApiModelProperty(name = "供应住宿",notes = "2优,1良,0差")
+    private Integer item2 ;
+    /** 供应餐饮;2优,1良,0差 */
+    @ApiModelProperty(name = "供应餐饮",notes = "2优,1良,0差")
+    private Integer item3 ;
+    /** 洗浴评价;2优,1良,0差 */
+    @ApiModelProperty(name = "洗浴评价",notes = "2优,1良,0差")
+    private Integer item4 ;
+    /** 娱乐评价;2优,1良,0差 */
+    @ApiModelProperty(name = "娱乐评价",notes = "2优,1良,0差")
+    private Integer item5 ;
+    /** 军供文化;2优,1良,0差 */
+    @ApiModelProperty(name = "军供文化",notes = "2优,1良,0差")
+    private Integer item6 ;
+    /** 状态 */
+    @ApiModelProperty(name = "状态",notes = "")
+    private Integer status ;
+    /** 创建时间 */
+    @ApiModelProperty(name = "创建时间",notes = "")
+    private Date createDate ;
+
+}

src/main/java/com/yunzhi/inte/entity/NoticeMessage.java

@@ -0,0 +1,45 @@
+package com.yunzhi.inte.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+ /**
+ * 消息表;
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-13
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value = "消息表",description = "")
+@TableName("notice_message")
+public class NoticeMessage implements Serializable,Cloneable{
+    /** 消息ID */
+    @ApiModelProperty(name = "消息ID",notes = "")
+    @TableId(value = "id", type = IdType.INPUT)
+    private Integer id ;
+    /** 消息内容 */
+    @ApiModelProperty(name = "消息内容",notes = "")
+    private String message ;
+    /** 对象类型 */
+    @ApiModelProperty(name = "对象类型",notes = "")
+    private String targetType ;
+    /** 对象ID */
+    @ApiModelProperty(name = "对象ID",notes = "")
+    private String targetId ;
+    /** 状态 */
+    @ApiModelProperty(name = "状态",notes = "")
+    private Integer status ;
+    /** 创建时间 */
+    @ApiModelProperty(name = "创建时间",notes = "")
+    private Date createDate ;
+
+}

src/main/java/com/yunzhi/inte/entity/PostsFiles.java

@@ -0,0 +1,42 @@
+package com.yunzhi.inte.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+ /**
+ * 关联文件;
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-13
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value = "关联文件",description = "")
+@TableName("posts_files")
+public class PostsFiles implements Serializable,Cloneable{
+    /** 文件ID */
+    @ApiModelProperty(name = "文件ID",notes = "")
+    @TableId(value = "id", type = IdType.INPUT)
+    private Integer id ;
+    /** 信息ID */
+    @ApiModelProperty(name = "信息ID",notes = "")
+    private Integer postsId ;
+    /** 文件类型 */
+    @ApiModelProperty(name = "文件类型",notes = "")
+    private String fileType ;
+    /** 文件名称 */
+    @ApiModelProperty(name = "文件名称",notes = "")
+    private String fileName ;
+    /** 文件地址 */
+    @ApiModelProperty(name = "文件地址",notes = "")
+    private String fileAddr ;
+
+}

src/main/java/com/yunzhi/inte/entity/Resources.java

@@ -0,0 +1,45 @@
+package com.yunzhi.inte.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+ /**
+ * 资源;
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-12
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value = "资源",description = "")
+@TableName("resources")
+public class Resources implements Serializable,Cloneable{
+    /** ID */
+    @ApiModelProperty(name = "ID",notes = "")
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id ;
+    /** 名称 */
+    @ApiModelProperty(name = "名称",notes = "")
+    private String name ;
+    /** 父级ID */
+    @ApiModelProperty(name = "父级ID",notes = "")
+    private Integer parentId ;
+    /** 编码 */
+    @ApiModelProperty(name = "编码",notes = "")
+    private String code ;
+    /** 类型 */
+    @ApiModelProperty(name = "类型",notes = "")
+    private String type ;
+    /** 序号 */
+    @ApiModelProperty(name = "序号",notes = "")
+    private String sortNo ;
+
+}

src/main/java/com/yunzhi/inte/entity/RoleResources.java

@@ -0,0 +1,36 @@
+package com.yunzhi.inte.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+ /**
+ * 角色资源;
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-12
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value = "角色资源",description = "")
+@TableName("role_resources")
+public class RoleResources implements Serializable,Cloneable{
+    /** ID */
+    @ApiModelProperty(name = "ID",notes = "")
+    @TableId(value = "id", type = IdType.INPUT)
+    private Integer id ;
+    /** 角色ID */
+    @ApiModelProperty(name = "角色ID",notes = "")
+    private Integer roleId ;
+    /** 资源ID */
+    @ApiModelProperty(name = "资源ID",notes = "")
+    private Integer resourceId ;
+
+}

src/main/java/com/yunzhi/inte/entity/Roles.java

@@ -0,0 +1,33 @@
+package com.yunzhi.inte.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+ /**
+ * 角色;
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-12
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value = "角色",description = "")
+@TableName("roles")
+public class Roles implements Serializable,Cloneable{
+    /** 角色ID */
+    @ApiModelProperty(name = "角色ID",notes = "")
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id ;
+    /** 角色名称 */
+    @ApiModelProperty(name = "角色名称",notes = "")
+    private String name ;
+
+}

src/main/java/com/yunzhi/inte/entity/UserRoles.java

@@ -0,0 +1,36 @@
+package com.yunzhi.inte.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+ /**
+ * 授权角色;
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-12
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value = "授权角色",description = "")
+@TableName("user_roles")
+public class UserRoles implements Serializable,Cloneable{
+    /** 序号 */
+    @ApiModelProperty(name = "序号",notes = "")
+    @TableId(value = "id", type = IdType.INPUT)
+    private Integer id ;
+    /** 用户ID */
+    @ApiModelProperty(name = "用户ID",notes = "")
+    private Integer userId ;
+    /** 角色ID */
+    @ApiModelProperty(name = "角色ID",notes = "")
+    private Integer roleId ;
+
+}

src/main/java/com/yunzhi/inte/entity/Users.java

@@ -0,0 +1,45 @@
+package com.yunzhi.inte.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+ /**
+ * 用户表;
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-12
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value = "用户表",description = "")
+@TableName("users")
+public class Users implements Serializable,Cloneable{
+    /** ID */
+    @ApiModelProperty(name = "ID",notes = "")
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id ;
+    /** 姓名 */
+    @ApiModelProperty(name = "姓名",notes = "")
+    private String name ;
+    /** 登录名 */
+    @ApiModelProperty(name = "登录名",notes = "")
+    private String loginName ;
+    /** 密码 */
+    @ApiModelProperty(name = "密码",notes = "")
+    private String password ;
+    /** 状态 */
+    @ApiModelProperty(name = "状态",notes = "")
+    private Integer status ;
+    /** 创建时间 */
+    @ApiModelProperty(name = "创建时间",notes = "")
+    private Date createDate ;
+
+}

src/main/java/com/yunzhi/inte/exception/GlobalException.java

@@ -1,5 +1,6 @@
 package com.yunzhi.inte.exception;
 
+import cn.dev33.satoken.exception.SaTokenException;
 import com.yunzhi.inte.common.ResponseBean;
 import org.springframework.web.bind.annotation.ControllerAdvice;
 import org.springframework.web.bind.annotation.ExceptionHandler;
@@ -8,6 +9,16 @@ import org.springframework.web.bind.annotation.ResponseBody;
 @ControllerAdvice
 @ResponseBody
 public class GlobalException {
+
+    @ExceptionHandler(SaTokenException.class)
+    public ResponseBean handleSaTokenException(Exception e){
+        e.printStackTrace();
+        ResponseBean response = new ResponseBean();
+        response.setMessage(e.getMessage());
+        response.setCode(ResponseBean.ERROR_AUTH_FAIL);
+        return response;
+    }
+
     @ExceptionHandler(Exception.class)
     public ResponseBean handleException(Exception e){
         e.printStackTrace();

src/main/java/com/yunzhi/inte/mapper/EvaluateMapper.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import com.yunzhi.inte.entity.Evaluate;
+
+ /**
+ * 评价表;(evaluate)表数据库访问层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-13
+ */
+@Mapper
+public interface EvaluateMapper  extends BaseMapper<Evaluate>{
+    
+}

src/main/java/com/yunzhi/inte/mapper/NoticeMessageMapper.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import com.yunzhi.inte.entity.NoticeMessage;
+
+ /**
+ * 消息表;(notice_message)表数据库访问层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-13
+ */
+@Mapper
+public interface NoticeMessageMapper  extends BaseMapper<NoticeMessage>{
+    
+}

src/main/java/com/yunzhi/inte/mapper/PostsFilesMapper.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import com.yunzhi.inte.entity.PostsFiles;
+
+ /**
+ * 关联文件;(posts_files)表数据库访问层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-13
+ */
+@Mapper
+public interface PostsFilesMapper  extends BaseMapper<PostsFiles>{
+    
+}

src/main/java/com/yunzhi/inte/mapper/ResourcesMapper.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import com.yunzhi.inte.entity.Resources;
+
+ /**
+ * 资源;(resources)表数据库访问层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+@Mapper
+public interface ResourcesMapper  extends BaseMapper<Resources>{
+    
+}

src/main/java/com/yunzhi/inte/mapper/RoleResourcesMapper.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import com.yunzhi.inte.entity.RoleResources;
+
+ /**
+ * 角色资源;(role_resources)表数据库访问层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+@Mapper
+public interface RoleResourcesMapper  extends BaseMapper<RoleResources>{
+    
+}

src/main/java/com/yunzhi/inte/mapper/RolesMapper.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import com.yunzhi.inte.entity.Roles;
+
+ /**
+ * 角色;(roles)表数据库访问层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+@Mapper
+public interface RolesMapper  extends BaseMapper<Roles>{
+    
+}

src/main/java/com/yunzhi/inte/mapper/UserRolesMapper.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import com.yunzhi.inte.entity.UserRoles;
+
+ /**
+ * 授权角色;(user_roles)表数据库访问层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+@Mapper
+public interface UserRolesMapper  extends BaseMapper<UserRoles>{
+    
+}

src/main/java/com/yunzhi/inte/mapper/UsersMapper.java

@@ -0,0 +1,17 @@
+package com.yunzhi.inte.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import com.yunzhi.inte.entity.Users;
+
+ /**
+ * 用户表;(users)表数据库访问层
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+@Mapper
+public interface UsersMapper  extends BaseMapper<Users>{
+
+     Users getByLoginID(@Param("loginName") String loginName);
+ }

src/main/java/com/yunzhi/inte/rtsp/ChannelGroupHolder.java

@@ -1,72 +0,0 @@
-package com.yunzhi.inte.rtsp;
-
-import io.netty.channel.Channel;
-import io.netty.channel.ChannelId;
-import io.netty.channel.group.ChannelGroup;
-import io.netty.channel.group.DefaultChannelGroup;
-import io.netty.util.concurrent.ImmediateEventExecutor;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * 保存群组
- */
-@Slf4j
-public class ChannelGroupHolder {
-
-    private static Map<String, ChannelGroup> channelGroups = new HashMap<>();
-    private static Map<String, String> channelTagMapping = new HashMap<>();
-
-    public static Map<String, ChannelGroup> getChannelGroups() {
-        return channelGroups;
-    }
-
-    /**
-     * 添加channel到群组
-     */
-    public static synchronized void add(String tag, Channel channel) {
-        ChannelGroup group = channelGroups.get(tag);
-        if (group == null) {
-            group = new DefaultChannelGroup(ImmediateEventExecutor.INSTANCE);
-            log.info("创建新群组：{}", tag);
-            channelGroups.put(tag, group);
-        }
-        group.add(channel);
-        ChannelId channelId = channel.id();
-        channelTagMapping.put(channelId.toString(), tag);
-        log.info("群组{}加入新channel：{}", tag, channelId);
-    }
-
-    /**
-     * 根据IP获取群组
-     */
-    public static ChannelGroup get(String tag) {
-        return channelGroups.get(tag);
-    }
-
-    /**
-     * 移除指定channel，如果群组变为空，返回对应IP
-     */
-    public static String remove(Channel channel) {
-        String channelId = channel.id().toString();
-        String tag = channelTagMapping.get(channelId);
-        channelTagMapping.remove(channelId);
-        if (tag != null && !channelTagMapping.containsValue(tag)) {
-            log.info("移除channel：{}，所在群组：{}", channelId, tag);
-            return tag;
-        }
-        return null;
-    }
-
-    /**
-     * 关闭所有群组
-     */
-    public static void close() {
-        for (ChannelGroup group : channelGroups.values()) {
-            group.close();
-        }
-    }
-
-}

src/main/java/com/yunzhi/inte/rtsp/FFmpeg.java

@@ -1,26 +0,0 @@
-package com.yunzhi.inte.rtsp;
-
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.stereotype.Component;
-
-import java.io.IOException;
-
-@Slf4j
-@Component
-public class FFmpeg {
-    @Value("${my.minitor.port}")
-    Integer port;
-
-    @Value("${my.minitor.ffmpeg}")
-    String ffmpegBin;
-
-    public Process run(String source) throws IOException {
-        String command = ffmpegBin + " -f rtsp -rtsp_transport tcp -i " + source
-                + " -strict -2 -c:v libx264 -vsync 2 -c:a aac "
-                + "-f mpegts -codec:v mpeg1video -s 640x480 -b:v 1000k -bf 0 http://127.0.0.1:" + port
-                + "/push/" + source;
-        log.info(command);
-        return Runtime.getRuntime().exec(command);
-    }
-}

src/main/java/com/yunzhi/inte/rtsp/HttpRequestHandler.java

@@ -1,107 +0,0 @@
-package com.yunzhi.inte.rtsp;
-
-import io.netty.buffer.ByteBuf;
-import io.netty.buffer.Unpooled;
-import io.netty.channel.ChannelFuture;
-import io.netty.channel.ChannelFutureListener;
-import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.SimpleChannelInboundHandler;
-import io.netty.channel.group.ChannelGroup;
-import io.netty.channel.group.ChannelGroupFuture;
-import io.netty.handler.codec.http.*;
-import io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame;
-import lombok.extern.slf4j.Slf4j;
-
-import java.io.File;
-import java.io.IOException;
-import java.io.RandomAccessFile;
-
-/**
- * 处理HTTP请求
- */
-@Slf4j
-@SuppressWarnings("deprecation")
-public class HttpRequestHandler extends SimpleChannelInboundHandler<HttpObject> {
-    private final String wsUri;
-    private String monitorIp;
-
-    public HttpRequestHandler(String wsUri) {
-        this.wsUri = wsUri;
-    }
-
-    @Override
-    public void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception {
-        if (msg instanceof HttpRequest) {
-            HttpRequest request = (HttpRequest) msg;
-            String uri = request.getUri();
-            log.info("收到HTTP请求：{}", uri);
-
-            // 处理WebSocket请求
-            if (uri.contains(wsUri)) {
-                String ip = uri.split(wsUri + "/")[1];
-                ChannelGroupHolder.add(ip, ctx.channel());
-                TransferRtspHelper.open(ip);
-                ctx.fireChannelRead(new DefaultFullHttpRequest(request.protocolVersion(), request.method(), wsUri,
-                        Unpooled.buffer(), request.headers(), request.headers()));
-            } else if (uri.contains("/push/")) {
-                monitorIp = uri.split("/push/")[1];
-                log.info("开始接收转码推流：{}", monitorIp);
-            }
-            // 处理HTTP请求
-            else {
-                FullHttpResponse response = null;
-                response = generateResponse(request, null);
-                ctx.write(response);
-                ChannelFuture future = ctx.writeAndFlush(LastHttpContent.EMPTY_LAST_CONTENT);
-                if (!HttpHeaders.isKeepAlive(request)) {
-                    future.addListener(ChannelFutureListener.CLOSE);
-                }
-            }
-        } else if (msg instanceof HttpContent && !(msg instanceof LastHttpContent)) {
-            HttpContent chunk = (HttpContent) msg;
-            ChannelGroup group = ChannelGroupHolder.get(monitorIp);
-            ChannelGroupFuture groupFuture = group.writeAndFlush(new BinaryWebSocketFrame(chunk.retain().content()));
-            groupFuture.sync();
-        }
-    }
-
-    @Override
-    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
-        cause.printStackTrace();
-        ctx.close();
-    }
-
-    /**
-     * 生成HTTP响应
-     */
-    private FullHttpResponse generateResponse(HttpRequest request, RandomAccessFile file) throws IOException {
-        ByteBuf buf = generateByteBuf(file);
-        FullHttpResponse response = new DefaultFullHttpResponse(request.getProtocolVersion(), HttpResponseStatus.OK,
-                buf);
-        if (HttpHeaders.isKeepAlive(request)) {
-            response.headers().set(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
-        }
-        response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, buf.writerIndex());
-        return response;
-    }
-
-    /**
-     * 生成HTTP响应内容
-     */
-    private ByteBuf generateByteBuf(RandomAccessFile file) throws IOException {
-        ByteBuf buf = Unpooled.buffer(0);
-        if (file != null) {
-            int length = (int) file.length();
-            byte[] fileByte = new byte[length];
-            file.read(fileByte);
-            file.close();
-
-            buf = Unpooled.buffer(length);
-            for (int i = 0; i < length; i++) {
-                buf.writeByte(fileByte[i]);
-            }
-        }
-        return buf;
-    }
-
-}

src/main/java/com/yunzhi/inte/rtsp/MonitorServer.java

@@ -1,54 +0,0 @@
-package com.yunzhi.inte.rtsp;
-
-import io.netty.bootstrap.ServerBootstrap;
-import io.netty.channel.Channel;
-import io.netty.channel.EventLoopGroup;
-import io.netty.channel.nio.NioEventLoopGroup;
-import io.netty.channel.socket.nio.NioServerSocketChannel;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.PostConstruct;
-
-/**
- * 引导服务器
- */
-@Slf4j
-@Component
-public class MonitorServer extends Thread {
-    @Value("${my.minitor.port}")
-    Integer port;
-
-    @Autowired
-    FFmpeg fFmpeg;
-
-    public void run() {
-        TransferRtspHelper.TransferTask.fFmpeg = fFmpeg;
-        EventLoopGroup group = new NioEventLoopGroup();
-        EventLoopGroup workerGroup = new NioEventLoopGroup();
-
-        ServerBootstrap bootstrap = new ServerBootstrap();
-        bootstrap.group(group, workerGroup).channel(NioServerSocketChannel.class)
-                .childHandler(new MonitorServerInitializer());
-
-        try {
-            Channel channel = bootstrap.bind(port).sync().channel();
-
-            TransferRtspHelper.schedule();
-            log.info("服务器开始运行......[:{}]", port);
-
-            channel.closeFuture().sync();
-        } catch (InterruptedException e) {
-            e.printStackTrace();
-        }
-
-        Runtime.getRuntime().addShutdownHook(new Thread(() -> {
-            group.shutdownGracefully();
-            workerGroup.shutdownGracefully();
-            ChannelGroupHolder.close();
-            log.info("服务器已关闭");
-        }));
-    }
-}

src/main/java/com/yunzhi/inte/rtsp/MonitorServerInitializer.java

@@ -1,24 +0,0 @@
-package com.yunzhi.inte.rtsp;
-
-import io.netty.channel.Channel;
-import io.netty.channel.ChannelInitializer;
-import io.netty.channel.ChannelPipeline;
-import io.netty.handler.codec.http.HttpContentCompressor;
-import io.netty.handler.codec.http.HttpServerCodec;
-import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
-
-/**
- * 初始化ChannelPipeline
- */
-public class MonitorServerInitializer extends ChannelInitializer<Channel> {
-
-    @Override
-    public void initChannel(Channel ch) {
-        ChannelPipeline pipeline = ch.pipeline();
-        pipeline.addLast(new HttpServerCodec());
-        pipeline.addLast(new HttpContentCompressor());
-        pipeline.addLast(new HttpRequestHandler("/ws"));
-        pipeline.addLast(new WebSocketServerProtocolHandler("/ws"));
-        pipeline.addLast(new WebSocketHandler());
-    }
-}

src/main/java/com/yunzhi/inte/rtsp/TransferRtspHelper.java

@@ -1,147 +0,0 @@
-package com.yunzhi.inte.rtsp;
-
-import com.yunzhi.inte.InteApplication;
-import io.netty.channel.group.ChannelGroup;
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-import lombok.SneakyThrows;
-import lombok.extern.slf4j.Slf4j;
-
-import java.io.IOException;
-import java.util.*;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.TimeUnit;
-
-/**
- * 转码
- */
-@Slf4j
-public class TransferRtspHelper {
-
-    private static final ScheduledExecutorService SCHEDULE = Executors.newScheduledThreadPool(2);
-    private static final ExecutorService PROCESS_EXECUTOR = Executors.newCachedThreadPool();
-    private static Map<String, Transfer> transferMap = new HashMap<>();
-
-    /**
-     * 开启
-     */
-    public static synchronized void open(String ip) throws IOException {
-        Transfer transfer = transferMap.get(ip);
-        if (transfer == null) {
-            transfer = new Transfer();
-            transfer.setIp(ip);
-            transfer.setStartTime(new Date());
-            transfer.setContinueTime(new Date());
-            transfer.setCount(1);
-            PROCESS_EXECUTOR.submit(new TransferTask(transfer));
-            transferMap.put(ip, transfer);
-        } else {
-            transfer.setContinueTime(new Date());
-            transfer.incCount();
-        }
-        log.info("开始转码：{}", transfer);
-    }
-
-    /**
-     * 关闭
-     */
-    public static synchronized void close(String ip) {
-        Transfer transfer = transferMap.get(ip);
-        if (transfer != null) {
-            transfer.decCount();
-            if (transfer.getCount() <= 0) {
-                Process process = transfer.getProcess();
-                if (process != null && process.isAlive()) {
-                    process.destroy();
-                }
-                transferMap.remove(ip);
-            }
-        }
-        log.info("结束转码：{}", transfer);
-    }
-
-    /**
-     * 若当前有在转码，打印相关信息
-     */
-    public static void report() {
-        Map<String, ChannelGroup> channelGroups = ChannelGroupHolder.getChannelGroups();
-        transferMap.forEach((k, v) -> {
-            ChannelGroup group = channelGroups.get(k);
-            if (group != null && !group.isEmpty()) {
-                log.info("当前转码中：{}", v);
-            }
-        });
-    }
-
-    /**
-     * 如果没有对应channel，停止转码，如果前端页面还开着，会自动建立回连接
-     */
-    public static void clear() {
-        List<String> toClearIp = new ArrayList<>();
-        Map<String, ChannelGroup> channelGroups = ChannelGroupHolder.getChannelGroups();
-        transferMap.forEach((k, v) -> {
-            ChannelGroup group = channelGroups.get(k);
-            if (group == null || group.isEmpty()
-                    || System.currentTimeMillis() - v.getContinueTime().getTime() > 1800_000L) {
-                toClearIp.add(k);
-            }
-        });
-        if (!toClearIp.isEmpty()) {
-            log.info("关闭以下无效转码：{}", toClearIp);
-            toClearIp.forEach(TransferRtspHelper::close);
-        }
-    }
-
-    /**
-     * 开启定时器
-     */
-    public static void schedule() {
-        SCHEDULE.scheduleAtFixedRate(TransferRtspHelper::report, 1L, 5L, TimeUnit.MINUTES);
-        SCHEDULE.scheduleAtFixedRate(TransferRtspHelper::clear, 60L, 5L, TimeUnit.SECONDS);
-    }
-
-    @Data
-    @NoArgsConstructor
-    @AllArgsConstructor
-    private static class Transfer {
-        private String ip;
-        private Process process;
-        private int count;
-        private Date startTime;
-        private Date continueTime;
-
-        public void incCount() {
-            count++;
-        }
-
-        public void decCount() {
-            count--;
-        }
-    }
-
-    @Data
-    @NoArgsConstructor
-    @AllArgsConstructor
-    public static class TransferTask implements Runnable {
-
-        private Transfer transfer;
-
-        public static FFmpeg fFmpeg;
-
-        @SneakyThrows
-        @Override
-        public void run() {
-            try {
-                String ip = transfer.getIp();
-                Process process = fFmpeg.run(ip);
-                transfer.setProcess(process);
-            } catch (Exception e) {
-                e.printStackTrace();
-            }
-        }
-    }
-
-}

src/main/java/com/yunzhi/inte/rtsp/WebSocketHandler.java

@@ -1,40 +0,0 @@
-package com.yunzhi.inte.rtsp;
-
-import io.netty.channel.Channel;
-import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.SimpleChannelInboundHandler;
-import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
-import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
-import lombok.extern.slf4j.Slf4j;
-
-/**
- * 处理文本帧
- */
-@Slf4j
-public class WebSocketHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> {
-
-    @Override
-    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
-        if (evt == WebSocketServerProtocolHandler.ServerHandshakeStateEvent.HANDSHAKE_COMPLETE) {
-            log.info("WebSocket连接成功：{}", ctx.channel().id());
-        } else {
-            super.userEventTriggered(ctx, evt);
-        }
-    }
-
-    @Override
-    public void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame msg) throws Exception {
-    }
-
-    @Override
-    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
-        Channel channel = ctx.channel();
-        log.info("websocket连接断开：{}", channel.id());
-        String toDeleteTag = ChannelGroupHolder.remove(channel);
-        if (toDeleteTag != null) {
-            TransferRtspHelper.close(toDeleteTag);
-        }
-        ctx.fireChannelInactive();
-    }
-
-}

src/main/java/com/yunzhi/inte/service/EvaluateService.java

@@ -0,0 +1,13 @@
+package com.yunzhi.inte.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yunzhi.inte.entity.Evaluate;
+
+ /**
+ * 评价表;(evaluate)表服务接口
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-13
+ */
+public interface EvaluateService extends IBaseService<Evaluate> {
+    
+}

src/main/java/com/yunzhi/inte/service/NoticeMessageService.java

@@ -0,0 +1,13 @@
+package com.yunzhi.inte.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yunzhi.inte.entity.NoticeMessage;
+
+ /**
+ * 消息表;(notice_message)表服务接口
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-13
+ */
+public interface NoticeMessageService extends IBaseService<NoticeMessage> {
+    
+}

src/main/java/com/yunzhi/inte/service/PostsFilesService.java

@@ -0,0 +1,13 @@
+package com.yunzhi.inte.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yunzhi.inte.entity.PostsFiles;
+
+ /**
+ * 关联文件;(posts_files)表服务接口
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-13
+ */
+public interface PostsFilesService extends IBaseService<PostsFiles> {
+    
+}

src/main/java/com/yunzhi/inte/service/ResourcesService.java

@@ -0,0 +1,13 @@
+package com.yunzhi.inte.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yunzhi.inte.entity.Resources;
+
+ /**
+ * 资源;(resources)表服务接口
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+public interface ResourcesService extends IBaseService<Resources> {
+    
+}

src/main/java/com/yunzhi/inte/service/RoleResourcesService.java

@@ -0,0 +1,13 @@
+package com.yunzhi.inte.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yunzhi.inte.entity.RoleResources;
+
+ /**
+ * 角色资源;(role_resources)表服务接口
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+public interface RoleResourcesService extends IBaseService<RoleResources> {
+    
+}

src/main/java/com/yunzhi/inte/service/RolesService.java

@@ -0,0 +1,13 @@
+package com.yunzhi.inte.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yunzhi.inte.entity.Roles;
+
+ /**
+ * 角色;(roles)表服务接口
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+public interface RolesService extends IBaseService<Roles> {
+    
+}

src/main/java/com/yunzhi/inte/service/UserRolesService.java

@@ -0,0 +1,13 @@
+package com.yunzhi.inte.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yunzhi.inte.entity.UserRoles;
+
+ /**
+ * 授权角色;(user_roles)表服务接口
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+public interface UserRolesService extends IBaseService<UserRoles> {
+    
+}

src/main/java/com/yunzhi/inte/service/UsersService.java

@@ -0,0 +1,15 @@
+package com.yunzhi.inte.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yunzhi.inte.entity.Users;
+import com.yunzhi.inte.vo.LoginParm;
+
+/**
+ * 用户表;(users)表服务接口
+ * @author : http://njyunzhi.com
+ * @date : 2022-10-12
+ */
+public interface UsersService extends IBaseService<Users> {
+
+     Users login(LoginParm loginParm) throws Exception;
+ }

src/main/java/com/yunzhi/inte/service/impl/EvaluateServiceImpl.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.yunzhi.inte.entity.Evaluate;
+import com.yunzhi.inte.mapper.EvaluateMapper;
+import com.yunzhi.inte.service.EvaluateService;
+ /**
+ * 评价表;(evaluate)表服务实现类
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-13
+ */
+@Service
+public class EvaluateServiceImpl extends BaseServiceImpl<EvaluateMapper, Evaluate> implements EvaluateService {
+    
+}

src/main/java/com/yunzhi/inte/service/impl/NoticeMessageServiceImpl.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.yunzhi.inte.entity.NoticeMessage;
+import com.yunzhi.inte.mapper.NoticeMessageMapper;
+import com.yunzhi.inte.service.NoticeMessageService;
+ /**
+ * 消息表;(notice_message)表服务实现类
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-13
+ */
+@Service
+public class NoticeMessageServiceImpl extends BaseServiceImpl<NoticeMessageMapper, NoticeMessage> implements NoticeMessageService {
+    
+}

src/main/java/com/yunzhi/inte/service/impl/PostsFilesServiceImpl.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.yunzhi.inte.entity.PostsFiles;
+import com.yunzhi.inte.mapper.PostsFilesMapper;
+import com.yunzhi.inte.service.PostsFilesService;
+ /**
+ * 关联文件;(posts_files)表服务实现类
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-13
+ */
+@Service
+public class PostsFilesServiceImpl extends BaseServiceImpl<PostsFilesMapper, PostsFiles> implements PostsFilesService {
+    
+}

src/main/java/com/yunzhi/inte/service/impl/ResourcesServiceImpl.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.yunzhi.inte.entity.Resources;
+import com.yunzhi.inte.mapper.ResourcesMapper;
+import com.yunzhi.inte.service.ResourcesService;
+ /**
+ * 资源;(resources)表服务实现类
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-12
+ */
+@Service
+public class ResourcesServiceImpl extends BaseServiceImpl<ResourcesMapper, Resources> implements ResourcesService {
+    
+}

src/main/java/com/yunzhi/inte/service/impl/RoleResourcesServiceImpl.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.yunzhi.inte.entity.RoleResources;
+import com.yunzhi.inte.mapper.RoleResourcesMapper;
+import com.yunzhi.inte.service.RoleResourcesService;
+ /**
+ * 角色资源;(role_resources)表服务实现类
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-12
+ */
+@Service
+public class RoleResourcesServiceImpl extends BaseServiceImpl<RoleResourcesMapper, RoleResources> implements RoleResourcesService {
+    
+}

src/main/java/com/yunzhi/inte/service/impl/RolesServiceImpl.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.yunzhi.inte.entity.Roles;
+import com.yunzhi.inte.mapper.RolesMapper;
+import com.yunzhi.inte.service.RolesService;
+ /**
+ * 角色;(roles)表服务实现类
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-12
+ */
+@Service
+public class RolesServiceImpl extends BaseServiceImpl<RolesMapper, Roles> implements RolesService {
+    
+}

src/main/java/com/yunzhi/inte/service/impl/UserRolesServiceImpl.java

@@ -0,0 +1,16 @@
+package com.yunzhi.inte.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.yunzhi.inte.entity.UserRoles;
+import com.yunzhi.inte.mapper.UserRolesMapper;
+import com.yunzhi.inte.service.UserRolesService;
+ /**
+ * 授权角色;(user_roles)表服务实现类
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-12
+ */
+@Service
+public class UserRolesServiceImpl extends BaseServiceImpl<UserRolesMapper, UserRoles> implements UserRolesService {
+    
+}

src/main/java/com/yunzhi/inte/service/impl/UsersServiceImpl.java

@@ -0,0 +1,38 @@
+package com.yunzhi.inte.service.impl;
+
+import com.yunzhi.inte.common.EncryptUtils;
+import com.yunzhi.inte.vo.LoginParm;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.yunzhi.inte.entity.Users;
+import com.yunzhi.inte.mapper.UsersMapper;
+import com.yunzhi.inte.service.UsersService;
+ /**
+ * 用户表;(users)表服务实现类
+ * @author : http://www.chiner.pro
+ * @date : 2022-10-12
+ */
+@Service
+public class UsersServiceImpl extends BaseServiceImpl<UsersMapper, Users> implements UsersService {
+
+      @Override
+      public Users login(LoginParm loginParm) throws Exception {
+          Users sysUser = baseMapper.getByLoginID(loginParm.getUserName());
+          if (null == sysUser) {
+              throw new Exception("用户名或者密码不正确");
+          }
+
+          boolean isRight = checkPassword(loginParm.getPassword(), sysUser.getPassword(), sysUser.getId().toString());
+          if (!isRight) {
+              throw new Exception("用户名或者密码不正确");
+          }
+
+          sysUser.setPassword(null);
+          return sysUser;
+      }
+
+     boolean checkPassword(String src, String targ, String salt) {
+         String newPass = EncryptUtils.md5(src, salt);
+         return targ.equals(newPass);
+     }
+ }

src/main/java/com/yunzhi/inte/vo/ChangePassword.java

@@ -0,0 +1,17 @@
+package com.yunzhi.inte.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/yunzhi/inte/vo/LoginParm.java

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

src/main/resources/application.yml

@@ -3,37 +3,58 @@ server:
   servlet:
     context-path: /api
 
-### ??????????
 spring:
   datasource:
-    driver-class-name: org.sqlite.JDBC
-    url: jdbc:sqlite:E:\work\jgz\service\db\ybai.db
-    username:
-    password:
+    url: jdbc:mysql://110.40.183.156:3306/jgz?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false&allowPublicKeyRetrieval=true
+    username: jgz
+    password: jgz@ABCD1234
   application:
-    name: inte
+    name: jgz
   mvc:
     pathmatch:
       matching-strategy: ANT_PATH_MATCHER
-    static-path-pattern: ${my.static-prefix}/**
   web:
     resources:
       static-locations: file:///${my.upload-path}
   servlet:
     multipart:
-      max-file-size: 50MB #设置允许单个文件上传的大小
-      max-request-size: 50MB #设置允许上传的总的文件的大小
-  ### sqlite??????????
-#  jpa:
-#    database-platform: com.restart1025.sqlite.SQLiteDialect
-#    hibernate:
-#      ddl-auto: update
-#    show-sql: true
+      max-file-size: 1024MB #设置允许单个文件上传的大小
+      max-request-size: 1024MB #设置允许上传的总的文件的大小
+
+###
+yz:
+  filter:
+    annList:
+      - "/swagger-ui/**"
+      - "/swagger-resources/**"
+      - "/v2/**"
+      - "/login"
+
+# Sa-Token??
+sa-token:
+  # jwt??
+  jwt-secret-key: K85pMhy0HREVoCxYMv3OfDgkVPua5ZPN
+  # token?? (????cookie??)
+  token-name: Authorization
+  # ?? cookie
+  is-read-cookie: false
+  # token??????s ??30?, -1??????
+  timeout: 2592000
+  # token????? (???????????token??) ??: ?
+  activity-timeout: -1
+  # ???????????? (?true???????, ?false?????????)
+  is-concurrent: true
+  # ?????????????????token (?true?????????token, ?false?????????token)
+  is-share: false
+  # token??
+  token-style: uuid
+  # ????????
+  is-log: false
 
 my:
   server-base: http://192.168.89.147:8087/api
   upload-path: E:\work\jgz\upload
-  static-prefix: /assets
+  static-prefix: /
   minitor:
     port: 7777
     ffmpeg: D:\applications\ffmpeg-5.1-essentials_build\bin\ffmpeg.exe

src/main/resources/mapper/EvaluateMapper.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.yunzhi.inte.mapper.EvaluateMapper">
+    
+</mapper>

src/main/resources/mapper/NoticeMessageMapper.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.yunzhi.inte.mapper.NoticeMessageMapper">
+    
+</mapper>

src/main/resources/mapper/PostsFilesMapper.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.yunzhi.inte.mapper.PostsFilesMapper">
+    
+</mapper>

src/main/resources/mapper/ResourcesMapper.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.yunzhi.inte.mapper.ResourcesMapper">
+    
+</mapper>

src/main/resources/mapper/RoleResourcesMapper.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.yunzhi.inte.mapper.RoleResourcesMapper">
+    
+</mapper>

src/main/resources/mapper/RolesMapper.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.yunzhi.inte.mapper.RolesMapper">
+    
+</mapper>

src/main/resources/mapper/UserRolesMapper.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.yunzhi.inte.mapper.UserRolesMapper">
+    
+</mapper>

src/main/resources/mapper/UsersMapper.xml

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.yunzhi.inte.mapper.UsersMapper">
+
+    <select id="getByLoginID" resultType="com.yunzhi.inte.entity.Users">
+        SELECT * FROM users t WHERE t.login_name = #{loginName}
+    </select>
+</mapper>