添加区域树

setup-project-manager/src/main/java/com/mortals/xhx/daemon/task/CheckProjectStatusTaskImpl.java

@@ -7,7 +7,9 @@ import com.mortals.framework.exception.AppException;
 import com.mortals.framework.service.ITask;
 import com.mortals.framework.service.ITaskExcuteService;
 import com.mortals.xhx.base.system.user.service.UserService;
+import com.mortals.xhx.common.code.ProjectStatusEnum;
 import com.mortals.xhx.common.code.ProjectTypeEnum;
+import com.mortals.xhx.common.pdu.ListItem;
 import com.mortals.xhx.common.pdu.NacosResponse;
 import com.mortals.xhx.module.setup.model.SetupProjectEntity;
 import com.mortals.xhx.module.setup.service.SetupProjectService;
@@ -17,6 +19,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -43,10 +46,21 @@ public class CheckProjectStatusTaskImpl implements ITaskExcuteService {
                 //todo http://192.168.0.250:8848/nacos/v1/ns/catalog/instances?message=true&serviceName=bill-manager&clusterName=DEFAULT&groupName=DEFAULT_GROUP&pageSize=10&pageNo=1&namespaceId=smart-gov
                 String serverUrl = nacosUrl + "/nacos/v1/ns/catalog/instances?message=true&serviceName=" + setupProjectEntity.getProjectCode() + "&clusterName=DEFAULT&groupName=DEFAULT_GROUP&pageSize=10&pageNo=1&namespaceId=smart-gov";
                 String resp = HttpUtil.get(serverUrl);
-
                 NacosResponse nacosResponse = JSON.parseObject(resp, new TypeReference<NacosResponse>() {
                 });
-
+                int count = nacosResponse.getCount();
+                if(count>0){
+                    ListItem item = nacosResponse.getList().get(0);
+                    String serviceName = item.getServiceName();
+                    boolean healthy = item.isHealthy();
+                    if(healthy){
+                        setupProjectEntity.setProjectStatus(ProjectStatusEnum.运行.getValue());
+                    }else {
+                        setupProjectEntity.setProjectStatus(ProjectStatusEnum.停止.getValue());
+                    }
+                    setupProjectEntity.setUpdateTime(new Date());
+                    setupProjectService.update(setupProjectEntity);
+                }
 
                 log.info("服务实例详细查询url:{},返回:{},naocsResponse:{}", serverUrl, resp, JSON.toJSONString(nacosResponse));