package cn.stylefeng.rest.modular.im.controller;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import cn.stylefeng.guns.modular.business.dto.CustomerImInfoDTO;
import cn.stylefeng.guns.modular.business.dto.ImEffectiveInfoDTO;
import cn.stylefeng.guns.modular.business.dto.ImGroupUserDto;
import cn.stylefeng.guns.modular.business.dto.ImPushDataDTO;
import cn.stylefeng.guns.modular.business.dto.request.ImGroupUpdateRequest;
import cn.stylefeng.guns.modular.business.dto.request.ImTestMessageSendRequest;
import cn.stylefeng.guns.modular.business.entity.*;
import cn.stylefeng.guns.modular.business.service.*;
import cn.stylefeng.guns.modular.business.service.impl.ImBizService;
import cn.stylefeng.roses.kernel.auth.api.context.LoginContext;
import cn.stylefeng.roses.kernel.auth.api.pojo.login.LoginUser;
import cn.stylefeng.roses.kernel.customer.api.pojo.CustomerInfo;
import cn.stylefeng.roses.kernel.customer.modular.entity.Customer;
import cn.stylefeng.roses.kernel.customer.modular.service.CustomerService;
import cn.stylefeng.roses.kernel.im.api.ImServerApi;
import cn.stylefeng.roses.kernel.rule.enums.CustomerWorkStatusEnum;
import cn.stylefeng.roses.kernel.rule.enums.ImPushTypeEnum;
import cn.stylefeng.roses.kernel.rule.enums.ImUserTypeEnum;
import cn.stylefeng.roses.kernel.rule.enums.PostIdEnum;
import cn.stylefeng.roses.kernel.rule.pojo.response.ErrorResponseData;
import cn.stylefeng.roses.kernel.rule.pojo.response.ResponseData;
import cn.stylefeng.roses.kernel.rule.pojo.response.SuccessResponseData;
import cn.stylefeng.roses.kernel.scanner.api.annotation.ApiResource;
import cn.stylefeng.roses.kernel.scanner.api.annotation.GetResource;
import cn.stylefeng.roses.kernel.scanner.api.annotation.PostResource;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Assert;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import io.rong.messages.TxtMessage;
import io.rong.models.Result;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

@Slf4j
@Api(tags = "IM接口")
@RestController
@ApiResource(name = "IM接口")
@RequestMapping("/im")
public class ImController {

    @Resource
    ImBizService imBizService;

    @Resource
    ImServerApi imServerApi;

    @Resource
    CustomerService customerService;

    @Resource
    IImGroupService imGroupService;

    @Resource
    IImNoticeService imNoticeService;

    @Resource
    private ICourseOrderService courseOrderService;

    @Resource
    private ICounsellingUserService counsellingUserService;

    @Resource
    private IImGroupUserService imGroupUserService;

    @ApiOperation(value = "测试发送IM消息")
    @PostResource(name = "测试发送IM消息", path = "/testMessageSend")
    public ResponseData testMessageSend(@RequestBody ImTestMessageSendRequest req) {
        // IM推送数据json
        ImPushDataDTO pushData = req.getPushData();

        Result messageSendResult;
        if (req.getSendTpe() == null || req.getSendTpe() == 0) {
            messageSendResult = imBizService.messageSendSystem(
                    req.getFromUserId(),
                    new String[]{req.getToId()},
                    pushData,
                    ImUserTypeEnum.USER,
                    null,
                    false
            );
        } else if (req.getSendTpe() == 1) {
            messageSendResult = imServerApi.messageSendPrivate(req.getFromUserId(), new String[]{req.getToId()}, new TxtMessage(JSONUtil.toJsonStr(pushData), pushData.getExtra()));
        } else {
            messageSendResult = imBizService.messageSendGroup(req.getFromUserId(), new String[]{req.getToId()}, pushData);
        }
        log.error("发送消息结果：{}", messageSendResult);
        return new SuccessResponseData(messageSendResult);
    }

