connection problem fixed

eda/smart_rank/tool.py

@@ -391,6 +391,10 @@ def get_tag3_user_log(cl_id):
                  from kafka_tag3_log where cl_id = '{}'""".format(cl_id)
 
         db, cursor = get_jerry_test()
+        # print('connection stauts 1:', db.open)
+        db.close()
+        db.ping(reconnect=True)
+        # print('connection stauts 2:', db.open)
         cursor.execute(sql)
         data = list(cursor.fetchall())
         db.close()
@@ -460,6 +464,10 @@ def get_user_portrait_log(cl_id):
                  second_demands, first_positions, second_positions, projects, score_type
                  from kafka_tag3_log where cl_id = '{}' """.format(cl_id)
         db, cursor = get_jerry_test()
+        # print('connection stauts 1:', db.open)
+        db.close()
+        db.ping(reconnect=True)
+        # print('connection stauts 2:', db.open)
         cursor.execute(sql)
         data = list(cursor.fetchall())
         db.close()
@@ -554,32 +562,16 @@ def write_user_portrait_action_divided(cl_id,event_cn,score,first_solutions, sec
         today = datetime.date.today()
         oneday = datetime.timedelta(days=1)
         yesterday = today - oneday
-        print('%'*100)
-        print(type(yesterday))
-        print(type(score))
-
-        # sql = """insert into user_portrait_action_divided_score values(null, '{}', '{}', '{}', '{}', '{}', '{}', '{}', '{}', '{}', '{}')""".format(
-        #     yesterday, cl_id,event_cn, ",".join(first_solutions), ",".join(second_solutions), ",".join(first_demands),
-        #     ",".join(second_demands), ",".join(first_positions), ",".join(second_positions), ",".join(projects))
-
-        # sql = """insert into user_portrait_test3 values(null, '{}', '{}', '{}')""".format(
-        #     yesterday, cl_id, score)
-
-        # sql = """insert into user_portrait_test values(null, '{}', '{}', '{}')""".format(
-        #     yesterday, cl_id,score)
-
-        # sql = """insert into user_portrait_test2 values(null, '{}', '{}','{}')""".format(
-        #     yesterday,cl_id, score)
-
-        # sql = """insert into user_portrait_action_divided_score values(null, '{}', '{}', '{}', '{}', '{}', '{}', '{}', '{}', '{}', '{}')""".format(
-        #     yesterday, cl_id,event_cn,  ",".join(first_solutions),  ",".join(second_solutions), ",".join(first_demands), ",".join(second_demands),",".join(first_positions),
-        #     ",".join(second_positions), ",".join(projects),",".join(score))
 
         sql = """insert into user_portrait_action_divided_score values(null, '{}', '{}', '{}', '{}', '{}', '{}', '{}', '{}', '{}', '{}', '{}')""".format(
             yesterday, cl_id,event_cn, ",".join(first_solutions), ",".join(second_solutions), ",".join(first_demands),
             ",".join(second_demands), ",".join(first_positions), ",".join(second_positions), ",".join(projects),score)
 
         db, cursor = connect_mysql()
+        # print('connection stauts 1:', db.open)
+        db.close()
+        db.ping(reconnect=True)
+        # print('connection stauts 2:', db.open)
         # db, cursor = get_jerry_test()
         cursor.execute(sql)
         db.commit()