manage.py 4.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153
  1. import os, io, sys, platform, shutil, time, subprocess, json, datetime
  2. import socket
  3. from threading import Thread
  4. from api.utils import shell_execute, network, docker
  5. from api.model.app import App
  6. # 获取所有app的信息
  7. def get_my_app(app_name=None):
  8. #{"name":"id",...}
  9. ip_result = shell_execute.execute_command_output_all("curl ifconfig.me")
  10. ip = ip_result["result"]
  11. ret = {}
  12. ret["code"] = -1
  13. ret["message"] = "app查询失败"
  14. ret["data"] = None
  15. # get all info
  16. cmd = "sudo docker compose ls"
  17. output = shell_execute.execute_command_output_all(cmd)
  18. if int(output["code"]) == 0:
  19. output_list = output["result"].split()
  20. list = []
  21. output_list = output_list[4:]
  22. num = int(len(output_list) / 3)
  23. for i in range(0, num):
  24. name = output_list[3 * i] #name
  25. id = 0 #id
  26. status = output_list[3 * i + 1].split("(")[0] #status
  27. status_code = 0 #status_code
  28. volume = output_list[3 * i+2] #volume
  29. # get env info
  30. path = "/data/apps/" + name + "/.env"
  31. http_port_env, http_port = docker.read_env(path, "APP_HTTP_PORT")
  32. db_port_env, db_port = docker.read_env(path, "APP_DB.*_PORT")
  33. print(name+": "+ db_port)
  34. # get port and url
  35. port = 0
  36. url = "-"
  37. if http_port != "":
  38. port = int(http_port)
  39. url = "http://"+ip+":"+str(port)
  40. elif db_port != "":
  41. port = int(db_port)
  42. url = "http://" + ip + ":" + str(port)
  43. # get user_name
  44. username_env, user_name = docker.read_env(path, "APP_USER")
  45. if user_name == "":
  46. user_name = "-"
  47. # get password
  48. password_env, password = docker.read_env(path, "POWER_PASSWORD")
  49. if password == "":
  50. password = "-"
  51. app = App(id=id, name=name, status_code=status_code, status=status, port=port, volume=volume, url=url, user_name=user_name, password=password)
  52. list.append(app.dict())
  53. flag = 0
  54. if app_name != None:
  55. for app in list:
  56. if app["name"] == app_name:
  57. list.clear()
  58. list.append(app)
  59. flag = 1
  60. break
  61. if app_name == None or flag == 1:
  62. ret["code"] = 0
  63. ret["message"] = "app查询成功"
  64. ret["data"] = list
  65. return ret
  66. def install_app(app_name):
  67. # check directory
  68. docker.create_app_directory(app_name)
  69. # check port
  70. docker.check_app_compose(app_name)
  71. cmd = "cd /data/apps/"+app_name+" && sudo docker compose up -d"
  72. t1 = Thread(target=shell_execute.execute_command_output_all, args=(cmd,))
  73. t1.start()
  74. ret = {}
  75. ret["code"] = 0
  76. ret["message"] = "应用正在启动中,请过几分钟再查询"
  77. ret["data"] = ""
  78. return ret
  79. def if_app_exits(app_name):
  80. cmd = "docker compose ls -a | grep \'"+app_name+"\\b\'"
  81. output = shell_execute.execute_command_output_all(cmd)
  82. if int(output["code"]) == -1:
  83. return False
  84. else:
  85. return True
  86. def start_app(app_name):
  87. ret = {}
  88. ret["code"] = -1
  89. if if_app_exits(app_name):
  90. cmd = "docker start "+app_name
  91. output = shell_execute.execute_command_output_all(cmd)
  92. if int(output["code"]) == 0:
  93. ret["code"] = 0
  94. ret["message"] = "应用启动成功"
  95. else:
  96. ret["message"] = "应用启动失败"
  97. else:
  98. ret["message"] = "应用不存在"
  99. return ret
  100. def stop_app(app_name):
  101. ret = {}
  102. ret["code"] = -1
  103. if if_app_exits(app_name):
  104. cmd = "docker stop " + app_name
  105. output = shell_execute.execute_command_output_all(cmd)
  106. if int(output["code"]) == 0:
  107. ret["code"] = 0
  108. ret["message"] = "应用停止成功"
  109. else:
  110. ret["message"] = "应用停止失败"
  111. else:
  112. ret["message"] = "应用不存在"
  113. return ret
  114. def restart_app(app_name):
  115. ret = {}
  116. ret["code"] = -1
  117. if if_app_exits(app_name):
  118. cmd = "docker restart " + app_name
  119. output = shell_execute.execute_command_output_all(cmd)
  120. if int(output["code"]) == 0:
  121. ret["code"] = 0
  122. ret["message"] = "应用重启成功"
  123. else:
  124. ret["message"] = "应用重启失败"
  125. else:
  126. ret["message"] = "应用不存在"
  127. return ret
  128. def delete_app(app_name):
  129. ret = {}
  130. ret["code"] = -1
  131. if_stopped = stop_app(app_name)
  132. if if_stopped["code"] == 0:
  133. cmd = "docker rm "+app_name
  134. output = shell_execute.execute_command_output_all(cmd)
  135. if int(output["code"]) == 0:
  136. ret["code"] = 0
  137. ret["message"] = "应用删除成功"
  138. else:
  139. ret["message"] = "应用删除失败"
  140. else:
  141. ret["message"] = if_stopped["message"]
  142. return ret