    @ApiOperation(value = "即时咨询销售顾问", notes = "即时咨询，获取用户销售顾问，没有绑定随机分配一位当前在上班的咨询顾问")
    @GetResource(name = "即时咨询销售顾问", path = "/realTimeConsult")
    public ResponseData<Long> realTimeConsult() {
        // 获取当前登录用户信息
        LoginUser loginUser = LoginContext.me().getLoginUser();
        Long userId = loginUser.getUserId();

        // 获取C端用户的详细信息
        CustomerInfo customerInfo = customerService.getCustomerInfoById(userId);
        Assert.notNull(customerInfo, "获取用户信息失败！");
        Long consultWorkerId = customerInfo.getConsultWorkerId();
        if (consultWorkerId == null) {
            // 获取销售顾问
            consultWorkerId = customerService.randomWorkerIdByLineStatusAndPost(null, null, PostIdEnum.PO_21.getCode(), CustomerWorkStatusEnum.ON_WORK.getCode());
            if (consultWorkerId != null) {
                // 设置用户信息销售顾问
                Customer customer = new Customer();
                customer.setCustomerId(userId);
                customer.setConsultWorkerId(consultWorkerId);
                customerService.updateCustomerRemoveCache(customer);
            }
        }

        if (consultWorkerId != null) {
            return new SuccessResponseData(consultWorkerId);
        } else {
            return new ErrorResponseData("获取销售顾问失败！");
        }
    }

    @ApiOperation(value = "即时课程销售顾问", notes = "即时咨询，获取用户销售顾问，没有绑定随机分配一位当前在上班的咨询顾问")
    @GetResource(name = "即时课程销售顾问", path = "/realTimeClass")
    public ResponseData<Long> realTimeClass() {
        // 获取当前登录用户信息
        LoginUser loginUser = LoginContext.me().getLoginUser();
        Long userId = loginUser.getUserId();

        // 获取C端用户的详细信息
        CustomerInfo customerInfo = customerService.getCustomerInfoById(userId);
        Assert.notNull(customerInfo, "获取用户信息失败！");
        Long classWorkerId = customerInfo.getClassWorkerId();
        if (classWorkerId == null) {
            // 获取销售顾问
            classWorkerId = customerService.randomWorkerIdByLineStatusAndPost(null, null, PostIdEnum.PO_11.getCode(), CustomerWorkStatusEnum.ON_WORK.getCode());
            if (classWorkerId != null) {
                // 设置用户信息销售顾问
                Customer customer = new Customer();
                customer.setCustomerId(userId);
                customer.setClassWorkerId(classWorkerId);
                customerService.updateCustomerRemoveCache(customer);
            }
        }

        if (classWorkerId != null) {
            return new SuccessResponseData(classWorkerId);
        } else {
            return new ErrorResponseData("获取销售顾问失败！");
        }
    }

    @ApiOperation(value = "获取IM通讯token", notes = "获取指定用户IM通讯token，没有则注册IM")
    @GetResource(name = "获取IM通讯token", path = "/getImToken")
    public ResponseData<String> getImToken(Long userId) {
        Assert.notNull(userId, "用户ID不能为空！");
        // 获取用户IM通讯token
        return new SuccessResponseData(imBizService.getImToken(userId));
    }

