/*
 *      Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
 *
 *  Redistribution and use in source and binary forms, with or without
 *  modification, are permitted provided that the following conditions are met:
 *
 *  Redistributions of source code must retain the above copyright notice,
 *  this list of conditions and the following disclaimer.
 *  Redistributions in binary form must reproduce the above copyright
 *  notice, this list of conditions and the following disclaimer in the
 *  documentation and/or other materials provided with the distribution.
 *  Neither the name of the dreamlu.net developer nor the names of its
 *  contributors may be used to endorse or promote products derived from
 *  this software without specific prior written permission.
 *  Author: Chill 庄骞 (smallchill@163.com)
 */
package org.springblade.modules.assessment.controller;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import lombok.AllArgsConstructor;
import org.springblade.core.boot.ctrl.BladeController;
import org.springblade.core.excel.util.ExcelUtil;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.core.secure.BladeUser;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.constant.BladeConstant;
import org.springblade.core.tool.utils.DateUtil;
import org.springblade.core.tool.utils.Func;
import org.springblade.modules.assessment.entity.AssessmentScoreEntity;
import org.springblade.modules.assessment.entity.AssessmentSetAssessorEntity;
import org.springblade.modules.assessment.entity.AssessmentSetEntity;
import org.springblade.modules.assessment.excel.AssessmentScoreExcel;
import org.springblade.modules.assessment.service.IAssessmentScoreService;
import org.springblade.modules.assessment.service.IAssessmentSetAssessorService;
import org.springblade.modules.assessment.service.IAssessmentSetService;
import org.springblade.modules.assessment.service.IAssessmentTaskService;
import org.springblade.modules.assessment.vo.AssessmentScoreVO;
import org.springblade.modules.assessment.wrapper.AssessmentScoreWrapper;
import org.springframework.web.bind.annotation.*;
import springfox.documentation.annotations.ApiIgnore;

import javax.servlet.http.HttpServletResponse;
import javax.validation.Valid;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 考核评分 控制器
 *
 * @author aix
 * @since 2023-12-13
 */
@RestController
@AllArgsConstructor
@RequestMapping("assessment/assessmentScore")
@Api(value = "考核评分", tags = "考核评分接口")
public class AssessmentScoreController extends BladeController {

	private final IAssessmentScoreService assessmentScoreService;
	private final IAssessmentSetService assessmentSetService;

	private final IAssessmentTaskService assessmentTaskService;

	private final IAssessmentSetAssessorService assessmentSetAssessorService;

	/**
	 * 考核评分 详情
	 */
	@GetMapping("/detail")
	@ApiOperationSupport(order = 1)
	@ApiOperation(value = "详情", notes = "传入assessmentScore")
	public R<AssessmentScoreVO> detail(AssessmentScoreEntity assessmentScore) {
		AssessmentScoreEntity detail = assessmentScoreService.getOne(Condition.getQueryWrapper(assessmentScore));
		return R.data(AssessmentScoreWrapper.build().entityVO(detail));
	}
	/**
	 * 考核评分 分页
	 */
	@GetMapping("/list")
	@ApiOperationSupport(order = 2)
	@ApiOperation(value = "分页", notes = "传入assessmentScore")
	public R<IPage<AssessmentScoreVO>> list(@ApiIgnore @RequestParam Map<String, Object> assessmentScore, Query query) {
		IPage<AssessmentScoreEntity> pages = assessmentScoreService.page(Condition.getPage(query), Condition.getQueryWrapper(assessmentScore, AssessmentScoreEntity.class));
		return R.data(AssessmentScoreWrapper.build().pageVO(pages));
	}

