commit

src/main/java/com/jz/dmp/modules/service/impl/DmpRealtimeSyncInfoServiceImpl.java

@@ -1049,6 +1049,7 @@ public class DmpRealtimeSyncInfoServiceImpl implements DmpRealtimeSyncInfoServic
      * kafka rest api 获取任务状态
      * */
     public String getExecuteKafkaStatus(String statusUrl, Map params) throws Exception {
+        String status = "";
         String respData = HttpClientUtils.getJsonForParam(statusUrl, new HashMap<>());
         if (StringUtils.isEmpty(respData)) {
             throw new RuntimeException("get status failed！");
@@ -1062,13 +1063,15 @@ public class DmpRealtimeSyncInfoServiceImpl implements DmpRealtimeSyncInfoServic
             return tasksStatus;
         }*/
         Map connector = (Map) map.get("connector");
+        if (null != connector && connector.size() > 0) {
             if (!connector.containsKey("state")) {
                 throw new RuntimeException("get status failed！");
             }
-        String status = (String) connector.get("state");
+            status = (String) connector.get("state");
             logger.info("response connector status{}" + status);
+        }
 
-        if (StringUtils.isNotEmpty((String) params.get("id"))) {
+        if (StringUtils.isNotEmpty((String) params.get("id")) && StringUtils.isEmpty(status)) {
             Thread thread = new Thread(new Runnable() {
                 @Override
                 public void run() {

src/main/resources/mapper/dmp/OfflineSynchMapper.xml

@@ -182,7 +182,7 @@
         left join dmp_member t3 on ddt.create_user_id=t3.user_id
         WHERE ddt.data_status ='1' and dnt.TYPE ='01' and dnt.IS_LEVEL ='1'
         and dnt.PROJECT_ID =#{projectId}
-        <if test="treeName != null and treeName != ''">dnt.NAME like concat('%',#{treeName},'%') </if>
+        <if test="treeName != null and treeName != ''">and dnt.NAME like concat('%',#{treeName},'%') </if>
         ORDER BY ddt.create_time DESC
     </select>
 </mapper>
\ No newline at end of file