package com.tievd.jyz.mqtt;

import com.tievd.jyz.cache.CameraFactoryCache;
import com.tievd.jyz.constants.SystemConstant;
import com.tievd.jyz.entity.Camera;
import com.tievd.jyz.entity.Device;
import com.tievd.jyz.entity.OilPosition;
import com.tievd.jyz.mqtt.dto.CameraDTO;
import com.tievd.jyz.mqtt.dto.InitConfigDTO;
import com.tievd.jyz.mqtt.dto.OilPositionDTO;
import com.tievd.jyz.mqtt.dto.RegisterDTO;
import com.tievd.jyz.util.BeanUtil;
import com.tievd.jyz.util.S3Util;
import org.apache.commons.lang3.StringUtils;

import java.sql.Timestamp;
import java.util.Date;

/**
 * 传输数据对象转换器
 * @author timi
 */
public class PojoDataConverter {

    /**
     * 网关状态转换
     * @param deviceSN
     * @param registerDTO
     * @return
     */
    public static Device deviceConvert(String deviceSN,RegisterDTO registerDTO){
        Device device = new Device();
        device.setDeviceIp(registerDTO.getIp());
        device.setHeartTime(new Date());
        device.setSn(deviceSN);
        device.setStatus(SystemConstant.DEVICE_ONLINE);
        device.setPort(Integer.parseInt(registerDTO.getPort()));
        device.setDeviceVersion(registerDTO.getVersion());
        return device;
    }

    /**
     * 初始化配置转换
     * @param s3Util
     * @param heartbeatTime
     * @return
     */
    public static InitConfigDTO InitConfigConvert(S3Util s3Util,Integer heartbeatTime){
        InitConfigDTO initConfigDTO = new InitConfigDTO();
        initConfigDTO.setS3(s3Util.deviceServiceEndpoint,s3Util.accessKey,s3Util.secretKey,s3Util.bucketName);
        initConfigDTO.setHeartbeat(String.valueOf(heartbeatTime));
        return initConfigDTO;
    }

    /**
     * 终端转换
     * @param camera
     * @return
     */
    public static CameraDTO cameraDTOConvert(Camera camera){
        CameraDTO cameraDTO = new CameraDTO();
        BeanUtil.copyPropertiesIgnoreNull(camera,cameraDTO);
        cameraDTO.setIp(camera.getIpAddress());
        cameraDTO.setRtsp(camera.getStreamAddress());
        cameraDTO.setUsername(camera.getUserName());
        return cameraDTO;
    }

    /**
     * 终端转换
     * @param cameraDTO
     * @return
     */
    public static Camera cameraConvert(CameraDTO cameraDTO){
        Camera camera = new Camera();
        BeanUtil.copyPropertiesIgnoreNull(cameraDTO,camera);
        camera.setIpAddress(cameraDTO.getIp());
        camera.setStreamAddress(cameraDTO.getRtsp());
        camera.setUserName(cameraDTO.getUsername());
        try {
            String factoryId = CameraFactoryCache.getFactoryId(cameraDTO.getFactory());
            if(StringUtils.isNotEmpty(factoryId)){
                camera.setFactory(Byte.valueOf(factoryId));
            }
        }catch (Exception ex){
            ex.printStackTrace();
        }
        camera.setUpdateTime(new Date(Long.parseLong(cameraDTO.getUpdateTime())));
        return camera;
    }

    /**
     * 加油位数据转换
     * @param oilPosition
     * @return
     */
    public static OilPositionDTO oilPositionDTOConvert(OilPosition oilPosition){
        OilPositionDTO oilPositionDTO = new OilPositionDTO();
        oilPositionDTO.setCode(oilPosition.getPositionCode());
        oilPositionDTO.setName(oilPosition.getOilPosition());
        oilPositionDTO.setUpdateTime(String.valueOf(oilPosition.getCreateTime().getTime()));
        return oilPositionDTO;
    }

    /**
     * 加油位数据转换
     * @param oilPositionDTO
     * @return
     */
    public static OilPosition oilPositionConvert(OilPositionDTO oilPositionDTO){
        OilPosition oilPosition = new OilPosition();
        oilPosition.setPositionCode(oilPositionDTO.getCode());
        oilPosition.setOilPosition(oilPositionDTO.getName());
        oilPosition.setCreateTime(new Timestamp(Long.parseLong(oilPositionDTO.getUpdateTime())));
        return oilPosition;
    }

}