package com.ruoyi.web.controller.fuzhou;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.fuzhou.domain.*;
import com.ruoyi.fuzhou.domain.vo.ReceiveValueListVo;
import com.ruoyi.fuzhou.enums.DataTypeEnum;
import com.ruoyi.fuzhou.service.*;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import java.util.ArrayList;
import java.util.List;

/**
 * <p>
 * 数据接收信息 前端控制器
 * </p>
 *
 * @author zhangyy
 * @since 2025-03-10
 */
@Tag(name = "设备数据管理")
@RestController
@RequestMapping("/dp/receiveInfo")
public class ReceiveInfoController {

    @Resource
    private EquipmentService equipmentService;

    @Resource
    private ReceiveOilValueService receiveOilValueService;

    @Resource
    private ReceiveWaterValueService receiveWaterValueService;

    @Resource
    private ReceiveWaterInfoService receiveWaterInfoService;

    @Resource
    private ReceiveOilInfoService receiveOilInfoService;

    @Resource
    private ReceiveElectricityInfoService receiveElectricityInfoService;
    @Resource
    private ReceiveWeatherInfoService receiveWeatherInfoService;
    @Resource
    private ReceiveWeatherValueService receiveWeatherValueService;

    @Resource
    private ReceiveSlmInfoService receiveSlmInfoService;

    @Resource
    private ReceiveSlmValueService receiveSlmValueService;

    @Resource
    private ReceiveElectricityValueService receiveElectricityValueService;

    @Resource
    private ReceiveCarRuleService receiveCarRuleService;

    @Resource
    private ReceiveCarValueService receiveCarValueService;

    @Operation(summary = "设备列表列表")
    @GetMapping("/list")
    public R<List<DpEquipment>> list(@RequestParam(value = "deviceType", required = false) Integer deviceType) {
        return R.ok(equipmentService.list(new LambdaQueryWrapper<DpEquipment>() {{
            or().eq(DpEquipment::getEquipmentTypeId, deviceType);
        }}));
    }

    @Operation(summary = "获取设备数据")
    @PostMapping("/dataList")
    public R<List> dataList(@Validated @RequestBody ReceiveValueListVo vo) {
        DpEquipment receiveInfo = equipmentService.getById(vo.getId());
        if (receiveInfo == null) {
            throw new ServiceException("设备不存在！");
        }
        if (DataTypeEnum.LIJIUOIL.getCode().equals(receiveInfo.getEquipmentTypeId()) || DataTypeEnum.OIL.getCode().equals(receiveInfo.getEquipmentTypeId()) ||
                DataTypeEnum.LIJIUJUN.getCode().equals(receiveInfo.getEquipmentTypeId()) || DataTypeEnum.NIGDETUIYOU.getCode().equals(receiveInfo.getEquipmentTypeId())) {
            return R.ok(receiveOilValueService.list(new LambdaQueryWrapper<ReceiveOilValue>() {{
                or().eq(ReceiveOilValue::getDeviceName, String.valueOf(receiveInfo.getId()))
                        .ge(vo.getStartTime() != null, ReceiveOilValue::getCreateTime, vo.getStartTime())
                        .lt(vo.getEndTime() != null, ReceiveOilValue::getCreateTime, vo.getEndTime())
                        .orderByDesc(ReceiveOilValue::getCreateTime);
            }}));
        } else if (DataTypeEnum.WATER_FLOW.getCode().equals(receiveInfo.getEquipmentTypeId()) || DataTypeEnum.WATER_YA.getCode().equals(receiveInfo.getEquipmentTypeId())
                || DataTypeEnum.WATER_DEPT.getCode().equals(receiveInfo.getEquipmentTypeId())) {
            return R.ok(receiveWaterValueService.list(new LambdaQueryWrapper<ReceiveWaterValue>() {{
                or().eq(ReceiveWaterValue::getDeviceName, String.valueOf(receiveInfo.getId()))
                        .ge(vo.getStartTime() != null, ReceiveWaterValue::getCreateTime, vo.getStartTime())
                        .lt(vo.getEndTime() != null, ReceiveWaterValue::getCreateTime, vo.getEndTime())
                        .orderByDesc(ReceiveWaterValue::getCreateTime);
            }}));
        } else if (DataTypeEnum.ELECTRICITY.getCode().equals(receiveInfo.getEquipmentTypeId())) {
            return R.ok(receiveElectricityValueService.list(new LambdaQueryWrapper<ReceiveElectricityValue>() {{
                or().eq(ReceiveElectricityValue::getDeviceName, String.valueOf(receiveInfo.getId()))
                        .ge(vo.getStartTime() != null, ReceiveElectricityValue::getCreateTime, vo.getStartTime())
                        .lt(vo.getEndTime() != null, ReceiveElectricityValue::getCreateTime, vo.getEndTime())
                        .orderByDesc(ReceiveElectricityValue::getCreateTime);
            }}));
        } else if (DataTypeEnum.GONGKUANG.getCode().equals(receiveInfo.getEquipmentTypeId())) {
            return R.ok(receiveCarValueService.list(new LambdaQueryWrapper<ReceiveCarValue>() {{
                or().eq(ReceiveCarValue::getVin, receiveInfo.getEquCode())
                        .ge(vo.getStartTime() != null, ReceiveCarValue::getCreateTime, vo.getStartTime())
                        .lt(vo.getEndTime() != null, ReceiveCarValue::getCreateTime, vo.getEndTime())
                        .orderByDesc(ReceiveCarValue::getCreateTime);
            }}));
        }else if (DataTypeEnum.WEATHER.getCode().equals(receiveInfo.getEquipmentTypeId())) {
            return R.ok(receiveWeatherValueService.list(new LambdaQueryWrapper<ReceiveWeatherValue>() {{
                or().eq(ReceiveWeatherValue::getDeviceName, receiveInfo.getId())
                        .ge(vo.getStartTime() != null, ReceiveWeatherValue::getCreateTime, vo.getStartTime())
                        .lt(vo.getEndTime() != null, ReceiveWeatherValue::getCreateTime, vo.getEndTime())
                        .orderByDesc(ReceiveWeatherValue::getCreateTime);
            }}));
        }else if (DataTypeEnum.SLM.getCode().equals(receiveInfo.getEquipmentTypeId())) {
            return R.ok(receiveSlmValueService.list(new LambdaQueryWrapper<ReceiveSlmValue>() {{
                or().eq(ReceiveSlmValue::getDeviceName, receiveInfo.getId())
                        .ge(vo.getStartTime() != null, ReceiveSlmValue::getCreateTime, vo.getStartTime())
                        .lt(vo.getEndTime() != null, ReceiveSlmValue::getCreateTime, vo.getEndTime())
                        .orderByDesc(ReceiveSlmValue::getCreateTime);
            }}));
        }
        return R.ok(new ArrayList());
    }

