package cn.ksource.web.service.message;

import cn.ksource.beans.GG_MESSAGE;
import cn.ksource.beans.WORKFLOW_BASE;
import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.page.PageInfo;
import cn.ksource.core.util.*;
import cn.ksource.core.web.LoginUser;
import cn.ksource.core.web.WebUtil;
import cn.ksource.entity.SysMessage;
import cn.ksource.web.Constants;
import cn.ksource.web.entity.message.CmsNews;
import cn.ksource.web.service.file.FileService;
import cn.ksource.web.service.wechat.WechatService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.context.ContextLoader;
import org.springframework.web.context.request.async.DeferredResult;

import javax.annotation.Resource;
import javax.servlet.ServletContext;
import javax.servlet.http.HttpServletRequest;
import java.util.*;

@Service("messageService")
@SuppressWarnings("unchecked")
public class MessageServiceImpl implements MessageService {

	@Autowired
	private BaseDao baseDao;
	
	@Resource(name="fileService")
	private FileService fileService;
	
	@Autowired
	private WechatService wechatService;

	@Override
	public List<Map> queryMeunListById() {
		String sql = "SELECT * FROM CMS_CATEGORY WHERE USINGSTATE = 1 ORDER BY LEVEL,ORDERNUM";
		/*List<Map> list = baseDao.queryForList(sql, new HashMap());
		List<Map> yjLevel = new ArrayList();
		if(null!=list && list.size()>0) {
			for(Map m: list) {
				if(ConvertUtil.obj2StrBlank(m.get("LEVEL")).equals("1")) {
					m.put("subMenu", new ArrayList());
					yjLevel.add(m);
				} else if(ConvertUtil.obj2StrBlank(m.get("LEVEL")).equals("2")) {
					for(Map map : yjLevel) {
						if(m.get("UP_ID").equals(map.get("ID"))) {
							List listSub = (List)map.get("subMenu");
							listSub.add(m);
						}
					}
				}
			}
			System.out.println(yjLevel);
			return yjLevel;
		}*/
		List<Map> xtgnList = baseDao.queryForList(sql, new SqlParameter());
		
		List<Map> resultList = new LinkedList<Map>();
		
		Map<String, Map> yjgnCache = new HashMap<String, Map>();
		Map<String, Map> ejgnCache = new HashMap<String, Map>();
		Map<String, Map> sjgnCache = new HashMap<String, Map>();
		
		for (Map map : xtgnList) {
			
			//一级功能
			if (map.get("LEVEL").toString().equalsIgnoreCase("1")) {
				yjgnCache.put(map.get("ID").toString(), map);
				List<Map> ejgnList = new LinkedList<Map>();
				map.put("subMenu", ejgnList);
				resultList.add(map);
				continue;
			}
			if (map.get("LEVEL").toString().equalsIgnoreCase("2")) {
				Map yjgnMap = yjgnCache.get(map.get("UP_ID").toString());
				List<Map> list = (List<Map>)yjgnMap.get("subMenu");
				map.put("subMenu", new LinkedList<Map>());
				list.add(map);
				
				ejgnCache.put(map.get("ID").toString(), map);
				continue;
			}
			if (map.get("LEVEL").toString().equalsIgnoreCase("3")) {
				Map ejgnMap = ejgnCache.get(map.get("UP_ID").toString());
				List<Map> list = (List<Map>)ejgnMap.get("subMenu");
				map.put("subMenu", new LinkedList<Map>());
				list.add(map);
				sjgnCache.put(map.get("ID").toString(), map);
				continue;
			}
		}
		return resultList;
	}

	/**
	 * 通过分类id查询该分类下的信息数量
	 * @param categoryId 分类编号
	 * @return
	 */
	@Override
	public int queryMessageCountByCategoryId(String categoryId) {
		String sql = "SELECT COUNT(*) FROM CMS_NEWS WHERE CATEGORY_ID = :categoryId AND SHENPI_STATUS = 1";
		return baseDao.queryForInteger(sql, new SqlParameter().addValue("categoryId", categoryId));
	}

