KH/kh-device-admin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 油井实时数据相关接口

Browse Source
This commit is contained in:
mzaxd
2024-04-07 10:33:52 +08:00
parent 3a827266de
commit e1340f1732
6 changed files with 265 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kh-modules/src/main/java/com/jero/modules/controller/KhOilRealtimeDataController.java
+66
View File
@@ -0,0 +1,66 @@
package com.jero.modules.controller;
import java.util.Map;
import com.jero.common.api.vo.Results;
import com.jero.modules.entity.KhOilRealtimeData;
import com.jero.modules.service.IKhOilRealtimeDataService;
import lombok.extern.slf4j.Slf4j;
import com.jero.common.system.base.controller.JeroController;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import com.jero.common.aspect.annotation.AutoLog;
/**
* @Description: 油井实时数据
* @Author: jero-boot
* @Date: 2024-04-02
* @Version: V1.0
*/
@Api(tags = "油井实时数据")
@RestController
@RequestMapping("/khOilRealtimeData")
@Slf4j
public class KhOilRealtimeDataController extends JeroController<KhOilRealtimeData, IKhOilRealtimeDataService> {
@Autowired
private IKhOilRealtimeDataService khOilRealtimeDataService;
/**
* 通过id查询
*
* @param id
* @return
*/
@AutoLog(value = "油井实时数据-通过id查询")
@ApiOperation(value = "油井实时数据-通过id查询", notes = "油井实时数据-通过id查询")
@GetMapping(value = "/queryById")
public Results<KhOilRealtimeData> queryById(@RequestParam(name = "id", required = true) String id) {
KhOilRealtimeData khOilRealtimeData = khOilRealtimeDataService.queryById(id);
if (khOilRealtimeData == null) {
return Results.error("未找到对应数据");
}
return Results.OK(khOilRealtimeData);
}
/**
* 返回动态数据
*
* @param id
* @return
*/
@AutoLog(value = "油井实时数据-返回动态数据")
@ApiOperation(value = "油井实时数据-返回动态数据", notes = "油井实时数据-返回动态数据")
@GetMapping(value = "/realtimeDataResults")
public Results<Map<String, Object>> realtimeDataResults(@RequestParam(name = "id", required = true) String id) {
if (!id.equals("default")) {
return Results.error("未找到对应数据");
}
Map<String, Object> khOilRealtimeData = khOilRealtimeDataService.realtimeDataResults(id);
return Results.OK(khOilRealtimeData);
}
}
kh-modules/src/main/java/com/jero/modules/entity/KhOilRealTimeData.java → kh-modules/src/main/java/com/jero/modules/entity/KhOilRealtimeData.java
+35 -2
View File
@@ -3,13 +3,16 @@ package com.jero.modules.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import org.springframework.format.annotation.DateTimeFormat;
import java.io.Serializable;
import java.util.Date;
/**
* @author: Mzaxd
@@ -17,11 +20,11 @@ import java.io.Serializable;
*/
@Data
@TableName("kh_oil_realTime_data")
@TableName("kh_oil_realtime_data")
@Accessors(chain = true)
@EqualsAndHashCode(callSuper = false)
@ApiModel(value="kh_oil_realTime_data对象", description="油井实时数据")
public class KhOilRealTimeData implements Serializable {
public class KhOilRealtimeData implements Serializable {
private static final long serialVersionUID = 1L;
/**
@@ -31,6 +34,30 @@ public class KhOilRealTimeData implements Serializable {
@ApiModelProperty(value = "id")
private String id;
/**创建人*/
@ApiModelProperty(value = "创建人")
private String createBy;
/**创建日期*/
@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
@ApiModelProperty(value = "创建日期")
private Date createTime;
/**更新人*/
@ApiModelProperty(value = "更新人")
private String updateBy;
/**更新日期*/
@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
@ApiModelProperty(value = "更新日期")
private Date updateTime;
/**所属部门*/
@ApiModelProperty(value = "所属部门")
private String sysOrgCode;
/**
* 油压
*/
@@ -127,4 +154,10 @@ public class KhOilRealTimeData implements Serializable {
@ApiModelProperty(value = "冲次")
private int strokeCount;
/**
* 设备唯一标识
*/
@ApiModelProperty(value = "设备唯一标识")
private int deviceId;
}
kh-modules/src/main/java/com/jero/modules/mapper/KhOilRealtimeDataMapper.java
+15
View File
@@ -0,0 +1,15 @@
package com.jero.modules.mapper;
import com.jero.modules.entity.KhOilRealtimeData;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
/**
* @Description: 油井实时数据
* @Author: jero-boot
* @Date: 2024-04-02
* @Version: V1.0
*/
public interface KhOilRealtimeDataMapper extends BaseMapper<KhOilRealtimeData> {
}
kh-modules/src/main/java/com/jero/modules/mapper/xml/KhOilRealtimeDataMapper.xml
+29
View File
@@ -0,0 +1,29 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.jero.modules.mapper.KhOilRealtimeDataMapper">
<resultMap id="KhOilRealtimeDataResultMap" type="com.jero.modules.entity.KhOilRealtimeData">
<id column="id" property="id" />
<result column="create_by" property="createBy" />
<result column="create_time" property="createTime" />
<result column="update_by" property="updateBy" />
<result column="update_time" property="updateTime" />
<result column="sys_org_code" property="sysOrgCode" />
<result column="oil_pressure" property="oilPressure" />
<result column="current_a" property="currentA" />
<result column="current_b" property="currentB" />
<result column="current_c" property="currentC" />
<result column="active_power" property="activePower" />
<result column="power_factor" property="powerFactor" />
<result column="max_load" property="maxLoad" />
<result column="stroke" property="stroke" />
<result column="casing_pressure" property="casingPressure" />
<result column="voltage_a" property="voltageA" />
<result column="voltage_b" property="voltageB" />
<result column="voltage_c" property="voltageC" />
<result column="reactive_power" property="reactivePower" />
<result column="output_frequency" property="outputFrequency" />
<result column="min_load" property="minLoad" />
<result column="stroke_count" property="strokeCount" />
<result column="sync_date" property="syncDate" />
</resultMap>
</mapper>
kh-modules/src/main/java/com/jero/modules/service/IKhOilRealtimeDataService.java
+48
View File
@@ -0,0 +1,48 @@
package com.jero.modules.service;
import com.jero.modules.entity.KhOilRealtimeData;
import com.baomidou.mybatisplus.extension.service.IService;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
import java.util.Map;
/**
* @Description: 油井实时数据
* @Author: jero-boot
* @Date: 2024-04-02
* @Version: V1.0
*/
public interface IKhOilRealtimeDataService extends IService<KhOilRealtimeData> {
/**
* 列表查询
*
* @param khOilRealtimeData
* @param req
* @return
*/
List<KhOilRealtimeData> queryList(KhOilRealtimeData khOilRealtimeData, HttpServletRequest req);
/**
* 保存
*
* @param khOilRealtimeData
* @return
*/
void add(KhOilRealtimeData khOilRealtimeData);
/**
* 通过id查询
*
* @param id
* @return
*/
KhOilRealtimeData queryById(String id);
/**
* 实时数据
* @param id
* @return
*/
Map<String, Object> realtimeDataResults(String id);
}
kh-modules/src/main/java/com/jero/modules/service/impl/KhOilRealtimeDataServiceImpl.java
+72
View File
@@ -0,0 +1,72 @@
package com.jero.modules.service.impl;
import com.jero.modules.entity.KhOilRealtimeData;
import com.jero.modules.mapper.KhOilRealtimeDataMapper;
import com.jero.modules.service.IKhOilRealtimeDataService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.jero.common.exception.JeroBootException;
import java.util.List;
import java.util.Date;
import java.util.Map;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.jero.common.system.query.QueryGenerator;
import javax.servlet.http.HttpServletRequest;
/**
* @Description: 油井实时数据
* @Author: jero-boot
* @Date: 2024-04-02
* @Version: V1.0
*/
@Service
@Transactional(rollbackFor = JeroBootException.class)
public class KhOilRealtimeDataServiceImpl extends ServiceImpl<KhOilRealtimeDataMapper, KhOilRealtimeData> implements IKhOilRealtimeDataService {
/**
* 列表查询
*
* @param khOilRealtimeData
* @param req
* @return
*/
@Override
public List<KhOilRealtimeData> queryList(KhOilRealtimeData khOilRealtimeData, HttpServletRequest req) {
return list(QueryGenerator.initQueryWrapper(khOilRealtimeData, req.getParameterMap()));
}
/**
* 保存
*
* @param khOilRealtimeData
* @return
*/
@Override
public void add(KhOilRealtimeData khOilRealtimeData) {
Date now = new Date();
khOilRealtimeData.setCreateTime(now);
khOilRealtimeData.setUpdateTime(now);
save(khOilRealtimeData);
}
/**
* 通过id查询
*
* @param id
* @return
*/
@Override
public KhOilRealtimeData queryById(String id) {
return getById(id);
}
@Override
public Map<String, Object> realtimeDataResults(String id) {
KhOilRealtimeData khOilRealtimeData = new KhOilRealtimeData();
return null;
}
}