git update

README.txt

@@ -16,21 +16,21 @@
 #
 # $ start.sh all        : start all process
 #     $ start.sh comm   : start signal communication process(sig-comm-server)
-#     $ start.sh todp   : start signal communication process(sig-todp-server)
-#     $ start.sh etlp   : start signal communication process(ggits-etlp-server)
-#     $ start.sh ggits  : start signal communication process(ggits-ggits-server)
+#     $ start.sh todp   : start signal tod process(sig-todp-server)
+#     $ start.sh etlp   : start signal ggits etl process(ggits-etlp-server)
+#     $ start.sh ggits  : start signal ggits communication process(ggits-ggits-server)
 #
 # $ stop.sh all         : stop all process
 #     $ stop.sh comm    : stop signal communication process(sig-comm-server)
-#     $ stop.sh todp    : stop signal communication process(sig-todp-server)
-#     $ stop.sh etlp    : stop signal communication process(ggits-etlp-server)
-#     $ stop.sh ggits   : stop signal communication process(ggits-ggits-server)
+#     $ stop.sh todp    : stop signal tod process(sig-todp-server)
+#     $ stop.sh etlp    : stop signal ggits etl process(ggits-etlp-server)
+#     $ stop.sh ggits   : stop signal ggits communication process(ggits-ggits-server)
 #
 # $$$$$$$$$$ info.sh not supported in unix system.................................................
 # $ info.sh comm        : monitoring signal communication process(sig-comm-server)
-# $ info.sh todp        : monitoring signal communication process(sig-todp-server)
-# $ info.sh etlp        : monitoring signal communication process(ggits-etlp-server)
-# $ info.sh ggits       : monitoring signal communication process(ggits-ggits-server)
+# $ info.sh todp        : monitoring signal tod process(sig-todp-server)
+# $ info.sh etlp        : monitoring signal ggits etl process(ggits-etlp-server)
+# $ info.sh ggits       : monitoring signal ggits communication process(ggits-ggits-server)
 #
 ###################################################################################################
 # Log file monitoring

ggits-comm-server/build.gradle

@@ -39,6 +39,7 @@ dependencies {
     implementation 'com.its:its-common:0.0.1'
     implementation 'com.its:its-network:0.0.1'
     implementation 'com.its:its-spring:0.0.1'
+    implementation 'com.its:its-cluster:0.0.1'
 
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
 

ggits-etlp-server/build.gradle

@@ -37,6 +37,7 @@ dependencies {
     implementation 'com.its:its-common:0.0.1'
     implementation 'com.its:its-network:0.0.1'
     implementation 'com.its:its-spring:0.0.1'
+    implementation 'com.its:its-cluster:0.0.1'
 
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
 

ggits-etlp-server/src/main/java/com/sig/ggits/etlp/server/dao/mapper/sig/batch/SigDao.java

@@ -18,11 +18,11 @@ public class SigDao extends BatchDaoService {
     }
 
     public int updateTbInt(List<HashMap<String, Object>> req) {
-        return updateBatch("updateTbInt", req);
+        return insertBatch("updateTbInt", req);
     }
 
     public int updateGgitsEtlp(List<HashMap<String, Object>> req) {
-        return updateBatch("updateGgitsEtlp", req);
+        return insertBatch("updateGgitsEtlp", req);
     }
 
     public int insertGgitsEtlpHist(List<HashMap<String, Object>> req) {
@@ -30,27 +30,27 @@ public class SigDao extends BatchDaoService {
     }
 
     public int updateTbIntFlow(List<HashMap<String, Object>> req) {
-        return updateBatch("updateTbIntFlow", req);
+        return insertBatch("updateTbIntFlow", req);
     }
 
     public int updateTbIntPhase(List<HashMap<String, Object>> req) {
-        return updateBatch("updateTbIntPhase", req);
+        return insertBatch("updateTbIntPhase", req);
     }
 
     public int updateTbIntOperPlan(List<HashMap<String, Object>> req) {
-        return updateBatch("updateTbIntOperPlan", req);
+        return insertBatch("updateTbIntOperPlan", req);
     }
 
     public int updateTbIntDyPlan(List<HashMap<String, Object>> req) {
-        return updateBatch("updateTbIntDyPlan", req);
+        return insertBatch("updateTbIntDyPlan", req);
     }
 
     public int updateTbIntResrvPlan(List<HashMap<String, Object>> req) {
-        return updateBatch("updateTbIntResrvPlan", req);
+        return insertBatch("updateTbIntResrvPlan", req);
     }
 
     public int updateTbIntSignalMap(List<HashMap<String, Object>> req) {
-        return updateBatch("updateTbIntSignalMap", req);
+        return insertBatch("updateTbIntSignalMap", req);
     }
 
 }

ggits-etlp-server/src/main/resources/mybatis/mapper/sig/SigMapper.xml

@@ -31,7 +31,7 @@
         ]]>
     </select>
 
