|
|
@@ -1,185 +1,185 @@
|
|
|
package cn.com.usky.iot.alarm.dao;
|
|
|
|
|
|
-import java.util.List;
|
|
|
-
|
|
|
import cn.com.usky.iot.entity.MonthReport;
|
|
|
import cn.com.usky.iot.entity.YearReport;
|
|
|
-import org.hibernate.SQLQuery;
|
|
|
+import cn.com.usky.utils.DaoQuery;
|
|
|
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
|
|
|
|
|
|
-import cn.com.usky.utils.DaoQuery;
|
|
|
+import java.util.List;
|
|
|
|
|
|
public class YtiotVAlarmDaoImpl extends HibernateDaoSupport implements YtiotVAlarmDao {
|
|
|
|
|
|
- private DaoQuery daoQuery;
|
|
|
-
|
|
|
- public DaoQuery getDaoQuery() {
|
|
|
- return daoQuery;
|
|
|
- }
|
|
|
-
|
|
|
- public void setDaoQuery(DaoQuery daoQuery) {
|
|
|
- this.daoQuery = daoQuery;
|
|
|
- }
|
|
|
-
|
|
|
- public String tbname(String name) {
|
|
|
- if (name.equals("ytiot_v_hj"))
|
|
|
- return "YtiotVHj";
|
|
|
- if (name.equals("ytiot_v_sj"))
|
|
|
- return "YtiotVSj";
|
|
|
- if (name.equals("ytiot_v_rtu"))
|
|
|
- return "YtiotVRtu";
|
|
|
- if (name.equals("ytiot_v_video2017"))
|
|
|
- return "YtiotVideoAlarm";
|
|
|
- if(name.equals("ytiot_v_sync"))
|
|
|
- return"YtiotVSync";
|
|
|
- if(name.equals("ytiot_v_syncdata"))
|
|
|
- return"YtiotVSyncData";
|
|
|
- if(name.equals("ytiot_v_lift"))
|
|
|
- return"YtiotVLift";
|
|
|
- if(name.equals("ytiot_v_video2017s"))
|
|
|
- return"YtiotVideoOffline";
|
|
|
- return name;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int getCount(String tablename, String sqlwhere) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return daoQuery.getCount(tbname(tablename), sqlwhere);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List query(String tablename, String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return daoQuery.query(tbname(tablename), sqlwhere, order, dir, start, limit);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int getHJCount(String sqlwhere) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return getCount("ytiot_v_hj", sqlwhere);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int getEFCount(String sqlwhere) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return getCount("ytiot_v_efire", sqlwhere);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int getEFireCount(String sqlwhere) {
|
|
|
- return daoQuery.getCount("YtiotVEfire", sqlwhere);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List HJQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return query("ytiot_v_hj", sqlwhere, order, dir, start, limit);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List HJ2Query(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return query("ytiot_v_hj2", sqlwhere, order, dir, start, limit);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int getSJCount(String sqlwhere) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return getCount("ytiot_v_sj", sqlwhere);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List SJQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return query("ytiot_v_sj", sqlwhere, order, dir, start, limit);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int getRTUCount(String sqlwhere) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return getCount("ytiot_v_rtu", sqlwhere);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List RTUQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return query("ytiot_v_rtu", sqlwhere, order, dir, start, limit);
|
|
|
- }
|
|
|
- @Override
|
|
|
- public List VideoAlarmQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return query("ytiot_v_video2017", sqlwhere, order, dir, start, limit);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int getLiftCount(String sqlwhere) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return getCount("ytiot_v_lift", sqlwhere);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List LiftQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return query("ytiot_v_lift", sqlwhere, order, dir, start, limit);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List EFireQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- return query("YtiotVEfire", sqlwhere, order, dir, start, limit);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int getDeviceCount(String sqlwhere) {
|
|
|
- return getCount("ytiot_v_sync", sqlwhere);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List DeviceQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
- return query("YtiotVSync", sqlwhere, order, dir, start, limit);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List queryBySQL(String sql) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
- System.out.println(sql);
|
|
|
- return daoQuery.queryBySQL(sql);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public void execSQL(String sql) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
+ private DaoQuery daoQuery;
|
|
|
+
|
|
|
+ public DaoQuery getDaoQuery() {
|
|
|
+ return daoQuery;
|
|
|
+ }
|
|
|
+
|
|
|
+ public void setDaoQuery(DaoQuery daoQuery) {
|
|
|
+ this.daoQuery = daoQuery;
|
|
|
+ }
|
|
|
+
|
|
|
+ public String tbname(String name) {
|
|
|
+ if (name.equals("ytiot_v_hj"))
|
|
|
+ return "YtiotVHj";
|
|
|
+ if (name.equals("ytiot_v_sj"))
|
|
|
+ return "YtiotVSj";
|
|
|
+ if (name.equals("ytiot_v_rtu"))
|
|
|
+ return "YtiotVRtu";
|
|
|
+ if (name.equals("ytiot_v_video2017"))
|
|
|
+ return "YtiotVideoAlarm";
|
|
|
+ if (name.equals("ytiot_v_sync"))
|
|
|
+ return "YtiotVSync";
|
|
|
+ if (name.equals("ytiot_v_syncdata"))
|
|
|
+ return "YtiotVSyncData";
|
|
|
+ if (name.equals("ytiot_v_lift"))
|
|
|
+ return "YtiotVLift";
|
|
|
+ if (name.equals("ytiot_v_video2017s"))
|
|
|
+ return "YtiotVideoOffline";
|
|
|
+ return name;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int getCount(String tablename, String sqlwhere) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return daoQuery.getCount(tbname(tablename), sqlwhere);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List query(String tablename, String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return daoQuery.query(tbname(tablename), sqlwhere, order, dir, start, limit);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int getHJCount(String sqlwhere) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return getCount("ytiot_v_hj", sqlwhere);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int getEFCount(String sqlwhere) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return getCount("ytiot_v_efire", sqlwhere);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int getEFireCount(String sqlwhere) {
|
|
|
+ return daoQuery.getCount("YtiotVEfire", sqlwhere);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List HJQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return query("ytiot_v_hj", sqlwhere, order, dir, start, limit);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List HJ2Query(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return query("ytiot_v_hj2", sqlwhere, order, dir, start, limit);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int getSJCount(String sqlwhere) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return getCount("ytiot_v_sj", sqlwhere);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List SJQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return query("ytiot_v_sj", sqlwhere, order, dir, start, limit);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int getRTUCount(String sqlwhere) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return getCount("ytiot_v_rtu", sqlwhere);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List RTUQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return query("ytiot_v_rtu", sqlwhere, order, dir, start, limit);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List VideoAlarmQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return query("ytiot_v_video2017", sqlwhere, order, dir, start, limit);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int getLiftCount(String sqlwhere) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return getCount("ytiot_v_lift", sqlwhere);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List LiftQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return query("ytiot_v_lift", sqlwhere, order, dir, start, limit);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List EFireQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return query("YtiotVEfire", sqlwhere, order, dir, start, limit);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int getDeviceCount(String sqlwhere) {
|
|
|
+ return getCount("ytiot_v_sync", sqlwhere);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List DeviceQuery(String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
+ return query("YtiotVSync", sqlwhere, order, dir, start, limit);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List queryBySQL(String sql) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ System.out.println(sql);
|
|
|
+ return daoQuery.queryBySQL(sql);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void execSQL(String sql) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
// System.out.println(sql);
|
|
|
- daoQuery.execSQL(sql);
|
|
|
- }
|
|
|
+ daoQuery.execSQL(sql);
|
|
|
+ }
|
|
|
|
|
|
- /**
|
|
|
- * 获取数据数量
|
|
|
- * @param hqlwhere
|
|
|
- * @return
|
|
|
- */
|
|
|
+ /**
|
|
|
+ * 获取数据数量
|
|
|
+ *
|
|
|
+ * @param hqlwhere
|
|
|
+ * @return
|
|
|
+ */
|
|
|
|
|
|
- @Override
|
|
|
- public int getVideoCount(String hqlwhere) {
|
|
|
- return getCount("ytiot_v_video2017", hqlwhere);
|
|
|
- }
|
|
|
+ @Override
|
|
|
+ public int getVideoCount(String hqlwhere) {
|
|
|
+ return getCount("ytiot_v_video2017", hqlwhere);
|
|
|
+ }
|
|
|
|
|
|
- @Override
|
|
|
- public List<?> videoOfflienQuery(String hqlwhere, String order, String dir, String start, String limit) {
|
|
|
- return query("ytiot_v_video2017s", hqlwhere, order, dir, start, limit);
|
|
|
+ @Override
|
|
|
+ public List<?> videoOfflienQuery(String hqlwhere, String order, String dir, String start, String limit) {
|
|
|
+ return query("ytiot_v_video2017s", hqlwhere, order, dir, start, limit);
|
|
|
|
|
|
- }
|
|
|
+ }
|
|
|
|
|
|
- @Override
|
|
|
- public MonthReport getMonthReport(String buildCode, String month) {
|
|
|
- String sql="SELECT * FROM yt_t_month_report where company_code='"+buildCode+"' and event_time='"+month+"';";
|
|
|
- MonthReport o = (MonthReport)getSession().createSQLQuery(sql).addEntity(MonthReport.class).uniqueResult();
|
|
|
- return o;
|
|
|
- }
|
|
|
+ @Override
|
|
|
+ public MonthReport getMonthReport(String buildCode, String month) {
|
|
|
+ String sql = "SELECT * FROM yt_t_month_report where company_code='" + buildCode + "' and event_time='" + month + "';";
|
|
|
+ MonthReport o = (MonthReport) getSession().createSQLQuery(sql).addEntity(MonthReport.class).uniqueResult();
|
|
|
+ return o;
|
|
|
+ }
|
|
|
|
|
|
@Override
|
|
|
public List<MonthReport> getTimeList(String queryJson) {
|
|
|
- String sql="SELECT * FROM yt_t_month_report where company_code='"+queryJson+"' ORDER BY event_time desc;";
|
|
|
+ String sql = "SELECT * FROM yt_t_month_report where company_code='" + queryJson + "' ORDER BY event_time desc;";
|
|
|
|
|
|
List list = getSession().createSQLQuery(sql).addEntity(MonthReport.class).list();
|
|
|
|
|
|
@@ -188,42 +188,49 @@ public class YtiotVAlarmDaoImpl extends HibernateDaoSupport implements YtiotVAla
|
|
|
|
|
|
@Override
|
|
|
public YearReport getYearReport(String buildCode, String month) {
|
|
|
- String sql="SELECT * FROM yt_t_year_report where company_code='"+buildCode+"' and event_time='"+month+"';";
|
|
|
- YearReport o = (YearReport)getSession().createSQLQuery(sql).addEntity(YearReport.class).uniqueResult();
|
|
|
+ String sql = "SELECT * FROM yt_t_year_report where company_code='" + buildCode + "' and event_time='" + month + "';";
|
|
|
+ YearReport o = (YearReport) getSession().createSQLQuery(sql).addEntity(YearReport.class).uniqueResult();
|
|
|
return o;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public List<YearReport> getYearTimeList(String queryJson) {
|
|
|
- String sql="SELECT * FROM yt_t_year_report where company_code='"+queryJson+"' ORDER BY event_time desc;";
|
|
|
+ String sql = "SELECT * FROM yt_t_year_report where company_code='" + queryJson + "' ORDER BY event_time desc;";
|
|
|
|
|
|
List list = getSession().createSQLQuery(sql).addEntity(YearReport.class).list();
|
|
|
|
|
|
return list;
|
|
|
}
|
|
|
|
|
|
- @Override
|
|
|
- public int getContracCount(String hhwhere) {
|
|
|
- return daoQuery.getCount("YtiotContractEntity", hhwhere);
|
|
|
- }
|
|
|
+ @Override
|
|
|
+ public int getContracCount(String hhwhere) {
|
|
|
+ return daoQuery.getCount("YtiotContractEntity", hhwhere);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<?> ContracQuery(String hhwhere, String order_str, String dir, String start, String limit) {
|
|
|
+ return query("YtiotContractEntity", hhwhere, order_str, dir, start, limit);
|
|
|
+ }
|
|
|
|
|
|
- @Override
|
|
|
- public List<?> ContracQuery(String hhwhere, String order_str, String dir, String start, String limit) {
|
|
|
- return query("YtiotContractEntity", hhwhere, order_str, dir, start, limit);
|
|
|
- }
|
|
|
+ @Override
|
|
|
+ public List<?> queryGroup(String hhwhere, String order_str, String dir, String start, String limit) {
|
|
|
+ return query("YtTGroupEntity", hhwhere, order_str, dir, start, limit);
|
|
|
+ }
|
|
|
|
|
|
- @Override
|
|
|
- public List<?> queryGroup(String hhwhere, String order_str, String dir, String start, String limit) {
|
|
|
- return query("YtTGroupEntity", hhwhere, order_str, dir, start, limit);
|
|
|
- }
|
|
|
+ @Override
|
|
|
+ public int getGroupCount(String hqlwhere) {
|
|
|
+ return daoQuery.getCount("YtTGroupEntity", hqlwhere);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public int getVideoofflienCount(String hqlwhere) {
|
|
|
+ return getCount("ytiot_v_video2017s", hqlwhere);
|
|
|
+ }
|
|
|
|
|
|
- @Override
|
|
|
- public int getGroupCount(String hqlwhere) {
|
|
|
- return daoQuery.getCount("YtTGroupEntity", hqlwhere);
|
|
|
- }
|
|
|
|
|
|
- @Override
|
|
|
- public int getVideoofflienCount(String hqlwhere) {
|
|
|
- return getCount("ytiot_v_video2017s", hqlwhere);
|
|
|
- }
|
|
|
+ @Override
|
|
|
+ public List getDeviceList(String tablename, String sqlwhere, String order, String dir, String start, String limit) {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ return daoQuery.query(tablename, sqlwhere, order, dir, start, limit);
|
|
|
+ }
|
|
|
}
|
jichaobo