package org.springblade.onenetstudio.tm;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.onenet.studio.acc.sdk.OpenApi;
import com.onenet.studio.acc.sdk.OpenApiExtention;
import com.onenet.studio.acc.sdk.dto.GeoLocationStructDTO;
import org.springblade.onenetstudio.entity.Equipments;
import org.springblade.onenetstudio.service.EquipmentService;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 设备属性数据交互
 */
@Component
public class PropertyPost {

    @Resource
	private EquipmentService equipmentService;

	@Value("${sdk.api.url}")
	private String url;

    @PostConstruct
    public void init() {
		//查询设备
		List<Equipments> equipmentsList = equipmentService.selRegisterEqList();
		//有数据则创建openApi对象
		if (equipmentsList.size()>0){
			for (Equipments equipments:equipmentsList) {
				try {
					OpenApi openApi = OpenApi.Builder.newBuilder()
						.url(url)
						.productId(equipments.getProId())
						.devKey(equipments.getEqName())
						.accessKey(equipments.getEqSecret())
	//                .caCrtFile(caCrtFile)
						.build();
					System.out.println("openApi = " + openApi);
					OpenApiExtention extention = new OpenApiExtention(openApi);
					//属性上报
					propertyUp(extention,equipments);
					//属性设置
					//        propertySet(extention);
					//属性获取
					//        peropertyGet(extention);
					//期望值获取
					//        desiredGet(extention);
					//期望值删除
					//        desiredDel(extention);
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}
    }

    /**
     * 属性上报
     *
     * @author wjl
     * @date 2020/12/29
     * @param extention 物模型扩展API
     **/
    public void propertyUp(OpenApiExtention extention,Equipments equipments) {
    	//设置坐标数据
        GeoLocationStructDTO geoLocationStructDTO = new GeoLocationStructDTO();
        geoLocationStructDTO.setAltitude(100.00);
		geoLocationStructDTO.setLatitude(Double.parseDouble(String.format("%.2f", Double.parseDouble(equipments.getWd()))));
        geoLocationStructDTO.setLongitude(Double.parseDouble(String.format("%.2f", Double.parseDouble(equipments.getJd()))));
        geoLocationStructDTO.setCoordinateSystem(1);
        try {
        	//设备数据上报
            int result = extention.propertyUpload(5000,
												0,
												100,
												geoLocationStructDTO,
												equipments.getDeviceName(),
												equipments.getNetType(),
												equipments.getSerialNumber(),
												equipments.getEqModel());
            //result 0 即为上报成功   1：失败
            System.out.println("up result : " + result);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 属性设置
     *
     * @author wjl
     * @date 2020/12/29
     * @param extention 物模型扩展API
     **/
    public void propertySet(OpenApiExtention extention) {
//        try {
//            extention.propertySet(oneJson -> {
//                System.out.println("receive oneJson : " + oneJson);
//                JSONObject json = JSON.parseObject(oneJson);
//                try {
//                    extention.propertySetReply(json.getString("id"), 200, "success");
//                } catch (Exception e) {
//                    e.printStackTrace();
//                }
//            });
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
    }

    /**
     * 属性获取
     *
     * @author wjl
     * @date 2020/12/29
     * @param extention 物模型扩展API
     **/
    public void peropertyGet(OpenApiExtention extention) {
        try {
            extention.propertyGet(oneJson -> {
                System.out.println("receive oneJson : " + oneJson);
                JSONObject json = JSON.parseObject(oneJson);
                try {
                    // 返回的属性与收到的属性要对应上，否则不成功
                    Map<String, Object> map = new HashMap<>();
                    map.put("DeviceStatus", 1);
                    extention.propertyGetReply(json.getString("id"), 200, "success", map);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            });
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 期望值获取
     *
     * @author wjl
     * @date 2020/12/29
     * @param extention 物模型扩展API
     **/
    public void desiredGet(OpenApiExtention extention) {
        List<String> list = new ArrayList<>();
        list.add("DeviceStatus");

        try {
            JSONObject get = extention.propertyDesiredGet(list.toArray(new String[list.size()]), 5000);
            System.out.println("desired get oneJson : " + get.toJSONString());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 期望值删除
     *
     * @author wjl
     * @date 2020/12/29
     * @param extention 物模型扩展API
     * @return void
     **/
    public void desiredDel(OpenApiExtention extention) {
        Map<String, Integer> map = new HashMap<>();
        map.put("DeviceStatus", 1);
        try {
            int result = extention.propertyDesiredDel(5000, map);
            System.out.println("desired del result : " + result);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}