Parcourir la source

rpeort_push: 条件sql的时间范围

Signed-off-by: binren <zhangbr@elab-plus.com>
binren il y a 5 ans
Parent
commit
a48824cebd
1 fichiers modifiés avec 6 ajouts et 3 suppressions
  1. 6 3
      report_push.py

+ 6 - 3
report_push.py

@@ -457,6 +457,7 @@ class ReportPush(object):
 
     def __init__(self, db_name):
         self.db = MysqlDB(db_name)
+        pass
 
     mails = ['1285211525@qq.com', 'lijm@elab-plus.com', 'xuanxc@elab-plus.com', 'zhuyl@elab-plus.com']
 
@@ -759,11 +760,13 @@ class ReportPush(object):
         number_2 = data_2[0][0]
         result.append(number_2)
         # 3:新增获客
-        data_3 = self.db.select(self.sql_1_4, [time_range[0], time_range[1], house_ids, time_range[0], time_range[1], house_ids])
+        time_1 = time_range[0] + ' 00:00:00'
+        time_2 = time_range[1] + ' 23:59:59'
+        data_3 = self.db.select(self.sql_1_4, [time_1, time_2, house_ids, time_1, time_2, house_ids])
         number_3 = data_3[0][0]
         result.append(number_3)
         # 4:新增获电
-        data_4 = self.db.select(self.sql_1_5, [time_range[0], time_range[1], house_ids, house_ids, time_range[0], time_range[1]])
+        data_4 = self.db.select(self.sql_1_5, [time_1, time_2, house_ids, house_ids, time_1, time_2])
         number_4 = data_4[0][0]
         result.append(number_4)
         xcx_top_data_part = [x for x in xcx_top_data if x[0] in house_ids]
@@ -1088,4 +1091,4 @@ class ReportPush(object):
 
 if __name__ == '__main__':
     rp = ReportPush('linshi')
-    print(rp.get_time_range(2))
+    times = rp.get_time_range(1)