基于Java与Shell脚本的内网系统巡逻设计源码

package com.soyuan.patrolinside.controller; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.auth0.jwt.JWT; import com.auth0.jwt.algorithms.Algorithm; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import com.soyuan.patrolinside.common.*; import com.soyuan.patrolinside.conf.PatrolConf; import com.soyuan.patrolinside.dto.DailyAlarm.DailyAlarmExcelDto; import com.soyuan.patrolinside.dto.DailyAlarm.QueryDailyAlarmDto; import com.soyuan.patrolinside.dto.alarm.QueryAlarmDto; import com.soyuan.patrolinside.dto.outer.PatrolPeople; import com.soyuan.patrolinside.dto.outer.PeopleTrackViewModel; import com.soyuan.patrolinside.dto.user.*; import com.soyuan.patrolinside.entity.user.User; import com.soyuan.patrolinside.mapper.RoleMapper; import com.soyuan.patrolinside.result.ApiResult; import com.soyuan.patrolinside.result.PageResult; import com.soyuan.patrolinside.service.IAlarmService; import com.soyuan.patrolinside.service.IDailyAlarmService; import com.soyuan.patrolinside.service.IUserService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import java.io.File; import java.util.*; import java.util.stream.Collectors; /** * <p> * 前端控制器 * </p> * * @author zhaops * @since 2021-04-09 */ @RestController @RequestMapping("/api/user") @Slf4j public class UserController { @Autowired private IUserService userService; @Autowired private PatrolConf patrolConf; @Autowired private RoleMapper roleMapper; @Autowired private IAlarmService alarmService; @Autowired private UserInfo userInfo; @Autowired private IDailyAlarmService dailyAlarmService; /** * 登录 * * @param params * @return */ @PostMapping("/login") public LoginUserDto login(@RequestBody LoginUserDto params) { LambdaQueryWrapper<User> queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(User::getUserName, params.getUserName()); queryWrapper.eq(User::getIsDelete, 0); User userEntity = userService.getOne(queryWrapper); if (userEntity == null) { throw new PatrolException(HttpStatusEnum.Error400, "用户不存在！"); } LoginUserDto loginUserDto = LoginUserDto.toDto(userEntity); if (!loginUserDto.getPassword().equals(params.getPassword())) { throw new PatrolException(HttpStatusEnum.Error400, "密码错误！"); } String token = JWT.create().withAudience(loginUserDto.getId().toString()) .sign(Algorithm.HMAC256(loginUserDto.getPassword())); loginUserDto.setToken(token); return loginUserDto; } /** * 是获取用户信息 * * @return */ @PostMapping("/getUserInfo") @UserLoginToken public LoginUserDto getUserInfo() { LambdaQueryWrapper<User> queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(User::getUserName, userInfo.getUser().getUserName()); queryWrapper.eq(User::getIsDelete, 0); User userEntity = userService.getOne(queryWrapper); LoginUserDto loginUserDto = LoginUserDto.toDto(userEntity); return loginUserDto; } /** * 获取菜单 * * @return */ @PostMapping("/menus") @UserLoginToken public List<MenuDto> menus() { return userService.getMenus(); } /** * 获取所有派出所 * * @return */ @GetMapping("/allPolices") @UserLoginToken public ApiResult getAllPolices() { return ApiResult.ok(userService.getAllPolices()); } /** * 获取角色列表 * * @return */ @PostMapping("/roles") @UserLoginToken public PageResult<QueryRoleDto> roles(@RequestBody QueryRoleDto param) { return userService.selectRoles(param); } /** * 通过id查询权限 * * @param id * @return */ @GetMapping("/role/{id}") @UserLoginToken public ApiResult getRoleById(@PathVariable("id") String id) { QueryRoleDto queryRoleDto = userService.getRoleById(id); if (queryRoleDto == null) { throw new PatrolException(HttpStatusEnum.Error400, "查询角色不存在！"); } return ApiResult.ok(queryRoleDto); } /** * 添加角色 * * @param param * @return */ @PostMapping("/role") @UserLoginToken public ApiResult addRole(@RequestBody AddRoleDto param) { userService.addRole(param); return ApiResult.ok(true); } /** * 删除角色 * * @param ids * @return */ @DeleteMapping("/role/{ids}") @UserLoginToken public ApiResult deleteRole(@PathVariable("ids") String ids) { List<String> idsArray = Arrays.stream(ids.split(",")).collect(Collectors.toList()); userService.deleteRoles(idsArray); return ApiResult.ok(true); } /** * 修改橘色 * * @param param * @return */ @PutMapping("/role") @UserLoginToken public ApiResult updateRole(@RequestBody AddRoleDto param) { userService.updateRole(param); return ApiResult.ok(true); } /** * 获取用户列表 * * @param param * @return */ @PostMapping("/users") @UserLoginToken public PageResult<QueryUserDto> getUsers(@RequestBody QueryUserDto param) { return userService.getUsers(param); } /** * 上传头像 * * @param multipartFile * @return */ @PutMapping("/uploadHeadImg") @UserLoginToken public ApiResult uploadHeadImg(@RequestParam("headImg") MultipartFile multipartFile) { if (multipartFile.isEmpty() || StringUtils.isBlank(multipartFile.getOriginalFilename())) { throw new PatrolException(HttpStatusEnum.Error400, "图片不能为空"); } /*路径不存在新建*/ String filePath = Utils.getJarFilePath() + patrolConf.getHeadImgPath(); File file = new File(filePath); if (!file.exists()) { file.mkdir(); } String rootFileName = multipartFile.getOriginalFilename(); String fileName = Utils.getUUID() + rootFileName.substring(rootFileName.indexOf(".")); /* 相对路径 */ String relativeFileName = patrolConf.getHeadImgPath() + fileName; /* 绝对路径 */ String absoluteFileName = Utils.getJarFilePath() + relativeFileName; try { Utils.saveFile(multipartFile, absoluteFileName); } catch (Exception e) { throw new PatrolException(HttpStatusEnum.Error400, "上传失败！"); } return ApiResult.ok(relativeFileName); } /** * 添加用户 * * @param param * @return */ @PostMapping("") @UserLoginToken public ApiResult addUser(@RequestBody AddUserDto param) { userService.addUser(param); return ApiResult.ok(true); } /** * 修改用户 * * @param param * @return */ @PutMapping("") @UserLoginToken public ApiResult updateUser(@RequestBody AddUserDto param) { userService.updateUser(param); return ApiResult.ok(true); } /** * 通过id获取用户 * * @param id * @return */ @GetMapping("{id}") @UserLoginToken public ApiResult getUserById(@PathVariable("id") String id) { QueryUserDto user = QueryUserDto.toDto(userService.getById(id)); if (user == null) { throw new PatrolException(HttpStatusEnum.Error400, "查询记录不