status

src/main/java/com/glxp/api/idc/service/impl/IdcServiceImpl.java

@@ -239,6 +239,7 @@ public class IdcServiceImpl implements IdcService {
         }
     }
 
+   
     /*数据删除同步*/
     private void asyncDelete(String tname,boolean isUpload,String syncIp) {
         String[] tnames = tname.split("/");
@@ -306,7 +307,7 @@ public class IdcServiceImpl implements IdcService {
                    } else {
                        saveIdcLog(tnames[9], "", tnames[2] + ">success(delete)", i * limit, total);
                    }
-                   syncAddTaskStatus(msg, isUpload ? 1 : 0, success, startTime, isUpload);
+                   syncAddTaskStatus(msg, isUpload ? 1 : 0, true, startTime, isUpload,success);
                 }
             }
         }
@@ -390,6 +391,7 @@ public class IdcServiceImpl implements IdcService {
                     setUpdateTime(tnames[2] + "." + tnames[0]+"."+tnames[1], DateUtil.formatDate(nowUpdateTime, "yyyy-MM-dd HH:mm:ss"));
                 }
             }
+            
             //}
         } catch (Exception ex) {
 
@@ -425,11 +427,11 @@ public class IdcServiceImpl implements IdcService {
                 } else {
                     success = false;
                 }
-                syncAddTaskStatus(json.getJSONObject("data"), 3, success, startTime, true);
+                syncAddTaskStatus(json.getJSONObject("data"), 3, true, startTime, true,success);
             } else {
                 if (json.get("code") != null && json.get("data") != null) {
                     //logger.info("res1-->"+JSON.toJSONString(json));
-                    syncAddTaskStatus(json.getJSONObject("data"), 0, success, startTime, true);
+                    syncAddTaskStatus(json.getJSONObject("data"), 0, true, startTime, true,success);
                     analyMiddle(host, json.getJSONObject("data"), files, false, false);
                 }
             }
@@ -517,7 +519,7 @@ public class IdcServiceImpl implements IdcService {
         boolean success = false;
         if (isLastLevel()) {
             success = analyMiddle("", json, files, true, true);
-            syncAddTaskStatus(json, 3, success, startTime, true);
+            syncAddTaskStatus(json, 3, true, startTime, true,success);
             if (!success) {
 
                 return ResultVOUtils.error(9000, "解析失败");
@@ -528,11 +530,11 @@ public class IdcServiceImpl implements IdcService {
                 String host = getNextHost();
                 String result = relay(request.getHeader("reqNo"), content, saveFiles, host);
                 if (IDCUtils.isJson(result)) {
-                    syncAddTaskStatus(json, 2, true, startTime, true);
+                    syncAddTaskStatus(json, 2, true, startTime, true,true);
                     BaseResponse object = JSON.parseObject(result, BaseResponse.class);
                     return object;
                 } else {
-                    syncAddTaskStatus(json, 2, false, startTime, false);
+                    syncAddTaskStatus(json, 2, true, startTime, false,false);
                     return ResultVOUtils.error(9000, "转发失败");
                 }
 
@@ -592,9 +594,6 @@ public class IdcServiceImpl implements IdcService {
     private void saveExportStatus(Map<String, Object> params) {
         Map<String, Object> map = new HashMap<String, Object>();
         map.putAll(params);
-        map.put("receiveStatus", "0");
-
-
         Map<String, Object> columns = getColumn("basic_export_status");
         String sql = "replace basic_export_status " + DBAUtils.parseInsert(map, columns);
 
@@ -603,7 +602,6 @@ public class IdcServiceImpl implements IdcService {
 
     private void saveDownloadStatus(Map<String, Object> params) {
         Map<String, Object> map = new HashMap<String, Object>();
-        map.put("receiveStatus", "0");
         map.putAll(params);
 
         Map<String, Object> columns = getColumn("basic_download_status");
@@ -763,7 +761,7 @@ public class IdcServiceImpl implements IdcService {
                             }
                             saveIdcLog(messageType, "", tableName + ">success", i * limit, total);
                         }
-                        syncAddTaskStatus(data, isUpload ? 1 : 0, success, startTime, isUpload);
+                        syncAddTaskStatus(data, isUpload ? 1 : 0, true, startTime, isUpload,success);
                     }
                 }
             }
@@ -775,7 +773,7 @@ public class IdcServiceImpl implements IdcService {
 
     /*增加同步任务状态*/
     private void syncAddTaskStatus(Map<String, Object> json, int scheduleType, boolean success, Date startTime,
-                                   boolean isEnd) {
+                                   boolean isEnd,boolean isReceive) {
         try {
             String content = JSON.toJSONString(json);
             String datePath = DateUtil.formatDate(new Date(), "yyyy-MM-dd");
@@ -800,6 +798,7 @@ public class IdcServiceImpl implements IdcService {
             map.put("taskId", json.get("messageId"));
             map.put("cacheFilePath", fileName);
             map.put("status", success ? "1" : "0");
+            map.put("receiveStatus", isReceive ? "1" : "0");
             map.put("startTime", startTime != null ? startTime : new Date());
             map.put("updateTime", new Date());
             map.put("remark", json.get("messageType") + ": " + json.get("total") + "条");
@@ -1204,6 +1203,7 @@ public class IdcServiceImpl implements IdcService {
         map.put("filePathColumn", params.get("filePathColumn"));
         map.put("sendTime", new Date());
         map.put("version", "1.0");
+        map.put("level", 0);
         map.put("total", list.size());
         map.put("data", list);
         return map;
@@ -1347,4 +1347,4 @@ public class IdcServiceImpl implements IdcService {
     }
 
 
-} 
+}