257 lines
10 KiB
Python
257 lines
10 KiB
Python
import json
|
|
import logging
|
|
import traceback
|
|
import pydapper
|
|
|
|
from ..schemas import model
|
|
from .. import local_db
|
|
from ..services.auth_guard import check_jwt
|
|
|
|
from BreCal.database.update_database import evaluate_shipcall_state
|
|
|
|
def GetShipcalls(options):
|
|
"""
|
|
No parameters, gets all entries
|
|
"""
|
|
|
|
try:
|
|
|
|
pooledConnection = local_db.getPoolConnection()
|
|
commands = pydapper.using(pooledConnection)
|
|
query = ("SELECT s.id as id, ship_id, type, eta, voyage, etd, arrival_berth_id, departure_berth_id, tug_required, pilot_required, " +
|
|
"flags, s.pier_side, bunkering, replenishing_terminal, replenishing_lock, draft, tidal_window_from, " +
|
|
"tidal_window_to, rain_sensitive_cargo, recommended_tugs, anchored, moored_lock, canceled, evaluation, " +
|
|
"evaluation_message, evaluation_time, evaluation_notifications_sent, s.created as created, s.modified as modified, time_ref_point " +
|
|
"FROM shipcall s " +
|
|
"LEFT JOIN times t ON t.shipcall_id = s.id AND t.participant_type = 8 " +
|
|
"WHERE " +
|
|
"(type = 1 AND (COALESCE(t.eta_berth, eta) >= DATE(NOW() - INTERVAL %d DAY))) OR " +
|
|
"((type = 2 OR type = 3) AND (COALESCE(t.etd_berth, etd) >= DATE(NOW() - INTERVAL %d DAY)))" +
|
|
"ORDER BY s.id") % (options["past_days"], options["past_days"])
|
|
|
|
data = commands.query(query, model=model.Shipcall.from_query_row, buffered=True)
|
|
for shipcall in data:
|
|
participant_query = "SELECT participant_id, type FROM shipcall_participant_map WHERE shipcall_id=?shipcall_id?";
|
|
for record in commands.query(participant_query, model=dict, param={"shipcall_id" : shipcall.id}, buffered=False):
|
|
# model.Participant_Assignment = model.Participant_Assignment()
|
|
pa = model.Participant_Assignment(record["participant_id"], record["type"])
|
|
shipcall.participants.append(pa)
|
|
|
|
return json.dumps(data, default=model.obj_dict), 200, {'Content-Type': 'application/json; charset=utf-8'}
|
|
|
|
except Exception as ex:
|
|
logging.error(traceback.format_exc())
|
|
logging.error(ex)
|
|
print(ex)
|
|
result = {}
|
|
result["message"] = "call failed"
|
|
return json.dumps(result), 500, {'Content-Type': 'application/json; charset=utf-8'}
|
|
|
|
finally:
|
|
if pooledConnection is not None:
|
|
pooledConnection.close()
|
|
|
|
|
|
def PostShipcalls(schemaModel):
|
|
"""
|
|
|
|
:param schemaModel: The deserialized dict of the request
|
|
"""
|
|
|
|
# TODO: Validate the upload data
|
|
|
|
# This creates a *new* entry
|
|
try:
|
|
|
|
pooledConnection = local_db.getPoolConnection()
|
|
commands = pydapper.using(pooledConnection)
|
|
|
|
query = "INSERT INTO shipcall ("
|
|
isNotFirst = False
|
|
for key in schemaModel.keys():
|
|
if key == "id":
|
|
continue
|
|
if key == "participants":
|
|
continue
|
|
if key == "created":
|
|
continue
|
|
if key == "modified":
|
|
continue
|
|
if key == "evaluation":
|
|
continue
|
|
if key == "evaluation_message":
|
|
continue
|
|
if key == "type_value":
|
|
continue
|
|
if key == "evaluation_value":
|
|
continue
|
|
if isNotFirst:
|
|
query += ","
|
|
isNotFirst = True
|
|
query += key
|
|
query += ") VALUES ("
|
|
isNotFirst = False
|
|
for key in schemaModel.keys():
|
|
param_key = key
|
|
if key == "id":
|
|
continue
|
|
if key == "participants":
|
|
continue
|
|
if key == "created":
|
|
continue
|
|
if key == "modified":
|
|
continue
|
|
if key == "evaluation":
|
|
continue
|
|
if key == "evaluation_message":
|
|
continue
|
|
if key == "type":
|
|
param_key = "type_value"
|
|
if key == "type_value":
|
|
continue
|
|
if key == "evaluation":
|
|
param_key = "evaluation_value"
|
|
if key == "evaluation_value":
|
|
continue
|
|
if isNotFirst:
|
|
query += ","
|
|
isNotFirst = True
|
|
query += "?" + param_key + "?"
|
|
query += ")"
|
|
|
|
logging.info(query)
|
|
commands.execute(query, schemaModel)
|
|
new_id = commands.execute_scalar("select last_insert_id()")
|
|
|
|
# add participant assignments if we have a list of participants
|
|
if 'participants' in schemaModel:
|
|
pquery = "INSERT INTO shipcall_participant_map (shipcall_id, participant_id, type) VALUES (?shipcall_id?, ?participant_id?, ?type?)"
|
|
for participant_assignment in schemaModel["participants"]:
|
|
commands.execute(pquery, param={"shipcall_id" : new_id, "participant_id" : participant_assignment["participant_id"], "type" : participant_assignment["type"]})
|
|
|
|
# apply 'Traffic Light' evaluation to obtain 'GREEN', 'YELLOW' or 'RED' evaluation state. The function internally updates the mysql database
|
|
# evaluate_shipcall_state(mysql_connector_instance=pooledConnection, shipcall_id=new_id) # new_id (last insert id) refers to the shipcall id
|
|
|
|
# save history data
|
|
# TODO: set ETA properly
|
|
user_data = check_jwt()
|
|
query = "INSERT INTO history (participant_id, shipcall_id, user_id, timestamp, eta, type, operation) VALUES (?pid?, ?scid?, ?uid?, CURRENT_TIMESTAMP, CURRENT_TIMESTAMP, 1, 1)"
|
|
commands.execute(query, {"scid" : new_id, "pid" : user_data["participant_id"], "uid" : user_data["id"]})
|
|
|
|
return json.dumps({"id" : new_id}), 201, {'Content-Type': 'application/json; charset=utf-8'}
|
|
|
|
except Exception as ex:
|
|
logging.error(traceback.format_exc())
|
|
logging.error(ex)
|
|
print(ex)
|
|
result = {}
|
|
result["message"] = "call failed"
|
|
return json.dumps(result), 500, {'Content-Type': 'application/json; charset=utf-8'}
|
|
|
|
finally:
|
|
if pooledConnection is not None:
|
|
pooledConnection.close()
|
|
|
|
|
|
def PutShipcalls(schemaModel):
|
|
"""
|
|
|
|
:param schemaModel: The deserialized dict of the request
|
|
"""
|
|
|
|
# This updates an *existing* entry
|
|
try:
|
|
|
|
pooledConnection = local_db.getPoolConnection()
|
|
commands = pydapper.using(pooledConnection)
|
|
|
|
# test if object to update is found
|
|
|
|
sentinel = object()
|
|
theshipcall = commands.query_single_or_default("SELECT * FROM shipcall where id = ?id?", sentinel, param={"id" : schemaModel["id"]})
|
|
if theshipcall is sentinel:
|
|
pooledConnection.close()
|
|
return json.dumps("no such record"), 404, {'Content-Type': 'application/json; charset=utf-8'}
|
|
|
|
query = "UPDATE shipcall SET "
|
|
isNotFirst = False
|
|
for key in schemaModel.keys():
|
|
param_key = key
|
|
if key == "id":
|
|
continue
|
|
if key == "participants":
|
|
continue
|
|
if key == "created":
|
|
continue
|
|
if key == "modified":
|
|
continue
|
|
if key == "evaluation":
|
|
continue
|
|
if key == "evaluation_message":
|
|
continue
|
|
if key == "type":
|
|
param_key = "type_value"
|
|
if key == "type_value":
|
|
continue
|
|
if key == "evaluation":
|
|
param_key = "evaluation_value"
|
|
if key == "evaluation_value":
|
|
continue
|
|
if isNotFirst:
|
|
query += ", "
|
|
isNotFirst = True
|
|
query += key + " = ?" + param_key + "? "
|
|
|
|
query += "WHERE id = ?id?"
|
|
affected_rows = commands.execute(query, param=schemaModel)
|
|
|
|
pquery = "SELECT id, participant_id, type FROM shipcall_participant_map where shipcall_id = ?id?"
|
|
pdata = commands.query(pquery,param={"id" : schemaModel["id"]}) # existing list of assignments
|
|
|
|
# loop across passed participant ids, creating entries for those not present in pdata
|
|
|
|
for participant_assignment in schemaModel["participants"]:
|
|
found_participant = False
|
|
for elem in pdata:
|
|
if elem["participant_id"] == participant_assignment["participant_id"] and elem["type"] == participant_assignment["type"]:
|
|
found_participant = True
|
|
break
|
|
if not found_participant:
|
|
nquery = "INSERT INTO shipcall_participant_map (shipcall_id, participant_id, type) VALUES (?shipcall_id?, ?participant_id?, ?type?)"
|
|
commands.execute(nquery, param={"shipcall_id" : schemaModel["id"], "participant_id" : participant_assignment["participant_id"], "type" : participant_assignment["type"]})
|
|
|
|
# loop across existing pdata entries, deleting those not present in participant list
|
|
for elem in pdata:
|
|
found_participant = False
|
|
for participant_assignment in schemaModel["participants"]:
|
|
if(participant_assignment["participant_id"] == elem["participant_id"] and participant_assignment["type"] == elem["type"]):
|
|
found_participant = True
|
|
break;
|
|
if not found_participant:
|
|
dquery = "DELETE FROM shipcall_participant_map WHERE id = ?existing_id?"
|
|
commands.execute(dquery, param={"existing_id" : elem["id"]})
|
|
|
|
# apply 'Traffic Light' evaluation to obtain 'GREEN', 'YELLOW' or 'RED' evaluation state. The function internally updates the mysql database
|
|
# evaluate_shipcall_state(mysql_connector_instance=pooledConnection, shipcall_id=schemaModel["id"]) # schemaModel["id"] refers to the shipcall id
|
|
|
|
# save history data
|
|
# TODO: set ETA properly
|
|
user_data = check_jwt()
|
|
query = "INSERT INTO history (participant_id, shipcall_id, user_id, timestamp, eta, type, operation) VALUES (?pid?, ?scid?, ?uid?, CURRENT_TIMESTAMP, CURRENT_TIMESTAMP, 1, 2)"
|
|
commands.execute(query, {"scid" : schemaModel["id"], "pid" : user_data["participant_id"], "uid" : user_data["id"]})
|
|
|
|
return json.dumps({"id" : schemaModel["id"]}), 200
|
|
|
|
except Exception as ex:
|
|
logging.error(traceback.format_exc())
|
|
logging.error(ex)
|
|
print(ex)
|
|
result = {}
|
|
result["message"] = "call failed"
|
|
return json.dumps(result), 500, {'Content-Type': 'application/json; charset=utf-8'}
|
|
|
|
finally:
|
|
if pooledConnection is not None:
|
|
pooledConnection.close()
|
|
|