	/**
	 * 保存信息
	 */
	@Override
	public void saveMessage(CmsNews cmsNews,HttpServletRequest request) {
		String idSql = "SELECT MAX(ID) FROM CMS_NEWS";
		Integer idObj = baseDao.queryForInteger(idSql);
		int id = 1;
		if(null != idObj) {
			id = idObj;
		}
		String sql = "INSERT INTO CMS_NEWS(ID,CATEGORY_ID,TITLE,TITLEIMAGE,CREATE_TIME,THETOP," +
				"SUMMARY,CONTENT,THEURL,SHENPI_STATUS," +
				"ISREPORT,REPORTID,MAIN_PEOPLE,MAIN_PEOPLE_NAME,TIMEOUT,SHOOT_ID,SHOOT_NAME,SHOW_NUM) " +
					"VALUES (:id,:categoryId,:title,:titleimageurl,:createTime" +
					",:thetop,:summary,:content,:theurl,:status," +
					 "2,null,:main_people,:main_people_name,:timeout,:shoot_id,:shoot_name,:show_num)";
		Map paramMap = new HashMap();
		paramMap.put("id", id+1);
		paramMap.put("categoryId", cmsNews.getCategoryId());
		paramMap.put("title", cmsNews.getTitle());
		paramMap.put("titleimageurl", cmsNews.getTitleimageurl());
		paramMap.put("createTime", DateUtil.getCurrentDate14());
		paramMap.put("thetop", cmsNews.getThetop());
		paramMap.put("summary", cmsNews.getSummary());
		paramMap.put("content", cmsNews.getContent());
		paramMap.put("theurl", cmsNews.getTheurl());
		paramMap.put("status", cmsNews.getShenpiStatus());
		paramMap.put("main_people", cmsNews.getMainPeopleId());
		paramMap.put("main_people_name", cmsNews.getMainPeopleName());
		paramMap.put("shoot_id", cmsNews.getShoot_id());
		paramMap.put("shoot_name", cmsNews.getShoot_name());
		paramMap.put("show_num", cmsNews.getShow_num());
		int categoryId = cmsNews.getCategoryId();
		System.out.println("categoryId:"+categoryId);
		if(categoryId==10){
			String timeout = cmsNews.getTimeout();
			System.out.println("timeout:"+timeout);
			long timeoutt = Long.valueOf(timeout.replaceAll("-", ""));
			paramMap.put("timeout", timeoutt);
		}else{
			paramMap.put("timeout", null);
		}
		baseDao.execute(sql, paramMap);
		
		//上传附件
		//fileService.uploadFile(request, ConvertUtil.obj2Str(id+1));
		LoginUser loginUser = WebUtil.getLoginUser(request);
		String createUserId = String.valueOf(loginUser.getLoginUser().get("ID"));
		String createUserName = String.valueOf(loginUser.getLoginUser().get("LOGINNAME"));
		Map<String,String> params = ParamsMapUtil.getParameterMap(request);
		params.put("business_id", ConvertUtil.obj2Str(id+1));
		params.put("userId", createUserId);
		params.put("userName", createUserName);
		fileService.uploadFile(params);
	}

	/**
	 * 查询指定分类下的列表信息
	 */
	@Override
	public Map queryMessageListJson(String categoryId, int page, int pageSize) {
		StringBuilder builder = new StringBuilder("SELECT * FROM CMS_NEWS WHERE CATEGORY_ID = :categoryId AND SHENPI_STATUS=1");
		StringBuilder countBuilder = new StringBuilder("SELECT COUNT(ID) FROM CMS_NEWS WHERE CATEGORY_ID = :categoryId AND SHENPI_STATUS=1");
		Map paramMap = new HashMap();
		builder.append(" ORDER BY THETOP ASC,CREATE_TIME DESC");
	    builder.append(" LIMIT :begin,:size");
		page = page==0?1:page;
		pageSize = pageSize==0?10:pageSize;
		int begin = (page-1)*pageSize;
		paramMap.put("begin", begin);
		paramMap.put("size", pageSize);
		paramMap.put("categoryId", categoryId);
		int count = baseDao.queryForInteger(countBuilder.toString(), paramMap);
		List<Map> resultList = new ArrayList<Map>();
		if(count>0) {
			resultList = baseDao.queryForList(builder.toString(),paramMap);
			for(Map map : resultList) {
				map.put("CREATE_TIME", DateUtil.format("yyyy-MM-dd", map.get("CREATE_TIME")));
			}
		}
		Map resultMap = new HashMap();
		resultMap.put("total", count); //信息总数
		resultMap.put("rows", resultList);
		return resultMap;
	}

