package com.yami.trading.service.chat.online;


import com.yami.trading.bean.Tip;
import com.yami.trading.bean.chat.domain.MessageUser;
import com.yami.trading.bean.chat.domain.OnlineChatMessage;
import com.yami.trading.bean.model.Customer;
import com.yami.trading.common.constants.TipConstants;
import com.yami.trading.common.exception.BusinessException;
import com.yami.trading.common.util.StringUtils;
import com.yami.trading.common.util.UnicodeUtils;
import com.yami.trading.service.chat.MessageUserService;
import com.yami.trading.service.customer.CustomerService;
import com.yami.trading.service.system.TipService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.net.URLDecoder;
import java.util.*;

/**
 * @author lucas
 */
@Service
public class OnlineChatVisitorMessageServiceImpl implements OnlineChatVisitorMessageService {
    @Autowired
    private TipService tipService;

    @Autowired
    OnlineChatMessageService onlinechatMessageService;

    @Autowired
    private MessageUserService messageUserService;

    @Autowired
    CustomerService customerService;
    @Autowired
    private DBOnlineChatVisitorMessageServiceImpl onlineChatVisitorMessageService;


    @Override
    public OnlineChatMessage saveSend(String ip, String type, String send_receive, String content, String username, boolean isAutoAnswer) {
        OnlineChatMessage onlineChatMessage = new OnlineChatMessage();
//		onlineChatMessage.setPartyId(ip);
        onlineChatMessage.setContentType(type);
        onlineChatMessage.setSendReceive(send_receive);
        content = UnicodeUtils.gbEncoding(content);
        onlineChatMessage.setContent(content);
        onlineChatMessage.setCreateTime(new Date());
        onlineChatMessage.setUsername(username);
        onlineChatMessage.setIp(ip);
        onlineChatMessage.setDeleteStatus(0);

        onlineChatVisitorMessageService.save(onlineChatMessage);
        List<OnlineChatMessage> list = onlinechatMessageService.cacheMessage(ip);
        if (list == null) {
            list = new LinkedList<OnlineChatMessage>();
        }
        list.add(onlineChatMessage);
        Collections.sort(list);
        Collections.reverse(list);// 添加完后，时间倒叙排序加回
        onlinechatMessageService.putMessage(ip, list);
        if (onlinechatMessageService.cacheMessageUser(ip) == null) {// 不存在则添加用户
            saveCreate(ip, username);
        }
        switch (send_receive) {
            case "receive":// 客服发送
                if (!isAutoAnswer) {
                    updateUnread(ip, "user", "write");
                }
                break;
            case "send":// 用户发送
                updateUnread(ip, "customer", "write");
//			tipService.saveTip(onlineChatMessage.getId().toString(), TipConstants.ONLINECHAT);
                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.setUserUnreadmsg(0);
                } else if ("write".equals(type)) {
                    messageUser.setUserUnreadmsg(messageUser.getUserUnreadmsg() + 1);
                    messageUser.setDeleteStatus(0);
                }
                break;
            case "customer":
                if ("read".equals(type)) {
					removeTipNum = messageUser.getCustomerUnreadmsg();
                    messageUser.setCustomerUnreadmsg(0);
                } else if ("write".equals(type)) {
					messageUser.setCustomerUnreadmsg(messageUser.getCustomerUnreadmsg() + 1);
                    messageUser.setDeleteStatus(0);
                    final String targetUsername = onlinechatMessageService.userSendTarget(ip, new Date(), messageUser.getTargetUsername());
                    if (StringUtils.isNotEmpty(targetUsername)
                            && !targetUsername.equals(messageUser.getTargetUsername())) {
                        final Customer customer = customerService.cacheByUsername(targetUsername);
                        // 客服不存在或者回复内容无效则不回复
                        if (customer != null && customer.getAutoAnswer() != null
                                && !StringUtils.isEmptyString(customer.getAutoAnswer().trim())) {
                            // 客服自动回复一条
                            saveSend(ip, "text", "receive", customer.getAutoAnswer(), targetUsername + "SYSTEM", true);
//						Thread t = new Thread(new Runnable() {
//							@Override
//							public void run() {
//								// TODO Auto-generated method stub
//								// 异步，延迟200毫秒发送
//								ThreadUtils.sleep(200);
//								saveSend(ip, "text", "receive", customer.getAutoAnswer(), targetUsername + "SYSTEM");// 客服自动回复一条
//							}
//						});
//						t.start();
                        }
                    }
                    messageUser.setTargetUsername(targetUsername);
                    if (StringUtils.isNotEmpty(targetUsername)) {// 指定的在线客服存在，则发起通知
                        Tip tip = new Tip();
                        tip.setBusinessId(onlinechatMessageService.cacheMessage(ip).get(0).getUuid().toString());
                        tip.setModel(TipConstants.ONLINECHAT);
                        tip.setTargetUsername(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) {
            messageUser = new MessageUser();
            messageUser.setIp(ip);
            messageUser.setUserUnreadmsg(0);
            messageUser.setCustomerUnreadmsg(0);
        }
        messageUser.setUpdatetime(new Date());
        messageUser.setDeleteStatus(0);
        messageUser.setTargetUsername(username);
        messageUserService.saveOrUpdate(messageUser);
        onlinechatMessageService.putMessageUser(ip, 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());
//		result.put("username", party.getUsername());
//		result.put("usercode", party.getUsercode());
//		result.put("last_login_time", DateUtils.format(party.getLast_loginTime(),DateUtils.DF_yyyyMMddHHmmss));
//		result.put("create_time", DateUtils.format(party.getCreateTime(),DateUtils.DF_yyyyMMddHHmmss));
//		result.put("role_name", party.getRolename());
//		result.put("loginIp", party.getLoginIp());
//		List<UserRecom> parents = userRecomService.getParents(party.getId());
//		if(!CollectionUtils.isEmpty(parents)&&parents.size()>=2) {
//			Party parentParty = partyService.cachePartyBy(parents.get(1).getPartyId(), true);
//			result.put("recom_parent_name", parentParty==null?null:parentParty.getUsername());
//		}else {
//			result.put("recom_parent_name", null);
//		}
        return result;
    }


}