xiatian пре 2 година
родитељ
комит
bc5403ffe7

+ 10 - 0
src/main/java/cn/com/qmth/scancloud/tools/service/impl/StructImportTask.java

@@ -6,7 +6,9 @@ import java.io.IOException;
 import java.io.InputStream;
 import java.io.InputStream;
 import java.util.ArrayList;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Arrays;
+import java.util.HashSet;
 import java.util.List;
 import java.util.List;
+import java.util.Set;
 
 
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -52,6 +54,14 @@ public class StructImportTask extends AbstractTask {
         }
         }
 
 
         List<Struct> structs = readData(examId);
         List<Struct> structs = readData(examId);
+        Set<String> keys=new HashSet<>();
+        for(Struct s:structs) {
+            String key=s.getExamId()+"-"+s.getPaperType()+"-"+s.getSubjectCode()+"-"+s.getMainNumber()+"-"+s.getSubNumber();
+            if(keys.contains(key)) {
+                throw new StatusException("数据重复, " + key);
+            }
+            keys.add(key);
+        }
         String url = SysProperty.SCAN_SERVER_URL + "/api/tool/import/cet/absent";// TODO
         String url = SysProperty.SCAN_SERVER_URL + "/api/tool/import/cet/absent";// TODO
         String json = JsonHelper.toJson(structs);
         String json = JsonHelper.toJson(structs);
         HttpHelper.post(url, json);
         HttpHelper.post(url, json);