|
@@ -1769,3 +1769,120 @@ public class YtiotVDataServiceImpl implements YtiotVDataService {
|
|
|
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");
|
|
|
+ }
|
|
|
+
|
|
|
+ dwtype= "7";
|
|
|
+
|
|
|
+ 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;
|
|
|
+ Page = q_json.has("page")?q_json.getString("page"):null;
|
|
|
+ order = q_json.has("order")?q_json.getString("order"):null;
|
|
|
+ dir = q_json.has("dir")?q_json.getString("dir"):null;
|
|
|
+ Start = q_json.has("start")?q_json.getString("start"):null;
|
|
|
+ Limit = q_json.has("limit")?q_json.getString("limit"):null;
|
|
|
+ }
|
|
|
+
|
|
|
+ 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
|
|
|
+ Company_Code_List += ","+oid.getOwnerCode();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(device_id!=null)
|
|
|
+ hqlwhere = chkhw(hqlwhere)+" u.id."+fieldname("device_id")+" = '"+device_id+"' ";
|
|
|
+ else {
|
|
|
+ if(company!=null) {
|
|
|
+ hqlwhere = chkhw(hqlwhere)+" u.id."+fieldname("owner_name")+" like '%"+company+"%' ";
|
|
|
+ }
|
|
|
+ if(Company_Code_List!=null)
|
|
|
+ hqlwhere = chkhw(hqlwhere) + " u.id."+fieldname("company_code")+" in ("+Company_Code_List+") ";
|
|
|
+ else {
|
|
|
+ if(company_code!=null)
|
|
|
+ hqlwhere = chkhw(hqlwhere) + " u.id."+fieldname("company_code")+" like '%"+company_code+"%' ";
|
|
|
+ if(company_code_list!=null)
|
|
|
+ hqlwhere = chkhw(hqlwhere) + " u.id."+fieldname("company_code")+" in ("+company_code_list+") ";
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(device_id_list!=null)
|
|
|
+ hqlwhere = chkhw(hqlwhere)+" u.id."+fieldname("device_id")+" in ("+device_id+") ";
|
|
|
+ if(dwtype!=null)
|
|
|
+ hqlwhere = chkhw(hqlwhere)+" u.id."+fieldname("dwtype")+" = "+dwtype+" ";
|
|
|
+ if(dwtype_list!=null)
|
|
|
+ hqlwhere = chkhw(hqlwhere)+" u.id."+fieldname("dwtype")+" in ("+dwtype_list+") ";
|
|
|
+ if(point_code!=null)
|