-    <update id="updateGgitsEtlp" parameterType="java.util.Map">
+    <insert id="updateGgitsEtlp" parameterType="java.util.Map">
     <![CDATA[
         MERGE INTO TB_GGITS_ETLP L
             USING (SELECT
@@ -77,7 +77,7 @@
                        M.STR_TM,
                        M.END_TM )
         ]]>
-    </update>
+    </insert>
 
 
     <insert id="insertGgitsEtlpHist" parameterType="java.util.Map">
@@ -134,7 +134,7 @@
         ]]>
     </select>
 
-    <update id="updateTbInt" parameterType="java.util.Map">
+    <insert id="updateTbInt" parameterType="java.util.Map">
     <![CDATA[
         MERGE INTO TB_INT L
             USING (SELECT
@@ -195,9 +195,9 @@
                                M.UPD_DTIME,
                                M.BATCH_JOB_DEL )
         ]]>
-    </update>
+    </insert>
 
-    <update id="updateTbIntFlow" parameterType="java.util.Map">
+    <insert id="updateTbIntFlow" parameterType="java.util.Map">
     <![CDATA[
         MERGE INTO TB_INT_FLOW L
             USING (SELECT
@@ -265,9 +265,9 @@
                                M.FLOW_E_LNG,
                                M.COLLCT_DTIME )
         ]]>
-    </update>
+    </insert>
 
-    <update id="updateTbIntPhase" parameterType="java.util.Map">
+    <insert id="updateTbIntPhase" parameterType="java.util.Map">
     <![CDATA[
         MERGE INTO TB_INT_PHASE L
             USING (SELECT
@@ -303,9 +303,9 @@
                                M.FLOW_NUM_VAL,
                                M.BATCH_JOB_DEL )
         ]]>
-    </update>
+    </insert>
 
-    <update id="updateTbIntOperPlan" parameterType="java.util.Map">
+    <insert id="updateTbIntOperPlan" parameterType="java.util.Map">
     <![CDATA[
         MERGE INTO TB_INT_OPER_PLAN L
             USING (SELECT
@@ -413,9 +413,9 @@
                                M.B_RING_7_PHASE_VAL,
                                M.B_RING_8_PHASE_VAL )
         ]]>
-    </update>
+    </insert>
 
-    <update id="updateTbIntDyPlan" parameterType="java.util.Map">
+    <insert id="updateTbIntDyPlan" parameterType="java.util.Map">
     <![CDATA[
         MERGE INTO TB_INT_DY_PLAN L
             USING (SELECT
@@ -444,9 +444,9 @@
                                M.PLAN_DY,
                                M.COLLCT_DTIME )
         ]]>
-    </update>
+    </insert>
 
-    <update id="updateTbIntResrvPlan" parameterType="java.util.Map">
+    <insert id="updateTbIntResrvPlan" parameterType="java.util.Map">
     <![CDATA[
         MERGE INTO TB_INT_RESRV_PLAN L
             USING (SELECT
@@ -507,9 +507,9 @@
                                M.RESRV_PLAN_NO,
                                M.COLLCT_DTIME )
         ]]>
-    </update>
+    </insert>
 
-    <update id="updateTbIntSignalMap" parameterType="java.util.Map">
+    <insert id="updateTbIntSignalMap" parameterType="java.util.Map">
     <![CDATA[
         MERGE INTO TB_INT_SIGNALMAP L
             USING (SELECT
@@ -617,6 +617,6 @@
                                M.MAX_TM,
                                M.EOP )
         ]]>
-    </update>
+    </insert>
 
 </mapper>

kafka.txt

@@ -0,0 +1,3 @@
+192.168.11.23
+ssh -p 22 cvim@192.168.11.23
+

readme2.txt

@@ -0,0 +1,12 @@
+
+signal db connect information
+
+id
+siguser
+pwd
+siguser
+tns
+SIGDB
+
+
+

sig-comm-server/build.gradle

@@ -39,6 +39,7 @@ dependencies {
     implementation 'com.its:its-common:0.0.1'
     implementation 'com.its:its-network:0.0.1'
     implementation 'com.its:its-spring:0.0.1'
+    implementation 'com.its:its-cluster:0.0.1'
 
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
 

sig-comm-server/src/main/resources/mybatis/mapper/IntMapper.xml

@@ -167,7 +167,7 @@
         ]]>
     </select>
 
