Repository for M.A.I.L system's recording client.
Вы не можете выбрать более 25 тем Темы должны начинаться с буквы или цифры, могут содержать дефисы(-) и должны содержать не более 35 символов.

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140
  1. import tkinter
  2. import json
  3. import paramiko
  4. import time
  5. from tkinter import messagebox
  6. import os
  7. from paramiko import file
  8. window = tkinter.Tk()
  9. settings =[]
  10. customer_code = ''
  11. surgery_date = str(time.strftime('%Y%m%d', time.localtime(time.time())))
  12. with open('./settings.json', encoding='utf-8')as json_file:
  13. json_data = json.load(json_file)
  14. settings.append(json_data['window_name'])
  15. settings.append(json_data['window_position'])
  16. settings.append(json_data['branch_location'])
  17. settings.append(json_data['surgery_room_number'])
  18. settings.append(json_data['ddns'])
  19. settings.append(json_data['account']) #settings[5]
  20. settings.append(json_data['password']) #settings[6]
  21. window.title(settings[0])
  22. window.geometry(settings[1])
  23. window.resizable(False,False)
  24. def sshConnect(cs, sd):
  25. cs = cs
  26. sd = sd
  27. ssh = paramiko.SSHClient()
  28. ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  29. ssh.connect(settings[4],port= settings[3], username=settings[5], password=settings[6])
  30. data_root_dir = './data/'+cs+sd
  31. stdin, stdout, stderr = ssh.exec_command('mkdir ' + data_root_dir)
  32. #TODO: 여기에 도커 명령어 및 동시 녹화 코드 입력
  33. stdin, stdout, stderr = ssh.exec_command('docker run --rm --name mail_recorder --gpus 1 --privileged -v /dev:/dev -v /home/mc365/sources:/sources -v /home/mc365/data/'+cs+sd+':/data/'+cs+sd+' stereolabs/zed:3.5-gl-devel-cuda11.1-ubuntu18.04 python3 /sources/recorder.py')
  34. def sshQuit(cs, sd):
  35. cs = cs
  36. sd = sd
  37. filepath = './log.txt'
  38. data_root_dir = './data/'+cs+sd
  39. f = open(filepath, 'w')
  40. f.write('record succesfully stopped')
  41. f.close()
  42. transport = paramiko.Transport((settings[4], settings[3]))
  43. transport.connect(username=settings[5], password=settings[6])
  44. sftp = paramiko.SFTPClient.from_transport(transport)
  45. sftp.put(filepath, data_root_dir + filepath[1:])
  46. sftp.close()
  47. transport.close()
  48. os.remove(filepath)
  49. ssh = paramiko.SSHClient()
  50. ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  51. ssh.connect(settings[4],port= settings[3], username=settings[5], password=settings[6])
  52. stdin, stdout, stderr = ssh.exec_command('docker stop mail_recorder')
  53. time.sleep(10)
  54. stdin, stdout, stderr = ssh.exec_command('mv ' + data_root_dir + ' /hdd/')
  55. label_branch = tkinter.Label(window, text = '지점 위치: ' + settings[2] + ' / 수술방 번호: ' + str(settings[3]))
  56. label_customer_code = tkinter.Label(window, text="고객번호(지점 번호 포함 9자리)")
  57. def dummyexit():
  58. pass
  59. def askInformation(customer_code,surgery_date):
  60. cs = customer_code
  61. sd = surgery_date
  62. if len(cs) != 9:
  63. err_box = messagebox.showerror("고객 번호 오류", '지점 번호를 포함한 9자리를 입력해주세요.')
  64. else:
  65. msg_box = messagebox.askquestion("입력 정보 확인", "입력하신 정보가 정확한지 확인해주세요.\n고객 번호: "+customer_code + '\n 수술일자: ' + surgery_date +'\n\nYes를 눌러 기록 시작을,\n입력 정보의 수정을 원하시면 No을 눌러 변경해주세요.')
  66. #TODO: try: 형태로 고칠 것. Err 메세지도 종류 정할 것
  67. if msg_box == 'yes':
  68. err_status = True
  69. if err_status == False:
  70. label_recording = tkinter.Label(window, text='분석 PC에 문제가 발생하였습니다.\nHOBIT LAB으로 연락 부탁드립니다.\n내선번호: 1237 \n에러 코드: REQUEST TIME OUT')
  71. label_recording.pack()
  72. else:
  73. #TODO: paramiko로 ssh 접속 후 도커 명령어 보낼 것
  74. sshConnect(cs, sd)
  75. button_confirm['text'] = '기록 종료'
  76. window.protocol('WM_DELETE_WINDOW', dummyexit)
  77. label_recording = tkinter.Label(window, text='MAIL system에 수술을 기록 중입니다.\n기록 중단을 원할 시 \n기록 종료 버튼을 눌러주세요.')
  78. label_recording.pack()
  79. def askQuit(cn, sd):
  80. customer_number = cn
  81. surgery_date = sd
  82. msg_box = messagebox.askquestion("기록 중지 확인", '기록을 중지하시겠습니까?')
  83. if msg_box == 'yes':
  84. #TODO: docker 중지 명령어 보내기
  85. sshQuit(customer_number, surgery_date)
  86. window.destroy()
  87. def buttonAction(event):
  88. customer_code = str(entry_customer_code.get())
  89. if button_confirm['text'] == '입력완료':
  90. askInformation(customer_code, surgery_date)
  91. else:
  92. askQuit(customer_code,surgery_date)
  93. # def fillSurgeryDate():
  94. entry_customer_code = tkinter.Entry(window)
  95. entry_surgery_date = tkinter.Entry(window)
  96. button_confirm = tkinter.Button(window, text="입력완료", width=20, height=2)
  97. button_confirm.bind("<Button-1>", buttonAction)
  98. label_branch.pack()
  99. label_customer_code.pack()
  100. entry_customer_code.pack()
  101. button_confirm.pack()
  102. window.mainloop()