Commit 765c1770 authored by 任婷婷's avatar 任婷婷

.

parent 0943557e
......@@ -26,8 +26,6 @@ def get_user_portrait_log(cl_id):
sql = """select cl_id,event_cn, first_solutions, second_solutions, first_demands,
second_demands, first_positions, second_positions, projects
from kafka_tag3_log where cl_id in {} """.format(tuple(cl_id))
print('&'*100)
print("sql", sql)
db, cursor = get_jerry_test()
cursor.execute(sql)
data = list(cursor.fetchall())
......@@ -44,7 +42,7 @@ def user_portrait_action_statistic(cl_id):
ud_dict = {}
user_df = get_user_portrait_log(cl_id)
for ud in user_df:
print("ud", ud)
# print("ud", ud)
ud2_list = ud[2].split(",")
ud3_list = ud[3].split(",")
ud4_list = ud[4].split(",")
......@@ -63,7 +61,7 @@ def user_portrait_action_statistic(cl_id):
ud_dict[ud[0]][ud[1]]["second_positions"].extend(ud7_list)
ud_dict[ud[0]][ud[1]]["projects"].extend(ud8_list)
else:
print('*'*100)
ud_dict[ud[0]][ud[1]] = {}
ud_dict[ud[0]][ud[1]] = {"first_solutions": ud2_list, "second_solutions": ud3_list,
"first_demands": ud4_list, "second_demands": ud5_list,
......@@ -121,12 +119,12 @@ if __name__ == '__main__':
second_solutions = []
projects = []
cl_ids = [1, 3]
# cl_ids = [1,3]
cl_ids = ['3D878D3E-9C19-4CC9-BB7A-0082B38996F2', '03BF3310-C5AF-4049-8041-DC5ECE927A81']
data = user_portrait_action_statistic(cl_ids)
for key, values in data.items():
cl_id = key
print("val", values.keys())
for item in values.keys():
if values[item]:
first_solutions = values[item].get("first_solutions", [])
......
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 to comment