	/**
	 * 删除指定id的信息
	 */
	@Override
	public void deleteMessage(String id) {
		String sql = "DELETE FROM CMS_NEWS WHERE ID = :id";
		baseDao.execute(sql, new SqlParameter().addValue("id", id));
	}

	/**
	 * 通过信息id查询信息详细信息
	 */
	@Override
	public Map queryMessageById(String messageId) {
		String sql = "SELECT * FROM CMS_NEWS WHERE ID = :id";
		return baseDao.queryForMap(sql, new SqlParameter().addValue("id", messageId));
	}

	/**
	 * 修改信息内容
	 */
	@Override
	public void updateMessage(CmsNews cmsNews) {
		long updateTime = DateUtil.getCurrentDate14();
		String sql = "UPDATE CMS_NEWS SET TITLE = :title,TITLEIMAGE = :titleimageurl,UPDATE_TIME = :updateTime,THETOP = :thetop," +
				"SUMMARY = :summary,CONTENT = :content,THEURL = :theurl" +
				",MAIN_PEOPLE=:main_people,MAIN_PEOPLE_NAME=:main_people_name,TIMEOUT=:timeout,SHOOT_ID=:shoot_id,SHOOT_NAME=:shoot_name,SHOW_NUM = :show_num WHERE ID = :id";
		Map paramMap = new HashMap();
		
		paramMap.put("title", cmsNews.getTitle());
		paramMap.put("titleimageurl", cmsNews.getTitleimageurl());
		paramMap.put("updateTime", updateTime);
		paramMap.put("thetop", cmsNews.getThetop());
		paramMap.put("summary", cmsNews.getSummary());
		paramMap.put("content", cmsNews.getContent());
		paramMap.put("theurl", cmsNews.getTheurl());
		paramMap.put("main_people", cmsNews.getMainPeopleId());
		paramMap.put("main_people_name", cmsNews.getMainPeopleName());
		paramMap.put("shoot_id", cmsNews.getShoot_id());
		paramMap.put("shoot_name", cmsNews.getShoot_name());
		paramMap.put("show_num", cmsNews.getShow_num());
		if(cmsNews.getCategoryId()==10){
			String time = cmsNews.getTimeout();
			long timeout = Long.valueOf(time.replaceAll("-", ""));
			paramMap.put("timeout", timeout);
			
		}else{
			paramMap.put("timeout", null);
		}
		paramMap.put("id", cmsNews.getId());
		baseDao.execute(sql, paramMap);
		
	}

	/**
	 * 查询
	 */
	@Override
	public List queryAttachment(String messageId) {
		String sql = "SELECT * FROM CMS_ATTACHEMENTS WHERE NEWS_ID = :messageId";
		return baseDao.queryForList(sql, new SqlParameter().addValue("messageId", messageId));
	}
	
