group-four
/
cloud-car
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat():围栏和故障的缓存

master
86191 2024-09-30 09:22:46 +08:00
parent 55169e9267
commit 7b36e4b359
21 changed files with 425 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
cloud-common/cloud-common-cache/pom.xml 100644
View File

@ -0,0 +1,28 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-common</artifactId>
<version>3.6.3</version>
</parent>
<groupId>com.muyu.cache</groupId>
<artifactId>cloud-common-cache</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-redis</artifactId>
</dependency>
</dependencies>
</project>

38
cloud-common/cloud-common-cache/src/main/java/com/muyu/cache/CacheAbsBasic.java vendored 100644
View File

@ -0,0 +1,38 @@
package com.muyu.cache;/**
* @author yuping
* @package com.muyu.cache
* @name CacheAbsBasic
* @date 2024/9/29 20:10 抽象缓存层
*/
import com.muyu.common.redis.service.RedisService;
import org.springframework.beans.factory.annotation.Autowired;
import static cn.hutool.core.lang.ansi.AnsiEncoder.encode;
/**
* @Author YuPing
* @Description
* @Version 1.0
* @Data 2024-09-29 20:10:09
*/
public abstract class CacheAbsBasic<K,V> implements CacheBasic<K,V>{
@Autowired
private RedisService redisService; // spring redis 工具类
@Override
public void put(K key, V value) {
redisService.setCacheObject(encodeKey(key), value); // 编码 --> 缓存基础的对象 Integer String 实体类等
}
@Override
public V get(K key) {
return redisService.getCacheObject(encode(key)); // 获取缓存的基本对象 编码
}
@Override
public void remove(K key) {
redisService.deleteObject(encode(key));
}
}

16
cloud-common/cloud-common-cache/src/main/java/com/muyu/cache/CacheBasic.java vendored 100644
View File

@ -0,0 +1,16 @@
package com.muyu.cache;
/**
* @author yuping
* @package com.muyu.cache
* @name CacheBasic
* @date 2024/9/29 20:08 缓存基础
*/
public interface CacheBasic <K,V> extends PrimaryKeyBasic<K>{
void put(K key, V value);
V get(K key);
void remove(K key);
}

34
cloud-common/cloud-common-cache/src/main/java/com/muyu/cache/PrimaryKeyBasic.java vendored 100644
View File

@ -0,0 +1,34 @@
package com.muyu.cache;
/**
* @author yuping
* @package com.muyu.cache
* @name PrimaryKeyBasic
* @date 2024/9/29 20:03 主键基础
*/
public interface PrimaryKeyBasic <K> {
/**
* key 前缀
* @return key前缀
*/
public String keyPre();
/**
* key 编码
* @param key 缓存键
* @return 封装键
*/
public default String encodeKey(K key) {
return keyPre() + key.toString(); //key 前缀
}
/**
* 解码 key
* @param key 编码key
* @return 解码后的key
*/
public K decode(String key);
}

1
cloud-common/pom.xml
View File

@ -21,6 +21,7 @@
<module>cloud-common-xxl</module>
<module>cloud-common-rabbit</module>
<module>cloud-common-saas</module>
<module>cloud-common-cache</module>
</modules>
<artifactId>cloud-common</artifactId>

1
cloud-modules/saas/pom.xml
View File

@ -14,6 +14,7 @@
<modules>
<module>saas-common</module>
<module>saas-server</module>
<module>saas-cache</module>
</modules>
<properties>

40
cloud-modules/saas/saas-cache/pom.xml 100644
View File

@ -0,0 +1,40 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>saas</artifactId>
<version>3.6.3</version>
</parent>
<artifactId>saas-cache</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<description>
saas-cache缓存模块
</description>
<dependencies>
<dependency>
<groupId>com.muyu.common</groupId>
<artifactId>saas-common</artifactId>
<version>3.6.3</version>
</dependency>
<dependency>
<groupId>com.muyu.cache</groupId>
<artifactId>cloud-common-cache</artifactId>
<version>3.6.3</version>
</dependency>
</dependencies>
</project>

32
cloud-modules/saas/saas-cache/src/main/java/com/muyu/cache/ElectronicFenceCacheService.java vendored 100644
View File

