mesh-code高效能多数据中心调度

package com.gcloud.mesh.asset.service.impl; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; import java.util.stream.Collectors; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import com.gcloud.mesh.dcs.service.VoltageFmService; import com.gcloud.mesh.framework.core.util.JsonUtil; import org.apache.commons.lang3.StringUtils; import org.jeecg.common.cache.PermissionCodeCache; import org.jeecg.common.constant.enums.SysLogOperateType; import org.jeecg.common.constant.enums.SysLogType; import org.jeecg.common.constant.enums.SysLogUrlOperate; import org.jeecg.common.exception.ParamException; import org.jeecg.common.system.api.ISysBaseAPI; import org.jeecg.common.util.LogUtil; import org.jeecg.common.util.RedisUtil; import org.jeecg.common.util.SpringContextUtils; import org.jeecg.common.util.sm.SmManager; import org.jeecg.common.vo.PermissionsInfoVo; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import com.alibaba.fastjson.JSONObject; import com.ctc.wstx.util.StringUtil; import com.gcloud.framework.db.OperatorType; import com.gcloud.framework.db.PageResult; import com.gcloud.mesh.asset.dao.CloudResourceDao; import com.gcloud.mesh.asset.dao.DatacenterDao; import com.gcloud.mesh.asset.dao.IaasDao; import com.gcloud.mesh.asset.dao.NodeDao; import com.gcloud.mesh.asset.dao.SwitcherDao; import com.gcloud.mesh.asset.entity.CloudResourceEntity; import com.gcloud.mesh.asset.entity.DatacenterEntity; import com.gcloud.mesh.asset.entity.IaasEntity; import com.gcloud.mesh.asset.entity.NodeEntity; import com.gcloud.mesh.asset.entity.SwitcherEntity; import com.gcloud.mesh.asset.enums.DeviceType; import com.gcloud.mesh.asset.enums.MockType; import com.gcloud.mesh.asset.enums.NetworkStatus; import com.gcloud.mesh.asset.enums.PowerStatus; import com.gcloud.mesh.asset.service.IAssetService; import com.gcloud.mesh.asset.sync.ISyncL2System; import com.gcloud.mesh.asset.utils.supervisionsystem.ISupervisionSystem; import com.gcloud.mesh.dcs.dao.AuthorityDao; import com.gcloud.mesh.dcs.service.AuthorityService; import com.gcloud.mesh.header.enums.ResourceSourceType; import com.gcloud.mesh.header.enums.AuthorityResourceClassification; import com.gcloud.mesh.header.enums.OrderType; import com.gcloud.mesh.header.exception.AppErrorCode; import com.gcloud.mesh.header.exception.AssetErrorCode; import com.gcloud.mesh.header.exception.BaseException; import com.gcloud.mesh.header.msg.asset.CreateDatacenterMsg; import com.gcloud.mesh.header.msg.asset.CreateDeviceMsg; import com.gcloud.mesh.header.msg.asset.CreateNodeMsg; import com.gcloud.mesh.header.msg.asset.CreateNodeSmMsg; import com.gcloud.mesh.header.msg.asset.CreateSwitcherMsg; import com.gcloud.mesh.header.msg.asset.ListDatacenterMsg; import com.gcloud.mesh.header.msg.asset.ListDeviceMsg; import com.gcloud.mesh.header.msg.asset.UpdateDatacenterMsg; import com.gcloud.mesh.header.msg.asset.UpdateDeviceMsg; import com.gcloud.mesh.header.msg.asset.UpdateNodeMsg; import com.gcloud.mesh.header.msg.asset.UpdateNodeSmMsg; import com.gcloud.mesh.header.msg.asset.UpdateSwitcherMsg; import com.gcloud.mesh.header.msg.dcs.ListByClassificationMsg; import com.gcloud.mesh.header.vo.asset.CountDeviceVo; import com.gcloud.mesh.header.vo.asset.DatacenterItemVo; import com.gcloud.mesh.header.vo.asset.DeviceItemVo; import com.gcloud.mesh.header.vo.asset.MockIaasVo; import com.gcloud.mesh.header.vo.asset.MockNodeVo; import com.gcloud.mesh.header.vo.asset.MockSwitcherVo; import com.gcloud.mesh.header.vo.asset.NodeItemVo; import com.gcloud.mesh.header.vo.asset.SwitcherItemVo; import com.gcloud.mesh.header.vo.dcs.AuthorityVo; import com.gcloud.mesh.redis.MockRedis; import com.gcloud.mesh.sm.service.SmService; import com.gcloud.mesh.threads.ThreadManager; import com.gcloud.mesh.utils.TimestampUtil; import lombok.extern.slf4j.Slf4j; @Slf4j @Service public class AssetServiceImpl implements IAssetService { private static final String PERFORMANCE = "performance"; private static final String SM_TOKEN = "sm-token"; private boolean isPerformance = false; @Autowired private RedisUtil redisUtil; @Autowired private IaasDao iaasDao; @Autowired private DatacenterDao datacenterDao; @Autowired private NodeDao nodeDao; @Autowired private SwitcherDao switcherDao; @Autowired private CloudResourceDao cloudResourceDao; @Autowired private AuthorityDao authorityDao; @Autowired private AuthorityService authorityService; @Autowired private MockRedis<MockIaasVo> mockIaasRedis; @Autowired private MockRedis<MockNodeVo> mockNodeRedis; @Autowired private MockRedis<MockSwitcherVo> mockSwitcherRedis; @Autowired private SmService smService; @Autowired private VoltageFmService voltageFmService; @Autowired private ISysBaseAPI sysBaseAPI; @Autowired private ISupervisionSystem supervision; @Autowired private ISyncL2System syncL2System; private Map<String, String> datacenterNameMap = new HashMap<String, String>(); private Map<String, DatacenterItemVo> datacenterMap = new ConcurrentHashMap<String, DatacenterItemVo>(); private Map<Integer, Boolean> authorityMap = new ConcurrentHashMap<Integer, Boolean>(); private List<DeviceItemVo> performanceDevices = null; @Override public String createDevice(CreateDeviceMsg msg, String userId) throws BaseException { // TODO Auto-generated method stub // if (isPerformance) { // // 高性能模式 // IaasEntity iaas = new IaasEntity(); // iaas.setId(UUID.randomUUID().toString()); // iaas.setName(msg.getName()); // iaas.setType(msg.getType()); // iaas.setEsn(msg.getEsn()); // iaas.setDatacenterId(msg.getDatacenterId()); // iaas.setCreator(userId); // iaas.setCreateTime(new Date()); // iaas.setDeviceManufacturer(msg.getDeviceManufacturer()); // iaas.setDeviceModel(msg.getDeviceModel()); // iaas.setFrom(ResourceSourceType.MANUAL.getName()); // try { // iaasDao.save(iaas); // } catch (BaseException e) { // log.error("数据库保存失败", e.getMessage()); // throw new BaseException(AssetErrorCode.RESOURSE_DB_SAVE); // } // ThreadManager.submit(new Runnable() { // @Override // public void run() { // // TODO Auto-generated method stub // try { // iaasDao.save(iaas); // } catch (BaseException e) { // log.error("数据库保存失败", e.getMessage()); // throw new BaseException(AssetErrorCode.RESOURSE_DB_SAVE); // } // } // // }); // return iaas.getId(); // } else { IaasEntity iaas = null; Map<String, Object> props = new HashMap<String, Object>(); props.put("type", msg.getType()); props.put("name", msg.getName()); List<IaasEntity> iaass = iaasDao.findByProperties(props); for (IaasEntity iaasdb : iaass) { if (iaasdb != null && iaasdb.getName().equals(msg.getName())) { throw new ParamException(AssetErrorCode.DEVICE_NAME_EXIST); } } if (DeviceType.getDeviceTypeByNo(msg.getType()) == null) { throw new ParamException(AssetErrorCode.RESOURSE_NOT_EXIST); } if (DeviceType.SERVER.getNo() == msg.getType() || DeviceType.SWITCHER.getNo() == msg.getType()) { throw new ParamException(AssetErrorCode.RESOURSE_TYPE_ERROR); } DatacenterEntity dc = datacenterDao.getById(msg.getDatacenterId()); if (dc == null) { throw new ParamException(AssetErrorCode.DATACENTER_NOT_EXIST); } iaas = new IaasEntity(); iaas.setId(UUID.ran