Revert "feat: 新增接口用于修改工作流全局变量#AI Commit#"

This reverts commit fc623db, reversing
changes made to f6887de.

Author: SunPengWan

dss-orchestrator/orchestrators/dss-workflow/dss-workflow-common/src/main/java/com/webank/wedatasphere/dss/workflow/common/entity/DSSFlow.java

@@ -57,8 +57,6 @@ public class DSSFlow implements Flow {
 
     private String defaultProxyUser;
 
-    private String defaultTenant;
-
     public List<String[]> getFlowIdParamConfTemplateIdTuples() {
         return flowIdParamConfTemplateIdTuples;
     }
@@ -297,12 +295,4 @@ public String getDefaultProxyUser() {
     public void setDefaultProxyUser(String defaultProxyUser) {
         this.defaultProxyUser = defaultProxyUser;
     }
-
-    public String getDefaultTenant() {
-        return defaultTenant;
-    }
-
-    public void setDefaultTenant(String defaultTenant) {
-        this.defaultTenant = defaultTenant;
-    }
 }

dss-orchestrator/orchestrators/dss-workflow/dss-workflow-server/src/main/java/com/webank/wedatasphere/dss/workflow/dao/FlowMapper.java

@@ -17,7 +17,6 @@
 package com.webank.wedatasphere.dss.workflow.dao;
 
 
-import com.webank.wedatasphere.dss.orchestrator.common.entity.DSSOrchestratorInfo;
 import com.webank.wedatasphere.dss.workflow.common.entity.DSSFlow;
 import com.webank.wedatasphere.dss.workflow.common.entity.DSSFlowRelation;
 import com.webank.wedatasphere.dss.workflow.entity.vo.FlowInfoVo;
@@ -64,6 +63,4 @@ public interface FlowMapper {
     List<String> getSubflowName(Long parentFlowID);
 
     List<DSSFlow> selectFlowListByOrchestratorId(@Param("orchestratorIdList") List<Long> orchestratorIdList);
-
-    List<DSSOrchestratorInfo> selectOrchestratorByName(@Param("projectId") Long projectId,@Param("orchestratorName") String orchestratorName);
 }

dss-orchestrator/orchestrators/dss-workflow/dss-workflow-server/src/main/java/com/webank/wedatasphere/dss/workflow/dao/TenantVariableLogMapper.java

@@ -163,10 +163,6 @@
           </foreach>
         ) t2 on t1.id = t2.app_id
     </select>
-
-
-    <select id="selectOrchestratorByName">
-        select * from dss_orchestrator_info where project_id = #{projectId} and name =#{orchestratorName}
-    </select>
-
+    
+    
 </mapper>

dss-orchestrator/orchestrators/dss-workflow/dss-workflow-server/src/main/java/com/webank/wedatasphere/dss/workflow/dao/impl/flowMapper.xml

@@ -30,7 +30,6 @@
 import com.webank.wedatasphere.dss.common.label.EnvDSSLabel;
 import com.webank.wedatasphere.dss.common.label.LabelRouteVO;
 import com.webank.wedatasphere.dss.common.utils.AuditLogUtils;
-import com.webank.wedatasphere.dss.common.conf.DSSCommonConf;
 import com.webank.wedatasphere.dss.common.utils.DSSCommonUtils;
 import com.webank.wedatasphere.dss.common.utils.DSSExceptionUtils;
 import com.webank.wedatasphere.dss.contextservice.service.ContextService;
@@ -53,7 +52,6 @@
 import com.webank.wedatasphere.dss.workflow.service.PublishService;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang.StringUtils;
-import org.apache.commons.lang3.ArrayUtils;
 import org.apache.linkis.common.exception.ErrorException;
 import org.apache.linkis.cs.client.utils.SerializeHelper;
 import org.apache.linkis.cs.common.entity.source.LinkisHAWorkFlowContextID;
@@ -501,37 +499,4 @@ public Message getNodeInfoByName(@RequestBody QueryNodeInfoByNameRequest queryNo
         return Message.ok("获取节点信息成功").data("data",dssNodeDefaultList);
     }
 
-    /**
-     * 更新租户变量接口，仅超级管理员可调用
-     * 将tenant全局变量写入到指定根工作流中（子工作流通过getRootFlowProxy动态继承）
-     *
-     * @param request 包含orchestratorName、projectName、tenantValue的请求体
-     * @return 操作结果
-     */
-    @RequestMapping(value = "/updateTenantVariable", method = RequestMethod.POST)
-    public Message updateTenantVariable(@RequestBody UpdateTenantVariableRequest request) {
-        String userName = SecurityFilter.getLoginUsername(httpServletRequest);
-
-        // 校验超级用户权限
-        if (!ArrayUtils.contains(DSSCommonConf.SUPER_ADMIN_LIST, userName)) {
-            return Message.error("仅超级管理员可执行此操作").data("errCode", 90005);
-        }
-
-        request.setOperator(userName);
-
-        try {
-            Cookie[] cookies = httpServletRequest.getCookies();
-            String ticketId = Arrays.stream(cookies)
-                    .filter(cookie -> DSSWorkFlowConstant.BDP_USER_TICKET_ID.equals(cookie.getName()))
-                    .findFirst().map(Cookie::getValue).get();
-            dssFlowService.updateTenantVariable(request, ticketId);
-        } catch (Exception e) {
-            LOGGER.error("租户变量更新失败, orchestratorName={}, projectName={}",
-                    request.getOrchestratorName(), request.getProjectName(), e);
-            return Message.error("租户变量更新失败，原因为：" + e.getMessage());
-        }
-
-        return Message.ok("租户变量写入成功");
-    }
-
 }

dss-orchestrator/orchestrators/dss-workflow/dss-workflow-server/src/main/java/com/webank/wedatasphere/dss/workflow/entity/TenantVariableLogEntry.java

@@ -136,6 +136,4 @@ QueryNodeInfoByPathResponse queryNodeInfo(Long projectId,
 
     void updateGlobalVariables(UpdateGlobalVariablesRequest request, String ticketId) throws Exception;
 
-    void updateTenantVariable(UpdateTenantVariableRequest request, String ticketId) throws Exception;
-
 }