Skip to content

Commit

Permalink
Updated
Browse files Browse the repository at this point in the history
  • Loading branch information
@Parv17k
Parv17k committed Dec 6, 2020
1 parent 7c79e0b commit dd4bf15
Showing 1 changed file with 112 additions and 70 deletions.
182 changes: 112 additions & 70 deletions main.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,39 +5,17 @@
from configparser import ConfigParser
##import plotly.express as px
import SessionState
session_state = SessionState.get(id=0,domain='')
session_state = SessionState.get(id=0,data=pd.DataFrame())
head=st.title("")


def submit_feedback(user):
st.title("Add a Feedback:")
sql_tickets = f"select ticket_id from tickets where issuer_id={user['id'][0]};"
tickets=[]
data = query_db(sql_tickets)
for t in data.values.tolist():
temp = str(t[0])
tickets.append(temp)
ticket_id = st.selectbox('Choose a system: ( ID : name type) ', tickets)

points = st.text_input("Rate out of 10:")
feedback = st.text_input('feedback:')
if st.button('Submit Feedback'):
sql = f"insert into feedbacks (points, remark, time_stamp, feedback_by,ticket_id) values({points}, '{feedback}','{datetime.datetime.now()}',{user['id'][0]} ,{ticket_id} );"
result= query_db(sql,True)
if result=='done':
st.success('Feedback submitted!!')
st.write(result)
else: st.error('error occured in SQL')



def get_config(filename='database.ini', section='postgresql'):
parser = ConfigParser()
parser.read(filename)
return {k: v for k, v in parser.items(section)}


@st.cache(allow_output_mutation=True)
#@st.cache(allow_output_mutation=True)
def query_db(sql: str,flag= False):
# print(f'Running query_db(): {sql}')
conn=None
Expand Down Expand Up @@ -70,11 +48,8 @@ def query_db(sql: str,flag= False):
st.write(error)
cur.execute("ROLLBACK")
conn.commit()
cur.close()
return None



@st.cache(allow_output_mutation=True)
def createConnection():
try:
Expand All @@ -88,6 +63,46 @@ def createConnection():
print("Error connecting to PostgreSQL database", error)
return None

def submit_feedback(user):

sql_tickets = f"""select distinct * from tickets t where issuer_id ={user['id'][0]}
and t.ticket_id not in (select ticket_id from feedbacks
where feedback_by = {user['id'][0]});"""

tickets=[]
data = query_db(sql_tickets)
if len(data) >0:
st.title("Add a Feedback:")
for t in data.values.tolist():
temp = str(t[0])
tickets.append(temp)
ticket_id = st.selectbox('Choose a Ticket created by you which are available the table above ', tickets)

points = st.text_input("Rate out of 10:")
feedback = st.text_input('feedback:')
if st.button('Submit Feedback'):
sql = f"""insert into feedbacks (points, remark, time_stamp, feedback_by,ticket_id)
values({points}, '{feedback}','{datetime.datetime.now()}',{user['id'][0]} ,{ticket_id} );"""
result= query_db(sql,True)
if result=='done':
st.success('Feedback submitted!!')
else: st.error('error occured in SQL')
else: st.write('All tickets feedback have been assigned for the tickets created by you')

def showFeedback(user):
sql =''
if user['domain'][0] == 'issue_reporter':
sql = f'select * from feedbacks where feedback_by={str(user["id"][0])};'
elif user['domain'][0] == 'employees':
sql = f'select * from feedbacks where ticket_id in (select ticket_id from tickets where assigned_to_id = {str(user["id"][0])});'

else:
sql = f"""select * from feedbacks where ticket_id in (select ticket_id from tickets
where ms_id in (select id from management_system where managerid = {str(user["id"][0])}));"""

data=query_db(sql)
st.table(data)

@st.cache
def load_tickets(user):
sql=''
Expand All @@ -96,44 +111,39 @@ def load_tickets(user):

sql = f"""select i.name, et.ticket_id,et.status, et.start_time, et.end_time, et.title, et.issuer_id,
et.assigned_to_id, et.name as emp_name from (select * from
(select * from
tickets,ticket_status
where tickets.status_id = ticket_status.id
) t
(select * from tickets,ticket_status where tickets.status_id = ticket_status.id) t
left join employees e on t.assigned_to_id = e.id)
et , issue_reporter i where i.id = et.issuer_id and i.id={str(user['id'][0])} ;"""

