package org.jeecg.modules.demo.bussMapQuery.controller;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.jeecg.common.api.vo.Result;
import org.jeecg.common.api.CommonAPI;
import org.jeecg.common.aspect.annotation.AutoLog;
import org.jeecg.modules.demo.hzz.axgh.axghgnq.entity.Lskzx;
import org.jeecg.modules.demo.hzz.axgh.axghgnq.entity.RmAxghgnqgeo;
import org.jeecg.modules.demo.hzz.axgh.axghgnq.entity.Wykzx;
import org.jeecg.modules.demo.hzz.axgh.axghgnq.service.ILskzxService;
import org.jeecg.modules.demo.hzz.axgh.axghgnq.service.IRmAxghgnqgeoService;
import org.jeecg.modules.demo.hzz.axgh.axghgnq.service.IWykzxService;
import org.jeecg.modules.demo.hzz.hhhj.glfwx.entity.RmHhglfwx;
import org.jeecg.modules.demo.hzz.hhhj.glfwx.service.IRmHhglfwxService;
import org.jeecg.modules.demo.hzz.hhhj.gsp.entity.RmBulletinBoard;
import org.jeecg.modules.demo.hzz.hhhj.gsp.service.IRmBulletinBoardService;
import org.jeecg.modules.demo.hzz.hhhj.hdzhx.entity.Hdzhx;
import org.jeecg.modules.demo.hzz.hhhj.hdzhx.service.IHdzhxService;
import org.jeecg.modules.demo.hzz.hhhj.jzd.entity.RmBoundaryMarker;
import org.jeecg.modules.demo.hzz.hhhj.jzd.service.IRmBoundaryMarkerService;
import org.jeecg.modules.demo.hzz.shjsgc.bzgc.entity.RmBzgc;
import org.jeecg.modules.demo.hzz.shjsgc.bzgc.geo.service.IRmBzgcgeoService;
import org.jeecg.modules.demo.hzz.shjsgc.bzgc.service.IRmBzgcService;
import org.jeecg.modules.demo.hzz.shjsgc.dfgc.entity.RmDfgc;
import org.jeecg.modules.demo.hzz.shjsgc.dfgc.geo.service.IRmDfgcgeoService;
import org.jeecg.modules.demo.hzz.shjsgc.dfgc.service.IRmDfgcService;
import org.jeecg.modules.demo.hzz.shjsgc.shxmxx.entity.RmShxmxxb;
import org.jeecg.modules.demo.hzz.shjsgc.shxmxx.service.IRmShxmxxbService;
import org.jeecg.modules.demo.hzz.shjsgc.xmrk.entity.RmAxshbfgcxxb;
import org.jeecg.modules.demo.hzz.shjsgc.xmrk.entity.RmAxxmxx;
import org.jeecg.modules.demo.hzz.shjsgc.xmrk.service.IRmAxshbfgcxxbService;
import org.jeecg.modules.demo.hzz.shjsgc.xmrk.service.IRmAxxmxxService;
import org.jeecg.modules.demo.hzz.shjsgc.zbgc.entity.RmZbgc;
import org.jeecg.modules.demo.hzz.shjsgc.zbgc.geo.service.IRmZbgcgeoService;
import org.jeecg.modules.demo.hzz.shjsgc.zbgc.service.IRmZbgcService;
import org.jeecg.modules.demo.hzz.video.entity.RmVideogeo;
import org.jeecg.modules.demo.hzz.video.service.IRmVideogeoService;
import org.jeecg.modules.demo.hzz.xzqh.cjxzq.entity.Cjxzq;
import org.jeecg.modules.demo.hzz.xzqh.cjxzq.service.ICjxzqService;
import org.jeecg.modules.demo.hzz.xzqh.xjxzq.entity.Xjxzq;
import org.jeecg.modules.demo.hzz.xzqh.xjxzq.service.IXjxzqService;
import org.jeecg.modules.demo.hzz.xzqh.zjxzq.entity.Zjxzq;
import org.jeecg.modules.demo.hzz.xzqh.zjxzq.service.IZjxzqService;
import org.jetbrains.annotations.Contract;
import org.jetbrains.annotations.NotNull;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;



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