@ -0,0 +1,32 @@
package com.muyu.cache;
import com.muyu.common.domain.database.ElectronicFence;
import org.springframework.stereotype.Component;
/**
* @Author YuPing
* @Description 电子围栏缓存
* @Version 1.0
* @Data 2024-09-29 20:53:46
*/
@Component
public class ElectronicFenceCacheService extends CacheAbsBasic<String, ElectronicFence>{
/**
* key前缀
* @return
*/
@Override
public String keyPre() {
return "electronicFence";
}
/**
* 解码
* @param key 编码key
* @return
*/
@Override
public String decode(String key) {
return key.replace(keyPre(), "");
}
}

32
cloud-modules/saas/saas-cache/src/main/java/com/muyu/cache/ElectronicFenceGroupCacheService.java vendored 100644
View File

@ -0,0 +1,32 @@
package com.muyu.cache;
import com.muyu.common.domain.database.ElectronicFenceGroup;
import org.springframework.stereotype.Component;
/**
* @Author YuPing
* @Description 围栏组缓存
* @Version 1.0
* @Data 2024-09-29 20:57:46
*/
@Component
public class ElectronicFenceGroupCacheService extends CacheAbsBasic<String, ElectronicFenceGroup>{
/**
* key前缀
* @return
*/
@Override
public String keyPre() {
return "electronicFenceGroup";
}
/**
* 解码
* @param key 编码key
* @return
*/
@Override
public String decode(String key) {
return key.replace(keyPre(), "");
}
}

32
cloud-modules/saas/saas-cache/src/main/java/com/muyu/cache/EnterpriseCacheService.java vendored 100644
View File

@ -0,0 +1,32 @@
package com.muyu.cache;
import com.muyu.common.domain.Enterprise;
import org.springframework.stereotype.Component;
/**
* @author yuping
* @package com.muyu.cache
* @name EnterpriseCacheService
* @date 2024/9/29 20:21 企业缓存
*/
@Component
public class EnterpriseCacheService extends CacheAbsBasic<String, Enterprise>{
/**
* 缓存前缀
* @return
*/
@Override
public String keyPre() {
return "enterprise:info:";
}
/**
* 解码
* @param key 编码key
* @return
*/
@Override
public String decode(String key) {
return key.replace(keyPre(), "");
}
}

32
cloud-modules/saas/saas-cache/src/main/java/com/muyu/cache/SysCarFaultCacheService.java vendored 100644
View File

@ -0,0 +1,32 @@
package com.muyu.cache;
import com.muyu.common.domain.SysCarFault;
import org.springframework.stereotype.Component;
/**
* @Author YuPing
* @Description 故障缓存
* @Version 1.0
* @Data 2024-09-29 21:10:31
*/
@Component
public class SysCarFaultCacheService extends CacheAbsBasic<String, SysCarFault>{
/**
* 缓存前缀
* @return
*/
@Override
public String keyPre() {
return "sysCarFault";
}
/**
* 解码
* @param key 编码key
* @return
*/
@Override
public String decode(String key) {
return key.replace(keyPre(), "");
}
}

23
cloud-modules/saas/saas-cache/src/main/java/com/muyu/cache/SysCarFaultMessageCacheService.java vendored 100644
View File

@ -0,0 +1,23 @@
package com.muyu.cache;
import com.muyu.common.domain.SysCarFaultMessage;
import org.springframework.stereotype.Component;
/**
* @Author YuPing
* @Description 站内信缓存
* @Version 1.0
* @Data 2024-09-29 21:13:19
*/
@Component
public class SysCarFaultMessageCacheService extends CacheAbsBasic<String, SysCarFaultMessage>{
@Override
public String keyPre() {
return "sysCarFaultMessage";
}
@Override
public String decode(String key) {
return key.replace(keyPre(), "");
}
}

5
cloud-modules/saas/saas-cache/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports 100644
View File

@ -0,0 +1,5 @@
com.muyu.cache.ElectronicFenceCacheService
com.muyu.cache.ElectronicFenceGroupCacheService
com.muyu.cache.EnterpriseCacheService
com.muyu.cache.SysCarFaultCacheService
com.muyu.cache.SysCarFaultMessageCacheService

