Commit 3c085f2c by 刘豪

update

parent 7c29c48a
Showing with 35 additions and 40 deletions
...@@ -64,13 +64,13 @@ class TsCrm: ...@@ -64,13 +64,13 @@ class TsCrm:
print("遍历第{}组".format(index)) print("遍历第{}组".format(index))
outter_uids = [] outter_uids = []
str_outter_uids_list = [] str_outter_uids_list = []
for i in row: for i in [65506,67743]:
outter_uid = i[0] outter_uid = i
user_id = i[1] user_id = i
self.dd[outter_uid] = { self.dd[outter_uid] = {
'user_id': user_id, 'user_id': user_id,
'outter_uid': outter_uid, 'outter_uid': outter_uid,
'is_order': 0, 'is_order': 1,
'last_order_time': 0, 'last_order_time': 0,
'order_num': 0, 'order_num': 0,
'model_num': 0, 'model_num': 0,
...@@ -82,19 +82,9 @@ class TsCrm: ...@@ -82,19 +82,9 @@ class TsCrm:
outter_uids.append(outter_uid) outter_uids.append(outter_uid)
str_outter_uids_list.append(str(outter_uid)) str_outter_uids_list.append(str(outter_uid))
str_outter_uids = ",".join(str_outter_uids_list) str_outter_uids = ",".join(str_outter_uids_list)
self.is_order(str_outter_uids)
for outter_uid in outter_uids: self.order_num(str_outter_uids)
user_ids = self.is_order(str_outter_uids) self.model_num(str_outter_uids)
if outter_uid in user_ids:
self.dd[outter_uid]["is_order"] = 2
else:
self.dd[outter_uid]['is_order'] = 1
sql = "SELECT count(order_id) FROM lie_order WHERE user_id = %d AND is_type = 0 AND order_type = 1 AND status = 10" % outter_uid
order = self.read(self.cursor, self.db, sql)
self.dd[outter_uid]['order_num'] = order[0]["count(order_id)"]
sql = "SELECT count(i.goods_id) FROM lie_order_items i LEFT JOIN lie_order o ON i.order_id = o.order_id WHERE o.user_id = %d AND i.status = 1 AND o.is_type = 0 AND o.order_type = 1 AND o.status = 10" % outter_uid
model = self.read(self.cursor, self.db, sql)
self.dd[outter_uid]['model_num'] = model[0]["count(i.goods_id)"]
self.last_order(str_outter_uids) self.last_order(str_outter_uids)
self.order_amount(str_outter_uids) self.order_amount(str_outter_uids)
self.paid_amount(str_outter_uids) self.paid_amount(str_outter_uids)
...@@ -102,15 +92,14 @@ class TsCrm: ...@@ -102,15 +92,14 @@ class TsCrm:
self.iap_data(outter_uids) self.iap_data(outter_uids)
def is_order(self, str_outter_uids): def is_order(self, str_outter_uids):
user_ids = []
try: try:
# sql = "SELECT 1 FROM lie_order WHERE user_id = %d AND is_type = 0 AND order_type = 1" % outter_uid # sql = "SELECT 1 FROM lie_order WHERE user_id = %d AND is_type = 0 AND order_type = 1" % outter_uid
sql = "SELECT user_id FROM lie_order WHERE user_id in (%s) AND is_type = 0 AND order_type = 1" % str_outter_uids sql = "SELECT user_id FROM lie_order WHERE user_id in (%s) AND is_type = 0 AND order_type = 1" % str_outter_uids
order = self.read(self.cursor, self.db, sql) order = self.read(self.cursor, self.db, sql)
user_ids = list(set([o["user_id"] for o in order])) for o in order:
self.dd[o["user_id"]]["is_order"] = 2
except Exception as e: except Exception as e:
print(e) print(e)
return user_ids
def last_order(self, str_outter_uids): def last_order(self, str_outter_uids):
try: try:
...@@ -122,26 +111,32 @@ class TsCrm: ...@@ -122,26 +111,32 @@ class TsCrm:
self.dd[o["user_id"]]['last_order_time'] = o["create_time"] self.dd[o["user_id"]]['last_order_time'] = o["create_time"]
except Exception as e: except Exception as e:
print(e) print(e)
#
#
# def order_num(self, outter_uids): def order_num(self, str_outter_uids):
# for outter_uid in outter_uids: try:
# try: sql = "SELECT user_id FROM lie_order WHERE user_id in (%s) AND is_type = 0 AND order_type = 1 AND status = 10" % str_outter_uids
# sql = "SELECT count(order_id) FROM lie_order WHERE user_id = %d AND is_type = 0 AND order_type = 1 AND status = 10" % outter_uid order = self.read(self.cursor, self.db, sql)
# order = self.read(self.cursor, self.db, sql) user_ids = []
# self.dd[outter_uid]['order_num'] = order[0]["count(order_id)"] for o in order:
# except Exception as e: user_ids.append(o["user_id"])
# print(e) for i in set(user_ids):
self.dd[i]['order_num'] = user_ids.count(i)
# def model_num(self): except Exception as e:
# for outter_uid in self.dd: print(e)
# try:
# sql = "SELECT count(i.goods_id) FROM lie_order_items i LEFT JOIN lie_order o ON i.order_id = o.order_id WHERE o.user_id = %d AND i.status = 1 AND o.is_type = 0 AND o.order_type = 1 AND o.status = 10" % outter_uid def model_num(self, str_outter_uids):
# model = DBHandler.read(self.db, sql) try:
# model_num = model[0][0] sql = "SELECT o.user_id FROM lie_order_items i LEFT JOIN lie_order o ON i.order_id = o.order_id WHERE o.user_id in (%s) AND i.status = 1 AND o.is_type = 0 AND o.order_type = 1 AND o.status = 10" % str_outter_uids
# self.dd[outter_uid]['model_num'] = model_num model = self.read(self.cursor, self.db, sql)
# except: user_ids = []
# self.dd[outter_uid]['model_num'] = 0 for o in model:
user_ids.append(o["user_id"])
for i in set(user_ids):
self.dd[i]['model_num'] = user_ids.count(i)
except Exception as e:
print(e)
def order_amount(self, str_outter_uids): def order_amount(self, str_outter_uids):
try: try:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment