package cn.com.usky.iot.patrolplan.service;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Calendar; 
import java.util.HashMap;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;

import cn.com.usky.iot.entity.YtiotTPatrolPlan;
import cn.com.usky.iot.entity.YtiotTControlroom;
import cn.com.usky.iot.entity.YtiotVUsercompany;
import cn.com.usky.iot.entity.YtiotVUsercompanyId;
import cn.com.usky.iot.entity.YtiotTAdmin;
import cn.com.usky.iot.entity.YtiotTArea;
import cn.com.usky.iot.entity.YtiotTInspectors;
import cn.com.usky.iot.entity.YtiotTRoute;
import cn.com.usky.iot.entity.YtiotVCompany;
import cn.com.usky.iot.entity.YtiotVCompanyId;
import cn.com.usky.iot.entity.YtiotTCompany;
import cn.com.usky.iot.admin.dao.YtiotVUserCompanyDao;
import cn.com.usky.iot.admin.dao.YtiotTAdminDao;
import cn.com.usky.iot.inspectors.dao.YtiotTInspectorsDao;
import cn.com.usky.iot.patrolplan.dao.YtiotTPatrolPlanDao;
import cn.com.usky.iot.route.dao.YtiotTRouteDao;
import cn.com.usky.utils.DaoResult;
import cn.com.usky.utils.MD5Util;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

public class YtiotTPatrolPlanServicesImpl implements YtiotTPatrolPlanService {
	private YtiotTPatrolPlanDao ytiotTPatrolPlanDao;
	private YtiotVUserCompanyDao ytiotVUserCompanyDao;
	private YtiotTAdminDao ytiotTAdminDao;
	private YtiotTRouteDao ytiotTRouteDao;
	private YtiotTInspectorsDao ytiotTInspectorsDao;
	
	public YtiotTAdminDao getYtiotTAdminDao() {
		return ytiotTAdminDao;
	}
	public void setYtiotTAdminDao(YtiotTAdminDao ytiotTAdminDao) {
		this.ytiotTAdminDao = ytiotTAdminDao;
	}

	public YtiotTPatrolPlanDao getYtiotTPatrolPlanDao() {
		return ytiotTPatrolPlanDao;
	}
			   
	public void setYtiotTPatrolPlanDao(YtiotTPatrolPlanDao ytiotTPatrolPlanDao) {
		this.ytiotTPatrolPlanDao = ytiotTPatrolPlanDao;
	}
	public YtiotVUserCompanyDao getYtiotVUserCompanyDao() {
		return ytiotVUserCompanyDao;
	}

	public void setYtiotVUserCompanyDao(YtiotVUserCompanyDao ytiotVUserCompanyDao) {
		this.ytiotVUserCompanyDao = ytiotVUserCompanyDao;
	}

	public YtiotTInspectorsDao getYtiotTInspectorsDao() {
		return ytiotTInspectorsDao;
	}
			   
	public void setYtiotTInspectorsDao(YtiotTInspectorsDao ytiotTInspectorsDao) {
		this.ytiotTInspectorsDao = ytiotTInspectorsDao;
	}

	public YtiotTRouteDao getYtiotTRouteDao() {
		return ytiotTRouteDao;
	}
			   
