|
@@ -314,3 +314,119 @@ public class YtiotVDataServiceImpl implements YtiotVDataService {
|
|
|
// TODO Auto-generated method stub
|
|
|
String company_code = null;
|
|
|
String company_code_list = null;
|
|
|
+ String device_id = null;
|
|
|
+ String device_id_list = null;
|
|
|
+ String dwtype = null;
|
|
|
+ String dwtype_list = null;
|
|
|
+ String point_code = null;
|
|
|
+ String point_code_list = null;
|
|
|
+ String id = null;
|
|
|
+ String id_list = null;
|
|
|
+ String company = null;
|
|
|
+ String data_time_start = null;
|
|
|
+ String data_time_end = null;
|
|
|
+ String name = null;
|
|
|
+ String Company_Code_List = null;
|
|
|
+ String V_LOGINNAME = null;
|
|
|
+ String hqlwhere = null;
|
|
|
+ String order = null;
|
|
|
+ String dir = null;
|
|
|
+ String Start = null;
|
|
|
+ String Limit = null;
|
|
|
+ String Page = null;
|
|
|
+ String order_str = null;
|
|
|
+ JSONObject q_json = null;
|
|
|
+ JSONArray Sort = null;
|
|
|
+ JSONArray jSONArray = new JSONArray();
|
|
|
+ JSONObject json = new JSONObject();
|
|
|
+ json.put("action", "getSyncDataVList");
|
|
|
+ if(queryJson!=null) {
|
|
|
+ q_json = JSONObject.fromObject(queryJson);
|
|
|
+ if(q_json.has("company_code")) {
|
|
|
+ if((q_json.optJSONObject("company_code")!=null)&&(q_json.optJSONObject("company_code").isArray())) {
|
|
|
+ JSONArray j_tmp = q_json.getJSONArray("company_code");
|
|
|
+ for(int i=0;i<j_tmp.size();i++) {
|
|
|
+ if(i==0)
|
|
|
+ company_code_list = j_tmp.getString(i);
|
|
|
+ else
|
|
|
+ company_code_list += ","+j_tmp.getString(i);
|
|
|
+ }
|
|
|
+ }else
|
|
|
+ company_code = q_json.getString("company_code");
|
|
|
+ }
|
|
|
+ if(q_json.has("device_id")) {
|
|
|
+ if((q_json.optJSONObject("device_id")!=null)&&(q_json.optJSONObject("device_id").isArray())) {
|
|
|
+ JSONArray j_tmp = q_json.getJSONArray("device_id");
|
|
|
+ for(int i=0;i<j_tmp.size();i++) {
|
|
|
+ if(i==0)
|
|
|
+ device_id_list = j_tmp.getString(i);
|
|
|
+ else
|
|
|
+ device_id_list += ","+j_tmp.getString(i);
|
|
|
+ }
|
|
|
+ }else
|
|
|
+ device_id = q_json.getString("device_id");
|
|
|
+ }
|
|
|
+ if(q_json.has("dwtype")) {
|
|
|
+ if((q_json.optJSONObject("dwtype")!=null)&&(q_json.optJSONObject("dwtype").isArray())) {
|
|
|
+ JSONArray j_tmp = q_json.getJSONArray("dwtype");
|
|
|
+ for(int i=0;i<j_tmp.size();i++) {
|
|
|
+ if(i==0)
|
|
|
+ dwtype_list = j_tmp.getString(i);
|
|
|
+ else
|
|
|
+ dwtype_list += ","+j_tmp.getString(i);
|
|
|
+ }
|
|
|
+ }else
|
|
|
+ dwtype = q_json.getString("dwtype");
|
|
|
+ }
|
|
|
+ if(q_json.has("point_code")) {
|
|
|
+ if((q_json.optJSONObject("point_code")!=null)&&(q_json.optJSONObject("point_code").isArray())) {
|
|
|
+ JSONArray j_tmp = q_json.getJSONArray("point_code");
|
|
|
+ for(int i=0;i<j_tmp.size();i++) {
|
|
|
+ if(i==0)
|
|
|
+ point_code_list = j_tmp.getString(i);
|
|
|
+ else
|
|
|
+ point_code_list += ","+j_tmp.getString(i);
|
|
|
+ }
|
|
|
+ }else
|
|
|
+ point_code = q_json.getString("point_code");
|
|
|
+ }
|
|
|
+ if(q_json.has("id")) {
|
|
|
+ if((q_json.optJSONObject("id")!=null)&&(q_json.optJSONObject("id").isArray())) {
|
|
|
+ JSONArray j_tmp = q_json.getJSONArray("id");
|
|
|
+ for(int i=0;i<j_tmp.size();i++) {
|
|
|
+ if(i==0)
|
|
|
+ id_list = j_tmp.getString(i);
|
|
|
+ else
|
|
|
+ id_list += ","+j_tmp.getString(i);
|
|
|
+ }
|
|
|
+ }else
|
|
|
+ id = q_json.getString("id");
|
|
|
+ }
|
|
|
+ company = q_json.has("company")?q_json.getString("company"):null;
|
|
|
+ data_time_start = q_json.has("data_time_start")?q_json.getString("data_time_start"):null;
|
|
|
+ data_time_end = q_json.has("data_time_end")?q_json.getString("data_time_end"):null;
|
|
|
+ name = q_json.has("name")?q_json.getString("name"):null;
|
|
|
+ V_LOGINNAME = q_json.has("V_LOGINNAME")?q_json.getString("V_LOGINNAME"):null;
|
|
|
+ }
|
|
|
+// if(sort!=null) {
|
|
|
+// Sort = JSONArray.fromObject(sort);
|
|
|
+// if((Sort.isArray())&&(Sort.size()>0)) {
|
|
|
+// JSONObject s_json = Sort.getJSONObject(0);
|
|
|
+// order = s_json.has("property")?s_json.getString("property"):order;
|
|
|
+// dir = s_json.has("direction")?s_json.getString("direction"):dir;
|
|
|
+// }
|
|
|
+// json.put("sort", sort);
|
|
|
+// }
|
|
|
+// Start = start;
|
|
|
+// Limit = limit;
|
|
|
+// Page = page;
|
|
|
+ if((V_LOGINNAME!=null)&&(company_code==null)&&(Company_Code_List==null)) {
|
|
|
+ String where = " where u.id.agentid='"+V_LOGINNAME+"' ";
|
|
|
+ List list = ytiotVUserCompanyDao.query(where, null, null, null, null);
|
|
|
+ if(list.size()>0) {
|
|
|
+ for(int i=0;i<list.size();i++) {
|
|
|
+ YtiotVUsercompany o = (YtiotVUsercompany)list.get(i);
|
|
|
+ YtiotVUsercompanyId oid = o.getId();
|
|
|
+ if(i==0)
|
|
|
+ Company_Code_List = oid.getOwnerCode();
|
|
|
+ else
|