package com.tievd.cube.modules.system.controller;

import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.fasterxml.jackson.databind.JsonNode;
import com.tievd.cube.commons.base.CubeController;
import com.tievd.cube.commons.base.Result;
import com.tievd.cube.modules.system.entity.SysGatewayRoute;
import com.tievd.cube.modules.system.service.ISysGatewayRouteService;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;

import java.util.List;

/**
 * 网关路由管理
 *
 * @author xinwuy
 * @version V1.0.0
 * @since 2020-05-26
 */
@Slf4j
@Tag(name = "网关路由管理相关接口")
@RestController
@RequestMapping("/sys/gateway/route")
public class SysGatewayRouteController extends CubeController<SysGatewayRoute, ISysGatewayRouteService> {

    /**
     * 更新所有路由配置
     *
     * @param json 参数
     */
    @PostMapping("/updateAll")
    public Result<?> updateAll(@RequestBody JsonNode json) {
        service.updateAll(json);
        return Result.ok();
    }

    /**
     * 查询路由列表
     */
    @GetMapping("/list")
    public Result<?> queryPageList() {
        LambdaQueryWrapper<SysGatewayRoute> query = new LambdaQueryWrapper<>();
        List<SysGatewayRoute> ls = service.list(query);
        JSONArray array = JSONUtil.createArray();
        for (SysGatewayRoute rt : ls) {
            JSONObject obj = JSONUtil.parseObj(rt);
            if (StrUtil.isNotEmpty(rt.getPredicates())) {
                obj.set("predicates", JSONUtil.parseArray(rt.getPredicates()));
            }
            if (StrUtil.isNotEmpty(rt.getFilters())) {
                obj.set("filters", JSONUtil.parseArray(rt.getFilters()));
            }
            array.add(obj);
        }
        return Result.ok(array);
    }

    /**
     * 清除路由缓存
     */
    @GetMapping("/clearRedis")
    public Result<?> clearRedis() {
        service.clearRedis();
        return Result.ok();
    }

    /**
     * 通过id删除
     *
     * @param id 主键id
     */
    @DeleteMapping("/delete")
    public Result<?> delete(@RequestParam String id) {
        service.deleteById(id);
        return Result.ok();
    }
}