package com.fdkankan.contro.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.fdkankan.common.constant.CommonSuccessStatus;
import com.fdkankan.contro.entity.Camera;
import com.fdkankan.contro.entity.SSOUser;
import com.fdkankan.contro.entity.ScenePlus;
import com.fdkankan.contro.entity.ScenePlusExt;
import com.fdkankan.contro.service.*;
import com.fdkankan.rabbitmq.util.RabbitMqProducer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.HashMap;
import java.util.Map;
import java.util.Objects;

@Service
public class IntermitSceneServiceImpl implements IntermitSceneService {

    @Autowired
    private IScenePlusService scenePlusService;
    @Autowired
    private IScenePlusExtService scenePlusExtService;
    @Autowired
    private IUserService userService;
    @Autowired
    private ICameraService cameraService;
    @Autowired
    private RabbitMqProducer mqProducer;

    @Override
    public void sendMq(String num, JSONObject fdageData, int status) {
        ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
        ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());

        String phoneNum = null;
        if(Objects.nonNull(scenePlus.getUserId())){
            SSOUser user = userService.getSSOUserByUserId(scenePlus.getUserId());
            phoneNum = user.getUserName();
        }
        Camera camera = cameraService.getById(scenePlus.getCameraId());
        Map<String, Object> params = new HashMap<>();
        params.put("sceneCode", num);
        params.put("location", fdageData.getInteger("location"));
        params.put("algorithmTime", scenePlusExt.getAlgorithmTime());
        params.put("snCode", camera.getSnCode());
        params.put("userId", scenePlus.getUserId());
        params.put("phoneNum", phoneNum);
        params.put("status", status);
        params.put("sceneName", scenePlus.getTitle());
        params.put("pwd", fdageData.getString("pwd"));
        params.put("shootCount", fdageData.getJSONArray("points").size());
        params.put("gps", fdageData.getJSONObject("gps"));
        params.put("createTime", scenePlus.getCreateTime());
        mqProducer.sendByWorkQueue("queue-pano-scene", params);
    }
}