elif user['domain'][0]=='employees':
sql =f"""select i.name, et.ticket_id, et.start_time, et.end_time,
sql =f"""select i.name, et.ticket_id,et.status ,et.start_time, et.end_time,
et.title, et.issuer_id, et.assigned_to_id, et.name as emp_name from
(select * from (select * from
tickets,ticket_status
(select * from (select * from tickets,ticket_status
where tickets.status_id = ticket_status.id
) t left join employees e on e.id ={str(user['id'][0])} )
) t, employees e where t.assigned_to_id =e.id and e.id={str(user['id'][0])} )
et left join issue_reporter i on i.id = et.issuer_id;"""

else:
sql= f"""select temp.title, m.name as manager_name , temp.name as management_system,temp.type as department
from ( select t.title, ms.name,t.ms_id,ms.type from (select * from
tickets,ticket_status
where tickets.status_id = ticket_status.id
) t right join management_system ms on t.ms_id=ms.id)
temp ,chief_management m where m.id = temp.ms_id and m.id = {str(user['id'][0])} ;"""
sql= f"""select temp.ticket_id,temp.status ,temp.title, m.name as manager_name , temp.name as management_system,
temp.type as department from ( select t.title, ms.name,t.ms_id,ms.type,ms.managerid,t.ticket_id,t.status from
(select * from tickets,ticket_status where tickets.status_id = ticket_status.id) t
right join management_system ms on t.ms_id=ms.id) temp ,chief_management m
where m.id = temp.managerid and m.id ={str(user['id'][0])};"""

data=query_db(sql)
#print(data)
return data

def show_tickets(user):
st.title("Your Tickets:")
st.table(load_tickets(user))

def createticket(user_id):
st.title("Create a Ticket:")
title = st.text_input("title of the ticket:")
groupid = st.text_input('Group_id:')
sql_management = 'select id , name , type from management_system;'
management=[]
data = query_db(sql_management)
st.table(data)
for t in data.values.tolist():
temp = str(t[0]) + ' :' + t[1] + ' -'+ t[2]
management.append(temp)
Expand All @@ -142,15 +152,43 @@ def createticket(user_id):
if st.button('create'):

sql = f"insert into tickets (group_id, ms_id, title, issuer_id,status_id) values({groupid}, {ms_id},'{title}', {user_id},1 );"
st.write(sql)
result= query_db(sql,True)
if result=='done':
st.success('Ticket is created')
st.write(result)
else: st.error('error occured in SQL')




def updatestatus(user):
st.write("I am in")
sql = f"""select et.ticket_id,et.status, et.title
from (select * from (select * from tickets,ticket_status where tickets.status_id = ticket_status.id) t
left join employees e on t.assigned_to_id = e.id)
et , issue_reporter i where i.id = et.issuer_id and i.id={str(user['id'][0])} ;"""

data = query_db(sql)
tickets=[]
for t in data.values.tolist():
temp = f'{str(t[0])} : {t[2] } : {t[1]}'
tickets.append(temp)

selT=st.selectbox('select the ticket for which want to update status',tickets)
sql1= 'select id,status from ticket_status;'
data1 = query_db(sql1)
statuss=[]
for t in data1.values.tolist():
temp = f'{str(t[0])} : {t[1]}'
statuss.append(temp)
ent= f'select the the new status for the ticket {selT}'
selS=st.selectbox(ent,statuss)
if st.button('update status'):
selS=selS.split(":")[0]
selT=selT.split(":")[0]
sq=f"update tickets set status_id ={selS} where ticket_id ={selT};"
result= query_db(sq,True)
if result=='done':
st.success('Ticket is updated')
else: st.error('error occured in SQL')



def dashboard_reporter(user_data):
Expand All @@ -160,17 +198,27 @@ def dashboard_reporter(user_data):
show_tickets(user_data)
createticket(user_data['id'][0])
submit_feedback(user_data)


if st.button('show feedback table for the user'):
showFeedback(user_data)

def dashboard_employee(user_data):
head.title("Employee Dashboard")
st.success("Hello '"+user_data['name'][0]+"', Please scroll down and access your dashboard")
show_tickets(user_data)
st.write("I am up")

updatestatus(user_data)
st.write("I am down")
if st.button('show feedback table for the user'):
showFeedback(user_data)

def dashboard_management(user_data):
head.title("Management Dashboard")
st.success("Hello '"+user_data['name'][0]+"', Please scroll down and access your dashboard")
show_tickets(user_data)
if st.button('show feedback table for the user'):
showFeedback(user_data)

def auth(id,password,domain):

query="SELECT * from "+domain+" where id="+id+" and password = '"+password+"';"
Expand All @@ -181,21 +229,24 @@ def auth(id,password,domain):
except Exception as error:
st.write("Error Occured",error)
return
st.write(session_state.domain)
df=session_state.data
if df.empty== False:
df = df.drop(columns='password')
st.write(df )
if session_state.id == 0:
head.title("Issue Management System")
option = st.selectbox('Select your domain/role?',('employees', 'issue_reporter', 'chief_management'))
st.write('Your selected domian:', option)
user_id = st.text_input("ID:")
user_password = st.text_input("Password:")

if st.button('add'):
if st.button('Login'):
result = auth(user_id, user_password,option)
#print("Here is auth data",result)
if result is not None :
result['domain']=option
session_state.id=result['id'][0]
session_state.domain=result
session_state.data=result
if "employees" == option:
dashboard_employee(result)
elif 'issue_reporter' == option:
Expand All @@ -206,21 +257,12 @@ def auth(id,password,domain):
else:
st.write("Please check your Credentials!")
else:
if "employees" == session_state.domain["domain"][0]:
dashboard_employee(session_state.domain)
elif 'issue_reporter' == session_state.domain["domain"][0]:
dashboard_reporter(session_state.domain)
elif 'chief_management' == session_state.domain["domain"][0]:
dashboard_management(resession_state.domain)

'## Read tables'

sql_all_table_names = "select relname from pg_class where relkind='r' and relname !~ '^(pg_|sql_)';"
all_table_names = query_db(sql_all_table_names)['relname'].tolist()
table_name = st.selectbox('Choose a table', all_table_names)
if table_name:
f'Display the table'

sql_table = f'select * from {table_name};'
df = query_db(sql_table)
st.dataframe(df)
if "employees" == session_state.data["domain"][0]:
dashboard_employee(session_state.data)
elif 'issue_reporter' == session_state.data["domain"][0]:
dashboard_reporter(session_state.data)
elif 'chief_management' == session_state.data["domain"][0]:
dashboard_management(session_state.data)



0 comments on commit dd4bf15

Please sign in to comment.