From 36f06ccf0b7ff29e4e4cde0a1705344668795f6f Mon Sep 17 00:00:00 2001
From: v_yangyangwang <v_yangyangwang@webank.com>
Date: Sat, 9 Apr 2022 19:10:55 +0800
Subject: [PATCH] submit dss appconns del project and update project

---
 .../ExchangisProjectDeletionOperation.java    | 18 ++--
 .../ExchangisProjectUpdateOperation.java      |  8 +-
 .../service/ExchangisProjectService.java      |  3 +-
 .../project/server/mapper/ProjectMapper.java  |  8 ++
 .../server/mapper/impl/ProjectMapper.xml      | 10 +++
 .../ExchangisProjectDssAppConnRestfulApi.java | 82 ++++++++++++++++++-
 .../server/service/ProjectService.java        |  9 ++
 .../service/impl/ProjectServiceImpl.java      | 18 +++-
 .../components/datasourceForm/index.vue       |  2 +-
 9 files changed, 138 insertions(+), 20 deletions(-)

diff --git a/exchangis-plugins/exchangis-appconn/src/main/java/com/webank/wedatasphere/exchangis/dss/appconn/operation/project/ExchangisProjectDeletionOperation.java b/exchangis-plugins/exchangis-appconn/src/main/java/com/webank/wedatasphere/exchangis/dss/appconn/operation/project/ExchangisProjectDeletionOperation.java
index 4a4cd2bb3..08643297d 100644
--- a/exchangis-plugins/exchangis-appconn/src/main/java/com/webank/wedatasphere/exchangis/dss/appconn/operation/project/ExchangisProjectDeletionOperation.java
+++ b/exchangis-plugins/exchangis-appconn/src/main/java/com/webank/wedatasphere/exchangis/dss/appconn/operation/project/ExchangisProjectDeletionOperation.java
@@ -9,12 +9,14 @@
 import com.webank.wedatasphere.exchangis.dss.appconn.constraints.Constraints;
 import com.webank.wedatasphere.exchangis.dss.appconn.request.action.ExchangisDeleteAction;
 import com.webank.wedatasphere.exchangis.dss.appconn.ref.ExchangisProjectResponseRef;
+import com.webank.wedatasphere.exchangis.dss.appconn.request.action.ExchangisEntityPostAction;
 import com.webank.wedatasphere.exchangis.dss.appconn.response.result.ExchangisEntityRespResult;
 import org.apache.linkis.httpclient.request.HttpAction;
 import org.apache.linkis.httpclient.response.HttpResult;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.HashMap;
 import java.util.Map;
 import java.util.Objects;
 
@@ -39,15 +41,17 @@ protected Logger getLogger() {
 
     @Override
     public ProjectResponseRef deleteProject(ProjectRequestRef projectRequestRef) throws ExternalOperationFailedException {
-        // TODO Get the project id
-        long projectId = 0l;
-        String url = requestURL("/project/" + projectId);
         LOG.info("delete project request => dss_projectId:{}, name:{}, createName:{}", projectRequestRef.getId(),
                 projectRequestRef.getName(), projectRequestRef.getCreateBy());
-        ExchangisEntityRespResult.BasicMessageEntity<Map<String, String>> entity = requestToGetEntity(url, projectRequestRef.getWorkspace(), projectRequestRef,
-                (requestRef) -> {
-                    // Build project delete action
-                    return new ExchangisDeleteAction(requestRef.getCreateBy());
+        String url = requestURL("appProject/" + projectRequestRef.getName()+"/");
+        ExchangisEntityRespResult.BasicMessageEntity<Map<String, Object>> entity = requestToGetEntity(url,projectRequestRef.getWorkspace(), projectRequestRef,
+                (requestRef) ->{
+                    ExchangisEntityPostAction exchangisEntityPostAction = new ExchangisEntityPostAction();
+                    exchangisEntityPostAction.setUser(requestRef.getCreateBy());
+                    HashMap<String, String> labels = new HashMap<>();
+                    labels.put("route", "dev");
+                    exchangisEntityPostAction.addRequestPayload("labels", labels);
+                    return exchangisEntityPostAction;
                 }, Map.class);
         if (Objects.isNull(entity)){
             throw new ExternalOperationFailedException(31020, "The response entity cannot be empty", null);
diff --git a/exchangis-plugins/exchangis-appconn/src/main/java/com/webank/wedatasphere/exchangis/dss/appconn/operation/project/ExchangisProjectUpdateOperation.java b/exchangis-plugins/exchangis-appconn/src/main/java/com/webank/wedatasphere/exchangis/dss/appconn/operation/project/ExchangisProjectUpdateOperation.java
index 7a504431f..eac1d3c92 100644
--- a/exchangis-plugins/exchangis-appconn/src/main/java/com/webank/wedatasphere/exchangis/dss/appconn/operation/project/ExchangisProjectUpdateOperation.java
+++ b/exchangis-plugins/exchangis-appconn/src/main/java/com/webank/wedatasphere/exchangis/dss/appconn/operation/project/ExchangisProjectUpdateOperation.java
@@ -27,17 +27,15 @@ public class ExchangisProjectUpdateOperation extends AbstractExchangisProjectOpe
     private StructureService structureService;
 
     public ExchangisProjectUpdateOperation(StructureService structureService) {
+        super(new String[]{"appProject"});
         setStructureService(structureService);
     }
 
     @Override
     public ProjectResponseRef updateProject(ProjectRequestRef projectRequestRef) throws ExternalOperationFailedException {
-        // TODO Get the project id
-        long projectId = 0l;
-        String url = requestURL("/project/" + projectId);
         LOG.info("update project request => dss_projectId:{}, name:{}, createName:{}",
                 projectRequestRef.getId(), projectRequestRef.getName(),projectRequestRef.getCreateBy());
-        ExchangisEntityRespResult.BasicMessageEntity<Map<String, Object>> entity = requestToGetEntity(url, projectRequestRef.getWorkspace(), projectRequestRef,
+        ExchangisEntityRespResult.BasicMessageEntity<Map<String, Object>> entity = requestToGetEntity(projectRequestRef.getWorkspace(), projectRequestRef,
                 (requestRef) -> {
                     // Build project put(update) action
                     return new ExchangisEntityPutAction<>(getProjectEntity(requestRef), requestRef.getCreateBy());
@@ -47,7 +45,7 @@ public ProjectResponseRef updateProject(ProjectRequestRef projectRequestRef) thr
         }
         ExchangisEntityRespResult httpResult = entity.getResult();
         LOG.info("update project response => status {}, response {}", httpResult.getStatusCode(), httpResult.getResponseBody());
-        AtomicLong newProjectId = new AtomicLong(projectId);
+        AtomicLong newProjectId = new AtomicLong(projectRequestRef.getId());
         try {
             Optional.ofNullable(entity.getData()).ifPresent( data -> newProjectId
                     .set(Long.parseLong(String.valueOf(data.getOrDefault(Constraints.PROJECT_ID, newProjectId.get())))));
diff --git a/exchangis-plugins/exchangis-appconn/src/main/java/com/webank/wedatasphere/exchangis/dss/appconn/service/ExchangisProjectService.java b/exchangis-plugins/exchangis-appconn/src/main/java/com/webank/wedatasphere/exchangis/dss/appconn/service/ExchangisProjectService.java
index 34965d1ea..080220ff0 100644
--- a/exchangis-plugins/exchangis-appconn/src/main/java/com/webank/wedatasphere/exchangis/dss/appconn/service/ExchangisProjectService.java
+++ b/exchangis-plugins/exchangis-appconn/src/main/java/com/webank/wedatasphere/exchangis/dss/appconn/service/ExchangisProjectService.java
@@ -2,6 +2,7 @@
 
 import com.webank.wedatasphere.dss.standard.app.structure.project.*;
 import com.webank.wedatasphere.exchangis.dss.appconn.operation.project.ExchangisProjectCreationOperation;
+import com.webank.wedatasphere.exchangis.dss.appconn.operation.project.ExchangisProjectDeletionOperation;
 import com.webank.wedatasphere.exchangis.dss.appconn.operation.project.ExchangisProjectUpdateOperation;
 
 /**
@@ -31,7 +32,7 @@ protected ProjectUpdateOperation createProjectUpdateOperation() {
 
     @Override
     protected ProjectDeletionOperation createProjectDeletionOperation() {
-        return null;
+        return new ExchangisProjectDeletionOperation(this);
     }
 
     @Override
diff --git a/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/mapper/ProjectMapper.java b/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/mapper/ProjectMapper.java
index 129eb880e..7eeb19428 100644
--- a/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/mapper/ProjectMapper.java
+++ b/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/mapper/ProjectMapper.java
@@ -58,10 +58,18 @@ public interface ProjectMapper {
      */
     void deleteOne(Long projectId);
 
+    /**
+     * Delete project by name
+     * @param name
+     */
+    void deleteByName(String name);
+
     /**
      * get projects by name
      * @param projectName
      * @return List
      */
     List<ExchangisProject> getDetailByName(@Param("projectName") String projectName);
+
+    ExchangisProject selectByName(String name);
 }
diff --git a/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/mapper/impl/ProjectMapper.xml b/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/mapper/impl/ProjectMapper.xml
index fbd61e1ca..9871e1094 100644
--- a/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/mapper/impl/ProjectMapper.xml
+++ b/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/mapper/impl/ProjectMapper.xml
@@ -113,6 +113,16 @@
         <![CDATA[DELETE FROM `exchangis_project_info` WHERE id = #{id};]]>
     </delete>
 
+    <delete id="deleteByName">
+        DELETE FROM exchangis_project_info WHERE name = #{name}
+    </delete>
+
+
+    <select id="selectByName" resultMap="projectResult">
+        select * from exchangis_project_info WHERE name = #{name}
+    </select>
+
+
     <select id="getDetailByName" resultMap="projectResult">
         <![CDATA[ SELECT * FROM `exchangis_project_info`]]>
         <where>
diff --git a/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/restful/external/ExchangisProjectDssAppConnRestfulApi.java b/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/restful/external/ExchangisProjectDssAppConnRestfulApi.java
index 17bfb789f..a6274ce1a 100644
--- a/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/restful/external/ExchangisProjectDssAppConnRestfulApi.java
+++ b/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/restful/external/ExchangisProjectDssAppConnRestfulApi.java
@@ -1,11 +1,13 @@
 package com.webank.wedatasphere.exchangis.project.server.restful.external;
 
+import com.webank.wedatasphere.exchangis.common.validator.groups.UpdateGroup;
 import com.webank.wedatasphere.exchangis.project.server.entity.ExchangisProject;
 import com.webank.wedatasphere.exchangis.project.server.service.ProjectService;
 import com.webank.wedatasphere.exchangis.project.server.utils.ExchangisProjectRestfulUtils;
 import com.webank.wedatasphere.exchangis.project.server.vo.ExchangisProjectAppVo;
 import com.webank.wedatasphere.exchangis.project.server.vo.ExchangisProjectAppVo;
 import com.webank.wedatasphere.exchangis.project.server.vo.ExchangisProjectInfo;
+import org.apache.commons.lang.StringUtils;
 import org.apache.commons.math3.util.Pair;
 import org.apache.linkis.common.utils.JsonUtils;
 import org.apache.linkis.server.Message;
@@ -14,13 +16,12 @@
 import org.slf4j.LoggerFactory;
 import org.springframework.validation.BindingResult;
 import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
+import javax.validation.groups.Default;
+import java.util.Objects;
 
 /**
  * Restful class for dss project
@@ -58,4 +59,77 @@ public Message createProject(@Validated @RequestBody ExchangisProjectAppVo proje
             return Message.error("Fail to create project from DSS(创建工程失败)");
         }
     }
+
+
+    /**
+     * Update project
+     * @param request request
+     * @param projectVo project vo
+     * @return
+     */
+    @RequestMapping( value = "/{id:\\d+}", method = RequestMethod.PUT)
+    public Message updateProject(@PathVariable("id") Long id, @Validated({UpdateGroup.class, Default.class}) @RequestBody ExchangisProjectInfo projectVo
+            , BindingResult result, HttpServletRequest request) {
+        if (result.hasErrors()){
+            return Message.error(result.getFieldErrors().get(0).getDefaultMessage());
+        }
+        String username = SecurityFilter.getLoginUsername(request);
+        try {
+            ExchangisProjectInfo projectStored = projectService.getProjectById(Long.valueOf(projectVo.getId()));
+            if (!hasAuthority(username, projectStored)){
+                return Message.error("You have no permission to update (没有项目的更新权限)");
+            }
+            String domain = projectStored.getDomain();
+            if (StringUtils.isNotBlank(domain) && !ExchangisProject.Domain.STANDALONE.name()
+                    .equalsIgnoreCase(domain)){
+                return Message.error("Cannot update the outer project (无法更新来自 " + domain + " 的外部项目)");
+            }
+            LOG.info("UpdateProject vo: {}, userName: {}", JsonUtils.jackson().writeValueAsString(projectVo), username);
+            projectService.updateProject(projectVo, username);
+            return ExchangisProjectRestfulUtils.dealOk("更新工程成功",
+                    new Pair<>("projectName", projectVo.getName()),
+                    new Pair<>("projectId", projectVo.getId()));
+        } catch (Exception t) {
+            LOG.error("Failed to update project for user {}", username, t);
+            return Message.error("Fail to update project (更新工程失败)");
+        }
+    }
+
+    /**
+     * Delete project
+     * @param request http request
+     * @param name project name
+     * @return
+     */
+    @RequestMapping( value = "/{name}", method = RequestMethod.POST)
+    public Message deleteProject(HttpServletRequest request, @PathVariable("name") String name) {
+        String username = SecurityFilter.getLoginUsername(request);
+        try {
+            ExchangisProjectInfo projectInfo = projectService.selectByName(name);
+//            if (!hasAuthority(username, projectInfo)){
+//                return Message.error("You have no permission to delete (删除工程失败)");
+//            }
+//            String domain = projectInfo.getDomain();
+//            if (StringUtils.isNotBlank(domain) && !ExchangisProject.Domain.STANDALONE.name()
+//                    .equalsIgnoreCase(domain)){
+//                return Message.error("Cannot delete the outer project (无法删除来自 " + domain + " 的外部项目)");
+//            }
+            projectService.deleteProjectByName(name);
+            return ExchangisProjectRestfulUtils.dealOk("删除工程成功");
+        } catch (Exception t) {
+            LOG.error("Failed to delete project for user {}", username, t);
+            return Message.error("Failed to delete project (删除工程失败)");
+        }
+
+    }
+
+
+    /**
+     * @param username username
+     * @param project project
+     * @return
+     */
+    private boolean hasAuthority(String username, ExchangisProjectInfo project){
+        return Objects.nonNull(project) && username.equals(project.getCreateUser());
+    }
 }
diff --git a/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/service/ProjectService.java b/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/service/ProjectService.java
index f963ab110..6ae561dd6 100644
--- a/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/service/ProjectService.java
+++ b/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/service/ProjectService.java
@@ -3,6 +3,7 @@
 
 import com.webank.wedatasphere.exchangis.common.pager.PageResult;
 import com.webank.wedatasphere.exchangis.job.exception.ExchangisJobException;
+import com.webank.wedatasphere.exchangis.project.server.entity.ExchangisProject;
 import com.webank.wedatasphere.exchangis.project.server.vo.ExchangisProjectInfo;
 import com.webank.wedatasphere.exchangis.project.server.vo.ProjectQueryVo;
 
@@ -48,6 +49,12 @@ public interface ProjectService {
       */
      void deleteProject(Long projectId) throws ExchangisJobException;
 
+     /**
+      * Delete project by name
+      * @param name
+      */
+     void deleteProjectByName(String name) throws ExchangisJobException;
+
      /**
       * Query the project detail
       * @param projectId project id
@@ -56,4 +63,6 @@ public interface ProjectService {
      ExchangisProjectInfo getProjectDetailById(Long projectId);
 
      ExchangisProjectInfo getProjectById(Long projectId);
+
+     ExchangisProjectInfo selectByName(String name);
 }
diff --git a/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/service/impl/ProjectServiceImpl.java b/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/service/impl/ProjectServiceImpl.java
index 32d3c089f..c078133e5 100644
--- a/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/service/impl/ProjectServiceImpl.java
+++ b/exchangis-project/exchangis-project-server/src/main/java/com/webank/wedatasphere/exchangis/project/server/service/impl/ProjectServiceImpl.java
@@ -75,6 +75,7 @@ public void updateProject(ExchangisProjectInfo projectVo, String userName) {
         updatedProject.setViewUsers(projectVo.getViewUsers());
         updatedProject.setEditUsers(projectVo.getEditUsers());
         updatedProject.setExecUsers(projectVo.getExecUsers());
+        updatedProject.setDescription(projectVo.getDescription());
         // Set the updated properties
         updatedProject.setLastUpdateUser(userName);
         updatedProject.setLastUpdateTime(Calendar.getInstance().getTime());
@@ -115,7 +116,13 @@ public void deleteProject(Long projectId) throws ExchangisJobException {
         }
     }
 
-
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void deleteProjectByName(String name) throws ExchangisJobException {
+        // First to delete the project to lock the record
+        ExchangisProject project = this.projectMapper.selectByName(name);
+        this.projectMapper.deleteByName(name);
+    }
     @Override
     public ExchangisProjectInfo getProjectDetailById(Long projectId) {
         ExchangisProject project = this.projectMapper.getDetailById(projectId);
@@ -144,5 +151,12 @@ public ExchangisProjectInfo getProjectById(Long projectId) {
         return null;
     }
 
-
+    @Override
+    public ExchangisProjectInfo selectByName(String name){
+        ExchangisProject project = this.projectMapper.selectByName(name);
+        if (Objects.nonNull(project)){
+            return new ExchangisProjectInfo(project);
+        }
+        return null;
+    }
 }
diff --git a/web/src/pages/dataSourceManage/components/datasourceForm/index.vue b/web/src/pages/dataSourceManage/components/datasourceForm/index.vue
index 5b1a73d15..280b7ca55 100644
--- a/web/src/pages/dataSourceManage/components/datasourceForm/index.vue
+++ b/web/src/pages/dataSourceManage/components/datasourceForm/index.vue
@@ -53,7 +53,7 @@ const typesMap = {
     const fApi = self.fApi;
     if(typeof data.dataSource === 'string'){
       if (!/^https?:/.test(data.dataSource)) {
-        data.dataSource = window.location.origin + '/api/rest_j/v1' + data.dataSource
+        data.dataSource = window.location.origin  + data.dataSource
       }
       request(data.dataSource, {
         labels: ''