From 7e9d552bc54bc8fd4d30339d7c59fed2d74a3ae7 Mon Sep 17 00:00:00 2001
From: lwl0608 <lwl0608@foxmail.com>
Date: Mon, 5 Feb 2024 01:03:38 +0800
Subject: [PATCH] calc

---
 vas/calc_coins.py | 52 +++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 52 insertions(+)
 create mode 100644 vas/calc_coins.py

diff --git a/vas/calc_coins.py b/vas/calc_coins.py
new file mode 100644
index 0000000..b780e3a
--- /dev/null
+++ b/vas/calc_coins.py
@@ -0,0 +1,52 @@
+from lib.all import *
+
+mysql_db_vas = Mysql(
+    "rm-bp11t1616a1kjvmx5.mysql.rds.aliyuncs.com", 3306, "vas", "root", "Wishpal2024"
+)
+
+# mid充值数
+mid_charge_map = dict()
+mid_charge_list = mysql_db_vas.query('''
+select mid, sum(coins) total_coins from vas_order
+where order_status>0
+group by mid
+''')
+for item in mid_charge_list:
+    mid = safe_get_int(item, "mid")
+    total_coins = safe_get_int(item, "total_coins")
+    mid_charge_map[mid] = total_coins
+
+# mid消费
+mid_consume_map = dict()
+mid_consume_list = mysql_db_vas.query('''
+select mid, sum(coins) total_coins from vas_coin_order
+where order_status>0
+group by mid
+''')
+for item in mid_consume_list:
+    mid = safe_get_int(item, "mid")
+    total_coins = safe_get_int(item, "total_coins")
+    mid_consume_map[mid] = total_coins
+
+# mid钱包
+# mid消费
+mid_wallet_map = dict()
+mid_wallet_list = mysql_db_vas.query('''
+select mid, sum(coins) total_coins from vas_wallet
+where coins>0
+group by mid
+''')
+for item in mid_wallet_list:
+    mid = safe_get_int(item, "mid")
+    total_coins = safe_get_int(item, "total_coins")
+    mid_wallet_map[mid] = total_coins
+
+mids = list(set(
+    list(mid_charge_map.keys()) + list(mid_consume_map.keys()) + list(mid_wallet_map.keys())
+))
+for mid in mids:
+    charge = safe_get_int(mid_charge_map, mid)
+    consume = safe_get_int(mid_consume_map, mid)
+    wallet = safe_get_int(mid_wallet_map, mid)
+    if charge != mid + wallet:
+        print(mid, charge, consume, wallet)