add junit test case for InstanceServiceImpl(createInstance)

Author: shaolinchu

cloudnative/src/main/java/com/highgo/platform/apiserver/model/vo/request/CreateInstanceVO.java

@@ -19,6 +19,7 @@
 
 import com.highgo.cloud.enums.InstanceType;
 import lombok.Getter;
+import lombok.Setter;
 
 import javax.persistence.EnumType;
 import javax.persistence.Enumerated;
@@ -31,6 +32,7 @@
 import java.util.Map;
 
 @Getter
+@Setter
 public class CreateInstanceVO implements Serializable {
 
     /**

cloudnative/src/main/java/com/highgo/platform/apiserver/service/impl/InstanceServiceImpl.java

@@ -152,8 +152,6 @@ public InstanceVO createInstance(CreateInstanceVO createInstanceVO) {
                 instanceDTO.getName())) {
             throw new InstanceException(InstanceError.DUPLICATE_NAME);
         }
-        // 获取开通实例的集群的配置信息并入库
-        k8sClusterService.saveClusterInfo(createInstanceVO.getClusterId());
 
         // 执行创建实例并返回实例信息
         instanceDTO = createInstance(instanceDTO);

cloudnative/src/main/java/com/highgo/platform/operator/service/impl/CrServiceImpl.java

@@ -47,6 +47,7 @@
 import io.fabric8.kubernetes.client.KubernetesClient;
 import io.fabric8.kubernetes.client.Watcher;
 import io.fabric8.kubernetes.client.WatcherException;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -189,10 +190,13 @@ public boolean isCrExist(String clusterId, String namespace, String crName) {
         KubernetesClient k8sClient = k8sClientConfiguration.getAdminKubernetesClientById(clusterId);
         DatabaseCluster databaseCluster =
                 k8sClient.customResources(DatabaseCluster.class).inNamespace(namespace).withName(crName).get();
+
+        // DatabaseCluster databaseCluster =
+        // k8sClient.customResources(DatabaseCluster.class).withName(crName).get();
         if (databaseCluster == null) {
             return false;
         } else {
-            return false;
+            return true;
         }
     }