Skip to content

D
data-acquisition
Commit be1ff70e authored by 竹天卫's avatar 竹天卫
Browse files
Options

111

parent ef083fc1
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 5 additions and 3350 deletions
acquisition-business/pom.xml
View file @ be1ff70e
......@@ -198,8 +198,8 @@
<dependency>
<groupId>com.microsoft.sqlserver</groupId>
<artifactId>mssq-jdbc</artifactId>
<scope>runtime</scope>
<artifactId>mssql-jdbc</artifactId>
<version>8.2.2.jre8</version>
</dependency>
<dependency>
<groupId>com.hynnet</groupId>
......
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/controller/LoginController.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.controller;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.service.impl.LoginService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@Api(tags = "登录接口")
@RestController
@RequestMapping("/login")
public class LoginController {
//
private static final Logger log = LoggerFactory.getLogger("LoginController");
@Autowired
private LoginService loginService;
@ApiOperation(value = "登录")
@GetMapping("/getToken")
public BaseResponse getToken(String userName, String password) {
try {
//测试服务器
return loginService.login(userName, password);
} catch (Exception e) {
log.debug("获取登录token{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "当前登录用户")
@GetMapping("/getLoginUser")
public BaseResponse getLoginUser() {
try {
return loginService.getLoginUser();
} catch (Exception e) {
log.debug("当前登录用户{}", e);
}
return BaseResponse.errorMsg("失败!");
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/controller/SysLogsController.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.controller;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.service.ISysLogsService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* <p>
* 前端控制器
* </p>
*
* @author ztw
* @since 2020-08-24
*/
@Api(tags = "系统管理-日志管理")
@RestController
@RequestMapping("/business/sys-logs")
public class SysLogsController {
private static final Logger log = LoggerFactory.getLogger("SysLogsController");
@Autowired
private ISysLogsService logsService;
@ApiOperation(value = "日志分页列表")
@ApiImplicitParams(value = {
@ApiImplicitParam(name = "startDate", value = "开始日期", paramType = "query", dataType = "String"),
@ApiImplicitParam(name = "endDate", value = "结束日期", paramType = "query", dataType = "String"),
@ApiImplicitParam(name = "objType", value = "日志类型(0系统日志, 1委托管理)", paramType = "query", dataType = "Integer"),
@ApiImplicitParam(name = "objId", value = "对象表id", paramType = "query", dataType = "Integer")
})
@GetMapping("/getPage")
public BaseResponse getPage(PageQuery pageQuery, String startDate, String endDate, Integer objType, Integer objId) {
try {
return logsService.getPage(pageQuery, startDate, endDate, objType, objId);
} catch (Exception e) {
log.debug("日志分页列表{}", e);
}
return BaseResponse.errorMsg("失败!");
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/controller/SysPermissionController.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.controller;
import cn.wise.sc.acquisition.business.service.ISysPermissionService;
import cn.wise.sc.acquisition.business.entity.SysPermission;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.service.ISysPermissionService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
/**
* <p>
* 前端控制器
* </p>
*
* @author ztw
* @since 2020-08-20
*/
@Api(tags = "系统管理-权限管理")
@RestController
@RequestMapping("/business/sys-permission")
public class SysPermissionController {
private static final Logger log = LoggerFactory.getLogger("SysPermissionController");
@Autowired
private ISysPermissionService permissionService;
@ApiOperation(value = "当前登录用户拥有的权限")
@GetMapping("/current")
public BaseResponse permissionsCurrent() {
try {
return permissionService.current();
} catch (Exception e) {
log.debug("当前登录用户拥有的权限{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "菜单列表")
@GetMapping("/permissionsList")
public BaseResponse permissionsList() {
try {
return permissionService.permissionsList();
} catch (Exception e) {
log.debug("菜单列表{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "一级菜单")
@GetMapping("/parents")
public BaseResponse parentMenu() {
try {
return permissionService.parents();
} catch (Exception e) {
log.debug("一级菜单{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "菜单树")
@GetMapping("/tree")
public BaseResponse tree() {
try {
return permissionService.tree();
} catch (Exception e) {
log.debug("菜单树{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "根据角色id获取权限")
@GetMapping("/listByRoleId")
public BaseResponse listByRoleId(Integer roleId) {
try {
return permissionService.listByRoleId(roleId);
} catch (Exception e) {
log.debug("根据角色id获取权限{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "保存菜单")
@PostMapping("/create")
public BaseResponse create(@RequestBody SysPermission permission) {
try {
return permissionService.create(permission);
} catch (Exception e) {
log.debug("保存菜单{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "修改菜单")
@PostMapping("/update")
public BaseResponse update(@RequestBody SysPermission permission) {
try {
return permissionService.update(permission);
} catch (Exception e) {
log.debug("修改菜单{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@GetMapping("/{id}")
@ApiOperation(value = "菜单详情")
public BaseResponse get(@PathVariable Integer id) {
try {
SysPermission permission = permissionService.getById(id);
return BaseResponse.okData(permission);
} catch (Exception e) {
log.debug("根据菜单id获取菜单{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@PostMapping("/delete/{id}")
@ApiOperation(value = "删除菜单")
@Transactional
public BaseResponse delete(@PathVariable Integer id) {
try {
permissionService.removeById(id);
return BaseResponse.okMsg("成功");
} catch (Exception e) {
log.debug("删除菜单{}", e);
}
return BaseResponse.errorMsg("失败!");
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/controller/SysPostController.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.controller;
import cn.wise.sc.acquisition.business.model.query.PostQuery;
import cn.wise.sc.acquisition.business.service.ISysPostService;
import cn.wise.sc.acquisition.business.service.ISysUserService;
import cn.wise.sc.acquisition.business.entity.SysPost;
import cn.wise.sc.acquisition.business.entity.SysUser;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.query.PostQuery;
import cn.wise.sc.acquisition.business.service.ISysPostService;
import cn.wise.sc.acquisition.business.service.ISysUserService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* <p>
* 前端控制器
* </p>
*
* @author ztw
* @since 2020-08-25
*/
@Api(tags = "系统管理-职务管理")
@RestController
@RequestMapping("/business/sys-post")
public class SysPostController {
private static final Logger log = LoggerFactory.getLogger("SysPostController");
@Autowired
private ISysPostService postService;
@Autowired
private ISysUserService userService;
@ApiOperation(value = "职务分页列表")
@ApiImplicitParams(value = {
@ApiImplicitParam(name = "name", value = "职务名称", paramType = "query", dataType = "String")
})
@GetMapping("/getPage")
public BaseResponse getPage(PageQuery pageQuery, String name) {
try {
return postService.getPage(pageQuery, name);
} catch (Exception e) {
log.debug("职务分页列表{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "新增职务")
@PostMapping("/create")
public BaseResponse create(@RequestBody PostQuery query) {
try {
return postService.create(query);
} catch (Exception e) {
log.debug("新增职务{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "修改职务")
@PostMapping("/update")
public BaseResponse update(@RequestBody PostQuery query) {
try {
return postService.update(query);
} catch (Exception e) {
log.debug("修改职务{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "职务详情")
@GetMapping("/{id}")
public BaseResponse getById(@PathVariable Integer id) {
try {
SysPost post = postService.getById(id);
if (post == null) {
return BaseResponse.errorMsg("信息错误!");
}
return BaseResponse.okData(post);
} catch (Exception e) {
log.debug("职务详情{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "职务列表")
@GetMapping("/getList")
public BaseResponse getList() {
try {
List<SysPost> list = postService.list();
return BaseResponse.okData(list);
} catch (Exception e) {
log.debug("职务列表{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "删除职务")
@PostMapping("/delete/{id}")
public BaseResponse delete(@PathVariable Integer id) {
try {
if(id == 1 || id == 2){
return BaseResponse.errorMsg("职务不允许删除!");
}
QueryWrapper<SysUser> sysUserQueryWrapper = new QueryWrapper<>();
sysUserQueryWrapper.eq("post_id", id);
Integer conunts = userService.count(sysUserQueryWrapper);
if (conunts != 0 && conunts > 0) {
return BaseResponse.errorMsg(conunts + "个用户正在使用!");
}
postService.removeById(id);
return BaseResponse.okData("删除成功");
} catch (Exception e) {
log.debug("删除职务{}", e);
}
return BaseResponse.errorMsg("失败!");
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/controller/SysRoleController.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.controller;
import cn.wise.sc.acquisition.business.model.query.RoleQuery;
import cn.wise.sc.acquisition.business.entity.SysRole;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.query.RoleQuery;
import cn.wise.sc.acquisition.business.service.ISysRoleService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* <p>
* 前端控制器
* </p>
*
* @author ztw
* @since 2020-08-20
*/
@Api(tags = "系统管理-角色管理")
@RestController
@RequestMapping("/business/sys-role")
public class SysRoleController {
private static final Logger log = LoggerFactory.getLogger("SysRoleController");
@Autowired
private ISysRoleService roleService;
@ApiOperation(value = "角色分页列表")
@ApiImplicitParams(value = {
@ApiImplicitParam(name = "name", value = "角色名称", paramType = "query", dataType = "String")
})
@GetMapping("/getPage")
public BaseResponse getPage(PageQuery pageQuery, String name) {
try {
return roleService.getPage(pageQuery, name);
} catch (Exception e) {
log.debug("角色分页列表{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "新增角色")
@PostMapping("/create")
public BaseResponse create(@RequestBody RoleQuery query) {
try {
return roleService.create(query);
} catch (Exception e) {
log.debug("新增角色{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "修改角色")
@PostMapping("/update")
public BaseResponse update(@RequestBody RoleQuery query) {
try {
return roleService.update(query);
} catch (Exception e) {
log.debug("修改角色{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "角色详情")
@GetMapping("/{id}")
public BaseResponse getById(@PathVariable Integer id) {
try {
SysRole role = roleService.getById(id);
if (role == null) {
return BaseResponse.errorMsg("信息错误!");
}
return BaseResponse.okData(role);
} catch (Exception e) {
log.debug("角色详情{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "所有角色")
@GetMapping("/getAll")
public BaseResponse getAll() {
try {
List<SysRole> list = roleService.list();
return BaseResponse.okData(list);
} catch (Exception e) {
log.debug("所有角色{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "根据用户id获取拥有的角色")
@GetMapping("/byUserId")
public BaseResponse byUserId(Integer userId) {
try {
return roleService.byUserId(userId);
} catch (Exception e) {
log.debug("根据用户id获取拥有的角色{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "删除角色")
@PostMapping("/delete/{id}")
public BaseResponse delete(@PathVariable Integer id) {
try {
return roleService.delete(id);
} catch (Exception e) {
log.debug("删除角色{}", e);
}
return BaseResponse.errorMsg("失败!");
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/controller/SysUserController.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.controller;
import cn.wise.sc.acquisition.business.model.query.SysUserEnclosureQuery;
import cn.wise.sc.acquisition.business.model.query.UserQuery;
import cn.wise.sc.acquisition.business.service.ISysUserService;
import cn.wise.sc.acquisition.business.entity.SysUser;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.LoginUser;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.query.SysUserEnclosureQuery;
import cn.wise.sc.acquisition.business.model.query.UserQuery;
import cn.wise.sc.acquisition.business.service.ISysUserService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* <p>
* 前端控制器
* </p>
*
* @author ztw
* @since 2020-08-14
*/
@Api(tags = "系统管理-人员管理")
@RestController
@RequestMapping("/tcdri/sys-user")
public class SysUserController {
private static final Logger log = LoggerFactory.getLogger("SysUserController");
@Autowired
private ISysUserService userService;
@ApiOperation(value = "人员分页列表")
@ApiImplicitParams(value = {
@ApiImplicitParam(name = "status", value = "状态0:禁用 1:启用", paramType = "query", dataType = "Integer"),
@ApiImplicitParam(name = "groupId", value = "工作组id", paramType = "query", dataType = "Integer"),
@ApiImplicitParam(name = "name", value = "姓名", paramType = "query", dataType = "String")
})
@GetMapping("/getPage")
public BaseResponse getPage(PageQuery pageQuery, Integer status, Integer groupId, String name) {
try {
return userService.getPage(pageQuery, status, groupId, name);
} catch (Exception e) {
log.debug("人员分页列表{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "新增人员", notes = "默认密码与用户名相同")
@PostMapping("/create")
public BaseResponse create(@RequestBody UserQuery query) {
try {
return userService.create(query);
} catch (Exception e) {
log.debug("新增人员{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "更新人员")
@PostMapping("/update")
public BaseResponse update(@RequestBody UserQuery query) {
try {
return userService.update(query);
} catch (Exception e) {
log.debug("更新人员{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "启用禁用")
@PostMapping("/status")
public BaseResponse status(Integer status, Integer id) {
try {
return userService.status(status, id);
} catch (Exception e) {
log.debug("启用禁用{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "人员详情")
@GetMapping("/{id}")
public BaseResponse getById(@PathVariable Integer id) {
try {
return userService.findById(id);
} catch (Exception e) {
log.debug("人员详情{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "人员列表")
@GetMapping("/getList")
public BaseResponse getList() {
try {
LoginUser loginUser = userService.getLoginUser();
QueryWrapper<SysUser> queryWrapper = new QueryWrapper<>();
if(loginUser != null && loginUser.getGroupId() != null){
queryWrapper.eq("group_id", loginUser.getGroupId());
}
List<SysUser> list = userService.list(queryWrapper);
return BaseResponse.okData(list);
} catch (Exception e) {
log.debug("人员列表{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "上传附件")
@PostMapping("/uploadPeoplePF")
public BaseResponse uploadPeoplePF(@RequestBody SysUserEnclosureQuery query){
try {
return userService.uploadPeoplePF(query);
}catch (Exception e){
log.debug("上传附件{}",e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "附件分页列表")
@GetMapping("/getUserEnclosurePage")
public BaseResponse getUserEnclosurePage(PageQuery pageQuery, Integer userId) {
try {
return userService.getUserEnclosurePage(pageQuery, userId);
} catch (Exception e) {
log.debug("附件分页列表{}", e);
}
return BaseResponse.errorMsg("失败!");
}
@ApiOperation(value = "删除人员附件")
@PostMapping("/deleteUserEnclosure")
public BaseResponse deleteUserEnclosure(Integer id) {
try {
return userService.deleteUserEnclosure(id);
} catch (Exception e) {
log.debug("删除人员附件{}", e);
}
return BaseResponse.errorMsg("失败!");
}
// @ApiOperation("人员详情导出列表")
// @PostMapping("/exportList")
// public void exportList(Integer status,String filename,String name, HttpServletResponse response) {
// try {
// userService.exportList(status, filename,name, response);
// } catch (Exception e) {
// log.debug("人员详情导出列表{}", e);
// }
// }
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/controller/SysUserMessageController.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.controller;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.service.ISysUserMessageService;
import cn.wise.sc.acquisition.business.wrapper.WrapMapper;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* <p>
* 前端控制器
* </p>
*
* @author ztw
* @since 2020-10-13
*/
@Api(tags = "企业微信移动端-消息管理")
@RestController
@RequestMapping("/business/sys-user-message")
public class SysUserMessageController {
private static final Logger log = LoggerFactory.getLogger("SysUserMessageController");
@Autowired
private ISysUserMessageService userMessageService;
@ApiOperation(value = "消息通知列表")
@GetMapping("/getMessages")
public BaseResponse getMessages() {
try {
return userMessageService.getMessages();
} catch (Exception e) {
log.debug("消息通知列表{}", e);
}
return BaseResponse.errorMsg("失败!");
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/entity/EntityEnclosure.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import java.time.LocalDateTime;
import java.io.Serializable;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
/**
* <p>
*
* </p>
*
* @author ztw
* @since 2020-09-02
*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
public class EntityEnclosure implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@TableId(value = "id", type = IdType.AUTO)
private Integer id;
@ApiModelProperty("实体id")
private Integer entityId;
/**
* 实体类型（0:用户(头像),
* 3设备校核附件，4标样材料）
*/
@ApiModelProperty("实体类型")
private Integer entityType;
@ApiModelProperty("附件地址")
private String enclosureUrl;
@ApiModelProperty("创建时间")
private LocalDateTime createTime;
@ApiModelProperty("更新时间")
private LocalDateTime updateTime;
@ApiModelProperty("是否删除(0:已经删除，1：未删除)")
private Integer isDeleted;
@ApiModelProperty("文件名")
private String alias;
@ApiModelProperty("扩展名")
private String extName;
@ApiModelProperty("pdf路径")
private String pdfUrl;
public interface EntityType {
int HEAD = 0;
int EQUIPMENT_TEST = 3;
int STANDARD_SAMPLE = 4;
int ENTRUST_REPORT = 5;
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/entity/SysLogs.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import java.time.LocalDateTime;
import java.io.Serializable;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
/**
* <p>
*
* </p>
*
* @author ztw
* @since 2020-08-24
*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
public class SysLogs implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@TableId(value = "id", type = IdType.AUTO)
private Integer id;
@ApiModelProperty("操作用户")
private Integer userId;
@ApiModelProperty("日志类型（1委托详情）")
private Integer objType;
@ApiModelProperty("对象表id（委托表id）")
private Integer objId;
@ApiModelProperty("操作内容")
private String module;
@ApiModelProperty("操作状态1成功,0失败")
private Integer flag;
@ApiModelProperty("创建时间")
private LocalDateTime createTime;
@ApiModelProperty("备注")
private String remark;
public interface ObjType {
int SYSTEM_LOG = 0;
int ENTRUST_LOG = 1;
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/entity/SysPermission.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableField;
import java.io.Serializable;
import java.util.List;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
/**
* <p>
*
* </p>
*
* @author ztw
* @since 2020-08-20
*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
public class SysPermission implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@TableId(value = "id", type = IdType.AUTO)
private Integer id;
@ApiModelProperty("上级ID(如果是一级为0)")
private Integer parentId;
@ApiModelProperty("名字")
private String name;
@ApiModelProperty("菜单图标")
private String css;
@ApiModelProperty("链接")
private String href;
@ApiModelProperty("1菜单权限,2按钮权限")
private Integer type;
@ApiModelProperty("接口权限")
private String permission;
@ApiModelProperty("排序")
private Integer sort;
@ApiModelProperty("备注")
private String remark;
@ApiModelProperty("子元素")
@TableField(exist = false)
private List<SysPermission> child;
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/entity/SysPost.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import java.time.LocalDateTime;
import java.io.Serializable;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
/**
* <p>
*
* </p>
*
* @author ztw
* @since 2020-08-25
*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
public class SysPost implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@TableId(value = "id", type = IdType.AUTO)
private Integer id;
@ApiModelProperty("职务名称")
private String name;
@ApiModelProperty("审批级别")
private Integer level;
@ApiModelProperty("状态（0禁用，1启用）")
private Integer status;
@ApiModelProperty("创建时间")
private LocalDateTime createTime;
@ApiModelProperty("备注")
private String remark;
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/entity/SysRole.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import java.time.LocalDateTime;
import java.io.Serializable;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
/**
* <p>
*
* </p>
*
* @author ztw
* @since 2020-08-20
*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
public class SysRole implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@TableId(value = "id", type = IdType.AUTO)
private Integer id;
@ApiModelProperty("角色名称")
private String name;
@ApiModelProperty("（0禁用，1启用）")
private Integer status;
@ApiModelProperty("创建时间")
private LocalDateTime createTime;
@ApiModelProperty("备注")
private String remark;
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/entity/SysUser.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.time.LocalDate;
import java.time.LocalDateTime;
/**
* <p>
*
* </p>
*
* @author ztw
* @since 2020-08-14
*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
public class SysUser implements Serializable {
private static final long serialVersionUID = 1L;
@TableId(value = "id", type = IdType.AUTO)
private Integer id;
@ApiModelProperty("真实姓名")
private String name;
@ApiModelProperty("用户账号")
private String userName;
@ApiModelProperty("密码")
private String passWord;
@ApiModelProperty("性别0女1男")
private Integer sex;
@ApiModelProperty("部门id")
private Integer groupId;
@ApiModelProperty("职务id")
private Integer postId;
@ApiModelProperty("微信号")
private String wxId;
@ApiModelProperty("职称")
private String qualifications;
@ApiModelProperty("状态（0禁用，1启用")
private Integer status;
@ApiModelProperty("工作年限")
private Double workYear;
@ApiModelProperty("手机号")
private String phone;
@ApiModelProperty("传真")
private String fax;
@ApiModelProperty("专业")
private String major;
@ApiModelProperty("邮箱")
private String email;
@ApiModelProperty("从事本技术领域日期")
private LocalDate technologyDate;
@ApiModelProperty("从事本技术领域年限")
private Double technologyYear;
@ApiModelProperty("文化程度")
private String education;
@ApiModelProperty("（0删除，1正常）")
private Integer isDelete;
@ApiModelProperty("创建时间")
private LocalDateTime createTime;
@ApiModelProperty("修改时间")
private LocalDateTime updateTime;
@ApiModelProperty("备注")
private String remark;
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/entity/SysUserEnclosure.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.time.LocalDateTime;
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName(value = "sys_user_enclosure")
public class SysUserEnclosure implements Serializable {
@TableId(value = "id", type = IdType.AUTO)
private Integer id;
private static final long serialVersionUID = 42L;
private Integer userId;
@ApiModelProperty("附件地址")
private String enclosureUrl;
@ApiModelProperty("状态(0未上传，1成功，2上传失败)")
private Integer FlStatus;
@ApiModelProperty("文件名")
private String alias;
@ApiModelProperty("扩展名")
private String extName;
@ApiModelProperty("上传时间")
private LocalDateTime uploadTime;
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/entity/SysUserMessage.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import java.time.LocalDateTime;
import java.io.Serializable;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
/**
* <p>
*
* </p>
*
* @author ztw
* @since 2020-10-13
*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
public class SysUserMessage implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@TableId(value = "id", type = IdType.AUTO)
private Integer id;
/**
* 接收人id
*/
private Integer userId;
/**
* 接收信息
*/
private String message;
/**
* 相关内容(委托表id)
*/
private Integer appId;
/**
* 是否查看(0:否，1：是)
*/
private Integer isCheck;
/**
* 消息类型(1委托管理)
*/
private Integer messageType;
/**
* 创建时间
*/
private LocalDateTime createTime;
/**
* 更新时间
*/
private LocalDateTime updateTime;
/**
* 是否处理(0:未处理，1：已处理)
*/
private Integer isDeal;
public interface MessageType {
int ENTRUST = 1; //委托
int EQUIPMENT = 2; //设备检定
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/EntityEnclosureMapper.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.mapper;
import cn.wise.sc.acquisition.business.entity.EntityEnclosure;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
/**
* <p>
* Mapper 接口
* </p>
*
* @author ztw
* @since 2020-09-02
*/
public interface EntityEnclosureMapper extends BaseMapper<EntityEnclosure> {
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/SysLogsMapper.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.mapper;
import cn.wise.sc.acquisition.business.model.vo.LogVo;
import cn.wise.sc.acquisition.business.entity.SysLogs;
import cn.wise.sc.acquisition.business.model.vo.LogVo;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.apache.ibatis.annotations.Param;
import java.util.Map;
/**
* <p>
* Mapper 接口
* </p>
*
* @author ztw
* @since 2020-08-24
*/
public interface SysLogsMapper extends BaseMapper<SysLogs> {
IPage<LogVo> getPage(@Param("page") Page page, @Param("params") Map<String, Object> params);
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/SysPermissionMapper.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.mapper;
import cn.wise.sc.acquisition.business.entity.SysPermission;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import io.swagger.models.auth.In;
import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update;
import java.util.List;
import java.util.Set;
/**
* <p>
* Mapper 接口
* </p>
*
* @author ztw
* @since 2020-08-20
*/
public interface SysPermissionMapper extends BaseMapper<SysPermission> {
@Select("select distinct sp.* from sys_permission sp " +
"inner join sys_role_permission rp on sp.id = rp.permission_id " +
"inner join sys_role_user ru on ru.role_id = rp.role_id " +
"where ru.user_id = #{userId} order by sp.parent_id,sp.sort")
List<SysPermission> listByUserId(Integer userId);
@Select("select p.* from sys_permission p inner join sys_role_permission rp on p.id = rp.permission_id where rp.role_id = #{roleId} order by p.parent_id, p.sort")
List<SysPermission> listByRoleId(Integer roleId);
@Select("select * from sys_permission t where t.id = #{id}")
SysPermission getById(Integer id);
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/SysPostMapper.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.mapper;
import cn.wise.sc.acquisition.business.entity.SysPost;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
/**
* <p>
* Mapper 接口
* </p>
*
* @author ztw
* @since 2020-08-25
*/
public interface SysPostMapper extends BaseMapper<SysPost> {
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/SysRoleMapper.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.mapper;
import cn.wise.sc.acquisition.business.entity.SysRole;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import java.util.List;
/**
* <p>
* Mapper 接口
* </p>
*
* @author ztw
* @since 2020-08-20
*/
public interface SysRoleMapper extends BaseMapper<SysRole> {
int saveRolePermission(@Param("roleId") Integer roleId, @Param("permissionIds") List<Integer> permissionIds);
@Delete("delete from sys_role_permission where role_id = #{roleId}")
int deleteRolePermission(Integer roleId);
@Select("select * from sys_role r inner join sys_role_user ru on r.id = ru.role_id where ru.user_id = #{userId}")
SysRole byUserId(Integer userId);
@Select("select count(*) from sys_role_user t where t.role_id = #{id}")
Integer getUserByRoleId(@Param("id") Integer id);
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/SysUserEnclosureMapper.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.mapper;
import cn.wise.sc.acquisition.business.entity.SysUserEnclosure;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.apache.ibatis.annotations.Param;
import java.util.Map;
/**
* <p>
* Mapper 接口
* </p>
*
* @author wlb
* @since 2020-11-9
*/
public interface SysUserEnclosureMapper extends BaseMapper<SysUserEnclosure> {
IPage<SysUserEnclosure> getPage(@Param("page") Page page, @Param("params") Map<String, Object> params);
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/SysUserMapper.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.mapper;
import cn.wise.sc.acquisition.business.model.vo.UserVo;
import cn.wise.sc.acquisition.business.entity.SysUser;
import cn.wise.sc.acquisition.business.model.vo.UserVo;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import java.util.Map;
/**
* <p>
* Mapper 接口
* </p>
*
* @author ztw
* @since 2020-08-14
*/
public interface SysUserMapper extends BaseMapper<SysUser> {
IPage<UserVo> getPage(@Param("page") Page page, @Param("params") Map<String, Object> params);
UserVo getById(Integer id);
// List<Map<String,Object>> exportList(@Param("params") Map<String,Object> params);
@Delete("delete from sys_role_user where user_id = #{userId}")
int deleteUserRole(Integer userId);
int saveUserRoles(@Param("userId") Integer userId, @Param("roleId") Integer roleId);
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/SysUserMessageMapper.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.mapper;
import cn.wise.sc.acquisition.business.entity.SysUserMessage;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* <p>
* Mapper 接口
* </p>
*
* @author ztw
* @since 2020-10-13
*/
public interface SysUserMessageMapper extends BaseMapper<SysUserMessage> {
List<SysUserMessage> getNoCheck(@Param(value = "userId") Integer userId,
@Param(value = "appId") Integer appId,
@Param(value = "messageType") Integer messageType);
List<SysUserMessage> getNoDeal(@Param(value = "userId") Integer userId,
@Param(value = "appId") Integer appId,
@Param(value = "messageType") Integer messageType);
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/xml/EntityEnclosureMapper.xml deleted 100644 → 0
View file @ ef083fc1
<?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="cn.wise.sc.acquisition.business.mapper.EntityEnclosureMapper">
</mapper>
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/xml/SysLogsMapper.xml deleted 100644 → 0
View file @ ef083fc1
<?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="cn.wise.sc.acquisition.business.mapper.SysLogsMapper">
<sql id="where">
<where>
<if test="params.startDate != null and params.startDate != ''">
and DATE(t.create_time) &gt;= #{params.startDate}
</if>
<if test="params.endDate != null and params.endDate != ''">
and DATE(t.create_time) &lt;= #{params.endDate}
</if>
<if test="params.objType != null">
and t.obj_type = #{params.objType}
</if>
<if test="params.objId != null">
and t.obj_id = #{params.objId}
</if>
</where>
</sql>
<select id="getPage" resultType="cn.wise.sc.acquisition.business.model.vo.LogVo">
select t.*,su.name as userName
from sys_logs t
left join sys_user su on su.id = t.user_id
<include refid="where"/>
order by t.create_time desc
</select>
</mapper>
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/xml/SysPermissionMapper.xml deleted 100644 → 0
View file @ ef083fc1
<?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="cn.wise.sc.acquisition.business.mapper.SysPermissionMapper">
</mapper>
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/xml/SysPostMapper.xml deleted 100644 → 0
View file @ ef083fc1
<?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="cn.wise.sc.acquisition.business.mapper.SysPostMapper">
</mapper>
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/xml/SysRoleMapper.xml deleted 100644 → 0
View file @ ef083fc1
<?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="cn.wise.sc.acquisition.business.mapper.SysRoleMapper">
<insert id="saveRolePermission">
insert into sys_role_permission(role_id, permission_id) values
<foreach collection="permissionIds" item="permissionId"
separator=",">
(#{roleId}, #{permissionId})
</foreach>
</insert>
</mapper>
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/xml/SysUserEnclosureMapper.xml deleted 100644 → 0
View file @ ef083fc1
<?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="cn.wise.sc.acquisition.business.mapper.SysUserEnclosureMapper">
<select id="getPage" resultType="cn.wise.sc.acquisition.business.entity.SysUserEnclosure">
select sue.*
from sys_user_enclosure sue
<if test="params.userId != null">
where sue.user_id = #{params.userId}
</if>
</select>
</mapper>
\ No newline at end of file
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/xml/SysUserMapper.xml deleted 100644 → 0
View file @ ef083fc1
<?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="cn.wise.sc.acquisition.business.mapper.SysUserMapper">
<sql id="where">
<where>
<if test="params.status != null ">
and su.status = #{params.status}
</if>
<if test="params.groupId != null">
and su.group_id = #{params.groupId}
</if>
<if test="params.name != null and params.name != ''">
and su.name like concat('%', #{params.name}, '%')
</if>
</where>
</sql>
<select id="getPage" resultType="cn.wise.sc.acquisition.business.model.vo.UserVo">
SELECT su.*, sg.name as groupName, sp.name as postName
FROM sys_user su
left join sys_group sg on sg.id = su.group_id
left join sys_post sp on sp.id = su.post_id
<include refid="where"/>
ORDER BY su.create_time DESC
</select>
<select id="getById" resultType="cn.wise.sc.acquisition.business.model.vo.UserVo">
SELECT su.*, sg.name as groupName, sp.name as postName,
sr.id as roleId, sr.name as roleName
FROM sys_user su
left join sys_group sg on sg.id = su.group_id
left join sys_post sp on sp.id = su.post_id
left join sys_role_user sru on sru.user_id = su.id
left join sys_role sr on sr.id = sru.role_id
where su.id = #{id}
</select>
<insert id="saveUserRoles">
insert into sys_role_user(role_id, user_id) values
(#{roleId}, #{userId})
</insert>
<!-- <select id="exportList" resultType="java.util.HashMap">-->
<!-- SELECT-->
<!-- su.id as 序号,-->
<!-- su.username as 用户账号,-->
<!-- su.name as 真实姓名,-->
<!-- (-->
<!-- CASE su.sex-->
<!-- WHEN 0 THEN '女'-->
<!-- ELSE '男'-->
<!-- END-->
<!-- )as 性别,-->
<!-- su.group_id as 组别id,-->
<!-- su.post_id as 职务id,-->
<!-- su.wx_id as 微信号,-->
<!-- su.qualifications as 职称,-->
<!-- (-->
<!-- CASE su.status-->
<!-- WHEN 0 THEN '禁用'-->
<!-- ELSE '启用'-->
<!-- END-->
<!-- )as 状态,-->
<!-- su.work_year as 工作年限,-->
<!-- su.phone as 手机号,-->
<!-- su.fax as 传真,-->
<!-- su.major as 专业,-->
<!-- su.email as 邮箱,-->
<!-- su.technology_date as 从事本技术领域日期,-->
<!-- su.technology_year as 从事本技术领域年限,-->
<!-- su.education as 文化程度,-->
<!-- su.create_time as 创建时间,-->
<!-- su.update_time as 修改时间,-->
<!-- su.remark as 备注-->
<!-- FROM sys_user su-->
<!-- <include refid="where" />-->
<!-- ORDER BY su.id ASC-->
<!-- </select>-->
</mapper>
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/xml/SysUserMessageMapper.xml deleted 100644 → 0
View file @ ef083fc1
<?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="cn.wise.sc.acquisition.business.mapper.SysUserMessageMapper">
<!-- 未查看消息 -->
<select id="getNoCheck" resultType="cn.wise.sc.acquisition.business.entity.SysUserMessage">
select *
FROM sys_user_message rum
where rum.is_check=0
<if test="userId != null and userId !=''">
and rum.user_id = #{userId}
</if>
<if test="appId != null and appId !=''">
and rum.app_id = #{appId}
</if>
<if test="messageType != null and messageType !=''">
and rum.message_type = #{messageType}
</if>
</select>
<!-- 未处理消息记录 -->
<select id="getNoDeal" resultType="cn.wise.sc.acquisition.business.entity.SysUserMessage">
select *
FROM sys_user_message rum
where rum.is_deal=0
<if test="userId != null and userId !=''">
and rum.user_id = #{userId}
</if>
<if test="appId != null and appId !=''">
and rum.app_id = #{appId}
</if>
<if test="messageType != null and messageType !=''">
and rum.message_type = #{messageType}
</if>
</select>
</mapper>
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/model/LoginUser.java
View file @ be1ff70e
......@@ -2,9 +2,6 @@ package cn.wise.sc.acquisition.business.model;
import java.util.List;
import cn.wise.sc.acquisition.business.entity.SysPermission;
import cn.wise.sc.acquisition.business.entity.SysRole;
import cn.wise.sc.acquisition.business.entity.SysUser;
import lombok.Data;
@Data
......
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/IEntityEnclosureService.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service;
import cn.wise.sc.acquisition.business.entity.EntityEnclosure;
import com.baomidou.mybatisplus.extension.service.IService;
/**
* <p>
* 服务类
* </p>
*
* @author ztw
* @since 2020-09-02
*/
public interface IEntityEnclosureService extends IService<EntityEnclosure> {
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/ISysLogsService.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service;
import cn.wise.sc.acquisition.business.entity.SysLogs;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.entity.SysLogs;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.vo.LogVo;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.IService;
/**
* <p>
* 服务类
* </p>
*
* @author ztw
* @since 2020-08-24
*/
public interface ISysLogsService extends IService<SysLogs> {
BaseResponse<IPage<LogVo>> getPage(PageQuery pageQuery, String startDate, String endDate, Integer objType, Integer objId);
void saveLog(Integer objType, Integer objId, String module, String remark);
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/ISysPermissionService.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service;
import cn.wise.sc.acquisition.business.entity.SysPermission;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import com.alibaba.fastjson.JSONArray;
import com.baomidou.mybatisplus.extension.service.IService;
import java.util.List;
/**
* <p>
* 服务类
* </p>
*
* @author ztw
* @since 2020-08-20
*/
public interface ISysPermissionService extends IService<SysPermission> {
BaseResponse<List<SysPermission>> current();
BaseResponse<List<SysPermission>> permissionsList();
BaseResponse<List<SysPermission>> parents();
BaseResponse<JSONArray> tree();
BaseResponse<List<SysPermission>> listByRoleId(Integer roleId);
BaseResponse<SysPermission> create(SysPermission permission);
BaseResponse<SysPermission> update(SysPermission permission);
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/ISysPostService.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service;
import cn.wise.sc.acquisition.business.entity.SysPost;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.query.PostQuery;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.IService;
/**
* <p>
* 服务类
* </p>
*
* @author ztw
* @since 2020-08-25
*/
public interface ISysPostService extends IService<SysPost> {
BaseResponse<IPage<SysPost>> getPage(PageQuery pageQuery, String name);
BaseResponse<SysPost> create(PostQuery query);
BaseResponse<SysPost> update(PostQuery query);
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/ISysRoleService.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.query.RoleQuery;
import cn.wise.sc.acquisition.business.entity.SysRole;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.query.RoleQuery;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.IService;
/**
* <p>
* 服务类
* </p>
*
* @author ztw
* @since 2020-08-20
*/
public interface ISysRoleService extends IService<SysRole> {
BaseResponse<IPage<SysRole>> getPage(PageQuery pageQuery, String name);
BaseResponse<SysRole> create(RoleQuery query);
BaseResponse<SysRole> update(RoleQuery query);
BaseResponse<SysRole> byUserId(Integer userId);
BaseResponse<String> delete(Integer id);
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/ISysUserMessageService.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service;
import cn.wise.sc.acquisition.business.entity.SysUserMessage;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.entity.SysUserMessage;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.util.WebSocketServer;
import com.baomidou.mybatisplus.extension.service.IService;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.List;
/**
* <p>
* 服务类
* </p>
*
* @author ztw
* @since 2020-10-13
*/
public interface ISysUserMessageService extends IService<SysUserMessage> {
BaseResponse<String> sendMessage(Integer userId, String message, Integer appId, Integer messageType);
BaseResponse<String> checkMessage(Integer userId, Integer appId, Integer messageType);
BaseResponse<String> dealMessage(Integer userId, Integer appId, Integer messageType);
BaseResponse<List<SysUserMessage>> getMessages();
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/ISysUserService.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service;
import cn.wise.sc.acquisition.business.model.query.UserQuery;
import cn.wise.sc.acquisition.business.entity.SysUser;
import cn.wise.sc.acquisition.business.entity.SysUserEnclosure;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.LoginUser;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.query.SysUserEnclosureQuery;
import cn.wise.sc.acquisition.business.model.query.UserQuery;
import cn.wise.sc.acquisition.business.model.vo.UserVo;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.IService;
/**
* <p>
* 服务类
* </p>
*
* @author ztw
* @since 2020-08-14
*/
public interface ISysUserService extends IService<SysUser> {
LoginUser getLoginUser();
BaseResponse<IPage<UserVo>> getPage(PageQuery pageQuery, Integer status, Integer groupId, String name);
BaseResponse<SysUser> create(UserQuery query);
BaseResponse<SysUser> update(UserQuery query);
BaseResponse<String> status(Integer status, Integer id);
BaseResponse<UserVo> findById(Integer id);
BaseResponse<String> uploadPeoplePF(SysUserEnclosureQuery query);
BaseResponse<IPage<SysUserEnclosure>> getUserEnclosurePage(PageQuery pageQuery, Integer userId);
BaseResponse<String> deleteUserEnclosure(Integer id);
/**
* 人员详情列表导出
* @param status 状态
* @param filename 文件名
* @param name 姓名
* @param response
*/
// void exportList(Integer status,String filename,String name, HttpServletResponse response);
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/EntityEnclosureServiceImpl.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service.impl;
import cn.wise.sc.acquisition.business.mapper.EntityEnclosureMapper;
import cn.wise.sc.acquisition.business.service.IEntityEnclosureService;
import cn.wise.sc.acquisition.business.entity.EntityEnclosure;
import cn.wise.sc.acquisition.business.mapper.EntityEnclosureMapper;
import cn.wise.sc.acquisition.business.service.IEntityEnclosureService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
/**
* <p>
* 服务实现类
* </p>
*
* @author ztw
* @since 2020-09-02
*/
@Service
public class EntityEnclosureServiceImpl extends ServiceImpl<EntityEnclosureMapper, EntityEnclosure> implements IEntityEnclosureService {
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/LoginService.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service.impl;
import cn.hutool.core.util.StrUtil;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.LoginUser;
import cn.wise.sc.acquisition.business.service.ISysUserService;
import cn.wise.sc.acquisition.business.util.JwtUtil;
import cn.wise.sc.acquisition.business.util.MD5Util;
import cn.wise.sc.acquisition.business.util.RedisUtil;
import cn.wise.sc.acquisition.business.entity.SysUser;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.LoginUser;
import cn.wise.sc.acquisition.business.service.ISysUserService;
import cn.wise.sc.acquisition.business.util.JwtUtil;
import cn.wise.sc.acquisition.business.util.MD5Util;
import cn.wise.sc.acquisition.business.util.RedisUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@Service
public class LoginService {
@Autowired
private ISysUserService userService;
@Autowired
RedisUtil redisUtil;
/**
* 登录
* @param userName
* @param password
* @return
*/
public BaseResponse<String> login(String userName, String password) {
if (StrUtil.isEmpty(userName)) {
return BaseResponse.errorMsg("用户名为必填项!");
}
if (StrUtil.isEmpty(password)) {
return BaseResponse.errorMsg("密码为必填项!");
}
System.out.println("=========userName==========password=========");
System.out.println(userName + "\n" + password);
try {
QueryWrapper<SysUser> wrapper = new QueryWrapper<>();
wrapper.eq("user_name", userName);
SysUser sysUser = userService.getOne(wrapper);
if (sysUser == null) {
return BaseResponse.errorMsg("非系统用户不允许登录!");
}
if (sysUser.getStatus() == 0) {
return BaseResponse.errorMsg("用户被禁用!");
}
if (sysUser.getIsDelete() == 0) {
return BaseResponse.errorMsg("用户被删除!");
}
String loginPassWd = MD5Util.MD5Encode(password,"UTF-8");
if (!sysUser.getPassWord().equals(loginPassWd)) {
return BaseResponse.errorMsg("密码错误");
}
//生成token,存入redis
String token = JwtUtil.createToken(sysUser.getId(), sysUser.getUserName(),
sysUser.getName(), sysUser.getPhone());
System.out.println(token);
redisUtil.setString(sysUser.getId().toString(), token, 3600);
return BaseResponse.okData(token);
} catch (Exception e) {
return BaseResponse.errorMsg(e.getMessage());
}
}
public static void main(String args[]){
String loginPassWd = MD5Util.MD5Encode("123456","UTF-8");
System.out.println(loginPassWd);
}
/**
* 当前登录用户
* @return
*/
public BaseResponse<LoginUser> getLoginUser() {
LoginUser loginUser = userService.getLoginUser();
return BaseResponse.okData(loginUser);
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/SysLogsServiceImpl.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service.impl;
import cn.wise.sc.acquisition.business.mapper.SysLogsMapper;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.LoginUser;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.vo.LogVo;
import cn.wise.sc.acquisition.business.service.ISysUserService;
import cn.wise.sc.acquisition.business.entity.SysLogs;
import cn.wise.sc.acquisition.business.mapper.SysLogsMapper;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.LoginUser;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.vo.LogVo;
import cn.wise.sc.acquisition.business.service.ISysLogsService;
import cn.wise.sc.acquisition.business.service.ISysUserService;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.HashMap;
import java.util.Map;
/**
* <p>
* 服务实现类
* </p>
*
* @author ztw
* @since 2020-08-24
*/
@Service
public class SysLogsServiceImpl extends ServiceImpl<SysLogsMapper, SysLogs> implements ISysLogsService {
@Resource
private SysLogsMapper logsMapper;
@Autowired
private ISysUserService userService;
/**
* 分页列表
*
* @param pageQuery
* @param startDate
* @param endDate
* @param objType
* @param objId
* @return
*/
@Override
public BaseResponse<IPage<LogVo>> getPage(PageQuery pageQuery, String startDate, String endDate, Integer objType, Integer objId) {
Map<String, Object> params = new HashMap<>();
params.put("startDate", startDate);
params.put("endDate", endDate);
params.put("objType", objType);
params.put("objId", objId);
Page<LogVo> page = new Page<>(pageQuery.getPageNo(), pageQuery.getPageSize());
IPage<LogVo> pages = logsMapper.getPage(page, params);
return BaseResponse.okData(pages);
}
/**
* 添加日志
*
* @param objType
* @param objId
* @param module
* @param remark
*/
@Transactional
@Override
public void saveLog(Integer objType, Integer objId, String module, String remark) {
LoginUser loginUser = userService.getLoginUser();
SysLogs sysLogs = new SysLogs();
sysLogs.setUserId(loginUser.getId())
.setObjType(objType)
.setObjId(objId)
.setModule(module)
.setFlag(1)
.setCreateTime(LocalDateTime.now())
.setRemark(remark);
logsMapper.insert(sysLogs);
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/SysPermissionServiceImpl.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service.impl;
import cn.wise.sc.acquisition.business.mapper.SysPermissionMapper;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.LoginUser;
import cn.wise.sc.acquisition.business.service.ISysPermissionService;
import cn.wise.sc.acquisition.business.service.ISysUserService;
import cn.wise.sc.acquisition.business.entity.SysPermission;
import cn.wise.sc.acquisition.business.mapper.SysPermissionMapper;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.LoginUser;
import cn.wise.sc.acquisition.business.service.ISysPermissionService;
import cn.wise.sc.acquisition.business.service.ISysUserService;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.google.common.collect.Lists;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.util.List;
import java.util.stream.Collectors;
/**
* <p>
* 服务实现类
* </p>
*
* @author ztw
* @since 2020-08-20
*/
@Service
public class SysPermissionServiceImpl extends ServiceImpl<SysPermissionMapper, SysPermission> implements ISysPermissionService {
@Resource
private SysPermissionMapper permissionMapper;
@Autowired
private ISysUserService userService;
/**
* 当前登录用户拥有的权限
*
* @return
*/
@Override
public BaseResponse<List<SysPermission>> current() {
LoginUser loginUser = userService.getLoginUser();
List<SysPermission> list = loginUser.getPermissions();
final List<SysPermission> permissions = list.stream().filter(l -> l.getType().equals(1))
.collect(Collectors.toList());
// setChild(permissions);
//
// return permissions.stream().filter(p -> p.getParentId().equals(0L)).collect(Collectors.toList());
// 2018.06.09 支持多级菜单
List<SysPermission> firstLevel = permissions.stream().filter(p -> p.getParentId().equals(0)).collect(Collectors.toList());
firstLevel.parallelStream().forEach(p -> {
setChild(p, permissions);
});
return BaseResponse.okData(firstLevel);
}
private void setChild(SysPermission p, List<SysPermission> permissions) {
List<SysPermission> child = permissions.parallelStream().filter(a -> a.getParentId().equals(p.getId())).collect(Collectors.toList());
p.setChild(child);
if (!CollectionUtils.isEmpty(child)) {
child.parallelStream().forEach(c -> {
//递归设置子元素，多级菜单支持
setChild(c, permissions);
});
}
}
/**
* 菜单列表
*/
@Override
public BaseResponse<List<SysPermission>> permissionsList() {
List<SysPermission> permissionsAll = this.list();
List<SysPermission> list = Lists.newArrayList();
setPermissionsList(0, permissionsAll, list);
return BaseResponse.okData(list);
}
private void setPermissionsList(Integer pId, List<SysPermission> permissionsAll, List<SysPermission> list) {
for (SysPermission per : permissionsAll) {
if (per.getParentId().equals(pId)) {
list.add(per);
if (permissionsAll.stream().filter(p -> p.getParentId().equals(per.getId())).findAny() != null) {
setPermissionsList(per.getId(), permissionsAll, list);
}
}
}
}
/**
* 一级菜单
*
* @return
*/
@Override
public BaseResponse<List<SysPermission>> parents() {
QueryWrapper<SysPermission> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("type", 1);
queryWrapper.eq("parent_id", 0);
queryWrapper.orderByAsc("parent_id", "sort");
List<SysPermission> list = this.list(queryWrapper);
return BaseResponse.okData(list);
}
/**
* 菜单树
*
* @return
*/
@Override
public BaseResponse<JSONArray> tree() {
List<SysPermission> permissionsAll = this.list();
JSONArray array = new JSONArray();
setPermissionsTree(0, permissionsAll, array);
return BaseResponse.okData(array);
}
private void setPermissionsTree(Integer pId, List<SysPermission> permissionsAll, JSONArray array) {
for (SysPermission per : permissionsAll) {
if (per.getParentId().equals(pId)) {
String string = JSONObject.toJSONString(per);
JSONObject parent = (JSONObject) JSONObject.parse(string);
array.add(parent);
if (permissionsAll.stream().filter(p -> p.getParentId().equals(per.getId())).findAny() != null) {
JSONArray child = new JSONArray();
parent.put("child", child);
setPermissionsTree(per.getId(), permissionsAll, child);
}
}
}
}
/**
* 根据角色id获取权限
*
* @param roleId
* @return
*/
@Override
public BaseResponse<List<SysPermission>> listByRoleId(Integer roleId) {
List<SysPermission> list = permissionMapper.listByRoleId(roleId);
return BaseResponse.okData(list);
}
/**
* 新增
*
* @param permission
* @return
*/
@Override
@Transactional
public BaseResponse<SysPermission> create(SysPermission permission) {
if (StringUtils.isEmpty(permission.getName())) {
return BaseResponse.errorMsg("权限名称不可为空");
}
this.save(permission);
return BaseResponse.okData(permission);
}
/**
* 修改
*
* @param permission
* @return
*/
@Override
@Transactional
public BaseResponse<SysPermission> update(SysPermission permission) {
if (StringUtils.isEmpty(permission.getName())) {
return BaseResponse.errorMsg("权限名称不可为空");
}
this.updateById(permission);
return BaseResponse.okData(permission);
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/SysPostServiceImpl.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service.impl;
import cn.wise.sc.acquisition.business.mapper.SysPostMapper;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.query.PostQuery;
import cn.wise.sc.acquisition.business.service.ISysPostService;
import cn.wise.sc.acquisition.business.entity.SysPost;
import cn.wise.sc.acquisition.business.mapper.SysPostMapper;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.query.PostQuery;
import cn.wise.sc.acquisition.business.service.ISysPostService;
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.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.time.LocalDateTime;
/**
* <p>
* 服务实现类
* </p>
*
* @author ztw
* @since 2020-08-25
*/
@Service
public class SysPostServiceImpl extends ServiceImpl<SysPostMapper, SysPost> implements ISysPostService {
@Resource
private SysPostMapper postMapper;
/**
* 获取分页
*
* @param pageQuery
* @param name
* @return
*/
@Override
public BaseResponse<IPage<SysPost>> getPage(PageQuery pageQuery, String name) {
QueryWrapper<SysPost> qw = new QueryWrapper<>();
if (StringUtils.isNotEmpty(name)) {
qw.like("name", name);
}
qw.orderByDesc("create_time");
IPage<SysPost> page = new Page<>(pageQuery.getPageNo(), pageQuery.getPageSize());
page = postMapper.selectPage(page, qw);
return BaseResponse.okData(page);
}
/**
* 新增职务
*
* @param query
* @return
*/
@Override
@Transactional
public BaseResponse<SysPost> create(PostQuery query) {
if (StringUtils.isEmpty(query.getName())) {
return BaseResponse.errorMsg("职务名称不能为空!");
}
QueryWrapper<SysPost> qw = new QueryWrapper<>();
qw.eq("name", query.getName());
int count = postMapper.selectCount(qw);
if (count > 0) {
return BaseResponse.errorMsg(query.getName() + "已存在");
}
SysPost post = new SysPost();
BeanUtils.copyProperties(query, post);
post.setStatus(1);
post.setCreateTime(LocalDateTime.now());
postMapper.insert(post);
return BaseResponse.okData(post);
}
/**
* 修改职务
*
* @param query
* @return
*/
@Override
public BaseResponse<SysPost> update(PostQuery query) {
if (StringUtils.isEmpty(query.getName())) {
return BaseResponse.errorMsg("职务名称不能为空!");
}
QueryWrapper<SysPost> qw = new QueryWrapper<>();
qw.eq("name", query.getName());
qw.ne("id", query.getId());
int count = postMapper.selectCount(qw);
if (count > 0) {
return BaseResponse.errorMsg(query.getName() + "已存在");
}
SysPost post = new SysPost();
BeanUtils.copyProperties(query, post);
postMapper.updateById(post);
return BaseResponse.okData(post);
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/SysRoleServiceImpl.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service.impl;
import cn.wise.sc.acquisition.business.mapper.SysRoleMapper;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.query.RoleQuery;
import cn.wise.sc.acquisition.business.entity.SysRole;
import cn.wise.sc.acquisition.business.mapper.SysRoleMapper;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.PageQuery;
import cn.wise.sc.acquisition.business.model.query.RoleQuery;
import cn.wise.sc.acquisition.business.service.ISysRoleService;
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.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.List;
/**
* <p>
* 服务实现类
* </p>
*
* @author ztw
* @since 2020-08-20
*/
@Service
public class SysRoleServiceImpl extends ServiceImpl<SysRoleMapper, SysRole> implements ISysRoleService {
@Resource
private SysRoleMapper roleMapper;
/**
* 获取分页
*
* @param pageQuery
* @param name
* @return
*/
@Override
public BaseResponse<IPage<SysRole>> getPage(PageQuery pageQuery, String name) {
QueryWrapper<SysRole> qw = new QueryWrapper<>();
if (StringUtils.isNotEmpty(name)) {
qw.like("name", name);
}
qw.orderByDesc("create_time");
IPage<SysRole> page = new Page<>(pageQuery.getPageNo(), pageQuery.getPageSize());
page = roleMapper.selectPage(page, qw);
return BaseResponse.okData(page);
}
/**
* 新增角色
*
* @param query
* @return
*/
@Override
@Transactional
public BaseResponse<SysRole> create(RoleQuery query) {
if (StringUtils.isEmpty(query.getName())) {
return BaseResponse.errorMsg("角色名称不能为空!");
}
QueryWrapper<SysRole> qw = new QueryWrapper<>();
qw.eq("name", query.getName());
int count = roleMapper.selectCount(qw);
if (count > 0) {
return BaseResponse.errorMsg(query.getName() + "已存在");
}
SysRole role = new SysRole();
BeanUtils.copyProperties(query, role);
List<Integer> permissionIds = query.getPermissionIds();
if(!permissionIds.contains(2)){
permissionIds.add(2);
}
if(!permissionIds.contains(11)){
permissionIds.add(11);
}
role.setStatus(1);
role.setCreateTime(LocalDateTime.now());
roleMapper.insert(role);
if (!CollectionUtils.isEmpty(permissionIds)) {
roleMapper.saveRolePermission(role.getId(), permissionIds);
}
return BaseResponse.okData(role);
}
@Override
@Transactional
public BaseResponse<SysRole> update(RoleQuery query) {
if(query.getId() == 1){
return BaseResponse.errorMsg("系统管理员角色不允许修改!");
}
if (StringUtils.isEmpty(query.getName())) {
return BaseResponse.errorMsg("角色名称不能为空!");
}
QueryWrapper<SysRole> qw = new QueryWrapper<>();
qw.eq("name", query.getName());
qw.ne("id", query.getId());
int count = roleMapper.selectCount(qw);
if (count > 0) {
return BaseResponse.errorMsg(query.getName() + "已存在");
}
SysRole role = new SysRole();
BeanUtils.copyProperties(query, role);
List<Integer> permissionIds = query.getPermissionIds();
if(!permissionIds.contains(2)){
permissionIds.add(2);
}
if(!permissionIds.contains(11)){
permissionIds.add(11);
}
roleMapper.updateById(role);
roleMapper.deleteRolePermission(role.getId());
if (!CollectionUtils.isEmpty(permissionIds)) {
roleMapper.saveRolePermission(role.getId(), permissionIds);
}
return BaseResponse.okData(role);
}
/**
* 根据用户id获取拥有的角色
*
* @param userId
* @return
*/
@Override
public BaseResponse<SysRole> byUserId(Integer userId) {
if (userId == null) {
return BaseResponse.errorMsg("用户id不能为空!");
}
SysRole role = roleMapper.byUserId(userId);
return BaseResponse.okData(role);
}
/**
* 删除角色
*
* @param id
* @return
*/
@Override
@Transactional
public BaseResponse<String> delete(Integer id) {
if(id == 1){
return BaseResponse.errorMsg("系统管理员角色不允许删除!");
}
if(id == 2){
return BaseResponse.errorMsg("角色不允许删除!");
}
SysRole role = roleMapper.selectById(id);
if (role == null) {
return BaseResponse.errorMsg("角色不存在!");
}
Integer conunts = roleMapper.getUserByRoleId(id);
if (conunts != 0 && conunts > 0) {
return BaseResponse.errorMsg(conunts + "个用户正在使用!");
}
roleMapper.deleteById(id);
return BaseResponse.okData("删除成功");
}
}
acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/SysUserMessageServiceImpl.java deleted 100644 → 0
View file @ ef083fc1
package cn.wise.sc.acquisition.business.service.impl;
import cn.wise.sc.acquisition.business.mapper.SysUserMessageMapper;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.LoginUser;
import cn.wise.sc.acquisition.business.model.Message;
import cn.wise.sc.acquisition.business.service.ISysUserService;
import cn.wise.sc.acquisition.business.entity.SysUser;
import cn.wise.sc.acquisition.business.entity.SysUserMessage;
import cn.wise.sc.acquisition.business.mapper.SysUserMessageMapper;
import cn.wise.sc.acquisition.business.model.BaseResponse;
import cn.wise.sc.acquisition.business.model.LoginUser;
import cn.wise.sc.acquisition.business.model.Message;
import cn.wise.sc.acquisition.business.service.ISysUserMessageService;
import cn.wise.sc.acquisition.business.service.ISysUserService;
import cn.wise.sc.acquisition.business.util.WebSocketServer;
import cn.wise.sc.acquisition.business.wrapper.WrapMapper;
import cn.wise.sc.acquisition.business.wrapper.Wrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.time.LocalDateTime;
import java.util.Date;
import java.util.List;
/**
* <p>
* 服务实现类
* </p>
*
* @author ztw
* @since 2020-10-13
*/
@Service
public class SysUserMessageServiceImpl extends ServiceImpl<SysUserMessageMapper, SysUserMessage> implements ISysUserMessageService {
@Resource
private SysUserMessageMapper userMessageMapper;
@Resource
protected HttpServletResponse response;
@Autowired
protected HttpServletRequest request;
@Autowired
WebSocketServer webSocketServer;
@Autowired
private ISysUserService userService;
/**
* 发送消息
*
* @param userId
* @param message
* @param appId
* @param messageType
* @return
*/
@Override
public BaseResponse<String> sendMessage(Integer userId, String message, Integer appId, Integer messageType) {
int ret = 0;
SysUserMessage userMessage = new SysUserMessage();
userMessage.setUserId(userId);
userMessage.setMessage(message);
userMessage.setAppId(appId);
userMessage.setIsCheck(0);
userMessage.setMessageType(messageType);
userMessage.setCreateTime(LocalDateTime.now());
userMessage.setUpdateTime(userMessage.getCreateTime());
userMessage.setIsDeal(0);
ret = this.userMessageMapper.insert(userMessage);
if (ret == 0) {
return BaseResponse.errorMsg("消息推送失败");
}
String dealer = String.valueOf(userId);
Message m = Message.builder().userId(dealer).message(message).messageType(messageType).appId(appId)
.createTime(userMessage.getCreateTime()).build();
webSocketServer.sendTo(m);
/*SysUser sysUser = userService.getById(userId);
if(sysUser != null && StringUtils.isNotBlank(sysUser.getPhone())){
SMSUtil.sendCode(sysUser.getPhone(), message);
}*/
return BaseResponse.okData("成功");
}
/**
* 查看消息
*
* @param userId
* @param appId
* @param messageType
* @return
*/
@Override
public BaseResponse<String> checkMessage(Integer userId, Integer appId, Integer messageType) {
int ret = 0;
List<SysUserMessage> list = this.userMessageMapper.getNoCheck(userId, appId, messageType);
if (list != null && list.size() > 0) {
for (SysUserMessage um : list) {
um.setIsCheck(1);
ret = this.userMessageMapper.updateById(um);
if (ret == 0) {
return BaseResponse.errorMsg("查看消息记录更新失败");
}
}
}
return BaseResponse.okData("成功");
}
/**
* 处理消息
*
* @param userId
* @param appId
* @param messageType
* @return
*/
@Override
public BaseResponse<String> dealMessage(Integer userId, Integer appId, Integer messageType) {
int ret = 0;
List<SysUserMessage> list = this.userMessageMapper.getNoDeal(userId, appId, messageType);
if (list != null && list.size() > 0) {
for (SysUserMessage um : list) {
um.setIsCheck(1);
um.setIsDeal(1);
ret = this.userMessageMapper.updateById(um);
if (ret == 0) {
return BaseResponse.errorMsg("处理消息记录更新失败");
}
}
}
return BaseResponse.okData("成功");
}
/**
* 消息列表
*
* @return
*/
@Override
public BaseResponse<List<SysUserMessage>> getMessages() {
LoginUser loginUser = userService.getLoginUser();
if (loginUser == null) {
return BaseResponse.noLogin("请登录账号");
}
List<SysUserMessage> list = this.userMessageMapper.getNoDeal(loginUser.getId(), null, null);
return BaseResponse.okData(list);
}
}
acquisition-business/src/main/resources/application-dev.yml
View file @ be1ff70e
......@@ -9,10 +9,9 @@ spring:
datasource:
# 192.168.110.85 fpsn
url: jdbc:sqlserver://192.168.110.85:1433;DatabaseName=fpsn
driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver
username: root
password: admin!@#123
driverClassName: com.mysql.cj.jdbc.Driver
driverClassName: com.microsoft.sqlserver.jdbc.SQLServerDriver
hikari:
minimum-idle: 3
maximum-pool-size: 10
......
mybatis-generator/src/main/java/cn/wise/sc/acquisition/mg/GeneratorApplication.java
View file @ be1ff70e
......@@ -47,8 +47,8 @@ public class GeneratorApplication {
AutoGenerator mpg = new AutoGenerator();
// 数据源配置
DataSourceConfig dsc = new DataSourceConfig();
dsc.setUrl("jdbc:mysql://192.168.110.85:3306/sinoma_tcdri?useUnicode=true&useSSL=false&characterEncoding=utf8");
dsc.setDriverName("com.mysql.jdbc.Driver");
dsc.setUrl("jdbc:sqlserver://192.168.110.85:1433");
dsc.setDriverName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
dsc.setUsername("root");
dsc.setPassword("admin!@#123");
mpg.setDataSource(dsc);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment