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

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import cn.com.usky.iot.entity.YtiotTCompany;
import cn.com.usky.iot.entity.YtiotTCompanyVer;
import cn.com.usky.iot.company.dao.YtiotTCompanyDao;
import cn.com.usky.iot.company.dao.YtiotTCompanyVerDao;
import cn.com.usky.utils.DaoResult;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

public class YtiotTCompanyServicesImpl implements YtiotTCompanyService {
	private YtiotTCompanyDao ytiotTCompanyDao;
	private YtiotTCompanyVerDao ytiotTCompanyVerDao;

	public YtiotTCompanyDao getYtiotTCompanyDao() {
		return ytiotTCompanyDao;
	}

	public void setYtiotTCompanyDao(YtiotTCompanyDao ytiotTCompanyDao) {
		this.ytiotTCompanyDao = ytiotTCompanyDao;
	}

	public YtiotTCompanyVerDao getYtiotTCompanyVerDao() {
		return ytiotTCompanyVerDao;
	}

	public void setYtiotTCompanyVerDao(YtiotTCompanyVerDao ytiotTCompanyVerDao) {
		this.ytiotTCompanyVerDao = ytiotTCompanyVerDao;
	}
	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("I_COMPANYVER_ID"))
			return "ICompanyverId";
		if(field.equals("UQ_COMPANY_ID"))
			return "uqCompanyId";
		if(field.equals("I_ORDER_IDX"))
			return "IOrderIdx";
		if(field.equals("UQ_PARENT_ID"))
			return "uqParentId";
		if(field.equals("UQ_PARENT_COMPANY_ID"))
			return "uqParentCompanyId";
		if(field.equals("V_COMPANY_NAME"))
			return "VCompanyName";
		if(field.equals("V_COMPANY_ADDRESS_0"))
			return "VCompanyAddress0";
		if(field.equals("V_COMPANY_ADDRESS_1"))
			return "VCompanyAddress1";
		if(field.equals("V_COMPANY_ADDRESS_2"))
			return "VCompanyAddress2";
		if(field.equals("E_STATUS"))
			return "EStatus";
		if(field.equals("UQ_ADMIN_ID"))
			return "uqAdminId";
		if(field.equals("I_VERSION"))
			return "IVersion";
		if(field.equals("D_STORETIME"))
			return "DStoretime";
		if(field.equals("V_COMMENT"))
			return "VComment";
		return null;
	}
	@Override
	public String appendCompany(String queryJson) throws Exception {
		// TODO Auto-generated method stub		
		String UQ_COMPANY_ID = null;
		String UQ_PARENT_ID = null;//上级部门ID
		//String UQ_PARENT_COMPANY_ID = null;//所属单位的ID
		String V_COMPANY_NAME = null;//单位/部门名称
		String V_COMPANY_ADDRESS_0 = null;//单位/部门地址_1
		String V_COMPANY_ADDRESS_1  = null;//单位/部门地址_2
		String V_COMPANY_ADDRESS_2  = null;//单位/部门地址_3
		String E_STATUS  = null;//当前状态，0为待开通服务，1为已开通服务，2为服务锁定，3为已注销，4、5留用
		String UQ_ADMIN_ID = null;//信息录入人ID
		String V_COMMENT  = null;//注册/修改说明
		JSONObject q_json = null;
		JSONArray jSONArray = new JSONArray();
		JSONObject json = new JSONObject();
		json.put("action", "appendCompany");
		if(queryJson!=null) {
			q_json = JSONObject.fromObject(queryJson);
			UQ_PARENT_ID = q_json.has("UQ_PARENT_ID")?q_json.getString("UQ_PARENT_ID"):null;
			//UQ_PARENT_COMPANY_ID = q_json.has("UQ_PARENT_COMPANY_ID")?q_json.getString("UQ_PARENT_COMPANY_ID"):null;			
			V_COMPANY_NAME = q_json.has("V_COMPANY_NAME")?q_json.getString("V_COMPANY_NAME"):null;
			V_COMPANY_ADDRESS_0 = q_json.has("V_COMPANY_ADDRESS_0")?q_json.getString("V_COMPANY_ADDRESS_0"):null;
			V_COMPANY_ADDRESS_1 = q_json.has("V_COMPANY_ADDRESS_1")?q_json.getString("V_COMPANY_ADDRESS_1"):null;			
			V_COMPANY_ADDRESS_2 = q_json.has("V_COMPANY_ADDRESS_2")?q_json.getString("V_COMPANY_ADDRESS_2"):null;
//			E_STATUS = q_json.has("E_STATUS")?q_json.getString("E_STATUS"):null;
			UQ_ADMIN_ID = q_json.has("UQ_ADMIN_ID")?q_json.getString("UQ_ADMIN_ID"):null;
			V_COMMENT = q_json.has("V_COMMENT")?q_json.getString("V_COMMENT"):"";
			json.put("query", queryJson);
		}
		if(chk_string_param(UQ_PARENT_ID)//&&chk_string_param(UQ_PARENT_COMPANY_ID)
				&&chk_string_param(V_COMPANY_NAME)&&chk_string_param(V_COMPANY_ADDRESS_0)
				&&chk_string_param(V_COMPANY_ADDRESS_1)&&chk_string_param(V_COMPANY_ADDRESS_2)//&&chk_string_param(E_STATUS)
				&&chk_string_param(UQ_ADMIN_ID)&&chk_string_param(V_COMMENT)) {
			YtiotTCompany o = new YtiotTCompany();
			o.setUqParentId(UQ_PARENT_ID);
			//o.setUqParentCompanyId(UQ_PARENT_COMPANY_ID);			
			o.setVCompanyName(V_COMPANY_NAME);
			o.setVCompanyAddress0(V_COMPANY_ADDRESS_0);
			o.setVCompanyAddress1(V_COMPANY_ADDRESS_1);
			o.setVCompanyAddress2(V_COMPANY_ADDRESS_2);
			o.setEStatus("0");
			o.setUqAdminId(UQ_ADMIN_ID);			
			o.setDStoretime(new Date());
			DaoResult ret = ytiotTCompanyDao.add(o, V_COMMENT);
			json.put("success", ret.isSuccess());
			json.put("Msg", ret.getResult());
		}else {
			json.put("success", false);
			json.put("Msg", "参数验证错误");
		}
		return json.toString();
	}

	@Override
	public String updateCompany(String queryJson) throws Exception {
		// TODO Auto-generated method stub
		String UQ_COMPANY_ID = null;
		String V_COMPANY_NAME = null;//单位/部门名称
		String V_COMPANY_ADDRESS_0 = null;//单位/部门地址_1
//		String V_COMPANY_ADDRESS_1  = null;//单位/部门地址_2
//		String V_COMPANY_ADDRESS_2  = null;//单位/部门地址_3
		String V_COMMENT  = null;//注册/修改说明
		String UQ_ADMIN_ID = null;//信息录入人ID
//		String UQ_PARENT_ID = null;//上级部门ID
//		String UQ_PARENT_COMPANY_ID = null;//所属单位的ID
		String E_STATUS  = null;//当前状态，0为待开通服务，1为已开通服务，2为服务锁定，3为已注销，4、5留用
		JSONObject q_json = null;
		JSONArray jSONArray = new JSONArray();
		JSONObject json = new JSONObject();
		json.put("action", "updateCompany");
		if(queryJson!=null) {
			q_json = JSONObject.fromObject(queryJson);
			UQ_COMPANY_ID = q_json.has("UQ_COMPANY_ID")?q_json.getString("UQ_COMPANY_ID"):null;
			V_COMPANY_NAME = q_json.has("V_COMPANY_NAME")?q_json.getString("V_COMPANY_NAME"):null;
			V_COMPANY_ADDRESS_0 = q_json.has("V_COMPANY_ADDRESS_0")?q_json.getString("V_COMPANY_ADDRESS_0"):null;
//			V_COMPANY_ADDRESS_1 = q_json.has("V_COMPANY_ADDRESS_1")?q_json.getString("V_COMPANY_ADDRESS_1"):null;			
//			V_COMPANY_ADDRESS_2 = q_json.has("V_COMPANY_ADDRESS_2")?q_json.getString("V_COMPANY_ADDRESS_2"):null;
			V_COMMENT = q_json.has("V_COMMENT")?q_json.getString("V_COMMENT"):"";
//			UQ_PARENT_ID = q_json.has("UQ_PARENT_ID")?q_json.getString("UQ_PARENT_ID"):null;
			UQ_ADMIN_ID = q_json.has("UQ_ADMIN_ID")?q_json.getString("UQ_ADMIN_ID"):null;			
//			UQ_PARENT_COMPANY_ID = q_json.has("UQ_PARENT_COMPANY_ID")?q_json.getString("UQ_PARENT_COMPANY_ID"):null;			
			E_STATUS = q_json.has("E_STATUS")?q_json.getString("E_STATUS").toUpperCase():null;
			json.put("query", queryJson);
		}
		if(chk_string_param(UQ_COMPANY_ID)&&chk_string_param(V_COMPANY_NAME)&&chk_string_param(V_COMPANY_ADDRESS_0)
//				&&chk_string_param(V_COMPANY_ADDRESS_1)&&chk_string_param(V_COMPANY_ADDRESS_2)
				&&(V_COMMENT!=null)&&chk_string_param(UQ_ADMIN_ID)//&&chk_string_param(UQ_PARENT_ID)
				&&chk_string_param(E_STATUS)) {
			if(UQ_COMPANY_ID!=null) {
				List list = ytiotTCompanyDao.query(" where u."+fieldname("UQ_COMPANY_ID")+" ='"+UQ_COMPANY_ID+"' ", null, null, null, null);
				if(list.size()>0) {
					YtiotTCompany o = (YtiotTCompany) list.get(0);
					if(V_COMPANY_NAME!=null)
						o.setVCompanyName(V_COMPANY_NAME);
					if(V_COMPANY_ADDRESS_0!=null)
						o.setVCompanyAddress0(V_COMPANY_ADDRESS_0);
//					if(UQ_PARENT_ID!=null)
//						o.setUqParentId(UQ_PARENT_ID);
//					if(UQ_PARENT_COMPANY_ID!=null)
//						o.setUqParentId(UQ_PARENT_COMPANY_ID);
//					o.setUqParentId(UQ_PARENT_ID);
//					o.setVCompanyAddress1(V_COMPANY_ADDRESS_1);
//					o.setVCompanyAddress2(V_COMPANY_ADDRESS_2);
					o.setUqAdminId(UQ_ADMIN_ID);
					o.setEStatus(E_STATUS);
					DaoResult ret = ytiotTCompanyDao.update(o, V_COMMENT);
					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 deleteCompany(String queryJson) throws Exception {
		// TODO Auto-generated method stub
		//String UQ_COMPANY_ID = null;
		JSONObject q_json = null;
		JSONArray jSONArray = new JSONArray();
		JSONArray jsonCompanyList = new JSONArray();
		JSONObject json = new JSONObject();
		json.put("action", "deleteCompany");	
		if(queryJson!=null) {
			q_json = JSONObject.fromObject(queryJson);
			if(q_json.has("COMPANY_LIST")) {
				jsonCompanyList = q_json.getJSONArray("COMPANY_LIST");
				for(int i=0;i<jsonCompanyList.size();i++) {
					JSONObject j_temp = jsonCompanyList.getJSONObject(i);
					if(j_temp.has("UQ_COMPANY_ID")) {
						List list = ytiotTCompanyDao.query(" where u."+fieldname("UQ_COMPANY_ID")+" ='"+j_temp.getString("UQ_COMPANY_ID")+"' ", null, null, null, null);
						
						if(list.size()>0) {
							
							for(int j=0;j<list.size();j++) {
								YtiotTCompany o = (YtiotTCompany) list.get(j);
								o.setEStatus("3");
								ytiotTCompanyDao.delect(o, "注销");
								System.out.println("测试：111111111111111");
							}
						}
					}
				}
			}
		}	
		
//		if(queryJson!=null) {
//			q_json = JSONObject.fromObject(queryJson);
//			UQ_COMPANY_ID = q_json.has("UQ_COMPANY_ID")?q_json.getString("UQ_COMPANY_ID"):null;
//			json.put("query", queryJson);
//		}
//		
//		if(chk_string_param(UQ_COMPANY_ID)) {
//			if(UQ_COMPANY_ID!=null) {
//				List list = ytiotTCompanyDao.query(" where u."+fieldname("UQ_COMPANY_ID")+" ='"+UQ_COMPANY_ID+"' ", null, null, null, null);
//				if(list.size()>0) {
//					YtiotTCompany o = (YtiotTCompany) list.get(0);
//					o.setEStatus("3");
//					DaoResult ret = ytiotTCompanyDao.delect(o, V_COMMENT);
//					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 getCompanyList(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 UQ_COMPANY_ID = null;
		
		String V_COMPANY_NAME=null;//单位名称
		String V_COMPANY_ADDRESS_0=null;//单位地址_1
		String I_VERSION=null;//当前记录版本
		String D_STORETIME=null;//记录存储时间
		String UQ_ADMIN_ID=null;//信息录入人ID\
		String E_STATUS=null;//当前状态，0为待开通服务，1为已开通服务，2为服务锁定，3为已注销，4、5留用
		String V_COMMENT  = null;//注册/修改说明
		String I_ORDER_IDX  = null;//序号
		String Page = null;
		String Start = null;
		JSONArray Sort = null;
		String Limit = 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", "getCompanyList");
		if(queryJson!=null) {
			q_json = JSONObject.fromObject(queryJson);
			I_ORDER_IDX= q_json.has("I_ORDER_IDX")?q_json.getString("I_ORDER_IDX"):null;
			UQ_COMPANY_ID = q_json.has("UQ_COMPANY_ID")?q_json.getString("UQ_COMPANY_ID"):null;
			V_COMPANY_NAME = q_json.has("V_COMPANY_NAME")?q_json.getString("V_COMPANY_NAME"):null;
			V_COMPANY_ADDRESS_0 = q_json.has("V_COMPANY_ADDRESS_0")?q_json.getString("V_COMPANY_ADDRESS_0"):null;			
			UQ_ADMIN_ID = q_json.has("UQ_ADMIN_ID")?q_json.getString("UQ_ADMIN_ID"):null;
			V_COMMENT = q_json.has("V_COMMENT")?q_json.getString("V_COMMENT"):null;
			I_VERSION = q_json.has("I_VERSION")?q_json.getString("I_VERSION"):null;
			//E_STATUS = q_json.has("E_STATUS")?q_json.getString("E_STATUS"):null;
			D_STORETIME = q_json.has("D_STORETIME")?q_json.getString("D_STORETIME"):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);
		}
//		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(UQ_COMPANY_ID!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("UQ_COMPANY_ID")+"='"+UQ_COMPANY_ID+"'";
		if(V_COMPANY_NAME!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("V_COMPANY_NAME")+" like '%"+V_COMPANY_NAME+"%'";		
		if(UQ_ADMIN_ID!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("UQ_ADMIN_ID")+"='"+UQ_ADMIN_ID+"'";
		if(V_COMPANY_ADDRESS_0!=null)
			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("V_COMPANY_ADDRESS_0")+" like '%"+V_COMPANY_ADDRESS_0+"%'";	
//		if(E_STATUS!=null) 
//			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("E_STATUS")+"='"+E_STATUS+"'";
		
		if(order!=null) 
			order_str = " order by u."+fieldname(order);
		else
			order_str = " order by u."+fieldname("I_ORDER_IDX");
		int totalCount = ytiotTCompanyDao.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 = ytiotTCompanyDao.query(hqlwhere, order_str, dir, Start, Limit);
			if(list.size()>0) {
				for(int i=0;i<list.size();i++) {
					YtiotTCompany o = (YtiotTCompany)list.get(i);
					Map map = new HashMap();
					int a=Integer.parseInt(o.getEStatus());
					if(a==0) {
						map.put("E_STATUS", "待开通");
					}
					if(a==1) {
						map.put("E_STATUS", "已开通");
					}
					if(a==2) {
						map.put("E_STATUS", "已锁定");
					}
					if(a==3) {
						map.put("E_STATUS", "注销");
					}
					map.put("I_ORDER_IDX", o.getIOrderIdx());
					map.put("UQ_COMPANY_ID", o.getUqCompanyId());
					map.put("V_COMPANY_NAME", o.getVCompanyName());
					map.put("V_COMPANY_CODE", o.getVCompanyCode());
					map.put("UQ_ADMIN_ID", o.getUqAdminId());
					map.put("V_COMPANY_ADDRESS_0", o.getVCompanyAddress0());
					map.put("V_COMMENT", o.getIVersion());
					map.put("I_VERSION", o.getIVersion());
//					map.put("E_STATUS", o.getEStatus());
					map.put("D_STORETIME", formatter.format(o.getDStoretime()));
					JSONObject jSONObject = JSONObject.fromObject(map);
					jSONArray.add(jSONObject);
				}
				json.put("RESULT", jSONArray);
			}
		}
		return json.toString();
	}

	@Override
	public String getCompanyVerList(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 UQ_COMPANY_ID = null;
		String V_COMPANY_NAME = null;
		String V_COMPANY_ADDRESS_0 = null;
		String E_STATUS = null;
//		String UQ_ADMIN_ID = null;
		String D_STORETIME = 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", "getCompanyVerList");
		if(queryJson!=null) {
			q_json = JSONObject.fromObject(queryJson);
			UQ_COMPANY_ID = q_json.has("UQ_COMPANY_ID")?q_json.getString("UQ_COMPANY_ID"):null;
			V_COMPANY_NAME = q_json.has("V_COMPANY_NAME")?q_json.getString("V_COMPANY_NAME"):null;
//			UQ_ADMIN_ID = q_json.has("UQ_ADMIN_ID")?q_json.getString("UQ_ADMIN_ID"):null;
			V_COMPANY_ADDRESS_0 = q_json.has("V_COMPANY_ADDRESS_0")?q_json.getString("V_COMPANY_ADDRESS_0"):null;
			E_STATUS = q_json.has("E_STATUS")?q_json.getString("E_STATUS"):null;
//			System.out.println("测试"+E_STATUS);
//			int a=Integer.parseInt("E_STATUS");