写入飞书表成功，支持列计算，

feishu/feishu.py

@@ -79,7 +79,7 @@ class Feishu(object):
             }
         }
         response = requests.request("POST", url=insert_value_url, headers=headers, json=body)
-        print(response.json())
+        # print(response.json())
 
     def bot(self, platform_name, flag=1):
         """

manager.py

@@ -5,12 +5,14 @@ import numpy as np
 
 from feishu.feishu import Feishu
 from applications.mysql import Mysql
+from applications.config import platform_map
 
 
 class FeishuManager(object):
     """
     写入飞书管理器
     """
+
     def __init__(self):
         self.F = Feishu()
         self.M = Mysql()
@@ -19,8 +21,28 @@ class FeishuManager(object):
             "产品实验": "gwzBOM",
             "广告实验": "Pt6JUj",
             "产品/广告实验": "avHzKO",
+            " 产品/广告实验": "avHzKO",
             "算法实验": "MFwgBr",
-            "广告类型策略实验": "XCCAOP"
+            "广告类型策略实验": "XCCAOP",
+            "广告类型策略实验层": "XCCAOP"
+        }
+        self.subject_map = {
+            "小程序分享人数": "微信分享人数",
+            "小程序分享次数": "微信分享次数",
+            "小程序访问人数": "微信访问人数",
+            "广告 eCPM": "腾讯CPM",
+            "广告收入": "腾讯收入",
+            "广告曝光人数": "腾讯曝光人数",
+            "广告曝光次数": "腾讯曝光次数"
+        }
+        self.order_map = {
+            "腾讯曝光次数": 0,
+            "腾讯曝光人数": 1,
+            "腾讯CPM": 2,
+            "腾讯收入": 11,
+            "微信访问人数": 14,
+            "微信分享人数": 15,
+            "微信分享次数": 16
         }
 
     def select(self, minigram, date, task_name):
@@ -29,22 +51,16 @@ class FeishuManager(object):
         :param task_name: 实验名称
         :param minigram: 小程序名称
         :param date: 日期
-        :return: data_list
+        :return: data_dict
         """
         select_sql = f"""SELECT * FROM we_analysis_results where mini_program = '{minigram}' and date = '{date}' and task_name = '{task_name}';"""
         we_tuple = self.M.select(select_sql)
-        init_list = []
+        data_dict = {}
         for line in we_tuple:
-            result = [i for i in ([line[3]] + list(line[5:]))]
-            init_list.append(result)
-        # We分析矩阵
-        we_array = np.transpose(init_list)
-        we_array_v2 = we_array[1:, :]
-        # 去掉全部是0的行
-        non_zero_rows = np.any(we_array_v2 != 0, axis=1)
-        we_array_v3 = we_array_v2[non_zero_rows]
-        we_list = we_array_v3.tolist()
-        return we_list
+            result = list(line[5:])
+            key = line[3]
+            data_dict[key] = result
+        return data_dict
 
     def insert(self, we_list, date, mini_program, task_name):
         """
@@ -63,14 +79,39 @@ class FeishuManager(object):
         self.F.insert_value(
             sheet_id=self.map[task_name],
             values=datas,
-            ranges="A4:AW24"
+            ranges="A4:CI{}".format(4 + len(datas))
         )
 
+    def process_data_dict(self, data_dict):
+        """
+        把数据处理成格式
+        :param data_dict: we-analysis-information
+        :return:
+        """
+        init_array = np.zeros((25, 80))
+        for key in data_dict.keys():
+            sub_data = np.array(data_dict[key])
+            index = self.order_map[self.subject_map[key]]
+            init_array[:, index] = sub_data
+        non_zero_rows = np.any(init_array != 0, axis=1)
+        init_array = init_array[non_zero_rows]
+        # 处理其他数据指标
+        wechat_uv = np.where(init_array[:, 14] == 0, 0, init_array[:, 1] / init_array[:, 14])
+        personal_expose = np.where(init_array[:, 1] == 0, 0, init_array[:, 0] / init_array[:, 1])
+        total_arpu = np.where(init_array[:, 14] == 0, 0, (init_array[:, 11] + init_array[:, 12]) / init_array[:, 14])
+        init_array[:, 10] = wechat_uv
+        init_array[:, 3] = personal_expose
+        init_array[:, 13] = total_arpu
+        we_list = init_array.tolist()
+        return we_list
+
 
 if __name__ == '__main__':
     Fm = FeishuManager()
-    account_name = "票圈内容精选"
     date_str = "2024-01-17"
-    temp = Fm.select(account_name, date_str)
-    Fm.insert(temp, date_str, account_name)
-
+    for account_name in platform_map.keys():
+        for task_n in platform_map[account_name].keys():
+            temp = Fm.select(account_name, date_str, task_n)
+            temp_list = Fm.process_data_dict(temp)
+            Fm.insert(temp_list, date_str, account_name, task_n)
+            print(account_name, task_n)