package cn.besteam.modules.medical.controller;

import java.io.IOException;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import cn.besteam.modules.medical.dto.MwWasteWaterDetailDto;
import cn.besteam.modules.medical.dto.MwWasteWaterDto;
import cn.besteam.modules.medical.dto.MwWasteWaterReportDto;
import cn.besteam.modules.medical.dto.MwWasteWaterSeacherDto;
import cn.besteam.modules.medical.vo.WasteWaterVo;
import cn.besteam.modules.report.dto.ReportDTO;
import cn.besteam.modules.report.vo.WasteWaterReportVo;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import cn.besteam.common.api.vo.Result;
import cn.besteam.common.aspect.annotation.AutoLog;
import cn.besteam.common.util.oConvertUtils;
import cn.besteam.modules.medical.entity.MwWasteWater;
import cn.besteam.modules.medical.service.IMwWasteWaterService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.extern.slf4j.Slf4j;

 /**
 * @Title: Controller
 * @Description: 废水
 * @author： besteam
 * @date：   2022-09-04
 * @version： V1.0
 */
@RestController
@RequestMapping("/medical/mwWasteWater")
@Slf4j
@Api(description = "废水")
public class MwWasteWaterController {

	@Autowired
	private IMwWasteWaterService mwWasteWaterService;

	 @GetMapping("/exportReport")
	 @ApiOperation(value = "导出报表")
	 public void exportReport(HttpServletResponse response, MwWasteWaterReportDto dto) throws Exception {

		 mwWasteWaterService.exportReport(response, dto);
	 }

	 @GetMapping("/getWasteWaterReportList")
	 @ApiOperation("废水统计")
	 public Result<WasteWaterReportVo> getWasteWaterReportList(MwWasteWaterReportDto dto) {

		 return Result.ok(mwWasteWaterService.getWasteWaterReportList(dto));
	 }

	 @GetMapping("/getWasteWaterList")
	 @ApiOperation("废水统计-列表")
	 public Result<WasteWaterReportVo> getWasteWaterList(MwWasteWaterReportDto dto) {

		 return Result.ok(mwWasteWaterService.getWasteWaterList(dto));
	 }

	 @GetMapping(value = "/list")
	 @ApiOperation(value = "获取数据监控列表", notes = "获取数据监控列表", produces = "application/json")
	 public Result<IPage<WasteWaterVo>> list(MwWasteWaterSeacherDto dto, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {
		 IPage<WasteWaterVo> pageList = mwWasteWaterService.queryPageList(pageNo, pageSize, dto);
		 return Result.ok(pageList);
	 }

	
	/**
	  *   添加
	 * @param dto
	 * @return
	 */
	@PostMapping(value = "/add")
	@AutoLog(value = "添加废水")
	@ApiOperation(value = "添加废水", notes = "添加废水", produces = "application/json")
	public Result<MwWasteWater> add(@RequestBody MwWasteWaterDto dto) {

		Result<MwWasteWater> result = new Result<MwWasteWater>();
		try {
			Integer number = mwWasteWaterService.count(new QueryWrapper<MwWasteWater>().lambda().eq(MwWasteWater::getEquipmentnumber,dto.getEquipmentNumber()).eq(MwWasteWater::getDatetime,dto.getDateTime()));
			if(number<=0){
				for(MwWasteWaterDetailDto detailDto:dto.getData()){
					MwWasteWater mwWasteWater = new MwWasteWater();
					mwWasteWater.setId(null);
					mwWasteWater.setRequestnumber(dto.getRequestNumber());
					mwWasteWater.setSystemcode(dto.getSystemCode());
					mwWasteWater.setCommandcode(dto.getCommandCode());
					mwWasteWater.setPassword(dto.getPassword());
					mwWasteWater.setEquipmentnumber(dto.getEquipmentNumber());
					mwWasteWater.setDatetime(dto.getDateTime());
					mwWasteWater.setCode(detailDto.getCode());
					mwWasteWater.setTotalnum(detailDto.getTotal());
					mwWasteWater.setMinnum(detailDto.getMin());
					mwWasteWater.setMaxnum(detailDto.getMax());
					mwWasteWater.setAvgnum(detailDto.getAvg());
					mwWasteWater.setFlagnum(detailDto.getFlag());
					mwWasteWaterService.save(mwWasteWater);
				}

			}
			result.success("添加成功！");
		} catch (Exception e) {
			log.error("", e);
			result.error500("操作失败");
		}
		return result;
	}



}