package com.highdatas.mdm.util;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.highdatas.mdm.pojo.ActivitiBusinessType;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.http.*;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.http.converter.StringHttpMessageConverter;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import org.springframework.web.client.RestTemplate;

import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;

@ConfigurationProperties(prefix = "todo")
@Component
public class TodoClient {

    @Value("${todo.url}")
    String url;

    String prefix ;

    private TodoClient() {
        this.prefix = "/api/datacvg/activiti/";
    }
    public  boolean putRedisVal(String key, String value) {
        String url = this.url + prefix + "put";
        Map<String, String> params = new LinkedHashMap<>();
        params.put("key",key);
        params.put("value",value);
        params.put("type",Constant.MainData);
        String s = HttpUtils.HttpRestClient(url, HttpMethod.POST, params);
        JSONObject result = (JSONObject) JSON.parse(s);
        String sucess = result.getString(Constant.Success);
        if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
            return false;
        }else {
            return true;
        }
    }

    public boolean open(String key, String businessId,String content, String userId, ActivitiBusinessType type) {
            String url =  this.url + prefix + "open";
        ArrayList<HashMap<String, String>> hashMaps = new ArrayList<>();
        HashMap<String, String> oneAct = new HashMap<>();
        oneAct.put("approvalId", businessId);
        oneAct.put("approvalItem", content);
        hashMaps.add(oneAct);
        HashMap<String, Object> params = new LinkedHashMap<>();
            params.put("functionName","MasActivitiServiceImpl");
            params.put("approvalType","MAS");
            params.put("businessId",businessId);
            params.put("expectValue","nobody");
            params.put("userId",userId);
            params.put("businessType", type);
            params.put("approvalList", hashMaps);

        String json = HttpRestClient(url, HttpMethod.POST, params, null, MediaType.APPLICATION_JSON);
        JSONObject result = (JSONObject) JSON.parse(json);
            String sucess = result.getString(Constant.Success);
            if (StringUtils.isEmpty(sucess) || !Boolean.valueOf(sucess)) {
                return false;
            }else {
                return true;
            }

    }

    public String HttpRestClient(String url, HttpMethod method, HashMap<String, Object> formParams, String getParams,  MediaType mediaType) {
        if (!StringUtils.isEmpty(getParams)) {
            url = url + Constant.QUESTION + getParams;
        }
        SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
        requestFactory.setConnectTimeout(10*1000);
        requestFactory.setReadTimeout(10*1000);
        RestTemplate client = new RestTemplate(requestFactory);
        client.getMessageConverters().set(1,new StringHttpMessageConverter(StandardCharsets.UTF_8));
        HttpHeaders headers = new HttpHeaders();
        if (mediaType == null){
            headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
        }else {
            headers.setContentType(mediaType);
        }
        String s = JSON.toJSONString(formParams);
        JSONObject result = (JSONObject) JSON.parse(s);
        HttpEntity<JSONObject> requestEntity = new HttpEntity<JSONObject>(result, headers);
        //  执行HTTP请求
        ResponseEntity<String> response = client.exchange(url, method, requestEntity, String.class);

        return response.getBody();
    }
}