package com.ruoyi.user.controller;

import cn.hutool.core.util.RandomUtil;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.security.service.TokenService;
import com.ruoyi.order.api.entity.EvaluateOrderInfoVO;
import com.ruoyi.order.api.entity.OrderEvaluateSubmitRequest;
import com.ruoyi.order.api.entity.OrderEvaluateVO;
import com.ruoyi.order.api.feignClient.EvaluateClient;
import com.ruoyi.system.api.model.LoginUserInfo;
import com.ruoyi.user.entity.RecoveryServe;
import com.ruoyi.user.request.OrderEvaluateRequest;
import com.ruoyi.user.service.RecoveryServeService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

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

/**
 * <p>
 * 用户评价表 前端控制器
 * </p>
 *
 * @author hjl
 * @since 2024-05-29
 */
@RestController
@RequestMapping("/evaluate")
@Api(tags = {"用户端-个人中心"})
public class EvaluateController {

    @Resource
    private TokenService tokenService;
    @Resource
    private EvaluateClient evaluateClient;
    @Resource
    private RecoveryServeService recoveryServeService;

    @GetMapping("/orderEvaluate")
    @ApiOperation(value = "订单评价列表", tags = {"用户端-个人中心"})
    public R<Page<OrderEvaluateVO>> orderEvaluate(@RequestParam("state") Integer state,
                                                  @RequestParam(name = "pageNum", defaultValue = "1") Integer pageNum,
                                                  @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {
        LoginUserInfo loginUser = tokenService.getLoginUserByUser();
        if (null == loginUser) {
            return R.loginExpire("登录失效！");
        }
        Page<OrderEvaluateVO> list = evaluateClient.evaluateListByUser(loginUser.getUserid(), state, pageNum, pageSize).getData();
        if (null != list) {
            // 数据封装，减少循环io
            List<Integer> ids = list.getRecords().stream().map(data -> data.getOrderInfo().getServeId()).collect(Collectors.toList());
            if (!ids.isEmpty()) {
                List<RecoveryServe> serveList = recoveryServeService.lambdaQuery()
                        .in(RecoveryServe::getId, ids)
                        .eq(RecoveryServe::getIsDelete, 0).list();
                Map<Integer, RecoveryServe> map = serveList.stream().collect(Collectors.
                        toMap(RecoveryServe::getId, data -> data));
                for (OrderEvaluateVO data : list.getRecords()) {
                    Integer serveId = data.getOrderInfo().getServeId();
                    RecoveryServe recoveryServe = map.get(serveId);
                    if (null != recoveryServe) {
                        EvaluateOrderInfoVO orderInfo = data.getOrderInfo();
                        orderInfo.setServeName(recoveryServe.getServeName());
                        orderInfo.setServeDescribe(recoveryServe.getServeDescribe());
                        orderInfo.setCover(recoveryServe.getCover());
                    }
                }
            }
        }
        return R.ok(list);
    }

    @GetMapping("/conductEvaluation")
    @ApiOperation(value = "进行评价(服务单号)", tags = {"用户端-个人中心"})
    public R<String> conductEvaluation() {
        return R.ok(RandomUtil.randomNumbers(15));
    }

    @PostMapping("/submitEvaluation")
    @ApiOperation(value = "提交评价", tags = {"用户端-个人中心"})
    public R<String> submitEvaluation(@RequestBody @Validated OrderEvaluateRequest orderEvaluate) {
        Long orderId = orderEvaluate.getOrderId();
        String content = orderEvaluate.getContent();
        Double starRating = orderEvaluate.getStarRating();
        String serveNo = orderEvaluate.getServeNo();
        LoginUserInfo loginUser = tokenService.getLoginUserByUser();
        if (null == loginUser) {
            return R.loginExpire("登录失效！");
        }
        boolean save = evaluateClient.evaluateSave(new OrderEvaluateSubmitRequest(orderId, content, starRating,
                serveNo, loginUser.getUserid())).getData();
        return save ? R.ok() : R.fail();
    }

}