package cn.ksource.web.facade.uc.login;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import cn.ksource.beans.GG_MESSAGE;
import cn.ksource.beans.GG_USER;
import cn.ksource.core.CascadeMap;
import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.DateUtil;
import cn.ksource.core.util.HttpCharset;
import cn.ksource.core.util.HttpUtil;
import cn.ksource.core.util.JsonUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.core.web.PasswordEncoder;
import cn.ksource.core.web.WebUtil;
import cn.ksource.core.weixin.service.WeiXinCoreService;
import cn.ksource.web.Constants;
import cn.ksource.web.controller.wechat.util.WechatConstants;
import cn.ksource.web.facade.message.MessageFacade;

@Service("ucFacade")
public class UcFacadeImpl implements UcFacade {
	
	@Autowired
	private BaseDao baseDao;
	
	@Autowired
	private MessageFacade messageFacade;
	@Autowired
	private WeiXinCoreService weiXinCoreService;

	@Override
	public String updateUserPwd(String userId, String newPassword) {
		Map map = new HashMap();
		if(!(StringUtil.notEmpty(newPassword)&&StringUtil.isPasswordReg(newPassword))) {
			map.put("status", "0");
			map.put("msg", "密码由6-18位的字母,数字,下划线组成");
			return JsonUtil.map2Json(map);
		}
		newPassword = newPassword.trim();
		String sql = "SELECT * FROM CUSTOMER_CONTACTS WHERE ID = :userId ";
		Map userMap = baseDao.queryForMap(sql,new SqlParameter("userId",userId));
		if(PasswordEncoder.encode(newPassword).equals(userMap.get("PASSWORD"))) {
			map.put("status", "0");
			map.put("msg", "新密码和原密码一样！");
			return JsonUtil.map2Json(map);
		}
		String updateSql = "UPDATE CUSTOMER_CONTACTS SET PASSWORD = :newPassword WHERE ID = :userId";
		baseDao.execute(updateSql, new SqlParameter("newPassword",PasswordEncoder.encode(newPassword)).addValue("userId", userId));
		map.put("status", "1");
		return JsonUtil.map2Json(map);
	}
	
	@Override
	public String updateUserMobile(String userId, String mobile) {
		
		String sql = "UPDATE CUSTOMER_CONTACTS SET MOBILE = :phone,ISPHONE = 2 WHERE ID = :userId";
		baseDao.execute(sql, new SqlParameter("phone",mobile).addValue("userId", userId));
		
		return "1";
	}

	@Override
	public boolean isPhone(String userId, String mobile) {
		String selectSql = "SELECT COUNT(1) FROM CUSTOMER_CONTACTS WHERE ID = :userId AND MOBILE = :phone AND ISPHONE = 2";
		Integer count = baseDao.queryForInteger(selectSql,new SqlParameter("userId",userId).addValue("phone", mobile));
		if(count>0){
			return false;
		}else{
			return true;
		}
	}

	@Override
	public boolean isEmail(String userId, String email) {
		String selectSql = "SELECT COUNT(1) FROM CUSTOMER_CONTACTS WHERE EMAIL = :email AND ISEMAIL = 2";
		Integer count = baseDao.queryForInteger(selectSql,new SqlParameter("email", email));
		if(count>0){
			return false;
		}else{
			return true;
		}
	}

	@Override
	public String updateUserEmail(String userId, String email) {
		String sql = "UPDATE CUSTOMER_CONTACTS SET EMAIL = :email,ISEMAIL = 2 WHERE ID = :userId";
		baseDao.execute(sql, new SqlParameter("email",email).addValue("userId", userId));
		
		return "1";
	}
	
	@Override
	public String updateUserOldPwd(String userId, String oldPassword,String newPassword) {
		Map map = new HashMap();
		if(!(StringUtil.notEmpty(newPassword)&&StringUtil.isPasswordReg(newPassword)&&StringUtil.notEmpty(oldPassword)&&StringUtil.isPasswordReg(oldPassword))) {
			map.put("status", "0");
			map.put("msg", "密码由6-18位的字母,数字,下划线组成");
			return JsonUtil.map2Json(map);
		}
		oldPassword = oldPassword.trim();
		newPassword = newPassword.trim();
		String sql = "SELECT COUNT(ID) FROM CUSTOMER_CONTACTS WHERE ID = :userId AND PASSWORD = :password";
		int count = baseDao.queryForInteger(sql,new SqlParameter("userId",userId).addValue("password", PasswordEncoder.encode(oldPassword)));
		if(count == 0) {
			map.put("status", "0");
			map.put("msg", "原密码输入错误！");
			return JsonUtil.map2Json(map);
		}
		String updateSql = "UPDATE CUSTOMER_CONTACTS SET PASSWORD = :newPassword WHERE ID = :userId";
		baseDao.execute(updateSql, new SqlParameter("newPassword",PasswordEncoder.encode(newPassword)).addValue("userId", userId));
		map.put("status", "1");
		return JsonUtil.map2Json(map);
	}

	@Override
	public Map getCusMsgByCusId(String customer_Id) {
		String sql = "SELECT A.CUSTOMER_NAME,A.YWJL_NAME,A.VALID_BEGIN_DATE,A.VALID_END_DATE,A.YWJL_ID FROM SC_PARTNER_CUSTOMER_INFO A,CUSTOMER_CONTACTS B WHERE B.CUSTOMER_ID = A.ID AND A.ID = :id ";
		Map proMap = baseDao.queryForMap(sql, new SqlParameter("id",customer_Id));
		proMap.put("VALID_BEGIN_DATE", DateUtil.format("yyyy-MM-dd", proMap.get("VALID_BEGIN_DATE")));
		proMap.put("VALID_END_DATE", DateUtil.format("yyyy-MM-dd", proMap.get("VALID_END_DATE")));
		String id=ConvertUtil.obj2StrBlank(proMap.get("YWJL_ID"));
		if(StringUtil.notEmpty(id)){
			GG_USER user=new GG_USER(id).getInstanceById();
			proMap.put("PHONE", user.getSjhm());
		}
		return proMap;
	}

	@Override
	public String getCusSatisByCusId(String customer_Id) {
		String sql = "SELECT ALL_SCORE FROM TOTLE_SATIS_INFO WHERE CUSTOMER_ID = :customer_Id AND MONTH = :month ";
		Map param = new HashMap();
		param.put("customer_Id", customer_Id);
		param.put("month", DateUtil.getMonthAdd("yyyyMM", -1));
		
		return baseDao.queryForString(sql, param);
	}

	@Override
	public int getZcUserByCusId(String customer_Id) {
		Map param = new HashMap();
		param.put("customer_Id", customer_Id);
		String sqluser="SELECT COUNT(a.ID) FROM SC_CUSTOMER_ZC_UESR a,GG_USER b,AC_ROLE c,AC_USER_REF_ROLE d WHERE a.CUSTOMER_ID = :customer_Id and a.USER_ID=b.ID and b.ID=D.YHBH and c.ID=D.JSBH and c.IDENTIFY='LOCATION' and b.ZT=1  ";
		String sqlSubuser="SELECT COUNT(e.ID) FROM SC_PARTNER_CUSTOMER_SUB e,SC_CUSTOMER_ZC_UESR a,GG_USER b,AC_ROLE c,AC_USER_REF_ROLE d WHERE e.CUSTOMER_ID = :customer_Id AND a.ID = e.CUSTOMER_ID and a.USER_ID=b.ID and b.ID=D.YHBH and c.ID=D.JSBH and c.IDENTIFY='LOCATION' and b.ZT=1 ";
		int usernum = baseDao.queryForInteger(sqluser, param);
		int usersubnum = baseDao.queryForInteger(sqlSubuser, param);
		
		return usernum+usersubnum;
	}

	@Override
	public List<Map> getOrderNumByCusId(String customer_Id) {
		String sql = "SELECT BUSINESSTYPE ,COUNT(ID) AS NUM FROM WORKFLOW_BASE WHERE CUSTOMER_ID = :customer_Id GROUP BY BUSINESSTYPE ";
		return baseDao.queryForList(sql, new SqlParameter("customer_Id",customer_Id));
	}

	@Override
	public List<Map> getOrderListByCusId(String customer_Id, int i) {
		String sql = "SELECT * FROM WORKFLOW_BASE WHERE WFSTATE != :ysc AND CUSTOMER_ID = :customer_Id ORDER BY CREATETIME DESC LIMIT 0,:size ";
		Map param = new HashMap();
		param.put("customer_Id", customer_Id);
		param.put("size", i);
		param.put("ysc", Constants.WORKFLOW_BASE_WFSTATE_DELETE);
		return baseDao.queryForList(sql, param);
	}

	@Override
	public int getZcxjCount(String customer_Id) {
		StringBuilder sql = new StringBuilder();
		sql.append(" select count(ID)  from CI_DAILY_PATROL where CUS_ID=:customer_Id ");
		return baseDao.queryForInteger(sql.toString(), new SqlParameter("customer_Id",customer_Id));
	}

	@Override
	public int getUserByRole(String rolemark) {
		String sql = "SELECT COUNT(C.ID) FROM AC_ROLE A,AC_USER_REF_ROLE B,GG_USER C WHERE A.ID = B.JSBH AND B.YHBH = C.ID AND A.IDENTIFY = :rolemark AND C.ZT = 1 ";
		return baseDao.queryForInteger(sql, new SqlParameter("rolemark",rolemark));
	}

	@Override
	public int getUserByPwd(String userId, String pwd) {
		String sql = "SELECT COUNT(ID) FROM CUSTOMER_CONTACTS WHERE ID = :userId AND PASSWORD = :password";
		int count = baseDao.queryForInteger(sql,new SqlParameter("userId",userId).addValue("password", PasswordEncoder.encode(pwd)));
	    return count;
	}

	@SuppressWarnings({ "unchecked", "rawtypes" })
	@Override
	public void doSubRepair(Map<String, String> params) {
		StringBuilder sql = new StringBuilder();
		sql.append(" insert into repair_record (id,create_id,create_name,status,create_time,cus_id,bx_title,bx_content,lx_phone)   ");
		sql.append(" values (:id,:userId,:userName,:status,:create_time,:cusId,:bx_title,:bx_content,:lx_phone)   ");
		params.put("id", StringUtil.getUUID());
		params.put("create_time", DateUtil.getCurrentDate14().toString());
		params.put("status", Constants.REPAIR_STATE_DXY.toString());
		baseDao.execute(sql.toString(), params);
		params.put("SERVICE", "SERVICE");
		String sqla="SELECT id FROM AC_ROLE where IDENTIFY=:SERVICE";
		String id=baseDao.queryForString(sqla, params);
		sqla="select OPEN_ID from gg_user a,AC_USER_REF_ROLE b where a.id=b.yhbh and a.zt=1 and b.jsbh=:id";
		params.put("id", id);
		List<Map> list=baseDao.queryForList(sqla, params);
		String openIds="";
		if(list!=null && list.size()>0){
			for(Map map:list){
				if(StringUtil.notEmpty(ConvertUtil.obj2Str(map.get("OPEN_ID")))){
					openIds+=ConvertUtil.obj2Str(map.get("OPEN_ID"))+",";
				}
			}
		}
		String[] openId=openIds.split(",");
		//发送微信消息
		String token = weiXinCoreService.getAccess_token();
		System.out.println("token---------------------->"+token);
		String url = WechatConstants.SEND_TEMPLATE_MSG + token;
		String title="";
		String userName="";
		if(StringUtil.notEmpty(ConvertUtil.obj2Str(params.get("userName")))){
			userName="报修人-"+ConvertUtil.obj2Str(params.get("userName"));
		}else{
			userName="报修人-"+ConvertUtil.obj2Str(params.get("lxr"));
		}
		String content=params.get("bx_content");
//		if(null!=openId && openId.length>0) {
//			Map result = new HashMap();
//			result.put("template_id", WechatConstants.REMINDER_TEMP_ID);
//			result.put("topcolor", "#FF0000");
//			if(!StringUtil.notEmpty(title)) {
//				title = "您有新的报修事件";
//			}
//			String content=params.get("bx_content");
//			Map data = new HashMap();
//			result.put("data", data);
//			data.put("first", new CascadeMap("value",title).put("color", "#173177"));
//			data.put("keyword1", new CascadeMap("value",content).put("color", "#173177"));
//			data.put("keyword2", new CascadeMap("value",userName).put("color", "#173177"));
//			data.put("keyword3", new CascadeMap("value",DateUtil.getToday("yyyy-MM-dd HH:mm:ss")).put("color", "#173177"));
//			data.put("remark", new CascadeMap("value","请及时处理").put("color", "#173177"));
//			for(String str : openId) {
//				result.put("url", "");
//				result.put("touser", str);
//				String json = JsonUtil.map2Json(result);
//				HttpUtil.doPost(url, json, HttpCharset.UTF8);
//			}
//		}
		
		
		if(null!=openId && openId.length>0) {
			Map result = new HashMap();
			result.put("template_id", WechatConstants.NEW_ORDER_TEMP_ID);
			
			String orderDetailUrl = "";
			if(!StringUtil.notEmpty(title)) {
				title = "您有新的报修事件";
			}
			result.put("topcolor", "#FF0000");
			Map data = new HashMap();
			result.put("data", data);
			data.put("first", new CascadeMap("value",title).put("color", "#173177"));
			data.put("keyword1", new CascadeMap("value",content).put("color", "#173177"));
			data.put("keyword2", new CascadeMap("value",userName).put("color", "#173177"));
			data.put("keyword3", new CascadeMap("value",DateUtil.format("yyyy-MM-dd HH:mm:ss", DateUtil.getCurrentDate14())).put("color", "#173177"));
			data.put("remark", new CascadeMap("value","").put("color", "#173177"));
			
			String baseWxUrl = "";
			for(String str : openId) {
				result.put("touser", str);
				result.put("url", WechatConstants.BASE_ADDRESS+"/ewyw/ewrepair/ewrepairPool.html"+"?openId="+str);
				String json = JsonUtil.map2Json(result);
				//开始发送数据信息
				System.out.println("url------------------->"+url);
				System.out.println("json------------------->"+json);
				
				
				HttpUtil.doPost(url, json, HttpCharset.UTF8);
			}
		}
		
		
	}
}