Jelajahi Sumber

[1011] 增加文件上报数据展示: data_report_log增加domain/mapper/service/controller(MyBatis-Plus, 分页list接口)

taosj 1 Minggu lalu
induk
melakukan
e079b61613

+ 38 - 0
forecast-backend-server/src/main/java/com/ufo/project/forecast/fileupload/controller/DataReportLogController.java

@@ -0,0 +1,38 @@
+package com.ufo.project.forecast.fileupload.controller;
+
+import java.util.List;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import com.ufo.base.framework.web.controller.BaseController;
+import com.ufo.base.framework.web.page.TableDataInfo;
+import com.ufo.project.forecast.fileupload.domain.DataReportLog;
+import com.ufo.project.forecast.fileupload.service.IDataReportLogService;
+
+/**
+ * 功率预测上报日志Controller
+ *
+ * @author ufo
+ * @date 2026-10-21
+ */
+@RestController
+@RequestMapping("/fileupload/reportLog")
+public class DataReportLogController extends BaseController
+{
+    @Autowired
+    private IDataReportLogService dataReportLogService;
+
+    /**
+     * 查询功率预测上报日志列表(分页)
+     */
+    @PreAuthorize("@ss.hasPermi('fileupload:reportLog:list')")
+    @GetMapping("/list")
+    public TableDataInfo list(DataReportLog dataReportLog)
+    {
+        startPage();
+        List<DataReportLog> list = dataReportLogService.selectDataReportLogList(dataReportLog);
+        return getDataTable(list);
+    }
+}

+ 254 - 0
forecast-backend-server/src/main/java/com/ufo/project/forecast/fileupload/domain/DataReportLog.java

@@ -0,0 +1,254 @@
+package com.ufo.project.forecast.fileupload.domain;
+
+import java.util.Date;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+/**
+ * 功率预测上报日志对象 data_report_log
+ *
+ * @author ufo
+ * @date 2026-10-21
+ */
+@TableName("data_report_log")
+public class DataReportLog
+{
+    /** 日志主键ID */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    /** 文件类型:supershort|short|medium */
+    private String type;
+
+    /** 关联预测曲线ID(forecast_curve) */
+    private Long curveId;
+
+    /** 上报发起时间 */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date reportTime;
+
+    /** 目标调度机构:省调/地调名称 */
+    private String targetDispatch;
+
+    /** 上报通道:1=IEC104,2=XML文件,3=FTP,4=MQTT */
+    private Integer channel;
+
+    /** 报文流水号,对外唯一 */
+    private String messageNo;
+
+    /** 报文原文存储路径 */
+    private String contentPath;
+
+    /** 上报状态:0待发送,1上报成功,2上报失败,3超时 */
+    private Integer status;
+
+    /** 调度侧返回报文/反馈信息 */
+    private String responseMsg;
+
+    /** 备注,失败原因描述 */
+    private String remark;
+
+    /** 记录创建时间 */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date createTime;
+
+    /** 记录更新时间 */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date updateTime;
+
+    private String createBy;
+
+    private String updateBy;
+
+    /** 上报时间起(查询用) */
+    @TableField(exist = false)
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date startTime;
+
+    /** 上报时间止(查询用) */
+    @TableField(exist = false)
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date endTime;
+
+    public void setId(Long id)
+    {
+        this.id = id;
+    }
+
+    public Long getId()
+    {
+        return id;
+    }
+    public void setType(String type)
+    {
+        this.type = type;
+    }
+
+    public String getType()
+    {
+        return type;
+    }
+    public void setCurveId(Long curveId)
+    {
+        this.curveId = curveId;
+    }
+
+    public Long getCurveId()
+    {
+        return curveId;
+    }
+    public void setReportTime(Date reportTime)
+    {
+        this.reportTime = reportTime;
+    }
+
+    public Date getReportTime()
+    {
+        return reportTime;
+    }
+    public void setTargetDispatch(String targetDispatch)
+    {
+        this.targetDispatch = targetDispatch;
+    }
+
+    public String getTargetDispatch()
+    {
+        return targetDispatch;
+    }
+    public void setChannel(Integer channel)
+    {
+        this.channel = channel;
+    }
+
+    public Integer getChannel()
+    {
+        return channel;
+    }
+    public void setMessageNo(String messageNo)
+    {
+        this.messageNo = messageNo;
+    }
+
+    public String getMessageNo()
+    {
+        return messageNo;
+    }
+    public void setContentPath(String contentPath)
+    {
+        this.contentPath = contentPath;
+    }
+
+    public String getContentPath()
+    {
+        return contentPath;
+    }
+    public void setStatus(Integer status)
+    {
+        this.status = status;
+    }
+
+    public Integer getStatus()
+    {
+        return status;
+    }
+    public void setResponseMsg(String responseMsg)
+    {
+        this.responseMsg = responseMsg;
+    }
+
+    public String getResponseMsg()
+    {
+        return responseMsg;
+    }
+    public void setRemark(String remark)
+    {
+        this.remark = remark;
+    }
+
+    public String getRemark()
+    {
+        return remark;
+    }
+    public void setCreateTime(Date createTime)
+    {
+        this.createTime = createTime;
+    }
+
+    public Date getCreateTime()
+    {
+        return createTime;
+    }
+    public void setUpdateTime(Date updateTime)
+    {
+        this.updateTime = updateTime;
+    }
+
+    public Date getUpdateTime()
+    {
+        return updateTime;
+    }
+    public void setCreateBy(String createBy)
+    {
+        this.createBy = createBy;
+    }
+
+    public String getCreateBy()
+    {
+        return createBy;
+    }
+    public void setUpdateBy(String updateBy)
+    {
+        this.updateBy = updateBy;
+    }
+
+    public String getUpdateBy()
+    {
+        return updateBy;
+    }
+    public void setStartTime(Date startTime)
+    {
+        this.startTime = startTime;
+    }
+
+    public Date getStartTime()
+    {
+        return startTime;
+    }
+    public void setEndTime(Date endTime)
+    {
+        this.endTime = endTime;
+    }
+
+    public Date getEndTime()
+    {
+        return endTime;
+    }
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
+            .append("id", getId())
+            .append("type", getType())
+            .append("curveId", getCurveId())
+            .append("reportTime", getReportTime())
+            .append("targetDispatch", getTargetDispatch())
+            .append("channel", getChannel())
+            .append("messageNo", getMessageNo())
+            .append("contentPath", getContentPath())
+            .append("status", getStatus())
+            .append("responseMsg", getResponseMsg())
+            .append("remark", getRemark())
+            .append("createTime", getCreateTime())
+            .append("updateTime", getUpdateTime())
+            .append("createBy", getCreateBy())
+            .append("updateBy", getUpdateBy())
+            .append("startTime", getStartTime())
+            .append("endTime", getEndTime())
+            .toString();
+    }
+}

