import uuid

import psycopg2
import pymysql

host = "210.72.82.249"
user = "pom"
password = "pomWechat2020"
port = 3306
database = 'pomdb'
mysql = pymysql.connect(host=host,user=user,password=password,port=port,database=database)
cursor = mysql.cursor()
G2 = 'host=210.77.68.250 port=5432 dbname=newmediaDB3 user=newmedia password=newmedia2020!@#'


def insert(mp, title, content, author, timestamp, link,weixin_id):
    try:
        with psycopg2.connect(G2) as connection:
            with connection.cursor() as cursor1:
                cursor1.execute("select * from dashboard_weixin where weixinid = '%s'" % (weixin_id))
                r = cursor1.fetchall()
                for i in r:
                    with connection.cursor() as cursor:
                        id = uuid.uuid4()
                        cursor.execute(
                            "insert into dashboard_weixin_data(id,weixin_id, mp, title, content, author, timestamp, link,created,updated) values (%s,%s,%s,%s,%s,%s,%s,%s,now(),now() )"
                            , (str(id), i[0], mp, title, content, author, timestamp, link))
                        connection.commit()
    except:
        pass
if __name__ == '__main__':
    sql = 'select * from weixin_article'
    cursor.execute(sql)
    results = cursor.fetchall()
    for r in results:
        print(r)
        mp = r[1]
        title = r[2]
        content = r[3]
        author = r[4]
        timestamp = r[5]
        link = r[6]
        weixin_id = str(link).split('biz=')[1].split('&mid')[0]
        insert(mp, title, content, author, timestamp, link,weixin_id)