mvp: 修改清空数据逻辑

mysql_db: 增加删除方法

Signed-off-by: binren <zhangbr@elab-plus.com>

mvp.py

@@ -86,7 +86,7 @@ class Mvp:
         """
         params = self.tag_table.get(tag_type_name)
         if params:
-            return self.base_insert_sql.format(params[0], [1])
+            return self.base_insert_sql.format(params[0], params[1])
 
     crowd = ['A', 'B', 'C', 'D', 'E', 'F']
 
@@ -228,6 +228,23 @@ class Mvp:
         AND a.STATUS = b.STATUS = 1
     '''
 
+    sql_18 = '''
+        DELETE
+        FROM
+            mvp_crowd_info_behavior
+        WHERE
+            crowd_info_id not IN (
+                SELECT
+                    GROUP_CONCAT(id)
+                FROM
+                    mvp_crowd_info
+                WHERE
+                    city_name = '上海市'
+                AND age_area = '85后'
+                AND STATUS = 1
+            )
+    '''
+
     """
         数据debug SQL
         1：
@@ -460,7 +477,10 @@ class Mvp:
                     if len(insert_data) > 0:
                         table_name = self.get_table_name(key)
                         if table_name:
-                            self.linshi_db.truncate(table_name)
+                            if table_name == 'mvp_crowd_info_behavior':
+                                self.linshi_db.delete(self.sql_18)
+                            else:
+                                self.linshi_db.truncate(table_name)
                         self.linshi_db.add_some(insert_sql, insert_data)
                 else:
                     print('未找到对应的表，数据无法插入...')
@@ -797,4 +817,4 @@ class Mvp:
 
 if __name__ == '__main__':
     mvp = Mvp()
-    mvp.people_info()
+    print(mvp.get_insert_sql('模块分数'))

mysql_db.py

@@ -30,6 +30,13 @@ class MysqlDB:
             self.cursor.execute(sql)
         return self.cursor.fetchall()
 
+    def delete(self, sql):
+        try:
+            self.cursor.execute(sql)
+            self.con.commit()
+        except:
+            self.con.rollback()
+
     def add_some(self, sql, data):
         try:
             self.cursor.executemany(sql, data)