package project.onlinechat.internal;

import java.net.URLDecoder;
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;

import kernel.exception.BusinessException;
import kernel.util.StringUtils;
import kernel.web.ApplicationUtil;
import project.onlinechat.MessageUser;
import project.onlinechat.OnlineChatMessage;
import project.onlinechat.OnlineChatMessageService;
import project.onlinechat.OnlineChatVisitorMessageService;
import project.tip.TipConstants;
import project.tip.TipService;
import project.tip.model.Tip;
import systemuser.CustomerService;
import systemuser.model.Customer;

public class OnlineChatVisitorMessageServiceImpl implements OnlineChatVisitorMessageService {

	private TipService tipService;
	
	private CustomerService customerService;
	
	private OnlineChatMessageService onlineChatMessageService;
	
	@Override
	public OnlineChatMessage saveSend(String ip, String type, String send_receive, String content, String username) {
		OnlineChatMessage onlineChatMessage = new OnlineChatMessage();
		onlineChatMessage.setType(type);
		onlineChatMessage.setSend_receive(send_receive);
		onlineChatMessage.setContent(content);
		onlineChatMessage.setCreateTime(new Date());
		onlineChatMessage.setUsername(username);
		onlineChatMessage.setIp(ip);

		ApplicationUtil.executeInsert(onlineChatMessage);
		
		List<OnlineChatMessage> list = onlineChatMessageService.cacheMessage(ip);
		if (list == null) onlineChatMessageService.putMessage(ip,list=new LinkedList<OnlineChatMessage>());
		list.add(onlineChatMessage);
		Collections.sort(list,Collections.reverseOrder());
		
		if (onlineChatMessageService.cacheMessageUser(ip) == null) saveCreate(ip,username);
		
		switch (send_receive) {
			case "receive":// 客服发送
				updateUnread(ip, "user", "write");
				break;
			case "send":// 用户发送
				updateUnread(ip, "customer", "write");
				break;
		}
		
		return onlineChatMessage;
	}

	/**
	 * 更新未读数
	 * @param ip
	 * @param user_customer 更新对象，用户，客服
	 * @param type read:读，write：写
	 */
	public void updateUnread(final String ip, String user_customer, String type) {
		MessageUser messageUser = onlineChatMessageService.cacheMessageUser(ip);
		if (messageUser == null) {
			saveCreate(ip,null);
			messageUser = onlineChatMessageService.cacheMessageUser(ip);
		}
		
		int removeTipNum = 0;
		switch (user_customer) {
			case "user":
				if ("read".equals(type)) {
					messageUser.setUser_unreadmsg(0);
				} else if ("write".equals(type)) {
					messageUser.setUser_unreadmsg(messageUser.getUser_unreadmsg() + 1);
					messageUser.setDelete_status(0);
				}
				break;
			case "customer":
				if ("read".equals(type)) {
					removeTipNum = messageUser.getCustomer_unreadmsg();
					messageUser.setCustomer_unreadmsg(0);
				} else if ("write".equals(type)) {
					messageUser.setCustomer_unreadmsg(messageUser.getCustomer_unreadmsg() + 1);
					messageUser.setDelete_status(0);
					final String targetUsername = onlineChatMessageService.userSendTarget(ip, new Date(), messageUser.getTarget_username());
					if (StringUtils.isNotEmpty(targetUsername) && !targetUsername.equals(messageUser.getTarget_username())) {
						Customer customer = customerService.cacheByUsername(targetUsername);
						if (customer != null && customer.getAuto_answer() != null && !StringUtils.isEmptyString(customer.getAuto_answer().trim())) {
							saveSend(ip, "text", "receive", customer.getAuto_answer(), targetUsername + "_SYSTEM");
						}
					}
					messageUser.setTarget_username(targetUsername);
					if (StringUtils.isNotEmpty(targetUsername)) {// 指定的在线客服存在，则发起通知
						Tip tip = new Tip();
						tip.setBusiness_id(onlineChatMessageService.cacheMessage(ip).get(0).getId().toString());
						tip.setModel(TipConstants.ONLINECHAT);
						tip.setTarget_username(targetUsername);
						tipService.saveTip(tip);
					}
				}
				break;
		}
		
		onlineChatMessageService.updateMessageUserByIp(messageUser);
		if (removeTipNum > 0) onlineChatMessageService.removeTips(messageUser.getIp(), removeTipNum);
	}

	@Override
	public MessageUser saveCreate(String ip,String username) {
		MessageUser messageUser = onlineChatMessageService.cacheMessageUser(ip);
		if (messageUser == null) onlineChatMessageService.putMessageUser(ip,messageUser=new MessageUser());
		
		messageUser.setIp(ip);
		messageUser.setDelete_status(0);
		messageUser.setUpdateTime(new Date());
		messageUser.setTarget_username(username);
		
		ApplicationUtil.executeSaveOrUpdate(messageUser);
		
		return messageUser;
	}

	/**
	 * 设置备注
	 * 
	 * @param ip
	 * @param remarks
	 */
	public String updateResetRemarks(String ip, String remarks) throws Exception {
		if (StringUtils.isEmptyString(remarks) || StringUtils.isEmptyString(remarks.trim())) return null;
		
		MessageUser messageUser = onlineChatMessageService.cacheMessageUser(ip);
		if (messageUser == null) throw new BusinessException("用户不存在");
		
		messageUser.setRemarks(URLDecoder.decode(remarks, "utf-8"));
		onlineChatMessageService.updateMessageUserByIp(messageUser);
		return remarks;
	}

	/**
	 * 获取用户信息
	 * @param ip
	 * @return
	 */
	public Map<String, Object> getUserInfo(String ip) {
		MessageUser messageUser = this.onlineChatMessageService.cacheMessageUser(ip);
		Map<String, Object> result = new HashMap<String, Object>();
		result.put("partyId", ip);
		result.put("remarks", messageUser.getRemarks());
		return result;
	}

	public void setOnlineChatMessageService(OnlineChatMessageService onlineChatMessageService) {
		this.onlineChatMessageService = onlineChatMessageService;
	}

	public void setTipService(TipService tipService) {
		this.tipService = tipService;
	}

	public void setCustomerService(CustomerService customerService) {
		this.customerService = customerService;
	}
}