@RestController
@RequestMapping("/bussMapQueryController")
@Slf4j
public class BussMapQueryConrtroller {
    @Autowired
    private IRmHhglfwxService rmHhglfwxService;
    @Autowired
    private IRmBulletinBoardService rmBulletinBoardService;
    @Autowired
    private IRmBoundaryMarkerService rmBoundaryMarkerService;
    @Autowired
    private IRmAxghgnqgeoService rmAxghgnqgeoService;
    @Autowired
    private IRmAxshbfgcxxbService rmAxshbfgcxxbService;
    @Autowired
    private IWykzxService wykzxService;
    @Autowired
    private ILskzxService lskzxService;
    @Autowired
    private IRmShxmxxbService rmShxmxxbService;
    @Autowired
    private IRmAxxmxxService rmAxxmxxService;
    @Autowired
    private IRmVideogeoService rmVideogeoService;
    @Autowired
    private ICjxzqService cjxzqService;
    @Autowired
    private IZjxzqService zjxzqService;
    @Autowired
    private IXjxzqService xjxzqService;
    @Autowired
    private IHdzhxService hdzhxService;
    @Autowired
    private CommonAPI commonAPI;


    @AutoLog(value = "划界信息查询")
    @ApiOperation(value="划界信息查询", notes="划界信息查询")
    @GetMapping(value = "/queryByHjInfo")
    public Result<?> queryByHjInfo(@RequestParam(name = "queryInfo", required = true) String queryInfo,
                                   @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
                                   @RequestParam(name="pageSize", defaultValue="10") Integer pageSize) {
        List<QueryRecord> queryRecords = new ArrayList<>();

        LambdaQueryWrapper<RmHhglfwx> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.like(RmHhglfwx::getName, queryInfo).or().like(RmHhglfwx::getRvcd, queryInfo);
        List<RmHhglfwx> rmGlfwxList = rmHhglfwxService.list(queryWrapper);
        if(rmGlfwxList.size()>0){
            for(int i=0;i<rmGlfwxList.size();i++){
                RmHhglfwx rmHhglfwx = rmGlfwxList.get(i);
                QueryRecord queryRecord = new QueryRecord();
                queryRecord.setId(rmHhglfwx.getId().toString());
                queryRecord.setName(rmHhglfwx.getName());
                queryRecord.setLayerName("管理范围线");
                queryRecord.setOtherInfo(rmHhglfwx.getAreaName());
                queryRecord.setGeoinfo(rmHhglfwx.getGeoinfo());
                queryRecords.add(queryRecord);
            }
        }

        LambdaQueryWrapper<RmBoundaryMarker> jzdQueryWapper = new LambdaQueryWrapper<>();
        jzdQueryWapper.eq(RmBoundaryMarker::getJzbh, queryInfo);
        List<RmBoundaryMarker> rmBoundaryMarkerList = rmBoundaryMarkerService.list(jzdQueryWapper);
        if(rmBoundaryMarkerList.size()>0){
            for(int i=0;i<rmBoundaryMarkerList.size();i++){
                RmBoundaryMarker rmBoundaryMarker = rmBoundaryMarkerList.get(i);
                QueryRecord queryRecord = new QueryRecord();
                queryRecord.setId(rmBoundaryMarker.getId());
                queryRecord.setName(rmBoundaryMarker.getJzbh()+"-"+rmBoundaryMarker.getHlmc());
                queryRecord.setLayerName("界桩点");
                queryRecord.setOtherInfo(rmBoundaryMarker.getDmdz());
                queryRecord.setGeoinfo(rmBoundaryMarker.getGeoinfo());
                queryRecords.add(queryRecord);
            }
        }

        LambdaQueryWrapper<RmBulletinBoard> ggpQueryWrapper = new LambdaQueryWrapper<>();
        ggpQueryWrapper.eq(RmBulletinBoard::getGspbm, queryInfo);
        List<RmBulletinBoard> rmBulletinBoardList = rmBulletinBoardService.list(ggpQueryWrapper);
        if(rmBulletinBoardList.size()>0){
            for(int i=0;i<rmBulletinBoardList.size();i++){
                RmBulletinBoard rmBulletinBoard = rmBulletinBoardList.get(i);
                QueryRecord queryRecord = new QueryRecord();
                queryRecord.setId(rmBulletinBoard.getId());
                queryRecord.setName(rmBulletinBoard.getGspbm()+"-"+rmBulletinBoard.getHlmc());
                queryRecord.setLayerName("公告牌");
                queryRecord.setOtherInfo(rmBulletinBoard.getSzwz());
                queryRecord.setGeoinfo(rmBulletinBoard.getGeoinfo());
                queryRecords.add(queryRecord);
            }
        }

        QueryResult queryResult = new QueryResult();
        queryResult.setRecords(getListpaging(queryRecords,pageNo,pageSize));
        queryResult.setCurrent(pageNo);
        queryResult.setSize(pageSize);
        queryResult.setTotal(queryRecords.size());
        return Result.OK(queryResult);
    }

