package com.fdkankan.tools.service.impl;

import com.fdkankan.tools.entity.*;
import com.fdkankan.tools.httpClient.client.ZfbClient;
import com.fdkankan.tools.service.*;
import com.fdkankan.tools.utils.OssToOssUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;
import java.util.stream.Collectors;

@Service
@Slf4j
public class CnToZfbService {
    @Autowired
    ISceneProService cnSceneProService;
    @Autowired
    ISceneProEditService cnSceneProEditService;
    @Autowired
    IUserService userService;

    @Autowired
    ITbSceneProService zfbSceneProService;
    @Autowired
    ITbSceneProEditService zfbSceneProEditService;
    @Autowired
    OssToOssUtil ossToOssUtil;
    @Autowired
    ZfbClient zfbClient;
    @Autowired
    ICameraService cameraService;


    public void cnSceneToZfb(String cnPhone,String zfbPhone,String zfbSnCode) {
        User user = userService.getByUserName(cnPhone);
        if(user == null){
            log.info("db1-user-not-exist--chPhone:{}",cnPhone);
            return;
        }
        Camera camera = cameraService.getBySnCode(zfbSnCode);
        if(camera == null){
            log.info("db1-camera-not-exist--zfbSnCode:{}",zfbSnCode);
            return;
        }
        List<ScenePro> scenePros = cnSceneProService.getByUserId(user.getId(),camera.getId());
        if(scenePros.size() <=0){
            log.info("db1-scenePro-not-exist--user:{}",user);
            return;
        }
        List<Long> proIds = scenePros.stream().map(ScenePro::getId).collect(Collectors.toList());
        List<SceneProEdit> sceneProEdits = cnSceneProEditService.getByProIds(proIds);

        List<TbScenePro> list = zfbSceneProService.saveDb(scenePros, sceneProEdits, zfbPhone, zfbSnCode);

        if(list ==null || list.size() <=0){
            log.info("db2-scenePro-not-in--user:{}",user);
            return;
        }
        for (TbScenePro tbScenePro : list) {
            ossToOssUtil.awsToOss(tbScenePro.getDataSource(),tbScenePro.getNum(),"zfb");
            zfbClient.rebuildScene(tbScenePro.getNum());
        }

    }
}