-    <update id="initIntStts">
+    <insert id="initIntStts">
     <![CDATA[
         MERGE INTO TB_INT_STATUS L
             USING (SELECT A.REGION_CD, B.INT_NO
@@ -181,9 +181,9 @@
                 INSERT (REGION_CD, INT_NO)
                 VALUES (M.REGION_CD, M.INT_NO)
         ]]>
-    </update>
+    </insert>
 
-    <update id="initIntPlan">
+    <insert id="initIntPlan">
     <![CDATA[
         MERGE INTO TB_INT_PLAN L
             USING (SELECT A.REGION_CD, B.INT_NO, C.IDX AS INT_PLAN_NO
@@ -198,9 +198,9 @@
                 INSERT (REGION_CD, INT_NO, INT_PLAN_NO)
                 VALUES (M.REGION_CD, M.INT_NO, M.INT_PLAN_NO)
         ]]>
-    </update>
+    </insert>
 
-    <update id="initIntOperPlan">
+    <insert id="initIntOperPlan">
     <![CDATA[
         MERGE INTO TB_INT_OPER_PLAN L
             USING (SELECT A.REGION_CD, B.INT_NO, C.INT_PLAN_NO, C.INT_PLAN_IDX_NO
@@ -219,9 +219,9 @@
                 INSERT (REGION_CD, INT_NO, INT_PLAN_NO, INT_PLAN_IDX_NO)
                 VALUES (M.REGION_CD, M.INT_NO, M.INT_PLAN_NO, M.INT_PLAN_IDX_NO)
         ]]>
-    </update>
+    </insert>
 
-    <update id="initIntDyPlan">
+    <insert id="initIntDyPlan">
     <![CDATA[
         MERGE INTO TB_INT_DY_PLAN L
             USING (SELECT A.REGION_CD, B.INT_NO, C.IDX AS PLAN_DY
@@ -237,9 +237,9 @@
                 INSERT (REGION_CD, INT_NO, PLAN_DY, INT_PLAN_NO)
                 VALUES (M.REGION_CD, M.INT_NO, M.PLAN_DY, 1)
         ]]>
-    </update>
+    </insert>
 
-    <update id="initIntResrvPlan">
+    <insert id="initIntResrvPlan">
     <![CDATA[
         MERGE INTO TB_INT_RESRV_PLAN L
             USING (SELECT A.REGION_CD, B.INT_NO, C.IDX AS RESRV_NO
@@ -254,9 +254,9 @@
                 INSERT (REGION_CD, INT_NO, RESRV_NO)
                 VALUES (M.REGION_CD, M.INT_NO, M.RESRV_NO)
         ]]>
-    </update>
+    </insert>
 
-    <update id="initIntHolyDdPlan">
+    <insert id="initIntHolyDdPlan">
     <![CDATA[
         MERGE INTO TB_INT_HOLYDD_PLAN L
             USING (SELECT A.REGION_CD, B.INT_NO, C.IDX AS PLAN_SN
@@ -271,9 +271,9 @@
                 INSERT (REGION_CD, INT_NO, PLAN_SN)
                 VALUES (M.REGION_CD, M.INT_NO, M.PLAN_SN)
         ]]>
-    </update>
+    </insert>
 
-    <update id="initIntSignalMap">
+    <insert id="initIntSignalMap">
     <![CDATA[
         MERGE INTO TB_INT_SIGNALMAP L
             USING (SELECT A.REGION_CD, A.INT_NO, B.RING_NO, B.PLAN_TP, B.STEP_NO
@@ -296,7 +296,7 @@
                 INSERT (REGION_CD, INT_NO, RING_NO, PLAN_TP, STEP_NO)
                 VALUES (M.REGION_CD, M.INT_NO, M.RING_NO, M.PLAN_TP, M.STEP_NO)
         ]]>
-    </update>
+    </insert>
 
     <update id="updateIntPhaseChange" parameterType="java.util.Map">
     <![CDATA[

sig-todp-server/build.gradle

@@ -38,6 +38,7 @@ dependencies {
     implementation 'com.its:its-common:0.0.1'
     implementation 'com.its:its-network:0.0.1'
     implementation 'com.its:its-spring:0.0.1'
+    implementation 'com.its:its-cluster:0.0.1'
 
     testImplementation 'org.springframework.boot:spring-boot-starter-test'