Browse Source

fixcode

master
刘力 3 years ago
parent
commit
349dea63f3
  1. 2
      logging/src/main/java/com/storeroom/annotation/Log.java
  2. 22
      logging/src/main/java/com/storeroom/controller/LogController.java
  3. 1
      pom.xml
  4. 7
      storeroom/src/main/java/com/storeroom/modules/device/service/impl/DeviceArchivesTagImpl.java
  5. 50
      storeroom/src/main/java/com/storeroom/modules/device/service/impl/DeviceImpl.java

2
logging/src/main/java/com/storeroom/annotation/Log.java

@ -10,4 +10,6 @@ import java.lang.annotation.Target;
@Retention(RetentionPolicy.RUNTIME) @Retention(RetentionPolicy.RUNTIME)
public @interface Log { public @interface Log {
String value() default ""; String value() default "";
//int type();
} }

22
logging/src/main/java/com/storeroom/controller/LogController.java

@ -1,6 +1,7 @@
package com.storeroom.controller; package com.storeroom.controller;
import com.storeroom.annotaion.rest.AnonymousGetMapping;
import com.storeroom.annotation.Log; import com.storeroom.annotation.Log;
import com.storeroom.service.LogService; import com.storeroom.service.LogService;
import com.storeroom.service.dto.LogQueryCriteria; import com.storeroom.service.dto.LogQueryCriteria;
@ -28,8 +29,7 @@ public class LogController {
@Log("导出数据") @Log("导出数据")
@ApiOperation("导出数据") @ApiOperation("导出数据")
@GetMapping(value = "/download")
@PreAuthorize("@ys.check()")
@AnonymousGetMapping(value = "/download")
public void exportLog(HttpServletResponse response, LogQueryCriteria criteria) throws IOException { public void exportLog(HttpServletResponse response, LogQueryCriteria criteria) throws IOException {
criteria.setLogType("INFO"); criteria.setLogType("INFO");
logService.download(logService.queryAll(criteria), response); logService.download(logService.queryAll(criteria), response);
@ -37,21 +37,21 @@ public class LogController {
@Log("导出错误数据") @Log("导出错误数据")
@ApiOperation("导出错误数据") @ApiOperation("导出错误数据")
@GetMapping(value = "/error/download")
@PreAuthorize("@ys.check()")
@AnonymousGetMapping(value = "/error/download")
// @PreAuthorize("@ys.check()")
public void exportErrorLog(HttpServletResponse response, LogQueryCriteria criteria) throws IOException { public void exportErrorLog(HttpServletResponse response, LogQueryCriteria criteria) throws IOException {
criteria.setLogType("ERROR"); criteria.setLogType("ERROR");
logService.download(logService.queryAll(criteria), response); logService.download(logService.queryAll(criteria), response);
} }
@GetMapping
@AnonymousGetMapping
@ApiOperation("日志查询") @ApiOperation("日志查询")
@PreAuthorize("@ys.check()")
public ResponseEntity<Object> queryLog(LogQueryCriteria criteria, Pageable pageable){ public ResponseEntity<Object> queryLog(LogQueryCriteria criteria, Pageable pageable){
criteria.setLogType("INFO"); criteria.setLogType("INFO");
return new ResponseEntity<>(logService.queryAll(criteria,pageable), HttpStatus.OK); return new ResponseEntity<>(logService.queryAll(criteria,pageable), HttpStatus.OK);
} }
@GetMapping(value = "/user")
@AnonymousGetMapping(value = "/user")
@ApiOperation("用户日志查询") @ApiOperation("用户日志查询")
public ResponseEntity<Object> queryUserLog(LogQueryCriteria criteria, Pageable pageable){ public ResponseEntity<Object> queryUserLog(LogQueryCriteria criteria, Pageable pageable){
criteria.setLogType("INFO"); criteria.setLogType("INFO");
@ -59,20 +59,19 @@ public class LogController {
return new ResponseEntity<>(logService.queryAllByUser(criteria,pageable), HttpStatus.OK); return new ResponseEntity<>(logService.queryAllByUser(criteria,pageable), HttpStatus.OK);
} }
@GetMapping(value = "/error")
@AnonymousGetMapping(value = "/error")
@ApiOperation("错误日志查询") @ApiOperation("错误日志查询")
@PreAuthorize("@ys.check()")
public ResponseEntity<Object> queryErrorLog(LogQueryCriteria criteria, Pageable pageable){ public ResponseEntity<Object> queryErrorLog(LogQueryCriteria criteria, Pageable pageable){
criteria.setLogType("ERROR"); criteria.setLogType("ERROR");
return new ResponseEntity<>(logService.queryAll(criteria,pageable), HttpStatus.OK); return new ResponseEntity<>(logService.queryAll(criteria,pageable), HttpStatus.OK);
} }
@GetMapping(value = "/error/{id}")
@AnonymousGetMapping(value = "/error/{id}")
@ApiOperation("日志异常详情查询") @ApiOperation("日志异常详情查询")
@PreAuthorize("@ys.check()")
public ResponseEntity<Object> queryErrorLogDetail(@PathVariable Long id){ public ResponseEntity<Object> queryErrorLogDetail(@PathVariable Long id){
return new ResponseEntity<>(logService.findByErrDetail(id), HttpStatus.OK); return new ResponseEntity<>(logService.findByErrDetail(id), HttpStatus.OK);
} }
@DeleteMapping(value = "/del/error") @DeleteMapping(value = "/del/error")
@Log("删除所有ERROR日志") @Log("删除所有ERROR日志")
@ApiOperation("删除所有ERROR日志") @ApiOperation("删除所有ERROR日志")
@ -85,7 +84,6 @@ public class LogController {
@DeleteMapping(value = "/del/info") @DeleteMapping(value = "/del/info")
@Log("删除所有INFO日志") @Log("删除所有INFO日志")
@ApiOperation("删除所有INFO日志") @ApiOperation("删除所有INFO日志")
@PreAuthorize("@ys.check()")
public ResponseEntity<Object> delAllInfoLog(){ public ResponseEntity<Object> delAllInfoLog(){
logService.delAllByInfo(); logService.delAllByInfo();
return new ResponseEntity<>(HttpStatus.OK); return new ResponseEntity<>(HttpStatus.OK);

1
pom.xml

@ -86,6 +86,7 @@
<version>3.12.0</version> <version>3.12.0</version>
</dependency> </dependency>
<!--监控sql日志--> <!--监控sql日志-->
<dependency> <dependency>
<groupId>org.bgee.log4jdbc-log4j2</groupId> <groupId>org.bgee.log4jdbc-log4j2</groupId>

7
storeroom/src/main/java/com/storeroom/modules/device/service/impl/DeviceArchivesTagImpl.java

@ -5,11 +5,14 @@ import com.storeroom.modules.device.domain.DeviceArchivesTag;
import com.storeroom.modules.device.repository.DeviceArchivesTagRepository; import com.storeroom.modules.device.repository.DeviceArchivesTagRepository;
import com.storeroom.modules.device.repository.DeviceInfoRepository; import com.storeroom.modules.device.repository.DeviceInfoRepository;
import com.storeroom.modules.device.service.DeviceArchivesTagService; import com.storeroom.modules.device.service.DeviceArchivesTagService;
import com.storeroom.utils.PageSort;
import com.storeroom.utils.PageUtil; import com.storeroom.utils.PageUtil;
import com.storeroom.utils.StringUtils; import com.storeroom.utils.StringUtils;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.springframework.data.domain.Page; import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable; import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.ArrayList; import java.util.ArrayList;
@ -22,7 +25,6 @@ public class DeviceArchivesTagImpl implements DeviceArchivesTagService {
private final DeviceArchivesTagRepository deviceArchivesTagRepository; private final DeviceArchivesTagRepository deviceArchivesTagRepository;
private final DeviceInfoRepository deviceInfoRepository;
@Override @Override
public String findDeviceIdByShelfId(String shelfId) { public String findDeviceIdByShelfId(String shelfId) {
@ -46,7 +48,8 @@ public class DeviceArchivesTagImpl implements DeviceArchivesTagService {
@Override @Override
public Object queryTagList(String deviceInfoId, Pageable pageable) { public Object queryTagList(String deviceInfoId, Pageable pageable) {
Page<DeviceArchivesTag> page=deviceArchivesTagRepository.findByDeviceInfoId(deviceInfoId, pageable);
PageRequest pageRequest = PageSort.pageRequest(pageable.getPageNumber(), pageable.getPageSize(), "position", Sort.Direction.ASC);
Page<DeviceArchivesTag> page = deviceArchivesTagRepository.findByDeviceInfoId(deviceInfoId, pageRequest);
return PageUtil.toPage(page); return PageUtil.toPage(page);
} }
} }

50
storeroom/src/main/java/com/storeroom/modules/device/service/impl/DeviceImpl.java

@ -189,10 +189,6 @@ public class DeviceImpl implements DeviceService {
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void updateDeseCabinet(DeviceInfoDto deviceInfoDto) { public void updateDeseCabinet(DeviceInfoDto deviceInfoDto) {
DeviceInfo deviceInfo = deviceInfoMapper.toEntity(deviceInfoDto); DeviceInfo deviceInfo = deviceInfoMapper.toEntity(deviceInfoDto);
// List<DeviceInfo> deviceInfoList = deviceInfoRepository.findByAreaNoAndAndDeviceIpAndAndDevicePort(deviceInfo.getAreaNo(), deviceInfo.getDeviceIp(), deviceInfo.getDevicePort());
// if (!ObjectUtils.isEmpty(deviceInfoList)) {
// throw new BaseException("区号IP端口不能重复添加设备");
// }
DeviceInfo deviceInfo1 = deviceInfoRepository.findById(deviceInfo.getId()).orElseGet(DeviceInfo::new); DeviceInfo deviceInfo1 = deviceInfoRepository.findById(deviceInfo.getId()).orElseGet(DeviceInfo::new);
if (ObjectUtils.isEmpty(deviceInfo1)) { if (ObjectUtils.isEmpty(deviceInfo1)) {
throw new BaseException("数据不存在"); throw new BaseException("数据不存在");
@ -217,24 +213,24 @@ public class DeviceImpl implements DeviceService {
deviceInfoDto.setId(NanoIdUtils.randomNanoId()); deviceInfoDto.setId(NanoIdUtils.randomNanoId());
DeviceArchivesTag deviceArchivesTag = new DeviceArchivesTag(); DeviceArchivesTag deviceArchivesTag = new DeviceArchivesTag();
for (int i = 1; i < deviceInfoDto.getCupboardNo(); i++) {
for (int k = 1; k < deviceInfoDto.getRowNo(); k++) {
for (int n = 1; n < deviceInfoDto.getColumnRowNo(); n++) {
String position = i + "-" + k + "-" + n;
String positionName = i + "柜" + k + "层" + n + "列";
deviceArchivesTag.setId(NanoIdUtils.randomNanoId());
deviceArchivesTag.setPosition(position);
deviceArchivesTag.setPosition_name(positionName);
deviceArchivesTag.setDeviceInfoId(deviceInfoDto.getId());
deviceArchivesTag.setCupboardNo(i);
deviceArchivesTag.setRowNo(k);
deviceArchivesTag.setColumnRowNo(n);
deviceArchivesTag.setStoreroomCode(deviceInfoDto.getStoreroomCode());
deviceArchivesTagRepository.save(deviceArchivesTag);
}
// for (int i = 1; i < deviceInfoDto.getCupboardNo(); i++) {
for (int k = 0; k < deviceInfoDto.getRowNo(); k++) {
for (int n = 0; n < deviceInfoDto.getColumnRowNo(); n++) {
String position = deviceInfoDto.getCupboardNo() + "-" + k + "-" + n;
String positionName = deviceInfoDto.getCupboardNo() + "柜" + k + "层" + n + "列";
deviceArchivesTag.setId(NanoIdUtils.randomNanoId());
deviceArchivesTag.setPosition(position);
deviceArchivesTag.setPosition_name(positionName);
deviceArchivesTag.setDeviceInfoId(deviceInfoDto.getId());
deviceArchivesTag.setCupboardNo(deviceInfoDto.getCupboardNo());
deviceArchivesTag.setRowNo(k);
deviceArchivesTag.setColumnRowNo(n);
deviceArchivesTag.setStoreroomCode(deviceInfoDto.getStoreroomCode());
deviceArchivesTagRepository.save(deviceArchivesTag);
} }
} }
// }
Integer num = deviceInfoRepository.findByMax(); Integer num = deviceInfoRepository.findByMax();
@ -251,10 +247,6 @@ public class DeviceImpl implements DeviceService {
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void updateRotaryCabinet(DeviceInfoDto deviceInfoDto) { public void updateRotaryCabinet(DeviceInfoDto deviceInfoDto) {
// List<DeviceInfo> deviceInfoList = deviceInfoRepository.findByDeviceIpAndDevicePort(deviceInfoDto.getDeviceIp(), deviceInfoDto.getDevicePort());
// if (!ObjectUtils.isEmpty(deviceInfoList)) {
// throw new BaseException("同一IP和端口号下不能重复添加设备");
// }
DeviceInfo deviceInfo = deviceInfoRepository.findById(deviceInfoDto.getId()).orElseGet(DeviceInfo::new); DeviceInfo deviceInfo = deviceInfoRepository.findById(deviceInfoDto.getId()).orElseGet(DeviceInfo::new);
if (ObjectUtils.isEmpty(deviceInfo)) { if (ObjectUtils.isEmpty(deviceInfo)) {
throw new BaseException("数据不存在"); throw new BaseException("数据不存在");
@ -296,14 +288,7 @@ public class DeviceImpl implements DeviceService {
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void updateCamera(DeviceInfoDto deviceInfoDto) { public void updateCamera(DeviceInfoDto deviceInfoDto) {
// List<DeviceInfo> deviceInfoList = deviceInfoRepository.findByDeviceIpAndDevicePortAndVideoRouteAndDeviceTypeId(deviceInfoDto.getDeviceIp(),
// deviceInfoDto.getDevicePort(),
// deviceInfoDto.getVideoRoute(),
// deviceInfoDto.getDeviceTypeId());
//
// if (!ObjectUtils.isEmpty(deviceInfoList)) {
// throw new BaseException("同一IP和端口号下不能重复添加设备");
// }
DeviceInfo deviceInfo = deviceInfoMapper.toEntity(deviceInfoDto); DeviceInfo deviceInfo = deviceInfoMapper.toEntity(deviceInfoDto);
DeviceInfo deviceInfo1 = deviceInfoRepository.findById(deviceInfo.getId()).orElseGet(DeviceInfo::new); DeviceInfo deviceInfo1 = deviceInfoRepository.findById(deviceInfo.getId()).orElseGet(DeviceInfo::new);
deviceInfo1.setDeviceName(deviceInfo.getDeviceName()); deviceInfo1.setDeviceName(deviceInfo.getDeviceName());
@ -312,6 +297,7 @@ public class DeviceImpl implements DeviceService {
deviceInfo1.setDeviceAccount(deviceInfo.getDeviceAccount()); deviceInfo1.setDeviceAccount(deviceInfo.getDeviceAccount());
deviceInfo1.setDevicePassword(deviceInfo.getDevicePassword()); deviceInfo1.setDevicePassword(deviceInfo.getDevicePassword());
deviceInfo1.setVideoRoute(deviceInfo.getVideoRoute()); deviceInfo1.setVideoRoute(deviceInfo.getVideoRoute());
deviceInfo1.setStoreroomCode(deviceInfoDto.getStoreroomCode());
deviceInfoRepository.save(deviceInfo1); deviceInfoRepository.save(deviceInfo1);
} }

Loading…
Cancel
Save