TAlarmRecordController.java 6.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165
  1. package com.szwl.controller;
  2. import cn.com.crbank.ommo.bean.ResultMessage;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  5. import com.baomidou.mybatisplus.core.metadata.IPage;
  6. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  7. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  8. import com.szwl.constant.ResponseCodesEnum;
  9. import com.szwl.model.bo.R;
  10. import com.szwl.model.bo.ResponseModel;
  11. import com.szwl.model.entity.*;
  12. import com.szwl.model.utils.PushUtils;
  13. import com.szwl.service.TAdminService;
  14. import com.szwl.service.TAlarmRecordService;
  15. import com.szwl.service.TEquipmentService;
  16. import io.swagger.annotations.Api;
  17. import io.swagger.annotations.ApiOperation;
  18. import org.apache.commons.lang.StringUtils;
  19. import org.springframework.beans.factory.annotation.Autowired;
  20. import org.springframework.http.HttpStatus;
  21. import org.springframework.http.ResponseEntity;
  22. import org.springframework.web.bind.annotation.*;
  23. import java.text.ParseException;
  24. import java.text.SimpleDateFormat;
  25. import java.util.*;
  26. import java.util.stream.Collectors;
  27. /**
  28. * <p>
  29. * 报警信息 前端控制器
  30. * </p>
  31. *
  32. * @author wuhs
  33. * @since 2022-04-27
  34. */
  35. @Api(value = "/tAlarmRecord", tags = {"报警信息"})
  36. @RestController
  37. @RequestMapping("/tAlarmRecord")
  38. public class TAlarmRecordController {
  39. @Autowired
  40. TEquipmentService tEquipmentService;
  41. @Autowired
  42. TAlarmRecordService tAlarmRecordService;
  43. @Autowired
  44. TAdminService adminService;
  45. @ApiOperation(value = "消除报警")
  46. @PostMapping("/eliminate")
  47. public ResponseEntity<?> eliminate(@RequestBody TAlarmRecord param){
  48. TAlarmRecord tAlarmRecord = tAlarmRecordService.getById(param.getId());
  49. TEquipment equipment = tEquipmentService.getById(tAlarmRecord.getEquipmentId());
  50. JSONObject kindData = new JSONObject();
  51. kindData.put("id" , param.getId());
  52. kindData.put("content" , tAlarmRecord.getAlarmContent());
  53. tEquipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("eliminate", kindData.toString()).toString());
  54. return ResponseEntity.status(HttpStatus.OK)
  55. .body(new ResultMessage().setCode(true).setData("0").setMessage("已发送"));
  56. }
  57. @ApiOperation(value = "获取分销信息列表 分页")
  58. @GetMapping("/pageAlarmRecord")
  59. public ResponseModel<IPage<?>> pageAlarmRecord(String adminId, String clientId, String name, Date startDate,Date endDate, long current, long size ) {
  60. TAdmin admin = adminService.getById(adminId);
  61. if(StringUtils.isEmpty(adminId)){
  62. return R.fail(ResponseCodesEnum.A0100);
  63. }
  64. LambdaQueryWrapper<TAlarmRecord> query = Wrappers.lambdaQuery();
  65. if(admin.getType()>1){
  66. query.eq(TAlarmRecord::getAdminId,admin.getId());
  67. }
  68. // 申泽平台管理员
  69. if (admin.getId() == 2738) {
  70. LambdaQueryWrapper<TAdmin> adminQuery = Wrappers.lambdaQuery();
  71. adminQuery.isNull(TAdmin::getCompanyType).or()
  72. .eq(TAdmin::getCompanyType, "0");
  73. List<Long> adminIds = adminService.list(adminQuery).stream()
  74. .map(TAdmin::getId).collect(Collectors.toList());
  75. query.in(TAlarmRecord::getAdminId,adminIds);
  76. }
  77. // 七云平台管理员
  78. if (admin.getId() == 2739) {
  79. LambdaQueryWrapper<TAdmin> adminQuery = Wrappers.lambdaQuery();
  80. adminQuery.eq(TAdmin::getCompanyType, "1");
  81. List<Long> adminIds = adminService.list(adminQuery).stream()
  82. .map(TAdmin::getId).collect(Collectors.toList());
  83. query.in(TAlarmRecord::getAdminId,adminIds);
  84. }
  85. if(StringUtils.isNotEmpty(clientId)){
  86. LambdaQueryWrapper<TEquipment> query1 = Wrappers.lambdaQuery();
  87. query1.like(TEquipment::getClientId,clientId);
  88. TEquipment equipment = tEquipmentService.getOnly(query1);
  89. if(admin.getType()>1){
  90. if(equipment.getAdminId().toString().equals(adminId)){
  91. query.eq(TAlarmRecord::getClientId,equipment.getClientId());
  92. }else {
  93. return R.fail("设备编号出错");
  94. }
  95. }else {
  96. query.like(TAlarmRecord::getClientId,clientId);
  97. }
  98. }
  99. if(StringUtils.isNotEmpty(name)){
  100. query.like(TAlarmRecord::getName,name);
  101. }
  102. if(startDate!=null){
  103. query.gt(TAlarmRecord::getOccurrenceTime,startDate);
  104. }
  105. if(endDate!=null){
  106. query.lt(TAlarmRecord::getOccurrenceTime,endDate);
  107. }
  108. query.orderByDesc(TAlarmRecord::getOccurrenceTime);
  109. Page<TAlarmRecord> page = new Page<>(current, size, true);
  110. IPage<TAlarmRecord> iPage = tAlarmRecordService.page(page, query);
  111. return R.ok(iPage);
  112. }
  113. @ApiOperation(value = "查询今天是否有报警")
  114. @GetMapping("/isAlarm")
  115. public ResponseModel<?> isAlarm(Long adminId, String todayDate){
  116. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
  117. Date date = null;
  118. try {
  119. date = sdf.parse(todayDate);
  120. } catch (ParseException e) {
  121. e.printStackTrace();
  122. }
  123. Calendar calendar = new GregorianCalendar();
  124. Calendar calendarEnd = new GregorianCalendar();
  125. calendar.setTime(date);
  126. calendarEnd.setTime(date);
  127. calendar.set(Calendar.HOUR_OF_DAY, 0);
  128. calendar.set(Calendar.MINUTE, 0);
  129. calendar.set(Calendar.SECOND, 0);
  130. calendar.set(Calendar.MILLISECOND, 0);
  131. calendarEnd.set(Calendar.HOUR_OF_DAY, 23);
  132. calendarEnd.set(Calendar.MINUTE, 59);
  133. calendarEnd.set(Calendar.SECOND, 59);
  134. calendarEnd.set(Calendar.MILLISECOND, 999);
  135. Date dateStart = calendar.getTime();
  136. Date dateEnd = calendarEnd.getTime();
  137. LambdaQueryWrapper<TAlarmRecord> tAlarmRecord = new LambdaQueryWrapper<>();
  138. tAlarmRecord.eq(TAlarmRecord::getAdminId, adminId);
  139. tAlarmRecord.eq(TAlarmRecord::getIsEliminate, 0);
  140. tAlarmRecord.gt(TAlarmRecord::getOccurrenceTime, dateStart);
  141. tAlarmRecord.le(TAlarmRecord::getOccurrenceTime, dateEnd);
  142. tAlarmRecord.orderByAsc(TAlarmRecord::getOccurrenceTime);
  143. List<TAlarmRecord> list = tAlarmRecordService.list(tAlarmRecord);
  144. if (list.size() > 0) {
  145. Map<Long, TAlarmRecord> latestRecordsMap = new HashMap<>();
  146. for (TAlarmRecord alarmRecord : list) {
  147. latestRecordsMap.put(alarmRecord.getEquipmentId(), alarmRecord);
  148. }
  149. list = new ArrayList<>(latestRecordsMap.values());
  150. return R.ok(list);
  151. }
  152. return R.ok();
  153. }
  154. }