    private static List getListpaging(List list, int pageNo, int pageSize){
        if(list == null || list.size() <= 0){
            return new ArrayList<>(0);
        }
        //开始下标
        int startIndex = (pageNo - 1) * pageSize;
        //结束下标 subList()方法不包含结束下标的元素
        int endIndex = pageNo * pageSize;
        //list总条数
        int total = list.size();
        //总页数
        int pageCount = 0;
        //通过取余决定是否给总页数加1
        int num = total % pageSize;
        if (num == 0) {
            pageCount = total / pageSize;
        } else {
            pageCount = total / pageSize + 1;
        }
        //如果当前页是最后一页的话 要包含集合的最后一条数据，因为sublist方法本身结束的下标是不包含当前元素的
        if (pageNo == pageCount) {
            endIndex = total;
        }
        return list.subList(startIndex, endIndex);
    }

    @AutoLog(value = "岸线规划信息查询")
    @ApiOperation(value="岸线规划信息查询", notes="岸线规划信息查询")
    @GetMapping(value = "/queryByAxghInfo")
    public Result<?> queryByAxghInfo(@RequestParam(name = "queryInfo", required = true) String queryInfo,
                                     @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
                                     @RequestParam(name="pageSize", defaultValue="10") Integer pageSize) {
        List<QueryRecord> queryRecords = new ArrayList<>();

        LambdaQueryWrapper<RmAxghgnqgeo> axgnqQueryWrapper = new LambdaQueryWrapper<>();
        axgnqQueryWrapper.like(RmAxghgnqgeo::getHhmc, queryInfo).or().eq(RmAxghgnqgeo::getHhbm, queryInfo);
        List<RmAxghgnqgeo> rmAxghgnqgeoList = rmAxghgnqgeoService.list(axgnqQueryWrapper);
        if(rmAxghgnqgeoList.size()>0){
            for(int i=0;i<rmAxghgnqgeoList.size();i++){
                RmAxghgnqgeo rmAxghgnqgeo = rmAxghgnqgeoList.get(i);
                QueryRecord queryRecord = new QueryRecord();
                queryRecord.setId(rmAxghgnqgeo.getId().toString());
                queryRecord.setName(rmAxghgnqgeo.getHhmc().equals(null)?"未知河流":rmAxghgnqgeo.getHhmc());
                queryRecord.setLayerName(rmAxghgnqgeo.getGnqlx());
                queryRecord.setOtherInfo(rmAxghgnqgeo.getXqmc());
                queryRecord.setGeoinfo(rmAxghgnqgeo.getGeoinfo());
                queryRecords.add(queryRecord);
            }
        }

        LambdaQueryWrapper<Wykzx> wykzxQueryWapper = new LambdaQueryWrapper<>();
        wykzxQueryWapper.eq(Wykzx::getHhbm, queryInfo).or().like(Wykzx::getHhmc,queryInfo);
        List<Wykzx> wykzxList = wykzxService.list(wykzxQueryWapper);
        if(wykzxList.size()>0){
            for(int i=0;i<wykzxList.size();i++){
                Wykzx wykzx = wykzxList.get(i);
                QueryRecord queryRecord = new QueryRecord();
                queryRecord.setId(wykzx.getId().toString());
                queryRecord.setName(wykzx.getHhmc().equals(null)?"未知河流":wykzx.getHhmc());
                queryRecord.setLayerName("外缘控制线");
                queryRecord.setOtherInfo(wykzx.getXqmc());
                queryRecord.setGeoinfo(wykzx.getGeoinfo());
                queryRecords.add(queryRecord);
            }
        }

        LambdaQueryWrapper<Lskzx> lskzxQueryWrapper = new LambdaQueryWrapper<>();
        lskzxQueryWrapper.eq(Lskzx::getHhbm, queryInfo).or().like(Lskzx::getHhmc,queryInfo);
        List<Lskzx> lskzxList = lskzxService.list(lskzxQueryWrapper);
        if(lskzxList.size()>0){
            for(int i=0;i<lskzxList.size();i++){
                Lskzx lskzx = lskzxList.get(i);
                QueryRecord queryRecord = new QueryRecord();
                queryRecord.setId(lskzx.getId().toString());
                queryRecord.setName(lskzx.getHhmc().equals(null)?"未知河流":lskzx.getHhmc());
                queryRecord.setLayerName("临水控制线");
                queryRecord.setOtherInfo(lskzx.getXqmc());
                queryRecord.setGeoinfo(lskzx.getGeoinfo());
                queryRecords.add(queryRecord);
            }
        }

        QueryResult queryResult = new QueryResult();
        queryResult.setRecords(getListpaging(queryRecords,pageNo,pageSize));
        queryResult.setCurrent(pageNo);
        queryResult.setSize(pageSize);
        queryResult.setTotal(queryRecords.size());
        return Result.OK(queryResult);
    }


