parent
5a464028f2
commit
0117a0eab0
@ -1,99 +1,91 @@
|
||||
package com.ruoyi.page.service.impl;
|
||||
|
||||
import java.util.List;
|
||||
import com.ruoyi.common.utils.DateUtils;
|
||||
import com.ruoyi.page.domain.Alarm;
|
||||
import com.ruoyi.page.domain.dto.request.AlarmFindRequest;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
import com.ruoyi.page.mapper.AlarmMapper;
|
||||
import com.ruoyi.page.domain.Alarm;
|
||||
import com.ruoyi.page.service.IAlarmService;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 报警事件Service业务层处理
|
||||
*
|
||||
*
|
||||
* @author ruoyi
|
||||
* @date 2024-05-30
|
||||
*/
|
||||
@Service
|
||||
public class AlarmServiceImpl implements IAlarmService
|
||||
{
|
||||
public class AlarmServiceImpl implements IAlarmService {
|
||||
@Resource
|
||||
private AlarmMapper alarmMapper;
|
||||
|
||||
/**
|
||||
* 查询报警事件
|
||||
*
|
||||
*
|
||||
* @param emergencyEventId 报警事件主键
|
||||
* @return 报警事件
|
||||
*/
|
||||
@Override
|
||||
public Alarm selectAlarmByEmergencyEventId(Long emergencyEventId)
|
||||
{
|
||||
public Alarm selectAlarmByEmergencyEventId(Long emergencyEventId) {
|
||||
return alarmMapper.selectAlarmByEmergencyEventId(emergencyEventId);
|
||||
}
|
||||
|
||||
/**
|
||||
* 查询报警事件列表
|
||||
*
|
||||
*
|
||||
* @param req 报警事件
|
||||
* @return 报警事件
|
||||
*/
|
||||
@Override
|
||||
public List<Alarm> selectAlarmList(AlarmFindRequest req)
|
||||
{
|
||||
public List<Alarm> selectAlarmList(AlarmFindRequest req) {
|
||||
return alarmMapper.selectAlarmList(req);
|
||||
}
|
||||
|
||||
/**
|
||||
* 新增报警事件
|
||||
*
|
||||
*
|
||||
* @param alarm 报警事件
|
||||
* @return 结果
|
||||
*/
|
||||
@Override
|
||||
public int insertAlarm(Alarm alarm)
|
||||
{
|
||||
public int insertAlarm(Alarm alarm) {
|
||||
alarm.setCreateTime(DateUtils.getNowDate());
|
||||
return alarmMapper.insertAlarm(alarm);
|
||||
}
|
||||
|
||||
/**
|
||||
* 修改报警事件
|
||||
*
|
||||
*
|
||||
* @param alarm 报警事件
|
||||
* @return 结果
|
||||
*/
|
||||
@Override
|
||||
public int updateAlarm(Alarm alarm)
|
||||
{
|
||||
public int updateAlarm(Alarm alarm) {
|
||||
alarm.setUpdateTime(DateUtils.getNowDate());
|
||||
return alarmMapper.updateAlarm(alarm);
|
||||
}
|
||||
|
||||
/**
|
||||
* 批量删除报警事件
|
||||
*
|
||||
*
|
||||
* @param emergencyEventIds 需要删除的报警事件主键
|
||||
* @return 结果
|
||||
*/
|
||||
@Override
|
||||
public int deleteAlarmByEmergencyEventIds(Long[] emergencyEventIds)
|
||||
{
|
||||
public int deleteAlarmByEmergencyEventIds(Long[] emergencyEventIds) {
|
||||
return alarmMapper.deleteAlarmByEmergencyEventIds(emergencyEventIds);
|
||||
}
|
||||
|
||||
/**
|
||||
* 删除报警事件信息
|
||||
*
|
||||
*
|
||||
* @param emergencyEventId 报警事件主键
|
||||
* @return 结果
|
||||
*/
|
||||
@Override
|
||||
public int deleteAlarmByEmergencyEventId(Long emergencyEventId)
|
||||
{
|
||||
public int deleteAlarmByEmergencyEventId(Long emergencyEventId) {
|
||||
return alarmMapper.deleteAlarmByEmergencyEventId(emergencyEventId);
|
||||
}
|
||||
}
|
||||
|
||||
@ -1,132 +0,0 @@
|
||||
package com.ruoyi.framework.config;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import javax.sql.DataSource;
|
||||
import org.apache.ibatis.io.VFS;
|
||||
import org.apache.ibatis.session.SqlSessionFactory;
|
||||
import org.mybatis.spring.SqlSessionFactoryBean;
|
||||
import org.mybatis.spring.boot.autoconfigure.SpringBootVFS;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
import org.springframework.core.env.Environment;
|
||||
import org.springframework.core.io.DefaultResourceLoader;
|
||||
import org.springframework.core.io.Resource;
|
||||
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
|
||||
import org.springframework.core.io.support.ResourcePatternResolver;
|
||||
import org.springframework.core.type.classreading.CachingMetadataReaderFactory;
|
||||
import org.springframework.core.type.classreading.MetadataReader;
|
||||
import org.springframework.core.type.classreading.MetadataReaderFactory;
|
||||
import org.springframework.util.ClassUtils;
|
||||
import com.ruoyi.common.utils.StringUtils;
|
||||
|
||||
/**
|
||||
* Mybatis支持*匹配扫描包
|
||||
*
|
||||
* @author ruoyi
|
||||
*/
|
||||
@Configuration
|
||||
public class MyBatisConfig
|
||||
{
|
||||
@Autowired
|
||||
private Environment env;
|
||||
|
||||
static final String DEFAULT_RESOURCE_PATTERN = "**/*.class";
|
||||
|
||||
public static String setTypeAliasesPackage(String typeAliasesPackage)
|
||||
{
|
||||
ResourcePatternResolver resolver = (ResourcePatternResolver) new PathMatchingResourcePatternResolver();
|
||||
MetadataReaderFactory metadataReaderFactory = new CachingMetadataReaderFactory(resolver);
|
||||
List<String> allResult = new ArrayList<String>();
|
||||
try
|
||||
{
|
||||
for (String aliasesPackage : typeAliasesPackage.split(","))
|
||||
{
|
||||
List<String> result = new ArrayList<String>();
|
||||
aliasesPackage = ResourcePatternResolver.CLASSPATH_ALL_URL_PREFIX
|
||||
+ ClassUtils.convertClassNameToResourcePath(aliasesPackage.trim()) + "/" + DEFAULT_RESOURCE_PATTERN;
|
||||
Resource[] resources = resolver.getResources(aliasesPackage);
|
||||
if (resources != null && resources.length > 0)
|
||||
{
|
||||
MetadataReader metadataReader = null;
|
||||
for (Resource resource : resources)
|
||||
{
|
||||
if (resource.isReadable())
|
||||
{
|
||||
metadataReader = metadataReaderFactory.getMetadataReader(resource);
|
||||
try
|
||||
{
|
||||
result.add(Class.forName(metadataReader.getClassMetadata().getClassName()).getPackage().getName());
|
||||
}
|
||||
catch (ClassNotFoundException e)
|
||||
{
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
if (result.size() > 0)
|
||||
{
|
||||
HashSet<String> hashResult = new HashSet<String>(result);
|
||||
allResult.addAll(hashResult);
|
||||
}
|
||||
}
|
||||
if (allResult.size() > 0)
|
||||
{
|
||||
typeAliasesPackage = String.join(",", (String[]) allResult.toArray(new String[0]));
|
||||
}
|
||||
else
|
||||
{
|
||||
throw new RuntimeException("mybatis typeAliasesPackage 路径扫描错误,参数typeAliasesPackage:" + typeAliasesPackage + "未找到任何包");
|
||||
}
|
||||
}
|
||||
catch (IOException e)
|
||||
{
|
||||
e.printStackTrace();
|
||||
}
|
||||
return typeAliasesPackage;
|
||||
}
|
||||
|
||||
public Resource[] resolveMapperLocations(String[] mapperLocations)
|
||||
{
|
||||
ResourcePatternResolver resourceResolver = new PathMatchingResourcePatternResolver();
|
||||
List<Resource> resources = new ArrayList<Resource>();
|
||||
if (mapperLocations != null)
|
||||
{
|
||||
for (String mapperLocation : mapperLocations)
|
||||
{
|
||||
try
|
||||
{
|
||||
Resource[] mappers = resourceResolver.getResources(mapperLocation);
|
||||
resources.addAll(Arrays.asList(mappers));
|
||||
}
|
||||
catch (IOException e)
|
||||
{
|
||||
// ignore
|
||||
}
|
||||
}
|
||||
}
|
||||
return resources.toArray(new Resource[resources.size()]);
|
||||
}
|
||||
|
||||
@Bean
|
||||
public SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception
|
||||
{
|
||||
String typeAliasesPackage = env.getProperty("mybatis.typeAliasesPackage");
|
||||
String mapperLocations = env.getProperty("mybatis.mapperLocations");
|
||||
String configLocation = env.getProperty("mybatis.configLocation");
|
||||
typeAliasesPackage = setTypeAliasesPackage(typeAliasesPackage);
|
||||
VFS.addImplClass(SpringBootVFS.class);
|
||||
|
||||
final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
|
||||
sessionFactory.setDataSource(dataSource);
|
||||
sessionFactory.setTypeAliasesPackage(typeAliasesPackage);
|
||||
sessionFactory.setMapperLocations(resolveMapperLocations(StringUtils.split(mapperLocations, ",")));
|
||||
sessionFactory.setConfigLocation(new DefaultResourceLoader().getResource(configLocation));
|
||||
return sessionFactory.getObject();
|
||||
}
|
||||
}
|
||||
Loading…
Reference in new issue