IotCenter/src/main/java/com/zswl/dataservice/service/mqtt/DeviceSyncFullCardService.java

package com.zswl.dataservice.service.mqtt;

import com.github.microservice.models.device.DeviceInfoSyncParam;
import com.github.microservice.models.device.DeviceSyncListParam;
import com.zswl.dataservice.dao.mqtt.DeviceInfoDao;
import com.zswl.dataservice.dao.mqtt.GateWayInfoDao;
import com.zswl.dataservice.domain.mqtt.DeviceInfo;
import com.zswl.dataservice.domain.mqtt.GateWayInfo;
import com.zswl.dataservice.event.DeviceSyncEvent;
import com.zswl.dataservice.event.GateWaySyncEvent;
import com.zswl.dataservice.httpRequest.ApiRequestService;
import com.zswl.dataservice.httpRequest.apiConf.APIResponseModel;
import com.zswl.dataservice.httpRequest.conf.FullCardAPIConfig;
import com.zswl.dataservice.service.base.SuperService;
import com.zswl.dataservice.utils.bean.BeanUtil;
import com.zswl.dataservice.utils.bean.BeanUtils;
import com.zswl.dataservice.utils.result.ResultContent;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import java.lang.reflect.InvocationTargetException;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 物联网平台 设备 网关同步到全卡项目
 *
 * @author TRX
 * @date 2024/6/26
 */
@Slf4j
@Service
public class DeviceSyncFullCardService extends SuperService {

    @Autowired
    DeviceInfoDao deviceInfoDao;

    @Autowired
    GateWayInfoDao gateWayInfoDao;

    @Autowired
    OperationLogsService operationLogsService;

    @Autowired
    ApiRequestService apiRequestService;

    @Autowired
    ApplicationContext applicationContext;

    /**
     * 通知同步设备
     *
     * @param deviceInfo
     * @return
     */
    public ResultContent noticeSyncDevice(DeviceInfo deviceInfo) {
        if (ObjectUtils.isNotEmpty(deviceInfo)) {
            List<String> deviceIds = new ArrayList<>();
            deviceIds.add(deviceInfo.getDeviceId());
            DeviceSyncEvent event = new DeviceSyncEvent(this, deviceIds);
            applicationContext.publishEvent(event);
        }
        return ResultContent.buildSuccess();
    }

    /**
     * 通知同步设备
     *
     * @param deviceInfos
     * @return
     */
    public ResultContent noticeSyncDevice(List<DeviceInfo> deviceInfos) {
        if (ObjectUtils.isNotEmpty(deviceInfos)) {
            List<String> deviceIds = deviceInfos.stream().map(it -> it.getDeviceId()).collect(Collectors.toList());
            DeviceSyncEvent event = new DeviceSyncEvent(this, deviceIds);
            applicationContext.publishEvent(event);
        }
        return ResultContent.buildSuccess();
    }

    /**
     * 通知同步设备
     *
     * @param deviceIds
     * @return
     */
    public ResultContent noticeSyncDeviceIds(List<String> deviceIds) {
        if (ObjectUtils.isNotEmpty(deviceIds)) {
            DeviceSyncEvent event = new DeviceSyncEvent(this, deviceIds);
            applicationContext.publishEvent(event);
        }
        return ResultContent.buildSuccess();
    }

    /**
     * 接收到同步设备的事件
     *
     * @param event
     */
    @EventListener(classes = DeviceSyncEvent.class)
    @Async
    @SneakyThrows
    public void syncDeviceInfo(DeviceSyncEvent event) {
        List<String> deviceIds = event.getDeviceIds();
        log.info("event syncDeviceInfo: {}", deviceIds);
        List<DeviceInfo> list = deviceInfoDao.findByDeviceIdIn(deviceIds);
        DeviceSyncListParam param = new DeviceSyncListParam();
        List<DeviceInfoSyncParam> deviceInfos = new ArrayList<>();
        if (ObjectUtils.isNotEmpty(list)) {
            list.stream().map(it -> {
                DeviceInfoSyncParam syncParam = new DeviceInfoSyncParam();
                BeanUtils.copyProperties(it, syncParam);
                return syncParam;
            }).collect(Collectors.toList());
        }
        param.setList(deviceInfos);
        APIResponseModel api = apiRequestService.sendFullCardAPI(FullCardAPIConfig.deviceSync, param);
        log.info("同步设备情况：{} {}", api.isSuccess(), api.getMsg());
    }

    /**
     * 通知同步网关信息
     *
     * @param gateWayInfo
     * @return
     */
    public ResultContent noticeSyncGateWay(GateWayInfo gateWayInfo) {
        if (ObjectUtils.isNotEmpty(gateWayInfo)) {
            GateWaySyncEvent event = new GateWaySyncEvent(this, gateWayInfo.getGateWayId());
            applicationContext.publishEvent(event);
        }
        return ResultContent.buildSuccess();
    }

    /**
     * 同步网关信息
     *
     * @param event
     */
    @EventListener(classes = GateWaySyncEvent.class)
    @Async
    @SneakyThrows
    public void syncGateWayInfo(GateWaySyncEvent event) {
        String gatewayId = event.getGateWayId();
        log.info("event syncGateWayInfo: {}", gatewayId);

    }
}