package org.theyeasy.weixin.service.impl;

import java.lang.reflect.Method;
import java.math.BigDecimal;
import java.net.URLEncoder;
import java.util.Collections;
import java.util.Comparator;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.lang3.RandomUtils;
import org.joda.time.DateTime;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.testng.util.Strings;
import org.theyeasy.weixin.model.BaseMessage;
import org.theyeasy.weixin.service.WxMiniService;
import org.theyeasy.weixin.service.WxOpenService;
import org.theyeasy.weixin.service.WxPayService;
import org.theyeasy.weixin.util.ActivitySettingUtils;
import org.theyeasy.weixin.util.WxMessageUtil;
import org.theyeasy.weixin.util.WxMiniUtil;
import org.theyeasy.weixin.util.WxMpUtil;

import com.w1hd.zzhnc.dao.AutoreplyDao;
import com.w1hd.zzhnc.dao.FansDao;
import com.w1hd.zzhnc.dao.LotteryLogDao;
import com.w1hd.zzhnc.enums.ActivityStatus;
import com.w1hd.zzhnc.enums.ChatLogReplyType;
import com.w1hd.zzhnc.model.Activity;
import com.w1hd.zzhnc.model.Autoreply;
import com.w1hd.zzhnc.model.Chatlog;
import com.w1hd.zzhnc.model.Fans;
import com.w1hd.zzhnc.model.Lotterylog;
import com.w1hd.zzhnc.model.Prize;
import com.w1hd.zzhnc.service.ActivityService;
import com.w1hd.zzhnc.service.AutoreplyService;
import com.w1hd.zzhnc.service.ChatLogService;
import com.w1hd.zzhnc.service.FansService;
import com.w1hd.zzhnc.service.PrizeService;
import com.w1hd.zzhnc.util.CommonUtil;
import com.w1hd.zzhnc.util.JsonMapper;
import com.w1hd.zzhnc.util.QQFaceUtil;
import com.w1hd.zzhnc.util.RedisUtil;
import com.w1hd.zzhnc.vo.Vo_msg;

import me.chanjar.weixin.common.api.WxConsts;
import me.chanjar.weixin.common.exception.WxErrorException;
import tk.mybatis.mapper.entity.Example;
import tk.mybatis.mapper.entity.Example.Criteria;

@Service
public class WxMiniServiceImpl implements WxMiniService {

	@Autowired
	WxOpenService wxOpenService;

	@Autowired
	FansService fansService;

	@Autowired
	ChatLogService chatLogService;

	@Autowired
	AutoreplyService AutoreplyService;

	@Autowired
	ActivityService activityService;

	@Autowired
	LotteryLogDao lotteryLogDao;

	@Autowired
	AutoreplyDao autoreplyDao;

	@Autowired
	FansDao fansDao;

	@Autowired
	WxPayService wxPayService;
	@Autowired
	PrizeService prizeService;