+ 14 - 0
forecast-backend-server/src/main/java/com/ufo/project/forecast/fileupload/mapper/DataReportLogMapper.java

@@ -0,0 +1,14 @@
+package com.ufo.project.forecast.fileupload.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ufo.project.forecast.fileupload.domain.DataReportLog;
+
+/**
+ * 功率预测上报日志Mapper接口(MyBatis-Plus, 无需Mapper XML)
+ *
+ * @author ufo
+ * @date 2026-10-21
+ */
+public interface DataReportLogMapper extends BaseMapper<DataReportLog>
+{
+}

+ 21 - 0
forecast-backend-server/src/main/java/com/ufo/project/forecast/fileupload/service/IDataReportLogService.java

@@ -0,0 +1,21 @@
+package com.ufo.project.forecast.fileupload.service;
+
+import java.util.List;
+import com.ufo.project.forecast.fileupload.domain.DataReportLog;
+
+/**
+ * 功率预测上报日志Service接口
+ *
+ * @author ufo
+ * @date 2026-10-21
+ */
+public interface IDataReportLogService
+{
+    /**
+     * 查询功率预测上报日志列表
+     *
+     * @param dataReportLog 功率预测上报日志(查询条件)
+     * @return 功率预测上报日志集合
+     */
+    public List<DataReportLog> selectDataReportLogList(DataReportLog dataReportLog);
+}

+ 46 - 0
forecast-backend-server/src/main/java/com/ufo/project/forecast/fileupload/service/impl/DataReportLogServiceImpl.java

@@ -0,0 +1,46 @@
+package com.ufo.project.forecast.fileupload.service.impl;
+
+import java.util.List;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.ufo.base.common.utils.StringUtils;
+import com.ufo.project.forecast.fileupload.domain.DataReportLog;
+import com.ufo.project.forecast.fileupload.mapper.DataReportLogMapper;
+import com.ufo.project.forecast.fileupload.service.IDataReportLogService;
+
+/**
+ * 功率预测上报日志Service业务层处理
+ *
+ * @author ufo
+ * @date 2026-10-21
+ */
+@Service
+public class DataReportLogServiceImpl implements IDataReportLogService
+{
+    @Autowired
+    private DataReportLogMapper dataReportLogMapper;
+
+    /**
+     * 查询功率预测上报日志列表
+     *
+     * @param dataReportLog 功率预测上报日志(查询条件)
+     * @return 功率预测上报日志集合
+     */
+    @Override
+    public List<DataReportLog> selectDataReportLogList(DataReportLog dataReportLog)
+    {
+        LambdaQueryWrapper<DataReportLog> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(StringUtils.isNotEmpty(dataReportLog.getType()), DataReportLog::getType, dataReportLog.getType())
+                .eq(dataReportLog.getCurveId() != null, DataReportLog::getCurveId, dataReportLog.getCurveId())
+                .like(StringUtils.isNotEmpty(dataReportLog.getTargetDispatch()), DataReportLog::getTargetDispatch, dataReportLog.getTargetDispatch())
+                .eq(StringUtils.isNotEmpty(dataReportLog.getMessageNo()), DataReportLog::getMessageNo, dataReportLog.getMessageNo())
+                .eq(dataReportLog.getChannel() != null, DataReportLog::getChannel, dataReportLog.getChannel())
+                .eq(dataReportLog.getStatus() != null, DataReportLog::getStatus, dataReportLog.getStatus())
+                .ge(dataReportLog.getStartTime() != null, DataReportLog::getReportTime, dataReportLog.getStartTime())
+                .le(dataReportLog.getEndTime() != null, DataReportLog::getReportTime, dataReportLog.getEndTime())
+                .orderByDesc(DataReportLog::getReportTime)
+                .orderByDesc(DataReportLog::getId);
+        return dataReportLogMapper.selectList(wrapper);
+    }
+}