package project.monitor.noderpc.internal;

import java.util.HashMap;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;

import project.monitor.noderpc.NodeRpcActionEnum;
import project.monitor.noderpc.NodeRpcService;
import project.monitor.noderpc.NodeRpcVerificationEndecrypt;
import project.monitor.noderpc.http.HttpHelper;
import project.monitor.noderpc.http.HttpMethodType;
import project.syspara.SysparaService;

public class NodeRpcServiceImpl implements NodeRpcService {

	private static final Logger logger = LoggerFactory.getLogger(NodeRpcServiceImpl.class);
	
	private SysparaService sysparaService;
	
	private String encryptKey = "addddd";

	private String url;

	private boolean initia = false;

	public void init() {
		this.url = sysparaService.find("rpc_node_url").getValue();
		initia = true;
	}

	public JSONObject send(NodeRpcActionEnum action, String[] values) {
		if (!initia) {
			init();
		}

		String url = this.url + action.getUrl();
		try {
			Map<String, Object> paramSend = new HashMap<String, Object>();
			paramSend.put(action.getParamName(), encryptParam(values));
			String result = HttpHelper.getJSONFromHttp(url, paramSend, HttpMethodType.GET);
			JSONObject resultJson = JSON.parseObject(result);

			return resultJson;

		} catch (Exception e) {
			logger.error("NodeRpcServiceImpl send error", e);
			e.printStackTrace();
		}
		return null;
	}

	public String encryptParam(String[] values) throws Exception {
		String value = String.join("&", values);
		return NodeRpcVerificationEndecrypt.encryptDES(value, encryptKey);
	}

	public void setSysparaService(SysparaService sysparaService) {
		this.sysparaService = sysparaService;
	}

}