aclisp · December 12, 2019 09:32 · Dec 12, 2019
diff --git a/mongo.js b/mongo.js
@@ -0,0 +1,48 @@
+var now = Math.floor(Date.now() / 1000)
+
+var db = connect("10.70.0.140:10002/admin", "ikdx_admin", "vws6XGl78Q4D")
+db = db.getSiblingDB("channel_biz")
+
+var table = db.getCollection('fixed_pos_channels')
+
+var cursor = table.aggregate([
+        {"$group": {_id:"$cid", count:{$sum:1}}}
+])
+
+var dup_cid = []
+
+// 找出所有的重复cid
+while ( cursor.hasNext() ) {
+        row = cursor.next()
+        if (row.count > 1) {
+                dup_cid.push(row._id)
+        }
+}
+
+var delete_id = []
+
+// 只保留最新时间段的cid
+function keep_latest(cid) {
+        var cursor = table.find({"cid": cid})
+        while ( cursor.hasNext() ) {
+                row = cursor.next()
+                remove = " "
+                if (row.end_time < now) {
+                        remove = "!"
+                        delete_id.push(row._id)
+                }
+                print(remove, row.short_cid, row.cid, row.start_time, row.end_time)
+        }
+}
+
+for (var i=0; i<dup_cid.length; i++) {
+        cid = dup_cid[i]
+        keep_latest(cid)
+}
+
+// 删除之前备份表
+
+for (var i=0; i<delete_id.length; i++) {
+        id = delete_id[i]
+        table.remove({_id: id})
+}