package com.ld.igds.protocol.weight;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.inout.dto.ApiInoutData;
import com.ld.igds.util.HttpUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.time.DateFormatUtils;

import java.util.concurrent.Callable;


/**
 * 子任务，用于远程调用称重网关，且不影响正常业务逻辑
 */
@Slf4j
public class WeightGatewayRemoteTask implements Callable<String> {

    private ApiInoutData param;

    private String[] actionCodes;


    public ApiInoutData getParam() {
        return param;
    }

    public void setParam(ApiInoutData param) {
        this.param = param;
    }

    public String[] getActionCode() {
        return actionCodes;
    }

    public void setActionCode(String[] actionCode) {
        this.actionCodes = actionCodes;
    }

    public WeightGatewayRemoteTask() {
    }

    public WeightGatewayRemoteTask(ApiInoutData param, String[] actionCodes) {
        this.param = param;
        this.actionCodes = actionCodes;
    }

    @Override
    public String call() throws Exception {


        String url;
        JSONObject json;

        for (String actionCode : actionCodes) {

            url = "http://" + param.getIp() + ":" + param.getPort();
            json = new JSONObject();
            if (WeightUtil.ACTION_CODE_10.equals(actionCode)) {
                url += "/white-plate";
                json.put("actionCode", WeightUtil.ACTION_CODE_10);
                json.put("plateNum", param.getPlateNum());
                json.put("time", DateFormatUtils.format(param.getTime(), "yyyyMMddHHmmss"));
            }

            if (WeightUtil.ACTION_CODE_11.equals(actionCode)) {
                url += "/white-plate";
                json.put("actionCode", WeightUtil.ACTION_CODE_11);
                json.put("plateNum", param.getPlateNum());
                json.put("time", DateFormatUtils.format(param.getTime(), "yyyyMMddHHmmss"));

            }

            if (WeightUtil.ACTION_CODE_30.equals(actionCode)) {
                url += "/radio";
                json.put("actionCode", WeightUtil.ACTION_CODE_30);
                json.put("content", param.getMsg());
                json.put("repeat", param.getRepeat());
                json.put("time", DateFormatUtils.format(param.getTime(), "yyyyMMddHHmmss"));
            }

            if (WeightUtil.ACTION_CODE_60.equals(actionCode)) {
                url += "/progress";
                json.put("actionCode", WeightUtil.ACTION_CODE_60);
                json.put("progress", "30");
                json.put("time", DateFormatUtils.format(param.getTime(), "yyyyMMddHHmmss"));
            }

            log.debug("----调用地磅控制器-----{}-{}", url, json.toString());

            HttpUtils.doPostJson(url, json.toJSONString());

            Thread.sleep(1000);
        }

        return "SUCCESS";
    }

}