zuhu

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<String ,String > 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"));