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

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjUtil;
import cn.stylefeng.guns.modular.business.dto.ImPushDataDTO;
import cn.stylefeng.guns.modular.business.dto.MentalAppointmentPageDTO;
import cn.stylefeng.guns.modular.business.dto.request.MentalAppointmentAssignWorkRequest;
import cn.stylefeng.guns.modular.business.dto.request.MentalAppointmentRecordRequest;
import cn.stylefeng.guns.modular.business.entity.MentalAppointment;
import cn.stylefeng.guns.modular.business.service.IMentalAppointmentService;
import cn.stylefeng.guns.modular.business.service.impl.ImBizService;
import cn.stylefeng.roses.kernel.db.api.factory.PageFactory;
import cn.stylefeng.roses.kernel.db.api.factory.PageResultFactory;
import cn.stylefeng.roses.kernel.db.api.pojo.page.PageResult;
import cn.stylefeng.roses.kernel.rule.enums.ImPushTypeEnum;
import cn.stylefeng.roses.kernel.rule.enums.MentalAppointmentConsultStatusEnum;
import cn.stylefeng.roses.kernel.rule.enums.MentalAppointmentStatusEnum;
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.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
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.Arrays;
import java.util.List;

@RestController
@Api(tags = "工作人员")
@ApiResource(name = "工作人员")
@RequestMapping("/worker")
public class MentalAnalysisTimeConfigController {

    @Resource
    private ImBizService imBizService;

    @Resource
    private IMentalAppointmentService mentalAppointmentService;

