Add view controller

eventmesh-dashboard-console/pom.xml

@@ -79,6 +79,48 @@
             <scope>runtime</scope>
         </dependency>
 
+        <!-- health check client -->
+        <!-- EventMesh SDK -->
+<!--        <dependency>-->
+<!--            <groupId>org.apache.eventmesh</groupId>-->
+<!--            <artifactId>eventmesh-sdk-java</artifactId>-->
+<!--            <version>1.10.0-release</version>-->
+<!--            <exclusions>-->
+<!--                <exclusion>-->
+<!--                    <groupId>junit</groupId>-->
+<!--                    <artifactId>junit</artifactId>-->
+<!--                </exclusion>-->
+<!--                <exclusion>-->
+<!--                    <groupId>junit</groupId>-->
+<!--                    <artifactId>junit-dep</artifactId>-->
+<!--                </exclusion>-->
+<!--                <exclusion>-->
+<!--                    <groupId>org.apache.logging.log4j</groupId>-->
+<!--                    <artifactId>log4j-slf4j-impl</artifactId>-->
+<!--                </exclusion>-->
+<!--            </exclusions>-->
+<!--        </dependency>-->
+        <!-- storage redis client -->
+        <dependency>
+            <groupId>io.lettuce</groupId>
+            <artifactId>lettuce-core</artifactId>
+        </dependency>
+        <!-- rocketmq client -->
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-client</artifactId>
+            <version>4.9.4</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-tools</artifactId>
+            <version>5.2.0</version>
+        </dependency>
+        <!-- health check client end -->
+
+
+
+
         <!--health check client -->
         <!--EventMesh SDK -->
         <!--<dependency>-->

eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/EventMeshDashboardApplication.java

@@ -19,13 +19,15 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.EnableAspectJAutoProxy;
 import org.springframework.transaction.annotation.EnableTransactionManagement;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
 @SpringBootApplication
 @EnableTransactionManagement
