package org.springnewfiber.dataadapter.ziguang.hd.dto;

import com.google.common.collect.Maps;
import lombok.Data;
import org.springnewfiber.dataadapter.entity.MqNodeData;
import org.springnewfiber.dataadapter.entity.PtReceiveBaseModel;

import java.util.Date;
import java.util.Map;

/**
 * @program: newfiber-data-adapter
 * @description:  河道dto
 * @author: djt
 * @create: 2022-01-19 09:14
 **/
@Data
public class HdDto {
    //站码
    private String STCD;
    //站名
    private String STNM;
    //FRZ 设防水位
    private Float FRZ;
    // 保证水位
    private Float GRZ;
    // 警戒水位
    private Float WRZ;
    // 最新监测时间啊  YYYY-MM-DD HH:mm:ss
    private Date TM;
    // 纬度
    private Float LGTD;
    // 纬度
    private Float LTTD;
    // 新监测水位值
    private Float Z;
    //流量
    private Float Q;
    //类型 zz
    private String STTP;
    //未知
    private String WPTN;
    //所属河流
    private String RVNM;

    public static PtReceiveBaseModel convert(HdDto dto){
        PtReceiveBaseModel model=new PtReceiveBaseModel();
        model.setSt(dto.getSTCD());
        model.setTt(dto.getTM());
        model.setUt(new Date());
        model.setSn("");
        MqNodeData data= new MqNodeData();
        data.setKey("z");
        data.setValue(dto.getZ());
        data.setSn("z");
        Map<String, MqNodeData> dataMap= Maps.newHashMap();
        dataMap.put("z",data);
        if(dto.getQ()!=null){
            MqNodeData q= new MqNodeData();
            q.setKey("q");
            q.setValue(dto.getQ());
            q.setSn("q");
            dataMap.put("q",q);
        }
        model.setDataMap(dataMap);
        return model;
    }
}