bunti/src/main/java/de/ctdo/bunti/control/BuntiControllerImpl.java

package de.ctdo.bunti.control;

import java.util.Collection;
import java.util.HashMap;
import java.util.Map;

import de.ctdo.bunti.dao.RoomsDAO;
import de.ctdo.bunti.model.*;
import org.apache.commons.collections.map.HashedMap;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.stereotype.Component;

import de.ctdo.bunti.dao.BuntiDevicesDAO;

@Component
public class BuntiControllerImpl  implements BuntiController, ApplicationEventPublisherAware {
	private static final Logger LOGGER = LoggerFactory.getLogger(BuntiControllerImpl.class);
	private ApplicationEventPublisher applicationEventPublisher = null;
	private BuntiDevicesDAO devicesDAO;
    private RoomsDAO roomsDAO;
    private Map<Integer, Map<String, Object>> deviceCache = new HashMap<Integer, Map<String, Object>>();


	@Autowired
	public final void setDevicesDAO(BuntiDevicesDAO devicesDAO) {
		this.devicesDAO = devicesDAO;
	}

    @Autowired
    public final void setRoomsDAO(RoomsDAO roomsDAO) {
        this.roomsDAO = roomsDAO;
    }

    @Override
    public final void setApplicationEventPublisher(ApplicationEventPublisher publisher) {
        this.applicationEventPublisher = publisher;
    }


    @Override
	public final boolean updateDeviceData(int deviceId, Map<String, Object> options) {
		BuntiDevice device = devicesDAO.getDeviceById(deviceId);
		
		if (device != null) {
            LOGGER.debug("publishEvent in BuntiController");

            Map<String, Object> cached = deviceCache.get(deviceId);
            if(cached == null ) {
                cached = new HashMap<String, Object>();
                deviceCache.put(deviceId, cached);
            }
            cached.putAll(options);
            
            device.setValuesFromOptions(options) ;

            this.applicationEventPublisher.publishEvent(new DeviceChangedEvent(this, device, options));

			return true;
		}

		return false;
	}

    @Override
    public DeviceUpdate getDeviceValues(int deviceId) {
        Map<String, Object> cached = deviceCache.get(deviceId);

        DeviceUpdate du = new DeviceUpdate();
        du.setDeviceId(deviceId);
        du.setOptions(cached);
        return du;
    }

    @Override
    public Collection<Room> getAllRooms() {
        return roomsDAO.getRooms();
    }

    @Override
    public Room getRoomById(int roomId) {
        return roomsDAO.getRoom(roomId);
    }

    @Override
    public Collection<BuntiDevice> getAllDevices() {
        return devicesDAO.getAllDevices();
    }

    @Override
    public BuntiDevice getDeviceById(int deviceId) {
        return devicesDAO.getDeviceById(deviceId);
    }

}