1.版本更新至1.2

2.注册windowsservice服务

gather-broker/${project.parent.basedir}/target/application-dev.yml

@@ -0,0 +1,48 @@
+spring:
+  main:
+    allow-bean-definition-overriding: true
+    allow-circular-references: true
+  shardingsphere:
+    datasource:
+      name: m1
+      m1:
+        type: com.alibaba.druid.pool.DruidDataSource
+        driver-class-name: com.mysql.cj.jdbc.Driver
+        #        url: jdbc:mysql://192.168.31.46:3377/gs_data_collection?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true&allowPublicKeyRetrieval=true&allowMutiQueries=true
+        #        username: root
+        #        password: gs12345
+        url: jdbc:mysql://127.0.0.1:3306/gather_broker?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true&allowPublicKeyRetrieval=true&allowMutiQueries=true
+        username: root
+        password: 123456
+    sharding:
+      tables:
+        item_record:
+          table-strategy:
+            inline:
+              sharding-column: id
+              algorithm-expression: item_record_$->{id%10+1}
+          actual-data-nodes: m1.item_record_$->{1..10}
+          key-generator:
+            column: id
+            type: SNOWFLAKE
+            props:
+              worker:
+                id: 1
+  web:
+    resources:
+      static-locations: classpath:/templates/
+  mvc:
+    view:
+      prefix: "/templates/"
+      suffix: ".html"
+server:
+  port: 8080
+#thymeleaf:
+#  prefix: classpath:/templates/
+#  mode: HTML
+#  cache: false
+#  encoding: UTF-8
+#  servlet:
+#    content-type: text/html
+logging:
+  config: classpath:logback-spring.xml

gather-broker/${project.parent.basedir}/target/application-pro.yml

@@ -0,0 +1,48 @@
+spring:
+  main:
+    allow-bean-definition-overriding: true
+    allow-circular-references: true
+  shardingsphere:
+    datasource:
+      name: m1
+      m1:
+        type: com.alibaba.druid.pool.DruidDataSource
+        driver-class-name: com.mysql.cj.jdbc.Driver
+        #        url: jdbc:mysql://192.168.31.46:3377/gs_data_collection?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true&allowPublicKeyRetrieval=true&allowMutiQueries=true
+        #        username: root
+        #        password: gs12345
+        url: jdbc:mysql://127.0.0.1:3377/gs_broker?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true&allowPublicKeyRetrieval=true&allowMutiQueries=true
+        username: root
+        password: gs12345
+    sharding:
+      tables:
+        item_record:
+          table-strategy:
+            inline:
+              sharding-column: id
+              algorithm-expression: item_record_$->{id%10+1}
+          actual-data-nodes: m1.item_record_$->{1..10}
+          key-generator:
+            column: id
+            type: SNOWFLAKE
+            props:
+              worker:
+                id: 1
+  web:
+    resources:
+      static-locations: classpath:/templates/
+  mvc:
+    view:
+      prefix: "/templates/"
+      suffix: ".html"
+server:
+  port: 20600
+#thymeleaf:
+#  prefix: classpath:/templates/
+#  mode: HTML
+#  cache: false
+#  encoding: UTF-8
+#  servlet:
+#    content-type: text/html
+logging:
+  config: classpath:logback-spring.xml

gather-broker/${project.parent.basedir}/target/application-test.yml

@@ -0,0 +1,48 @@
+spring:
+  main:
+    allow-bean-definition-overriding: true
+    allow-circular-references: true
+  shardingsphere:
+    datasource:
+      name: m1
+      m1:
+        type: com.alibaba.druid.pool.DruidDataSource
+        driver-class-name: com.mysql.cj.jdbc.Driver
+        #        url: jdbc:mysql://192.168.31.46:3377/gs_data_collection?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true&allowPublicKeyRetrieval=true&allowMutiQueries=true
+        #        username: root
+        #        password: gs12345
+        url: jdbc:mysql://127.0.0.1:3306/gather_broker?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true&allowPublicKeyRetrieval=true&allowMutiQueries=true
+        username: root
+        password: 123456
+    sharding:
+      tables:
+        item_record:
+          table-strategy:
+            inline:
+              sharding-column: id
+              algorithm-expression: item_record_$->{id%10+1}
+          actual-data-nodes: m1.item_record_$->{1..10}
+          key-generator:
+            column: id
+            type: SNOWFLAKE
+            props:
+              worker:
+                id: 1
+  web:
+    resources:
+      static-locations: classpath:/templates/
+  mvc:
+    view:
+      prefix: "/templates/"
+      suffix: ".html"
+server:
+  port: 8080
+#thymeleaf:
+#  prefix: classpath:/templates/
+#  mode: HTML
+#  cache: false
+#  encoding: UTF-8
+#  servlet:
+#    content-type: text/html
+logging:
+  config: classpath:logback-spring.xml

