修改解析MQTT水肥机协议主题的bug

liurunyu

2025-06-20 735cb44142daa455c0fd3d968e66e264205e5c0d

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voSpecial/VoSteal.java

New file
@@ -0,0 +1,140 @@
package com.dy.pipIrrGlobal.voSpecial;

import com.alibaba.fastjson2.annotation.JSONField;
import com.alibaba.fastjson2.writer.ObjectWriterImplToString;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;
import lombok.Data;

import java.util.Date;

/**
 * @Author: liurunyu
 * @Date: 2025/2/7 14:11
 * @Description
 */

@Data
@JsonPropertyOrder({"id",
        "intakeId",
        "clientId",
        "intakeNum",
        "intakeLng",
        "intakeLat",
        "clientName",
        "clientNum",
        "openDt",
        "openType",
        "openTotalAmount",
        "openRemainMoney",
        "closeDt",
        "closeType",
        "closeTotalAmount",
        "closeRemainMoney",
        "thisAmount",
        "thisMoney",
        "thisTime"
})
public class VoSteal {
    private static final long serialVersionUID = 202502071422001L;
    /**
     * 数据记录id(开关阀记录)
     */
    @JSONField(serializeUsing= ObjectWriterImplToString.class)
    public Long id ;

    /**
     * 取水口ID
     */
    @JSONField(serializeUsing= ObjectWriterImplToString.class)
    public Long intakeId;

    /**
     * 农户ID
     */
    @JSONField(serializeUsing= ObjectWriterImplToString.class)
    public Long clientId;
    /**
     * 取水口编号
     */
    public String intakeNum;
    /**
     * 取水口经度
     */
    public Double intakeLng;
    /**
     * 取水口纬度
     */
    public Double intakeLat;

    /**
     * 农户姓名
     */
    public String clientName;

    /**
     * 农户编号
     */
    public String clientNum;

    /**
     * 开阀时间
     */
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    public Date openDt;
    /**
     * 开阀类型
     */
    @JSONField(serialize = false)
    public Byte opType;
    /**
     * 开阀类型
     */
    public String openType;
    /**
     * 开阀时累计流量（m3）
     */
    public Double openTotalAmount;
    /**
     * 开阀时剩余金额（元）
     */
    public Double openRemainMoney;


    /**
     * 关阀时间
     */
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    public Date closeDt;
    /**
     * 关阀类型
     */
    @JSONField(serialize = false)
    public Byte clType;
    /**
     * 关阀类型
     */
    public String closeType;
    /**
     * 关阀时累计流量（m3）
     */
    public Double closeTotalAmount;
    /**
     * 关阀时剩余金额（元）
     */
    public Double closeRemainMoney;

    /**
     * 本次用水量（m3）
     */
    public Double thisAmount;
    /**
     * 本次金额（元）
     */
    public Double thisMoney;
    /**
     * 本次时长（分钟）
     */
    public Integer thisTime;

}