+@EnableAspectJAutoProxy(exposeProxy = true)
 public class EventMeshDashboardApplication {
 
     public static void main(String[] args) {

eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/ClusterController.java

@@ -0,0 +1,46 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.controller;
+
+
+import org.apache.eventmesh.dashboard.console.modle.vo.cluster.GetClusterBaseMessageVO;
+import org.apache.eventmesh.dashboard.console.modle.vo.cluster.ResourceNumVO;
+import org.apache.eventmesh.dashboard.console.service.cluster.ClusterService;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+
+public class ClusterController {
+
+    @Autowired
+    ClusterService clusterService;
+
+    @GetMapping("/cluster/getResourceNum")
+    public ResourceNumVO getResourceNumByClusterId(Long clusterId) {
+        return clusterService.getResourceNumByCluster(clusterId);
+    }
+
+
+    @GetMapping("/cluster/getBaseMessage")
+    public GetClusterBaseMessageVO getClusterBaseMessage(Long clusterId) {
+        return clusterService.getClusterBaseMessage(clusterId);
+    }
+}

eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/ConfigController.java

@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.controller;
+
+import org.apache.eventmesh.dashboard.console.entity.config.ConfigEntity;
+import org.apache.eventmesh.dashboard.console.modle.dto.config.DetailConfigsVO;
+import org.apache.eventmesh.dashboard.console.modle.dto.config.GetConfigsListDTO;
+import org.apache.eventmesh.dashboard.console.modle.dto.config.UpdateConfigDTO;
+import org.apache.eventmesh.dashboard.console.service.config.ConfigService;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class ConfigController {
+
+    @Autowired
+    private ConfigService configService;
+
+    @PostMapping("/cluster/config/updateConfigs")
+    public String updateConfigsByTypeAndId(@Validated @RequestBody UpdateConfigDTO updateConfigDTO) {
+        try {
+            configService.updateConfigsByInstanceId(updateConfigDTO.getUsername(), updateConfigDTO.getClusterId(), updateConfigDTO.getInstanceType(),
+                updateConfigDTO.getInstanceId(), updateConfigDTO.getChangeConfigDTOS());
+        } catch (Exception e) {
+            return e.getMessage();
+        }
+        return "success";
+    }
+
+
+    @PostMapping("/cluster/config/getInstanceDetailConfigs")
+    public List<DetailConfigsVO> getInstanceDetailConfigs(@Validated @RequestBody GetConfigsListDTO getConfigsListDTO) {
+        List<ConfigEntity> configEntityList = configService.selectToFront(getConfigsListDTO.getInstanceId(),
+            getConfigsListDTO.getInstanceType(), getConfigsListDTO.getDynamicGetConfigDto());
+        Map<String, String> stringStringConcurrentHashMap = configService.selectDefaultConfig(getConfigsListDTO.getBusinessType(),
+            getConfigsListDTO.getInstanceId(), getConfigsListDTO.getInstanceType());
+        ArrayList<DetailConfigsVO> showDetailConfigsVOS = new ArrayList<>();
+        configEntityList.forEach(n -> {
+            DetailConfigsVO showDetailConfigsVO = new DetailConfigsVO();
+            showDetailConfigsVO.setDefaultValue(stringStringConcurrentHashMap.get(n.getConfigName()));
+            showDetailConfigsVO.setIsModify(n.getIsModify());
+            showDetailConfigsVO.setConfigName(n.getConfigName());
+            showDetailConfigsVO.setConfigValue(n.getConfigValue());
+            showDetailConfigsVO.setAlreadyUpdate(n.getAlreadyUpdate());
+            showDetailConfigsVOS.add(showDetailConfigsVO);
+        });
+        return showDetailConfigsVOS;
+    }
+
+
+}

eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/ConnectionController.java

@@ -17,36 +17,73 @@
 
 package org.apache.eventmesh.dashboard.console.controller;
 
-import org.apache.eventmesh.dashboard.service.meta.ConnectionCore;
+import org.apache.eventmesh.dashboard.console.entity.config.ConfigEntity;
+import org.apache.eventmesh.dashboard.console.entity.connector.ConnectorEntity;
+import org.apache.eventmesh.dashboard.console.modle.dto.connection.AddConnectionDTO;
+import org.apache.eventmesh.dashboard.console.modle.dto.connection.CreateConnectionDTO;
+import org.apache.eventmesh.dashboard.console.modle.dto.connection.GetConnectionListDTO;
+import org.apache.eventmesh.dashboard.console.modle.vo.connection.ConnectionListVO;
+import org.apache.eventmesh.dashboard.console.service.connection.ConnectionDataService;
 
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
 
-import lombok.extern.slf4j.Slf4j;
-
-@Slf4j
 @RestController
 public class ConnectionController {
 
-    /**
-     * TODO expose implement by FunctionManager
-     */
-    ConnectionCore connectionCore;
+    @Autowired
+    private ConnectionDataService connectionDataService;
 
     /**
-     * Query Connection List
-     * <p>
-     * The subscription information of SourceConnector and SinkConnector reported by EventMesh Runtime to the meta,
-     * containing the configuration of each connection.
+     * 'type' only can be Sink or Source
      *
-     * @param page the page number
-     * @param size the page size
-     * @return A paged list of connection configuration and total number of pages
+     * @param type
+     * @return
      */
-    @GetMapping("/connection")
-    public String listConnections(@RequestParam("page") Integer page, @RequestParam("size") String size) {
-        return null;
+    @GetMapping("/cluster/connection/getConnectorBusinessType")
+    public List<String> getConnectorBusinessType(String type) {
+        return connectionDataService.getConnectorBusinessType(type);
+    }
+
+    @GetMapping("/cluster/connection/getConnectorConfigs")
+    public List<ConfigEntity> getConnectorConfigsByClassAndVersion(String version, String classType) {
+        return connectionDataService.getConnectorConfigsByClassAndVersion(classType, version);
     }
 
+
+    @GetMapping("/cluster/connection/showCreateConnectionMessage")
+    public AddConnectionDTO showCreateConnectionMessage() {
+        return new AddConnectionDTO();
+    }
+
+
+    @PostMapping("/cluster/connection/createConnection")
+    public String createConnection(@Validated @RequestBody CreateConnectionDTO createConnectionDTO) {
+        try {
+            connectionDataService.createConnection(createConnectionDTO);
+
+        } catch (Exception e) {
+            return e.getMessage();
+        }
+        return "success";
+    }
+
+
+    @PostMapping("/cluster/connection/getConnectionList")
+    public List<ConnectionListVO> getConnectionList(@Validated @RequestBody GetConnectionListDTO getConnectionListDTO) {
+        return connectionDataService.getConnectionToFrontByCluster(getConnectionListDTO.getClusterId(), getConnectionListDTO);
+    }
+
+    @GetMapping("/cluster/connection/getConnectorDetail")
+    public ConnectorEntity getConnectorDetail(Long connectorId) {
+        return connectionDataService.getConnectorById(connectorId);
+    }
+
+
 }

eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/HealthController.java

@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.controller;
+
+import org.apache.eventmesh.dashboard.console.entity.health.HealthCheckResultEntity;
+import org.apache.eventmesh.dashboard.console.modle.vo.health.InstanceLiveProportionVo;
+import org.apache.eventmesh.dashboard.console.service.health.HealthDataService;
+
+import java.sql.Timestamp;
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class HealthController {
+
+    @Autowired
+    HealthDataService healthDataService;
+
+    @GetMapping("/cluster/health/getHistoryLiveStatus")
+    public List<HealthCheckResultEntity> getHistoryLiveStatusById(Integer type, Long instanceId, String startTime) {
+        Timestamp timestamp = Timestamp.valueOf(startTime);
+        return healthDataService.getInstanceLiveStatusHistory(type, instanceId, timestamp);
+    }
+
+    @GetMapping("/cluster/health/getInstanceLiveProportion")
+    public InstanceLiveProportionVo getInstanceLiveProportion(Integer instanceType, Long theClusterId) {
+        return healthDataService.getInstanceLiveProportion(theClusterId, instanceType);
+    }
+}

eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/controller/LogController.java

@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.controller;
+
+import org.apache.eventmesh.dashboard.console.entity.log.LogEntity;
+import org.apache.eventmesh.dashboard.console.service.log.LogService;
+
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class LogController {
+
+    @Autowired
+    private LogService logService;
+
+    @GetMapping("/cluster/log/getList")
+    public List<LogEntity> getLogLIstToFront(Integer pageIndex, Integer pageNum) {
+        return logService.getLogListByCluster(pageIndex, pageNum);
+    }
+
+}