	@Override
	public boolean sendMessage(GG_MESSAGE message) {
		String msgId = message.getId();
		String selectSql = "SELECT B.ISWECHAT,B.ISPHONE,B.ISEMAIL,B.SJHM,B.EMAIL,B.OPEN_ID,B.REMIND_TYPE,B.ID AS USER_ID FROM GG_MESSAGE_RECEIVER A,GG_USER B WHERE A.RECEIVER_ID = B.ID AND B.ZT = 1 AND A.MESSAGE_ID = :msgId ";
		List<Map> msgs = baseDao.queryForList(selectSql,new SqlParameter("msgId",msgId));
		if(null!=msgs && msgs.size()>0) {
			//系统内消息推送对象
			SysMessage sysMessage = new SysMessage(message.getTitle(),message.getWeb_url());

			List<String> emails = new ArrayList<String>();
			List<String> openIds = new ArrayList<String>();
			List<String> userIds = new ArrayList<String>();
			//手机号码字符串
			String mobile = "";
			for(Map msg : msgs) {
				String userId = ConvertUtil.obj2StrBlank(msg.get("USER_ID"));
				// 推送系统内消息
				ServletContext servletContext = ContextLoader.getCurrentWebApplicationContext().getServletContext();
				Map<String,DeferredResult<SysMessage>> messageContext = (Map<String,DeferredResult<SysMessage>>)servletContext.getAttribute("messageContext");
				if (messageContext != null && !messageContext.isEmpty() && messageContext.keySet() != null) {
					System.out.println("connection size" + messageContext.size());
					for (String key : messageContext.keySet()) {
						try {
							if (key.indexOf(userId) == 0) {//需要发送
								if (messageContext.get(key) != null) {
									if (!messageContext.get(key).isSetOrExpired()) {
										messageContext.get(key).setResult(sysMessage);
									}
								}
							}
						}catch (Exception e){
							e.printStackTrace();
						}
					}

				}
				//系统内消息推送完毕
				userIds.add(userId);
				String remindType = ConvertUtil.obj2StrBlank(msg.get("REMIND_TYPE"));
				String isWechat = ConvertUtil.obj2StrBlank(msg.get("ISWECHAT"));
				if(isWechat.equals("2") && ((StringUtil.notEmpty(remindType) && remindType.substring(2, 3).equals("1"))||!StringUtil.notEmpty(remindType))) {
					openIds.add(ConvertUtil.obj2StrBlank(msg.get("OPEN_ID")));
				}

				if(StringUtil.notEmpty(remindType)) {
					String isEmail = ConvertUtil.obj2StrBlank(msg.get("ISEMAIL"));
					if(isEmail.equals("2") && remindType.substring(1, 2).equals("1")) {
						emails.add(ConvertUtil.obj2StrBlank(msg.get("EMAIL")));
					}
					
					String isPhone = ConvertUtil.obj2StrBlank(msg.get("ISPHONE"));
					if(isPhone.equals("2") && remindType.substring(0, 1).equals("1")) {
						//组装手机号码
						String telphoneNum = ConvertUtil.obj2StrBlank(msg.get("SJHM"));
						if(StringUtil.isNotBlank(telphoneNum)){
							if(mobile.equals("")){
								mobile = mobile + telphoneNum;
							}else{
								mobile = mobile + "," + telphoneNum;
							}
						}
					}
				}
				
			}
			//发送短信
			try {
				SMSUtil.sendSMS(SMSUtil.getOrderTipMsg(Constants.mapSC_MESSAGE_TYPE.get(String.valueOf(message.getType())),message.getTitle()),mobile);
			} catch (Exception e) {
				System.out.println("------------------------>发送短信异常");
			}
			
			if(emails.size()>0) {
				String[] email = (String[])emails.toArray(new String[emails.size()]);
				try {
					EmailUtil.sendEmail(email, message.getTitle(), message.getContent(), null);
				} catch (Exception e) {
					System.out.println("------------------------>发送邮件异常");
				}
			}
			
			if(openIds.size()>0) {
				String[] openId = (String[])openIds.toArray(new String[openIds.size()]);
				try {
					wechatService.sendSysMsg(openId, message);
				} catch (Exception e) {
					System.out.println("------------------------>发送微信信息异常");
				}
			}

		}
		return false;
	}
	
	/**
	 * 组装工单短信内容
	 * @param message
	 * @return
	 */
	private String assembleOrderContent(GG_MESSAGE message){
		StringBuilder content = new StringBuilder();
		content.append("【"+Constants.company_name+"】您有一条");
		content.append(Constants.mapSC_MESSAGE_TYPE.get(String.valueOf(message.getType())));
		content.append(message.getOrder_code());
		content.append("工单，标题:");
		content.append(message.getTitle());
		content.append("，请及时处理");
		return content.toString();
	}

	@Override
	public boolean sendOrderRemindersMsg(String flowId,String reminder,String text) {
		WORKFLOW_BASE base = new WORKFLOW_BASE(flowId).getInstanceById();
		//组装工单催办短信内容
		String msgContent = SMSUtil.getOrderRemindMsg(reminder, base.getOrder_code(), base.getWfname(), text);
		String title = "新的催办信息，工单编号【"+ base.getOrder_code() +"】";
		//邮箱内容
		String emailContent = "工单编号:" + base.getOrder_code() + "<br/>工单名称：" + base.getWfname();
		if(StringUtil.isNotBlank(text)){
			emailContent = emailContent +  "<br/>工单内容：" + text;
		}
		//微信内容
		String weChatContent = "工单编号:" + base.getOrder_code() + "\n\r工单名称：" + base.getWfname() ;
		if(StringUtil.isNotBlank(text)){
			weChatContent = weChatContent + "\n\r工单内容：" + text;
		}
		
		Map param = getRemindersUserInfo(flowId);
		String mobiles = param.get("mobiles").toString();
		List<String> emails = (List<String>)param.get("emails");
		List<String> openIds = (List<String>)param.get("openIds");
		
		System.out.println("mobiles-------------------"+mobiles);
		System.out.println("emails-------------------"+JsonUtil.list2Json(emails));
		System.out.println("openIds-------------------"+JsonUtil.list2Json(openIds));
		//发送短信
		if(StringUtil.isNotBlank(mobiles)){
			try {
				SMSUtil.sendSMS(msgContent,mobiles);
			} catch (Exception e) {
				e.printStackTrace();
				System.out.println("------------------------>发送短信异常");
			}
		}
		//发送email
		if(emails.size()>0) {
			String[] email = (String[])emails.toArray(new String[emails.size()]);
			try {
				EmailUtil.sendEmail(email, title, emailContent, null);
			} catch (Exception e) {
				e.printStackTrace();
				System.out.println("------------------------>发送邮件异常");
			}
		}
		
		//发送微信
		if(openIds.size()>0) {
			String[] openId = (String[])openIds.toArray(new String[openIds.size()]);
			try {
				wechatService.sendReminderTemplateMsg(openId,flowId,title,base.getBusinesstype().toString(),weChatContent,reminder,"");
			} catch (Exception e) {
				System.out.println("------------------------>发送微信信息异常");
			}
		}
		return true;
	}
	
	
	/**
	 * 获取催办用户信息
	 * @param flowId
	 * @return
	 */
	private Map getRemindersUserInfo(String flowId){
		Map param = new HashMap();
		String mobiles = "";
		List<String> emails = new ArrayList<String>();
		List<String> openIds = new ArrayList<String>();
		
		StringBuilder builder = new StringBuilder();
		builder.append(" select DEAL_TYPE,CURRENT_NODE_ID,CURRENT_DEAL_ROLEIDA from workflow_base where id=:flowId ");
		Map flowInfo = baseDao.queryForMap(builder.toString(), new SqlParameter("flowId",flowId));
		builder.setLength(0);
		List<Map> list = new ArrayList<Map>();
		String nodeType = flowInfo.get("DEAL_TYPE").toString();
		if(nodeType.equals("1")){//指定角色
			builder.append(" SELECT U.REMIND_TYPE,U.SJHM,U.OPEN_ID,U.EMAIL FROM AC_USER_REF_ROLE G,GG_USER U ");
			builder.append(" WHERE U.ID = G.YHBH AND G.JSBH = :groupId AND U.ZT=1  ");
			list = baseDao.queryForList(builder.toString(),new SqlParameter("groupId",flowInfo.get("CURRENT_DEAL_ROLEIDA")));
		}else if(nodeType.equals("2")){//指定人
			builder.append(" SELECT u.REMIND_TYPE,u.SJHM,u.OPEN_ID,u.EMAIL FROM workflow_node n,gg_user u   ");
			builder.append(" WHERE n.CURRENT_DEALER_ID = u.ID and ( ");
			builder.append(" (  ");
			builder.append(" 	n.SAME_NODE_KEY IS NULL AND n.id = :nodeId ");
			builder.append(" )  ");
			builder.append(" OR (  ");
			builder.append(" 	n.SAME_NODE_KEY IS NOT NULL  ");
			builder.append(" 	AND n.SAME_NODE_KEY = (  ");
			builder.append(" 			SELECT SAME_NODE_KEY FROM workflow_node WHERE id = :nodeId ");
			builder.append(" 		)  ");
			builder.append(" 	)  ");
			builder.append(" )  ");
			list = baseDao.queryForList(builder.toString(),new SqlParameter("nodeId",flowInfo.get("CURRENT_NODE_ID")));
		}
		
		if(list!=null&&list.size()>0){
			for(Map map:list){
				//手机
				if(map.get("REMIND_TYPE")!=null&&map.get("REMIND_TYPE").toString().substring(0, 1).equals("1")){
					if(map.get("SJHM")!=null){
						if(mobiles.equals("")){
							mobiles = map.get("SJHM").toString();
						}else{
							mobiles = mobiles + "," + map.get("SJHM").toString();
						}
					}
				}
				//邮箱
				if(map.get("REMIND_TYPE")!=null&&map.get("REMIND_TYPE").toString().substring(1, 2).equals("1")){
					if(map.get("EMAIL")!=null){
						emails.add(map.get("EMAIL").toString());
					}
				}
				//微信号
				if((map.get("REMIND_TYPE")!=null&&map.get("REMIND_TYPE").toString().substring(2, 3).equals("1"))||map.get("REMIND_TYPE")==null){
					if(map.get("OPEN_ID")!=null){
						openIds.add(map.get("OPEN_ID").toString());
					}
				}
			}
		}
		param.put("mobiles", mobiles);
		param.put("emails", emails);
		param.put("openIds", openIds);
		
		return param;
	}

	@Override
	public boolean sendNoticeMessage(GG_MESSAGE message) {
		String msgId = message.getId();
		String selectSql = "SELECT B.ISWECHAT,B.ISPHONE,B.ISEMAIL,B.SJHM,B.EMAIL,B.OPEN_ID,B.REMIND_TYPE,A.WX_URL FROM GG_MESSAGE_RECEIVER A,GG_USER B WHERE A.RECEIVER_ID = B.ID AND B.ZT = 1 AND A.MESSAGE_ID = :msgId ";
		List<Map> msgs = baseDao.queryForList(selectSql,new SqlParameter("msgId",msgId));
		if(null!=msgs && msgs.size()>0) {
			List<String> emails = new ArrayList<String>();
			List<Map> openIds = new ArrayList<Map>();
			//手机号码字符串
			String mobile = "";
			for(Map msg : msgs) {
				String isWechat = ConvertUtil.obj2StrBlank(msg.get("ISWECHAT"));
				
				String remindType = ConvertUtil.obj2StrBlank(msg.get("REMIND_TYPE"));
				
					
				if(isWechat.equals("2") && ((StringUtil.notEmpty(remindType) && remindType.substring(2, 3).equals("1"))||!StringUtil.notEmpty(remindType))) {
					String wxUrl = ConvertUtil.obj2StrBlank(msg.get("WX_URL"));
					Map map = new HashMap();
					map.put("openId", ConvertUtil.obj2StrBlank(msg.get("OPEN_ID")));
					map.put("wxUrl", wxUrl);
					openIds.add(map);
				}
					
				if(StringUtil.notEmpty(remindType)) {
					String isEmail = ConvertUtil.obj2StrBlank(msg.get("ISEMAIL"));
					if(isEmail.equals("2") && remindType.substring(1, 2).equals("1")) {
						emails.add(ConvertUtil.obj2StrBlank(msg.get("EMAIL")));
					}
					
					String isPhone = ConvertUtil.obj2StrBlank(msg.get("ISPHONE"));
					if(isPhone.equals("2") && remindType.substring(0, 1).equals("1")) {
						//组装手机号码
						String telphoneNum = ConvertUtil.obj2StrBlank(msg.get("SJHM"));
						if(StringUtil.isNotBlank(telphoneNum)){
							if(mobile.equals("")){
								mobile = mobile + telphoneNum;
							}else{
								mobile = mobile + "," + telphoneNum;
							}
						}
					}
				}
				/*String isWechat = ConvertUtil.obj2StrBlank(msg.get("ISWECHAT"));
				if(isWechat.equals("2") && ((msg.get("REMIND_TYPE")!=null && msg.get("REMIND_TYPE").toString().substring(2, 3).equals("1"))||msg.get("REMIND_TYPE")==null)) {
					String wxUrl = ConvertUtil.obj2StrBlank(msg.get("WX_URL"));
					Map map = new HashMap();
					map.put("openId", ConvertUtil.obj2StrBlank(msg.get("OPEN_ID")));
					map.put("wxUrl", wxUrl);
					openIds.add(map);
				}
				
				String isEmail = ConvertUtil.obj2StrBlank(msg.get("ISEMAIL"));
				if(isEmail.equals("2") && msg.get("REMIND_TYPE")!=null && msg.get("REMIND_TYPE").toString().substring(1, 2).equals("1")) {
					emails.add(ConvertUtil.obj2StrBlank(msg.get("EMAIL")));
				}
				
				String isPhone = ConvertUtil.obj2StrBlank(msg.get("ISPHONE"));
				if(isPhone.equals("2") && msg.get("REMIND_TYPE")!=null && msg.get("REMIND_TYPE").toString().substring(0, 1).equals("1")) {
					//组装手机号码
					String telphoneNum = ConvertUtil.obj2StrBlank(msg.get("SJHM"));
					if(StringUtil.isNotBlank(telphoneNum)){
						if(mobile.equals("")){
							mobile = mobile + telphoneNum;
						}else{
							mobile = mobile + "," + telphoneNum;
						}
					}
				}*/
			}
			//发送短信
			try {
				SMSUtil.sendSMS(SMSUtil.getOrderTipMsg(Constants.mapSC_MESSAGE_TYPE.get(String.valueOf(message.getType())),message.getTitle()),mobile);
			} catch (Exception e) {
				System.out.println("------------------------>发送短信异常");
			}
			
			if(emails.size()>0) {
				String[] email = (String[])emails.toArray(new String[emails.size()]);
				try {
					EmailUtil.sendEmail(email, message.getTitle(), message.getContent(), null);
				} catch (Exception e) {
					System.out.println("------------------------>发送邮件异常");
				}
			}
			
			if(openIds.size()>0) {
				//String[] openId = (String[])openIds.toArray(new String[openIds.size()]);
				try {
					//wechatService.sendWxMsg(openIds, message);
				} catch (Exception e) {
					System.out.println("------------------------>发送微信信息异常");
				}
			}
			
		}
		return false;
	}