gather-broker/${project.parent.basedir}/target/application.yml

@@ -0,0 +1,10 @@
+spring:
+  application:
+    name: gather-broker
+  profiles:
+    active: pro # 设置激活的环境
+  main:
+    lazy-initialization: false
+mybatis: # mybatis 配置
+  configuration:
+    map-underscore-to-camel-case: true

gather-broker/${project.parent.basedir}/target/index.html

@@ -0,0 +1,32 @@
+<!DOCTYPE html>
+<html lang="en">
+  <head>
+    <meta charset="UTF-8" />
+    <meta http-equiv="X-UA-Compatible" content="IE=edge" />
+    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+    <title>Document</title>
+    <style>
+      html,
+      body,
+      #app {
+        width: 100%;
+        height: 100%;
+        overflow: hidden;
+        background-color: #f0f2f5;
+      }
+    </style>
+    <link rel="shortcut icon" type="image/x-icon" href="./favicon.ico" />
+    <link rel="stylesheet" href="./umi.c19e50b2.css" />
+    <script>
+      window.routerBase = "/";
+    </script>
+    <script>
+      //! umi version: 3.5.34
+    </script>
+  </head>
+  <body>
+    <div id="app"></div>
+
+    <script src="./umi.fc9f4d02.js"></script>
+  </body>
+</html>

gather-broker/${project.parent.basedir}/target/layouts__index-layouts.12c30f39.chunk.css

