| File was renamed from ard-work/src/main/java/com/ard/work/service/impl/ArdServerServiceImpl.java |
| | |
| | | import com.ard.common.utils.uuid.IdUtils; |
| | | import com.ard.work.component.forest.TyClient; |
| | | import com.ard.work.component.netty.TyTcpClientManager; |
| | | import com.ard.work.domain.cache.TyTcpServerCache; |
| | | import com.ard.work.domain.dto.TokenDTO; |
| | | import com.ard.work.domain.entity.ArdServerInfo; |
| | | import com.ard.work.domain.receiver.AccessTokenReceiver; |
| | | import com.ard.work.domain.receiver.TyHttpCommonReceiver; |
| | | import com.ard.work.mapper.ArdServerInfoMapper; |
| | | import com.ard.work.service.IArdServerService; |
| | | import com.ard.work.service.IArdServerInfoService; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.util.DigestUtils; |
| | | |
| | |
| | | */ |
| | | @Slf4j |
| | | @Service |
| | | public class ArdServerServiceImpl implements IArdServerService { |
| | | public class ArdServerInfoServiceImpl implements IArdServerInfoService { |
| | | |
| | | @Resource |
| | | private ArdServerInfoMapper ardServerInfoMapper; |
| | |
| | | * @return 服务器管理 |
| | | */ |
| | | @Override |
| | | public ArdServerInfo selectArdServerManagementById(String id) { |
| | | return ardServerInfoMapper.selectArdServerManagementById(id); |
| | | public ArdServerInfo selectArdServerInfoById(String id) { |
| | | return ardServerInfoMapper.selectArdServerInfoById(id); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @return 服务器管理 |
| | | */ |
| | | @Override |
| | | public List<ArdServerInfo> selectArdServerManagementList(ArdServerInfo ardServerInfo) { |
| | | return ardServerInfoMapper.selectArdServerManagementList(ardServerInfo); |
| | | public List<ArdServerInfo> selectArdServerInfoList(ArdServerInfo ardServerInfo) { |
| | | return ardServerInfoMapper.selectArdServerInfoList(ardServerInfo); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @return 结果 |
| | | */ |
| | | @Override |
| | | public int insertArdServerManagement(ArdServerInfo ardServerInfo) { |
| | | public int insertArdServerInfo(ArdServerInfo ardServerInfo) { |
| | | ardServerInfo.setId(IdUtils.fastUUID()); |
| | | int i = ardServerInfoMapper.insertArdServerManagement(ardServerInfo); |
| | | int i = ardServerInfoMapper.insertArdServerInfo(ardServerInfo); |
| | | if (i > 0) { |
| | | tyTcpClientManager.connectServer(ardServerInfo); |
| | | } |
| | |
| | | * @return 结果 |
| | | */ |
| | | @Override |
| | | public int updateArdServerManagement(ArdServerInfo ardServerInfo) { |
| | | int i = ardServerInfoMapper.updateArdServerManagement(ardServerInfo); |
| | | public int updateArdServerInfo(ArdServerInfo ardServerInfo) { |
| | | int i = ardServerInfoMapper.updateArdServerInfo(ardServerInfo); |
| | | if (i > 0) { |
| | | tyTcpClientManager.connectServer(ardServerInfo); |
| | | } |
| | |
| | | * @return 结果 |
| | | */ |
| | | @Override |
| | | public int deleteArdServerManagementByIds(String[] ids) { |
| | | int i = ardServerInfoMapper.deleteArdServerManagementByIds(ids); |
| | | public int deleteArdServerInfoByIds(String[] ids) { |
| | | int i = ardServerInfoMapper.deleteArdServerInfoByIds(ids); |
| | | if (i > 0) { |
| | | for (String id : ids) { |
| | | //移除tcp连接 |
| | |
| | | * @return 结果 |
| | | */ |
| | | @Override |
| | | public int deleteArdServerManagementById(String id) { |
| | | return ardServerInfoMapper.deleteArdServerManagementById(id); |
| | | public int deleteArdServerInfoById(String id) { |
| | | return ardServerInfoMapper.deleteArdServerInfoById(id); |
| | | } |
| | | |
| | | /** |
| | |
| | | public AccessTokenReceiver getAccessToken(String id) { |
| | | long timeStamp = getTimeStamp(); |
| | | AccessTokenReceiver accessToken = null; |
| | | ArdServerInfo serverInfo = selectArdServerManagementById(id); |
| | | ArdServerInfo serverInfo = selectArdServerInfoById(id); |
| | | // 准备请求的json |
| | | TokenDTO gtd = TokenDTO.builder() |
| | | .accessKeyId(serverInfo.getAccessKeyId()) |