#
#2025/11/16
#
import mysql.connector
from openai import OpenAI
import sys
import time
import os

def chat( com ):
    key=os.getenv("OPENAPI_KEY_ARA")
    client = OpenAI(api_key=key)
    
    res = client.chat.completions.create(
    model="gpt-4o",
    messages=[
        {"role": "system", "content": "あなたは親切なAIアシスタントです。"},
        {"role": "user", "content": com }
       ]
    )
    return( res.choices[0].message.content )
    
#
# main
#

idd=sys.argv[1]
#wnum=sys.argv[2]

cn=mysql.connector.connect(
    host='localhost',
    user='std',
    password='std',
    database='real_navi',
    charset='utf8mb4'
)

rs = cn.cursor(dictionary=True)
sql = f"SELECT LID,com,lat,lon FROM tb01 where tb01.ID={idd}"
rs.execute(sql)
dd = rs.fetchall()
lid=dd[0]['LID']
cm=dd[0]['com']
lat=dd[0]['lat']
lon=dd[0]['lon']
flg=( lat is None )
if flg == False:
    cm=f"{ cm }  ここの緯度経度です。({ lat },{ lon })"
aa=chat( cm )
aa=aa.replace("'", "\\'")

wtime=int(time.time())
sql="insert into tb01(LID,wtime,com,s_ID,flg,name) values(%s,%s,%s,%s,%s,%s)"
try:
    rs.execute(sql,(lid,wtime,aa,idd,1,'AI'))
    cn.commit()
except Exception as e:
    print("SQL実行エラー:", e)

cn.close()
