package com.ruoyi.web.controller.manage;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.ruoyi.buss.common.RfidUtil;
import com.ruoyi.buss.domain.vo.RfIdVo;
import com.ruoyi.common.config.RuoYiConfig;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.core.page.TableDataInfo;
import com.ruoyi.manage.domain.*;
import com.ruoyi.manage.service.DpBerthService;
import com.ruoyi.manage.service.DpShipTypeService;
import com.ruoyi.manage.service.DpShipsService;
import com.ruoyi.manage.service.DsTaskListService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

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

/**
 * <p>
 * 任务分配详情表 前端控制器
 * </p>
 *
 * @author sunjiawei
 * @since 2025-03-24
 */
@RestController
@RequestMapping("/dp/dsTaskList")
@Tag(name = "大屏--任务分配详情")
public class DsTaskListController {
    @Autowired
    private DsTaskListService dsTaskListService;
    @Autowired
    private DpShipsService dpShipsService;
    @Autowired
    private DpShipTypeService dpShipTypeService;
    @Autowired
    private DpBerthService dpBerthService;
    @Autowired
    private RuoYiConfig ruoYiConfig;


    @GetMapping("/list")
    @Operation(summary = "任务分配详情列表")
    public AjaxResult getList(){
        return AjaxResult.success(dsTaskListService.list());
    }



    @GetMapping("/pageList")
    @Operation(summary = "任务分配详情分页列表")
    public TableDataInfo getPageList(DsTaskList dsTaskList) {
        return dsTaskListService.getPageList(dsTaskList);
    }

    @GetMapping("/pageListDaily")
    @Operation(summary = "日常任务分配详情分页列表")
    public TableDataInfo pageListDaily(DsTaskList dsTaskList) {
        return dsTaskListService.getPageListDaily(dsTaskList);
    }


    @GetMapping(value = "/{id}")
    @Operation(summary = "获取任务分配详情详细信息")
    public AjaxResult getInfo(@PathVariable("id") Integer pkid)
    {
        return AjaxResult.success(dsTaskListService.getById(pkid));
    }


    @Operation(summary = "群组新增")
    @PostMapping
    public AjaxResult add(@RequestBody DsTaskList dsTaskList)
    {
        return AjaxResult.success(dsTaskListService.save(dsTaskList));
    }

    @Operation(summary = "日常新增")
    @PostMapping(value = "/dailyAdd")
    public AjaxResult dailyAdd(@RequestBody DsTaskList dsTaskList,
                               @RequestParam(value = "lon") Double lon,
                               @RequestParam(value = "lat") Double lat,
                               @RequestParam(value = "alt") Double alt,
                               @RequestParam(value = "heading") Double heading)
    {
        String shipType = dsTaskList.getShipType();
        LambdaQueryWrapper<DpShipType> shipTypeWrapper = new LambdaQueryWrapper<>();
        shipTypeWrapper.eq(DpShipType::getShipDesign,shipType);
        DpShipType dpShipType = dpShipTypeService.getOne(shipTypeWrapper);
        Integer shipTypeId = dpShipType.getId();
        Integer whId = dsTaskList.getHarborId().intValue();
        Integer beId = dsTaskList.getBerthId().intValue();
        String shipId = dsTaskList.getShipNo();

        DpShips dpShip = new DpShips();
        dpShip.setShipTypeId(shipTypeId);
        dpShip.setWhId(whId);
        dpShip.setBeId(beId);
        dpShip.setShipId(shipId);
        dpShip.setShipName(shipId);
        dpShip.setLon(lon);
        dpShip.setLat(lat);
        dpShip.setAlt(alt);
        dpShip.setHeading(heading);

        DmBerth dmBerth =dpBerthService.getById(beId);
        String path = dmBerth.getPath();

        boolean taskListRes = dsTaskListService.save(dsTaskList);
        if(taskListRes){
            List<RfIdVo> list = new ArrayList<>();
            RfIdVo rfIdVo = new RfIdVo();
            rfIdVo.setId((999+Integer.parseInt(shipId)));
            rfIdVo.setName(String.valueOf(999+Integer.parseInt(shipId)));
            rfIdVo.setPath(path);
            list.add(rfIdVo);
            RfidUtil.sendJsonPost(ruoYiConfig.getBussRfidUrl(),list.toString());
        }
        boolean shipRes = dpShipsService.save(dpShip);
        if(taskListRes && shipRes){
            return AjaxResult.success();
        }else {
            return AjaxResult.error();
        }

    }


    @Operation(summary = "修改")
    @PutMapping
    public AjaxResult edit(@RequestBody DsTaskList dsTaskList)
    {
        return AjaxResult.success(dsTaskListService.updateById(dsTaskList));
    }


    @Operation(summary = "删除")
    @DeleteMapping("/{pkid}")
    public AjaxResult remove(@PathVariable Integer pkid)
    {
        return AjaxResult.success(dsTaskListService.removeById(pkid));
    }

    @Operation(summary = "日常任务删除")
    @DeleteMapping("/deleteDaily/{pkid}")
    public AjaxResult deleteDaily(@PathVariable Integer pkid)
    {
        DsTaskList dsTaskList = dsTaskListService.getById(pkid);
        LambdaQueryWrapper<DpShips> lambdaQueryWrapper = new LambdaQueryWrapper<>();
        lambdaQueryWrapper.eq(DpShips::getShipId,dsTaskList.getShipNo());
        boolean shipRes = dpShipsService.remove(lambdaQueryWrapper);
        boolean taskRes = dsTaskListService.removeById(pkid);
        if(shipRes && taskRes){
            return AjaxResult.success();
        }else {
            return AjaxResult.error();
        }

    }

    @GetMapping(value = "/getByBeId")
    @Operation(summary = "根据泊位ID获取任务分配详情")
    public R<DsTaskList> getByBeId(@RequestParam("beId") Integer beId)
    {
        LambdaQueryWrapper<DsTaskList> lambdaQueryWrapper = new LambdaQueryWrapper();
        lambdaQueryWrapper.eq(DsTaskList::getBerthId,beId)
                .eq(DsTaskList::getTaskId,999)
                .orderByDesc(DsTaskList::getCreateTime)
                .last("LIMIT 1");
        return R.ok(dsTaskListService.getOne(lambdaQueryWrapper));
    }

}