大屏库里查询sql优化

data-collect-server/src/main/java/com/zq/datacollect/DataCollectApplication.java

@@ -3,9 +3,13 @@ package com.zq.datacollect;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
-@SpringBootApplication
+@EnableScheduling
 @MapperScan({"com.zq.datacollect.mapper"})
+@EnableDiscoveryClient
+@SpringBootApplication
 public class DataCollectApplication {
 
     public static void main(String[] args) {

data-collect-server/src/main/java/com/zq/datacollect/config/TokenFilter.java

@@ -37,8 +37,7 @@ import java.io.IOException;
  * @author /
  */
 @Slf4j
-public class
-TokenFilter extends GenericFilterBean {
+public class TokenFilter extends GenericFilterBean {
 
     private final TokenProvider tokenProvider;
     private RedisUtils redisUtils;

data-collect-server/src/main/java/com/zq/datacollect/controller/BigScreenController.java

 package com.zq.datacollect.controller;
 
+import com.zq.common.annotation.AnonymousAccess;
 import com.zq.common.vo.ResultVo;
 import com.zq.datacollect.service.BigScreenService;
 import com.zq.datacollect.service.DataCollecSiteService;
@@ -9,6 +10,7 @@ import io.swagger.annotations.ApiParam;
 import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
+import java.sql.SQLException;
 
 @RestController
 @Api(tags = "大屏数据显示")
@@ -29,31 +31,32 @@ public class BigScreenController {
 
     @ApiOperation("获取检察院数据统计")
     @GetMapping(value = "/getAllCount")
-    public ResultVo getAllCount() {
+    public ResultVo getAllCount() throws SQLException {
         return ResultVo.success(bigScreenService.getAllCount());
     }
 
     @ApiOperation("获取模型类型数据统计")
     @GetMapping(value = "/getModelTypeCount")
-    public ResultVo getModelTypeCount() {
+    @AnonymousAccess
+    public ResultVo getModelTypeCount() throws SQLException {
         return ResultVo.success(bigScreenService.getModelTypeCount());
     }
 
     @ApiOperation("获取模型地区数据统计")
     @GetMapping(value = "/getModelCityCount")
-    public ResultVo getModelCityCount() {
+    public ResultVo getModelCityCount() throws SQLException {
         return ResultVo.success(bigScreenService.getModelCityCount());
     }
 
     @ApiOperation("获取业务类型数据统计")
     @GetMapping(value = "/getYwuType")
-    public ResultVo getYwuType() {
+    public ResultVo getYwuType() throws SQLException {
         return ResultVo.success(bigScreenService.getYwuType());
     }
 
     @ApiOperation("获取市内各地区线索数据统计")
     @GetMapping(value = "/getCluesNum")
-    public ResultVo getCluesNum() {
+    public ResultVo getCluesNum() throws SQLException {
         return ResultVo.success(bigScreenService.getCluesNum());
     }
 
@@ -89,31 +92,31 @@ public class BigScreenController {
 
     @ApiOperation("办案成效数据")
     @GetMapping(value = "/bacxData")
-    public ResultVo getBacxData() {
+    public ResultVo getBacxData() throws SQLException {
         return ResultVo.success(bigScreenService.getBacxData());
     }
 
     @ApiOperation("模型应用成效")
     @GetMapping(value = "/modelEffect")
-    public ResultVo getModelEffect(@RequestParam String shiyuan) {
+    public ResultVo getModelEffect(@RequestParam String shiyuan) throws SQLException {
         return ResultVo.success(bigScreenService.getModelEffect(shiyuan));
     }
 
     @ApiOperation("办案总量")
     @GetMapping(value = "/getBazlNums")
-    public ResultVo getbazlNums() {
+    public ResultVo getbazlNums() throws SQLException {
         return ResultVo.success(bigScreenService.getbazlNums());
     }
 
     @ApiOperation("取保候审案件长期未结列表")
     @GetMapping(value = "/getQbhsajcqwjList")
-    public ResultVo getQbhsajcqwjList() {
+    public ResultVo getQbhsajcqwjList() throws SQLException {
         return ResultVo.success(bigScreenService.getQbhsajcqwjList());
     }
 
     @ApiOperation("模型类型")
     @GetMapping(value = "/getProxyType")
-    public ResultVo getProxyType() {
+    public ResultVo getProxyType() throws SQLException {
         return ResultVo.success(bigScreenService.getProxyType());
     }
 
@@ -126,22 +129,27 @@ public class BigScreenController {
 
     @ApiOperation("平台成果")
     @GetMapping(value = "/getPingTaiData")
-    public ResultVo getPingTaiData() {
+    public ResultVo getPingTaiData() throws SQLException {
         return ResultVo.success(bigScreenService.getPingTaiData());
     }
 
     @ApiOperation("质量指标")
     @GetMapping(value = "/getZhiBiaoData")
-    public ResultVo getZhiBiaoData(@RequestParam String diqu,String type) {
+    public ResultVo getZhiBiaoData(@RequestParam String diqu,String type) throws SQLException {
         return ResultVo.success(bigScreenService.getZhiBiaoData(diqu,type));
     }
 
     @ApiOperation("法律监督")
     @GetMapping(value = "/getJianDuData")
-    public ResultVo getJianDuData(@RequestParam String diqu,String type) {
+    public ResultVo getJianDuData(@RequestParam String diqu,String type) throws SQLException {
         return ResultVo.success(bigScreenService.getJianDuData(diqu,type));
     }
 
+    @ApiOperation("重大敏感案件跟踪情况")
+    @GetMapping(value = "/getZdmgajData")
+    public ResultVo getZdmgajData(@RequestParam String diqu) throws SQLException {
+        return ResultVo.success(bigScreenService.getZdmgajData(diqu));
+    }
 
 
 }

data-collect-server/src/main/java/com/zq/datacollect/entity/CommonQuerySettings.java

+package com.zq.datacollect.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@TableName(value = "common_query_setting")
+public class CommonQuerySettings {
+
+    /**
+     * id
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 查询数据源id
+     */
+    private Long queryDbId;
+
+    /**
+     * 查询名称
+     */
+    private String queryName;
+
+    /**
+     * 查询显示的字段（元数据的名称）
+     */
+    private String showFlied;
+
+    /**
+     * 查询的where条件，包含需要条件的参数
+     */
+    private String queryWhere;
+
+    /**
+     * 查询SQL
+     */
+    private String querySql;
+
+    /**
+     *  createTime
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private Date createTime;
+
+    /**
+     *  updateTime
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private Date updateTime;
+}

data-collect-server/src/main/java/com/zq/datacollect/holder/ConnectDB.java

+package com.zq.datacollect.holder;
+
+import com.alibaba.druid.pool.DruidDataSource;
+import com.alibaba.druid.pool.DruidPooledConnection;
+import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
+import com.zq.common.exception.BusinessException;
+import com.zq.datacollect.entity.QueryDb;
+import com.zq.datacollect.service.CommonQuerysService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.context.annotation.Bean;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PreDestroy;
+import javax.annotation.Resource;
+import java.sql.SQLException;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Slf4j
+@Component
+public class ConnectDB implements ApplicationRunner {
+
+    @Resource
+    private CommonQuerysService service;
+
+    private Map<Integer, DruidPooledConnection> connectionMap = new HashMap<>();
+
+    @Override
+    public void run(ApplicationArguments args) throws SQLException {
+        List<QueryDb> datasource = service.getDatasource();
+        for (QueryDb ds : datasource) {
+            DruidDataSource druidDataSource = DruidDataSourceBuilder.create().build();
+            String url = "";
+            String className = "";
+            switch (ds.getDbType()) {
+                case 1:
+                    className = "com.mysql.cj.jdbc.Driver";
+                    url = "jdbc:mysql://" + ds.getDbIp() + ":" + ds.getDbPort() + "/" + ds.getDbName() + "?characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8&autoReconnect=true&useOldAliasMetadataBehavior=true";
+                    break;
+                case 2:
+                    className = "oracle.jdbc.driver.OracleDriver";
+                    url = "jdbc:oracle:thin:@//" + ds.getDbIp() + ":" + ds.getDbPort() + "/" + ds.getDbName();
+                    break;
+                case 3:
+                    className = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
+                    url = "jdbc:sqlserver://" + ds.getDbIp() + ":" + ds.getDbPort() + "/" + ds.getDbName();
+                    break;
+                default:
+                    throw new BusinessException("不支持的数据库");
+            }
+            druidDataSource.setDriverClassName(className);
+            druidDataSource.setUrl(url);
+            druidDataSource.setUsername(ds.getUsername());
+            druidDataSource.setPassword(ds.getPassword());
+            druidDataSource.init();
+            DruidPooledConnection connection = druidDataSource.getConnection();
+            connectionMap.put(ds.getId(), connection);
+        }
+        log.info("成功加载数据库:" + connectionMap.size());
+    }
+
+    @Bean
+    public ConnectionHolder getConnectionHolder(){
+        return new ConnectionHolder(connectionMap);
+    }
+
+    @PreDestroy
+    public void onClose(){
+        for (DruidPooledConnection connection : connectionMap.values()) {
+            try {
+                connection.close();
+            } catch (SQLException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+}

data-collect-server/src/main/java/com/zq/datacollect/holder/ConnectionHolder.java

+package com.zq.datacollect.holder;
+
+import com.alibaba.druid.pool.DruidPooledConnection;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class ConnectionHolder {
+
+    private Map<Integer, DruidPooledConnection> connectionMap = new HashMap<>();
+
+    public ConnectionHolder(Map<Integer, DruidPooledConnection> connectionMap) {
+        this.connectionMap = connectionMap;
+    }
+
+    public DruidPooledConnection get(Integer id){
+        return connectionMap.get(id);
+    }
+}

data-collect-server/src/main/java/com/zq/datacollect/holder/DatabaseHolder.java

@@ -5,8 +5,6 @@ import com.zq.common.exception.BusinessException;
 import com.zq.datacollect.entity.QueryDb;
 import org.springframework.jdbc.core.JdbcTemplate;
 
-import java.sql.Connection;
-import java.sql.SQLException;
 import java.util.HashMap;
 import java.util.Map;
 
@@ -25,7 +23,7 @@ public class DatabaseHolder {
         switch (dbType) {
             case 1:
                 className = "com.mysql.cj.jdbc.Driver";
-                url = "jdbc:mysql://" + dbIp + ":" + dbPort + "/" + dbName + "?characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8&rewriteBatchedStatements=true&autoReconnect=true";
+                url = "jdbc:mysql://" + dbIp + ":" + dbPort + "/" + dbName + "?characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8&rewriteBatchedStatements=true&autoReconnect=true&useOldAliasMetadataBehavior=true";
                 break;
             case 2:
                 className = "oracle.jdbc.driver.OracleDriver";
@@ -53,4 +51,4 @@ public class DatabaseHolder {
         ((DruidDataSource)jdbcTemplateMap.get(id).getDataSource()).close();
         jdbcTemplateMap.remove(id);
     }
-}
\ No newline at end of file
+}

data-collect-server/src/main/java/com/zq/datacollect/mapper/CommonQuerySettingsDao.java

+package com.zq.datacollect.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.zq.datacollect.entity.CommonQuerySettings;
+
+public interface CommonQuerySettingsDao extends BaseMapper<CommonQuerySettings> {
+}

data-collect-server/src/main/java/com/zq/datacollect/service/BigScreenService.java

 package com.zq.datacollect.service;
 
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.zq.datacollect.entity.DataCollectSetting;
-import com.zq.datacollect.entity.QueryDb;
-import com.zq.datacollect.holder.DatabaseHolder;
-import com.zq.datacollect.mapper.BananChengxiaoMapper;
-import com.zq.datacollect.mapper.DataCollectMapper;
-import com.zq.datacollect.mapper.FljdDataMapper;
-import com.zq.datacollect.mapper.QueryDbMapper;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.jdbc.core.JdbcTemplate;
-import org.springframework.stereotype.Service;
+import java.sql.SQLException;
 
-import javax.annotation.Resource;
-import java.math.BigDecimal;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+public interface BigScreenService {
+    Object getCollectList();
 
-@Slf4j
-@Service
-@RequiredArgsConstructor
-public class BigScreenService {
+    Object getAllCount() throws SQLException;
 
-    @Resource
-    private DataCollectMapper dataCollectMapper;
-    @Resource
-    private QueryDbMapper queryDbMapper;
-    @Resource
-    private BananChengxiaoMapper bananChengxiaoMapper;
-    @Resource
-    private FljdDataMapper fljdDataMapper;
+    Object getModelTypeCount() throws SQLException;
 
+    Object getModelCityCount() throws SQLException;
 
-    public Object getModelTypeCount() {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-        List<Map<String, Object>> cityArea = jdbcTemplate.queryForList("SELECT id,diqu FROM city_area");
-        List<Object> objects = new ArrayList<>();
-        for (Map<String, Object> city : cityArea) {
-            String diqu = city.get("diqu").toString();
-            Map<String, Object> dataMap = new HashMap<>();
-            if (diqu.contains("市院")) {
-                List<Map<String, Object>> mapList = jdbcTemplate.queryForList("SELECT '市院',mx.`建设进度状态` as jsjd, COUNT(1) as typeCount FROM qsdsjfljdmxsjmx  mx  WHERE mx.`部门` like CONCAT('市院','%') GROUP BY  mx.`建设进度状态`");
-                dataMap.put("mapList", mapList);
-            } else if (diqu.contains("市总")) {
-                List<Map<String, Object>> mapList = jdbcTemplate.queryForList("SELECT '市总'as dept,mx.`建设进度状态` as jsjd, COUNT(1) as typeCount FROM qsdsjfljdmxsjmx  mx  GROUP BY  mx.`建设进度状态`");
-                dataMap.put("mapList", mapList);
-            } else {
-                List<Map<String, Object>> mapList = jdbcTemplate.queryForList("SELECT mx.`部门` as dept,mx.`建设进度状态` as jsjd, COUNT(1) as typeCount FROM qsdsjfljdmxsjmx  mx  WHERE mx.`部门` like CONCAT('%','" + diqu + "','%') GROUP BY  mx.`建设进度状态`,mx.`部门`");
-                dataMap.put("mapList", mapList);
-            }
-            objects.add(dataMap);
-        }
+    Object getYwuType() throws SQLException;
 
-        return objects;
-    }
+    Object getCluesNum() throws SQLException;
 
-    public Object getModelCityCount() {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
+    Object getModelDetails(String modelName);
 
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-        List<Map<String, Object>> cityArea = jdbcTemplate.queryForList("SELECT id,diqu FROM city_area");
-        ArrayList<Object> objects = new ArrayList<>();
-        for (Map<String, Object> city : cityArea) {
-            String diqu = city.get("diqu").toString();
-            String id = city.get("id").toString();
-            Map<String, Object> dataMap = new HashMap<>();
-            List<Map<String, Object>> mapLists = null;
-            if (diqu.contains("市总")) {
-                continue;
-            } else {
-                mapLists = jdbcTemplate.queryForList("SELECT mx.`部门` as dept,mx.`模型名称` as modelName,mx.业务条线 as caseType, mx.`建设进度状态` as jsjd FROM qsdsjfljdmxsjmx mx WHERE mx.`部门` like CONCAT('%','" + diqu + "','%')");
-            }
-            dataMap.put("id", id);
-            dataMap.put("numCount", mapLists.size());
-            dataMap.put("cityName", mapLists);
-            objects.add(dataMap);
-        }
+    Object getSjzyqkDetails(Integer dataType);
 
-        return objects;
-    }
+    Object getSjlytjDetails(Integer dataId);
 
-    public List<DataCollectSetting> getCollectList() {
-        List<QueryDb> datasource = queryDbMapper.selectList(new QueryWrapper<>());
-        List<DataCollectSetting> collectSettings = null;
-        for (QueryDb ds : datasource) {
-            if (ds.getDbName().contains("data_collect")) {
-                collectSettings = dataCollectMapper.selectList(new LambdaQueryWrapper<DataCollectSetting>().eq(DataCollectSetting::getToDbId, ds.getId()));
-            }
-        }
-        return collectSettings;
-    }
+    Object getBacxDetails(Integer type);
 
-    public Object getAllCount() {
-        List<Object> objects = new ArrayList<>();
-        List<DataCollectSetting> collectList = getCollectList();
-        for (DataCollectSetting list : collectList) {
-            Map<String, Object> dataMap = new HashMap<>();
-            String toTable = list.getToTable();
-            JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(list.getToDbId());
-            List<Map<String, Object>> mapList = jdbcTemplate.queryForList("SELECT count(1) as dataCount FROM " + toTable);
-            String dataCount = null;
-            for (Map<String, Object> map : mapList) {
-                dataCount = map.get("dataCount").toString();
-            }
-            dataMap.put("dataId", list.getId());
-            dataMap.put("dataType", list.getDataType());
-            dataMap.put("TaskName", list.getTaskName());
-            dataMap.put("dataCount", dataCount);
-            objects.add(dataMap);
-        }
+    Object getPtcgDetails(Integer type);
 
-        return objects;
-    }
+    Object getBacxData() throws SQLException;
 
+    Object getModelEffect(String shiyuan) throws SQLException;
 
-    public Object getYwuType() {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
-        List<String> ywuList = getYwuList();
-        List<Object> dataList = new ArrayList<>();
-        for (String data : ywuList) {
-            JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-            List<Map<String, Object>> mapList = jdbcTemplate.queryForList("SELECT mx.业务条线 as caseType,COUNT(1) as numsCount FROM qsdsjfljdmxsjmx mx  WHERE mx.业务条线 like CONCAT('%','" + data + "','%') GROUP BY caseType");
-            HashMap<String, Object> dataMap = new HashMap<>();
-            BigDecimal addNums = BigDecimal.ZERO;
-            for (Map<String, Object> map : mapList) {
-                BigDecimal numsCount = new BigDecimal(map.get("numsCount").toString());
-                addNums = addNums.add(numsCount);
-            }
-            dataMap.put("caseType", data);
-            dataMap.put("numsCount", addNums);
-            dataList.add(dataMap);
-        }
-        return dataList;
-    }
+    Object getbazlNums() throws SQLException;
 
-    public Object getCluesNum() {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-        List<Map<String, Object>> cityArea = jdbcTemplate.queryForList("SELECT id,diqu FROM city_area");
-        List<Object> objects = new ArrayList<>();
-        for (Map<String, Object> city : cityArea) {
-            String diqu = city.get("diqu").toString();
-            String id = city.get("id").toString();
-            Map<String, Object> dataMap = new HashMap<>();
-            if (diqu.contains("市院")) {
-                List<Map<String, Object>> mapList = jdbcTemplate.queryForList("SELECT '市院' as dept ,SUM(mx.筛查出线索数) as screenNums,SUM(mx.符合监督线索数) as clueNums,SUM(mx.监督数成效) as effectNums FROM qsdsjfljdmxsjmx mx WHERE mx.`部门` like CONCAT('市院','%')");
-                dataMap.put("cityNums", mapList);
-            } else if (diqu.contains("市总")) {
-                List<Map<String, Object>> mapList = jdbcTemplate.queryForList("SELECT '市总'as dept ,SUM(mx.筛查出线索数) as screenNums,SUM(mx.符合监督线索数) as clueNums,SUM(mx.监督数成效) as effectNums FROM qsdsjfljdmxsjmx mx");
-                dataMap.put("cityNums", mapList);
-            } else {
-                List<Map<String, Object>> mapLists = jdbcTemplate.queryForList("SELECT mx.`部门` as dept,SUM(mx.筛查出线索数) as screenNums,SUM(mx.符合监督线索数) as clueNums,SUM(mx.监督数成效) as effectNums FROM qsdsjfljdmxsjmx mx WHERE mx.`部门` like CONCAT('%','" + diqu + "','%')  GROUP BY dept");
-                dataMap.put("cityNums", mapLists);
-            }
-            dataMap.put("id", id);
-            objects.add(dataMap);
-        }
-        return objects;
-    }
+    Object getQbhsajcqwjList() throws SQLException;
 
-    public List<String> getYwuList() {
-        List<String> list = new ArrayList<>();
-        list.add("刑事检察");
-        list.add("刑事执行检察");
-        list.add("司法工作人员职务犯罪检察");
-        list.add("民事检察");
-        list.add("行政检察");
-        list.add("公益诉讼检察");
-        list.add("未成年检察");
-        list.add("控告申诉检察");
-        list.add("知识产权检察");
-        return list;
-    }
+    Object getProxyType() throws SQLException;
 
-    public Object getModelDetails(String modelName) {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-        List<Map<String, Object>> mapList = jdbcTemplate.queryForList("SELECT `部门` AS dept,`业务条线` AS caseType,`模型名称` AS modelName,`建设进度状态` AS jsjd,`备注` AS detail,`是否有成效` AS effect,`筛查出线索数` AS screenNums,`符合监督线索数` AS clueNums,`监督数成效` AS jdcx FROM qsdsjfljdmxsjmx t WHERE t.`模型名称` like CONCAT('%','" + modelName + "','%')");
-        return mapList;
-    }
+    Object getCityArea();
 
-    public List<Map<String, String>> getSjzyqkDetails(Integer dataType) {
-        List<Map<String, String>> list = new ArrayList<>();
-        for (int i = 0; i < 5; i++) {
-            Map<String, String> map = new HashMap<>();
-            map.put("dataName", "数据表" + (i + 1));
-            map.put("dataSize", "100");
-            list.add(map);
-        }
-        return list;
-    }
+    Object getPingTaiData() throws SQLException;
 
-    public List<Map<String, Object>> getSjlytjDetails(Integer dataId) {
-        DataCollectSetting dataCollectSetting = dataCollectMapper.selectById(dataId);
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(dataCollectSetting.getToDbId());
-        return jdbcTemplate.queryForList("SELECT * FROM " + dataCollectSetting.getToTable());
-    }
+    Object getZhiBiaoData(String diqu, String type) throws SQLException;
 
-    public List<Map<String, Object>> getBacxDetails(Integer type) {
-        List<QueryDb> datasource = queryDbMapper.selectList(new QueryWrapper<>());
-        Integer dbId = null;
-        for (QueryDb ds : datasource) {
-            if (ds.getDbName().contains("data_collect")) {
-                dbId = ds.getId();
-            }
-        }
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(dbId);
-        return jdbcTemplate.queryForList("SELECT * FROM qsdsjfljdmxsjmx WHERE 符合监督线索数 >= 1");
-    }
-
-    public List<Map<String, Object>> getPtcgDetails(Integer type) {
-        List<QueryDb> datasource = queryDbMapper.selectList(new QueryWrapper<>());
-        Integer dbId = null;
-        for (QueryDb ds : datasource) {
-            if (ds.getDbName().contains("data_collect")) {
-                dbId = ds.getId();
-            }
-        }
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(dbId);
-        List<Map<String, Object>> list = null;
-        switch (type) {
-            case 1:
-                list = jdbcTemplate.queryForList("SELECT * FROM qsdsjfljdmxsjmx");
-                break;
-            case 2:
-                list = jdbcTemplate.queryForList("SELECT * FROM qsdsjfljdmxsjmx WHERE 符合监督线索数 >= 1");
-                break;
-            case 3:
-                list = jdbcTemplate.queryForList("SELECT * FROM qsdsjfljdmxsjmx WHERE 推动建立机制 >= 1");
-                break;
-        }
-        return list;
-    }
-
-    public Object getbazlNums() {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
-
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-        List<Map<String, Object>> mapList = jdbcTemplate.queryForList("SELECT `单位` as dept,`1审查逮捕件` as scdbj,`2审查起诉件一审二审审监` as hcqsjysessj,`3民事` as ms,`4行政` as xz,`5公益` as gy,`6职务犯罪立案` as zwfzla,`7其他形执刑申检察建议听证` as qtxzxsjcjytz,`8办案总量件` as bazlj  FROM bazl");
-        return mapList;
-    }
-
-    public Object getQbhsajcqwjList() {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-        List<Map<String, Object>> mapList = jdbcTemplate.queryForList("SELECT `单位` as dept,`超过1个半月未结` as oneMonth,`超过2个半月未结`as twoMonth,`超过3个半月未结` as threeMonth,`超过6个半月未结` as sixMonth,`超过1年未结` as oneYear,`合计` as total FROM qbajcqwj");
-        return mapList;
-    }
-
-    public Object getBacxData() {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-        List<Map<String, Object>> objects = jdbcTemplate.queryForList("SELECT t.`南宁` as shiyuan,t.`线索条` as xiansuo,t.`核查条` as hecha,t.`成案件` as chengan,t.`成案件` as shouli,t.`成案件` as lian,t.`成案线索转化率` as chenganRate,t.`线索转化率` as xiansuoRate,t.`挽回损失万` as wanhui,t.`发放救助金万` as fafangjiuzhu,t.`推动建章立制` as jianzhanglizhi FROM bananchengxiao t ");
-        return objects;
-    }
-
-    public Object getModelEffect(String shiyuan) {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-        List<Map<String, Object>> objects = jdbcTemplate.queryForList("SELECT t.`模型类型` as moxing,t.`线索` as xiansuo,t.`核查` as hecha,t.`成案` as chengan,t.`线索转化率` as xiansuoRate,t.`挽回损失万` as wanhui,t.`发放救助金万` as fafangjiuzhu,t.`推动建章立制` as jianzhanglizhi FROM moxingleixing t WHERE t.`市院` like CONCAT('%','" + shiyuan + "','%')");
-        return objects;
-    }
-
-
-    public Object getProxyType() {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-        List<Map<String, Object>> objects = jdbcTemplate.queryForList("SELECT t.case_ratio FROM proxy_type t");
-        return objects;
-    }
-
-    public Object getCityArea() {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-        List<Map<String, Object>> cityArea = jdbcTemplate.queryForList("SELECT id,diqu FROM city_area");
-        return cityArea;
-    }
-
-    public Object getPingTaiData() {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-        List<Map<String, Object>> objects = jdbcTemplate.queryForList("SELECT * FROM pingtaichengguo");
-        return objects;
-    }
-
-    public Object getZhiBiaoData(String diqu,String type) {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
-
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-        List<Map<String, Object>> mapList =null;
-        if (diqu==null||diqu.equals("")) {
-            mapList = jdbcTemplate.queryForList("SELECT cases,piece,case_ratio as caseRatio,unit,cases_name as casesName,piece_name as pieceName ,case_ratio_name as caseRatioName FROM ajzlzypjzbdy WHERE case_ratio_name LIKE CONCAT('%','" + type + "','%')");
-        }else {
-            mapList = jdbcTemplate.queryForList("SELECT cases,piece,case_ratio as caseRatio,unit,cases_name as casesName,piece_name as pieceName ,case_ratio_name as caseRatioName FROM ajzlzypjzbdy WHERE unit LIKE CONCAT('%','" + diqu + "','%') AND case_ratio_name LIKE CONCAT('%','" + type + "','%')");
-        }
-        return mapList;
-    }
-
-    public Object getJianDuData(String diqu, String type) {
-        List<DataCollectSetting> collectList = getCollectList();
-        Integer toDbId = null;
-        for (DataCollectSetting list : collectList) {
-            toDbId = list.getToDbId();
-        }
-
-        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
-        List<Map<String, Object>> mapList =null;
-        if (diqu==null||diqu.equals("")) {
-            mapList=jdbcTemplate.queryForList("SELECT unit,control_data as controlData,data_type as dataType FROM fljd_data WHERE data_type LIKE CONCAT('%','" + type + "','%')");
-        }else if(type==null||type.equals("")){
-            mapList = jdbcTemplate.queryForList("SELECT 单位 as unit,1刑事立案监督 as xslajd,2侦查活动监督 as zchdjd,3审判活动监督 as spzxhdjd,4刑事执行活动违法监督 as xszxhdwfjd,5职务犯罪立案 as zwfzla,6民事裁判监督案件 as mscpjdaj,7民事审判监督案件 as msspjdaj,8民事执行监督案件 as mszxjdaj,9行政裁判监督 as xzcpjd,10行政审判监督 as xzspjd,11行政执行活动监督 as xzzxhdjd,12公益诉讼诉前检察 as gyssqjc,13四大检察监督合计 as sdjcjdhj,14办案总数 as bazs,15监督类案件占比 as jdlajzb,16刑检监督合计 as xjjdhj, 17刑检办案总数 as xjbazs,18刑检监督比重 as xjjdbz,19民事监督合计 as msjdhj,20民事办案总数 as msbazs,21民事监督占比 as msjdhj,22行政监督合计 as xzjdhj,23行政办案总数 as xzbazs,24行政监督占比 as xzjdzb,25民事行政依职权 as msxzyzq,26民行案件总数  as mxajzs,27民行依职职占比 as mxyzzzb,28公益办案总数 as gybazs,29公益监督占比 as gyjdzb FROM fljdsj WHERE 单位 LIKE CONCAT('%','" + diqu + "','%')");
-        }else{
-            mapList=jdbcTemplate.queryForList("SELECT unit,control_data as controlData,data_type as dataType FROM fljd_data WHERE unit LIKE CONCAT('%','" + diqu + "','%') AND data_type LIKE CONCAT('%','" + type + "','%')");
-        }
-        return mapList;
-    }
+    Object getJianDuData(String diqu, String type) throws SQLException;
 
+    Object getZdmgajData(String diqu) throws SQLException;
 }

data-collect-server/src/main/java/com/zq/datacollect/service/CommonQuerysService.java

+package com.zq.datacollect.service;
+
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zq.datacollect.entity.CommonQuerySettings;
+import com.zq.datacollect.entity.QueryDb;
+import com.zq.datacollect.mapper.CommonQuerySettingsDao;
+import com.zq.datacollect.mapper.QueryDbMapper;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+@Service
+public class CommonQuerysService extends ServiceImpl<CommonQuerySettingsDao, CommonQuerySettings> {
+
+    @Resource
+    private QueryDbMapper queryDbDao;
+
+    public List<QueryDb> getDatasource() {
+        return queryDbDao.selectList(new QueryWrapper<>());
+    }
+
+
+}

data-collect-server/src/main/java/com/zq/datacollect/service/impl/BigScreenServiceImpl.java

+package com.zq.datacollect.service.impl;
+
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.alibaba.druid.pool.DruidPooledConnection;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.zq.datacollect.entity.CommonQuerySettings;
+import com.zq.datacollect.entity.DataCollectSetting;
+import com.zq.datacollect.entity.QueryDb;
+import com.zq.datacollect.holder.ConnectionHolder;
+import com.zq.datacollect.holder.DatabaseHolder;
+import com.zq.datacollect.mapper.BananChengxiaoMapper;
+import com.zq.datacollect.mapper.DataCollectMapper;
+import com.zq.datacollect.mapper.FljdDataMapper;
+import com.zq.datacollect.mapper.QueryDbMapper;
+import com.zq.datacollect.service.BigScreenService;
+import com.zq.datacollect.service.CommonQuerysService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class BigScreenServiceImpl implements BigScreenService {
+
+    @Resource
+    private DataCollectMapper dataCollectMapper;
+    @Resource
+    private QueryDbMapper queryDbMapper;
+    @Resource
+    private BananChengxiaoMapper bananChengxiaoMapper;
+    @Resource
+    private FljdDataMapper fljdDataMapper;
+    @Resource
+    private CommonQuerysService commonQuerysService;
+    @Resource
+    private ConnectionHolder connectionHolder;
+
+    public List<Map<String, Object>> CommonQuery(Map<String, Object> body) throws SQLException {
+//        body.remove("token");
+        JSONObject jsonObject = JSONUtil.parseObj(body);
+        String queryName = jsonObject.get("queryName").toString();
+        CommonQuerySettings one = commonQuerysService.getOne(new LambdaQueryWrapper<CommonQuerySettings>().eq(CommonQuerySettings::getQueryName, queryName));
+        QueryDb queryDb = queryDbMapper.selectById(one.getQueryDbId());
+        String sql = one.getQuerySql();
+
+        StringBuilder sb = new StringBuilder();
+
+        Pattern pattern = Pattern.compile("\\{([^}]+)}");
+        Matcher matcher = pattern.matcher(sql);
+        while (matcher.find()) {
+            String group = matcher.group(1);
+            if (jsonObject.containsKey(group)) {
+                String params = jsonObject.getStr(group);
+                sb.append(params);
+                sql = sql.replace("{" + group + "}", params);
+            }
+        }
+
+//        String key = CacheKeys.queryResultKey(one.getId() + sb.toString());
+//        Object obj = redisUtils.getObj(key);
+//        if (obj != null) {
+//            return obj;
+//        }
+
+        PreparedStatement preparedStatement = null;
+        ResultSet resultSet = null;
+        List<Map<String, Object>> results = new ArrayList<>();
+        try {
+            DruidPooledConnection connection = connectionHolder.get(queryDb.getId());
+            preparedStatement = connection.prepareStatement(sql);
+            resultSet = preparedStatement.executeQuery();
+            int columnCount = resultSet.getMetaData().getColumnCount();
+            results = new ArrayList<>();
+            while (resultSet.next()) {
+                Map<String, Object> map = new HashMap<>(columnCount);
+                for (int i = 1; i <= columnCount; i++) {
+                    map.put(resultSet.getMetaData().getColumnName(i), resultSet.getString(i));
+                }
+                results.add(map);
+            }
+        } catch (Exception e) {
+            jsonObject.remove("token");
+            log.error("执行sql查询异常：{}", jsonObject, e);
+        } finally {
+            if (resultSet != null) {
+                resultSet.close();
+            }
+            if (preparedStatement != null) {
+                preparedStatement.close();
+            }
+        }
+
+//        if (CollUtil.isNotEmpty(results)) {
+//            redisUtils.setObj(key, results, 10);
+//
+//            String uuid = SecureUtil.md5(key);
+//            redisUtils.setObj(CacheKeys.queryExecuteKey(uuid), body, 11);
+//        }
+        return results;
+    }
+
+    //获取模型类型数据统计
+    @Override
+    public Object getModelTypeCount() throws SQLException {
+        Map<String, Object> body = new HashMap<>();
+        body.put("queryName", "获取院地市");
+        List<Map<String, Object>> mapList1 = CommonQuery(body);
+        List<Object> objects = new ArrayList<>();
+        for (Map<String, Object> city : mapList1) {
+            String diqu = city.get("diqu").toString();
+            Map<String, Object> dataMap = new HashMap<>();
+            if (diqu.contains("市院")) {
+                Map<String, Object> shiyuan = new HashMap<>();
+                shiyuan.put("queryName", "获取市院模型类型数");
+                List<Map<String, Object>> mapList = CommonQuery(shiyuan);
+                dataMap.put("mapList", mapList);
+            } else if (diqu.contains("市总")) {
+                Map<String, Object> shiyuan = new HashMap<>();
+                shiyuan.put("queryName", "获取市总模型类型数");
+                List<Map<String, Object>> mapList = CommonQuery(shiyuan);
+                dataMap.put("mapList", mapList);
+            } else {
+                Map<String, Object> shiyuan = new HashMap<>();
+                shiyuan.put("queryName", "获取全地市模型类型数");
+                shiyuan.put("diqu", "'" + diqu + "'");
+                List<Map<String, Object>> mapList = CommonQuery(shiyuan);
+                dataMap.put("mapList", mapList);
+            }
+            objects.add(dataMap);
+        }
+        return objects;
+    }
+
+
+    @Override
+    public Object getModelCityCount() throws SQLException {
+        Map<String, Object> body = new HashMap<>();
+        body.put("queryName", "获取院地市");
+        List<Map<String, Object>> mapList1 = CommonQuery(body);
+        List<Object> objects = new ArrayList<>();
+        for (Map<String, Object> city : mapList1) {
+            String diqu = city.get("diqu").toString();
+            String id = city.get("id").toString();
+            Map<String, Object> dataMap = new HashMap<>();
+            List<Map<String, Object>> mapLists = null;
+            if (diqu.contains("市总")) {
+                continue;
+            } else {
+                Map<String, Object> data = new HashMap<>();
+                data.put("queryName", "获取模型地区数据统计");
+                data.put("diqu", "'" + diqu + "'");
+                mapLists = CommonQuery(data);
+            }
+            dataMap.put("id", id);
+            dataMap.put("numCount", mapLists.size());
+            dataMap.put("cityName", mapLists);
+            objects.add(dataMap);
+        }
+        return objects;
+    }
+
+    @Override
+    public List<DataCollectSetting> getCollectList() {
+        List<QueryDb> datasource = queryDbMapper.selectList(new QueryWrapper<>());
+        List<DataCollectSetting> collectSettings = null;
+        for (QueryDb ds : datasource) {
+            if (ds.getDbName().contains("data_collect")) {
+                collectSettings = dataCollectMapper.selectList(new LambdaQueryWrapper<DataCollectSetting>().eq(DataCollectSetting::getToDbId, ds.getId()));
+            }
+        }
+        return collectSettings;
+    }
+
+    @Override
+    public Object getAllCount() throws SQLException {
+        List<Object> objects = new ArrayList<>();
+        List<DataCollectSetting> collectList = getCollectList();
+        for (DataCollectSetting list : collectList) {
+            Map<String, Object> dataMap = new HashMap<>();
+            String toTable = list.getToTable();
+            Map<String, Object> data = new HashMap<>();
+            data.put("queryName", "获取检察院数据统计");
+            data.put("toTable", toTable);
+            List<Map<String, Object>> mapList = CommonQuery(data);
+
+            String dataCount = null;
+            for (Map<String, Object> map : mapList) {
+                dataCount = map.get("dataCount").toString();
+            }
+            dataMap.put("dataId", list.getId());
+            dataMap.put("dataType", list.getDataType());
+            dataMap.put("TaskName", list.getTaskName());
+            dataMap.put("dataCount", dataCount);
+            objects.add(dataMap);
+        }
+
+        return objects;
+    }
+
+
+    @Override
+    public Object getYwuType() throws SQLException {
+        List<DataCollectSetting> collectList = getCollectList();
+        Integer toDbId = null;
+        for (DataCollectSetting list : collectList) {
+            toDbId = list.getToDbId();
+        }
+        List<String> ywuList = getYwuList();
+        List<Object> dataList = new ArrayList<>();
+        for (String data : ywuList) {
+            Map<String, Object> body = new HashMap<>();
+            body.put("queryName", "获取业务类型数据统计");
+            body.put("data", "'" + data + "'");
+            List<Map<String, Object>> mapList = CommonQuery(body);
+
+            HashMap<String, Object> dataMap = new HashMap<>();
+            BigDecimal addNums = BigDecimal.ZERO;
+            for (Map<String, Object> map : mapList) {
+                BigDecimal numsCount = new BigDecimal(map.get("numsCount").toString());
+                addNums = addNums.add(numsCount);
+            }
+            dataMap.put("caseType", data);
+            dataMap.put("numsCount", addNums);
+            dataList.add(dataMap);
+        }
+        return dataList;
+    }
+
+    @Override
+    public Object getCluesNum() throws SQLException {
+        Map<String, Object> body = new HashMap<>();
+        body.put("queryName", "获取院地市");
+        List<Map<String, Object>> mapList1 = CommonQuery(body);
+
+        List<Object> objects = new ArrayList<>();
+        for (Map<String, Object> city : mapList1) {
+            String diqu = city.get("diqu").toString();
+            String id = city.get("id").toString();
+
+            Map<String, Object> dataMap = new HashMap<>();
+            if (diqu.contains("市院")) {
+                Map<String, Object> data = new HashMap<>();
+                data.put("queryName", "获取市院线索数据统计");
+                List<Map<String, Object>> mapList = CommonQuery(data);
+                dataMap.put("cityNums", mapList);
+            } else if (diqu.contains("市总")) {
+                Map<String, Object> data = new HashMap<>();
+                data.put("queryName", "获取市总线索数据统计");
+                List<Map<String, Object>> mapList = CommonQuery(data);
+                dataMap.put("cityNums", mapList);
+            } else {
+                Map<String, Object> data = new HashMap<>();
+                data.put("queryName", "获取市内各地区线索数据统计");
+                data.put("diqu", "'" + diqu + "'");
+                List<Map<String, Object>> mapList = CommonQuery(data);
+                dataMap.put("cityNums", mapList);
+            }
+            dataMap.put("id", id);
+            objects.add(dataMap);
+        }
+        return objects;
+    }
+
+    public List<String> getYwuList() {
+        List<String> list = new ArrayList<>();
+        list.add("刑事检察");
+        list.add("刑事执行检察");
+        list.add("司法工作人员职务犯罪检察");
+        list.add("民事检察");
+        list.add("行政检察");
+        list.add("公益诉讼检察");
+        list.add("未成年检察");
+        list.add("控告申诉检察");
+        list.add("知识产权检察");
+        return list;
+    }
+
+    @Override
+    public Object getModelDetails(String modelName) {
+        List<DataCollectSetting> collectList = getCollectList();
+        Integer toDbId = null;
+        for (DataCollectSetting list : collectList) {
+            toDbId = list.getToDbId();
+        }
+        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
+        List<Map<String, Object>> mapList = jdbcTemplate.queryForList("SELECT `部门` AS dept,`业务条线` AS caseType,`模型名称` AS modelName,`建设进度状态` AS jsjd,`备注` AS detail,`是否有成效` AS effect,`筛查出线索数` AS screenNums,`符合监督线索数` AS clueNums,`监督数成效` AS jdcx FROM qsdsjfljdmxsjmx t WHERE t.`模型名称` like CONCAT('%','" + modelName + "','%')");
+        return mapList;
+    }
+
+    @Override
+    public List<Map<String, String>> getSjzyqkDetails(Integer dataType) {
+        List<Map<String, String>> list = new ArrayList<>();
+        for (int i = 0; i < 5; i++) {
+            Map<String, String> map = new HashMap<>();
+            map.put("dataName", "数据表" + (i + 1));
+            map.put("dataSize", "100");
+            list.add(map);
+        }
+        return list;
+    }
+
+    @Override
+    public List<Map<String, Object>> getSjlytjDetails(Integer dataId) {
+        DataCollectSetting dataCollectSetting = dataCollectMapper.selectById(dataId);
+        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(dataCollectSetting.getToDbId());
+        return jdbcTemplate.queryForList("SELECT * FROM " + dataCollectSetting.getToTable());
+    }
+
+    @Override
+    public List<Map<String, Object>> getBacxDetails(Integer type) {
+//        List<QueryDb> datasource = queryDbMapper.selectList(new QueryWrapper<>());
+//        Integer dbId = null;
+//        for (QueryDb ds : datasource) {
+//            if (ds.getDbName().contains("data_collect")) {
+//                dbId = ds.getId();
+//            }
+//        }
+//        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(dbId);
+//        return jdbcTemplate.queryForList("SELECT * FROM qsdsjfljdmxsjmx WHERE 符合监督线索数 >= 1");
+        return null;
+    }
+
+    @Override
+    public List<Map<String, Object>> getPtcgDetails(Integer type) {
+//        List<QueryDb> datasource = queryDbMapper.selectList(new QueryWrapper<>());
+//        Integer dbId = null;
+//        for (QueryDb ds : datasource) {
+//            if (ds.getDbName().contains("data_collect")) {
+//                dbId = ds.getId();
+//            }
+//        }
+//        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(dbId);
+//        List<Map<String, Object>> list = null;
+//        switch (type) {
+//            case 1:
+//                list = jdbcTemplate.queryForList("SELECT * FROM qsdsjfljdmxsjmx");
+//                break;
+//            case 2:
+//                list = jdbcTemplate.queryForList("SELECT * FROM qsdsjfljdmxsjmx WHERE 符合监督线索数 >= 1");
+//                break;
+//            case 3:
+//                list = jdbcTemplate.queryForList("SELECT * FROM qsdsjfljdmxsjmx WHERE 推动建立机制 >= 1");
+//                break;
+//        }
+//        return list;
+        return null;
+    }
+
+    @Override
+    public Object getbazlNums() throws SQLException {
+        Map<String, Object> body = new HashMap<>();
+        body.put("queryName", "办案总量");
+        List<Map<String, Object>> mapList = CommonQuery(body);
+        return mapList;
+    }
+
+    @Override
+    public Object getQbhsajcqwjList() throws SQLException {
+        Map<String, Object> body = new HashMap<>();
+        body.put("queryName", "取保候审案件长期未结列表");
+        List<Map<String, Object>> mapList = CommonQuery(body);
+        return mapList;
+    }
+
+    @Override
+    public Object getBacxData() throws SQLException {
+        Map<String, Object> body = new HashMap<>();
+        body.put("queryName", "办案成效数据");
+        List<Map<String, Object>> mapList = CommonQuery(body);
+        return mapList;
+    }
+
+    @Override
+    public Object getModelEffect(String shiyuan) throws SQLException {
+        Map<String, Object> body = new HashMap<>();
+        body.put("queryName", "模型应用成效");
+        body.put("shiyuan", "'" + shiyuan + "'");
+        List<Map<String, Object>> objects = CommonQuery(body);
+        return objects;
+    }
+
+
+    @Override
+    public Object getProxyType() throws SQLException {
+        Map<String, Object> body = new HashMap<>();
+        body.put("queryName", "模型类型");
+        List<Map<String, Object>> objects = CommonQuery(body);
+        return objects;
+    }
+
+    @Override
+    public Object getCityArea() {
+        List<DataCollectSetting> collectList = getCollectList();
+        Integer toDbId = null;
+        for (DataCollectSetting list : collectList) {
+            toDbId = list.getToDbId();
+        }
+        JdbcTemplate jdbcTemplate = DatabaseHolder.getJdbcTemplate(toDbId);
+        List<Map<String, Object>> cityArea = jdbcTemplate.queryForList("SELECT id,diqu FROM city_area");
+        return cityArea;
+    }
+
+    @Override
+    public Object getPingTaiData() throws SQLException {
+        Map<String, Object> body = new HashMap<>();
+        body.put("queryName", "平台成果");
+        List<Map<String, Object>> objects = CommonQuery(body);
+        return objects;
+    }
+
+    @Override
+    public Object getZhiBiaoData(String diqu, String type) throws SQLException {
+        List<Map<String, Object>> mapList = null;
+        if (diqu == null || diqu.equals("")) {
+            Map<String, Object> body = new HashMap<>();
+            body.put("diqu", "'" + diqu + "'");
+            body.put("type", "'" + type + "'");
+            body.put("queryName", "质量指标1");
+            mapList = CommonQuery(body);
+        } else {
+            Map<String, Object> body = new HashMap<>();
+            body.put("diqu", "'" + diqu + "'");
+            body.put("type", "'" + type + "'");
+            body.put("queryName", "质量指标2");
+            mapList = CommonQuery(body);
+        }
+        return mapList;
+    }
+
+    @Override
+    public Object getJianDuData(String diqu, String type) throws SQLException {
+        Map<String, Object> body = new HashMap<>();
+        body.put("diqu", "'" + diqu + "'");
+        body.put("type", "'" + type + "'");
+        List<Map<String, Object>> mapList = null;
+        if (diqu == null || diqu.equals("")) {
+            body.put("queryName", "法律监督1");
+            mapList = CommonQuery(body);
+        } else if (type == null || type.equals("")) {
+            body.put("queryName", "法律监督2");
+            mapList = CommonQuery(body);
+        } else {
+            body.put("queryName", "法律监督3");
+            mapList = CommonQuery(body);
+        }
+        return mapList;
+    }
+
+    @Override
+    public Object getZdmgajData(String diqu) throws SQLException {
+        ArrayList<Object> list = new ArrayList<>();
+        Map<String, Object> dataMap = new HashMap<>();
+
+        if (diqu !=null) {
+            Map<String, Object> body = new HashMap<>();
+            body.put("diqu", "'" + diqu + "'");
+            body.put("queryName", "重大敏感案件类型");
+            List<Map<String, Object>> mapList = CommonQuery(body);
+            dataMap.put("zdmgajlx", mapList);
+
+            Map<String, Object> body2 = new HashMap<>();
+            body2.put("diqu", "'" + diqu + "'");
+            body2.put("queryName", "关注案件类型");
+            List<Map<String, Object>> mapList2 = CommonQuery(body2);
+            dataMap.put("gzajlx", mapList2);
+
+            Map<String, Object> body3 = new HashMap<>();
+            body3.put("diqu", "'" + diqu + "'");
+            body3.put("queryName", "检察业务应用系统案件类别");
+            List<Map<String, Object>> mapList3 = CommonQuery(body3);
+            dataMap.put("jcywyyxtajlb", mapList3);
+
+            Map<String, Object> body4 = new HashMap<>();
+            body4.put("diqu", "'" + diqu + "'");
+            body4.put("queryName", "检察环节审结处理结果");
+            List<Map<String, Object>> mapList4 = CommonQuery(body4);
+            dataMap.put("jchjsjcljg", mapList4);
+        }else {
+            return "diqu为空";
+        }
+        list.add(dataMap);
+        return list;
+
+    }
+
+}