o ÓkhÆã@sJddlZddlZddlmZddlZedƒdd„Zd dd„Zdd „ZdS) éN)Ú load_dotenvz../.envcCs,tjjt d¡t d¡t d¡t d¡dS)NÚDB_HOSTÚDB_USERÚ DB_PASSWORDÚDB_NAME)ÚhostÚuserÚpasswordÚdatabase)ÚmysqlÚ connectorÚconnectÚosÚgetenv©rrú,/var/www/html/fb-bots/crmconnect/db_utils.pyÚget_dbs ürc Csd| ¡} |  d|||f¡| ¡|  d||f¡|  ¡d} |  d|| ||||| f¡| ¡dS)Nz‘ INSERT INTO contact (name, number_or_email, source) VALUES (%s, %s, %s) ON DUPLICATE KEY UPDATE name = VALUES(name) zASELECT id FROM contact WHERE number_or_email = %s AND source = %srz” INSERT INTO message (user_id, contact_id, direction, content, timestamp, channel, subject) VALUES (%s, %s, %s, %s, %s, %s, %s) )ÚcursorÚexecuteÚcommitÚfetchone) ÚdbÚuser_idÚnameÚ identifierÚsourceÚ directionÚcontentÚ timestampÚchannelÚsubjectrÚ contact_idrrrÚ save_messagesü ý r"cCsJ| dd¡}| dd¡}| dd¡}t dd|¡}t|ƒdkr#d|S|S)Nz@c.usÚzp:ú+z\b549Ú54é )ÚreplaceÚreÚsubÚlen)Ú contact_phonerrrÚnormalizephone%s    r,)N) rÚmysql.connectorr Údotenvrr(rr"r,rrrrÚs