| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950 | # Author renyupeng# coding=utf-8# @Time    : 2021/10/26 10:15 上午# @Site    :# @File    : ReplaceAccountInfo.py# @Software: PyCharm# @contact: renyupeng@c-top.com.cn# @Tel 1501435553import loggingfrom Apietl.conn.TidbConn import TidbConnclass ReplaceAccountInfo:    @staticmethod    def handler():        try:            sql = """replace into `jeecg-boot`.ctop_account_attribution_info(id, account_id, project_id,product_id, advertiser_id, company_id,account_name, project_name, advertiser_name, company_name, sale_id, user_id,org_code)select cua.account_id,       cua.account_id,       cp.id,       product.id,       ca.id,       uc.company_id,       cua.auth_name,       cp.project_name,       ca.name,       uc.company_name,       cp.sale_id,       su.id,       su.org_codefrom `jeecg-boot`.ctop_user_allocation cua         left join `jeecg-boot`.ctop_project cp on cua.project_id = cp.id         left join `jeecg-boot`.ctop_advertiser ca on ca.id = cua.advertiser_id         left join `jeecg-boot`.sys_user su on su.id = cua.user_id         left join `jeecg-boot`.user_company uc on uc.user_id = cua.user_id         left join `jeecg-boot`.ctop_product product on product.id = cp.product_idwhere cua.account_id is not null            """            TidbConn.upsert(conn=TidbConn.get_connection(), sql_buff=sql)            TidbConn.get_connection().commit()            TidbConn.conn_close(conn=TidbConn.get_connection())        except Exception as e:            logging.error(e)if __name__ == '__main__':    ReplaceAccountInfo.handler()
 |