package org.jeecg.modules.dry.controller;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.checkerframework.checker.units.qual.A;
|
import org.jeecg.common.api.vo.Result;
|
import org.jeecg.common.config.TenantContext;
|
import org.jeecg.common.constant.MqttConstant;
|
import org.jeecg.common.system.query.QueryGenerator;
|
import org.jeecg.common.util.DateUtils;
|
import org.jeecg.common.util.RedisUtil;
|
import org.jeecg.common.util.oConvertUtils;
|
import org.jeecg.config.mybatis.MybatisPlusSaasConfig;
|
import org.jeecg.modules.dry.api.EmqxApi;
|
import org.jeecg.modules.dry.entity.DryEquipment;
|
import org.jeecg.modules.dry.entity.DryFaultRecord;
|
import org.jeecg.modules.dry.entity.DryOrder;
|
import org.jeecg.modules.dry.service.IDryEquipmentService;
|
import org.jeecg.modules.dry.service.IDryFaultRecordService;
|
import org.jeecg.modules.dry.service.IDryOrderService;
|
import org.jeecg.modules.dry.vo.DryFaultRecordVo;
|
import org.jeecg.modules.dry.vo.MoEquVo;
|
import org.springframework.beans.BeanUtils;
|
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.RequestParam;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.time.Duration;
|
import java.time.LocalDateTime;
|
import java.time.ZonedDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
@Api(tags = "移动端")
|
@RestController
|
@RequestMapping("/mobile")
|
@Slf4j
|
public class MobileController {
|
@Autowired
|
private IDryEquipmentService dryEquipmentService;
|
@Autowired
|
private IDryFaultRecordService faultRecordService;
|
@Autowired
|
private RedisUtil redisUtil;
|
@Autowired
|
private IDryOrderService orderService;
|
|
@ApiOperation(value = "设备列表查询", notes = "设备列表查询")
|
@GetMapping(value = "/equ/list")
|
public Result<IPage<MoEquVo>> queryPageList(DryEquipment dryEquipment, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, HttpServletRequest req) {
|
//------------------------------------------------------------------------------------------------
|
//是否开启系统管理模块的多租户数据隔离【SAAS多租户模式】
|
if (MybatisPlusSaasConfig.OPEN_SYSTEM_TENANT_CONTROL) {
|
dryEquipment.setTenantId(oConvertUtils.getInt(TenantContext.getTenant(), 0));
|
}
|
//------------------------------------------------------------------------------------------------
|
QueryWrapper<DryEquipment> queryWrapper = QueryGenerator.initQueryWrapper(dryEquipment, req.getParameterMap());
|
Page<DryEquipment> page = new Page<DryEquipment>(pageNo, pageSize);
|
Page<MoEquVo> voPage = new Page<MoEquVo>(pageNo, pageSize);
|
IPage<DryEquipment> pageList = dryEquipmentService.page(page, queryWrapper);
|
|
|
compEqu(pageList, voPage);
|
|
|
return Result.OK(voPage);
|
}
|
|
@ApiOperation(value = "设备报警数据", notes = "设备报警数据列表查询")
|
@GetMapping(value = "/fault/list")
|
public Result<IPage<DryFaultRecordVo>> queryFaultList(DryFaultRecord faultRecord, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, HttpServletRequest req) {
|
int tenantId = oConvertUtils.getInt(TenantContext.getTenant(), 0);
|
//是否开启系统管理模块的多租户数据隔离【SAAS多租户模式】
|
if (MybatisPlusSaasConfig.OPEN_SYSTEM_TENANT_CONTROL) {
|
faultRecord.setTenantId(tenantId);
|
}
|
QueryWrapper<DryFaultRecord> queryWrapper = QueryGenerator.initQueryWrapper(faultRecord, req.getParameterMap());
|
Page<DryFaultRecord> page = new Page<DryFaultRecord>(pageNo, pageSize);
|
IPage<DryFaultRecord> pageList = faultRecordService.page(page, queryWrapper);
|
Page<DryFaultRecordVo> voPage = new Page<DryFaultRecordVo>(pageNo, pageSize);
|
compFault(pageList, voPage);
|
return Result.OK(voPage);
|
}
|
|
private void compFault(IPage<DryFaultRecord> pageList, Page<DryFaultRecordVo> page) {
|
List<DryFaultRecordVo> collect = pageList.getRecords().stream().filter(item -> item.getOrderId() != null).map(item -> {
|
DryFaultRecordVo vo = new DryFaultRecordVo();
|
BeanUtils.copyProperties(item, vo);
|
String orderCode = item.getOrderId();
|
QueryWrapper<DryOrder> orderQueryWrapper = new QueryWrapper<>();
|
orderQueryWrapper.lambda().eq(DryOrder::getCode, orderCode);
|
DryOrder order = orderService.getOne(orderQueryWrapper);
|
if (vo.getStartTime() != null && vo.getEndTime() != null) {
|
String faultTimeStr = calculateTimeDifference(DateUtils.date2Str(vo.getStartTime(), DateUtils.datetimeFormat.get()), DateUtils.date2Str(vo.getEndTime(), DateUtils.datetimeFormat.get()));
|
vo.setFaultTimeStr(faultTimeStr);
|
}
|
|
if (order == null) return vo;
|
String equId = order.getEquId();
|
if (equId == null) return vo;
|
DryEquipment equipment = dryEquipmentService.getById(equId);
|
if (equipment == null || equipment.getName() == null) return vo;
|
vo.setEquName(equipment.getName().substring(0, 2));
|
return vo;
|
}).collect(Collectors.toList());
|
BeanUtils.copyProperties(pageList, page);
|
page.setRecords(collect);
|
}
|
|
|
@ApiOperation(value = "报警图标数据", notes = "报警图标数据查询")
|
@GetMapping(value = "/fault/chart")
|
public List<DryFaultRecordVo> queryFaultChartData(DryFaultRecord faultRecord, HttpServletRequest req) {
|
int tenantId = oConvertUtils.getInt(TenantContext.getTenant(), 0);
|
//是否开启系统管理模块的多租户数据隔离【SAAS多租户模式】
|
if (MybatisPlusSaasConfig.OPEN_SYSTEM_TENANT_CONTROL) {
|
faultRecord.setTenantId(tenantId);
|
}
|
QueryWrapper<DryFaultRecord> queryWrapper = QueryGenerator.initQueryWrapper(faultRecord, req.getParameterMap());
|
List<DryFaultRecord> faultList = faultRecordService.list(queryWrapper);
|
List<DryFaultRecordVo> result = new ArrayList<>(faultList.stream()
|
.collect(Collectors.groupingBy(DryFaultRecord::getFaultName,
|
Collectors.collectingAndThen(Collectors.toList(), list ->
|
new DryFaultRecordVo(list.get(0), list.size()))))
|
.values())
|
.stream()
|
.sorted(Comparator.comparingInt(DryFaultRecordVo::getECount).reversed())
|
.collect(Collectors.toList());
|
return result;
|
}
|
|
|
//此接口仅用作uniapp下拉返回，无实际意义
|
@GetMapping(value = "/sample/list")
|
public Result<IPage<Object>> querySampleList(DryFaultRecord faultRecord, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, HttpServletRequest req) {
|
Page<Object> page = new Page<Object>(pageNo, pageSize);
|
page.setRecords(Arrays.asList(""));
|
page.setSize(1);
|
page.setCurrent(1);
|
return Result.OK(page);
|
}
|
|
|
private void compEqu(IPage<DryEquipment> pageList, Page<MoEquVo> page) {
|
//当前租户id
|
int tenantId = oConvertUtils.getInt(TenantContext.getTenant(), 0);
|
List<MoEquVo> collect = pageList.getRecords().stream().map(item -> {
|
MoEquVo vo = new MoEquVo();
|
BeanUtils.copyProperties(item, vo);
|
String clientid = "client-" + tenantId + "-" + item.getCode();
|
//JSONObject client = (JSONObject) redisUtil.hget(MqttConstant.MQTT_ONLINE_CLIENT ,tenantId);
|
JSONObject client = (JSONObject) redisUtil.hget(String.format(MqttConstant.MQTT_ONLINE_CLIENT, tenantId), clientid);
|
//组装状态数据
|
if (client != null) {
|
vo.setOnline(true);
|
//连接时间
|
String st = client.getString("connectedAt");
|
vo.setUpTime(st);
|
vo.setClientId(clientid);
|
}
|
return vo;
|
}).collect(Collectors.toList());
|
//排序
|
collect.sort(Comparator.comparing(obj -> obj.getCode(), Comparator.nullsLast(Comparator.naturalOrder())));
|
collect.sort(Comparator.comparing(obj -> obj.getOnline(), Comparator.nullsLast(Comparator.naturalOrder())));
|
BeanUtils.copyProperties(pageList, page);
|
page.setRecords(collect);
|
}
|
|
/**
|
* @param startTimeStr
|
* @param endTimeStr
|
* @return
|
*/
|
private String calculateTimeDifference(String startTimeStr, String endTimeStr) {
|
// 定义时间格式
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
// 将字符串解析为 LocalDateTime 对象
|
LocalDateTime startTime = LocalDateTime.parse(startTimeStr, formatter);
|
LocalDateTime endTime = LocalDateTime.parse(endTimeStr, formatter);
|
// 计算两个时间点之间的持续时间
|
Duration duration = Duration.between(startTime, endTime);
|
// 获取小时、分钟和秒数
|
long hours = duration.toHours();
|
long minutes = duration.toMinutes() % 60;
|
long seconds = duration.getSeconds() % 60;
|
|
StringBuilder result = new StringBuilder();
|
if (hours > 0) {
|
result.append(hours).append("时");
|
}
|
if (minutes > 0) {
|
result.append(minutes).append("分");
|
}
|
if (seconds > 0) {
|
result.append(seconds).append("秒");
|
}
|
|
return result.toString();
|
|
}
|
|
|
}
|
