同步工具类

query-app/src/main/java/db/util/ConvertFormat.java

@@ -0,0 +1,45 @@
+package db.util;
+
+import db.DBVal;
+import db.Globals;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+
+@Component
+@Slf4j
+public class ConvertFormat {
+    /**
+     * 将resodb查询到的id分配到各个磁盘文件中
+     *
+     * @param lists
+     */
+    public HashMap<Long, ArrayList<Integer>> convertToLongAndGetIndex(List<DBVal> lists) {
+        HashMap<Long, ArrayList<Integer>> map = new HashMap<>();
+        for (DBVal dbVal : lists) {
+            Long longId = Double.doubleToRawLongBits(dbVal.getValue());
+            long fileId = longId / Globals.MAX_LOG_ITEM;
+            int index = (int) (longId % Globals.MAX_LOG_ITEM);
+
+            ArrayList<Integer> arrayList = map.get(fileId);
+            if (arrayList == null) {
+                arrayList = new ArrayList<Integer>();
+                arrayList.add(index);
+                map.put(fileId, arrayList);
+            } else {
+                if (!arrayList.contains(index)) {
+                    arrayList.add(index);
+                }
+            }
+        }
+        for(Long item : map.keySet()){
+            Collections.sort(map.get(item));
+        }
+
+        return map;
+    }
+}