server.py

import socket
import pymysql
import json

#DB 연결 설정
db = pymysql.connect(
    host='ajsj123.iptime.org',
    port=3306,
    user='parksubin',
    password='qkr!tnqls',
    database='nfc_lock_db',
    charset='utf8mb4',
    cursorclass=pymysql.cursors.DictCursor
)

#TCP 서버 설정
HOST = '0.0.0.0'
PORT = 9999

server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind((HOST, PORT))
server_socket.listen()

print(f"DB 서버가 {PORT} 포트에서 대기 중입니다...")

while True:
    print("클라이언트 요청을 기다리는 중입니다...")
    client_socket, addr = server_socket.accept()
    print(f"{addr}에서 접속됨")


    try:
        data = client_socket.recv(1024).decode('utf-8')
        print(f"클라이언트로부터 받은 UID: {data}")

        data_json = json.loads(data)
        user_uid = data_json.get("user_uid", "").strip()
        print(f"추출된 UID: {user_uid}")
        
        with db.cursor() as cursor:
            sql = "SELECT * FROM users WHERE user_uid = %s"
            print(f"실행할 SQL: {sql} / 파라미터: {user_uid}")
            cursor.execute(sql, (user_uid,))
            result = cursor.fetchone()
            print(f"DB에서 조회된 결과: {result}")

        if result:
            response = json.dumps(result, default=str)
        else:
            response = json.dumps({"error": "사용자 정보를 찾을 수 없습니다."})

        client_socket.sendall(response.encode('utf-8'))

    finally:
        client_socket.close()