|
@ -6,8 +6,8 @@ import com.yihu.jw.mysql.query.BaseJpaService;
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
//import org.elasticsearch.search.aggregations.bucket.histogram.DateHistogramInterval;
|
|
|
import org.hibernate.FlushMode;
|
|
|
import org.hibernate.Query;
|
|
|
import org.hibernate.SQLQuery;
|
|
|
import org.hibernate.query.NativeQuery;
|
|
|
import org.hibernate.query.Query;
|
|
|
import org.hibernate.Session;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
@ -194,7 +194,7 @@ public class ResourceCenterService extends BaseJpaService {
|
|
|
" '0-1','1-10','11-20','21-30','31-40','41-50','51-60','61-70','71-80','81-90','> 90') as age from ( "+
|
|
|
" SELECT CASE when length(id)=15 then CONCAT('19',substr(id ,7,6)) ELSE substr(id ,7,8) end id from demographics t )t1 "+
|
|
|
" )tt WHERE tt.age is not null GROUP BY tt.age";
|
|
|
SQLQuery query = session.createSQLQuery(sql);
|
|
|
NativeQuery query = session.createSQLQuery(sql);
|
|
|
query.setFlushMode(FlushMode.COMMIT);
|
|
|
return query.list();
|
|
|
}
|
|
@ -206,7 +206,7 @@ public class ResourceCenterService extends BaseJpaService {
|
|
|
"'0-6','7-17','18-40','41-65','> 65') as age from ( " +
|
|
|
" SELECT CASE when length(id)=15 then CONCAT('19',substr(id ,7,6)) ELSE substr(id ,7,8) end id ,gender from demographics t )t1 " +
|
|
|
" )tt WHERE tt.age is not null AND gender IN ('1', '2') GROUP BY tt.age, tt.gender";
|
|
|
SQLQuery query = session.createSQLQuery(sql);
|
|
|
NativeQuery query = session.createSQLQuery(sql);
|
|
|
query.setFlushMode(FlushMode.COMMIT);
|
|
|
return query.list();
|
|
|
}
|
|
@ -268,7 +268,7 @@ public class ResourceCenterService extends BaseJpaService {
|
|
|
public List<Object[]> findAppFeatureIdAndNameByAppIdAndCode(String code, String appId) {
|
|
|
Session session = currentSession();
|
|
|
String sql = "SELECT id, name FROM apps_feature WHERE code = :code AND app_id = :appId";
|
|
|
SQLQuery query = session.createSQLQuery(sql);
|
|
|
NativeQuery query = session.createSQLQuery(sql);
|
|
|
query.setFlushMode(FlushMode.COMMIT);
|
|
|
query.setString("code", code);
|
|
|
query.setString("appId", appId);
|
|
@ -283,7 +283,7 @@ public class ResourceCenterService extends BaseJpaService {
|
|
|
} else {
|
|
|
sql = "SELECT COUNT(1) FROM rs_resource";
|
|
|
}
|
|
|
SQLQuery query = session.createSQLQuery(sql);
|
|
|
NativeQuery query = session.createSQLQuery(sql);
|
|
|
query.setFlushMode(FlushMode.COMMIT);
|
|
|
if (dataSource != null) {
|
|
|
query.setInteger("dataSource", dataSource);
|
|
@ -294,7 +294,7 @@ public class ResourceCenterService extends BaseJpaService {
|
|
|
public List<Object[]> getResourceCategoryIdAndNameList(){
|
|
|
Session session = currentSession();
|
|
|
String sql = "SELECT id, name FROM rs_resource_category";
|
|
|
SQLQuery query = session.createSQLQuery(sql);
|
|
|
NativeQuery query = session.createSQLQuery(sql);
|
|
|
query.setFlushMode(FlushMode.COMMIT);
|
|
|
return query.list();
|
|
|
}
|
|
@ -302,7 +302,7 @@ public class ResourceCenterService extends BaseJpaService {
|
|
|
public BigInteger countResourceByResourceCateIdAndDataSource (String cateId, Integer dataSource) {
|
|
|
Session session = currentSession();
|
|
|
String sql = "SELECT COUNT(1) FROM rs_resource WHERE category_id = :cateId AND data_source = :dataSource";
|
|
|
SQLQuery query = session.createSQLQuery(sql);
|
|
|
NativeQuery query = session.createSQLQuery(sql);
|
|
|
query.setFlushMode(FlushMode.COMMIT);
|
|
|
query.setString("cateId", cateId);
|
|
|
query.setInteger("dataSource", dataSource);
|
|
@ -313,7 +313,7 @@ public class ResourceCenterService extends BaseJpaService {
|
|
|
Session session = currentSession();
|
|
|
String sql;
|
|
|
sql = "SELECT COUNT(1) FROM rs_report";
|
|
|
SQLQuery query = session.createSQLQuery(sql);
|
|
|
NativeQuery query = session.createSQLQuery(sql);
|
|
|
query.setFlushMode(FlushMode.COMMIT);
|
|
|
return (BigInteger)query.uniqueResult();
|
|
|
}
|
|
@ -321,7 +321,7 @@ public class ResourceCenterService extends BaseJpaService {
|
|
|
public List<Object[]> getReportCategoryIdAndNameList(){
|
|
|
Session session = currentSession();
|
|
|
String sql = "SELECT id, name FROM rs_report_category";
|
|
|
SQLQuery query = session.createSQLQuery(sql);
|
|
|
NativeQuery query = session.createSQLQuery(sql);
|
|
|
query.setFlushMode(FlushMode.COMMIT);
|
|
|
return query.list();
|
|
|
}
|
|
@ -329,7 +329,7 @@ public class ResourceCenterService extends BaseJpaService {
|
|
|
public BigInteger countReportByReportCateId (Integer cateId) {
|
|
|
Session session = currentSession();
|
|
|
String sql = "SELECT COUNT(1) FROM rs_report WHERE report_category_id = :cateId";
|
|
|
SQLQuery query = session.createSQLQuery(sql);
|
|
|
NativeQuery query = session.createSQLQuery(sql);
|
|
|
query.setFlushMode(FlushMode.COMMIT);
|
|
|
query.setInteger("cateId", cateId);
|
|
|
return (BigInteger) query.uniqueResult();
|
|
@ -339,7 +339,7 @@ public class ResourceCenterService extends BaseJpaService {
|
|
|
Session session = currentSession();
|
|
|
String sql;
|
|
|
sql = "SELECT COUNT(1) FROM tj_quota";
|
|
|
SQLQuery query = session.createSQLQuery(sql);
|
|
|
NativeQuery query = session.createSQLQuery(sql);
|
|
|
query.setFlushMode(FlushMode.COMMIT);
|
|
|
return (BigInteger)query.uniqueResult();
|
|
|
}
|
|
@ -347,7 +347,7 @@ public class ResourceCenterService extends BaseJpaService {
|
|
|
public List<Object[]> getQuotaCategoryIdAndNameList(){
|
|
|
Session session = currentSession();
|
|
|
String sql = "SELECT id, name FROM tj_quota_category";
|
|
|
SQLQuery query = session.createSQLQuery(sql);
|
|
|
NativeQuery query = session.createSQLQuery(sql);
|
|
|
query.setFlushMode(FlushMode.COMMIT);
|
|
|
return query.list();
|
|
|
}
|
|
@ -355,7 +355,7 @@ public class ResourceCenterService extends BaseJpaService {
|
|
|
public BigInteger countQuotaByQuotaCateId (Integer cateId) {
|
|
|
Session session = currentSession();
|
|
|
String sql = "SELECT COUNT(1) FROM tj_quota WHERE quota_type = :cateId";
|
|
|
SQLQuery query = session.createSQLQuery(sql);
|
|
|
NativeQuery query = session.createSQLQuery(sql);
|
|
|
query.setFlushMode(FlushMode.COMMIT);
|
|
|
query.setInteger("cateId", cateId);
|
|
|
return (BigInteger) query.uniqueResult();
|