| | |
| | | package com.ard.work.service.impl; |
| | | |
| | | import com.ard.common.annotation.DataScope; |
| | | import com.ard.common.utils.uuid.IdUtils; |
| | | import com.ard.work.component.forest.TyClient; |
| | | import com.ard.work.component.netty.TyTcpClientManager; |
| | |
| | | public class ArdServerInfoServiceImpl implements IArdServerInfoService { |
| | | |
| | | @Resource |
| | | private ArdServerInfoMapper ardServerInfoMapper; |
| | | @Resource |
| | | private TyClient tyClient; |
| | | |
| | | @Resource |
| | | private ArdServerInfoMapper ardServerInfoMapper; |
| | | |
| | | @Resource |
| | | private TyTcpClientManager tyTcpClientManager; |
| | | |
| | |
| | | * @return 服务器管理 |
| | | */ |
| | | @Override |
| | | @DataScope(deptAlias = "d", userAlias = "u") |
| | | public List<ArdServerInfo> selectArdServerInfoList(ArdServerInfo ardServerInfo) { |
| | | return ardServerInfoMapper.selectArdServerInfoList(ardServerInfo); |
| | | } |
| | |
| | | @Override |
| | | public AccessTokenReceiver getAccessToken(String id) { |
| | | long timeStamp = getTimeStamp(); |
| | | AccessTokenReceiver accessToken = null; |
| | | |
| | | ArdServerInfo serverInfo = selectArdServerInfoById(id); |
| | | // 准备请求的json |
| | | TokenDTO gtd = TokenDTO.builder() |
| | |
| | | .encryptStr(getEncryptStr(serverInfo, timeStamp)) |
| | | .timeStamp(timeStamp) |
| | | .build(); |
| | | try { |
| | | TyHttpCommonReceiver<AccessTokenReceiver> getTokenRes = tyClient.getToken(id, gtd); |
| | | accessToken = getTokenRes.getContent(); |
| | | } catch (Exception e) { |
| | | log.error("获取token失败:{}", e.getMessage()); |
| | | } |
| | | // try { |
| | | TyHttpCommonReceiver<AccessTokenReceiver> getTokenRes = tyClient.getToken(id, gtd); |
| | | return getTokenRes.getContent(); |
| | | // } catch (Exception e) { |
| | | // log.error("获取 Token 失败 serverId={}, 异常: {}", id, e.getMessage()); |
| | | // return null; // 请求失败返回 null |
| | | // } |
| | | //{"state":0,"content":{"companyId":4127,"accessToken":"sOONT0MMVdoKcMBibb40xxgrUrq0Hw9RFiajic3KOzoNtk"}} |
| | | return accessToken; |
| | | } |
| | | |
| | | /** |
| | | * 修改服务器状态 |
| | | */ |
| | | @Override |
| | | public int updateServerStatus(String id,String status) { |
| | | return ardServerInfoMapper.updateServerStatus(id,status); |
| | | public int updateServerStatus(String id, String status) { |
| | | return ardServerInfoMapper.updateServerStatus(id, status); |
| | | } |
| | | |
| | | @Override |
| | | public List<String> getServerIdsList() { |
| | | return ardServerInfoMapper.getServerIdsList(); |
| | | } |
| | | |
| | | private String getEncryptStr(ArdServerInfo serverInfo, long timeStamp) { |