/*
|
* Copyright 1999-2019 Seata.io Group.
|
*
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
* you may not use this file except in compliance with the License.
|
* You may obtain a copy of the License at
|
*
|
* http://www.apache.org/licenses/LICENSE-2.0
|
*
|
* Unless required by applicable law or agreed to in writing, software
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
* See the License for the specific language governing permissions and
|
* limitations under the License.
|
*/
|
package io.seata.server.storage;
|
|
import io.seata.common.util.CollectionUtils;
|
import io.seata.common.util.StringUtils;
|
import io.seata.core.model.BranchStatus;
|
import io.seata.core.model.BranchType;
|
import io.seata.core.model.GlobalStatus;
|
import io.seata.core.store.BranchTransactionDO;
|
import io.seata.core.store.GlobalTransactionDO;
|
import io.seata.server.console.vo.BranchSessionVO;
|
import io.seata.server.console.vo.GlobalSessionVO;
|
import io.seata.server.session.BranchSession;
|
import io.seata.server.session.GlobalSession;
|
import io.seata.server.store.SessionStorable;
|
import org.springframework.beans.BeanUtils;
|
|
import java.util.*;
|
|
/**
|
* The session converter
|
*
|
* @author wangzhongxiang
|
* @author doubleDimple
|
*/
|
public class SessionConverter {
|
|
public static GlobalSession convertGlobalSession(GlobalTransactionDO globalTransactionDO, boolean lazyLoadBranch) {
|
if (globalTransactionDO == null) {
|
return null;
|
}
|
GlobalSession session = new GlobalSession(globalTransactionDO.getApplicationId(),
|
globalTransactionDO.getTransactionServiceGroup(),
|
globalTransactionDO.getTransactionName(),
|
globalTransactionDO.getTimeout(), lazyLoadBranch);
|
session.setXid(globalTransactionDO.getXid());
|
session.setTransactionId(globalTransactionDO.getTransactionId());
|
session.setStatus(GlobalStatus.get(globalTransactionDO.getStatus()));
|
session.setApplicationData(globalTransactionDO.getApplicationData());
|
session.setBeginTime(globalTransactionDO.getBeginTime());
|
return session;
|
}
|
|
public static GlobalSession convertGlobalSession(GlobalTransactionDO globalTransactionDO) {
|
return convertGlobalSession(globalTransactionDO, false);
|
}
|
|
public static BranchSession convertBranchSession(BranchTransactionDO branchTransactionDO) {
|
if (branchTransactionDO == null) {
|
return null;
|
}
|
BranchSession branchSession = new BranchSession();
|
branchSession.setXid(branchTransactionDO.getXid());
|
branchSession.setTransactionId(branchTransactionDO.getTransactionId());
|
branchSession.setApplicationData(branchTransactionDO.getApplicationData());
|
branchSession.setBranchId(branchTransactionDO.getBranchId());
|
branchSession.setBranchType(BranchType.valueOf(branchTransactionDO.getBranchType()));
|
branchSession.setResourceId(branchTransactionDO.getResourceId());
|
branchSession.setClientId(branchTransactionDO.getClientId());
|
branchSession.setResourceGroupId(branchTransactionDO.getResourceGroupId());
|
branchSession.setStatus(BranchStatus.get(branchTransactionDO.getStatus()));
|
return branchSession;
|
}
|
|
public static GlobalTransactionDO convertGlobalTransactionDO(SessionStorable session) {
|
if (session == null || !(session instanceof GlobalSession)) {
|
throw new IllegalArgumentException(
|
"The parameter of SessionStorable is not available, SessionStorable:" + StringUtils.toString(session));
|
}
|
GlobalSession globalSession = (GlobalSession)session;
|
|
GlobalTransactionDO globalTransactionDO = new GlobalTransactionDO();
|
globalTransactionDO.setXid(globalSession.getXid());
|
globalTransactionDO.setStatus(globalSession.getStatus().getCode());
|
globalTransactionDO.setApplicationId(globalSession.getApplicationId());
|
globalTransactionDO.setBeginTime(globalSession.getBeginTime());
|
globalTransactionDO.setTimeout(globalSession.getTimeout());
|
globalTransactionDO.setTransactionId(globalSession.getTransactionId());
|
globalTransactionDO.setTransactionName(globalSession.getTransactionName());
|
globalTransactionDO.setTransactionServiceGroup(globalSession.getTransactionServiceGroup());
|
globalTransactionDO.setApplicationData(globalSession.getApplicationData());
|
return globalTransactionDO;
|
}
|
|
public static BranchTransactionDO convertBranchTransactionDO(SessionStorable session) {
|
if (session == null || !(session instanceof BranchSession)) {
|
throw new IllegalArgumentException(
|
"The parameter of SessionStorable is not available, SessionStorable:" + StringUtils.toString(session));
|
}
|
BranchSession branchSession = (BranchSession)session;
|
BranchTransactionDO branchTransactionDO = new BranchTransactionDO();
|
branchTransactionDO.setXid(branchSession.getXid());
|
branchTransactionDO.setBranchId(branchSession.getBranchId());
|
branchTransactionDO.setBranchType(branchSession.getBranchType().name());
|
branchTransactionDO.setClientId(branchSession.getClientId());
|
branchTransactionDO.setResourceGroupId(branchSession.getResourceGroupId());
|
branchTransactionDO.setTransactionId(branchSession.getTransactionId());
|
branchTransactionDO.setApplicationData(branchSession.getApplicationData());
|
branchTransactionDO.setResourceId(branchSession.getResourceId());
|
branchTransactionDO.setStatus(branchSession.getStatus().getCode());
|
return branchTransactionDO;
|
}
|
|
public static void convertToGlobalSessionVo(List<GlobalSessionVO> result, List<GlobalSession> globalSessions) {
|
if (CollectionUtils.isNotEmpty(globalSessions)) {
|
for (GlobalSession globalSession : globalSessions) {
|
GlobalSessionVO globalSessionVO = new GlobalSessionVO();
|
BeanUtils.copyProperties(globalSession,globalSessionVO);
|
globalSessionVO.setStatus(globalSession.getStatus().getCode());
|
globalSessionVO.setTimeout(Long.valueOf(globalSession.getTimeout()));
|
globalSessionVO.setBranchSessionVOs(converToBranchSession(globalSession.getBranchSessions()));
|
result.add(globalSessionVO);
|
}
|
}
|
}
|
|
public static Set<BranchSessionVO> converToBranchSession(List<BranchSession> branchSessions) {
|
Set<BranchSessionVO> branchSessionVOs = new HashSet<>(branchSessions.size());
|
if (CollectionUtils.isNotEmpty(branchSessions)) {
|
for (BranchSession branchSession : branchSessions) {
|
BranchSessionVO branchSessionVONew = new BranchSessionVO();
|
BeanUtils.copyProperties(branchSession,branchSessionVONew);
|
|
branchSessionVONew.setBranchType(branchSession.getBranchType().name());
|
branchSessionVONew.setStatus(branchSession.getStatus().getCode());
|
branchSessionVOs.add(branchSessionVONew);
|
}
|
}
|
return branchSessionVOs;
|
}
|
|
/**
|
* convert GlobalSession to GlobalSessionVO
|
*
|
* @param filteredSessions the GlobalSession list
|
* @return the GlobalSessionVO list
|
*/
|
public static List<GlobalSessionVO> convertGlobalSession(List<GlobalSession> filteredSessions) {
|
|
if (CollectionUtils.isEmpty(filteredSessions)) {
|
return Collections.emptyList();
|
}
|
|
final ArrayList<GlobalSessionVO> result = new ArrayList<>(filteredSessions.size());
|
|
for (GlobalSession session : filteredSessions) {
|
result.add(new GlobalSessionVO(
|
session.getXid(),
|
session.getTransactionId(),
|
session.getStatus().getCode(),
|
session.getApplicationId(),
|
session.getTransactionServiceGroup(),
|
session.getTransactionName(),
|
(long) session.getTimeout(),
|
session.getBeginTime(),
|
session.getApplicationData(),
|
convertBranchSession(session.getBranchSessions())
|
));
|
}
|
return result;
|
}
|
|
/**
|
* convert BranchSession to BranchSessionVO
|
*
|
* @param branchSessions the BranchSession list
|
* @return the BranchSessionVO list
|
*/
|
public static Set<BranchSessionVO> convertBranchSession(List<BranchSession> branchSessions) {
|
|
if (CollectionUtils.isEmpty(branchSessions)) {
|
return Collections.emptySet();
|
}
|
|
final Set<BranchSessionVO> result = new HashSet<>(branchSessions.size());
|
|
for (BranchSession session : branchSessions) {
|
result.add(new BranchSessionVO(
|
session.getXid(),
|
session.getTransactionId(),
|
session.getBranchId(),
|
session.getResourceGroupId(),
|
session.getResourceId(),
|
session.getBranchType().name(),
|
session.getStatus().getCode(),
|
session.getClientId(),
|
session.getApplicationData()
|
));
|
}
|
return result;
|
}
|
|
}
|