4
cloud-modules/saas/saas-common/src/main/java/com/muyu/common/domain/DataType.java
View File

@ -28,10 +28,10 @@ public class DataType implements Serializable{
* 数据类型ID
*/
@TableId(value = "data_type_id",type = IdType.AUTO)
private Integer DataTypeId;
private Integer dataTypeId;
/**
* 数据类型名称
*/
private String DataTypeName;
private String dataTypeName;
}

6
cloud-modules/saas/saas-server/pom.xml
View File

@ -24,6 +24,12 @@
<dependencies>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>saas-cache</artifactId>
<version>3.6.3</version>
</dependency>
<dependency>
<groupId>com.muyu.common</groupId>
<artifactId>saas-common</artifactId>

2
cloud-modules/saas/saas-server/src/main/java/com/muyu/server/mapper/MessageTemplateTypeMapper.java
View File

@ -14,6 +14,4 @@ import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface MessageTemplateTypeMapper extends BaseMapper<MessageTemplateType> {
}

10
cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/ElectronicFenceGroupServiceImpl.java
View File

@ -2,6 +2,7 @@ package com.muyu.server.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.cache.ElectronicFenceGroupCacheService;
import com.muyu.common.core.utils.StringUtils;
import com.muyu.common.domain.database.ElectronicFenceGroup;
import com.muyu.common.domain.database.FenceGroupMid;
@ -38,6 +39,9 @@ public class ElectronicFenceGroupServiceImpl extends ServiceImpl<ElectronicFence
@Autowired
private FenceGroupMidService fenceGroupMidService;
@Autowired
private ElectronicFenceGroupCacheService electronicFenceGroupCacheService;
@Override
public List<ElectronicFenceGroup> selectGroupList(ElectronicFenceGroupListReq req) {
@ -55,6 +59,10 @@ public class ElectronicFenceGroupServiceImpl extends ServiceImpl<ElectronicFence
);
List<ElectronicFenceGroup> list = this.list(queryWrapper);
list.forEach(electronicFenceGroup -> {
electronicFenceGroupCacheService.put(electronicFenceGroup.getId().toString(),electronicFenceGroup);
});
return list;
}
@ -77,6 +85,8 @@ public class ElectronicFenceGroupServiceImpl extends ServiceImpl<ElectronicFence
electronicFenceGroupResp.setElectronicFenceRespList(electronicFenceRespList);
}
electronicFenceGroupCacheService.put(electronicFenceGroup.getId().toString(),electronicFenceGroup);
return electronicFenceGroupResp;
}

37
cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/ElectronicFenceServiceImpl.java
View File

