package com.vci.ubcs.deploy.service.impl;
|
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.nacos.shaded.com.google.protobuf.ServiceException;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.vci.ubcs.deploy.entity.DeployApps;
|
import com.vci.ubcs.deploy.entity.Instance;
|
import com.vci.ubcs.deploy.mapper.DeployAppsMapper;
|
import com.vci.ubcs.deploy.service.IDeployAppsService;
|
import com.vci.ubcs.deploy.vo.DeployAppsVO;
|
import com.vci.ubcs.starter.util.HttpUtils;
|
import org.springblade.core.tool.utils.Func;
|
import org.springblade.core.tool.utils.UrlUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.cloud.client.ServiceInstance;
|
import org.springframework.cloud.client.discovery.DiscoveryClient;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.MediaType;
|
import org.springframework.stereotype.Service;
|
|
import javax.servlet.ServletRequest;
|
import javax.servlet.http.HttpServletRequest;
|
import java.net.URL;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* @author ludc
|
* @date 2024/1/7 19:54
|
*/
|
@Service
|
public class DeployAppsServiceImpl extends ServiceImpl<DeployAppsMapper, DeployApps> implements IDeployAppsService {
|
|
@Autowired
|
private DeployAppsMapper deployAppsMapper;
|
|
@Value("${password-free.pwd-free-addr:localhost}")
|
private String pwdFreeAddr;
|
|
// 通过服务注册中心获取网关的端口号
|
@Autowired
|
private DiscoveryClient discoveryClient;
|
|
@Override
|
public List<DeployAppsVO> getApplications(ServletRequest servletRequest) throws ServiceException {
|
HttpServletRequest request = (HttpServletRequest) servletRequest;
|
String baldeAuth = request.getHeaders("Blade-Auth").nextElement();
|
String cookie = request.getHeaders("Cookie").nextElement();
|
// 免密登录接口地址
|
String loginUrl = "http://"+pwdFreeAddr+":"+this.getGatewayPort("ubcs-gateway")+"/ubcs-admin/applications";
|
log.debug("获取服务信息调用地址："+loginUrl);
|
// 请求ubcs-admin获取服务信息
|
HttpHeaders headers = new HttpHeaders();
|
ArrayList<MediaType> mediaTypes = new ArrayList<>();
|
mediaTypes.add(MediaType.APPLICATION_JSON);
|
headers.set("Authorization","Basic c2FiZXI6c2FiZXJfc2VjcmV0");
|
headers.set("Blade-Auth",baldeAuth);
|
headers.set("Cookie",cookie);
|
headers.setAccept(mediaTypes);
|
List<DeployAppsVO> deployAppsVOList = new ArrayList<>();
|
try {
|
// 发送GET请求
|
String responseBody = HttpUtils.get(loginUrl, headers);
|
if(Func.isNotEmpty(responseBody)){
|
// 将 JSON 字符串转换为 JSONArray
|
JSONArray jsonArray = JSON.parseArray(responseBody);
|
for (Object obj : jsonArray) {
|
DeployAppsVO deployAppsVO = new DeployAppsVO();
|
JSONObject jsonObject = (JSONObject) obj;
|
List instances = ((List) jsonObject.get("instances"));
|
deployAppsVO.setName(jsonObject.get("name").toString());
|
String serviceUrl = ((JSONObject) ((JSONObject) instances.get(0)).get("registration")).get("serviceUrl").toString();
|
deployAppsVO.setPort(String.valueOf(new URL(serviceUrl).getPort()));
|
deployAppsVO.setServiceNum(instances.size());
|
deployAppsVO.setStatus(jsonObject.get("status").toString());
|
deployAppsVO.setStatusTimestamp(jsonObject.get("statusTimestamp").toString());
|
deployAppsVOList.add(deployAppsVO);
|
}
|
|
}
|
}catch (Exception e){
|
throw new ServiceException("调用ubcs-admin获取服务信息失败，原因："+e.getMessage());
|
}
|
return deployAppsVOList;
|
}
|
|
/**
|
* 根据服务名获取端口号
|
* @param serviceId
|
* @return
|
*/
|
public String getGatewayPort(String serviceId) {
|
List<ServiceInstance> instances = discoveryClient.getInstances(serviceId);
|
if (!instances.isEmpty()) {
|
ServiceInstance gatewayInstance = instances.get(0);
|
return String.valueOf(gatewayInstance.getPort());
|
}
|
return "8080";
|
}
|
|
|
}
|
