package com.fzzy.protocol.weightyh;

import com.alibaba.fastjson2.JSONObject;
import com.fzzy.api.data.GatewayDeviceProtocol;
import com.fzzy.gateway.api.GatewayRemoteManager;
import com.fzzy.gateway.api.GatewaySyncWeightService;
import com.fzzy.gateway.data.BaseReqData;
import com.fzzy.gateway.data.BaseResp;
import com.fzzy.gateway.entity.GatewayDevice;
import com.fzzy.gateway.util.GatewayHttpUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.HashMap;
import java.util.Map;

/**
 * HTTP方式获取地磅信息
 * <p>
 * 注：当前协议包含JSON和JSONP两种支持，自动识别
 */
@Slf4j
@Component
public class GatewaySyncWeightImplHttp implements GatewaySyncWeightService {


    @Resource
    private GatewayRemoteManager gatewayRemoteManager;

    @Override
    public String getWeightProtocol() {
        return GatewayDeviceProtocol.DEVICE_WEIGHT_HTTP.getCode();
    }

    @Override
    public BaseResp syncWeightInfo(BaseReqData reqData) {
        GatewayDevice device = reqData.getDevice();

        if (null == device) return new BaseResp(500, "没有获取到设备信息");

        if (StringUtils.isEmpty(device.getHttpUrl())) new BaseResp(500, "没有配置HTTP请求地址");
        try {

            Map<String, String> paramsMap = new HashMap<>();
            paramsMap.put("time_", System.currentTimeMillis() + "");

            String responseText = GatewayHttpUtil.doGet(device.getHttpUrl(), paramsMap);

            log.debug("--HTTP-WEIGHT-请求返回--{}", responseText);

            String respJson;
            JSONObject resp;
            //说明是JSONP格式-jsonpCallback({"content":""})
            if (responseText.indexOf("jsonpCallback") >= 0) {
                respJson = responseText.substring(responseText.indexOf("(") + 1, responseText.length() - 1);
                resp = JSONObject.parseObject(respJson);
                resp.put("code", 200);
            } else {
                respJson = responseText;
                resp = JSONObject.parseObject(respJson);
            }

            if (200 == (Integer) resp.get("code")) {
                if (null == resp.get("content") || "".equals(resp.get("content"))) {
                    reqData.setWeight(0.0);
                } else {
                    reqData.setWeight((Double) resp.get("content"));
                }
            }

            //执行推送
            if (reqData.getWeight() > 0) {
                gatewayRemoteManager.getDeviceReportService(device.getPushProtocol()).reportWeightData(reqData);
            }
        } catch (Exception e) {
            log.error("--------------地磅-HTTP协议执行异常----{}", e.getMessage());
        }
        return new BaseResp(500, "后台执行失败");
    }
}