package com.iplatform.chat.support;

import com.iplatform.chat.ChatService;
import com.iplatform.chat.Constants;
import com.iplatform.chat.util.ChatUtils;
import com.iplatform.model.vo.ChatVo;
import com.walker.db.Sorts;
import com.walker.db.page.GenericPager;
import com.walker.db.page.ListPageContext;
import com.walker.db.page.PageSearch;
import com.walker.infrastructure.utils.DateUtils;
import com.walker.infrastructure.utils.NumberGenerator;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.jdbc.mongo.ChatRecord;
import com.walker.jdbc.mongo.MongoService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;

import java.util.ArrayList;
import java.util.List;
import java.util.regex.Pattern;

@Deprecated
public class MongoChatService implements ChatService {

    protected final transient Logger logger = LoggerFactory.getLogger(this.getClass());

    private Sorts.Sort timeDescSort = Sorts.DESC().setField("_id");

    @Override
    public void execInsertChat(ChatVo vo) {
        if(vo == null){
            return;
        }
        if(vo.getMe() <= 0){
            logger.error("聊天错误，当前用户ID必须设置");
            return;
        }
        if(StringUtils.isEmpty(vo.getMessage())){
            logger.error("聊天错误，无法发送空消息");
            return;
        }

        ChatRecord record = this.acquireChatRecord(vo);
        if(!vo.isCustomerServiceSend()){
            // ================= 我发的消息 =================
            // 写入我的表中
            record.setUserId(vo.getCustomerService());
            record.setType(ChatVo.TYPE_SEND);
            this.mongoService.insert(record, String.valueOf(vo.getMe()));
            // 写入对方表中
            if(vo.getCustomerService() != Constants.USER_ID_ROBOT){
                record.setUserId(vo.getMe());
                record.setType(ChatVo.TYPE_RECEIVED);
                this.mongoService.insert(record, String.valueOf(vo.getCustomerService()));
            }

        } else {
            // ================= 客服发的消息 =================
            // 写入我的表中
            record.setUserId(vo.getCustomerService());
            record.setType(ChatVo.TYPE_RECEIVED);
            this.mongoService.insert(record, String.valueOf(vo.getMe()));
            // 写入对方表中
            if(vo.getCustomerService() != Constants.USER_ID_ROBOT){
                record.setUserId(vo.getMe());
                record.setType(ChatVo.TYPE_SEND);
                this.mongoService.insert(record, String.valueOf(vo.getCustomerService()));
            }
        }
        /*// 写入我的表中
        record.setUserId(vo.getCustomerService());
        record.setType(ChatVo.TYPE_SEND);
        this.mongoService.insert(record, String.valueOf(vo.getMe()));
        // 写入对方表中
        record.setUserId(vo.getMe());
        record.setType(ChatVo.TYPE_RECEIVED);
        this.mongoService.insert(record, String.valueOf(vo.getCustomerService()));*/
    }

    /**
     * 生成一个聊天记录，不设置对方用户信息，在调用者中处理。
     * @param vo
     * @return
     */
    public ChatRecord acquireChatRecord(ChatVo vo){
        ChatRecord record = new ChatRecord();
        record.setId(NumberGenerator.getLongSequenceId());
        record.setCreateDate(DateUtils.getDateTimeNumber());
//        record.setUserId(vo.getUserId());
//        record.setType(vo.getType());
        record.setMsgType(vo.getMsgType());
        record.setMessage(vo.getMessage());
        record.setBizId(vo.getBizId());
        return record;
    }

    @Override
    public void execDeleteChat(String id) {
        throw new UnsupportedOperationException("未写代码");
    }

    @Override
    public GenericPager<ChatVo> queryPageChatList(long me
            , String bizId, long startTime, long endTime, long userId, String keyword, PageSearch pageSearch, boolean meIsCustomerService) {
        if(me <= 0){
            throw new IllegalArgumentException("缺少聊天人ID(me)");
        }
//        Criteria criteria = new Criteria();
        Query mongoQuery = new Query();
        if(StringUtils.isNotEmpty(bizId)){
            mongoQuery.addCriteria(Criteria.where(Constants.CHAT_FIELD_BIZ_ID).is(bizId));
        }
        if(userId > 0){
            mongoQuery.addCriteria(Criteria.where(Constants.CHAT_FIELD_USER_ID).is(userId));
        }
        if(startTime > 0){
            mongoQuery.addCriteria(Criteria.where(Constants.CHAT_FIELD_CREATE_TIME).gte(startTime));
        }
        if(endTime > 0){
            mongoQuery.addCriteria(Criteria.where(Constants.CHAT_FIELD_CREATE_TIME).lte(endTime));
        }
        if(StringUtils.isNotEmpty(keyword)){
            // 模糊查询名字中带有 三 的数据
            Pattern pattern = Pattern.compile(Constants.LIKE_PREFIX + keyword + Constants.LIKE_SUFFIX, Pattern.CASE_INSENSITIVE);
            mongoQuery.addCriteria(Criteria.where(Constants.CHAT_FIELD_MESSAGE).regex(pattern));
        }

        GenericPager<ChatRecord> pager = this.mongoService.queryPageList(mongoQuery, ChatRecord.class, String.valueOf(me), pageSearch, timeDescSort);
        List<ChatVo> chatVoList = null;
        if(pager.getTotalRows() > 0){
            List<ChatRecord> data = pager.getDatas();
            chatVoList = new ArrayList<>(data.size());
            for(ChatRecord record : data){
                chatVoList.add(ChatUtils.acquireChatVo(record, me, meIsCustomerService));
            }
        } else {
            chatVoList = new ArrayList<>(1);
        }
        return ListPageContext.createGenericPager(chatVoList, pager.getPageIndex(), pager.getPageSize(), (int)pager.getTotalRows());
    }

    public void setMongoService(MongoService mongoService) {
        this.mongoService = mongoService;
    }

    private MongoService mongoService;
}