package com.moral.service.impl;

import com.moral.entity.OrganizationSensorUnit;
import com.moral.entity.Sensor;
import com.moral.entity.SensorUnit;
import com.moral.mapper.OrganizationSensorUnitMapper;
import com.moral.mapper.SensorMapper;
import com.moral.service.OrganizationSensorUnitService;
import org.springframework.data.annotation.Transient;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

@Service
public class OrganizationSensorUnitServiceImpl implements OrganizationSensorUnitService{
    @Resource
    OrganizationSensorUnitMapper osuMapper;
    @Resource
    SensorMapper sensorMapper;

    /**
     * 获取所有传感器单位对应关系
     * @param organizationId
     * @return
     */
    @Override
    public List<OrganizationSensorUnit> queryAllByOrgId(Integer organizationId) {
            // 获取当前组织下所有传感器
            List<Sensor> sensorList = sensorMapper.selectByOrgId(organizationId);
            // 获取单位组织对应关系拉出单位数据
            List<OrganizationSensorUnit> organizationSensorUnits = osuMapper.selectByOrgId(organizationId);
            List<OrganizationSensorUnit> returnList = new ArrayList<>();
            for (int index=0;index<sensorList.size();index++){
                 Sensor sensor = sensorList.get(index);
                 OrganizationSensorUnit osuOutEntity = null;
                 for (int num =0; num< organizationSensorUnits.size();num++) {
                    OrganizationSensorUnit osuTemp = organizationSensorUnits.get(num);
                    SensorUnit sensorUnit = osuTemp.getSensorUnit();
                    if(sensorUnit!=null&&sensor.getId() == sensorUnit.getSensorId() ){
                        osuOutEntity = osuTemp;
                        break;
                    }
                 }
                 if(osuOutEntity==null) {osuOutEntity = new OrganizationSensorUnit();}
                 osuOutEntity.setOrganizationId(organizationId);
                 osuOutEntity.setSensor(sensor);
                returnList.add(osuOutEntity);
            }
            return  returnList;
    }

    @Override
    public List<OrganizationSensorUnit> queryByOrgId(Integer organizationId) {
        return osuMapper.selectByOrgId(organizationId);
    }

    @Override
    @Transient
    public void addsOrModifys(List<OrganizationSensorUnit> osuList) {
        osuList.forEach(
                item -> {
                    if(item.getId() != null) {
                        if(item.getSensorUnitId() == null) {
                            osuMapper.deleteByPrimaryKey(item);
                        }else {
                            osuMapper.updateByPrimaryKeySelective(item);
                        }
                    }else{
                        item.setCreateTime(new Date());
                        osuMapper.insertSelective(item);
                    }
                }
        );
    }
}