From 96bc081ea94bdb76af43439a43ee12c66a8bb9c7 Mon Sep 17 00:00:00 2001 From: 648540858 <18010473990@163.com> Date: 星期四, 05 八月 2021 12:35:54 +0800 Subject: [PATCH] 添加用户操作接口 --- src/main/java/com/genersoft/iot/vmp/gb28181/event/online/OnlineEventListener.java | 4 src/main/java/com/genersoft/iot/vmp/conf/MediaConfig.java | 4 sql/mysql.sql | 3 + src/main/java/com/genersoft/iot/vmp/service/impl/UserServiceImpl.java | 17 +++-- src/main/resources/wvp.sqlite | 0 src/main/java/com/genersoft/iot/vmp/service/impl/MediaServerServiceImpl.java | 2 src/main/java/com/genersoft/iot/vmp/vmanager/user/UserController.java | 89 +++++++++++++++++++++++++++-- src/main/java/com/genersoft/iot/vmp/service/IUserService.java | 6 +- src/main/java/com/genersoft/iot/vmp/conf/security/dto/LoginUser.java | 6 ++ src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java | 8 +- 10 files changed, 111 insertions(+), 28 deletions(-) diff --git a/sql/mysql.sql b/sql/mysql.sql index e654e98..ba78cd2 100644 --- a/sql/mysql.sql +++ b/sql/mysql.sql @@ -219,5 +219,8 @@ update_time varchar(50) not null ); +create unique index user_username_uindex + on user (username); + insert into user (username, password, roleId, create_time, update_time) values ('admin', '21232f297a57a5a743894a0e4a801fc3', '0', '2021-04-13 14:14:57', '2021-04-13 14:14:57'); diff --git a/src/main/java/com/genersoft/iot/vmp/conf/MediaConfig.java b/src/main/java/com/genersoft/iot/vmp/conf/MediaConfig.java index 66dedf2..72cefe1 100644 --- a/src/main/java/com/genersoft/iot/vmp/conf/MediaConfig.java +++ b/src/main/java/com/genersoft/iot/vmp/conf/MediaConfig.java @@ -188,8 +188,8 @@ mediaServerItem.setRecordAssistPort(recordAssistPort); SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - mediaServerItem.setCreateTime(format.format(new Date(System.currentTimeMillis()))); - mediaServerItem.setUpdateTime(format.format(new Date(System.currentTimeMillis()))); + mediaServerItem.setCreateTime(format.format(System.currentTimeMillis())); + mediaServerItem.setUpdateTime(format.format(System.currentTimeMillis())); return mediaServerItem; } diff --git a/src/main/java/com/genersoft/iot/vmp/conf/security/dto/LoginUser.java b/src/main/java/com/genersoft/iot/vmp/conf/security/dto/LoginUser.java index 4bb7017..93680fd 100644 --- a/src/main/java/com/genersoft/iot/vmp/conf/security/dto/LoginUser.java +++ b/src/main/java/com/genersoft/iot/vmp/conf/security/dto/LoginUser.java @@ -92,4 +92,10 @@ public int getId() { return user.getId(); } + + public int getRoleId() { + return user.getRoleId(); + } + + } diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/event/online/OnlineEventListener.java b/src/main/java/com/genersoft/iot/vmp/gb28181/event/online/OnlineEventListener.java index acdf272..270fb36 100644 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/event/online/OnlineEventListener.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/event/online/OnlineEventListener.java @@ -52,7 +52,7 @@ case VideoManagerConstants.EVENT_ONLINE_REGISTER: // 瓒呮椂鏃堕棿 redis.set(key, event.getDevice().getDeviceId(), sipConfig.getKeepaliveTimeOut()); - device.setRegisterTime(format.format(new Date(System.currentTimeMillis()))); + device.setRegisterTime(format.format(System.currentTimeMillis())); break; // 璁惧涓诲姩鍙戦�佸績璺宠Е鍙戠殑鍦ㄧ嚎浜嬩欢 case VideoManagerConstants.EVENT_ONLINE_KEEPLIVE: @@ -63,7 +63,7 @@ } else { redis.expire(key, sipConfig.getKeepaliveTimeOut()); } - device.setKeepaliveTime(format.format(new Date(System.currentTimeMillis()))); + device.setKeepaliveTime(format.format(System.currentTimeMillis())); break; // 璁惧涓诲姩鍙戦�佹秷鎭Е鍙戠殑鍦ㄧ嚎浜嬩欢 case VideoManagerConstants.EVENT_ONLINE_MESSAGE: diff --git a/src/main/java/com/genersoft/iot/vmp/service/IUserService.java b/src/main/java/com/genersoft/iot/vmp/service/IUserService.java index 112af35..c170c02 100644 --- a/src/main/java/com/genersoft/iot/vmp/service/IUserService.java +++ b/src/main/java/com/genersoft/iot/vmp/service/IUserService.java @@ -12,11 +12,11 @@ User getUserByUsername(String username); - void addUser(User user); + int addUser(User user); - void deleteUser(int id); + int deleteUser(int id); List<User> getAllUsers(); - void updateUsers(User user); + int updateUsers(User user); } diff --git a/src/main/java/com/genersoft/iot/vmp/service/impl/MediaServerServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/service/impl/MediaServerServiceImpl.java index d65b461..6234073 100644 --- a/src/main/java/com/genersoft/iot/vmp/service/impl/MediaServerServiceImpl.java +++ b/src/main/java/com/genersoft/iot/vmp/service/impl/MediaServerServiceImpl.java @@ -276,7 +276,7 @@ resetOnlineServerItem(serverItemFromConfig); setZLMConfig(serverItemFromConfig); }else { - String now = this.format.format(new Date(System.currentTimeMillis())); + String now = this.format.format(System.currentTimeMillis()); if (serverItem == null){ // 涓�涓柊鐨剒lm鎺ュ叆wvp serverItem = new MediaServerItem(zlmServerConfig, sipConfig.getSipIp()); diff --git a/src/main/java/com/genersoft/iot/vmp/service/impl/UserServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/service/impl/UserServiceImpl.java index e10fc79..32b6ad6 100644 --- a/src/main/java/com/genersoft/iot/vmp/service/impl/UserServiceImpl.java +++ b/src/main/java/com/genersoft/iot/vmp/service/impl/UserServiceImpl.java @@ -13,8 +13,7 @@ @Autowired private UserMapper userMapper; - - + @Override public User getUser(String username, String password) { return userMapper.select(username, password); @@ -33,12 +32,14 @@ } @Override - public void addUser(User user) { - userMapper.add(user); + public int addUser(User user) { + User userByUsername = userMapper.getUserByUsername(user.getUsername()); + if (userByUsername != null) return 0; + return userMapper.add(user); } @Override - public void deleteUser(int id) { - userMapper.delete(id); + public int deleteUser(int id) { + return userMapper.delete(id); } @Override @@ -47,8 +48,8 @@ } @Override - public void updateUsers(User user) { - userMapper.update(user); + public int updateUsers(User user) { + return userMapper.update(user); } diff --git a/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java b/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java index 82d9bdb..89c1d6c 100644 --- a/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java +++ b/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java @@ -109,7 +109,7 @@ */ @Override public synchronized boolean updateDevice(Device device) { - String now = this.format.format(new Date(System.currentTimeMillis())); + String now = this.format.format(System.currentTimeMillis()); device.setUpdateTime(now); Device deviceByDeviceId = deviceMapper.getDeviceByDeviceId(device.getDeviceId()); if (deviceByDeviceId == null) { @@ -126,7 +126,7 @@ String channelId = channel.getChannelId(); channel.setDeviceId(deviceId); channel.setStreamId(streamSession.getStreamId(deviceId, channel.getChannelId())); - String now = this.format.format(new Date(System.currentTimeMillis())); + String now = this.format.format(System.currentTimeMillis()); channel.setUpdateTime(now); DeviceChannel deviceChannel = deviceChannelMapper.queryChannel(deviceId, channelId); if (deviceChannel == null) { @@ -463,7 +463,7 @@ boolean result = false; streamProxyItem.setStreamType("proxy"); streamProxyItem.setStatus(true); - String now = this.format.format(new Date(System.currentTimeMillis())); + String now = this.format.format(System.currentTimeMillis()); streamProxyItem.setCreateTime(now); try { if (gbStreamMapper.add(streamProxyItem)<0 || streamProxyMapper.add(streamProxyItem) < 0) { @@ -609,7 +609,7 @@ @Override public void updateMediaServer(MediaServerItem mediaServerItem) { - String now = this.format.format(new Date(System.currentTimeMillis())); + String now = this.format.format(System.currentTimeMillis()); mediaServerItem.setUpdateTime(now); if (mediaServerMapper.queryOne(mediaServerItem.getId()) != null) { mediaServerMapper.update(mediaServerItem); diff --git a/src/main/java/com/genersoft/iot/vmp/vmanager/user/UserController.java b/src/main/java/com/genersoft/iot/vmp/vmanager/user/UserController.java index b552e1e..de40c2c 100644 --- a/src/main/java/com/genersoft/iot/vmp/vmanager/user/UserController.java +++ b/src/main/java/com/genersoft/iot/vmp/vmanager/user/UserController.java @@ -3,16 +3,24 @@ import com.genersoft.iot.vmp.conf.security.SecurityUtils; import com.genersoft.iot.vmp.conf.security.dto.LoginUser; import com.genersoft.iot.vmp.service.IUserService; +import com.genersoft.iot.vmp.storager.dao.dto.User; +import com.genersoft.iot.vmp.vmanager.bean.WVPResult; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.http.HttpStatus; +import org.springframework.http.ResponseEntity; import org.springframework.security.authentication.AuthenticationManager; import org.springframework.util.DigestUtils; import org.springframework.web.bind.annotation.*; import javax.security.sasl.AuthenticationException; +import javax.xml.crypto.Data; +import java.text.SimpleDateFormat; +import java.util.Date; +import java.util.List; @Api(tags = "鐢ㄦ埛绠$悊") @CrossOrigin @@ -26,13 +34,15 @@ @Autowired private IUserService userService; + private final SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + @ApiOperation("鐧诲綍") @ApiImplicitParams({ - @ApiImplicitParam(name = "username", value = "鐢ㄦ埛鍚�", dataTypeClass = String.class), - @ApiImplicitParam(name = "password", value = "瀵嗙爜锛�32浣峬d5鍔犲瘑锛�", dataTypeClass = String.class), + @ApiImplicitParam(name = "username", required = true, value = "鐢ㄦ埛鍚�", dataTypeClass = String.class), + @ApiImplicitParam(name = "password", required = true, value = "瀵嗙爜锛�32浣峬d5鍔犲瘑锛�", dataTypeClass = String.class), }) @GetMapping("/login") - public String login(String username, String password){ + public String login(@RequestParam String username, @RequestParam String password){ LoginUser user; try { user = SecurityUtils.login(username, password, authenticationManager); @@ -49,17 +59,17 @@ @ApiOperation("淇敼瀵嗙爜") @ApiImplicitParams({ - @ApiImplicitParam(name = "username", value = "鐢ㄦ埛鍚�", dataTypeClass = String.class), - @ApiImplicitParam(name = "oldpassword", value = "鏃у瘑鐮侊紙宸瞞d5鍔犲瘑鐨勫瘑鐮侊級", dataTypeClass = String.class), - @ApiImplicitParam(name = "password", value = "鏂板瘑鐮侊紙鏈猰d5鍔犲瘑鐨勫瘑鐮侊級", dataTypeClass = String.class), + @ApiImplicitParam(name = "username", required = true, value = "鐢ㄦ埛鍚�", dataTypeClass = String.class), + @ApiImplicitParam(name = "oldpassword", required = true, value = "鏃у瘑鐮侊紙宸瞞d5鍔犲瘑鐨勫瘑鐮侊級", dataTypeClass = String.class), + @ApiImplicitParam(name = "password", required = true, value = "鏂板瘑鐮侊紙鏈猰d5鍔犲瘑鐨勫瘑鐮侊級", dataTypeClass = String.class), }) @PostMapping("/changePassword") - public String changePassword(String oldpassword, String password){ + public String changePassword(@RequestParam String oldPassword, @RequestParam String password){ // 鑾峰彇褰撳墠鐧诲綍鐢ㄦ埛id String username = SecurityUtils.getUserInfo().getUsername(); LoginUser user = null; try { - user = SecurityUtils.login(username, oldpassword, authenticationManager); + user = SecurityUtils.login(username, oldPassword, authenticationManager); if (user != null) { int userId = SecurityUtils.getUserId(); boolean result = userService.changePassword(userId, DigestUtils.md5DigestAsHex(password.getBytes())); @@ -72,4 +82,67 @@ } return "fail"; } + + + @ApiOperation("娣诲姞鐢ㄦ埛") + @ApiImplicitParams({ + @ApiImplicitParam(name = "username", required = true, value = "鐢ㄦ埛鍚�", dataTypeClass = String.class), + @ApiImplicitParam(name = "password", required = true, value = "瀵嗙爜锛堟湭md5鍔犲瘑鐨勫瘑鐮侊級", dataTypeClass = String.class), + @ApiImplicitParam(name = "roleId", required = true, value = "瑙掕壊ID", dataTypeClass = String.class), + }) + @PostMapping("/add") + public ResponseEntity<WVPResult<Integer>> add(@RequestParam String username, + @RequestParam String password, + @RequestParam int roleId){ + // 鑾峰彇褰撳墠鐧诲綍鐢ㄦ埛id + int currenRoleId = SecurityUtils.getUserInfo().getRoleId(); + if (currenRoleId != 0) { + // 鍙敤瑙掕壊id涓�0鎵嶅彲浠ュ垹闄ゅ拰娣诲姞鐢ㄦ埛 + return new ResponseEntity<>(null, HttpStatus.FORBIDDEN); + } + User user = new User(); + user.setUsername(username); + user.setPassword(DigestUtils.md5DigestAsHex(password.getBytes())); + user.setRoleId(roleId); + user.setCreateTime(format.format(System.currentTimeMillis())); + user.setUpdateTime(format.format(System.currentTimeMillis())); + int addResult = userService.addUser(user); + WVPResult<Integer> result = new WVPResult<>(); + result.setCode(addResult > 0 ? 0 : -1); + result.setMsg(addResult > 0 ? "success" : "fail"); + result.setData(addResult); + return new ResponseEntity<>(result, HttpStatus.OK); + } + + @ApiOperation("鍒犻櫎鐢ㄦ埛") + @ApiImplicitParams({ + @ApiImplicitParam(name = "id", required = true, value = "鐢ㄦ埛Id", dataTypeClass = Integer.class), + }) + @DeleteMapping("/delete") + public ResponseEntity<WVPResult<String>> delete(@RequestParam Integer id){ + // 鑾峰彇褰撳墠鐧诲綍鐢ㄦ埛id + int currenRoleId = SecurityUtils.getUserInfo().getRoleId(); + if (currenRoleId != 0) { + // 鍙敤瑙掕壊id涓�0鎵嶅彲浠ュ垹闄ゅ拰娣诲姞鐢ㄦ埛 + return new ResponseEntity<>(null, HttpStatus.FORBIDDEN); + } + int deleteResult = userService.deleteUser(id); + WVPResult<String> result = new WVPResult<>(); + result.setCode(deleteResult>0? 0 : -1); + result.setMsg(deleteResult>0? "success" : "fail"); + return new ResponseEntity<>(result, HttpStatus.OK); + } + + @ApiOperation("鏌ヨ鐢ㄦ埛") + @ApiImplicitParams({}) + @GetMapping("/all") + public ResponseEntity<WVPResult<List<User>>> all(){ + // 鑾峰彇褰撳墠鐧诲綍鐢ㄦ埛id + List<User> allUsers = userService.getAllUsers(); + WVPResult<List<User>> result = new WVPResult<>(); + result.setCode(0); + result.setMsg("success"); + result.setData(allUsers); + return new ResponseEntity<>(result, HttpStatus.OK); + } } diff --git a/src/main/resources/wvp.sqlite b/src/main/resources/wvp.sqlite index 4dd9860..a76d7ee 100644 --- a/src/main/resources/wvp.sqlite +++ b/src/main/resources/wvp.sqlite Binary files differ -- Gitblit v1.8.0