|
@@ -0,0 +1,135 @@
|
|
|
+package cn.com.usky.iot.data.service;
|
|
|
+
|
|
|
+import java.text.SimpleDateFormat;
|
|
|
+import java.util.Date;
|
|
|
+import java.util.HashMap;
|
|
|
+import java.util.Iterator;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
+import cn.com.usky.iot.admin.dao.YtiotTAdminDao;
|
|
|
+import cn.com.usky.iot.admin.dao.YtiotVUserCompanyDao;
|
|
|
+import cn.com.usky.iot.alarm.dao.YtiotVAlarmDao;
|
|
|
+import cn.com.usky.iot.company.dao.YtiotVCompanyDao;
|
|
|
+import cn.com.usky.iot.data.dao.YtiotVDataDao;
|
|
|
+import cn.com.usky.iot.entity.YtiotTAdmin;
|
|
|
+import cn.com.usky.iot.entity.YtiotTArea;
|
|
|
+import cn.com.usky.iot.entity.YtiotVCompany;
|
|
|
+import cn.com.usky.iot.entity.YtiotVCompanyId;
|
|
|
+import cn.com.usky.iot.entity.YtiotVHj;
|
|
|
+import cn.com.usky.iot.entity.YtiotVHjId;
|
|
|
+import cn.com.usky.iot.entity.YtiotVRtu;
|
|
|
+import cn.com.usky.iot.entity.YtiotVRtuId;
|
|
|
+import cn.com.usky.iot.entity.YtiotVSj;
|
|
|
+import cn.com.usky.iot.entity.YtiotVSjId;
|
|
|
+import cn.com.usky.iot.entity.YtiotVSync;
|
|
|
+import cn.com.usky.iot.entity.YtiotVSyncData;
|
|
|
+import cn.com.usky.iot.entity.YtiotVSyncDataId;
|
|
|
+import cn.com.usky.iot.entity.YtiotVSyncId;
|
|
|
+import cn.com.usky.iot.entity.YtiotVSyncStatus;
|
|
|
+import cn.com.usky.iot.entity.YtiotVSyncStatusId;
|
|
|
+import cn.com.usky.iot.entity.YtiotVUsercompany;
|
|
|
+import cn.com.usky.iot.entity.YtiotVUsercompanyId;
|
|
|
+import cn.com.usky.utils.MD5Util;
|
|
|
+import net.sf.json.JSONArray;
|
|
|
+import net.sf.json.JSONObject;
|
|
|
+import java.util.Calendar;
|
|
|
+
|
|
|
+public class YtiotVDataServiceImpl implements YtiotVDataService {
|
|
|
+ private YtiotVDataDao ytiotVDataDao;
|
|
|
+ private YtiotVCompanyDao ytiotVCompanyDao;
|
|
|
+ private YtiotVUserCompanyDao ytiotVUserCompanyDao;
|
|
|
+ private YtiotVAlarmDao ytiotVAlarmDao;
|
|
|
+ private YtiotTAdminDao ytiotTAdminDao;
|
|
|
+ public YtiotVDataDao getYtiotVDataDao() {
|
|
|
+ return ytiotVDataDao;
|
|
|
+ }
|
|
|
+
|
|
|
+ public void setYtiotVDataDao(YtiotVDataDao ytiotVDataDao) {
|
|
|
+ this.ytiotVDataDao = ytiotVDataDao;
|
|
|
+ }
|
|
|
+
|
|
|
+ public YtiotVCompanyDao getYtiotVCompanyDao() {
|
|
|
+ return ytiotVCompanyDao;
|
|
|
+ }
|
|
|
+
|
|
|
+ public void setYtiotVCompanyDao(YtiotVCompanyDao ytiotVCompanyDao) {
|
|
|
+ this.ytiotVCompanyDao = ytiotVCompanyDao;
|
|
|
+ }
|
|
|
+
|
|
|
+ public YtiotVUserCompanyDao getYtiotVUserCompanyDao() {
|
|
|
+ return ytiotVUserCompanyDao;
|
|
|
+ }
|
|
|
+
|
|
|
+ public void setYtiotVUserCompanyDao(YtiotVUserCompanyDao ytiotVUserCompanyDao) {
|
|
|
+ this.ytiotVUserCompanyDao = ytiotVUserCompanyDao;
|
|
|
+ }
|
|
|
+
|
|
|
+ public YtiotTAdminDao getYtiotTAdminDao() {
|
|
|
+ return ytiotTAdminDao;
|
|
|
+ }
|
|
|
+
|
|
|
+ public void setYtiotTAdminDao(YtiotTAdminDao ytiotTAdminDao) {
|
|
|
+ this.ytiotTAdminDao = ytiotTAdminDao;
|
|
|
+ }
|
|
|
+
|
|
|
+ public YtiotVAlarmDao getYtiotVAlarmDao() {
|
|
|
+ return ytiotVAlarmDao;
|
|
|
+ }
|
|
|
+
|
|
|
+ public void setYtiotVAlarmDao(YtiotVAlarmDao ytiotVAlarmDao) {
|
|
|
+ this.ytiotVAlarmDao = ytiotVAlarmDao;
|
|
|
+ }
|
|
|
+
|
|
|
+ public boolean chk_string_param(String param) {
|
|
|
+ if(param==null)
|
|
|
+ return true;
|
|
|
+ if(param.indexOf("=")>=0)
|
|
|
+ return false;
|
|
|
+ if(param.indexOf("\'")>=0)
|
|
|
+ return false;
|
|
|
+ if(param.indexOf("\"")>=0)
|
|
|
+ return false;
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ public String chkhw(String hqlwhere){
|
|
|
+ if(hqlwhere==null)
|
|
|
+ return " where ";
|
|
|
+ else
|
|
|
+ return hqlwhere+" and ";
|
|
|
+ }
|
|
|
+ public String fieldname(String name) {
|
|
|
+ if(name.equals("company_code"))
|
|
|
+ return "companyCode";
|
|
|
+ if(name.equals("device_id"))
|
|
|
+ return "deviceId";
|
|
|
+ if(name.equals("device_name"))
|
|
|
+ return "deviceName";
|
|
|
+ if(name.equals("install_time"))
|
|
|
+ return "installTime";
|
|
|
+ if(name.equals("sync_id"))
|
|
|
+ return "syncId";
|
|
|
+ if(name.equals("table_name"))
|
|
|
+ return "tableName";
|
|
|
+ if(name.equals("data_time"))
|
|
|
+ return "dataTime";
|
|
|
+ if(name.equals("native_id"))
|
|
|
+ return "nativeId";
|
|
|
+ if(name.equals("point_code"))
|
|
|
+ return "pointCode";
|
|
|
+ if(name.equals("point_data"))
|
|
|
+ return "pointData";
|
|
|
+ if(name.equals("owner_name"))
|
|
|
+ return "ownerName";
|
|
|
+ if(name.equals("owner_id"))
|
|
|
+ return "ownerId";
|
|
|
+ return name;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public String getSyncPointVList(String queryJson, String page, String start, String limit, String sort)
|
|
|
+ throws Exception {
|
|
|
+ // TODO Auto-generated method stub
|
|
|
+ String company_code = null;
|
|
|
+ String company_code_list = null;
|
|
|
+ String device_id = null;
|
|
|
+ String device_id_list = null;
|