app.py

from flask import Flask, request, jsonify
import mysql.connector
import database

import csv
import json
import os
import hashlib

import threading
import access

# Store csv
jsonArray = []
jsonString=""
hex_dig=""
def csv_to_json(csvFilePath):

    #read csv file
    with open(csvFilePath, encoding='utf_8_sig') as csvf: 
        #load csv file data using csv library's dictionary reader
        csvReader = csv.DictReader(csvf) 

        #convert each csv row into python dict
        for row in csvReader: 
            #add this python dict to json array
            jsonArray.append(row)
    jsonString = json.dumps(jsonArray)
    # create an MD5 hash object
    hash_object = hashlib.md5()
    # update the hash object with the string
    hash_object.update(jsonString.encode('utf-8'))
    # get the hexadecimal representation of the hash
    hex_dig = hash_object.hexdigest()
    return jsonString, hex_dig

    
csvFilePath = os.getcwd()+r'/info.csv'
jsonString,hex_dig=csv_to_json(csvFilePath)


database.setup()
# Set up a connection to the MySQL server
cnx = mysql.connector.connect(
  host='localhost',
  user='root',
  password='AS324S1',
  database='mydatabase'
)

#start the thread of getting token
# start a new thread to run the function every 2 hours
# thread = threading.Thread(target=access.gettoken)
# thread.daemon = True
# thread.start()

token = "fUjXn2r5u8x!A%D*"
# Create a Flask app instance
app = Flask(__name__)

@app.route('/update', methods=['GET','POST'])
def update_record():
  # Check the integrity of the request
  if not request.json or 'id' not in request.json or 'activity' not in request.json or request.json['token']!=token:
    return "Invalid request", 400
  
  # Get the name and age values from the request
  id = request.json['id']
  activity = request.json['activity']
  
  # Create a cursor object to execute queries
  cursor = cnx.cursor()
  
  # Check if a record with the given name exists in the table
  query = "SELECT * FROM mytable WHERE name = %s"
  values = (id,)
  cursor.execute(query, values)
  result = cursor.fetchone()
 
  
  if result:
    #use activity to identify whether need update or not
    if activity == "get":
      data = {'activities': result[1]}
      cursor.close()
      return jsonify(data)
    # The record exists, so update the age value
    query = "UPDATE mytable SET activity = %s WHERE name = %s"
    values = (activity,id)
    cursor.execute(query, values)
    cnx.commit()
    cursor.close()
    return f"Record for {id} updated successfully{activity}"
  else:
    if activity == "get":
      data = {'activities': ''}
      cursor.close()
      return jsonify(data)

    # The record doesn't exist, so insert a new record
    query = "INSERT INTO mytable (name, activity) VALUES (%s, %s)"
    values = (id, activity)
    cursor.execute(query, values)
    cnx.commit()
    cursor.close()
    return f"New record for {id} created successfully"

  # Close the cursor
  

@app.route("/mapdata",  methods=['POST'])
def returncsv():
    if not request.json or request.json['token']!=token:
      return "Invalid request", 400
    if request.json['md5']!=hex_dig:
      print(hex_dig)
      return jsonString
    else:
      return "check"
    
# @app.route("/mini_token")
# def returntoken():
#    return access.token

@app.route("/mini_id", methods=['POST'])
def returnopenid():
   if not request.json or request.json['token']!=token:
      return "Invalid request", 400
   return access.getopenid(request.json['usercode'])

# Run the app on localhost:5001
if __name__ == '__main__':
  app.run(debug=True,port=5001)