package com.skyline.electricity.timer;


import com.alibaba.fastjson.JSONObject;
import com.skyline.electricity.controller.WebSocketController;
import com.skyline.electricity.entity.ConfigInfo;
import com.skyline.electricity.entity.SysUser;
import com.skyline.electricity.mapper.InformationMapper;
import com.skyline.electricity.pojo.*;
import com.skyline.electricity.service.DetectService;
import com.skyline.electricity.service.InfoSynchService;
import com.skyline.electricity.service.InformationService;
import com.vividsolutions.jts.geom.GeometryFactory;
import com.vividsolutions.jts.io.WKTReader;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import java.util.*;

@Slf4j
@Service
//192.168.121.193:9876
@RocketMQMessageListener(nameServer = "192.168.121.193:9876",topic = "deviceLocationData", consumerGroup = "test")
public class Consumer implements RocketMQListener<String> {

    @Autowired
    InfoSynchService infoSynchService ;

    @Autowired
    private DetectService detectService;

    @Autowired
    WebSocketController webSocketController ;

    @Autowired
    InformationService informationService ;
    @Override
    public void onMessage(String message) {
        System.out.println("recv msg:  "+message);
        sendAllMessage(message);
    }

    /*

     private String userId;
    private String shopId;
    private String userName;
    private String userIndex;
    private String mobile;
    private String email;
    private Integer satelliteNum;
    private String longitude;
    private String latitude;
    private String alitude;
    private String course;
    private List<Code> events;
    private String time;
    private String type;
     */

    public void sendAllMessage(String message) {
        System.out.println("【websocket消息】广播消息:"+message);

        JSONObject jsonObject = JSONObject.parseObject(message);
        String personNo = jsonObject.getString("personNo");

        SysUser sysUser = infoSynchService.selectUserInfoById(personNo) ;
        System.out.println("【user]:"+JSONObject.toJSONString(sysUser));
        List<RetInfo> list = new ArrayList<>();
        //查询用户所处围栏
        List<FencePosition> fencePositionList = (List<FencePosition>)this.detectService.checkInFence(jsonObject.get("w84lat").toString(),jsonObject.get("w84lon").toString());
        System.out.println("【FencePosition]:"+JSONObject.toJSONString(fencePositionList));
        RetInfo alertinfo = new RetInfo();
        initAlertInfos(jsonObject, personNo, sysUser, alertinfo);
        if( fencePositionList != null && fencePositionList.size() > 0){
            for( FencePosition f:fencePositionList) {
                // 判断用户是否是围栏合法用户
                Fence_User fence_user = detectService.checkInAlert(f.getWorkId(),sysUser.getId());
                alertinfo.setFence_name(f.getFname());
                alertinfo.setWtId(f.getWorkId());
                if( fence_user == null && checkHight(alertinfo.getBaseFloor(),f)){
                    alertinfo.setStatus("alert");

                }else{
                    alertinfo.setStatus("ok");
                }
                list.add(alertinfo) ;
            }
        }else{
            alertinfo.setStatus("ok");
            list.add(alertinfo) ;
        }
        insertInformation(list);
        System.out.println( "list:"+jsonObject.toJSONString(list));
//        if( list != null && list.size() > 0)
//            System.out.println( "websocket status ..["+webSocketController.sendAllMessage(JSONObject.toJSONString(list))+"["+JSONObject.toJSONString(list)+"]" );
    }

    private void initAlertInfos(JSONObject jsonObject, String personNo, SysUser sysUser, RetInfo alertinfo) {
        alertinfo.setLatitude(jsonObject.get("w84lat").toString());
        alertinfo.setLongitude(jsonObject.get("w84lon").toString());
//                alertinfo.setW84lat(jsonObject.get("w84lat").toString());
//                alertinfo.setW84lon(jsonObject.get("w84lon").toString());
        alertinfo.setUserId(personNo);
        alertinfo.setUserName(sysUser.getName());
        alertinfo.setType(jsonObject.get("locType").toString());
        alertinfo.setShopId("197");

        alertinfo.setEmail(sysUser.getEmail());
        alertinfo.setMobile(sysUser.getMobile());

        alertinfo.setBaseFloor(jsonObject.get("baseFloor").toString());
        alertinfo.setStartTime(jsonObject.get("timestamp").toString());
        alertinfo.setHb(jsonObject.getInteger("hb").intValue());
    }

    private boolean checkHight(String basefloor,FencePosition f){
        int fl = (int)(f.getEndaltitude()/7)+1 ;
        System.out.println("接收："+basefloor+" 围栏楼层:"+f.getFname()+":"+fl);
        return  (Integer.parseInt(basefloor)-1) ==fl ;
    }


    private void insertInformation(List<RetInfo> list){
        List<Information> iList = new ArrayList<>() ;
       for(RetInfo r:list) {
           Information information = new Information();
           information.setFence_type(r.getType());
           information.setName(r.getFence_name());
           //information.setStartTime(r.getStartTime());
           //避免时间同步问题
           information.setStartTime((new Date()).getTime()/1000+"");
           information.setStatus(r.getStatus());
           information.setUserId(r.getUserId());
           information.setWtId(r.getWtId());
           information.setUserName(r.getUserName());
           information.setXy(JSONObject.toJSONString(r));
           information.setHb(r.getHb());
           iList.add(information);
       }
       if( iList != null && iList.size() > 0)
       informationService.saveList(iList);
    }
}