package project.web.api.otc;

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

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import kernel.exception.BusinessException;
import kernel.util.DateUtils;
import kernel.util.JsonUtils;
import kernel.util.StringUtils;
import kernel.web.BaseAction;
import kernel.web.ResultObject;
import project.Constants;
import project.onlinechat.otc.OtcMessageUser;
import project.onlinechat.otc.OtcOnlineChatMessage;
import project.onlinechat.otc.OtcOnlineChatMessageService;

@RestController
@CrossOrigin
public class OtcOnlineChatController extends BaseAction {
	
	private Logger logger = LoggerFactory.getLogger(OtcOnlineChatController.class);
	
	@Resource
	private OtcOnlineChatMessageService otcOnlineChatMessageService;
	
	public final String action = "api/otcOnlinechat";

	/**
	 * 消息列表
	 */
	@RequestMapping(action + "!list.action")
	public Object list(HttpServletRequest request) {
		ResultObject resultObject = new ResultObject();
		resultObject = this.readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return JsonUtils.getJsonString(resultObject);
		}
		String partyId = getLoginPartyId();
		try {
			String messageId = request.getParameter("messageId");
			String orderNo = request.getParameter("orderNo");
			// 首页的时候才更新未读数
			if (StringUtils.isNullOrEmpty(messageId)) {
				OtcMessageUser cacheMessageUser = otcOnlineChatMessageService.cacheMessageUser(orderNo);
				if (cacheMessageUser != null && cacheMessageUser.getUser_unreadmsg() > 0) {
					otcOnlineChatMessageService.updateUnread(partyId, "read", orderNo);
				}
			}

			List<Map<String, Object>> data = new ArrayList<Map<String, Object>>();
			List<OtcOnlineChatMessage> list = otcOnlineChatMessageService.cacheGetList(messageId, 10, orderNo, "user");
			for (OtcOnlineChatMessage message : list) {
				Map<String, Object> map = new HashMap<String, Object>();
				map.put("id", message.getId());
				if (partyId.equals(message.getPartyId())) {
					map.put("send_receive", "send");
				} else {
					map.put("send_receive", "receive");
				}
				
				String type = message.getType();
				map.put("type", type);
				String content = message.getContent();
				if ("img".equals(type)) {
					content = Constants.WEB_URL + "/public/showimg!showImg.action?imagePath=" + content;
				}
				map.put("content", content);
				map.put("createtime", DateUtils.format(message.getCreateTime(), "MM-dd HH:mm"));
				data.add(map);
			}
			resultObject.setData(data);
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Exception e) {
			resultObject.setCode("1");
			resultObject.setMsg("Program error!");
			logger.error("error:", e);
		}
		return resultObject;
	}

	/**
	 * 发送消息
	 */
	@RequestMapping(value = action + "!send.action")
	public Object send(HttpServletRequest request) {
		ResultObject resultObject = new ResultObject();
		try {
			String content = request.getParameter("content");
			String type = request.getParameter("type");
			String orderNo = request.getParameter("orderNo");
			if (StringUtils.isNullOrEmpty(content.trim()) || StringUtils.isNullOrEmpty(type)) {
				return resultObject;
			}
			
			if(StringUtils.isEmptyString(orderNo)) {
				throw new BusinessException("订单号不能未空");
			}

			resultObject = this.readSecurityContextFromSession(resultObject);
			if (!"0".equals(resultObject.getCode())) {
				return JsonUtils.getJsonString(resultObject);
			}
			otcOnlineChatMessageService.saveSend(getLoginPartyId(), type, content, null, orderNo);
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Exception e) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", e);
		}
		return resultObject;
	}

	/**
	 * 获取未读消息数
	 */
	@RequestMapping(action + "!unread.action")
	public Object unread(HttpServletRequest request) {
		ResultObject resultObject = new ResultObject();
		resultObject = this.readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return JsonUtils.getJsonString(resultObject);
		}
		try {
			int unreadMsg = 0;
			String orderNo = request.getParameter("orderNo");
			if(StringUtils.isEmptyString(orderNo)) {
				throw new BusinessException("订单号不能未空");
			}
			unreadMsg = otcOnlineChatMessageService.unreadMsg(orderNo, getLoginPartyId());
			resultObject.setData(unreadMsg);

		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Exception e) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", e);
		}
		return resultObject;
	}

	public void setOtcOnlineChatMessageService(OtcOnlineChatMessageService otcOnlineChatMessageService) {
		this.otcOnlineChatMessageService = otcOnlineChatMessageService;
	}

}