    @AutoLog(value = "涉河项目信息查询")
    @ApiOperation(value="涉河项目信息查询", notes="涉河项目信息查询")
    @GetMapping(value = "/queryByShgcInfo")
    public Result<?> queryByShgcInfo(@RequestParam(name = "queryInfo", required = true) String queryInfo,
                                     @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
                                     @RequestParam(name="pageSize", defaultValue="10") Integer pageSize ) {
        List<QueryRecord> queryRecords = new ArrayList<>();
        LambdaQueryWrapper<RmAxxmxx> rmAxxmxxLambdaQueryWrapper = new LambdaQueryWrapper<>();
        rmAxxmxxLambdaQueryWrapper.like(RmAxxmxx::getXmmc,queryInfo);
        List<RmAxxmxx> rmAxxmxxList = rmAxxmxxService.list(rmAxxmxxLambdaQueryWrapper);
        if(rmAxxmxxList.size()>0){
            for(int i=0;i<rmAxxmxxList.size();i++){
                RmAxxmxx rmAxxmxx = rmAxxmxxList.get(i);
                QueryRecord queryRecord = new QueryRecord();
                queryRecord.setId(rmAxxmxx.getId());
                queryRecord.setName(rmAxxmxx.getXmmc());
                queryRecord.setLayerName("涉河项目");
                queryRecord.setOtherInfo(rmAxxmxx.getXzqh());
                //获取项目的涉河部分工程信息，并将坐标合并为多点显示
                queryRecord.setGeoinfo("");
                queryRecords.add(queryRecord);

                //获取项目下的所有涉河工程
                LambdaQueryWrapper<RmAxshbfgcxxb> shgcLQW = new LambdaQueryWrapper<>();
                shgcLQW.eq(RmAxshbfgcxxb::getMainId,rmAxxmxx.getId());
                List<RmAxshbfgcxxb> shgcList = rmAxshbfgcxxbService.list(shgcLQW);
                if(shgcList.size()>0){
                    for(int j=0;j<shgcList.size();j++){
                        RmAxshbfgcxxb shgc = shgcList.get(j);
                        QueryRecord qr = new QueryRecord();
                        qr.setId(shgc.getId());
                        qr.setName(shgc.getGcmc());
                        qr.setLayerName("涉河工程");
                        qr.setOtherInfo(shgc.getSjhd());
                        //获取项目的涉河部分工程信息，并将坐标合并为多点显示
                        qr.setGeoinfo(shgc.getGeoinfo());
                        queryRecords.add(qr);
                    }
                }
            }
        }

        QueryResult queryResult = new QueryResult();
        queryResult.setRecords(getListpaging(queryRecords,pageNo,pageSize));
        queryResult.setCurrent(pageNo);
        queryResult.setSize(pageSize);
        queryResult.setTotal(queryRecords.size());
        return Result.OK(queryResult);
    }

