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