blame | history | patch | commit | commitdiff | ignore whitespace
kaiyu
2021-06-23 5981f3413b9db0dea9ef7b5e33fd39d214ebb636 
 screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java


@@ -4,23 +4,13 @@


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.moral.api.entity.Device;


import com.moral.api.entity.ManageAccount;


import com.moral.api.entity.MonitorPoint;


import com.moral.api.entity.Organization;


import com.moral.api.entity.SysDictData;


import com.moral.api.entity.SysDictType;


import com.moral.api.entity.Version;


import com.moral.api.mapper.DeviceMapper;


import com.moral.api.mapper.ManageAccountMapper;


import com.moral.api.mapper.MonitorPointMapper;


import com.moral.api.mapper.OrganizationMapper;


import com.moral.api.mapper.SysDictDataMapper;


import com.moral.api.mapper.SysDictTypeMapper;


import com.moral.api.entity.*;


import com.moral.api.mapper.*;


import com.moral.api.pojo.vo.device.DeviceVO;


import com.moral.api.service.DeviceService;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;




import com.moral.api.util.CacheUtils;


import com.moral.api.util.LogUtils;


import com.moral.constant.Constants;


import com.moral.constant.RedisConstants;


@@ -31,6 +21,7 @@


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.ObjectUtils;


import org.springframework.web.context.request.RequestContextHolder;


import org.springframework.web.context.request.ServletRequestAttributes;