    @ApiOperation(value = "获取用户IM信息")
    @GetResource(name = "获取用户IM信息", path = "/userListByIds")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "ids", value = "用户ID串，逗号拼接")
    })
    public ResponseData<List<CustomerImInfoDTO>> userListByIds(String ids) {
        List<CustomerImInfoDTO> list = customerService.list(
                Wrappers.<Customer>lambdaQuery()
                        .select(
                                Customer::getCustomerId,
                                Customer::getNickName,
                                Customer::getRealName,
                                Customer::getAvatar,
                                Customer::getImToken,
                                Customer::getPostIds
                        )
                        .in(Customer::getCustomerId, ids.split(","))
        ).stream().map(o -> BeanUtil.toBean(o, CustomerImInfoDTO.class)).collect(Collectors.toList());
        return new SuccessResponseData(list);
    }

    @ApiOperation(value = "我的群聊")
    @GetResource(name = "我的群聊", path = "/myGroup")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "userId", value = "用户ID", dataTypeClass = Long.class),
            @ApiImplicitParam(name = "groupName", value = "群名", dataTypeClass = String.class),
            @ApiImplicitParam(name = "statusFlag", value = "状态：1正常，2冻结（解散）", dataTypeClass = Integer.class),
            @ApiImplicitParam(name = "nickName", value = "用户姓名", dataTypeClass = String.class),
            @ApiImplicitParam(name = "groupType", value = "群类型：1课程，2咨询", dataTypeClass = Integer.class),
            @ApiImplicitParam(name = "orderId", value = "订单ID", dataTypeClass = Long.class),
    })
    public ResponseData<List<ImGroup>> myGroup(Long userId, String groupName, Integer statusFlag, String nickName, Integer groupType, String orderId) {
        userId = userId == null ? LoginContext.me().getLoginUser().getUserId() : userId;
        return new SuccessResponseData(imGroupService.getMyGroup(userId, groupName, statusFlag, nickName, groupType, orderId));
    }

    @ApiOperation(value = "群聊详情")
    @GetResource(name = "群聊详情", path = "/groupDetail")
    public ResponseData<ImGroup> groupDetail(Long groupId) {
        // 获取用户IM通讯token
        return new SuccessResponseData(imGroupService.getById(groupId));
    }

    @ApiOperation(value = "编辑群聊信息")
    @PostResource(name = "编辑群聊信息", path = "/updateGroup")
    public ResponseData<Boolean> updateGroup(@RequestBody ImGroupUpdateRequest req) {
        ImGroup group = BeanUtil.toBean(req, ImGroup.class);
        // 编辑群聊信息
        boolean update = imGroupService.updateById(group);
        if (update && StrUtil.isNotBlank(group.getName())) {
            imServerApi.groupUpdate(group.getId().toString(), group.getName(), new String[]{});
        }
        return new SuccessResponseData(update);
    }

    @ApiOperation(value = "群聊用户列表")
    @GetResource(name = "群聊用户列表", path = "/groupUser")
    public ResponseData<List<ImGroupUserDto>> groupUser(Long groupId) {
        // 获取用户IM通讯token
        return new SuccessResponseData(imGroupService.groupUser(groupId));
    }

    @ApiOperation(value = "通知列表")
    @GetResource(name = "通知列表", path = "/imNotice")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "userId", value = "用户ID", dataTypeClass = Long.class),
            @ApiImplicitParam(name = "postId", value = "岗位ID", dataTypeClass = Integer.class),
    })
    public ResponseData<List<ImNotice>> imNotice(Long userId, Integer postId) {
        List<ImNotice> list = imNoticeService.list(
                Wrappers.<ImNotice>lambdaQuery()
                        .eq(userId != null, ImNotice::getUserId, userId)
                        .eq(postId != null, ImNotice::getPostId, postId)
                        .orderByDesc(ImNotice::getCreateTime)
        );
        return new SuccessResponseData(list);
    }

    @ApiOperation(value = "已读通知")
    @GetResource(name = "已读通知", path = "/readNotice")
    public ResponseData<List<ImNotice>> readNotice(Long id) {
        boolean update = imNoticeService.update(
                Wrappers.<ImNotice>lambdaUpdate()
                        .set(ImNotice::getReadFlag, 1)
                        .eq(ImNotice::getId, id)
        );
        return new SuccessResponseData(update);
    }

    @ApiOperation(value = "全部已读通知")
    @GetResource(name = "全部已读通知", path = "/allReadNotice")
    public ResponseData<List<ImNotice>> allReadNotice(Long userId) {
        boolean update = imNoticeService.update(
                Wrappers.<ImNotice>lambdaUpdate()
                        .set(ImNotice::getReadFlag, 1)
                        .eq(ImNotice::getUserId, userId)
        );
        return new SuccessResponseData(update);
    }

    @ApiOperation(value = "群聊禁用和启用")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "groupId", value = "群聊id", dataTypeClass = Long.class),
            @ApiImplicitParam(name = "statusFlag", value = "状态：1正常，2冻结", dataTypeClass = Long.class),
    })
    @PostResource(name = "群聊禁用和启用", path = "/updateImGroupState")
    public ResponseData<Boolean> updateImGroupState(Long groupId,Integer statusFlag) {
        LambdaUpdateWrapper<ImGroup> imGroupLambdaUpdateWrapper =  Wrappers.<ImGroup>lambdaUpdate()
                .set(ImGroup::getStatusFlag, statusFlag)
                .eq(ImGroup::getId, groupId);
        if (statusFlag.intValue() == 2 ){
            imGroupLambdaUpdateWrapper.set(ImGroup::getDisbandDate,new Date());
        }
        ImGroup imGroup = this.imGroupService.getById(groupId);
        Result result = imServerApi.groupDismiss(groupId.toString(),LoginContext.me().getLoginUser().getUserId().toString());
        log.info("解散群聊:"+JSONUtil.toJsonStr(result));
        if (result.getCode().intValue() == 200){
            boolean update = imGroupService.update(imGroupLambdaUpdateWrapper);
            //发送群聊消息解散消息
            List<ImGroupUser> imGroupUsers = this.imGroupUserService.list(new LambdaQueryWrapper<ImGroupUser>().select(ImGroupUser::getUserId,ImGroupUser::getGroupId).eq(ImGroupUser::getGroupId,groupId).eq(ImGroupUser::getIsDelete,0));
            if (CollectionUtil.isNotEmpty(imGroupUsers)){
               List<String> userIds = imGroupUsers.stream().map(ImGroupUser::getUserId).map(String::valueOf).collect(Collectors.toList());
                String pushContent = imGroup.getName()+".该群聊被解散";

                // IM推送数据json
                ImPushDataDTO pushData = ImPushDataDTO.builder()
                        .type(ImPushTypeEnum.S_TO_C_TIP_GROUP_CANCEL_INFO.getCode())
                        .objId(ObjUtil.toString(imGroup.getId()))
                        .title("通知")
                        .content(pushContent)
//                        .extra("发起聊天")
                        .data1(ObjUtil.toString(LoginContext.me().getLoginUser().getUserId()))
                        .build();

                    // 发送
                    imBizService.messageSendSystem(LoginContext.me().getLoginUser().getUserId() + "", userIds.toArray(new String[userIds.size()]), pushData, ImUserTypeEnum.USER,null, true);

            }

            return new SuccessResponseData(update);
        }
       return new ErrorResponseData<>("解散群聊失败！");
    }


    @ApiOperation(value = "根据分组id查询业务过期时间")
    @GetResource(name = "根据分组id查询业务过期时间", path = "/getGroupEffectiveInfo")
    public ResponseData<ImEffectiveInfoDTO> getGroupEffectiveInfo(Long groupId) {
        ImGroup imGroup = this.imGroupService.getById(groupId);
        if (imGroup == null){
            return new ErrorResponseData<>("没有对应群聊");
        }
        ImEffectiveInfoDTO imEffectiveInfoDTO = new ImEffectiveInfoDTO();
        imEffectiveInfoDTO.setGroupType(imGroup.getGroupType());
        imEffectiveInfoDTO.setOrderId(imGroup.getOrderId());
        if (imGroup.getGroupType().intValue() ==1){
            CourseOrder courseOrder = this.courseOrderService.getById(imGroup.getOrderId());
            if (courseOrder != null){
               imEffectiveInfoDTO.setUserId(courseOrder.getUserId());
               imEffectiveInfoDTO.setEffectiveEndTime(courseOrder.getEffectiveEndTime());
               imEffectiveInfoDTO.setEffectiveBeginTime(courseOrder.getEffectiveBeginTime());
                Customer customer = this.customerService.getById(imEffectiveInfoDTO.getUserId());
               imEffectiveInfoDTO.setPhone(customer.getTelephone());
            }
        }else{
           ImGroupUser imGroupUser =  this.imGroupUserService.getOne(new LambdaQueryWrapper<ImGroupUser>().eq(ImGroupUser::getGroupId,imGroup.getId())
                    .isNull(ImGroupUser::getUserPost).last(" limit 1 "));
           if (imGroupUser != null){
               CounsellingUser counsellingUser = this.counsellingUserService.getOne(new LambdaQueryWrapper<CounsellingUser>().eq(CounsellingUser::getUserId,imGroupUser.getUserId())
                       .eq(CounsellingUser::getCounsellingInfoId,imGroup.getOrderId()).eq(CounsellingUser::getIsDelete,0));
               if (counsellingUser != null){
                   imEffectiveInfoDTO.setEffectiveEndTime(counsellingUser.getEffectiveEndTime());
                   imEffectiveInfoDTO.setEffectiveBeginTime(counsellingUser.getEffectiveBeginTime());
                   imEffectiveInfoDTO.setPhone(counsellingUser.getPhone());
                   imEffectiveInfoDTO.setClassHours(counsellingUser.getClassHours());
                   imEffectiveInfoDTO.setResidueClassHours(counsellingUser.getResidueClassHours());
               }
               imEffectiveInfoDTO.setUserId(imGroupUser.getUserId());
           }
        }
        if (imEffectiveInfoDTO.getUserId() != null){
            Customer customer = this.customerService.getById(imEffectiveInfoDTO.getUserId());
            if (customer != null){
                imEffectiveInfoDTO.setNickName(customer.getNickName());
            }
        }

        return new SuccessResponseData(imEffectiveInfoDTO);
    }

}