Преглед на файлове

修复短信查询自定义人群数据库不对的bug

William преди 2 години
родител
ревизия
a2b47e635f
променени са 1 файла, в които са добавени 3 реда и са изтрити 3 реда
  1. 3 3
      src/main/java/org/springblade/sms/mapper/clickhouse/CubeGroupMapper.java

+ 3 - 3
src/main/java/org/springblade/sms/mapper/clickhouse/CubeGroupMapper.java

@@ -17,7 +17,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 public interface CubeGroupMapper extends BaseMapper<JSONObject> {
 
 	@Select("select distinct ${phoneColumn}\r\n"//
-			+ "from ads.${tableName}\r\n"//
+			+ "from ${tableName}\r\n"//
 			+ "where the_value = #{timeZone}\r\n"//
 			+ "${sqlLimit}") //
 	public List<String> getPhoneList(@Param(value = "phoneColumn") String phoneColumn,
@@ -25,13 +25,13 @@ public interface CubeGroupMapper extends BaseMapper<JSONObject> {
 			@Param(value = "sqlLimit") String sqlLimit);
 
 	@Select("select count(distinct ${phoneColumn})\r\n"//
-			+ "from ads.${tableName}\r\n"//
+			+ "from ${tableName}\r\n"//
 			+ "where the_value = #{timeZone}\r\n") //
 	public long getPhoneTotal(@Param(value = "phoneColumn") String phoneColumn,
 			@Param(value = "tableName") String tableName, @Param(value = "timeZone") String timeZone);
 
 	@Select("select *\r\n"//
-			+ "from ads.${tableName}\r\n"//
+			+ "from ${tableName}\r\n"//
 			+ "where the_value = #{timeZone}\r\n" //
 			+ "and ${phoneColumn} = #{phone}\r\n") //
 	public List<JSONObject> getValueByColumn(@Param(value = "tableName") String tableName,