	@GetMapping("/listGroupByTask/{type}/{taskId}")
	@ApiOperation(value = "后台考核任务考核结果", notes = "传入要查询的任务id")
	public R listGroupByTask(@ApiIgnore @PathVariable Integer type,@PathVariable Long taskId, Query query, AssessmentScoreVO assessmentScore) {
//		QueryWrapper<AssessmentScoreEntity> setEntityQueryWrapper = new QueryWrapper<>();
//		setEntityQueryWrapper.select("id,assessment_task_id,be_id,score_user_id,SUM(weight*score_val*0.01) as score_val,type");
//		setEntityQueryWrapper.eq("type", type);
//		setEntityQueryWrapper.eq("assessment_task_id",taskId);
//		setEntityQueryWrapper.groupBy("be_id");
//		IPage<AssessmentScoreEntity> pages = assessmentScoreService.page(Condition.getPage(query),setEntityQueryWrapper);
		assessmentScore.setType(type);
		assessmentScore.setAssessmentTaskId(taskId);

		//增加根据登录用户部门筛选
		boolean isadmin = AuthUtil.isAdmin();
		if (!isadmin) {
			assessmentScore.setDeptId(AuthUtil.getDeptId());
		}

		IPage<AssessmentScoreEntity> pages = assessmentScoreService.selectAssessmentScoreGroupByBeidPage(Condition.getPage(query), assessmentScore);

		return R.data(AssessmentScoreWrapper.build().pageVO(pages));
	}

	@GetMapping("/listMyScore/{userId}")
	@ApiOperation(value = "我的得分列表", notes = "传入要查询的用户id")
	public R listMyScore(@ApiIgnore @PathVariable Long userId) {
		QueryWrapper<AssessmentSetEntity> setEntityQueryWrapper = new QueryWrapper<>();
		setEntityQueryWrapper.eq("user_id",userId);
		List<AssessmentSetEntity> assessmentSetEntities = assessmentSetService.list(setEntityQueryWrapper);

		List<Map<String,Object>> retList = new ArrayList<>();
		for (AssessmentSetEntity po:assessmentSetEntities) {

			Map<String,Object> map = new HashMap<>();
			map.put("assessmentSetVO", po.getAssessmentTaskId()); //被考核人
			map.put("assessmentTaskVO", assessmentTaskService.getById(po.getAssessmentTaskId())); //考核任务

			QueryWrapper<AssessmentSetAssessorEntity> assessmentSetAssessorEntityQueryWrapper = new QueryWrapper<>();
			assessmentSetAssessorEntityQueryWrapper.eq("assessment_set_id",po.getId());
			long userAssCount = assessmentSetAssessorService.count(assessmentSetAssessorEntityQueryWrapper);

			if (userAssCount > 0) {
//				已经考核数量 获取得分
				QueryWrapper<AssessmentScoreEntity> scoreEntityQueryWrapper = new QueryWrapper<>();
				scoreEntityQueryWrapper.eq("be_id",userId);
				scoreEntityQueryWrapper.eq("type", 0l);
				scoreEntityQueryWrapper.eq("assessment_task_id",po.getAssessmentTaskId());
				List<AssessmentScoreEntity> scoreEntityList = assessmentScoreService.list(scoreEntityQueryWrapper);
				double score = 0.0;
				for (AssessmentScoreEntity scoreEntity:scoreEntityList) {
					score += scoreEntity.getWeight() * scoreEntity.getScoreVal() * 0.01;
				}
				map.put("scoreVal", score);
				map.put("isAssessmentOk", userAssCount == scoreEntityList.size());
				retList.add(map);
			}

		}

		return R.data(retList);
//		QueryWrapper<AssessmentTaskEntity> taskEntityQueryWrapper = new QueryWrapper<>();
//		taskEntityQueryWrapper.eq("type", 0l);
//		List<AssessmentTaskEntity> assessmentTaskEntityList = assessmentTaskService.list(taskEntityQueryWrapper);
//		List<Map<String,Object>> retList = new ArrayList<>();
//		for (AssessmentTaskEntity po:assessmentTaskEntityList) {
//			Map<String,Object> map = new HashMap<>();
//
//			QueryWrapper<AssessmentSetAssessorEntity> setEntityQueryWrapper = new QueryWrapper<>();
//			setEntityQueryWrapper.eq("user_id",userId);
//			long userAssCount = assessmentSetAssessorService.count(setEntityQueryWrapper);
//			if (userAssCount > 0) {
//
//				map.put("assessmentTaskVO", po);
//
//				//已经考核数量 获取得分
//				QueryWrapper<AssessmentScoreEntity> scoreEntityQueryWrapper = new QueryWrapper<>();
//				scoreEntityQueryWrapper.eq("be_id",userId);
//				scoreEntityQueryWrapper.eq("type", 0l);
//				scoreEntityQueryWrapper.eq("assessment_task_id",po.getId());
//				List<AssessmentScoreEntity> scoreEntityList = assessmentScoreService.list(scoreEntityQueryWrapper);
//				double score = 0.0;
//				for (AssessmentScoreEntity scoreEntity:scoreEntityList) {
//					score += scoreEntity.getWeight() * scoreEntity.getScoreVal() * 0.01;
//				}
//				map.put("scoreVal", score);
//				map.put("isAssessmentOk", userAssCount == scoreEntityList.size());
//				retList.add(map);
//			}
//
//
//		}
//		return R.data(retList);
	}

