package com.casic.missiles.controller;

import com.alibaba.fastjson.JSON;
import com.casic.missiles.core.base.controller.BaseController;
import com.casic.missiles.core.base.response.ResponseData;
import com.casic.missiles.core.util.ToolUtil;
import com.casic.missiles.dto.ParamsCasicBean;
import com.casic.missiles.util.HttpUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import java.util.Map;

/**
 * app调用前置开发
 */
@Controller
@RequestMapping("/server")
public class CommonSyncController extends BaseController {
    private static final Logger logger = LoggerFactory.getLogger(CommonSyncController.class);
    @Value("${casic.invoke.port:8081}")
    private String port;
    @Value("${casic.invoke.host:http://192.170.1.10}")
    private String host;

    /**
     * 总线前置调用
     */
    @PostMapping(value = "/invoke")
    @ResponseBody
    public Object prepositionInvoke(HttpServletRequest request, @RequestBody ParamsCasicBean requestBaseBean) {
        try {
            /***这里是业务逻辑处理***/
            logger.info(JSON.toJSONString(requestBaseBean));
            Map<String, String> map = requestBaseBean.getParams();
            String json = null;
            String localhostIp = host + ":" + port + "/";
            if (RequestMethod.POST.name().equals(requestBaseBean.getType())) {
                json = HttpUtils.sendPost(localhostIp + requestBaseBean.getMethodName(), map, requestBaseBean.getToken());
            } else {
                json = HttpUtils.sendGet(localhostIp + requestBaseBean.getMethodName(), map, requestBaseBean.getToken());
            }
            if (ToolUtil.isEmpty(json)) {
                return ResponseData.error("请求失败");
            }
            return ResponseData.success(JSON.parse(json));
        } catch (Exception e) {
            e.printStackTrace();
        }
        return ResponseData.error("请求失败");
    }
}