	@Override
	public String processRequest(HttpServletRequest request) {
		String respMessage = "success";
		Boolean copyToWxkf = true;
		try {
			// xml请求解析
			Map<String, String> requestMap = WxMessageUtil.parseXml(request);
			System.out.println("进入WxMiniUtil.processRequest,requestMap:" + requestMap);
			// 发送方帐号（open_id）
			String fromUserName = requestMap.get("FromUserName");
			// 公众帐号
			String toUserName = requestMap.get("ToUserName");
			// 消息类型
			String msgType = requestMap.get("MsgType");
			// 消息ID
			String msgId = requestMap.get("MsgId");
			// 消息时间
			String msgTime = requestMap.get("CreateTime");

			String key = "WxMiniMsgKey_";
			key += fromUserName + msgTime;

			long j = RedisUtil.setNX(key, "0");
			if (j == 0) {
				System.out.println("重复的wxWxMiniMsg,直接返回succes. key=" + key);
				return "success"; // 重复消息
			} else {
				RedisUtil.set(key, "0", 60 * 5);
			}

			Fans fans = fansService.getFansByMiniOpenid(fromUserName);
			if (fans == null) {
				fans = fansService.addFans(fromUserName);
				System.out.println("会话事件中添加了粉丝,id=" + fans.getId());
			}
			int goodsId = fans.getGoodsId();

			String sendResult = "";//

			if (msgType.equals(WxMessageUtil.REQ_MESSAGE_TYPE_TEXT)) {
				String content = requestMap.get("Content").trim(); // 用户发送的内容
				content = QQFaceUtil.regix(content);

				Activity activitySetting = activityService.getActivitySetting();
				if (activitySetting != null && activitySetting.getStatus() > ActivityStatus.UNSTART.getIndex()) {
					String[] keywords = activitySetting.getKeyword().split("\\|");
					boolean containKeyword = false;
					for (String keyword : keywords) {
						if (content.contains(keyword)) {
							containKeyword = true;
							break;
						}
					}

					BigDecimal currentMny = activitySetting.getCurrentMny();
					int compareTo = 0;
					if (currentMny != null) {
						compareTo = activitySetting.getPlanMny().compareTo(activitySetting.getCurrentMny());
					}

					if (containKeyword && (activitySetting.getStatus() > 2 || compareTo < 0)) {
						WxMiniUtil.sendCustomMsgText(fromUserName, activitySetting.getFinishReply());
						saveChatLog(fans.getId(), content, activitySetting.getFinishReply(), fans.getGoodsId(),
								ChatLogReplyType.自动回复, "", "");
						return respMessage;
					}

					// 抽奖活动进行中
					if (!Strings.isNullOrEmpty(activitySetting.getKeyword()) && containKeyword
							&& activitySetting.getStatus() == 2) {
						boolean sussess = false;

						// 指定城市范围
						String city = activitySetting.getCity();
						// 粉丝城市
						String fansCity = fans.getProvince();
						if (Strings.isNullOrEmpty(city) || Strings.isNullOrEmpty(fansCity)
								|| !fansCity.startsWith(city)) {
							if (null == fansCity || fansCity == "null" || fansCity.length() < 1)
								fansCity = "未授权";
							String msg = "红包活动仅限【" + city + "】,您的省份【" + fansCity + "】不在本次活动范围内,不能参与抽奖哦~~/玫瑰/玫瑰";
							WxMiniUtil.sendCustomMsgText(fromUserName, msg);
							saveChatLog(fans.getId(), content, msg, fans.getGoodsId(), ChatLogReplyType.自动回复, "", "");
							return respMessage;
						}

						WxMiniUtil.sendCustomMsgText(fromUserName, activitySetting.getReplyWait());
						saveChatLog(fans.getId(), content, activitySetting.getReplyWait(), fans.getGoodsId(),
								ChatLogReplyType.自动回复, "", "");

						Thread.sleep(1000);
						Prize temp = null;
						Lotterylog log = null;
						/** 执行抽奖核心 */
						fansService.getCountParentFansId(fans.getId());
						int fansCount = fansService.getCountParentFansId(fans.getId());
						if (fansCount == activitySetting.getShareCount()) {
							Integer randomKill = prizeService.randomKill(fans.getId(), 0);
							if(randomKill<1) {
								RedisUtil.remove("PRIZE_KILL_FANSID_" + fans.getId());
								Integer kill = prizeService.randomKill(fans.getId(), 0);
								if (kill > 0) {
									log = prizeService.getLog(kill);
									Method method = activitySetting.getClass().getMethod("getP" + log.getPrizeId());
									temp = (Prize) method.invoke(activitySetting, null);
								}	
							}
						}

						Vo_msg msg = new Vo_msg(-1, null, "未知错误.");
						int mny = 0;
						if (sussess && temp!=null && temp.getIsMoney()) {
							mny = (int) log.getMny().doubleValue() * 100;
							msg = wxPayService.payMoney("pay" + DateTime.now().getMillis(), fromUserName, mny,
									"来自【华南城的】的红包奖励");
							sussess = (msg.code == 0);
							activityService.updateActivity(activitySetting);
							activityService.addLotteryLog(fans.getId(), new BigDecimal(mny * 0.01), sussess == true ? 1 : 0,
									activitySetting.getTurn(), temp.getName());

						} 
						
						if (sussess) { // 已中奖
							if (temp.getIsMoney()) {
								RedisUtil.set("zzhnc_lottery_fansid_" + fans.getId(), "1", 10 * 60);
								// 发送中奖提示语
								WxMiniUtil.sendCustomMsgText(fromUserName, activitySetting.getReplySucceed());
								saveChatLog(fans.getId(), content, activitySetting.getReplySucceed(), fans.getGoodsId(),
										ChatLogReplyType.自动回复, "", "");
								// 推送中奖链接
								String url = "http://mini.weiyisz.com/zzhnc/wx/redpackage?mny=" + mny * 0.01;
								WxMiniUtil.sendCustomMsgLink(fromUserName, activitySetting.getLotteryTitle(),
										activitySetting.getLotterySubTitle(), url,
										"http://mini.weiyisz.com/zzhnc/res/images/redpackage.png");
							}else {
								WxMiniUtil.sendCustomMsgText(fromUserName,"恭喜获得["+temp.getName() +"] 请到【我的奖品出兑换奖品】");
								saveChatLog(fans.getId(), content, activitySetting.getReplySucceed(), fans.getGoodsId(),
										ChatLogReplyType.自动回复, "", "");
							}

							return respMessage;
						} else { // 未中奖
							// 发送未中奖提示语
							String failedReply = activitySetting.getUnLotteryReply(); // 第一次和第二次未中奖的提示语有区别
							WxMiniUtil.sendCustomMsgText(fromUserName, failedReply);
							saveChatLog(fans.getId(), content, failedReply, fans.getGoodsId(), ChatLogReplyType.自动回复,
									"", "");
							return respMessage;
						}
					}
				}

				String faces = WxMiniUtil.sponseQqFace(content);
				if (faces.startsWith("[") && faces.endsWith("]"))
					faces = faces.substring(1, faces.length() - 1);
				if (faces.length() > 0) {
					WxMiniUtil.sendCustomMsgText(fromUserName, faces);
					saveChatLog(fans.getId(), content, faces, goodsId, ChatLogReplyType.自动回复, "", "");
					return respMessage;
				}

				HashMap<Object, Object> data = AutoreplyService.autoreply(content, cache(toUserName), fromUserName);
				Autoreply auto = (Autoreply) data.get("autoreply");

				// 判断是否需要发送小程序卡片 add by lcc 2017-12-11
				if (auto.getContents().startsWith("【发送小程序卡片】")) {
					Vo_msg vo = SendMiniProgram(fromUserName);
					System.out.println("发送小程序卡片:" + vo.msg);
					return respMessage;
				}
				WxMiniUtil.sendCustomMsgText(fromUserName, auto.getContents());
				saveChatLog(fans.getId(), content, auto.getContents(), goodsId,
						Integer.parseInt(data.get("type").toString()) == 2 ? ChatLogReplyType.自动回复
								: ChatLogReplyType.机器人,
						"", "");

				return respMessage;

			} else if (msgType.equals(WxMessageUtil.REQ_MESSAGE_TYPE_IMAGE)) {// 图片消息

				String fansImgUrl = requestMap.get("PicUrl");
				String imgReply = getImgReply();
				WxMiniUtil.sendCustomMsgText(fromUserName, imgReply);// 还没办法自动回复图片
				saveChatLog(fans.getId(), "", imgReply, goodsId, ChatLogReplyType.机器人, fansImgUrl, "");

			} else if (msgType.equals(WxMessageUtil.REQ_MESSAGE_TYPE_LOCATION)) {// 地理位置消息
			} else if (msgType.equals(WxMessageUtil.REQ_MESSAGE_TYPE_LINK)) {// 链接消息
			} else if (msgType.equals(WxMessageUtil.RESP_MESSAGE_TYPE_MUSIC)) {// 音频消息
			} else if (msgType.equals(WxMessageUtil.REQ_MESSAGE_TYPE_VOICE)) {// 音频消息
			} else if (msgType.equals(WxMessageUtil.REQ_MESSAGE_TYPE_EVENT)) {// 事件推送
				String eventType = requestMap.get("Event");// 事件类型,未使用
				if (eventType.equals("user_enter_tempsession")) // 用户在小程序进入客服面板
				{
					// 保存进入会话时传入的参数
					String sessionFrom = requestMap.get("SessionFrom");
					cache(fromUserName, getSessionFromValue(sessionFrom, 0));
					String floorname = getSessionFromValue(sessionFrom, 1);// 楼盘名称

					// 保存粉丝最后一次进入会话的时间
					boolean firstEnter = (fans.getLastEnterTime() == null);
					fans.setLastEnterTime(DateTime.now().toDate());
					fansDao.updateByPrimaryKey(fans);

					// 发送欢迎语
					String welcome = getWelcome(firstEnter);
					if (firstEnter) {
						// 如果红包活动正在进行中，发送红包活动的提醒文字
						Activity activitySetting = activityService.getActivitySetting();
						if (activitySetting != null
								&& activitySetting.getStatus() == ActivityStatus.RUNNING.getIndex()) {
							welcome = activitySetting.getReplyWelcome();
						}
					}

					sendResult = WxMiniUtil.sendCustomMsgText(fromUserName, welcome);

					saveChatLog(fans.getId(), "进入会话:" + floorname, welcome, fans.getGoodsId(), ChatLogReplyType.进入会话,
							"", "");
				}
				copyToWxkf = false; // 事件不要转发给客服系统。
			}

			System.out.print("WxMiniMsg.sendResult=" + sendResult);
			// 以下处理回复给微信服务器的消息
			if (copyToWxkf) // 将用户发送的消息自动转发给微信的官方客服系统。
			{
				BaseMessage msg = new BaseMessage();
				msg.setToUserName(fromUserName);
				msg.setFromUserName(toUserName); // 开发者微信号
				msg.setCreateTime(new Date().getTime());
				msg.setMsgType("transfer_customer_service");
				respMessage = WxMessageUtil.messageToXml(msg);
			} else {
				respMessage = "success"; // 不希望微信作处理里回复success，微信收不到响应会重复5次推送消息。
			}
		} catch (Exception e) {
			e.printStackTrace();
		}

		return respMessage;
	}

