package com.ruoyi.web.controller.manage;

import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.*;

import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ruoyi.common.core.domain.model.LoginUser;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.fuzhou.domain.DpEquipment;
import com.ruoyi.fuzhou.domain.ReceiveSlmValueFinal;
import com.ruoyi.fuzhou.domain.ReceiveWaterValue;
import com.ruoyi.fuzhou.domain.vo.DpEquipmentVO;
import com.ruoyi.fuzhou.service.EquipmentService;
import com.ruoyi.fuzhou.service.ReceiveWaterValueService;
import com.ruoyi.manage.domain.DmBerth;
import com.ruoyi.manage.service.DpBerthService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.enums.BusinessType;
import com.ruoyi.manage.domain.DmHarbor;
import com.ruoyi.manage.service.IDmHarborService;
import com.ruoyi.common.utils.poi.ExcelUtil;
import com.ruoyi.common.core.page.TableDataInfo;

/**
 * 港口信息Controller
 * 
 * @author ruoyi
 * @date 2025-03-17
 */
@RestController
@RequestMapping("/dp/harbor")
@Tag(name = "大屏--港口管理")
public class DmHarborController extends BaseController
{
    @Autowired
    private IDmHarborService dmHarborService;
    @Autowired
    private DpBerthService dpBerthService;
    @Resource
    private EquipmentService dpEquipmentService;
    @Resource
    private ReceiveWaterValueService receiveWaterValueService;

    /**
     * 查询港口信息列表
     */
    @GetMapping("/list")
    @Operation(summary = "查询港口信息列表")
    public TableDataInfo list(DmHarbor dmHarbor)
    {

       return dmHarborService.getList(dmHarbor);
    }

    /**
     * 查询所有港口信息列表
     */
    @GetMapping("/listAll")
    @Operation(summary = "查询所有港口信息列表")
    public AjaxResult listAll()
    {
        return AjaxResult.success(dmHarborService.list());
    }

    /**
     * 查询所有港口信息列表
     */
    @GetMapping("/getListAll")
    @Operation(summary = "查询所有港口信息")
    public AjaxResult getListAll()
    {
        //获取用户信息根据部门ID查询港口信息
        LoginUser loginUser = SecurityUtils.getLoginUser();
        Long deptId = loginUser.getDeptId();
        if(deptId.equals(100L)){
            return AjaxResult.success(dmHarborService.list());
        }
        if(deptId.equals(4001L)){
            deptId = 101L;
        }
        if(deptId.equals(4002L)){
            deptId = 4000L;
        }
        QueryWrapper<DmHarbor> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("DEPT_ID",deptId);
        return AjaxResult.success(dmHarborService.list(queryWrapper));
    }

    /**
     * 查询港口及其泊位详情
     */
    @GetMapping("/getHarborBerth")
    @Operation(summary = "查询港口及其泊位详情")
    public AjaxResult getHarborBerth()
    {
        //获取用户信息根据部门ID查询港口信息
        LoginUser loginUser = SecurityUtils.getLoginUser();
        Long deptId = loginUser.getDeptId();
        List<DmHarbor> reslist = new ArrayList<>();
        if(deptId.equals(100L)){
            List<DmHarbor> list = dmHarborService.list();
            for (DmHarbor dmHarbor : list){
                LambdaQueryWrapper<DmBerth> berthQueryWrapper = new LambdaQueryWrapper<>();
                berthQueryWrapper.eq(DmBerth::getHarborId,dmHarbor.getPkId()).notIn(DmBerth::getName,"园区").orderByAsc(DmBerth::getOrderNum);
                List<DmBerth> dmBerths = dpBerthService.list(berthQueryWrapper);
                dmHarbor.setDmBerthList(dmBerths);
                reslist.add(dmHarbor);
            }
            return AjaxResult.success(reslist);
        }else {
            if(deptId.equals(4001L)){
                deptId = 101L;
            }
            QueryWrapper<DmHarbor> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("DEPT_ID",deptId);
            List<DmHarbor> list = dmHarborService.list(queryWrapper);
            for (DmHarbor dmHarbor : list){
                LambdaQueryWrapper<DmBerth> QueryWrapper = new LambdaQueryWrapper<>();
                QueryWrapper.eq(DmBerth::getHarborId,dmHarbor.getPkId()).notIn(DmBerth::getName,"园区").orderByAsc(DmBerth::getOrderNum);
                List<DmBerth> dmBerths = dpBerthService.list(QueryWrapper);
                dmHarbor.setDmBerthList(dmBerths);
                reslist.add(dmHarbor);
            }
            return AjaxResult.success(reslist);
        }
    }

