/**
 * 手机端报修查询命令类
 * 
 * 该类负责处理手机端报修查询请求，包括查询用户报修记录、计算报修评分、统计处理时长等功能
 * 通过注解@Java110Cmd(serviceCode = "repair.queryPhoneRepairs")标识为命令处理器
 * 
 * @author Java110
 * @version 1.0
 * @since 2023
 */
package com.java110.community.cmd.repair;

import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.context.CmdContextUtils;
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.factory.CommunitySettingFactory;
import com.java110.dto.privilege.BasePrivilegeDto;
import com.java110.dto.repair.RepairDto;
import com.java110.dto.user.UserDto;
import com.java110.intf.community.IMenuInnerServiceSMO;
import com.java110.intf.community.IRepairInnerServiceSMO;
import com.java110.intf.community.IRepairUserInnerServiceSMO;
import com.java110.intf.user.IUserV1InnerServiceSMO;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.constant.MappingConstant;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.*;
import com.java110.vo.ResultVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;

import java.math.BigDecimal;
import java.text.ParseException;
import java.util.*;

@Java110Cmd(serviceCode = "repair.queryPhoneRepairs")
public class QueryPhoneRepairsCmd extends Cmd {

    /**
     * 报修服务接口
     */
    @Autowired
    private IRepairInnerServiceSMO repairInnerServiceSMOImpl;

    /**
     * 报修用户关系服务接口
     */
    @Autowired
    private IRepairUserInnerServiceSMO repairUserInnerServiceSMOImpl;

    /**
     * 菜单服务接口
     */
    @Autowired
    private IMenuInnerServiceSMO menuInnerServiceSMOImpl;

    /**
     * 用户服务接口
     */
    @Autowired
    private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl;

    /**
     * 公共域常量
     */
    public static final String DOMAIN_COMMON = "DOMAIN.COMMON";

    /**
     * 员工报修列表视图常量
     */
    public static final String VIEW_LIST_STAFF_REPAIRS = "VIEW_LIST_STAFF_REPAIRS";

