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; } }