    /**
     * 查询港口水深数据列表
     */
    @GetMapping("/getWaterDepthList")
    @Operation(summary = "查询港口水深数据列表")
    public AjaxResult getWaterDepthList() {
        //获取用户信息根据部门ID查询港口信息
        LoginUser loginUser = SecurityUtils.getLoginUser();
        Long deptId = loginUser.getDeptId();
        List<DpEquipmentVO> resList = new ArrayList<>();
        if(deptId.equals(100L)){
            List<DmHarbor> list = dmHarborService.list();
            return AjaxResult.success(getWaterDepth(list));
        }else {
            if(deptId.equals(4001L)){
                deptId = 101L;
            }
            QueryWrapper<DmHarbor> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("DEPT_ID",deptId);
            List<DmHarbor> list = dmHarborService.list(queryWrapper);
            return AjaxResult.success(getWaterDepth(list));
        }
    }

    /**
     * 查询港口水深数据列表
     */
    @GetMapping("/getWaterListByIds")
    @Operation(summary = "通过设备id查询水深数据列表")
    public AjaxResult getWaterListByIds(String ids) {

        LocalDate today=LocalDate.now();
        LocalDateTime startOfDay=today.atStartOfDay();
        LocalDateTime endOfDay=today.plusDays(1).atStartOfDay().minusSeconds(1);


        List<ReceiveWaterValue> result=receiveWaterValueService.list(new LambdaQueryWrapper<ReceiveWaterValue>() {{
            in(ReceiveWaterValue::getDeviceName,ids.split(","))
            .ge(ReceiveWaterValue::getCreateTime,startOfDay)
            .le(ReceiveWaterValue::getCreateTime,endOfDay);
        }});

        List<Map<String,Object>>res=new ArrayList<>();
        String[] idArray=ids.split(",");
        for (int i = 0; i < idArray.length; i++){
            Map<String,Object> map=new HashMap<>();
            map.put("id",idArray[i]);
            List<ReceiveWaterValue> ds=new ArrayList<>();
            for (int k = 0; k < result.size(); k++) {
                ReceiveWaterValue data=result.get(k);
                if(data.getDeviceName().equals(idArray[i])){
                    ds.add(data);
                }
            }
            map.put("data",ds);
            res.add(map);
        }

        return AjaxResult.success(res);
    }

    private JSONArray getWaterDepth(List<DmHarbor> list){
        List<DpEquipmentVO> resList = new ArrayList<>();
        for (DmHarbor dmHarbor : list){
            List<DpEquipmentVO> dpEquipmentVOS = dpEquipmentService.getListByWhId(dmHarbor.getPkId().intValue());
            for (DpEquipmentVO dpEquipmentVO : dpEquipmentVOS){
                if(dpEquipmentVO.getEquipmentTypeId()==7){
                    ReceiveWaterValue waterValue = receiveWaterValueService.getOne(new LambdaQueryWrapper<ReceiveWaterValue>() {{
                        eq(ReceiveWaterValue::getDeviceName, String.valueOf(dpEquipmentVO.getId()))
                                .orderByDesc(ReceiveWaterValue::getCreateTime).last("LIMIT 1");
                    }});
                    if(waterValue!=null){
                        dpEquipmentVO.setFieldName(waterValue.getWaterDeep());
                        resList.add(dpEquipmentVO);
                    }
                }
            }
        }
        JSONArray jsonArray = new JSONArray();
        for (DpEquipmentVO dpEquipmentVO : resList){
            JSONObject jsonObject = new JSONObject();
            jsonObject.put("equName",dpEquipmentVO.getEquName());
            jsonObject.put("waterDeep",dpEquipmentVO.getFieldName());
            jsonArray.add(jsonObject);
        }
        return jsonArray;
    }


    /**
     * 导出港口信息列表
     */
//    @PreAuthorize("@ss.hasPermi('system:harbor:export')")
//    @Log(title = "港口信息", businessType = BusinessType.EXPORT)
//    @PostMapping("/export")
//    public void export(HttpServletResponse response, DmHarbor2 dmHarbor)
//    {
//        List<DmHarbor2> list = dmHarborService.selectDmHarborList(dmHarbor);
//        ExcelUtil<DmHarbor2> util = new ExcelUtil<DmHarbor2>(DmHarbor2.class);
//        util.exportExcel(response, list, "港口信息数据");
//    }

    /**
     * 获取港口信息详细信息
     */
    @GetMapping("/{pkId}")
    @Operation(summary = "获取港口信息详细信息")
    public AjaxResult getInfo(@PathVariable("pkId") Long pkId)
    {
        return success(dmHarborService.getById(pkId));
    }

    /**
     * 新增港口信息
     */
    @Operation(summary = "新增港口信息")
    @PostMapping
    public AjaxResult add(@RequestBody DmHarbor dmHarbor)
    {
        return toAjax(dmHarborService.save(dmHarbor));
    }

    /**
     * 修改港口信息
     */
    @Operation(summary = "修改港口信息")
    @PutMapping
    public AjaxResult edit(@RequestBody DmHarbor dmHarbor)
    {
        return toAjax(dmHarborService.updateById(dmHarbor));
    }

    /**
     * 删除港口信息
     */
    @Operation(summary = "删除港口信息")
    @DeleteMapping("/{pkId}")
    public AjaxResult remove(@PathVariable Long pkId)
    {
        return toAjax(dmHarborService.removeById(pkId));
    }
}