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

import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateUtil;
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.gq.dto.GqDto;

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

/**
 * @program: newfiber-data-adapter
 * @description: 泵站dto
 * @author: djt
 * @create: 2022-01-19 09:30
 **/
@Data
public class BzDto {
    //站码
    private String STCD;
    //站名
    private String STNM;
    //前池水位
    private String PPUPZ;
    // 起排水位
    private Float WRZ;
    // 控制水位
    private String FRZ;
    // 最新监测时间啊  YYYY-MM-DD HH:mm:ss     List的是 不规则的
    private String TM;
    // 纬度
    private Float LGTD;
    // 纬度
    private Float LTTD;
    // 设计流量
    private Float SLL;

    public static PtReceiveBaseModel convert(BzDto dto){
        PtReceiveBaseModel model=new PtReceiveBaseModel();
        model.setSt(dto.getSTCD());
        model.setTt(DateUtil.parse(dto.getTM(), DatePattern.NORM_DATETIME_PATTERN));
        model.setUt(new Date());
        model.setSn("");
        Map<String, MqNodeData> dataMap= Maps.newHashMap();
        MqNodeData data=new MqNodeData();
        data.setKey("z");
        data.setValue(dto.getPPUPZ());
        data.setSn("ppupz");
        dataMap.put("z",data);
        model.setDataMap(dataMap);
        return model;
    }
}