package com.hxzkappboot.controller;



import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.hxzkappboot.mapper.TbFenceMapper;
import com.hxzkappboot.mapper.TbPersonMapper;
import com.hxzkappboot.pojo.TbFence;
import com.hxzkappboot.pojo.TbPerson;
import com.hxzkappboot.pojo.TbTag;
import com.hxzkappboot.pojo.TbWarning;
import com.hxzkappboot.service.TbFenceService;
import com.hxzkappboot.udp.Udp_Out;
import com.hxzkappboot.util.R;
import com.hxzkappboot.util.StatusCode;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.ModelAndView;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.validation.Valid;
import java.io.IOException;
import java.text.ParseException;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;

/**
 * <p>
 *  前端控制器
 * </p>
 *
 * @author wangfei
 * @since 2024-03-08
 */
@RestController
//@RequestMapping("/tb-fence")
public class TbFenceController {

    @Autowired
    TbFenceService tbFenceService;

    @Autowired
    TbFenceMapper tbPersonMapper;


    @GetMapping("/api/wx/findAllFence")
    public R findAllFence(String company){
        R response ;
        response = new R(StatusCode.Success);
        response.setData(tbFenceService.findAllFence(company));
        return response;
    }
//    @PostMapping({"findFenA"})

    @GetMapping({"/api/wx/deleFence"})
    public R earlyWarning(String name) throws ParseException {
        String xieyi = "BSTOCS1,DELETEFENCE," + name + ",END";
        Udp_Out.udp_to_cs(xieyi);
        R response ;
//        List<TbFence> fenceList = new ArrayList();
        System.out.println(name);
//        fenceList = tbFenceService.earlyWarning();
        response = new R(StatusCode.Success);
//        response.setData(fenceList);
        return response;
    }

    @GetMapping("/api/wx/findFence")
    public R findAll(Page page, String objectid,String company) {
        R response;
        IPage<TbFence> ipage = tbFenceService.findFence(page,objectid,company);
        response = new R(StatusCode.Success);
        response.setData(ipage);
        return response;
    }

    @PostMapping("/api/wx/updateFence")
    public R processingWarn(@Valid @RequestBody TbFence tbFence) {
        R response ;
        response = new R(StatusCode.Success);
        TbFence gpsList =tbFenceService.updateFence(tbFence);
        response.setData(gpsList);
        return response;
    }

    @GetMapping("/api/wx/FenceKaiQi")
    public void fenceKai(TbFence fence){
//        TbUser user = sessionManager.getCurrentUser(request);
        String xieyi = "BSTOCS1,FENCE,OPEN," +fence.getName()+",END";
        Udp_Out.udp_to_cs(xieyi);
//        String content = "开启了一个围栏该围栏名称为："+fence.getName();
//        String contentew = "Открывается забор, который называется："+fence.getName();
//        SystemLogController.InsertSystemLog(user.getUsername(),gettime(),content,contentew);
    }
    @GetMapping("/api/wx/FenceGuanBi")
    public void fenceGuan(TbFence fence){
//        TbUser user = sessionManager.getCurrentUser(request);
        String xieyi = "BSTOCS1,FENCE,CLOSE," +fence.getName()+",END";
        System.out.println();
        Udp_Out.udp_to_cs(xieyi);
//        String content = "关闭了一个围栏该围栏名称为："+fence.getName();
//        String contentew= "Закрыли забор, который называется："+fence.getName();
//        SystemLogController.InsertSystemLog(user.getUsername(),gettime(),content,contentew);
    }

    @PostMapping("/api/wx/submitper")
    public R submitper(@Valid @RequestBody TbFence tbFence) {
        R response ;

//        for (int i = 0; i < ; i++) {
//
//        }
        QueryWrapper queryWrapper = new QueryWrapper<>();
//        queryWrapper.eq("status","未处理");
//        if (objectid!=null){
            queryWrapper.eq("name",tbFence.getName());
//        }
//        queryWrapper.orderByDesc("addtime");
        List<TbFence> CompanyPage = tbPersonMapper.selectList( queryWrapper);
        if (CompanyPage.size()>0){
            response = new R(StatusCode.Fail);
            response.setData("围栏名称重复，保存围栏失败！");
        }else{
            response = new R(StatusCode.Success);
            LocalDateTime now = LocalDateTime.now();
            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
            String formattedDateTime = now.format(formatter);
            String shengxiao = "00:00:00";
            String shixiao = "23:59:59";
            String xieyi = "";
        if (Objects.equals(tbFence.getShape(), "圆形")){
//            xieyi = "BSTOCS1,ADDFENCE," + layer + ","+weilanleixing+","+guanlianduixiang+","+quyumingcheng+","+sd+","+xingzhuang+","+shengxiao+","+shixiao+","+formattedDateTime+","+yanse+","+gao+",END";
            xieyi = "BSTOCS1,ADDFENCEYUAN,百度地图" + ","+tbFence.getType()+","+tbFence.getBumen()+","+tbFence.getBanjing()+","+tbFence.getName()+","+tbFence.getZuobiao().split(":")[0] +";"+tbFence.getZuobiao().split(":")[0]+","+"圆形"+","+"00:00:00"+","+"23:59:59"+","+formattedDateTime+","+"红色"+",END";
        }else{
            xieyi = "BSTOCS1,ADDFENCE,百度地图,"+tbFence.getType()+","+tbFence.getBumen()+","+tbFence.getName()+","+tbFence.getZuobiao()+","+tbFence.getShape()+","+shengxiao+","+shixiao+","+formattedDateTime+","+"红色"+","+tbFence.getBaoliu1()+",END";
        }
            System.out.println(xieyi);
            Udp_Out.udp_to_cs(xieyi);
        }

        //保存数据到cs的格式
//    TbPerson gpsList =personService.submitper(tbPerson);
//    response.setData(gpsList);
//    String xieyi = "BSTOCS1,TOMESSAGE," + people1.get(0).getPTagid() + "," + fenceList.get(i).getYjcontent() + ",系统,END";
//    Udp_Out.udp_to_cs(xieyi);
        return response;
    }

}