diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ApiController.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ApiController.java index ba90fb3..fa48764 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ApiController.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/ApiController.java @@ -8,6 +8,7 @@ import com.weaver.common.distribution.genid.IdGenerator; import com.weaver.common.distribution.lock.DistributionLockInterface; import com.weaver.common.i18n.tool.util.I18nContextUtil; import com.weaver.custom.configcenter.htsysjcmtConfig; +import com.weaver.ebuilder.datasource.api.entity.ExecuteSqlEntity; import com.weaver.ecode.api.dto.FolderDto; import com.weaver.ecode.api.rpc.EcodeService; import com.weaver.framework.client.annotation.WeaverConfigCenter; @@ -24,6 +25,7 @@ import com.weaver.openapi.pojo.message.params.vo.MessageReciver; import com.weaver.openapi.pojo.message.params.vo.MessageSender; import com.weaver.openapi.service.AuthService; import com.weaver.openapi.service.MessageService; +import com.weaver.seconddev.interfaces.prop.ConfigProp; import com.weaver.teams.domain.user.SimpleEmployee; import com.weaver.teams.security.context.UserContext; import com.weaver.teams.security.user.User; @@ -61,7 +63,8 @@ public class ApiController { WflRequestListRest wflRequestListRest; @Autowired private DistributionLockInterface distributionLock; - + @Autowired + private ConfigProp configProp; @Autowired private htsysjcmtConfig htsysjcmtConfig; // @Value("${srmbacklisturl}") @@ -80,10 +83,16 @@ public class ApiController { logger.error("srmbacklisturl == " +1); logger.error("ApiController info : basePackage " + basePackage); + + String jtzhkey = "t6kj9c07jr"; +// String jtzhadmin = configProp.getJtzhadmin(); +// log.error("jtzhkey:"+jtzhkey+" jtzhadmin:"+itzhadmin); + + TenantRpcContext.setTargetTenantKey(jtzhkey); +// TenantRpcContext.setTargetEmployeeId(jtzhadmin); Map map = new HashMap<>(); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); - /** * 外部数据源 查询大数据 */ @@ -103,21 +112,14 @@ public class ApiController { /** * 外部数据源查询超时 */ - - String sql = "select\n" + - " count(1) as zs\n" + - "from\n" + - " atdpersoncardexview\n" + - "where\n" + - " extype = '未刷卡'\n" + - " and shoulddate > '2024-12-01'\n" + - " and shoulddate < '2025-02-24'"; - + String sql = "select count(1) as zs from atdpersoncardexview " + + "where extype = '未刷卡' and shoulddate > '2024-12-01' and shoulddate < '2025-02-24'"; logger.error("sql == " +sql); boolean b1 = rs.executeQuery(sql, "hr"); - logger.error("sql getExecuteResult == " +rs.getExecuteResult()); + logger.error("b1 == " + b1); + logger.error("getExecuteResult == " +rs.getExecuteResult()); if(rs.next()){ logger.error("zs == " +rs.getString("zs"));