	@Override
	public PageInfo getMessageData(PageInfo pageInfo, Map<String, String> params) {
		String sql = messageListSupport(params);
		return baseDao.queryforSplitPageInfo(pageInfo,sql,params);
	}

	private String messageListSupport(Map<String, String> params) {
		StringBuilder sql = new StringBuilder();
		sql.append(" select m.id,m.send_time,m.title,m.web_url,m.sender_name,r.state,r.id receiveId from gg_message m inner join gg_message_receiver r ");
		sql.append(" on m.id = r.message_Id where r.receiver_id = :userId ");
		//根据标题查找标题
		if(StringUtil.isNotBlank(params.get("title"))){
			sql.append(" and m.title like :title ");
			params.put("title","%"+ params.get("title") +"%");
		}
		//根据内容查找标题
		if(StringUtil.isNotBlank(params.get("content"))){
			sql.append(" and m.content like :content ");
			params.put("content","%"+ params.get("content") +"%");
		}
		//根据类型查找
		if(StringUtil.isNotBlank(params.get("type"))){
			sql.append(" and type = :type ");
		}
		//根据状态查找
		if(StringUtil.isNotBlank(params.get("state"))){
			sql.append(" and r.state = :state ");
		}
		sql.append(" order by m.send_time desc ");
		return sql.toString();
	}

	@Override
	public Integer getMessageCount(Map<String, String> params) {
		String sql = "select count(*) from ( " + messageListSupport(params) + " ) temp";
		return baseDao.queryForInteger(sql,params);
	}

	@Override
	public void doReadMessage(String businessId, String receiverId) {
		String sql = "update gg_message m inner join gg_message_receiver r on m.id = r.message_id set state=2, READ_TIME=:curDate where "+
				" m.BUSINESS_ID=:businessId and r.RECEIVER_ID=:receviceId";
		Long curDate = DateUtil.getCurrentDate14();
		SqlParameter param = new SqlParameter();

		param.addValue("businessId", businessId)
				.addValue("receviceId", receiverId)
				.addValue("curDate", curDate);
		baseDao.execute(sql, param);
	}


}