sql execute

secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/UpdateTaskNumber.java

@@ -84,12 +84,7 @@ public class UpdateTaskNumber implements Action, EsbServerlessRpcRemoteInterface
                     }
 
                     String sql1 = "update e10_core_business.dbo." + detailTablename + "  set rwbh='" + rwbh + "_" + seq + "' where id=" + id;
-//                    logger_2c12a616.error(String.valueOf("sql1=" + sql1));
-//                    String poolname_dw = CONN_TYPE.workflow.getType();
-//                    // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
-//                    RecordSet rs1 = new RecordSet();
-//                    boolean b1 = rs1.executeUpdate(sql1, poolname_dw);
-                    executeForQuery(null2String(SourceType.LOGIC), "weaver-workflow-list-service", sql1);
+                    boolean b1 = rs.executeUpdate(sql1);
                     k++;
                 }
             } catch (Exception e) {
@@ -121,20 +116,7 @@ public class UpdateTaskNumber implements Action, EsbServerlessRpcRemoteInterface
         return map;
     }
 
-    public Map<String, Object> executeForQuery(String sourceType, String groupId, String sql) {
-//        log.error("executeForQuery sourceType-->" + sourceType + ",groupId-->" + groupId + ",sql-->" + sql);
-        final Tenant currentTenant = TenantContext.getCurrentTenant();
-        TenantRpcContext.setTargetTenantKey(String.valueOf(currentTenant));
-        ExecuteSqlEntity executeSqlEntity = new ExecuteSqlEntity();
-        executeSqlEntity.setSql(cn.hutool.core.codec.Base64.encode(sql));
-        executeSqlEntity.setGroupId(groupId); //groupid,可以访问  E10地址/api/datasource/ds/group?sourceType=LOGIC 获取
-        executeSqlEntity.setSourceType(SourceType.valueOf(sourceType));
-//        log.error("executeForQuery executeSqlEntity-->"+executeSqlEntity.getSql()+"-->"+executeSqlEntity.getGroupId()+"-->"+executeSqlEntity.getSourceType());
-        Map<String, Object> datas = dataSetService.executeSql(executeSqlEntity);
-        logger_2c12a616.error("executeForQuery datas-->" + datas);
-        TenantRpcContext.removeTargetTenantKey();
-        return datas;
-    }
+
     public static String null2String(String s){
         return s == null ? "" : s;
     }

secondev-ht-njwebservice/src/main/java/com/weaver/seconddev/njwebservice/DemoService.java

@@ -15,7 +15,7 @@ import org.springframework.stereotype.Service;
 public class DemoService {
     private final static Logger log = LoggerFactory.getLogger(DemoService.class);
 
-    private static final String HOST = "http://10.6.24.64:20600/papi/openapi";
+//    private static final String HOST = "http://10.6.24.64:20600/papi/openapi";
 
     @Autowired
     private DocUtil docUtil;