@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.cache.ElectronicFenceCacheService;
import com.muyu.common.core.utils.StringUtils;
import com.muyu.common.domain.database.ElectronicFence;
import com.muyu.common.domain.req.ElectroicFenceAddReq;
@ -31,6 +32,9 @@ public class ElectronicFenceServiceImpl extends ServiceImpl<ElectronicFenceMappe
@Autowired
private ElectronicFenceMapper electronicFenceMapper;
@Autowired
private ElectronicFenceCacheService electronicFenceCacheService;
@Override
public List<ElectronicFenceResp> fenceselectList(ElectroicFenceListReq electroicFenceListReq) {
@ -38,40 +42,44 @@ public class ElectronicFenceServiceImpl extends ServiceImpl<ElectronicFenceMappe
LambdaQueryWrapper<ElectronicFence> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.like(
StringUtils.isNotNull(electroicFenceListReq.getName()),ElectronicFence::getName, electroicFenceListReq.getName()
StringUtils.isNotEmpty(electroicFenceListReq.getName()),ElectronicFence::getName, electroicFenceListReq.getName()
);
queryWrapper.eq(
StringUtils.isNotEmpty(electroicFenceListReq.getFenceType()),ElectronicFence::getFenceType, electroicFenceListReq.getFenceType()
);
queryWrapper.eq(
StringUtils.isNotEmpty(electroicFenceListReq.getFenceType()),ElectronicFence::getFenceType, electroicFenceListReq.getFenceType()
);
queryWrapper.eq(
StringUtils.isNotEmpty(electroicFenceListReq.getStatus()),ElectronicFence::getStatus, electroicFenceListReq.getStatus()
);
List<ElectronicFence> list = this.list(queryWrapper);
list.forEach(electronicFence -> {
electronicFenceCacheService.put(electronicFence.getId().toString(),electronicFence);
});
return list.stream().map(ElectronicFence::bullerResp).toList();
}
@Override
public void AddFence(ElectroicFenceAddReq electroicFenceAddReq) {
electronicFenceMapper.insert(ElectronicFence.buildElectroicAdd(electroicFenceAddReq));
}
@Override
public ElectronicFence findElectronicByid(Long id) {
ElectronicFence electronicFence = electronicFenceMapper.selectById(id);
electronicFenceCacheService.put(id.toString(),electronicFence);
return electronicFence;
}
@Override
public void delElectronById(Long id) {
electronicFenceCacheService.remove(id.toString());
electronicFenceMapper.deleteById(id);
}
@ -118,6 +126,10 @@ public class ElectronicFenceServiceImpl extends ServiceImpl<ElectronicFenceMappe
List<ElectronicFence> list = this.list(wrapper);
list.forEach(electronicFence -> {
electronicFenceCacheService.put(electronicFence.getId().toString(),electronicFence);
});
return list.stream().map(ElectronicFence::bullerResp).toList();
}
@ -129,6 +141,8 @@ public class ElectronicFenceServiceImpl extends ServiceImpl<ElectronicFenceMappe
List<ElectronicFence> fenceList = this.list(queryWrapper);
electronicFenceCacheService.remove(name);
if (fenceList.size()>0){
throw new RuntimeException("电子围栏名不能重复");
}
@ -141,6 +155,9 @@ public class ElectronicFenceServiceImpl extends ServiceImpl<ElectronicFenceMappe
List<ElectronicFence> electronicFenceList = this.list(Wrappers.<ElectronicFence>lambdaQuery().in(ElectronicFence::getId, ids));
electronicFenceList.forEach(electronicFence -> {
electronicFenceCacheService.put(electronicFence.getId().toString(),electronicFence);
});
return electronicFenceList.stream().map(ElectronicFence::bullerResp).toList();
}

17
cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/EnterpriseServiceImpl.java
View File

