调整MQTT配置

jiazx0107@163.com

2023-11-08 0a8ef890592a9c0389c42daeebb9a3f0974c37e6

 src/main/java/com/fzzy/gateway/hx2023/controller/GatewayController.java

@@ -4,12 +4,15 @@
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;

/**
 *
@@ -21,6 +24,9 @@

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


    /**
     * 鉴权接口
@@ -39,28 +45,44 @@
    public @ResponseBody
    JSONObject authorize(@RequestBody GatewayAuthData data) {

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

        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;
        }


        //TODO 验证用户名和密码
        String token = "fzzy-" + gatewayId;


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

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

        JSONObject json = new JSONObject();

        JSONObject result = new JSONObject();

        result.put("token", token);

        json.put("result", result);
        json.put("message", "成功");
        json.put("status", 0);
        json.put("code", 200);
        json.put("timestamp", System.currentTimeMillis());

        return json;
    }