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

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

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

/**
 * @program: newfiber-data-adapter
 * @description: 港渠dto
 * @author: djt
 * @create: 2022-01-19 09:24
 **/
@Data
public class GqDto {
    //站码
    private String STCD;
    //站名
    private String STNM;
    //行政区划
    private String DSNM;
    // 设计洪水位
    private Float GULE;
    // 类型  自建/对接
    private String BZ;
    // 最新监测时间啊  YYYY-MM-DD HH:mm:ss
    private Date TM;
    // 纬度
    private Float LGTD;
    // 纬度
    private Float LTTD;
    // 最新水位
    private Float Z;
    //类型
    private String STTP;

    public static PtReceiveBaseModel convert(GqDto 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);
        model.setDataMap(dataMap);
        return model;
    }
}