增加成功标志位

pom.xml

@@ -120,7 +120,7 @@
         <dependency>
             <groupId>com.alibaba</groupId>
             <artifactId>druid</artifactId>
-            <version>1.0.18</version>
+            <version>1.1.10</version>
         </dependency>
 
         <!--SpringBoot 使用 JDBCTemplate 引用下面这个包才会自动注入,不要引用上面按个-->

src/main/java/com/winhc/common/enums/CompanyEnum.java

@@ -21,7 +21,8 @@ public class CompanyEnum {
         LEGAL_ENTITY_RELATION_V1("4", "legalEntityRelationV1ServiceImpl"),
         LEGAL_ENTITY_RELATION_V2("5", "legalEntityRelationV2ServiceImpl"),
         STAFF_RELATION("6", "staffRelationServiceImpl"),
-        PERSON_NODE_LABEL("7", "personNodeLabelServiceImpl");
+        PERSON_NODE_LABEL("7", "personNodeLabelServiceImpl"),
+        NODE_RELATION_SUCCESS_STATUS("100", "nodeRelationSuccessStatusServiceImpl");
 
         public final String CODE;
         public final String VALUE;

src/main/java/com/winhc/kafka/consumer/KafkaConsumerNeo4jV2.java

@@ -42,6 +42,7 @@ public class KafkaConsumerNeo4jV2 {
         this.map.get(CompanyEnum.TopicType.LEGAL_ENTITY_RELATION_V2.VALUE).save(CompanyUtils.filterList(listMap, CompanyEnum.TopicType.LEGAL_ENTITY_RELATION_V2.CODE));
         this.map.get(CompanyEnum.TopicType.STAFF_RELATION.VALUE).save(CompanyUtils.filterList(listMap, CompanyEnum.TopicType.STAFF_RELATION.CODE));
         this.map.get(CompanyEnum.TopicType.PERSON_NODE_LABEL.VALUE).save(CompanyUtils.filterList(listMap, CompanyEnum.TopicType.PERSON_NODE_LABEL.CODE));
+        this.map.get(CompanyEnum.TopicType.NODE_RELATION_SUCCESS_STATUS.VALUE).save(CompanyUtils.filterList(listMap, CompanyEnum.TopicType.NODE_RELATION_SUCCESS_STATUS.CODE));
     }
 
 

src/main/java/com/winhc/service/impl/NodeRelationSuccessStatusServiceImpl.java

@@ -0,0 +1,39 @@
+package com.winhc.service.impl;
+
+import com.winhc.service.RelationService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author π
+ * @Description:成功状态
+ * @date 2021/1/11 10:03
+ */
+@Slf4j
+@Service("nodeRelationSuccessStatusServiceImpl")
+@AllArgsConstructor
+public class NodeRelationSuccessStatusServiceImpl implements RelationService {
+
+
+    @Autowired
+    JdbcTemplate jdbcTemplate;
+
+    @Override
+    public String save(List<Map<String, Object>> batch_list) {
+        if (batch_list.isEmpty()) return null;
+        long start = System.currentTimeMillis();
+        Map<String, Object> map = batch_list.get(0);
+        String ds = String.valueOf(map.getOrDefault("ds", "-1"));
+        String status = String.valueOf(map.getOrDefault("status", "-1"));
+        String topic_type = String.valueOf(map.getOrDefault("topic_type", "-1"));
+        String sql = "REPLACE INTO node_relation_success_status VALUES (" + ds + ", " + status + ", " + topic_type + ", now())";
+        jdbcTemplate.execute(sql);
+        log.info("save success status | sql:{} |, | cost:{} | !", sql, (System.currentTimeMillis() - start));
+        return "success";
+    }
+}

src/main/resources/application-prd.properties

@@ -14,9 +14,10 @@ spring.data.neo4j.uri=bolt://192.168.2.57:7687
 #spring.datasource.url = jdbc:mysql://rm-uf61r3m23ba1p5z3dfo.mysql.rds.aliyuncs.com:3306/prism1?useUnicode=true&characterEncoding=utf-8
 
 #内网地址
-#spring.datasource.url = jdbc:mysql://rm-uf61r3m23ba1p5z3d.mysql.rds.aliyuncs.com:3306/prism1?useUnicode=true&characterEncoding=utf-8
-#spring.datasource.username = wenshu
-#spring.datasource.password = wenshu_168
+spring.datasource.url = jdbc:mysql://rm-uf61r3m23ba1p5z3d.mysql.rds.aliyuncs.com:3306/prism1?useUnicode=true&characterEncoding=utf-8
+spring.datasource.username = wenshu
+spring.datasource.password = wenshu_168
+spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
 
 scheduling.enabled = true
 

src/main/resources/application.properties

@@ -26,6 +26,7 @@ spring.messages.encoding=UTF-8
 spring.datasource.url = jdbc:mysql://rm-uf61r3m23ba1p5z3dfo.mysql.rds.aliyuncs.com:3306/prism1?useUnicode=true&characterEncoding=utf-8
 spring.datasource.username = wenshu
 spring.datasource.password = wenshu_168
+spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
 
 
 spring.datasource.type=com.alibaba.druid.pool.DruidDataSource

src/test/java/com/winhc/test/TestMongo.java

@@ -2,6 +2,7 @@ package com.winhc.test;
 
 import com.winhc.db.mongodb.dataobject.NodeRelationError;
 import com.winhc.db.mongodb.repository.NodeRelatonErrorRepository;
+import com.winhc.service.impl.NodeRelationSuccessStatusServiceImpl;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -9,6 +10,8 @@ import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringRunner;
 import java.util.ArrayList;
 import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
 
 /**
  * @author π
@@ -21,6 +24,8 @@ public class TestMongo {
     @Autowired
     NodeRelatonErrorRepository nodeRelatonErrorRepository;
 
+    @Autowired
+    NodeRelationSuccessStatusServiceImpl nodeRelationSuccessStatusServiceImpl;
     @Test
     public void saveData() {
         ArrayList<NodeRelationError> list = new ArrayList<>();
@@ -34,4 +39,14 @@ public class TestMongo {
         list.add(n1);
         nodeRelatonErrorRepository.saveAll(list);
     }
+    @Test
+    public void saveStaus() {
+        HashMap<String, Object> m = new HashMap<>();
+        m.put("topic_type","100");
+        m.put("ds","20210219");
+        m.put("status","1");
+        ArrayList<Map<String, Object>> list = new ArrayList<>();
+        list.add(m);
+        nodeRelationSuccessStatusServiceImpl.save(list);
+    }
 }