@ -1,6 +1,7 @@
package com.muyu.server.service.impl;
import cn.hutool.core.map.MapUtil;
import com.muyu.cache.EnterpriseCacheService;
import com.muyu.common.domain.Enterprise;
import com.muyu.common.util.PageUtils;
import com.muyu.server.mapper.EnterpriseDao;
@ -22,6 +23,9 @@ public class EnterpriseServiceImpl implements EnterpriseService {
@Autowired
private EnterpriseDao enterpriseDao;
@Autowired
private EnterpriseCacheService enterpriseCacheService;
/**
* 分页查询企业运营信息
* @param param
@ -49,6 +53,9 @@ public class EnterpriseServiceImpl implements EnterpriseService {
@Override
public int insert(Enterprise enterprise) {
int rows = enterpriseDao.insert(enterprise);
if (rows > 0){
enterpriseCacheService.put(String.valueOf(enterprise.getEnterpriseId()), enterprise);
}
return rows;
}
@ -61,6 +68,12 @@ public class EnterpriseServiceImpl implements EnterpriseService {
@Override
public HashMap searchById(int enterpriseId) {
HashMap map = enterpriseDao.searchById(enterpriseId);
if (map != null){
Enterprise enterprise = enterpriseCacheService.get(String.valueOf(enterpriseId));
if (enterprise != null){
map.put("enterprise", enterprise);
}
}
return map;
}
@ -73,6 +86,9 @@ public class EnterpriseServiceImpl implements EnterpriseService {
@Override
public int updateEnterprise(Enterprise enterprise) {
int rows = enterpriseDao.updateEnterprise(enterprise);
if (rows > 0){
enterpriseCacheService.put(String.valueOf(enterprise.getEnterpriseId()), enterprise);
}
return rows;
}
@ -90,6 +106,7 @@ public class EnterpriseServiceImpl implements EnterpriseService {
Integer[] idList = Arrays.asList(ids).toArray(new Integer[0]);
int rows = enterpriseDao.deleteByIds(idList);
enterpriseCacheService.remove(String.valueOf(idList));
return rows;
}

34
cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/SysCarFaultMessageServiceImpl.java
View File

@ -3,9 +3,11 @@ package com.muyu.server.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.cache.SysCarFaultMessageCacheService;
import com.muyu.common.domain.SysCarFaultMessage;
import com.muyu.server.mapper.SysCarFaultMessageMapper;
import com.muyu.server.service.SysCarFaultMessageService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
@ -20,6 +22,11 @@ import java.util.List;
@Service
public class SysCarFaultMessageServiceImpl extends ServiceImpl<SysCarFaultMessageMapper, SysCarFaultMessage> implements SysCarFaultMessageService {
@Autowired
private SysCarFaultMessageCacheService sysCarFaultMessageCacheService;
/**
* 查询故障消息列表
* @param sysCarFaultMessage
@ -28,7 +35,14 @@ public class SysCarFaultMessageServiceImpl extends ServiceImpl<SysCarFaultMessag
@Override
public List<SysCarFaultMessage> selectSysCarFaultMessageList(SysCarFaultMessage sysCarFaultMessage) {
LambdaQueryWrapper<SysCarFaultMessage> wrapper = new LambdaQueryWrapper<>();
return baseMapper.selectList(wrapper);
List<SysCarFaultMessage> list = baseMapper.selectList(wrapper);
list.forEach(item->{
sysCarFaultMessageCacheService.put(item.getContent(),item);
});
return list;
}
/**
@ -37,7 +51,14 @@ public class SysCarFaultMessageServiceImpl extends ServiceImpl<SysCarFaultMessag
*/
@Override
public List<SysCarFaultMessage> listStatusOnt( ) {
return baseMapper.listStatusOnt();
List<SysCarFaultMessage> list = baseMapper.listStatusOnt();
list.forEach(item->{
sysCarFaultMessageCacheService.put(item.getContent(),item);
});
return list;
}
/**
@ -46,6 +67,13 @@ public class SysCarFaultMessageServiceImpl extends ServiceImpl<SysCarFaultMessag
*/
@Override
public List<SysCarFaultMessage> listStatusTwo( ) {
return baseMapper.listStatusTwo();
List<SysCarFaultMessage> list = baseMapper.listStatusTwo();
list.forEach(item->{
sysCarFaultMessageCacheService.put(item.getContent(),item);
});
return list;
}
}

19
cloud-modules/saas/saas-server/src/main/java/com/muyu/server/service/impl/SysCarFaultServiceImpl.java
View File

@ -2,6 +2,7 @@ package com.muyu.server.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.cache.SysCarFaultCacheService;
import com.muyu.common.core.utils.StringUtils;
import com.muyu.common.domain.SysCarFault;
import com.muyu.server.mapper.SysCarFaultMapper;
@ -27,6 +28,9 @@ public class SysCarFaultServiceImpl
@Autowired
private SysCarFaultMapper mapper;
@Autowired
private SysCarFaultCacheService sysCarFaultCacheService;
/**
* 精确查询车辆故障管理
*
@ -39,6 +43,9 @@ public class SysCarFaultServiceImpl
LambdaQueryWrapper<SysCarFault> queryWrapper = new LambdaQueryWrapper<>();
Assert.notNull(id, "id不可为空");
queryWrapper.eq(SysCarFault::getId, id);
sysCarFaultCacheService.put(id.toString(),this.getOne(queryWrapper));
return this.getOne(queryWrapper);
}
@ -70,7 +77,14 @@ public class SysCarFaultServiceImpl
if (sysCarFault.getCarTypeId()!=null){
queryWrapper.eq(SysCarFault::getCarTypeId,sysCarFault.getTypeId());
}
return this.list(queryWrapper);
List<SysCarFault> list = this.list(queryWrapper);
list.forEach(sysCarFault1 -> {
sysCarFaultCacheService.put(sysCarFault1.getId().toString(),sysCarFault1);
});
return list;
}
@ -83,6 +97,9 @@ public class SysCarFaultServiceImpl
@Override
public SysCarFault selectFaultByFaultCode(String faultCode) {
sysCarFaultCacheService.put(faultCode,mapper.selectFaultByFaultCode(faultCode));
return mapper.selectFaultByFaultCode(faultCode);
}