    @ApiOperation("性格分析师-查看行程")
    @GetResource(name = "性格分析师-查看行程", path = "/mentalAnalysisTimeConfigSchedule", requiredPermission = false)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "counsellingInfoId", value = "性格分析师ID", dataTypeClass = Long.class, paramType = "query"),
            @ApiImplicitParam(name = "searchBeginTime", value = "开始时间", dataTypeClass = String.class, paramType = "query"),
            @ApiImplicitParam(name = "searchEndTime", value = "结束时间", dataTypeClass = String.class, paramType = "query"),
            @ApiImplicitParam(name = "userNickName", value = "用户姓名", dataTypeClass = String.class, paramType = "query"),
            @ApiImplicitParam(name = "userTelephone", value = "联系电话", dataTypeClass = String.class, paramType = "query"),
            @ApiImplicitParam(name = "statusFlag", value = "状态：1已分配，2服务中，3已完成，9已取消", dataTypeClass = Integer.class, paramType = "query"),
    })
    public ResponseData<List<MentalAppointmentPageDTO>> mentalAnalysisTimeConfigSchedule(Long counsellingInfoId, String searchBeginTime, String searchEndTime, String userNickName, String userTelephone, Integer statusFlag) {
        List<MentalAppointmentPageDTO> list = mentalAppointmentService.mentalAnalysisTimeConfigSchedule(searchBeginTime, searchEndTime, counsellingInfoId, null, userNickName, userTelephone, statusFlag, null);
        return new SuccessResponseData<>(list);
    }

    @ApiOperation("性格分析师-查看行程（分页）")
    @GetResource(name = "性格分析师-查看行程（分页）", path = "/mentalAnalysisTimeConfigSchedulePage", requiredPermission = false)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "pageNo", value = "分页：第几页（从1开始）", dataTypeClass = Integer.class, paramType = "query"),
            @ApiImplicitParam(name = "pageSize", value = "分页：每页大小（默认20）", dataTypeClass = Integer.class, paramType = "query"),
            @ApiImplicitParam(name = "counsellingInfoId", value = "性格分析师ID", dataTypeClass = Long.class, paramType = "query"),
            @ApiImplicitParam(name = "userNickName", value = "用户姓名", dataTypeClass = String.class, paramType = "query"),
            @ApiImplicitParam(name = "userTelephone", value = "联系电话", dataTypeClass = String.class, paramType = "query"),
            @ApiImplicitParam(name = "statusFlag", value = "状态：1预约中，2服务中，3已完成，9已取消", dataTypeClass = Integer.class, paramType = "query"),
    })
    public ResponseData<PageResult<MentalAppointmentPageDTO>> mentalAnalysisTimeConfigSchedulePage(Integer pageNo, Integer pageSize, Long counsellingInfoId, String userNickName, String userTelephone, Integer statusFlag) {
        Page<MentalAppointmentPageDTO> page = mentalAppointmentService.getPage(
                PageFactory.page(pageNo, pageSize),
                counsellingInfoId,
                null,
                userNickName,
                userTelephone,
                statusFlag,
                Arrays.asList(MentalAppointmentStatusEnum.WAIT_SERVICE.getCode(), MentalAppointmentStatusEnum.IN_SERVICE.getCode(), MentalAppointmentStatusEnum.DONE.getCode())
        );
        return new SuccessResponseData<>(PageResultFactory.createPageResult(page));
    }

    @ApiOperation("性格分析师-预约详情")
    @GetResource(name = "性格分析师-预约详情", path = "/mentalAppointmentDetail", requiredPermission = false)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id", value = "预约ID", dataTypeClass = Long.class, paramType = "query"),
    })
    public ResponseData<MentalAppointment> mentalAppointmentDetail(Long id) {
        MentalAppointment appointment = mentalAppointmentService.getById(id);
        return new SuccessResponseData<>(appointment);
    }

    @ApiOperation("性格分析师-开始咨询")
    @GetResource(name = "性格分析师-开始咨询", path = "/mentalAppointmentStartConsult", requiredPermission = false)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id", value = "预约ID", dataTypeClass = Long.class, paramType = "query"),
    })
    public ResponseData<Boolean> mentalAppointmentStartConsult(Long id) {
        boolean update = mentalAppointmentService.update(
                Wrappers.<MentalAppointment>lambdaUpdate()
                        .set(MentalAppointment::getStatusFlag, MentalAppointmentStatusEnum.IN_SERVICE.getCode())
                        .set(MentalAppointment::getConsultStatus, MentalAppointmentConsultStatusEnum.IN_CONSULT.getCode())
                        .eq(MentalAppointment::getId, id)
        );
        return new SuccessResponseData<>(update);
    }

    @ApiOperation("性格分析师-结束咨询")
    @GetResource(name = "性格分析师-结束咨询", path = "/mentalAppointmentStopConsult", requiredPermission = false)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id", value = "预约ID", dataTypeClass = Long.class, paramType = "query"),
    })
    public ResponseData<Boolean> mentalAppointmentStopConsult(Long id) {
        boolean update = mentalAppointmentService.update(
                Wrappers.<MentalAppointment>lambdaUpdate()
                        .set(MentalAppointment::getStatusFlag, MentalAppointmentStatusEnum.DONE.getCode())
                        .set(MentalAppointment::getConsultStatus, MentalAppointmentConsultStatusEnum.DONE.getCode())
                        .eq(MentalAppointment::getId, id)
        );

        try {
            MentalAppointment o = mentalAppointmentService.getById(id);

            // 推送消息内容
            String pushContent = "1v1咨询结束";

            // IM推送数据json
            ImPushDataDTO pushData_u = ImPushDataDTO.builder()
                    .type(ImPushTypeEnum.C_TO_C_TIP_STOP_IM.getCode())
                    .objId(ObjUtil.toString(o.getId()))
                    .title("通知")
                    .content(pushContent)
                    .data1(ObjUtil.toString(o.getWorkerId()))
                    .data2(ObjUtil.toString(o.getUserId()))
                    .build();
            // 通知性格分析师
            imBizService.messageSendSystem(o.getWorkerId()+"", new String[]{o.getUserId()+""}, pushData_u, null, null, false);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return new SuccessResponseData<>(update);
    }

    @ApiOperation("性格分析师-布置作业")
    @PostResource(name = "性格分析师-布置作业", path = "/mentalAppointmentAssignWorkRequest", requiredPermission = false)
    public ResponseData<Boolean> mentalAppointmentAssignWorkRequest(@RequestBody MentalAppointmentAssignWorkRequest req) {
        MentalAppointment mentalAppointment = BeanUtil.toBean(req, MentalAppointment.class);
        boolean update = mentalAppointmentService.updateById(mentalAppointment);
        return new SuccessResponseData<>(update);
    }

    @ApiOperation("性格分析师-咨询记录内容")
    @PostResource(name = "性格分析师-咨询记录内容", path = "/mentalAppointmentAddRecordRequest", requiredPermission = false)
    public ResponseData<Boolean> mentalAppointmentAddRecordRequest(@RequestBody MentalAppointmentRecordRequest req) {
        MentalAppointment mentalAppointment = BeanUtil.toBean(req, MentalAppointment.class);
        boolean update = mentalAppointmentService.updateById(mentalAppointment);
        return new SuccessResponseData<>(update);
    }

    @ApiOperation("性格分析师-当前可咨询订单")
    @GetResource(name = "性格分析师-当前可咨询订单", path = "/mentalAppointmentConsultOrderList", requiredPermission = false)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id", value = "预约ID", dataTypeClass = Long.class, paramType = "query"),
            @ApiImplicitParam(name = "userId", value = "用户ID", dataTypeClass = Long.class, paramType = "query"),
            @ApiImplicitParam(name = "workerId", value = "性格分析师ID", dataTypeClass = Long.class, paramType = "query"),
    })
    public ResponseData<List<MentalAppointment>> mentalAppointmentConsultOrderList(Long id, Long userId, Long workerId) {
        DateTime dateTime = DateUtil.date();
        String day = DateUtil.formatDate(dateTime);
        String time = DateUtil.format(dateTime, "HH:mm");
        List<MentalAppointment> list = mentalAppointmentService.list(
                Wrappers.<MentalAppointment>lambdaUpdate()
                        .in(MentalAppointment::getStatusFlag, Arrays.asList(
                                MentalAppointmentStatusEnum.WAIT_SERVICE.getCode(),
                                MentalAppointmentStatusEnum.IN_SERVICE.getCode()
                        ))
                        .eq(MentalAppointment::getAppointmentDay, day)
                        .le(MentalAppointment::getBeginTimePoint, time)
                        .ge(MentalAppointment::getEndTimePoint, time)
                        .eq(userId != null, MentalAppointment::getUserId, userId)
                        .eq(workerId != null, MentalAppointment::getWorkerId, workerId)
                        .eq(id != null, MentalAppointment::getId, id)
                        .orderByDesc(MentalAppointment::getStatusFlag)
        );
        return new SuccessResponseData<>(list);
    }

}