	/**
	 * 是否需要给销售或万小二发送模板消息通知
	 */
	@Override
	public boolean needNotifySales(String fansMsg) {
		String keywordsRegex = "有人吗|人工|客服|在吗|没人吗|有人不?|有人么|在不在?|找人工|找客服|客服在不在|有真人吗|有活人";
		Pattern p = Pattern.compile(keywordsRegex);
		Matcher m = p.matcher(fansMsg);
		return m.find();
	}

	// 发送模板消息给销售或万小二
	public Boolean SendTemplateToSale(String openId, String custMsg, Fans fromFans) {
		System.out.println("SendTemplateToSale");

		if (fromFans.getGoodsId() == 0) // 粉丝未绑定销售时，在此绑定对应销售(实际只在分配万小二时起作用) edit by lcc 2017-12-10
		{
			fansDao.updateByPrimaryKeySelective(fromFans);
		}

		String fansName = fromFans.getNickname();
		if (null == fansName || fansName.equals(""))
			fansName = "粉丝(id:" + fromFans.getId() + ")";
		String url = "http://www.baidu.com";

		try {
			String newurl = wxOpenService.getWxMpService(RedisUtil.getMpAppid()).oauth2buildAuthorizationUrl(url,
					WxConsts.OAUTH2_SCOPE_BASE, URLEncoder.encode(fromFans.getMiniopenid()));
			WxMpUtil.SendTemplate_Vanker(openId, custMsg, fansName, "无", DateTime.now().toString(), newurl);
			// 更新粉丝的最后触发时间
			fromFans.setLastAskMsg(custMsg);
			fromFans.setLastAskTime(DateTime.now().toDate());
			fromFans.setReaded(false);
			fansDao.updateByPrimaryKey(fromFans);
			return true;
		} catch (WxErrorException e) {
			e.printStackTrace();
		}
		return false;
	}

