package com.fzzy.gateway.hx2023.controller;

import com.alibaba.fastjson2.JSONObject;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.utils.RedisConst;
import com.fzzy.api.utils.RedisUtil;
import com.fzzy.gateway.entity.GatewayConf;
import com.fzzy.gateway.hx2023.data.GatewayAuthData;
import com.fzzy.gateway.service.GatewayConfService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.util.List;

/**
 *
 */
@Slf4j
@Controller
@RequestMapping("/sc2023/gateway")
public class GatewayController {

    @Resource
    private RedisUtil redisUtil;
    @Resource
    private GatewayConfService confService;


    /**
     * 鉴权接口
     *
     * @return {
     * "message": "成功",
     * "result": {
     * "token":"b2919bed493eca1ee1efb8d3cfa08a"
     * },
     * "status": 0,
     * "code": 200,
     * "timestamp": 0
     * }
     */
    @PostMapping("/authorize/login")
    public @ResponseBody
    JSONObject authorize(@RequestBody GatewayAuthData data) {


        List<GatewayConf> list = confService.getCacheConfList();

        JSONObject json = new JSONObject();
        json.put("timestamp", System.currentTimeMillis());
        if (null == list || list.isEmpty()) {
            json.put("code", 500);
            json.put("message", "未获取网关信息");
            return json;
        }

        String gatewayId = null;
        for (GatewayConf conf : list) {
            if (data.getUsername().equals(conf.getGatewayUsername()) && data.getPassword().equals(conf.getGatewayPassword())) {
                gatewayId = conf.getGatewayId();
                break;
            }
        }

        if (null == gatewayId) {
            json.put("code", 500);
            json.put("message", "未匹配到用户名和密码");
            return json;
        }


        String token = "fzzy-" + gatewayId;

        log.debug("============鉴权==========={}--{}--{}", data.getUsername(), data.getPassword(), token);

        this.updateGatewayToken(token, data.getUsername());

        JSONObject result = new JSONObject();
        result.put("token", token);
        json.put("result", result);
        json.put("message", "成功");
        json.put("status", 0);
        json.put("code", 200);
        return json;
    }

    public void updateGatewayToken(String token, String username) {
        String key = RedisConst.buildKey(RedisConst.KYE_GATE_TOKEN, username);
        redisUtil.set(key, token);
    }

    public String getGatewayToken(String username) {
        String key = RedisConst.buildKey(RedisConst.KYE_GATE_TOKEN, username);
        return (String) redisUtil.get(key);
    }
}