Method group_info

mod/project/java/groupMod.py:343–410

(self, project_cache: Optional[dict] = None)

        return ("start", "stop"), ""

    def group_info(self, project_cache: Optional[dict] = None) -> Optional[dict]:
        if not self.config:
            return
        if not project_cache:
            project_ids = [i["id"] for i in self.config["projects"]]
            if not project_ids:
                data = copy.deepcopy(self.config)
                data["group_id"] = self.group_id
                return data

            projects = public.M('sites').where(
                'project_type=? and id IN ({})'.format(",".join(["?"] * len(project_ids))),
                ('Java', *project_ids)).select()
            project_cache = {}
            for i in projects:
                i["project_config"] = json.loads(i["project_config"])
                project_cache[i["id"]] = i

        j_pro = JavaProject()

        res = copy.deepcopy(self.config)
        res["group_id"] = self.group_id
        res["operation_info"], res["now_operation"] = self.get_operation_info()
        running_num = 0
        need_del = []
        for idx, i in enumerate(res["projects"]):
            if i["id"] in project_cache:
                try:
                    listen = []
                    pid = j_pro.get_project_pid(project_cache[i["id"]])
                    p = psutil.Process(int(pid))
                    connections = p.connections()
                    for connection in connections:
                        if connection.status == "LISTEN":
                            listen.append(connection.laddr.port)
                except:
                    i["running"] = False
                    i["project_status"] = 'not_run'
                    i["pid"] = None
                    i["listen"] = []
                    continue

                running_num += 1
                i["running"] = True
                i["project_status"] = self.do_check_info(i["check_info"], p)
                i["pid"] = p.pid
                i["listen"] = listen
            else:
                need_del.append(idx)

        for j in need_del[::-1]:
            del res["projects"][j]
            del self.config["projects"][j]

        if need_del:
            self.save_group_data()

        if not res["now_operation"]: