package com.fdkankan.redis.util;

import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.fdkankan.project.tieta.httpclient.HttpClient;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

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

@Component
public class RedisClient {

    public final static String url_str_add = "/redis/string/add/";

    public final static String url_str_get = "/redis/string/get/";

    public final static String url_str_del = "/redis/string/delete";

    @Value("${redis.host}")
    private String host;

    @Value("${tieta.sysCode}")
    private String sysCode;

    @Value("${tieta.serverName}")
    private String serverName;

    @Resource
    private HttpClient httpClient;


     public void add(String key, String value){
         String url = host + url_str_add;
         Map<String, Object> params = new HashMap<>();
         params.put("key", this.genKey(key));
         params.put("value", value);
         JSONObject jsonObject = httpClient.postJson(url, params);
         if(Objects.isNull(jsonObject) || !"0".equals(jsonObject.getString("status"))){
             throw new RuntimeException("redis add string error");
         }
     }

    public String get(String key){
        String url = host + url_str_get;
        Map<String, Object> params = new HashMap<>();
        params.put("key", this.genKey(key));
        JSONObject jsonObject = httpClient.postJson(url, params);
        if(Objects.isNull(jsonObject) || !"0".equals(jsonObject.getString("status"))){
            throw new RuntimeException("redis get string error");
        }
        return jsonObject.getString("data");
    }

    public String del(String key){
        String url = host + url_str_del;
        Map<String, Object> params = new HashMap<>();
        params.put("key", this.genKey(key));
        JSONObject jsonObject = httpClient.postJson(url, params);
        if(Objects.isNull(jsonObject) || !"0".equals(jsonObject.getString("status"))){
            throw new RuntimeException("redis del string error");
        }
        return jsonObject.getString("data");
    }

    private String genKey(String key){
         return sysCode + "_" + serverName + "_" + key;
    }
}