@@ -0,0 +1 @@
+.menuTitle___vfXvH{padding:16px;display:flex;align-items:center;width:256px!important}.menuTitle___vfXvH img{width:32px;height:32px}.menuTitle___vfXvH h1{font-size:18px;color:#fff;margin:0 0 0 12px;display:inline-block;font-weight:700}.menuTitle___vfXvH .menuIcon___2bV5r{font-size:18px;color:#fff;margin-left:auto}.Menu___2m28J{height:100%;width:256px!important;background:#001529}.ant-breadcrumb{box-sizing:border-box;margin:0;padding:0;font-variant:tabular-nums;line-height:1.5715;list-style:none;font-feature-settings:"tnum","tnum";color:rgba(0,0,0,.45);font-size:14px}.ant-breadcrumb .anticon{font-size:14px}.ant-breadcrumb ol{display:flex;flex-wrap:wrap;margin:0;padding:0;list-style:none}.ant-breadcrumb a{color:rgba(0,0,0,.45);transition:color .3s}.ant-breadcrumb a:hover{color:rgba(0,0,0,.85)}.ant-breadcrumb li:last-child{color:rgba(0,0,0,.85)}.ant-breadcrumb li:last-child a{color:rgba(0,0,0,.85)}li:last-child>.ant-breadcrumb-separator{display:none}.ant-breadcrumb-separator{margin:0 8px;color:rgba(0,0,0,.45)}.ant-breadcrumb-link>.anticon+a,.ant-breadcrumb-link>.anticon+span{margin-left:4px}.ant-breadcrumb-overlay-link>.anticon{margin-left:4px}.ant-breadcrumb-rtl{direction:rtl}.ant-breadcrumb-rtl:before{display:table;content:""}.ant-breadcrumb-rtl:after{display:table;clear:both;content:""}.ant-breadcrumb-rtl>span{float:right}.ant-breadcrumb-rtl .ant-breadcrumb-link>.anticon+a,.ant-breadcrumb-rtl .ant-breadcrumb-link>.anticon+span{margin-right:4px;margin-left:0}.ant-breadcrumb-rtl .ant-breadcrumb-overlay-link>.anticon{margin-right:4px;margin-left:0}.layouts-nav{height:48px;line-height:48px;width:100%;z-index:19;padding:0 16px;box-sizing:border-box;border-bottom:1px solid #e0e0e0;background-color:#fff}.ant-breadcrumb-link{cursor:pointer;-webkit-user-select:none;-moz-user-select:none;-ms-user-select:none;user-select:none}.ant-breadcrumb{color:rgba(0,0,0,.85)}.ant-breadcrumb li:last-child{color:rgba(0,0,0,.45)!important}.childrenPage___1OO9Z{background-color:#f0f2f5;flex:1 1;margin:20px 20px 0;overflow:auto}.layout___2HAIu{height:100%;display:flex;overflow:hidden}.layoutRigth___2Rcww{flex:1 1;display:flex;flex-direction:column}

gather-broker/${project.parent.basedir}/target/logback-spring.xml

@@ -0,0 +1,70 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration debug="false">
+    <!--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径-->
+    <!--<property resource="application.properties"/>-->
+    <property name="LOG_HOME" value="log"/>
+    <property name="LOG_NAME" value="gather-broker"/>
+    <conversionRule conversionWord="clr" converterClass="org.springframework.boot.logging.logback.ColorConverter"/>
+    <conversionRule conversionWord="wex" converterClass="org.springframework.boot.logging.logback.WhitespaceThrowableProxyConverter"/>
+    <conversionRule conversionWord="wEx" converterClass="org.springframework.boot.logging.logback.ExtendedWhitespaceThrowableProxyConverter"/>
+    <property name="CONSOLE_LOG_PATTERN"
+              value="${CONSOLE_LOG_PATTERN:-%clr(%d{${LOG_DATEFORMAT_PATTERN:-yyyy-MM-dd HH:mm:ss.SSS}}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}}"/>
+    <property name="FILE_LOG_PATTERN"
+              value="${FILE_LOG_PATTERN:-%d{${LOG_DATEFORMAT_PATTERN:-yyyy-MM-dd HH:mm:ss.SSS}} ${LOG_LEVEL_PATTERN:-%5p} ${PID:- } --- [%t] %-40.40logger{39} : %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}}"/>
+
+    <logger name="org.apache.catalina.startup.DigesterFactory" level="ERROR"/>
+    <logger name="org.apache.catalina.util.LifecycleBase" level="ERROR"/>
+    <logger name="org.apache.coyote.http11.Http11NioProtocol" level="WARN"/>
+    <logger name="org.apache.sshd.common.util.SecurityUtils" level="WARN"/>
+    <logger name="org.apache.tomcat.util.net.NioSelectorPool" level="WARN"/>
+    <logger name="org.eclipse.jetty.util.component.AbstractLifeCycle" level="ERROR"/>
+    <logger name="org.hibernate.validator.internal.util.Version" level="WARN"/>
+    <!-- 控制台输出 -->
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+            <!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度 %msg：日志消息，%logger{50}  表示类名路径显示50字符。超过则只显示首字母 %n是换行符-->
+            <pattern>${CONSOLE_LOG_PATTERN}</pattern>
+        </encoder>
+    </appender>
+    <!-- 按照每天生成日志文件 -->
+    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <!--日志文件输出的文件名-->
+            <FileNamePattern>${LOG_HOME}/${LOG_NAME}.%d{yyyy-MM-dd}.log</FileNamePattern>
+            <!--日志文件保留天数-->
+            <MaxHistory>3</MaxHistory>
+        </rollingPolicy>
+        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+            <!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符-->
+            <pattern>${FILE_LOG_PATTERN}</pattern>
+        </encoder>
+        <!--日志文件最大的大小-->
+        <triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">
+            <MaxFileSize>100MB</MaxFileSize>
+        </triggeringPolicy>
+    </appender>
+
+    <!-- 日志输出级别 -->
+    <springProfile name="dev">
+        <root level="DEBUG">
+            <appender-ref ref="FILE"/>
+            <appender-ref ref="STDOUT"/>
+        </root>
+    </springProfile>
+    <springProfile name="test">
+        <root level="INFO">
+            <appender-ref ref="FILE"/>
+            <appender-ref ref="STDOUT"/>
+        </root>
+    </springProfile>
+    <springProfile name="pro">
+        <root level="INFO">
+            <appender-ref ref="FILE"/>
+            <appender-ref ref="STDOUT"/>
+        </root>
+    </springProfile>
+    <logger name="springfox.documentation" level="ERROR" additivity="false">
+        <appender-ref ref="FILE"/>
+        <appender-ref ref="STDOUT"/>
+    </logger>
+</configuration>

gather-broker/${project.parent.basedir}/target/mapper/ConnectionItemMapper.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.idtgz.dao.mapper.ConnectionItemMapper">
+    <delete id="cleanUp">
+        DELETE FROM  connection_item where connection_id not in (Select id from connection )
+    </delete>
+</mapper>

gather-broker/${project.parent.basedir}/target/mapper/ItemRecordMapper.xml

@@ -0,0 +1,36 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.idtgz.dao.mapper.ItemRecordMapper">
+
+
+    <insert id="saveByBatch">
+        INSERT INTO `gather_broker`.`item_record` (
+        `connection_type`,
+        `item_code`,
+        `item_index_id`,
+        `item_sign`,
+        `item_value`,
+        `item_timestamp`,
+        `item_extra_info`,
+        `connection_index_id`,
+        `upload_queue_id`,
+        `connection_sign`
+        )
+        VALUES
+        <foreach collection="entities" separator="," item="item" close=" ">
+            (
+            #{item.connectionType},
+            #{item.itemCode},
+            #{item.itemIndexId},
+            #{item.itemSign},
+            #{item.itemValue},
+            #{item.itemTimestamp},
+            #{item.itemExtraInfo},
+            #{item.connectionIndexId},
+            #{item.uploadQueueId},
+            #{item.connectionSign}
+            )
+        </foreach>
+    </insert>
+</mapper>

gather-broker/${project.parent.basedir}/target/p__404.c9e88f8d.async.js

@@ -0,0 +1 @@
+(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([[6],{"i6+/":function(n,e,c){"use strict";c.r(e);var r=c("nKUr");e["default"]=function(){return Object(r["jsx"])(r["Fragment"],{children:Object(r["jsx"])("h1",{children:"404"})})}}}]);

gather-broker/${project.parent.basedir}/target/p__homePage__index.8aa3a91e.async.js

@@ -0,0 +1 @@
+(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([[12],{x2bW:function(e,t,c){"use strict";c.r(t);var r=c("S3SW"),n=(c("3i0d"),c("p4vi")),j=c("q1tI"),s=Object(j["createContext"])({}),a=s,i=c("nKUr"),b=function(){var e=Object(j["useContext"])(a),t=e.fatherName,c=e.setFatherName;return Object(i["jsxs"])(i["Fragment"],{children:[Object(i["jsx"])("h3",{children:"\u5b50\u7ec4\u4ef6"}),Object(i["jsxs"])("p",{children:["\u7236\u7ec4\u4ef6\u6570\u636e\uff1a",t]}),Object(i["jsx"])(n["a"],{type:"primary",onClick:()=>{c("\u6211\u6539\u4e86\u7236\u7ec4\u4ef6")},children:"\u4fee\u6539\u7236\u7ec4\u4ef6\u540d\u79f0"})]})};t["default"]=function(){var e=Object(j["useState"])("\u7236\u7ec4\u4ef6"),t=Object(r["a"])(e,2),c=t[0],n=t[1],s=Object(j["useMemo"])((()=>c),[c]);return Object(i["jsx"])(a.Provider,{value:{fatherName:c,setFatherName:n},children:Object(i["jsxs"])("div",{children:[Object(i["jsx"])("h2",{children:c}),Object(i["jsx"])("p",{children:s}),Object(i["jsx"])(b,{})]})})}}}]);

gather-broker/${project.parent.basedir}/target/templates/index.html

@@ -0,0 +1,32 @@
+<!DOCTYPE html>
+<html lang="en">
+  <head>
+    <meta charset="UTF-8" />
+    <meta http-equiv="X-UA-Compatible" content="IE=edge" />
+    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+    <title>Document</title>
+    <style>
+      html,
+      body,
+      #app {
+        width: 100%;
+        height: 100%;
+        overflow: hidden;
+        background-color: #f0f2f5;
+      }
+    </style>
+    <link rel="shortcut icon" type="image/x-icon" href="./favicon.ico" />
+    <link rel="stylesheet" href="./umi.c19e50b2.css" />
+    <script>
+      window.routerBase = "/";
+    </script>
+    <script>
+      //! umi version: 3.5.34
+    </script>
+  </head>
+  <body>
+    <div id="app"></div>
+
+    <script src="./umi.fc9f4d02.js"></script>
+  </body>
+</html>

gather-broker/${project.parent.basedir}/target/templates/layouts__index-layouts.0b5cc4d9.chunk.css

@@ -0,0 +1 @@
+.menuTitle___vfXvH{padding:16px;display:flex;align-items:center;width:256px!important}.menuTitle___vfXvH img{width:32px;height:32px}.menuTitle___vfXvH h1{font-size:18px;color:#fff;margin:0 0 0 12px;display:inline-block;font-weight:700}.menuTitle___vfXvH .menuIcon___2bV5r{font-size:18px;color:#fff;margin-left:auto}.Menu___2m28J{height:100%;width:256px!important;background:#001529}.nav___2VwOK{height:48px;line-height:48px;width:100%;z-index:19;padding:0 16px;box-sizing:border-box;box-shadow:0 3px 3px rgb(0 0 0);border-bottom:1px solid #e0e0e0;background-color:#fff}.childrenPage___1OO9Z{background-color:#f0f2f5;flex:1 1;margin:20px 20px 0;overflow:auto}.layout___2HAIu{height:100%;display:flex;overflow:hidden}.layoutRigth___2Rcww{flex:1 1;display:flex;flex-direction:column}

gather-broker/${project.parent.basedir}/target/templates/layouts__index-layouts.12c30f39.chunk.css

@@ -0,0 +1 @@
+.menuTitle___vfXvH{padding:16px;display:flex;align-items:center;width:256px!important}.menuTitle___vfXvH img{width:32px;height:32px}.menuTitle___vfXvH h1{font-size:18px;color:#fff;margin:0 0 0 12px;display:inline-block;font-weight:700}.menuTitle___vfXvH .menuIcon___2bV5r{font-size:18px;color:#fff;margin-left:auto}.Menu___2m28J{height:100%;width:256px!important;background:#001529}.ant-breadcrumb{box-sizing:border-box;margin:0;padding:0;font-variant:tabular-nums;line-height:1.5715;list-style:none;font-feature-settings:"tnum","tnum";color:rgba(0,0,0,.45);font-size:14px}.ant-breadcrumb .anticon{font-size:14px}.ant-breadcrumb ol{display:flex;flex-wrap:wrap;margin:0;padding:0;list-style:none}.ant-breadcrumb a{color:rgba(0,0,0,.45);transition:color .3s}.ant-breadcrumb a:hover{color:rgba(0,0,0,.85)}.ant-breadcrumb li:last-child{color:rgba(0,0,0,.85)}.ant-breadcrumb li:last-child a{color:rgba(0,0,0,.85)}li:last-child>.ant-breadcrumb-separator{display:none}.ant-breadcrumb-separator{margin:0 8px;color:rgba(0,0,0,.45)}.ant-breadcrumb-link>.anticon+a,.ant-breadcrumb-link>.anticon+span{margin-left:4px}.ant-breadcrumb-overlay-link>.anticon{margin-left:4px}.ant-breadcrumb-rtl{direction:rtl}.ant-breadcrumb-rtl:before{display:table;content:""}.ant-breadcrumb-rtl:after{display:table;clear:both;content:""}.ant-breadcrumb-rtl>span{float:right}.ant-breadcrumb-rtl .ant-breadcrumb-link>.anticon+a,.ant-breadcrumb-rtl .ant-breadcrumb-link>.anticon+span{margin-right:4px;margin-left:0}.ant-breadcrumb-rtl .ant-breadcrumb-overlay-link>.anticon{margin-right:4px;margin-left:0}.layouts-nav{height:48px;line-height:48px;width:100%;z-index:19;padding:0 16px;box-sizing:border-box;border-bottom:1px solid #e0e0e0;background-color:#fff}.ant-breadcrumb-link{cursor:pointer;-webkit-user-select:none;-moz-user-select:none;-ms-user-select:none;user-select:none}.ant-breadcrumb{color:rgba(0,0,0,.85)}.ant-breadcrumb li:last-child{color:rgba(0,0,0,.45)!important}.childrenPage___1OO9Z{background-color:#f0f2f5;flex:1 1;margin:20px 20px 0;overflow:auto}.layout___2HAIu{height:100%;display:flex;overflow:hidden}.layoutRigth___2Rcww{flex:1 1;display:flex;flex-direction:column}

gather-broker/${project.parent.basedir}/target/templates/layouts__index-layouts.8a1f1467.async.js

@@ -0,0 +1 @@
+(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([[4],{"0+7N":function(e,n,c){"use strict";c.r(n),c.d(n,"default",(function(){return w}));c("FMPM");var t=c("m3pg"),a=c("S3SW"),i=c("x9r5"),s=c("QMUJ"),l=c("JKUY"),o=c("q1tI"),r=c("QttV"),j=c("pHMi"),d=c.n(j),b=c("nKUr");function u(e,n,c,t,a){return{key:n,icon:c,children:t,label:e,type:a}}var g=[u(Object(b["jsx"])(r["b"],{to:"/connectPage",children:"\u8fde\u63a5"}),"/connectPage",Object(b["jsx"])(i["a"],{})),u(Object(b["jsx"])(r["b"],{to:"/clientPage",children:"\u7ea7\u8054\u5ba2\u6237\u7aef"}),"/clientPage",Object(b["jsx"])(s["a"],{})),u(Object(b["jsx"])(r["b"],{to:"/configPage",children:"\u914d\u7f6e"}),"/configPage",Object(b["jsx"])(l["a"],{}))],h=()=>{var e=Object(o["useState"])(!1),n=Object(a["a"])(e,2),c=n[0];n[1];return Object(b["jsxs"])("div",{className:d.a.Menu,children:[Object(b["jsxs"])("div",{className:d.a.menuTitle,children:[Object(b["jsx"])("img",{src:"./favicon.ico"}),Object(b["jsx"])("h1",{children:"\u5de5\u6570\u6570\u636eBroker"})]}),Object(b["jsx"])(t["a"],{defaultSelectedKeys:["1"],mode:"inline",theme:"dark",inlineCollapsed:c,items:g,className:d.a.menuHeight,inlineCollapsed:!1,inlineIndent:24})]})},O=h,m=c("fmLK"),x=c.n(m),_=c("9kvl"),f=e=>(Object(o["useEffect"])((()=>{Object(_["d"])("/web/configInfo",{method:"get",skipErrorHandler:!0,getResponse:!1}).then((n=>{0===n.code&&e.dispatch({type:"global/setConnecting",payload:n.data.isConnected})})).catch((e=>{console.log("err\uff1a"+e)}))}),[]),Object(b["jsx"])(b["Fragment"],{children:Object(b["jsx"])("div",{className:x.a.nav,children:Object(b["jsxs"])("div",{className:x.a.connetType,children:["\u8fde\u63a5\u72b6\u6001\uff1a",1==e.connecting?"\u5df2\u8fde\u63a5":2==e.connecting?"\u4e2d\u65ad":"\u672a\u8fde\u63a5"]})})})),p=Object(_["a"])((e=>({connecting:e.global.connecting})))(f),v=c("bDFH"),y=c.n(v);function w(e){return Object(b["jsx"])(b["Fragment"],{children:Object(b["jsxs"])("div",{className:y.a.layout,children:[Object(b["jsx"])(O,{}),Object(b["jsxs"])("div",{style:{flex:1},className:y.a.layoutRigth,children:[Object(b["jsx"])(p,{}),Object(b["jsx"])("div",{className:y.a.childrenPage,children:e.children})]})]})})}},bDFH:function(e,n,c){e.exports={childrenPage:"childrenPage___1OO9Z",layout:"layout___2HAIu",layoutRigth:"layoutRigth___2Rcww"}},fmLK:function(e,n,c){e.exports={nav:"nav___2VwOK"}},pHMi:function(e,n,c){e.exports={menuTitle:"menuTitle___vfXvH",menuIcon:"menuIcon___2bV5r",Menu:"Menu___2m28J"}}}]);

gather-broker/${project.parent.basedir}/target/templates/p__404.172bb186.async.js

@@ -0,0 +1 @@
+(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([[5],{"i6+/":function(n,e,c){"use strict";c.r(e);var r=c("nKUr");e["default"]=function(){return Object(r["jsx"])(r["Fragment"],{children:Object(r["jsx"])("h1",{children:"404"})})}}}]);

gather-broker/${project.parent.basedir}/target/templates/p__404.c9e88f8d.async.js

@@ -0,0 +1 @@
+(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([[6],{"i6+/":function(n,e,c){"use strict";c.r(e);var r=c("nKUr");e["default"]=function(){return Object(r["jsx"])(r["Fragment"],{children:Object(r["jsx"])("h1",{children:"404"})})}}}]);

gather-broker/${project.parent.basedir}/target/templates/p__configPage__index.c306d520.async.js

@@ -0,0 +1 @@
+(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([[7],{"2Akm":function(e,t,a){"use strict";a.r(t);a("Si1/");var s=a("mYEJ"),n=(a("SiZr"),a("gDal")),c=(a("e4PP"),a("lUk2")),i=(a("3i0d"),a("p4vi")),r=(a("q03V"),a("fHXl")),l=(a("f/HG"),a("6iYR")),o=a("e22G"),d=(a("sWfU"),a("VNYO")),j=a("S3SW"),b=a("LRVh"),m=a.n(b),p=a("9kvl"),O=a("q1tI"),h=a("nKUr"),g={labelCol:{span:6},wrapperCol:{span:14}},f=e=>{var t=Object(O["useState"])(!1),a=Object(j["a"])(t,2),b=a[0],f=a[1],u=Object(O["useState"])(!1),x=Object(j["a"])(u,2),w=x[0],C=x[1],y=d["a"].useForm(),I=Object(j["a"])(y,1),L=I[0],k=d["a"].useForm(),v=Object(j["a"])(k,1),F=v[0];Object(O["useEffect"])((()=>{_()}),[]);var _=()=>{Object(p["d"])("/web/configInfo",{method:"get",skipErrorHandler:!0,getResponse:!1}).then((t=>{0===t.code&&(L.setFieldsValue(t.data),F.setFieldsValue(t.data),e.dispatch({type:"global/setConnecting",payload:t.data.isConnected}))})).catch((e=>{console.log("err\uff1a"+e)}))},S=()=>{L.validateFields().then((e=>{f(!0),Object(p["d"])("/web/pipeLineConfig",{params:Object(o["a"])({},e.pipeLineConfig),method:"post"}).then((e=>{0===e.code?(_(),l["default"].success(e.msg)):l["default"].warn(e.msg),f(!1)})).catch((e=>{f(!1)}))})).catch((e=>{console.error(e)}))},V=()=>{F.validateFields().then((e=>{C(!0),Object(p["d"])("/web/storeConfig",{params:Object(o["a"])({},e.storeConfig),method:"post"}).then((e=>{0===e.code?l["default"].success(e.msg):l["default"].warn(e.msg),C(!1)})).catch((e=>{C(!1)}))})).catch((e=>{console.error(e)}))};return Object(h["jsxs"])(h["Fragment"],{children:[Object(h["jsx"])(n["a"],{style:{width:700},className:m.a.auto,title:"\u901a\u9053\u914d\u7f6e",children:Object(h["jsx"])(c["a"],{spinning:b,children:Object(h["jsxs"])(d["a"],Object(o["a"])(Object(o["a"])({},g),{},{name:"form_in_modal",form:L,children:[Object(h["jsx"])(d["a"].Item,{name:["pipeLineConfig","host"],label:"host",rules:[{required:!0,message:"\u8bf7\u8f93\u5165host"}],children:Object(h["jsx"])(r["a"],{})}),Object(h["jsx"])(d["a"].Item,{name:["pipeLineConfig","port"],label:"port",rules:[{required:!0,message:"\u8bf7\u8f93\u5165port"}],children:Object(h["jsx"])(r["a"],{})}),Object(h["jsx"])(d["a"].Item,{name:["pipeLineConfig","username"],label:"username",children:Object(h["jsx"])(r["a"],{})}),Object(h["jsx"])(d["a"].Item,{name:["pipeLineConfig","password"],label:"password",children:Object(h["jsx"])(r["a"],{})}),Object(h["jsx"])(d["a"].Item,{name:["pipeLineConfig","clientId"],label:"clientId",children:Object(h["jsx"])(r["a"],{})}),Object(h["jsx"])(i["a"],{onClick:e=>S(),style:{marginLeft:480},type:"primary",children:"\u63d0\u4ea4"})]}))})}),Object(h["jsx"])(n["a"],{style:{width:700,marginTop:20},className:m.a.auto,title:"\u5b58\u50a8\u914d\u7f6e",children:Object(h["jsx"])(c["a"],{spinning:w,children:Object(h["jsxs"])(d["a"],Object(o["a"])(Object(o["a"])({},g),{},{name:"form_in_modal",form:F,children:[Object(h["jsx"])(d["a"].Item,{name:["storeConfig","expirationTime"],label:"\u6570\u636e\u6709\u6548\u671f",rules:[{required:!0,message:"\u8bf7\u8f93\u5165\u6570\u636e\u6709\u6548\u671f"}],children:Object(h["jsx"])(s["a"],{min:1,max:60,addonAfter:"\u5929",style:{width:"100%"},parser:e=>/^\d+$/.test(e)?e:parseInt(e)})}),Object(h["jsx"])(i["a"],{onClick:e=>V(),style:{marginLeft:480},type:"primary",children:"\u63d0\u4ea4"})]}))})})]})};t["default"]=Object(p["a"])((e=>({connecting:e.global.connecting})))(f)},LRVh:function(e,t,a){e.exports={auto:"auto___Xamnv"}}}]);

gather-broker/${project.parent.basedir}/target/templates/p__homePage__index.63fd3127.async.js

@@ -0,0 +1 @@
+(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([[11],{"3LD+":function(e,t,n){"use strict";n.d(t,"a",(function(){return c}));var r=n("a2Ed");function c(e,t){var n=Object(r["a"])({},e);return Array.isArray(t)&&t.forEach((function(e){delete n[e]})),n}},"9RdE":function(e,t,n){"use strict";n.d(t,"c",(function(){return c})),n.d(t,"b",(function(){return i})),n.d(t,"a",(function(){return a}));var r=n("q1tI"),c=r["isValidElement"];function i(e){return e&&e.type===r["Fragment"]}function u(e,t,n){return c(e)?r["cloneElement"](e,"function"===typeof n?n(e.props||{}):n):t}function a(e,t){return u(e,e,t)}},i9BZ:function(e,t,n){"use strict";n.d(t,"a",(function(){return r}));var r=function(){for(var e=arguments.length,t=new Array(e),n=0;n<e;n++)t[n]=arguments[n];return t}},x2bW:function(e,t,n){"use strict";n.r(t);var r=n("S3SW"),c=(n("3i0d"),n("p4vi")),i=n("q1tI"),u=Object(i["createContext"])({}),a=u,o=n("nKUr"),s=function(){var e=Object(i["useContext"])(a),t=e.fatherName,n=e.setFatherName;return Object(o["jsxs"])(o["Fragment"],{children:[Object(o["jsx"])("h3",{children:"\u5b50\u7ec4\u4ef6"}),Object(o["jsxs"])("p",{children:["\u7236\u7ec4\u4ef6\u6570\u636e\uff1a",t]}),Object(o["jsx"])(c["a"],{type:"primary",onClick:()=>{n("\u6211\u6539\u4e86\u7236\u7ec4\u4ef6")},children:"\u4fee\u6539\u7236\u7ec4\u4ef6\u540d\u79f0"})]})};t["default"]=function(){var e=Object(i["useState"])("\u7236\u7ec4\u4ef6"),t=Object(r["a"])(e,2),n=t[0],c=t[1],u=Object(i["useMemo"])((()=>n),[n]);return Object(o["jsx"])(a.Provider,{value:{fatherName:n,setFatherName:c},children:Object(o["jsxs"])("div",{children:[Object(o["jsx"])("h2",{children:n}),Object(o["jsx"])("p",{children:u}),Object(o["jsx"])(s,{})]})})}}}]);

gather-broker/${project.parent.basedir}/target/templates/p__homePage__index.8aa3a91e.async.js

@@ -0,0 +1 @@
+(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([[12],{x2bW:function(e,t,c){"use strict";c.r(t);var r=c("S3SW"),n=(c("3i0d"),c("p4vi")),j=c("q1tI"),s=Object(j["createContext"])({}),a=s,i=c("nKUr"),b=function(){var e=Object(j["useContext"])(a),t=e.fatherName,c=e.setFatherName;return Object(i["jsxs"])(i["Fragment"],{children:[Object(i["jsx"])("h3",{children:"\u5b50\u7ec4\u4ef6"}),Object(i["jsxs"])("p",{children:["\u7236\u7ec4\u4ef6\u6570\u636e\uff1a",t]}),Object(i["jsx"])(n["a"],{type:"primary",onClick:()=>{c("\u6211\u6539\u4e86\u7236\u7ec4\u4ef6")},children:"\u4fee\u6539\u7236\u7ec4\u4ef6\u540d\u79f0"})]})};t["default"]=function(){var e=Object(j["useState"])("\u7236\u7ec4\u4ef6"),t=Object(r["a"])(e,2),c=t[0],n=t[1],s=Object(j["useMemo"])((()=>c),[c]);return Object(i["jsx"])(a.Provider,{value:{fatherName:c,setFatherName:n},children:Object(i["jsxs"])("div",{children:[Object(i["jsx"])("h2",{children:c}),Object(i["jsx"])("p",{children:s}),Object(i["jsx"])(b,{})]})})}}}]);