	/**
	 * 考核评分 自定义分页
	 */
	@GetMapping("/page")
	@ApiOperationSupport(order = 3)
	@ApiOperation(value = "分页", notes = "传入assessmentScore")
	public R<IPage<AssessmentScoreVO>> page(AssessmentScoreVO assessmentScore, Query query) {
		IPage<AssessmentScoreVO> pages = assessmentScoreService.selectAssessmentScorePage(Condition.getPage(query), assessmentScore);
		return R.data(pages);
	}

	/**
	 * 考核评分 新增
	 */
	@PostMapping("/save")
	@ApiOperationSupport(order = 4)
	@ApiOperation(value = "新增", notes = "传入assessmentScore")
	public R save(@Valid @RequestBody AssessmentScoreEntity assessmentScore) {
		return R.status(assessmentScoreService.save(assessmentScore));
	}

	/**
	 * 考核评分 修改
	 */
	@PostMapping("/update")
	@ApiOperationSupport(order = 5)
	@ApiOperation(value = "修改", notes = "传入assessmentScore")
	public R update(@Valid @RequestBody AssessmentScoreEntity assessmentScore) {
		return R.status(assessmentScoreService.updateById(assessmentScore));
	}

	/**
	 * 考核评分 新增或修改
	 */
	@PostMapping("/submit")
	@ApiOperationSupport(order = 6)
	@ApiOperation(value = "新增或修改", notes = "传入assessmentScore")
	public R submit(@Valid @RequestBody AssessmentScoreEntity assessmentScore) {
		return R.status(assessmentScoreService.saveOrUpdate(assessmentScore));
	}

	/**
	 * 考核评分 删除
	 */
	@PostMapping("/remove")
	@ApiOperationSupport(order = 7)
	@ApiOperation(value = "逻辑删除", notes = "传入ids")
	public R remove(@ApiParam(value = "主键集合", required = true) @RequestParam String ids) {
		return R.status(assessmentScoreService.deleteLogic(Func.toLongList(ids)));
	}


	/**
	 * 导出数据
	 */
	@GetMapping("/export-assessmentScore")
	@ApiOperationSupport(order = 9)
	@ApiOperation(value = "导出数据", notes = "传入assessmentScore")
	public void exportAssessmentScore(@ApiIgnore @RequestParam Map<String, Object> assessmentScore, BladeUser bladeUser, HttpServletResponse response) {
		QueryWrapper<AssessmentScoreEntity> queryWrapper = Condition.getQueryWrapper(assessmentScore, AssessmentScoreEntity.class);
		//if (!AuthUtil.isAdministrator()) {
		//	queryWrapper.lambda().eq(AssessmentScore::getTenantId, bladeUser.getTenantId());
		//}
		queryWrapper.lambda().eq(AssessmentScoreEntity::getIsDeleted, BladeConstant.DB_NOT_DELETED);
		List<AssessmentScoreExcel> list = assessmentScoreService.exportAssessmentScore(queryWrapper);
		ExcelUtil.export(response, "考核评分数据" + DateUtil.time(), "考核评分数据表", list, AssessmentScoreExcel.class);
	}

}