Kaynağa Gözat

tongce: 清洗规则调整

Signed-off-by: binren <zhangbr@elab-plus.com>
binren 5 yıl önce
ebeveyn
işleme
abf6a5576f
1 değiştirilmiş dosya ile 12 ekleme ve 10 silme
  1. 12 10
      tongce.py

+ 12 - 10
tongce.py

@@ -487,11 +487,13 @@ class TongCe:
         # self.linshi_db.truncate('mvp_page_display_match')
         # self.linshi_db.add_some(self.sql_3, match_data)
         self.match_data_info = self.get_option_match_info()
+        self.linshi_db.truncate('mvp_page_display_data')
 
         # 筛选写入data的数据
-        insert_data = []
+        count = 0
         no_data_case = []
         for ci in crowd_info:
+            insert_data = []
             crowd_info_id = ci[0]
             zhifuli = ci[1]
             age = ci[2]
@@ -525,21 +527,21 @@ class TongCe:
                                 no_data_case.append([zhifuli, city, age, juzhujiegou, option_name])
                     else:
                         no_data_case.append([zhifuli, city, age, juzhujiegou, key])
+            count += len(insert_data)
+            self.linshi_db.add_some(self.sql_6, insert_data)
+        isnert_data_all = []
         quanliang_scores = self.scores()
         for q_s in quanliang_scores:
             rule_id = self.get_rule_id(q_s[0], rule)
             if rule_id:
                 for md in self.match_data_info:
-                    if str(md[1]) == str(q_s[0]) and str(md[1]) == str(q_s[1]):
+                    if str(md[1]) == str(q_s[0]) and str(md[2]) == str(q_s[1]):
                         match_id = md[0]
                         option_name_alias = md[3]
-                        insert_data.append([5405, match_id, rule_id, option_name_alias, q_s[2]])
-
-        if len(insert_data) > 0:
-            self.linshi_db.truncate('mvp_page_display_data')
-            self.linshi_db.add_some(self.sql_6, insert_data)
-
-        return {'写入库中的数据': len(insert_data), '无数据': len(no_data_case)}
+                        isnert_data_all.append([5405, match_id, rule_id, option_name_alias, q_s[2]])
+        self.linshi_db.add_some(self.sql_6, isnert_data_all)
+        count += len(isnert_data_all)
+        return {'写入库中的数据': len(count), '无数据': len(no_data_case)}
 
     sql_20 = '''
             UPDATE mvp_page_display_rule
@@ -563,7 +565,7 @@ class TongCe:
         for answer in self.answers:
             if answer[0] == city and answer[3] == age and answer[4] == zhifuli and answer[5] == juzhujiegou:
                 # 子题id, 子题题目,子选项id,子选项题目
-                result.append([answer[8], answer[9], answer[10], answer[11]])
+                result.append([answer[8], answer[9], answer[12], answer[13]])
         return result
 
     def get_testcase_ids_by_house_name(self, house_name):