	public void setYtiotTRouteDao(YtiotTRouteDao ytiotTRouteDao) {
		this.ytiotTRouteDao = ytiotTRouteDao;
	}

	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 field){
		if(field.equals("id"))
			return "id";
		if(field.equals("personnel"))
			return "personnel";
		if(field.equals("route"))
			return "route";
		if(field.equals("planned_date"))
			return "plannedDate";
		if(field.equals("start_time"))
			return "startTime";
		if(field.equals("end_time"))
			return "endTime";
		if(field.equals("completion_status"))
			return "completionStatus";
		if(field.equals("name"))
			return "name";
		if(field.equals("route_name"))
			return "routeName";
		if(field.equals("company_code"))
			return "companyCode";
		if(field.equals("V_COMPANY_CODE"))
			return "VCompanyCode";
		if(field.equals("control_room_name"))
			return "controlRoomName";
		if(field.equals("control_room_person"))
			return "controlRoomPerson";
		return null;
	}

	
	
	public static String[] getDates(String dateFrom, String dateEnd, String weekDays) {
        long time = 1l;
        long perDayMilSec = 24 * 60 * 60 * 1000;
        List<String> dateList = new ArrayList<String>();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
        //需要查询的星期系数
        String strWeekNumber = weekForNum(weekDays);
        try {
			dateFrom = sdf.format(sdf.parse(dateFrom).getTime() - perDayMilSec);
			while (true) {
					time = sdf.parse(dateFrom).getTime();
					time = time + perDayMilSec;
					Date date = new Date(time);
					dateFrom = sdf.format(date);
					if (dateFrom.compareTo(dateEnd) <= 0) {
						//查询的某一时间的星期系数
						Integer weekDay = dayForWeek(date);                    
						//判断当期日期的星期系数是否是需要查询的
						if (strWeekNumber.indexOf(weekDay.toString())!=-1) {
							System.out.println(dateFrom);
							dateList.add(dateFrom);
						}
					} else {
						break;
					}
			}
		} catch (Exception e1) {
			e1.printStackTrace();
		}
        String[] dateArray = new String[dateList.size()];
        dateList.toArray(dateArray);
        return dateArray;
    }
    //等到当期时间的周系数。星期日：1，星期一：2，星期二：3，星期三：4，星期四：5，星期五：6，星期六：7
    public static Integer dayForWeek(Date date) {
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(date);
        return calendar.get(Calendar.DAY_OF_WEEK);
    }
    
    /**
     * 得到对应星期的系数  星期日：1，星期一：2，星期二：3，星期三：4，星期四：5，星期五：6，星期六：7
     * @param weekDays 星期格式  星期一|星期二
     */
    public static String weekForNum(String weekDays){
    	//返回结果为组合的星期系数
    	String weekNumber = "";
    	//解析传入的星期
    	if(weekDays.indexOf("|")!=-1){//多个星期数
    		String []strWeeks = weekDays.split("\\|");
    		for(int i=0;i<strWeeks.length;i++){
    			weekNumber = weekNumber + "" + getWeekNum(strWeeks[i]).toString();
    		}
    	}else{//一个星期数
    		weekNumber = getWeekNum(weekDays).toString();
    	}
    	
    	return weekNumber;
    	
    }
    
    //将星期转换为对应的系数  星期日：1，星期一：2，星期二：3，星期三：4，星期四：5，星期五：6，星期六：7
    public static Integer getWeekNum(String strWeek){
    	Integer number = 1;//默认为星期日
    	if("星期日".equals(strWeek)){
    		number = 1;
    	}else if("星期一".equals(strWeek)){
    		number = 2;
    	}else if("星期二".equals(strWeek)){
    		number = 3;
    	}else if("星期三".equals(strWeek)){
    		number = 4;
    	}else if("星期四".equals(strWeek)){
    		number = 5;
    	}else if("星期五".equals(strWeek)){
    		number = 6;
    	}else if("星期六".equals(strWeek)){
    		number = 7;
    	}
    	return number;
    }
    

	
	@Override
	public String appendPatrolPlan(String queryJson) throws Exception {
		// TODO Auto-generated method stub		
		String id = null;
		String personnel = null;
		String route = null;
		String Inspectiontime = null;
		String start_time = null;
		String end_time = null;
		String start_data = null;
		String end_data = null;
		String completion_status  = null;
		String demoArray[]=null;
		String V_LOGINNAME = null;
		String Company_Code_List = null;
		
		JSONObject q_json = null;
		JSONArray jSONArray = new JSONArray();
		JSONObject json = new JSONObject();
		json.put("action", "appendPatrolPlan");
		
		if(queryJson!=null) {
			q_json 	  	 = JSONObject.fromObject(queryJson);
			personnel 	  	 = q_json.has("personnel")?q_json.getString("personnel"):null;
			route      = q_json.has("route")?q_json.getString("route"):null;
			Company_Code_List      = q_json.has("company_code")?q_json.getString("company_code"):null;
			Inspectiontime  = q_json.has("Inspectiontime")?q_json.getString("Inspectiontime"):null;
			start_time 	 = q_json.has("start_time")?q_json.getString("start_time"):null;		
			end_time = q_json.has("end_time")?q_json.getString("end_time"):null;
			start_data 	 = q_json.has("start_data")?q_json.getString("start_data"):null;		
			end_data = q_json.has("end_data")?q_json.getString("end_data"):null;
			completion_status = q_json.has("completion_status")?q_json.getString("completion_status"):null;
			V_LOGINNAME = q_json.has("V_LOGINNAME")?q_json.getString("V_LOGINNAME"):null;
			json.put("query", queryJson);
		}
//		if((V_LOGINNAME!=null)&&(Company_Code_List==null)&&(!V_LOGINNAME.equals("admin"))) {
//			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(!oid.getOwnerCode().equals("10012")&& !oid.getOwnerCode().equals("10068")) {
//					
//						Company_Code_List = oid.getOwnerCode();
//					
//					}
//				}
//			}
//		}
//		System.out.println(Company_Code_List);
		 demoArray=getDates(start_data, end_data,Inspectiontime);
		if(chk_string_param(personnel)&&chk_string_param(route)&&chk_string_param(Inspectiontime)
				&&chk_string_param(start_time)&&chk_string_param(end_time)&&chk_string_param(completion_status)) {
			YtiotTPatrolPlan o = new YtiotTPatrolPlan();
//			float F_HEIGHT1 = Float.parseFloat(F_HEIGHT);
			for(int i=0;i<demoArray.length;i++) {
				o.setPlannedDate(demoArray[i]);
			
			o.setPersonnel(personnel);
			o.setCompanyCode(Company_Code_List);
			o.setRoute(route);
//			o.setPlannedDate(planned_date);
			o.setStartTime(start_time);
			o.setEndTime(end_time);
			o.setCompletionStatus("0");
			DaoResult ret = ytiotTPatrolPlanDao.add(o);
			}
			json.put("success", true);
			json.put("Msg", "成功加入数据库");
		}else {
			json.put("success", false);
			json.put("Msg", "参数验证错误");
		}
		return json.toString();
	}

	@Override
	public String updatePatrolPlan(String queryJson) throws Exception {
		// TODO Auto-generated method stub
		String id = null;
		String personnel = null;
		String route = null;
		String planned_date = null;
		String start_time = null;
		String end_time = null;	
		String completion_status  = null;
		String hqlwhere = null;
		String hqlwhere1 = null;
		JSONObject q_json = null;
		JSONArray jSONArray = new JSONArray();
		JSONObject json = new JSONObject();
		json.put("action", "updatePatrolPlan");
		if(queryJson!=null) {
			q_json = JSONObject.fromObject(queryJson);
			id 	  	 = q_json.has("id")?q_json.getString("id"):null;
			
			personnel 	  	 = q_json.has("personnel")?q_json.getString("personnel"):null;
			route      = q_json.has("route")?q_json.getString("route"):null;
			planned_date  = q_json.has("planned_date")?q_json.getString("planned_date"):null;
			start_time 	 = q_json.has("start_time")?q_json.getString("start_time"):null;		
			end_time = q_json.has("end_time")?q_json.getString("end_time"):null;
			completion_status = q_json.has("completion_status")?q_json.getString("completion_status"):null;
			json.put("query", queryJson);
		}
		if(personnel!=null)
			hqlwhere =  "u."+fieldname("name")+"='"+personnel+"'";
		     List list1 =ytiotTPatrolPlanDao.query1(hqlwhere);
		     YtiotTInspectors g = (YtiotTInspectors)list1.get(0);
		     String personnel_id = Integer.toString(g.getId());
		if(route!=null)
			hqlwhere1 =  "u."+fieldname("route_name")+"='"+route+"'";
			List list2 =ytiotTPatrolPlanDao.query2(hqlwhere1);
			YtiotTRoute r = (YtiotTRoute)list2.get(0);
			String route_id = Integer.toString(r.getId());
		if(chk_string_param(id)&&chk_string_param(route_id)&&chk_string_param(personnel_id)&&chk_string_param(planned_date)
				&&chk_string_param(start_time)&&chk_string_param(end_time)&&chk_string_param(completion_status)) {
			if(id!=null) {
				List list = ytiotTPatrolPlanDao.query(" where u."+fieldname("id")+" ='"+id+"' ", null, null, null, null);
				if(list.size()>0) {
					YtiotTPatrolPlan o = (YtiotTPatrolPlan) list.get(0);
					if(personnel!=null)
						o.setPersonnel(personnel_id);
					if(route!=null)
						o.setRoute(route_id);
					if(planned_date!=null)
						o.setPlannedDate(planned_date);
					if(start_time!=null)
						o.setStartTime(start_time);
					if(end_time!=null)
						o.setEndTime(end_time);
					if(completion_status!=null)
						o.setCompletionStatus(completion_status);
					DaoResult ret = ytiotTPatrolPlanDao.update(o);
					json.put("success", ret.isSuccess());
					json.put("MSG", ret.getResult());
				}else {
					json.put("success", false);
					json.put("MSG", "需要编辑的权限记录不存在");
				}
			}else {
				json.put("success", false);
				json.put("MSG", "记录ID不能为空");
			}
		}else {
			json.put("success", false);
			json.put("MSG", "参数验证错误");
		}
		return json.toString();
	}


	@Override
	public String getPatrolPlanList(String queryJson, String page, String start, String limit, String sort) throws Exception {
		// TODO Auto-generated method stub
		SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");	
		String id = null;
		String personnel = null;
		String route = null;
		String planned_date = null;
		String start_time = null;
		String end_time = null;	
		String completion_status  = null;
		String company_code = null;
		String Company_Code_List = null;
		String V_LOGINNAME = null;
		String Page = null;
		String Start = null;
		JSONArray Sort = null;
		String Limit = null;
		String hqlwhere4 = null;
		String hqlwhere3 = null;
		String hqlwhere2 = null;
		String hqlwhere1 = null;
		String hqlwhere = null;
		String order = null;
		String dir = null;		
		String order_str = null;
		JSONObject q_json = null;		
		JSONArray jSONArray = new JSONArray();
		JSONObject json = new JSONObject();
		json.put("action", "getPatrolPlanList");
		if(queryJson!=null) {
			q_json = JSONObject.fromObject(queryJson);
			id 	  	 = q_json.has("id")?q_json.getString("id"):null;
			
			personnel 	  	 = q_json.has("personnel")?q_json.getString("personnel"):null;
			route      = q_json.has("route")?q_json.getString("route"):null;
			planned_date  = q_json.has("planned_date")?q_json.getString("planned_date"):null;
			start_time 	 = q_json.has("start_time")?q_json.getString("start_time"):null;		
			end_time = q_json.has("end_time")?q_json.getString("end_time"):null;
			completion_status = q_json.has("completion_status")?q_json.getString("completion_status"):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"):(start!=null)?start:"0";
			Limit = q_json.has("limit")?q_json.getString("limit"):(limit!=null)?limit:null;
			Page = q_json.has("page")?q_json.getString("page"):(page!=null)?page:"0";
			V_LOGINNAME = q_json.has("V_LOGINNAME")?q_json.getString("V_LOGINNAME"):null;
			json.put("query", queryJson);
		}
		if(personnel!=null) {
			hqlwhere3 =  "u."+fieldname("name")+"='"+personnel+"'";
		     List list3 =ytiotTPatrolPlanDao.query1(hqlwhere3);
		     YtiotTInspectors p = (YtiotTInspectors)list3.get(0);
		     personnel = Integer.toString(p.getId());
		}
		if(route!=null) {
			hqlwhere4 =  "u."+fieldname("route_name")+"='"+route+"'";
			List list4 =ytiotTPatrolPlanDao.query2(hqlwhere4);
			YtiotTRoute t = (YtiotTRoute)list4.get(0);
			route = Integer.toString(t.getId());
		}
//		System.out.println();
		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);
		}
		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();
					
				}
			}
		}
		Start = start;
		Limit = limit;
		Page = page;
		if(Company_Code_List!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("company_code")+" in ("+Company_Code_List+") ";
		if(personnel!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("personnel")+"='"+personnel+"'";
		if(route!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("route")+"='"+route+"'";
		if(start_time!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("start_time")+"='"+start_time+"'";
		if(end_time!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("end_time")+"='"+end_time+"'";
		if(planned_date!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("planned_date")+" like '%"+planned_date+"%'";
		if(completion_status!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("completion_status")+"='"+completion_status+"'";
		
		if(order!=null) 
			order_str = " order by u."+fieldname(order);
		else
			order_str = " order by u."+fieldname("id");
		int totalCount = ytiotTPatrolPlanDao.getCount(hqlwhere);
		//System.out.println(totalCount);
		json.put("totalCount", totalCount);
		if(Start!=null){
			if(Integer.parseInt(Start)>totalCount){
				Start = "0";
				Page = "0";
			}
			if(page==null)
				Page="0";
		}else{
			Start = "0";
			Page = "0";
		}
		json.put("page", Page);
		json.put("start", Start);
		json.put("limit", Limit);
		if(totalCount>0) {
			List list = ytiotTPatrolPlanDao.query(hqlwhere, order_str, dir, Start, Limit);
			if(list.size()>0) {
				for(int i=0;i<list.size();i++) {
					YtiotTPatrolPlan o = (YtiotTPatrolPlan)list.get(i);
					Map map = new HashMap();
					if(o.getPersonnel()!=null) {
						hqlwhere1 = "u."+fieldname("id")+"='"+o.getPersonnel()+"'";
						List list1 = ytiotTPatrolPlanDao.query1(hqlwhere1);
						if(list1.size()>0) {
						YtiotTInspectors g = (YtiotTInspectors)list1.get(0);
						map.put("personnel", g.getName());
						}	
					}
					if(o.getRoute()!=null) {
						hqlwhere2 =  "u."+fieldname("id")+"='"+o.getRoute()+"'";
						List list2 = ytiotTPatrolPlanDao.query2(hqlwhere2);
						if(list2.size()>0) {
						YtiotTRoute r = (YtiotTRoute)list2.get(0);
						map.put("route", r.getRouteName());
						}
					}
					map.put("id", o.getId());
					map.put("planned_date", o.getPlannedDate());
					map.put("start_time", o.getStartTime());
					map.put("end_time", o.getEndTime());
					map.put("completion_status", o.getCompletionStatus());
					JSONObject jSONObject = JSONObject.fromObject(map);
					jSONArray.add(jSONObject);
				}
				json.put("RESULT", jSONArray);
			}
		}
		return json.toString();
	}
	
	@Override
	public String getPatrolPlanExcelList(String queryJson) throws Exception {
		// TODO Auto-generated method stub
		SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");	
		String id = null;
		String personnel = null;
		String route = null;
		String planned_date = null;
		String start_time = null;
		String end_time = null;	
		String completion_status  = null;
		String company_code = null;
		String Company_Code_List = null;
		String V_LOGINNAME = null;
		String Page = null;
		String Start = null;
		JSONArray Sort = null;
		String Limit = null;
		String hqlwhere4 = null;
		String hqlwhere3 = null;
		String hqlwhere2 = null;
		String hqlwhere1 = null;
		String hqlwhere = null;
		String order = null;
		String dir = null;		
		String order_str = null;
		JSONObject q_json = null;		
		JSONArray jSONArray = new JSONArray();
		JSONObject json = new JSONObject();
		json.put("action", "getPatrolPlanList");
		if(queryJson!=null) {
			q_json = JSONObject.fromObject(queryJson);
			id 	  	 = q_json.has("id")?q_json.getString("id"):null;
			
			personnel 	  	 = q_json.has("personnel")?q_json.getString("personnel"):null;
			route      = q_json.has("route")?q_json.getString("route"):null;
			planned_date  = q_json.has("planned_date")?q_json.getString("planned_date"):null;
			start_time 	 = q_json.has("start_time")?q_json.getString("start_time"):null;		
			end_time = q_json.has("end_time")?q_json.getString("end_time"):null;
			completion_status = q_json.has("completion_status")?q_json.getString("completion_status"):null;
			
			order = q_json.has("order")?q_json.getString("order"):null;
			dir = q_json.has("dir")?q_json.getString("dir"):null;
			V_LOGINNAME = q_json.has("V_LOGINNAME")?q_json.getString("V_LOGINNAME"):null;
			json.put("query", queryJson);
		}
		if((personnel!=null)&&(personnel.length()>0)) {
			hqlwhere3 =  "u."+fieldname("name")+"='"+personnel+"'";
		     List list3 =ytiotTPatrolPlanDao.query1(hqlwhere3);
		     YtiotTInspectors p = (YtiotTInspectors)list3.get(0);
		     personnel = Integer.toString(p.getId());
		}
		if((route!=null)&&(route.length()>0)) {
			hqlwhere4 =  "u."+fieldname("route_name")+"='"+route+"'";
			List list4 =ytiotTPatrolPlanDao.query2(hqlwhere4);
			YtiotTRoute t = (YtiotTRoute)list4.get(0);
			route = Integer.toString(t.getId());
		}
//		System.out.println();
		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(Company_Code_List!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("company_code")+" in ("+Company_Code_List+") ";
		if((personnel!=null)&&(personnel.length()>0))
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("personnel")+"='"+personnel+"'";
		if((route!=null)&&(route.length()>0))
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("route")+"='"+route+"'";
		if((start_time!=null)&&(start_time.length()>0))
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("start_time")+"='"+start_time+"'";
		if((end_time!=null)&&(end_time.length()>0))
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("end_time")+"='"+end_time+"'";
		if((planned_date!=null)&&(planned_date.length()>0))
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("planned_date")+"='"+planned_date+"'";
		if(completion_status!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("completion_status")+"='"+completion_status+"'";
		System.out.println(hqlwhere);
		if(order!=null) 
			order_str = " order by u."+fieldname(order);
		else
			order_str = " order by u."+fieldname("id");
		int totalCount = ytiotTPatrolPlanDao.getCount(hqlwhere);
		
		json.put("totalCount", totalCount);
		if(totalCount>0) {
			List list = ytiotTPatrolPlanDao.query(hqlwhere, order_str, dir, Start, Limit);
			if(list.size()>0) {
				for(int i=0;i<list.size();i++) {
					YtiotTPatrolPlan o = (YtiotTPatrolPlan)list.get(i);
					Map map = new HashMap();
					if(o.getPersonnel()!=null) {
						hqlwhere1 = "u."+fieldname("id")+"='"+o.getPersonnel()+"'";
						List list1 = ytiotTPatrolPlanDao.query1(hqlwhere1);
						if(list1.size()>0) {
						YtiotTInspectors g = (YtiotTInspectors)list1.get(0);
						map.put("personnel", g.getName());
						}	
					}
					if(o.getRoute()!=null) {
						hqlwhere2 =  "u."+fieldname("id")+"='"+o.getRoute()+"'";
						List list2 = ytiotTPatrolPlanDao.query2(hqlwhere2);
						if(list2.size()>0) {
						YtiotTRoute r = (YtiotTRoute)list2.get(0);
						map.put("route", r.getRouteName());
						}
					}
					map.put("id", o.getId());
					map.put("planned_date", o.getPlannedDate());
					map.put("start_time", o.getStartTime());
					map.put("end_time", o.getEndTime());
					map.put("completion_status", o.getCompletionStatus());
					JSONObject jSONObject = JSONObject.fromObject(map);
					jSONArray.add(jSONObject);
				}
				json.put("result", jSONArray);
			}
		}
		return json.toString();
	}
	
//	巡检记录
	@Override
	public String getCheckRecordList(String queryJson, String page, String start, String limit, String sort) throws Exception {
		// TODO Auto-generated method stub
		SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		//设置时间格式，将该时间格式的时间转换为时间戳
	    SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
		String id = null;
		String personnel = null;
		String route = null;
		String planned_date = null;
		String start_time = null;
		String end_time = null;	
		String completion_status  = null;
		
		String sjc1=null;
		String sjc2=null;
		
		String company_code=null;
		String V_LOGINNAME = null;
		String V_PASSWORD = null;
		int E_STATUS=-1;
		String company_code_list = null;
		
		
		String Page = null;
		String Start = null;
		JSONArray Sort = null;
		String Limit = null;
		String hqlwhere4 = null;
		String hqlwhere3 = null;
		String hqlwhere2 = null;
		String hqlwhere1 = null;
		String hqlwhere = null;
		String order = null;
		String dir = null;		
		String order_str = null;
		JSONObject q_json = null;		
		JSONArray jSONArray = new JSONArray();
		JSONObject json = new JSONObject();
		json.put("action", "getPatrolPlanList");
		if(queryJson!=null) {
			q_json = JSONObject.fromObject(queryJson);
			id 	  	 = q_json.has("id")?q_json.getString("id"):null;
			
			personnel 	  	 = q_json.has("personnel")?q_json.getString("personnel"):null;
			route      = q_json.has("route")?q_json.getString("route"):null;
			planned_date  = q_json.has("planned_date")?q_json.getString("planned_date"):null;
			start_time 	 = q_json.has("start_time")?q_json.getString("start_time"):null;		
			end_time = q_json.has("end_time")?q_json.getString("end_time"):null;
			completion_status = q_json.has("completion_status")?q_json.getString("completion_status"):null;
			
			V_LOGINNAME = q_json.has("V_LOGINNAME")?q_json.getString("V_LOGINNAME"):null;
			V_PASSWORD = q_json.has("V_PASSWORD")?q_json.getString("V_PASSWORD"):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"):(start!=null)?start:"0";
			Limit = q_json.has("limit")?q_json.getString("limit"):(limit!=null)?limit:null;
			Page = q_json.has("page")?q_json.getString("page"):(page!=null)?page:"0";
			json.put("query", queryJson);
		}
		
		if((V_LOGINNAME!=null)&&(V_PASSWORD!=null)) {
			List list88 = ytiotTAdminDao.query(" where MD5(u.VLoginname)='"+MD5Util.EncoderByMd5(V_LOGINNAME)+"' and u.VPassword='"
					+V_PASSWORD+"' ", null, null, null, null);
			if(list88.size()>0) {
				YtiotTAdmin b2 = (YtiotTAdmin)list88.get(0);
//				System.out.println("测试1"+b2.getEStatus()); 
				E_STATUS = Integer.parseInt(b2.getEStatus());
//				System.out.println("测试2"+E_STATUS);
			}
		}
		
		if(E_STATUS==1) {
			if(V_LOGINNAME!=null) {
				String where99 = " where u.id.agentid='"+V_LOGINNAME+"' ";
				List list66 = ytiotVUserCompanyDao.query(where99, null, null, null, null);
				if(list66.size()>0) {
					for(int i=0;i<list66.size();i++) {
						YtiotVUsercompany b1 = (YtiotVUsercompany)list66.get(i);
						YtiotVUsercompanyId oid = b1.getId();
						if(i==0)
							company_code_list = oid.getOwnerCode();
						else
							company_code_list += ","+oid.getOwnerCode();
					}
				}
			}
			
			
			
			if(personnel!=null) {
				hqlwhere3 =  "u."+fieldname("name")+"='"+personnel+"'";
			     List list3 =ytiotTPatrolPlanDao.query1(hqlwhere3);
			     YtiotTInspectors p = (YtiotTInspectors)list3.get(0);
			     personnel = Integer.toString(p.getId());
			}
			if(route!=null) {
				hqlwhere4 =  "u."+fieldname("route_name")+"='"+route+"'";
				List list4 =ytiotTPatrolPlanDao.query2(hqlwhere4);
				YtiotTRoute t = (YtiotTRoute)list4.get(0);
				route = Integer.toString(t.getId());
			}
//			System.out.println();
			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(company_code!=null)
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("company_code")+"='"+company_code+"'";
			if(company_code_list!=null)
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("company_code")+" in("+company_code_list+")";
			
			if(personnel!=null)
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("personnel")+"='"+personnel+"'";
			if(route!=null)
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("route")+"='"+route+"'";
			if(start_time!=null)
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("start_time")+"='"+start_time+"'";
			if(end_time!=null)
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("end_time")+"='"+end_time+"'";
			if(planned_date!=null)
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("planned_date")+" like '%"+planned_date+"%'";
			if(completion_status!=null)
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("completion_status")+"='"+completion_status+"'";
			
			if(order!=null) 
				order_str = " order by u."+fieldname(order);
			else
				order_str = " order by u."+fieldname("id");
			int totalCount = ytiotTPatrolPlanDao.getCount(hqlwhere);
			//System.out.println(totalCount);
			json.put("totalCount", totalCount);
			if(Start!=null){
				if(Integer.parseInt(Start)>totalCount){
					Start = "0";
					Page = "0";
				}
				if(page==null)
					Page="0";
			}else{
				Start = "0";
				Page = "0";
			}
			json.put("page", Page);
			json.put("start", Start);
			json.put("limit", Limit);
			if(totalCount>0) {
				List list = ytiotTPatrolPlanDao.query(hqlwhere, order_str, dir, Start, Limit);
				if(list.size()>0) {
					//获得当天时间
					 Date date1 = simpleDateFormat.parse(simpleDateFormat.format(new Date()));
//					 System.out.println("测试三当前时间yyyy-MM-dd"+simpleDateFormat.format(new Date()));
					 long time1 = date1.getTime()/1000;
					 sjc1 = String.valueOf(time1);
					for(int i=0;i<list.size();i++) {
						YtiotTPatrolPlan o = (YtiotTPatrolPlan)list.get(i);
						Map map = new HashMap();
						//转换为时间戳
//						System.out.println("测试三记录时间yyyy-MM-dd"+o.getPlannedDate());
					    Date date2 = simpleDateFormat.parse(o.getPlannedDate());
					    long time2 = date2.getTime()/1000;
					    sjc2 = String.valueOf(time2);
					    
					    if(Integer.parseInt(sjc2)<Integer.parseInt(sjc1)) {
					    	if(o.getPersonnel()!=null) {
								hqlwhere1 = "u."+fieldname("id")+"='"+o.getPersonnel()+"'";
								List list1 = ytiotTPatrolPlanDao.query1(hqlwhere1);
								if(list1.size()>0) {
								YtiotTInspectors g = (YtiotTInspectors)list1.get(0);
								map.put("personnel", g.getName());
								}	
							}
					    	if(o.getRoute()!=null) {
								hqlwhere2 =  "u."+fieldname("id")+"='"+o.getRoute()+"'";
								List list2 = ytiotTPatrolPlanDao.query2(hqlwhere2);
								if(list2.size()>0) {
								YtiotTRoute r = (YtiotTRoute)list2.get(0);
								map.put("route", r.getRouteName());
								}
							}
					    	map.put("id", o.getId());
//							map.put("personnel", o.getPersonnel());
//							map.put("route", o.getRoute());
							map.put("planned_date", o.getPlannedDate());
							map.put("start_time", o.getStartTime());
							map.put("end_time", o.getEndTime());
							map.put("completion_status", o.getCompletionStatus());
							map.put("company_code1", o.getCompanyCode());
							JSONObject jSONObject = JSONObject.fromObject(map);
							jSONArray.add(jSONObject);
					    }	
						
					}
					json.put("RESULT", jSONArray);
				}
			}
		}else {
			json.put("success", "false");
			json.put("MSG", "用户权限错误，请重新登录后再试。");
		}
		
		
		
		return json.toString();
	}
	
	@Override
	public String getCheckRecordExcelList(String queryJson) throws Exception {
		// TODO Auto-generated method stub
		SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		//设置时间格式，将该时间格式的时间转换为时间戳
	    SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
		String id = null;
		String personnel = null;
		String route = null;
		String planned_date = null;
		String start_time = null;
		String end_time = null;	
		String completion_status  = null;
		
		String sjc1=null;
		String sjc2=null;
		
		String company_code=null;
		String V_LOGINNAME = null;
		String V_PASSWORD = null;
		int E_STATUS=-1;
		String company_code_list = null;
		
		
		String Page = null;
		String Start = null;
		JSONArray Sort = null;
		String Limit = null;
		String hqlwhere4 = null;
		String hqlwhere3 = null;
		String hqlwhere2 = null;
		String hqlwhere1 = null;
		String hqlwhere = null;
		String order = null;
		String dir = null;		
		String order_str = null;
		JSONObject q_json = null;		
		JSONArray jSONArray = new JSONArray();
		JSONObject json = new JSONObject();
		json.put("action", "getPatrolPlanList");
		if(queryJson!=null) {
			q_json = JSONObject.fromObject(queryJson);
			id 	  	 = q_json.has("id")?q_json.getString("id"):null;
			
			personnel 	  	 = q_json.has("personnel")?q_json.getString("personnel"):null;
			route      = q_json.has("route")?q_json.getString("route"):null;
			planned_date  = q_json.has("planned_date")?q_json.getString("planned_date"):null;
			start_time 	 = q_json.has("start_time")?q_json.getString("start_time"):null;		
			end_time = q_json.has("end_time")?q_json.getString("end_time"):null;
			completion_status = q_json.has("completion_status")?q_json.getString("completion_status"):null;
			
			V_LOGINNAME = q_json.has("V_LOGINNAME")?q_json.getString("V_LOGINNAME"):null;
			V_PASSWORD = q_json.has("V_PASSWORD")?q_json.getString("V_PASSWORD"):null;
			
			order = q_json.has("order")?q_json.getString("order"):null;
			dir = q_json.has("dir")?q_json.getString("dir"):null;
			
			json.put("query", queryJson);
		}
		
		if((V_LOGINNAME!=null)&&(V_PASSWORD!=null)) {
			List list88 = ytiotTAdminDao.query(" where MD5(u.VLoginname)='"+MD5Util.EncoderByMd5(V_LOGINNAME)+"' and u.VPassword='"
					+V_PASSWORD+"' ", null, null, null, null);
			if(list88.size()>0) {
				YtiotTAdmin b2 = (YtiotTAdmin)list88.get(0);
//				System.out.println("测试1"+b2.getEStatus()); 
				E_STATUS = Integer.parseInt(b2.getEStatus());
//				System.out.println("测试2"+E_STATUS);
			}
		}
//		System.out.println("bengkui"+E_STATUS);
		if(E_STATUS==1) {
			if(V_LOGINNAME!=null) {
				String where99 = " where u.id.agentid='"+V_LOGINNAME+"' ";
				List list66 = ytiotVUserCompanyDao.query(where99, null, null, null, null);
				if(list66.size()>0) {
					for(int i=0;i<list66.size();i++) {
						YtiotVUsercompany b1 = (YtiotVUsercompany)list66.get(i);
						YtiotVUsercompanyId oid = b1.getId();
						if(i==0)
							company_code_list = oid.getOwnerCode();
						else
							company_code_list += ","+oid.getOwnerCode();
					}
				}
			}
			
			
			if((personnel!=null)&&(personnel.length()>0)) {
				hqlwhere3 =  "u."+fieldname("name")+"='"+personnel+"'";
			     List list3 =ytiotTPatrolPlanDao.query1(hqlwhere3);
			     YtiotTInspectors p = (YtiotTInspectors)list3.get(0);
			     personnel = Integer.toString(p.getId());
			}
			if((route!=null)&&(route.length()>0)) {
				hqlwhere4 =  "u."+fieldname("route_name")+"='"+route+"'";
				List list4 =ytiotTPatrolPlanDao.query2(hqlwhere4);
				YtiotTRoute t = (YtiotTRoute)list4.get(0);
				route = Integer.toString(t.getId());
			}
//			System.out.println();
			
			
			if(company_code!=null)
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("company_code")+"='"+company_code+"'";
			if(company_code_list!=null)
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("company_code")+" in("+company_code_list+")";
			
			if((personnel!=null)&&(personnel.length()>0))
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("personnel")+"='"+personnel+"'";
			if((route!=null)&&(route.length()>0))
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("route")+"='"+route+"'";
			if((start_time!=null)&&(start_time.length()>0))
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("start_time")+"='"+start_time+"'";
			if((end_time!=null)&&(end_time.length()>0))
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("end_time")+"='"+end_time+"'";
			if((planned_date!=null)&&(planned_date.length()>0))
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("planned_date")+" like '%"+planned_date+"%'";
			if((completion_status!=null)&&(completion_status.length()>0))
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("completion_status")+"='"+completion_status+"'";
			
			if(order!=null) 
				order_str = " order by u."+fieldname(order);
			else
				order_str = " order by u."+fieldname("id");
			int totalCount = ytiotTPatrolPlanDao.getCount(hqlwhere);
			
			json.put("totalCount", totalCount);
			
			if(totalCount>0) {
				List list = ytiotTPatrolPlanDao.query(hqlwhere, order_str, dir, Start, Limit);
				if(list.size()>0) {
					//获得当天时间
					 Date date1 = simpleDateFormat.parse(simpleDateFormat.format(new Date()));
//					 System.out.println("测试三当前时间yyyy-MM-dd"+simpleDateFormat.format(new Date()));
					 long time1 = date1.getTime()/1000;
					 sjc1 = String.valueOf(time1);
					for(int i=0;i<list.size();i++) {
						YtiotTPatrolPlan o = (YtiotTPatrolPlan)list.get(i);
						Map map = new HashMap();
						//转换为时间戳
//						System.out.println("测试三记录时间yyyy-MM-dd"+o.getPlannedDate());
					    Date date2 = simpleDateFormat.parse(o.getPlannedDate());
					    long time2 = date2.getTime()/1000;
					    sjc2 = String.valueOf(time2);
					    
					    if(Integer.parseInt(sjc2)<Integer.parseInt(sjc1)) {
					    	if(o.getPersonnel()!=null) {
								hqlwhere1 = "u."+fieldname("id")+"='"+o.getPersonnel()+"'";
								List list1 = ytiotTPatrolPlanDao.query1(hqlwhere1);
								if(list1.size()>0) {
								YtiotTInspectors g = (YtiotTInspectors)list1.get(0);
								map.put("personnel", g.getName());
								}	
							}
					    	if(o.getRoute()!=null) {
								hqlwhere2 =  "u."+fieldname("id")+"='"+o.getRoute()+"'";
								List list2 = ytiotTPatrolPlanDao.query2(hqlwhere2);
								if(list2.size()>0) {
								YtiotTRoute r = (YtiotTRoute)list2.get(0);
								map.put("route", r.getRouteName());
								}
							}
					    	map.put("id", o.getId());
//							map.put("personnel", o.getPersonnel());
//							map.put("route", o.getRoute());
							map.put("planned_date", o.getPlannedDate());
							map.put("start_time", o.getStartTime());
							map.put("end_time", o.getEndTime());
							map.put("completion_status", o.getCompletionStatus());
							map.put("company_code1", o.getCompanyCode());
							JSONObject jSONObject = JSONObject.fromObject(map);
							jSONArray.add(jSONObject);
					    }	
						
					}
					json.put("result", jSONArray);
				}
			}
		}else {
			json.put("success", "false");
			json.put("MSG", "用户权限错误，请重新登录后再试。");
		}
		
		
		
		return json.toString();
	}

	@Override
	public String getControlroomList(String queryJson, String page, String start, String limit, String sort) throws Exception {
		// TODO Auto-generated method stub
		SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");	
		String control_room_name = null;
		String control_room_person = null;
		String planned_date = null;
		String start_time = null;
		String end_time = null;	
		String completion_status  = null;
		String company_code = null;
		String Company_Code_List = null;
		String V_LOGINNAME = null;
		int xh = 0;
		String Page = null;
		String Start = null;
		JSONArray Sort = null;
		String Limit = null;
		String hqlwhere4 = null;
		String hqlwhere3 = null;
		String hqlwhere2 = null;
		String hqlwhere1 = null;
		String hqlwhere = null;
		String order = null;
		String dir = null;		
		String order_str = null;
		JSONObject q_json = null;		
		JSONArray jSONArray = new JSONArray();
		JSONObject json = new JSONObject();
		json.put("action", "getPatrolPlanList");
		if(queryJson!=null) {
			q_json = JSONObject.fromObject(queryJson);
			control_room_name = q_json.has("control_room_name")?q_json.getString("control_room_name"):null;
			control_room_person = q_json.has("control_room_person")?q_json.getString("control_room_person"):null;
			company_code = q_json.has("company_code")?q_json.getString("company_code"):null;
			start_time = q_json.has("start_time")?q_json.getString("start_time"):null;		
			end_time = q_json.has("end_time")?q_json.getString("end_time"):null;
			completion_status = q_json.has("completion_status")?q_json.getString("completion_status"):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"):(start!=null)?start:"0";
			Limit = q_json.has("limit")?q_json.getString("limit"):(limit!=null)?limit:null;
			Page = q_json.has("page")?q_json.getString("page"):(page!=null)?page:"0";
			V_LOGINNAME = q_json.has("V_LOGINNAME")?q_json.getString("V_LOGINNAME"):null;
			json.put("query", queryJson);
		}
//		System.out.println();
		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);
		}
		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();
					
				}
			}
		}
		Start = start;
		Limit = limit;
		Page = page;
		if(company_code!=null) {
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("company_code")+"='"+company_code+"'";
		}else {
			if(Company_Code_List!=null)
				hqlwhere = chkhw(hqlwhere) + "u."+fieldname("company_code")+" in ("+Company_Code_List+") ";
		}
		if(control_room_name!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("control_room_name")+"='"+control_room_name+"'";
		if(control_room_person!=null&&!control_room_person.equals("所有人"))
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("control_room_person")+"='"+control_room_person+"'";
//		if(start_time!=null)
//			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("start_time")+"='"+start_time+"'";
//		if(end_time!=null)
//			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("end_time")+"='"+end_time+"'";
//		if(planned_date!=null)
//			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("planned_date")+" like '%"+planned_date+"%'";
//		if(completion_status!=null)
//			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("completion_status")+"='"+completion_status+"'";
		
		if(order!=null) 
			order_str = " order by u."+fieldname(order);
		else
			order_str = " order by u."+fieldname("id");
		int totalCount = ytiotTPatrolPlanDao.getControlCount(hqlwhere);
		//System.out.println(totalCount);
		json.put("totalCount", totalCount);
		if(Start!=null){
			if(Integer.parseInt(Start)>totalCount){
				Start = "0";
				Page = "0";
			}
			if(page==null)
				Page="0";
		}else{
			Start = "0";
			Page = "0";
		}
		json.put("page", Page);
		json.put("start", Start);
		json.put("limit", Limit);
		if(totalCount>0) {
			List list = ytiotTPatrolPlanDao.queryControl(hqlwhere, order_str, dir, Start, Limit);
			if(list.size()>0) {
				for(int i=0;i<list.size();i++) {
					YtiotTControlroom o = (YtiotTControlroom)list.get(i);
					Map map = new HashMap();
					if(o.getCompanyCode()!=null) {
						hqlwhere2 =  "u."+fieldname("V_COMPANY_CODE")+"='"+o.getCompanyCode()+"'";
						List list2 = ytiotTPatrolPlanDao.query3(hqlwhere2);
						if(list2.size()>0) {
							YtiotTCompany r = (YtiotTCompany)list2.get(0);
						map.put("company_name", r.getVCompanyName());
						}
					}
					xh=i+1;
					map.put("xh", xh);
					map.put("id", o.getId());
					map.put("control_room_name", o.getControlRoomName());
					map.put("control_room_person", o.getControlRoomPerson());
					map.put("control_room_address", o.getControlRoomAddress());
					map.put("control_room_phone", o.getControlRoomPhone());
					map.put("company_code", o.getCompanyCode());
					JSONObject jSONObject = JSONObject.fromObject(map);
					jSONArray.add(jSONObject);
				}
				json.put("RESULT", jSONArray);
			}
		}
		return json.toString();
	}
	
	@Override
	public String appendControlRoom(String queryJson) throws Exception {
		// TODO Auto-generated method stub		
		String id = null;
		String control_room_name = null;
		String control_room_person = null;
		String control_room_address = null;
		String control_room_phone = null;
		String end_time = null;
		String start_data = null;
		String end_data = null;
		String completion_status  = null;
		String demoArray[]=null;
		String V_LOGINNAME = null;
		String company_code = null;
		
		JSONObject q_json = null;
		JSONArray jSONArray = new JSONArray();
		JSONObject json = new JSONObject();
		json.put("action", "appendPatrolPlan");
		
		if(queryJson!=null) {
			q_json = JSONObject.fromObject(queryJson);
			control_room_name = q_json.has("control_room_name")?q_json.getString("control_room_name"):null;
			control_room_person = q_json.has("control_room_person")?q_json.getString("control_room_person"):null;
			company_code = q_json.has("company_code")?q_json.getString("company_code"):null;
			control_room_address = q_json.has("control_room_address")?q_json.getString("control_room_address"):null;
			control_room_phone = q_json.has("control_room_phone")?q_json.getString("control_room_phone"):null;
			V_LOGINNAME = q_json.has("V_LOGINNAME")?q_json.getString("V_LOGINNAME"):null;
			json.put("query", queryJson);
		}
//		if((V_LOGINNAME!=null)&&(Company_Code_List==null)&&(!V_LOGINNAME.equals("admin"))) {
//			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(!oid.getOwnerCode().equals("10012")&& !oid.getOwnerCode().equals("10068")) {
//					
//						Company_Code_List = oid.getOwnerCode();
//					
//					}
//				}
//			}
//		}
//		System.out.println(Company_Code_List);
		if(chk_string_param(control_room_name)&&chk_string_param(control_room_person)&&chk_string_param(control_room_address)
				&&chk_string_param(control_room_phone)&&chk_string_param(company_code)) {
			YtiotTControlroom o = new YtiotTControlroom();
			o.setCompanyCode(company_code);
			o.setControlRoomAddress(control_room_address);
			o.setControlRoomName(control_room_name);
			o.setControlRoomPerson(control_room_person);
			o.setControlRoomPhone(control_room_phone);
			DaoResult ret = ytiotTPatrolPlanDao.addControl(o);
			json.put("success", true);
			json.put("Msg", "成功加入数据库");
		}else {
			json.put("success", false);
			json.put("Msg", "参数验证错误");
		}
		return json.toString();
	}
	
	@Override
	public String updateControlRoom(String queryJson) throws Exception {
		// TODO Auto-generated method stub
		String id = null;
		String control_room_name = null;
		String control_room_person = null;
		String control_room_address = null;
		String control_room_phone = null;
		String end_time = null;	
		String company_code  = null;
		String hqlwhere = null;
		String hqlwhere1 = null;
		JSONObject q_json = null;
		JSONArray jSONArray = new JSONArray();
		JSONObject json = new JSONObject();
		json.put("action", "updatePatrolPlan");
		if(queryJson!=null) {
			q_json = JSONObject.fromObject(queryJson);
			id = q_json.has("id")?q_json.getString("id"):null;
			control_room_name = q_json.has("control_room_name")?q_json.getString("control_room_name"):null;
			control_room_person = q_json.has("control_room_person")?q_json.getString("control_room_person"):null;
			company_code = q_json.has("company_code")?q_json.getString("company_code"):null;
			control_room_address = q_json.has("control_room_address")?q_json.getString("control_room_address"):null;
			control_room_phone = q_json.has("control_room_phone")?q_json.getString("control_room_phone"):null;
			json.put("query", queryJson);
		}
		if(chk_string_param(id)&&chk_string_param(control_room_name)&&chk_string_param(control_room_person)&&chk_string_param(company_code)
				&&chk_string_param(control_room_address)&&chk_string_param(control_room_phone)) {
			if(id!=null) {
				List list = ytiotTPatrolPlanDao.queryControl(" where u."+fieldname("id")+" ='"+id+"' ", null, null, null, null);
				if(list.size()>0) {
					YtiotTControlroom o = (YtiotTControlroom) list.get(0);
					if(control_room_name!=null)
						o.setControlRoomName(control_room_name);
					if(control_room_person!=null)
						o.setControlRoomPerson(control_room_person);
					if(company_code!=null)
						o.setCompanyCode(company_code);
					if(control_room_address!=null)
						o.setControlRoomAddress(control_room_address);
					if(control_room_phone!=null)
						o.setControlRoomPhone(control_room_phone);
					DaoResult ret = ytiotTPatrolPlanDao.updateControl(o);
					json.put("success", ret.isSuccess());
					json.put("MSG", ret.getResult());
				}else {
					json.put("success", false);
					json.put("MSG", "需要编辑的消控室不存在");
				}
			}else {
				json.put("success", false);
				json.put("MSG", "记录ID不能为空");
			}
		}else {
			json.put("success", false);
			json.put("MSG", "参数验证错误");
		}
		return json.toString();
	}
	
}