	@Override
	public String sendCustMsgIdentify(String wxMiniOpenId, String info) {
		String url = "http://mini.weiyisz.com/zzhnc/wx/regist";

		try {
			String newurl = wxOpenService.getWxMpService(RedisUtil.getMpAppid()).oauth2buildAuthorizationUrl(url,
					WxConsts.OAUTH2_SCOPE_BASE, URLEncoder.encode(wxMiniOpenId));
			System.out.println("绑定销售身份的链接：" + newurl);
			String sendResult = WxMiniUtil.sendCustomMsgLink(wxMiniOpenId, info, "请点击打开页面，再输入手机号进行万小二销售人员的身份绑定。",
					newurl, "http://mini.weiyisz.com/zzhnc/res/images/confirm.jpg");
			return sendResult;
		} catch (WxErrorException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return "";
	}

	@Override
	public String sendLogin(int saleid, String wxMiniOpenId, String info) {
		String url = "http://mini.weiyisz.com/wx/chatListView?salesId=" + saleid;

		try {
			String newurl = wxOpenService.getWxMpService(RedisUtil.getMpAppid()).oauth2buildAuthorizationUrl(url,
					WxConsts.OAUTH2_SCOPE_BASE, "");
			System.out.println("推送万小二销售的登录链接：" + newurl);
			String sendResult = WxMiniUtil.sendCustomMsgLink(wxMiniOpenId, info, "点击登录到客服面板", newurl,
					"http://mini.weiyisz.com/zzhnc/res/images/confirm.jpg");
			return sendResult;
		} catch (WxErrorException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return "";
	}

	public boolean sendRedBack(int fansId, String fromUserName, String titile, String subTitle, int mny) {

		/** 正式的 */
		String merchatId = "199";
		String activityId = "1291";

		String sendGet = CommonUtil.sendGet("http://www.w1hd.com/api/wx/createOrder",
				"merchantid=" + merchatId + "&wxactivityId=" + activityId + "&mny=" + mny);

		Object fromJsonString = JsonMapper.fromJsonString(sendGet, Map.class);
		Map<String, Object> map = (Map<String, Object>) JsonMapper.fromJsonString(sendGet, Map.class);
		System.out.println("订单生成请求结果：" + sendGet);

		if (!map.get("code").equals(0) || !map.containsKey("data")) {
			return false;
		}

		String url = getAuthorizeUrl(map.get("data").toString(), activityId, fansId);

		WxMiniUtil.sendCustomMsgLink(fromUserName, titile, subTitle, url,
				"http://mini.weiyisz.com/zzhnc/res/images/redpackage.png");

		return true;
	}

	@Override
	public String getRandomReplyAfterNotify() {
		String allMsg = "亲,你的消息我已经转发给人工客服了,你不会是想要找客服投诉我吧/流泪|亲/玫瑰,伦家已经帮您通知人工客服啦...|哎哟,客服的哥哥姐姐怎么还不来/抓狂,我再催催/左太极/左太极|/西瓜/西瓜/西瓜,再跟小二聊会嘛,客服收到通知啦啦 ...|客服里有大美女哦../色/色 |你的问题太深奥啦啦 ，我去通知客服姐姐来/咖啡/咖啡";

		// 从autoReply表获取回复内容
		Example example = new Example(Autoreply.class);
		Criteria criteria = example.createCriteria();
		criteria.andEqualTo("keywords", "reply_when_notify_sales").andEqualTo("deleted", false);
		List<Autoreply> list = autoreplyDao.selectByExample(example);
		if (null != list && list.size() > 0) {
			allMsg = list.get(0).getContents();
		}

		String[] randomMsg = allMsg.split("\\|");
		int index = WxMiniUtil.getRandom(randomMsg.length);
		return randomMsg[index];
	}

	@Override
	public int saveChatLog(int fansid, String ask, String reply, int salesid, ChatLogReplyType replyType,
			String fansImgUrl, String replyImgurl) {
		Chatlog log = new Chatlog();

		log.setFansid(fansid);
		log.setAsk(ask);
		log.setReply(reply);
		log.setAsktime(new Date());
		log.setNoticetime(new Date());
		log.setSalesid(salesid);
		log.setVankerid(0);
		log.setReplytime(new Date());
		log.setAskfrom(1);
		log.setReplytype(replyType.getIndex());
		log.setReaded(false);
		log.setImgurl(fansImgUrl);
		log.setImgurl2(replyImgurl);

		return 1;
	}

	@Override
	public String getLastReply() {
		String allMsg = "你难住我了。。。/难过/大哭|世界那么大,我要出去走走/奋斗/奋斗/奋斗|....|今天天气真好呀!/呲牙/呲牙|让我想想.../阴险|我要提高下智商了/拳头/拳头/拳头|/抠鼻|/睡着|/睡着/睡着|skdfiqwkmqwemlqwdkl 哎呀，碰到键盘了。。。";
		String[] randomMsg = allMsg.split("\\|");
		int index = WxMiniUtil.getRandom(randomMsg.length);
		return randomMsg[index];
	}

	@Override
	public String getImgReply() {
		String reply = WxMiniUtil.getQQFace();

		return reply;
	}

	@Override
	public String getWelcome(boolean firstEnter) {
		String keyword = firstEnter ? "first_enter_session" : "second_enter_session";
		String reply = RedisUtil.get(keyword);
		if (null == reply || reply.length() < 1) // redis中没有欢迎语
		{
			Example example = new Example(Autoreply.class);
			Criteria criteria = example.createCriteria();
			criteria.andEqualTo("keywords", keyword).andEqualTo("deleted", false);
			List<Autoreply> list = autoreplyDao.selectByExample(example);
			if (null != list && list.size() > 0) {
				reply = list.get(0).getContents();
				RedisUtil.set(keyword, reply, 60 * 5); // 在redis内存中保留5分钟
			}
		}

		if (null == reply)
			return "";

		String[] randomMsg = reply.split("\\|");
		int index = WxMiniUtil.getRandom(randomMsg.length);

		return randomMsg[index];
	}

	@Override
	public String getSessionFromValue(String sessionFrom, int index) {
		// sessfrom的格式为:floorid:0,floorname:万科·珠江东岸,saleId:228

		if (sessionFrom == null)
			return "";

		String[] values = sessionFrom.split(",");
		System.out.println("values.length=" + values.length + " index=" + index);
		if (index >= values.length)
			return "";

		String[] kv = values[index].split(":");
		return kv.length == 2 ? kv[1] : "";
	}

	/**
	 * 发送模板消息给销售,如果saleid为0则发给所有万小二。
	 */
	@Override
	public void nofitySalesIncludeVanker(int saleid, String content, Fans fans) {
	}

	// 发送小程序卡片
	@Override
	public Vo_msg SendMiniProgram(String miniOpenId) {
		String thumb_url = RedisUtil.get("zzhnc_leave_program_thumb_url");
		String media_id = RedisUtil.get("zzhnc_leave_program_media_id");

		// redis中如果不存在，则重新上传临时素材
		if (null == media_id || media_id.length() < 1 || null == thumb_url || thumb_url.length() < 1) {

			Vo_msg imgMsg = WxMiniUtil.uploadImage(thumb_url, false);
			if (imgMsg.code != 0)
				return new Vo_msg(-1, null, imgMsg.msg);

			media_id = imgMsg.data.toString();
			RedisUtil.set("zzhnc_leave_program_media_id", media_id, 24 * 60 * 60); // redis缓存配置为24小时
			RedisUtil.set("zzhnc_leave_program_thumb_url", thumb_url, 24 * 60 * 60); // redis缓存配置为24小时
		}

		String result = WxMiniUtil.sendCustoMiniprogrampage(miniOpenId, "买房就找万小二", "pages/openAnimation/openAnimation",
				thumb_url, media_id);
		return new Vo_msg(0, null, result);
	}

	public static void main(String[] arg) {

	}

	public static String getAuthorizeUrl(String orderId, String activityId, int fansId) {

		String url = "https://open.weixin.qq.com/connect/oauth2/authorize?appid=wxd06aec668fe359d1&redirect_uri=http://www.w1hd.com/api/wx/wxd06aec668fe359d1/payWxMpUser2/"
				+ orderId + "/" + activityId + "/nmamtf&response_type=code&scope=snsapi_userinfo&state=" + fansId
				+ "&component_appid=wx79ad5a35526f26fb&connect_redirect=1#wechat_redirect";
		return url;
	}

	private void cache(String fromUserName, String projectId) {
		System.out.println("当前进入的楼盘projectId:" + projectId);
		if (Strings.isNullOrEmpty(projectId)) {
			RedisUtil.set("zzhnc_cache_project_" + fromUserName, 0 + "", 30 * RedisUtil.EXRP_MINUTE); // Edit by lcc
		} else {
			RedisUtil.set("zzhnc_cache_project_" + fromUserName, projectId + "", 30 * RedisUtil.EXRP_MINUTE);
		}
	}

	private Integer cache(String fromUserName) {
		String string = RedisUtil.get("zzhnc_cache_project_" + fromUserName);
		if (Strings.isNullOrEmpty(string)) {
			return 0;
		} else {
			return Integer.parseInt(string);
		}

	}

}