    @Operation(summary = "获取设备数据表头")
    @GetMapping("/tableList")
    public R<List> tableList(@RequestParam("id") Long id) {
        DpEquipment receiveInfo = equipmentService.getById(id);
        if (receiveInfo == null) {
            throw new ServiceException("设备不存在！");
        }
        if (DataTypeEnum.LIJIUOIL.getCode().equals(receiveInfo.getEquipmentTypeId()) || DataTypeEnum.OIL.getCode().equals(receiveInfo.getEquipmentTypeId()) ||
                DataTypeEnum.LIJIUJUN.getCode().equals(receiveInfo.getEquipmentTypeId()) || DataTypeEnum.NIGDETUIYOU.getCode().equals(receiveInfo.getEquipmentTypeId())) {
            return R.ok(receiveOilInfoService.list(new LambdaQueryWrapper<ReceiveOilInfo>() {{
                or().select(ReceiveOilInfo::getParam, ReceiveOilInfo::getParamCode, ReceiveOilInfo::getUnit).eq(ReceiveOilInfo::getDeviceName, String.valueOf(receiveInfo.getId()));
            }}));
        } else if (DataTypeEnum.WATER_FLOW.getCode().equals(receiveInfo.getEquipmentTypeId()) || DataTypeEnum.WATER_YA.getCode().equals(receiveInfo.getEquipmentTypeId())
                || DataTypeEnum.WATER_DEPT.getCode().equals(receiveInfo.getEquipmentTypeId())) {
            return R.ok(receiveWaterInfoService.list(new LambdaQueryWrapper<ReceiveWaterInfo>() {{
                or().select(ReceiveWaterInfo::getParam, ReceiveWaterInfo::getParamCode, ReceiveWaterInfo::getUnit).eq(ReceiveWaterInfo::getDeviceName, String.valueOf(receiveInfo.getId()));
            }}));
        } else if (DataTypeEnum.ELECTRICITY.getCode().equals(receiveInfo.getEquipmentTypeId())) {
            return R.ok(receiveElectricityInfoService.list(new LambdaQueryWrapper<ReceiveElectricityInfo>() {{
                or().select(ReceiveElectricityInfo::getParam, ReceiveElectricityInfo::getParamCode, ReceiveElectricityInfo::getUnit).eq(ReceiveElectricityInfo::getDeviceName, String.valueOf(receiveInfo.getId()));
            }}));
        } else if (DataTypeEnum.GONGKUANG.getCode().equals(receiveInfo.getEquipmentTypeId())) {
            List<ReceiveElectricityInfo> receiveElectricityInfos = new ArrayList<>();
            List<ReceiveCarRule> list = receiveCarRuleService.list();
            ReceiveElectricityInfo electricityInfo;
            for (ReceiveCarRule rule : list
            ) {
                electricityInfo = new ReceiveElectricityInfo();
                electricityInfo.setUnit(rule.getUnit());
                electricityInfo.setParamCode(rule.getCarCode());
                electricityInfo.setParam(rule.getDataName());
                receiveElectricityInfos.add(electricityInfo);
            }
            return R.ok(receiveElectricityInfos);
        } else if (DataTypeEnum.WEATHER.getCode().equals(receiveInfo.getEquipmentTypeId())) {
            return R.ok(receiveWeatherInfoService.list(new LambdaQueryWrapper<ReceiveWeatherInfo>() {{
                or().select(ReceiveWeatherInfo::getParam, ReceiveWeatherInfo::getParamCode, ReceiveWeatherInfo::getUnit).eq(ReceiveWeatherInfo::getDeviceName, String.valueOf(receiveInfo.getId()));
            }}));
        } else if (DataTypeEnum.SLM.getCode().equals(receiveInfo.getEquipmentTypeId())) {
            return R.ok(receiveSlmInfoService.list(new LambdaQueryWrapper<ReceiveSlmInfo>() {{
                or().select(ReceiveSlmInfo::getParam, ReceiveSlmInfo::getParamCode, ReceiveSlmInfo::getUnit).eq(ReceiveSlmInfo::getDeviceName, String.valueOf(receiveInfo.getId()));
            }}));
        }
        return R.ok(new ArrayList());
    }


}