    @AutoLog(value = "水利工程信息查询")
    @ApiOperation(value="水利工程信息查询", notes="水利工程信息查询")
    @GetMapping(value = "/queryBySlgcInfo")
    public Result<?> queryBySlgcInfo(@RequestParam(name = "queryInfo", required = true) String queryInfo,
                                     @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
                                     @RequestParam(name="pageSize", defaultValue="10") Integer pageSize ) {
        List<QueryRecord> queryRecords = new ArrayList<>();
        LambdaQueryWrapper<RmShxmxxb> shxmxxbLambdaQueryWrapper = new LambdaQueryWrapper<>();
        shxmxxbLambdaQueryWrapper.like(RmShxmxxb::getXmmc,queryInfo);
        List<RmShxmxxb> rmshxmxxbList = rmShxmxxbService.list(shxmxxbLambdaQueryWrapper);
        if(rmshxmxxbList.size()>0){
            for(int i=0;i<rmshxmxxbList.size();i++){
                RmShxmxxb rmShxmxxb = rmshxmxxbList.get(i);
                QueryRecord queryRecord = new QueryRecord();
                queryRecord.setId(rmShxmxxb.getId());
                queryRecord.setName(rmShxmxxb.getXmmc());
                String xmlx = rmShxmxxb.getXmlx();
                String xmlxText = commonAPI.translateDict("xmlx",xmlx);
                queryRecord.setLayerName(xmlxText);
                queryRecord.setOtherInfo(rmShxmxxb.getXzqh());
                queryRecord.setGeoinfo(rmShxmxxb.getGeoinfo());
                queryRecords.add(queryRecord);
            }
        }

        QueryResult queryResult = new QueryResult();
        queryResult.setRecords(getListpaging(queryRecords,pageNo,pageSize));
        queryResult.setCurrent(pageNo);
        queryResult.setSize(pageSize);
        queryResult.setTotal(queryRecords.size());
        return Result.OK(queryResult);
    }




    @AutoLog(value = "河湖信息查询")
    @ApiOperation(value="河湖监管信息查询", notes="河湖监管信息查询")
    @GetMapping(value = "/queryByHhxxInfo")
    public Result<?> queryByHhxxInfo(@RequestParam(name = "queryInfo", required = true) String queryInfo,
                                     @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
                                     @RequestParam(name="pageSize", defaultValue="10") Integer pageSize) {
        List<QueryRecord> queryRecords = new ArrayList<>();

        LambdaQueryWrapper<Hdzhx> hdzhxLambdaQueryWrapper = new LambdaQueryWrapper<>();
        hdzhxLambdaQueryWrapper.like(Hdzhx::getRvnm,queryInfo);
        List<Hdzhx> hdzhxList = hdzhxService.list(hdzhxLambdaQueryWrapper);
        if(hdzhxList.size()>0){
            for(int i=0;i<hdzhxList.size();i++){
                Hdzhx hdzhx = hdzhxList.get(i);
                QueryRecord queryRecord = new QueryRecord();
                queryRecord.setId(hdzhx.getRvid());
                queryRecord.setName(hdzhx.getRvnm());
                queryRecord.setLayerName("河道中泓线");
                queryRecord.setOtherInfo(hdzhx.getRvcd());
                queryRecord.setGeoinfo(hdzhx.getGeoinfo());
                queryRecords.add(queryRecord);
            }
        }

        QueryResult queryResult = new QueryResult();
        queryResult.setRecords(getListpaging(queryRecords,pageNo,pageSize));
        queryResult.setCurrent(pageNo);
        queryResult.setSize(pageSize);
        queryResult.setTotal(queryRecords.size());
        return Result.OK(queryResult);
    }

    @AutoLog(value = "行政区划查询")
    @ApiOperation(value="行政区划查询", notes="行政区划查询")
    @GetMapping(value = "/queryByXzqhInfo")
    public Result<?> queryByXzqhInfo(@RequestParam(name = "queryInfo", required = true) String queryInfo,
                                     @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
                                     @RequestParam(name="pageSize", defaultValue="10") Integer pageSize) {
        List<QueryRecord> queryRecords = new ArrayList<>();

        LambdaQueryWrapper<Cjxzq> cjxzqQueryWrapper = new LambdaQueryWrapper<>();
        cjxzqQueryWrapper.like(Cjxzq::getXzqmc, queryInfo);
        List<Cjxzq> cjxzqList = cjxzqService.list(cjxzqQueryWrapper);
        if(cjxzqList.size()>0){
            for(int i=0;i<cjxzqList.size();i++){
                Cjxzq cjxzq = cjxzqList.get(i);
                QueryRecord queryRecord = new QueryRecord();
                queryRecord.setId(cjxzq.getId().toString());
                queryRecord.setName(cjxzq.getXzqmc());
                queryRecord.setLayerName("村级行政区");
                queryRecord.setOtherInfo(cjxzq.getXzqdm());
                queryRecord.setGeoinfo(cjxzq.getGeoinfo());
                queryRecords.add(queryRecord);
            }
        }

        LambdaQueryWrapper<Zjxzq> zjxzqQueryWrapper = new LambdaQueryWrapper<>();
        zjxzqQueryWrapper.like(Zjxzq::getXzqmc,queryInfo);
        List<Zjxzq> zjxzqList = zjxzqService.list(zjxzqQueryWrapper);
        if(zjxzqList.size()>0){
            for(int i=0;i<zjxzqList.size();i++){
                Zjxzq zjxzq = zjxzqList.get(i);
                QueryRecord queryRecord = new QueryRecord();
                queryRecord.setId(zjxzq.getId().toString());
                queryRecord.setName(zjxzq.getXzqmc());
                queryRecord.setLayerName("乡镇行政区");
                queryRecord.setOtherInfo(zjxzq.getXzqdm());
                queryRecord.setGeoinfo(zjxzq.getGeoinfo());
                queryRecords.add(queryRecord);
            }
        }

        LambdaQueryWrapper<Xjxzq> xjxzqQueryWrapper = new LambdaQueryWrapper<>();
        xjxzqQueryWrapper.like(Xjxzq::getXzqmc,queryInfo);
        List<Xjxzq> xjxzqList = xjxzqService.list(xjxzqQueryWrapper);
        if(xjxzqList.size()>0){
            for(int i=0;i<xjxzqList.size();i++){
                Xjxzq xjxzq = xjxzqList.get(i);
                QueryRecord queryRecord = new QueryRecord();
                queryRecord.setId(xjxzq.getId().toString());
                queryRecord.setName(xjxzq.getXzqmc());
                queryRecord.setLayerName("县级行政区");
                queryRecord.setOtherInfo(xjxzq.getXzqdm());
                queryRecord.setGeoinfo(xjxzq.getGeoinfo());
                queryRecords.add(queryRecord);
            }
        }

        QueryResult queryResult = new QueryResult();
        queryResult.setRecords(getListpaging(queryRecords,pageNo,pageSize));
        queryResult.setCurrent(pageNo);
        queryResult.setSize(pageSize);
        queryResult.setTotal(queryRecords.size());
        return Result.OK(queryResult);
    }
}