修改充值报表字段

app/api/statement/crud.py

@@ -101,10 +101,39 @@ class RechargeStatement(object):
 
     def __init__(self):
         self.linkmysql = LinkMysql(env.DB_HISTORY)
-        # self.count=[]
+        self.order_id = []
         # self.once_res=[]
         # self.moeny_data=[]
 
+    def user_order_data(self, query_data):
+        if not query_data:
+            return []
+        Logger().logger.info("获取order_id")
+        for bus in query_data:
+            ref_type, o_id = bus['reference_number'].split('_')
+            if o_id not in self.order_id:
+                self.order_id.append(o_id)
+        Logger().logger.info("获取筛选条件")
+        o_sql = f"SELECT o.id,o.money,o.userid,v.nick_name,o.status,o.paychannel,o.sid,o.current FROM orders as o LEFT JOIN v2_user as v on o.userid=v.user_id where o.id in{tuple(self.order_id)}"
+        order_data = LinkMysql(env.DB_3YV2).query_mysql(o_sql)
+        Logger().logger.info("查询支付配置")
+        p_sql = "SELECT id,name FROM pay_config"
+        pay_data = LinkMysql(env.DB_3YV2).query_mysql(p_sql)
+        pay_dict = {}
+        for i in pay_data:
+            pay_dict[i['id']] = i['name']
+        for x in query_data:
+            ref_type, o_id = x['reference_number'].split('_')
+            for y in order_data:
+                if o_id == str(y['id']):
+                    x['user_id'] = y['userid']
+                    x['nick_name'] = y['nick_name']
+                    x['status'] = y['status']
+                    x['paychannel'] = pay_dict.get(y['paychannel'], y['paychannel'])
+                    x['sid'] = y['sid']
+        Logger().logger.info(f"拼接的数据：{query_data[0]}")
+        return query_data
+
     def query_data(self, db, page, size, order_number, uuid, sid, start_time, end_time, type, menu_id, month_type,export_status):
         """列表"""
         query = []
@@ -145,7 +174,8 @@ class RechargeStatement(object):
         else:
             query_data = self.query_add_time(start_time, end_time, query)
             count, once_res, moeny_data = self.thread_data(month_type, query_data, page, size,start_time,end_time,export_status)
-        return count, once_res, moeny_data
+        result = self.user_order_data(once_res)
+        return count, result, moeny_data
 
     def query_add_time(self, start_time, end_time, old_query):
         data = []