    /**
     * 参数验证方法
     * 
     * 验证请求参数是否完整，包括分页信息和必要的项目ID
     * 
     * @param event   命令事件对象，包含请求相关信息
     * @param context 数据流上下文对象，用于获取和设置上下文数据
     * @param reqJson 请求JSON对象，包含前端传递的参数
     * @throws CmdException 当参数验证失败时抛出命令异常
     */
    @Override
    public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
        // 调用父类方法验证分页信息
        super.validatePageInfo(reqJson);
        // 验证请求中必须包含项目ID
        Assert.hasKeyAndValue(reqJson, "communityId", "请求中未包含项目ID");
    }

    /**
     * 执行命令方法
     * 
     * 处理手机端报修查询请求，查询用户的报修记录，计算评分和处理时长，返回查询结果
     * 
     * @param event   命令事件对象
     * @param context 数据流上下文对象
     * @param reqJson 请求JSON对象，包含查询条件参数
     * @throws CmdException    命令执行异常
     * @throws ParseException  日期解析异常
     */
    @Override
    public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
        // 从上下文中获取当前用户ID
        String userId = CmdContextUtils.getUserId(context);

        // 构建用户查询条件
        UserDto userDto = new UserDto();
        userDto.setUserId(userId);
        // 查询用户信息
        List<UserDto> userDtos = userV1InnerServiceSMOImpl.queryUsers(userDto);

        // 验证用户信息，确保用户已登录且唯一
        Assert.listOnlyOne(userDtos, "用户未登录");

        // 将请求参数转换为报修DTO对象
        RepairDto ownerRepairDto = BeanConvertUtil.covertBean(reqJson, RepairDto.class);

        // 设置查询条件中的电话号码为当前用户的电话号码
        ownerRepairDto.setTel(userDtos.get(0).getTel());
        // 如果请求中包含报修状态参数，设置状态查询条件
        if (reqJson.containsKey("repairStates")) {
            String[] states = reqJson.getString("repairStates").split(",");
            ownerRepairDto.setStatess(states);
        }

        // 查询符合条件的报修记录总数
        int count = repairInnerServiceSMOImpl.queryRepairsCount(ownerRepairDto);
        List<RepairDto> repairDtos;
        
        // 如果有查询结果，获取报修列表并计算评分
        if (count > 0) {
            repairDtos = repairInnerServiceSMOImpl.queryRepairs(ownerRepairDto);
            computeRepairScore(repairDtos);
        } else {
            // 没有查询结果时返回空列表
            repairDtos = new ArrayList<>();
        }
        
        // 构建响应实体，包含分页信息和查询结果
        ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(
                (int) Math.ceil((double) count / (double) reqJson.getInteger("row")), // 计算总页数
                count, // 总记录数
                repairDtos // 报修数据列表
        );
        context.setResponseEntity(responseEntity);
    }

    /**
     * 计算报修评分方法
     * 
     * 对报修记录进行综合评分计算，包括：
     * 1. 综合评分、上门速度评分、维修员服务评分的计算和格式化
     * 2. 平均分的计算和四舍五入处理
     * 3. 处理时长计算和超时判断
     * 
     * @param repairDtos 报修数据对象列表
     */
    private void computeRepairScore(List<RepairDto> repairDtos) {
        // 如果报修列表为空，直接返回
        if (ListUtil.isNull(repairDtos)) {
            return;
        }
        
        Date finishTime = null;
        String submitHour;
        Date timeout = null;
        
        // 遍历所有报修记录，逐条计算评分
        for (RepairDto repairDto : repairDtos) {
            // 获取综合评价得分并转换为整数（向上取整）
            String appraiseScoreNumber = repairDto.getAppraiseScore();
            Double appraiseScoreNum = 0.0;
            if (!StringUtil.isEmpty(appraiseScoreNumber)) {
                appraiseScoreNum = Double.parseDouble(appraiseScoreNumber);
            }
            int appraiseScore = (int) Math.ceil(appraiseScoreNum);
            
            // 获取上门速度评分并转换为整数（向上取整）
            String doorSpeedScoreNumber = repairDto.getDoorSpeedScore();
            Double doorSpeedScoreNum = 0.0;
            if (!StringUtil.isEmpty(doorSpeedScoreNumber)) {
                doorSpeedScoreNum = Double.parseDouble(doorSpeedScoreNumber);
            }
            int doorSpeedScore = (int) Math.ceil(doorSpeedScoreNum);
            
            // 获取维修员服务评分并转换为整数（向上取整）
            String repairmanServiceScoreNumber = repairDto.getRepairmanServiceScore();
            Double repairmanServiceScoreNum = 0.0;
            if (!StringUtil.isEmpty(repairmanServiceScoreNumber)) {
                repairmanServiceScoreNum = Double.parseDouble(repairmanServiceScoreNumber);
            }
            int repairmanServiceScore = (int) Math.ceil(repairmanServiceScoreNum);
            
            // 计算三个评分的平均值，保留两位小数（四舍五入）
            double averageNumber = (appraiseScoreNum + doorSpeedScoreNum + repairmanServiceScoreNum) / 3.0;
            BigDecimal averageNum = new BigDecimal(averageNumber);
            Double average = averageNum.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
            
            // 将计算后的评分设置回报修对象
            repairDto.setAppraiseScore(String.valueOf(appraiseScore));
            repairDto.setDoorSpeedScore(String.valueOf(doorSpeedScore));
            repairDto.setRepairmanServiceScore(String.valueOf(repairmanServiceScore));
            repairDto.setAverage(String.valueOf(average));

            // 计算提单时长和处理超时判断
            finishTime = DateUtil.getCurrentDate(); // 获取当前时间作为完成时间
            repairDto.setTimeoutFlag("N"); // 默认设置为未超时
            
            // 如果报修记录有完成时间，使用完成时间计算
            if (!StringUtil.isEmpty(repairDto.getFinishTime())) {
                finishTime = DateUtil.getDateFromStringA(repairDto.getFinishTime());
            } else {
                // 如果没有完成时间，判断是否超时
                timeout = DateUtil.getDateFromStringA(repairDto.getTimeout());
                // 如果当前时间超过超时时间，标记为超时
                if (finishTime.getTime() > timeout.getTime()) {
                    repairDto.setStateName(repairDto.getStateName() + "(超时)");
                    repairDto.setTimeoutFlag("Y");
                }
            }
            
            // 计算从创建时间到完成时间的时长差
            submitHour = DateUtil.calculateTimeDifference(repairDto.getCreateTime(), finishTime);
            repairDto.setSubmitHours(submitHour);
        }
    }
}