@@ -80,6 +71,13 @@


    @Autowired


    private RedisTemplate redisTemplate;




    @Autowired


    private OrganizationUnitAlarmMapper organizationUnitAlarmMapper;




    @Autowired


    private VersionSensorUnitMapper versionSensorUnitMapper;








    /*


     * 从redis获取设备信息


@@ -127,12 +125,16 @@


        device.setOrganizationId(orgId);


        deviceMapper.insert(device);


        Map<String, Object> deviceInfo = selectDeviceInfoById(device.getId());


        //维护组织型号关系表


        insertOrganizationUnitAlarm(orgId,device.getDeviceVersionId());


        //新增设备信息存入redis


        String mac = device.getMac();


        //从redis中删除设备信息


        delDeviceInfoFromRedis(mac);


        //设备信息存入redis


        setDeviceInfoToRedis(mac, deviceInfo);


        //刷新deviceInfo缓存


        CacheUtils.flushDeviceAlarmInfo();


        //操作日志记录


        HttpServletRequest request = ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest();


        StringBuilder content = new StringBuilder();


@@ -150,6 +152,12 @@


        String mac = device.getMac();


        //从redis中删除设备信息


        delDeviceInfoFromRedis(mac);


        //维护组织型号关系表


        Integer versionId = device.getDeviceVersionId();


        Integer orgId = device.getOrganizationId();


        deleteOrganizationUnitAlarm(orgId,versionId);


        //刷新deviceInfo缓存


        CacheUtils.flushDeviceAlarmInfo();


        //操作日志记录


        HttpServletRequest request = ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest();


        StringBuilder content = new StringBuilder();


@@ -162,13 +170,30 @@


    public void update(Device device) {


        Integer deviceId = device.getId();


        Device oldDevice = deviceMapper.selectById(deviceId);


        //判断是否更新了站点，如果更新了站点则查询对应站点的组织id进行更新


        if(!ObjectUtils.isEmpty(device.getMonitorPointId())){


            MonitorPoint monitorPoint = monitorPointMapper.selectById(device.getMonitorPointId());


            device.setOrganizationId(monitorPoint.getOrganizationId());


        }


        deviceMapper.updateById(device);


        String mac = deviceMapper.selectById(deviceId).getMac();


        Device updateDevice = deviceMapper.selectById(deviceId);


        String mac = updateDevice.getMac();


        //维护组织型号关系表


       Integer oldOrgId = oldDevice.getOrganizationId();


       Integer newOrgId = updateDevice.getOrganizationId();


       Integer oldVersionId = oldDevice.getDeviceVersionId();


       Integer newVersionId = updateDevice.getDeviceVersionId();


       if(!oldOrgId.equals(newOrgId)||!oldVersionId.equals(newVersionId)){


           deleteOrganizationUnitAlarm(oldOrgId,oldVersionId);


           insertOrganizationUnitAlarm(newOrgId,newVersionId);


       }


        //从redis中删除设备信息


        delDeviceInfoFromRedis(mac);


        Map<String, Object> deviceInfo = selectDeviceInfoById(deviceId);


        //设备信息存入redis


        setDeviceInfoToRedis(mac, deviceInfo);


        //刷新deviceInfo缓存


        CacheUtils.flushDeviceAlarmInfo();


        //操作日志记录


        HttpServletRequest request = ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest();


        StringBuilder content = new StringBuilder();


@@ -409,5 +434,44 @@


        return null;


    }




    private void insertOrganizationUnitAlarm(Integer orgId,Integer versionId){


        QueryWrapper<OrganizationUnitAlarm> queryOrganizationVersionWrapper = new QueryWrapper<>();


        queryOrganizationVersionWrapper.eq("organization_id",orgId);


        queryOrganizationVersionWrapper.eq("version_id",versionId);


        queryOrganizationVersionWrapper.eq("is_delete",Constants.NOT_DELETE);


        List<OrganizationUnitAlarm> organizationUnitAlarms = organizationUnitAlarmMapper.selectList(queryOrganizationVersionWrapper);


        if(ObjectUtils.isEmpty(organizationUnitAlarms)){


            QueryWrapper<VersionSensorUnit> queryVersionSensorUnitWrapper =new QueryWrapper<>();


            queryVersionSensorUnitWrapper.eq("version_id",versionId);


            queryVersionSensorUnitWrapper.eq("is_delete",Constants.NOT_DELETE);


            List<VersionSensorUnit> versionSensorUnits = versionSensorUnitMapper.selectList(queryVersionSensorUnitWrapper);


            if(!ObjectUtils.isEmpty(versionSensorUnits)){


                for (VersionSensorUnit versionSensorUnit : versionSensorUnits) {


                    OrganizationUnitAlarm organizationUnitAlarm = new OrganizationUnitAlarm();


                    organizationUnitAlarm.setOrganizationId(orgId);


                    organizationUnitAlarm.setVersionId(versionId);


                    organizationUnitAlarm.setSensorCode(versionSensorUnit.getSensorCode());


                    organizationUnitAlarm.setUnitKey(versionSensorUnit.getUnitKey());


                    organizationUnitAlarm.setShowUnitKey(versionSensorUnit.getUnitKey());


                    organizationUnitAlarmMapper.insert(organizationUnitAlarm);


                }


            }


        }


    }




    private void deleteOrganizationUnitAlarm(Integer orgId,Integer versionId){


        QueryWrapper<Device> queryOrganizationVersionWrapper = new QueryWrapper<>();


        queryOrganizationVersionWrapper.eq("organization_id",orgId);


        queryOrganizationVersionWrapper.eq("device_version_id",versionId);


        queryOrganizationVersionWrapper.eq("is_delete",Constants.NOT_DELETE);


        List<Device> devices = deviceMapper.selectList(queryOrganizationVersionWrapper);


        if(ObjectUtils.isEmpty(devices)){//如果为空，则组织没有该型号的设备了。


            UpdateWrapper deleteWrapper = new UpdateWrapper();


            deleteWrapper.eq("organization_id",orgId);


            deleteWrapper.eq("version_id",versionId);


            deleteWrapper.eq("is_delete",Constants.NOT_DELETE);


            deleteWrapper.set("is_delete",Constants.DELETE);


            organizationUnitAlarmMapper.update(null,deleteWrapper);


        }


    }


}