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

Compare commits

base: group-four:59050208a0e577aa67a1c6bd8bc096118d2129d8
Branches Tags
group-four:dev
group-four:dev.template
group-four:dev.business
group-four:dev.vehiclegateway
group-four:dev.operation
group-four:dev.event
group-four:master
..
compare: group-four:6dd3d73f6291fc0c7767a3679a10469ec0f0379d
Branches Tags
group-four:dev
group-four:dev.template
group-four:dev.business
group-four:dev.vehiclegateway
group-four:dev.operation
group-four:dev.event
group-four:master

3 Commits
59050208a0 ... 6dd3d73f62

Author SHA1 Message Date
86191 6dd3d73f62 fix():把saas缓存对象换成缓存列表 2024-10-02 16:23:41 +08:00
86191 2623669eb0 fix():把saas缓存对象换成缓存列表 2024-10-02 16:22:39 +08:00
86191 3a8b35b710 fix():把saas缓存对象换成缓存列表 2024-10-02 16:21:58 +08:00
29 changed files with 72 additions and 267 deletions
Show Stats Expand all files Collapse all files

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

@ -10,6 +10,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;
import static cn.hutool.core.lang.ansi.AnsiEncoder.encode;
@ -26,7 +27,7 @@ public abstract class CacheAbsBasic<K,V> implements CacheBasic<K,V>{
@Override
public void put(K key, V value) {
redisService.setCacheObject(encodeKey(key), value); // 编码 --> 缓存基础的对象 Integer String 实体类等
redisService.setCacheObject(encodeKey(key), value,30L, TimeUnit.MINUTES); // 编码 --> 缓存基础的对象 Integer String 实体类等
}
@Override

4
cloud-modules/cloud-modules-template/src/main/java/com/muyu/template/config/MqttConfigure.java
View File

@ -4,9 +4,6 @@ import com.alibaba.fastjson2.JSON;
import com.muyu.common.domain.MessageTemplateType;
import com.muyu.common.domain.SysCar;
import com.muyu.common.redis.service.RedisService;
import com.muyu.server.service.MessageTemplateTypeService;
import com.muyu.server.service.SysCarService;
import com.muyu.server.service.impl.SysCarServiceImpl;
import lombok.extern.log4j.Log4j2;
import org.eclipse.paho.client.mqttv3.*;
import org.springframework.beans.factory.annotation.Autowired;
@ -16,6 +13,7 @@ import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.util.List;
/**
*
* @author liuxinyue
* @Package：com.muyu.mqtt.configure
* @Project：cloud-server

4
cloud-modules/saas/saas-cache/src/main/java/com/muyu/cache/CarTypeCacheService.java vendored
View File

@ -3,6 +3,8 @@ package com.muyu.cache;
import com.muyu.common.domain.CarType;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author YuPing
* @Description 车辆类型缓存
@ -10,7 +12,7 @@ import org.springframework.stereotype.Component;
* @Data 2024-09-30 16:31:44
*/
@Component
public class CarTypeCacheService extends CacheAbsBasic<String, CarType> {
public class CarTypeCacheService extends CacheAbsBasic<String, List<CarType>> {
/**
* 缓存key前缀
* @return

4
cloud-modules/saas/saas-cache/src/main/java/com/muyu/cache/DataTypeCacheService.java vendored
View File

@ -3,6 +3,8 @@ package com.muyu.cache;
import com.muyu.common.domain.DataType;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author YuPing
* @Description 数据类型缓存
@ -10,7 +12,7 @@ import org.springframework.stereotype.Component;
* @Data 2024-09-30 10:57:24
*/
@Component
public class DataTypeCacheService extends CacheAbsBasic<String, DataType> {
public class DataTypeCacheService extends CacheAbsBasic<String, List<DataType>> {
/**
* key前缀
* @return

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

@ -12,7 +12,7 @@ import java.util.List;
* @Data 2024-09-29 20:53:46
*/
@Component
public class ElectronicFenceCacheService extends CacheAbsBasic<String, ElectronicFence>{
public class ElectronicFenceCacheService extends CacheAbsBasic<String, List<ElectronicFence>>{
/**
* key前缀
* @return

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

@ -3,6 +3,8 @@ package com.muyu.cache;
import com.muyu.common.domain.database.ElectronicFenceGroup;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author YuPing
* @Description 围栏组缓存
@ -10,7 +12,7 @@ import org.springframework.stereotype.Component;
* @Data 2024-09-29 20:57:46
*/
@Component
public class ElectronicFenceGroupCacheService extends CacheAbsBasic<String, ElectronicFenceGroup>{
public class ElectronicFenceGroupCacheService extends CacheAbsBasic<String, List<ElectronicFenceGroup>>{
/**
* key前缀
* @return

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

@ -3,6 +3,8 @@ package com.muyu.cache;
import com.muyu.common.domain.Enterprise;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @author yuping
* @package com.muyu.cache
@ -10,7 +12,7 @@ import org.springframework.stereotype.Component;
* @date 2024/9/29 20:21 企业缓存
*/
@Component
public class EnterpriseCacheService extends CacheAbsBasic<String, Enterprise>{
public class EnterpriseCacheService extends CacheAbsBasic<String, List<Enterprise>>{
/**
* 缓存前缀
* @return

4
cloud-modules/saas/saas-cache/src/main/java/com/muyu/cache/MessageTemplateCacheService.java vendored
View File

@ -3,6 +3,8 @@ package com.muyu.cache;
import com.muyu.common.domain.MessageTemplate;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author YuPing
* @Description 报文缓存
@ -10,7 +12,7 @@ import org.springframework.stereotype.Component;
* @Data 2024-09-30 11:01:13
*/
@Component
public class MessageTemplateCacheService extends CacheAbsBasic<String, MessageTemplate>{
public class MessageTemplateCacheService extends CacheAbsBasic<String, List<MessageTemplate>>{
/**
* key前缀
* @return

4
cloud-modules/saas/saas-cache/src/main/java/com/muyu/cache/MessageTemplateTypeCacheService.java vendored
View File

@ -3,6 +3,8 @@ package com.muyu.cache;
import com.muyu.common.domain.MessageTemplateType;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author YuPing
* @Description 报文模版类型缓存
@ -10,7 +12,7 @@ import org.springframework.stereotype.Component;
* @Data 2024-09-30 11:04:43
*/
@Component
public class MessageTemplateTypeCacheService extends CacheAbsBasic<String, MessageTemplateType>{
public class MessageTemplateTypeCacheService extends CacheAbsBasic<String, List<MessageTemplateType>>{
/**
* 缓存key前缀
* @return

7
cloud-modules/saas/saas-cache/src/main/java/com/muyu/cache/SysCarCacheService.java vendored
View File

@ -1,8 +1,11 @@
package com.muyu.cache;
import com.muyu.common.domain.SysCar;
import com.muyu.common.domain.resp.SysCarVo;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author YuPing
* @Description 车辆缓存
@ -10,14 +13,14 @@ import org.springframework.stereotype.Component;
* @Data 2024-09-30 16:35:14
*/
@Component
public class SysCarCacheService extends CacheAbsBasic<String, SysCar>{
public class SysCarCacheService extends CacheAbsBasic<String, List<SysCarVo>>{
/**
* key前缀
* @return
*/
@Override
public String keyPre() {
return "car:";
return "car";
}
/**

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

@ -3,6 +3,8 @@ package com.muyu.cache;
import com.muyu.common.domain.SysCarFault;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author YuPing
* @Description 故障缓存
@ -10,7 +12,7 @@ import org.springframework.stereotype.Component;
* @Data 2024-09-29 21:10:31
*/
@Component
public class SysCarFaultCacheService extends CacheAbsBasic<String, SysCarFault>{
public class SysCarFaultCacheService extends CacheAbsBasic<String, List<SysCarFault>>{
/**
* 缓存前缀
* @return

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

@ -3,6 +3,8 @@ package com.muyu.cache;
import com.muyu.common.domain.SysCarFaultMessage;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author YuPing
* @Description 站内信缓存
@ -10,7 +12,7 @@ import org.springframework.stereotype.Component;
* @Data 2024-09-29 21:13:19
*/
@Component
public class SysCarFaultMessageCacheService extends CacheAbsBasic<String, SysCarFaultMessage>{
public class SysCarFaultMessageCacheService extends CacheAbsBasic<String, List<SysCarFaultMessage>>{
@Override
public String keyPre() {
return "sysCarFaultMessage";

4
cloud-modules/saas/saas-cache/src/main/java/com/muyu/cache/TemplateCacheService.java vendored
View File

@ -3,6 +3,8 @@ package com.muyu.cache;
import com.muyu.common.domain.Template;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author YuPing
* @Description 报文模版缓存
@ -10,7 +12,7 @@ import org.springframework.stereotype.Component;
* @Data 2024-09-30 18:21:46
*/
@Component
public class TemplateCacheService extends CacheAbsBasic<String, Template>{
public class TemplateCacheService extends CacheAbsBasic<String, List<Template>>{
/**
* 缓存key前缀
* @return

6
cloud-modules/saas/saas-cache/src/main/java/com/muyu/cache/WarnRuleCacheService.java vendored
View File

@ -1,8 +1,10 @@
package com.muyu.cache;
import com.muyu.common.domain.WarnRule;
import com.muyu.common.domain.resp.WarnRuleResp;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author YuPing
* @Description 预警规则缓存
@ -10,7 +12,7 @@ import org.springframework.stereotype.Component;
* @Data 2024-09-30 16:37:09
*/
@Component
public class WarnRuleCacheService extends CacheAbsBasic<String, WarnRule>{
public class WarnRuleCacheService extends CacheAbsBasic<String, List<WarnRuleResp>>{
/**
* 缓存key前缀
* @return

6
cloud-modules/saas/saas-cache/src/main/java/com/muyu/cache/WarnStrategyCacheService.java vendored
View File

@ -1,8 +1,10 @@
package com.muyu.cache;
import com.muyu.common.domain.WarnStrategy;
import com.muyu.common.domain.resp.WarnStrategyResp;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author YuPing
* @Description 预警策略缓存
@ -10,7 +12,7 @@ import org.springframework.stereotype.Component;
* @Data 2024-09-30 16:38:35
*/
@Component
public class WarnStrategyCacheService extends CacheAbsBasic<String, WarnStrategy> {
public class WarnStrategyCacheService extends CacheAbsBasic<String, List<WarnStrategyResp>> {
/**
* 缓存key前缀
* @return

5
cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/DataTypeController.java
View File

@ -48,10 +48,7 @@ public class DataTypeController {
public Result<List<DataType>> dataTypeList() {
List<DataType> list = dataTypeService.list();
// 缓存数据
list.forEach(item->dataTypeCacheService.put(item.getDataTypeId().toString(),item));
dataTypeCacheService.put("List",list);
return Result.success(list);
}

4
cloud-modules/saas/saas-server/src/main/java/com/muyu/server/controller/TemplateController.java
View File

@ -47,9 +47,7 @@ public class TemplateController {
List<Template> list = templateService.list();
list.forEach(template -> {
templateCacheService.put(template.getTemplateId().toString(),template);
});
templateCacheService.put("List",list);
return Result.success(list);
}

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

@ -34,9 +34,7 @@ public class CarTypeServiceImpl extends ServiceImpl<CarTypeMapper, CarType> impl
QueryWrapper<CarType> carTypeQueryWrapper = new QueryWrapper<>();
List<CarType> list = carTypeMapper.selectList(carTypeQueryWrapper);
for (CarType carType : list) {
carTypeCacheService.put(carTypeCacheService.keyPre() + carType.getId(), carType);
}
carTypeCacheService.put("List", list);
return list;
}
@ -44,9 +42,6 @@ public class CarTypeServiceImpl extends ServiceImpl<CarTypeMapper, CarType> impl
@Override
public CarTypeResp selectCarTypeRespList(Long id) {
CarTypeResp carTypeResp = carTypeMapper.selectCarTypeRespList(id);
carTypeCacheService.put(carTypeCacheService.keyPre() + id, carTypeResp);
return carTypeResp;
}
@ -55,21 +50,12 @@ public class CarTypeServiceImpl extends ServiceImpl<CarTypeMapper, CarType> impl
QueryWrapper<CarType> carTypeQueryWrapper = new QueryWrapper<>();
carTypeQueryWrapper.eq("car_type_id", carTypeId);
CarType carType = carTypeMapper.selectOne(carTypeQueryWrapper);
carTypeCacheService.put(carTypeCacheService.keyPre() + carTypeId, carType);
return carType;
}
@Override
public List<CarTypeResp> findAllCars() {
List<CarTypeResp> allCars = carTypeMapper.findAllCars();
for (CarTypeResp carTypeResp : allCars) {
carTypeCacheService.put(carTypeCacheService.keyPre() + carTypeResp.getId(), carTypeResp);
}
return allCars;
}
}

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

@ -60,9 +60,7 @@ public class ElectronicFenceGroupServiceImpl extends ServiceImpl<ElectronicFence
);
List<ElectronicFenceGroup> list = this.list(queryWrapper);
list.forEach(electronicFenceGroup -> {
electronicFenceGroupCacheService.put(electronicFenceGroup.getId().toString(),electronicFenceGroup);
});
electronicFenceGroupCacheService.put("List",list);
return list;
@ -85,10 +83,6 @@ public class ElectronicFenceGroupServiceImpl extends ServiceImpl<ElectronicFence
electronicFenceGroupResp.setElectronicFenceRespList(electronicFenceRespList);
}
electronicFenceGroupCacheService.put(electronicFenceGroup.getId().toString(),electronicFenceGroup);
return electronicFenceGroupResp;
}

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

@ -21,6 +21,7 @@ import java.util.List;
/**
* 电子围栏 服务层处理
*
* @author yuping
* @Package：com.muyu.fence.service.impl
* @Project：cloud-server
@ -44,126 +45,87 @@ public class ElectronicFenceServiceImpl extends ServiceImpl<ElectronicFenceMappe
LambdaQueryWrapper<ElectronicFence> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.like(
StringUtils.isNotEmpty(electroicFenceListReq.getName()),ElectronicFence::getName, electroicFenceListReq.getName()
StringUtils.isNotEmpty(electroicFenceListReq.getName()), ElectronicFence::getName, electroicFenceListReq.getName()
);
queryWrapper.eq(
StringUtils.isNotEmpty(electroicFenceListReq.getFenceType()),ElectronicFence::getFenceType, electroicFenceListReq.getFenceType()
StringUtils.isNotEmpty(electroicFenceListReq.getFenceType()), ElectronicFence::getFenceType, electroicFenceListReq.getFenceType()
);
queryWrapper.eq(
StringUtils.isNotEmpty(electroicFenceListReq.getStatus()),ElectronicFence::getStatus, electroicFenceListReq.getStatus()
StringUtils.isNotEmpty(electroicFenceListReq.getStatus()), ElectronicFence::getStatus, electroicFenceListReq.getStatus()
);
List<ElectronicFence> list = this.list(queryWrapper);
list.forEach(electronicFence -> {
electronicFenceCacheService.put(electronicFence.getId().toString(), electronicFence);
});
electronicFenceCacheService.put("List", list);
ElectronicFence electronicFence = electronicFenceCacheService.get("electronicFence");
log.info("electronicFenceCacheService.get(electronicFence) = {}",electronicFence);
List<ElectronicFence> electronicFenceList = electronicFenceCacheService.get("electronicFenceList");
log.info("electronicFenceCacheService.get(electronicFenceList) = {}", electronicFenceList);
return list.stream().map(ElectronicFence::bullerResp).toList();
}
@Override
public void AddFence(ElectroicFenceAddReq electroicFenceAddReq) {
electronicFenceMapper.insert(ElectronicFence.buildElectroicAdd(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);
}
@Override
public void openFence(Long id) {
updateStatus(id,0);
updateStatus(id, 0);
}
@Override
public void closeFence(Long id) {
updateStatus(id,1);
updateStatus(id, 1);
}
public void updateStatus (Long id,int status){
public void updateStatus(Long id, int status) {
UpdateWrapper<ElectronicFence> updateWrapper = new UpdateWrapper<>();
updateWrapper.eq("id",id).set("status",status);
updateWrapper.eq("id", id).set("status", status);
this.update(updateWrapper);
}
@Override
public void setFenceWay(Long id, String longitudeLatitude) {
UpdateWrapper<ElectronicFence> updateWrapper = new UpdateWrapper<>();
updateWrapper.eq("id",id).set("longitude_latitude",longitudeLatitude);
updateWrapper.eq("id", id).set("longitude_latitude", longitudeLatitude);
this.update(updateWrapper);
}
@Override
public List<ElectronicFenceResp> fenceArray() {
LambdaQueryWrapper<ElectronicFence> queryWrapper = new LambdaQueryWrapper<>();
LambdaQueryWrapper<ElectronicFence> wrapper = queryWrapper.eq(ElectronicFence::getStatus, 0);
List<ElectronicFence> list = this.list(wrapper);
list.forEach(electronicFence -> {
electronicFenceCacheService.put(electronicFence.getId().toString(),electronicFence);
});
return list.stream().map(ElectronicFence::bullerResp).toList();
}
@Override
public void unquireFence(String name) {
LambdaQueryWrapper<ElectronicFence> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(ElectronicFence::getName,name);
queryWrapper.eq(ElectronicFence::getName, name);
List<ElectronicFence> fenceList = this.list(queryWrapper);
electronicFenceCacheService.remove(name);
if (fenceList.size()>0){
if (fenceList.size() > 0) {
throw new RuntimeException("电子围栏名不能重复");
}
}
@Override
public List<ElectronicFenceResp> selectListByIds(List<Long> ids) {
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();
return electronicFenceList.stream().map(ElectronicFence::bullerResp).toList();
}
}

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

@ -34,7 +34,7 @@ public class EnterpriseServiceImpl implements EnterpriseService {
*/
@Override
public PageUtils selectEnterprise(Map param) {
ArrayList<HashMap> list = new ArrayList<>();
List<HashMap> list = new ArrayList<>();
long count = enterpriseDao.selectEnterpriseCount();
if (count > 0){
list = enterpriseDao.selectEnterprise(param);
@ -54,9 +54,6 @@ 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;
}
@ -69,12 +66,6 @@ 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;
}
@ -87,9 +78,6 @@ 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;
}
@ -104,10 +92,8 @@ public class EnterpriseServiceImpl implements EnterpriseService {
if (ids == null || ids.length == 0) {
throw new IllegalArgumentException("请选择要删除的企业名称编号");
}
Integer[] idList = Arrays.asList(ids).toArray(new Integer[0]);
int rows = enterpriseDao.deleteByIds(idList);
enterpriseCacheService.remove(String.valueOf(idList));
return rows;
}

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

@ -27,9 +27,6 @@ public class MessageTemplateTypeServiceImpl extends ServiceImpl<MessageTemplate
@Override
public Integer addMessageType(MessageTemplateType messageTemplateType) {
messageTemplateTypeCacheService.put(messageTemplateType.getMessageTemplateTypeId(),messageTemplateType);
return messageTemplateTypeMapper.insert(messageTemplateType);
}
@ -41,9 +38,7 @@ public class MessageTemplateTypeServiceImpl extends ServiceImpl<MessageTemplate
messageTemplateTypeQueryWrapper.eq("message_class",code);
List<MessageTemplateType> messageTemplateTypes = messageTemplateTypeMapper.selectList(messageTemplateTypeQueryWrapper);
messageTemplateTypes.forEach(messageTemplateType -> {
messageTemplateTypeCacheService.put(messageTemplateType.getMessageTemplateTypeId(),messageTemplateType);
});
messageTemplateTypeCacheService.put("List",messageTemplateTypes);
return messageTemplateTypes;
}
@ -54,11 +49,6 @@ public class MessageTemplateTypeServiceImpl extends ServiceImpl<MessageTemplate
messageTemplateTypeQueryWrapper.eq("template_id",templatedId);
messageTemplateTypeQueryWrapper.eq("message_class",code);
List<MessageTemplateType> messageTemplateTypes = messageTemplateTypeMapper.selectList(messageTemplateTypeQueryWrapper);
messageTemplateTypes.forEach(messageTemplateType -> {
messageTemplateTypeCacheService.put(messageTemplateType.getMessageTemplateTypeId(),messageTemplateType);
});
return messageTemplateTypes;
}
@ -68,11 +58,6 @@ public class MessageTemplateTypeServiceImpl extends ServiceImpl<MessageTemplate
messageTemplateTypeQueryWrapper.eq("template_id",templatedId);
messageTemplateTypeQueryWrapper.eq("message_class",code);
List<MessageTemplateType> messageTemplateTypes = messageTemplateTypeMapper.selectList(messageTemplateTypeQueryWrapper);
messageTemplateTypes.forEach(messageTemplateType -> {
messageTemplateTypeCacheService.put(messageTemplateType.getMessageTemplateTypeId(),messageTemplateType);
});
return messageTemplateTypes;
}
@ -82,11 +67,6 @@ public class MessageTemplateTypeServiceImpl extends ServiceImpl<MessageTemplate
QueryWrapper<MessageTemplateType> messageTemplateTypeQueryWrapper = new QueryWrapper<>();
messageTemplateTypeQueryWrapper.eq("template_id",templatedId);
List<MessageTemplateType> messageTemplateTypes = messageTemplateTypeMapper.selectList(messageTemplateTypeQueryWrapper);
messageTemplateTypes.forEach(messageTemplateType -> {
messageTemplateTypeCacheService.put(messageTemplateType.getMessageTemplateTypeId(),messageTemplateType);
});
return messageTemplateTypes;
}
@ -95,11 +75,6 @@ public class MessageTemplateTypeServiceImpl extends ServiceImpl<MessageTemplate
QueryWrapper<MessageTemplateType> messageTemplateTypeQueryWrapper = new QueryWrapper<>();
messageTemplateTypeQueryWrapper.eq("template_id",templateId);
List<MessageTemplateType> messageTemplateTypes = messageTemplateTypeMapper.selectList(messageTemplateTypeQueryWrapper);
messageTemplateTypes.forEach(messageTemplateType -> {
messageTemplateTypeCacheService.put(messageTemplateType.getMessageTemplateTypeId(),messageTemplateType);
});
return messageTemplateTypes;
}
}

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

@ -38,9 +38,7 @@ public class SysCarFaultMessageServiceImpl extends ServiceImpl<SysCarFaultMessag
List<SysCarFaultMessage> list = baseMapper.selectList(wrapper);
list.forEach(item->{
sysCarFaultMessageCacheService.put(item.getContent(),item);
});
sysCarFaultMessageCacheService.put("List",list);
return list;
}
@ -53,11 +51,6 @@ public class SysCarFaultMessageServiceImpl extends ServiceImpl<SysCarFaultMessag
public List<SysCarFaultMessage> listStatusOnt( ) {
List<SysCarFaultMessage> list = baseMapper.listStatusOnt();
list.forEach(item->{
sysCarFaultMessageCacheService.put(item.getContent(),item);
});
return list;
}
@ -67,13 +60,7 @@ public class SysCarFaultMessageServiceImpl extends ServiceImpl<SysCarFaultMessag
*/
@Override
public List<SysCarFaultMessage> listStatusTwo( ) {
List<SysCarFaultMessage> list = baseMapper.listStatusTwo();
list.forEach(item->{
sysCarFaultMessageCacheService.put(item.getContent(),item);
});
return list;
}
}

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

@ -43,9 +43,6 @@ 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);
}
@ -80,9 +77,7 @@ public class SysCarFaultServiceImpl
List<SysCarFault> list = this.list(queryWrapper);
list.forEach(sysCarFault1 -> {
sysCarFaultCacheService.put(sysCarFault1.getId().toString(),sysCarFault1);
});
sysCarFaultCacheService.put("List",list);
return list;
}
@ -97,9 +92,6 @@ public class SysCarFaultServiceImpl
@Override
public SysCarFault selectFaultByFaultCode(String faultCode) {
sysCarFaultCacheService.put(faultCode,mapper.selectFaultByFaultCode(faultCode));
return mapper.selectFaultByFaultCode(faultCode);
}

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

@ -13,6 +13,7 @@ import com.muyu.server.service.SysCarService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Collections;
import java.util.List;
@DS("lizzDB")
@ -27,56 +28,32 @@ public class SysCarServiceImpl extends ServiceImpl<SysCarMapper, SysCar> impleme
@Override
public List<SysCarVo> selectSysCarVoList(SysCarReq sysCarReq) {
List<SysCarVo> sysCarVos = sysCarMapper.selectSysCarVoList(sysCarReq);
sysCarVos.forEach(sysCarVo -> {
sysCarCacheService.put(String.valueOf(sysCarVo.getId()), sysCarVo);
});
sysCarCacheService.put("List", sysCarVos);
return sysCarVos;
}
@Override
public SysCarVo selectSysCarVoById(Long id) {
SysCarVo sysCarVo = sysCarMapper.selectSysCarVoById(id);
if (sysCarVo!=null){
sysCarCacheService.put(String.valueOf(sysCarVo.getId()), sysCarVo);
}
return sysCarVo;
}
@Override
public int addSysCar(SysCar sysCar) {
int rows = sysCarMapper.insert(sysCar);
if (rows>0){
sysCarCacheService.put(String.valueOf(sysCar.getId()), sysCar);
}
return rows;
}
@Override
public int deleteSysCarById(Long id) {
int rows = sysCarMapper.deleteById(id);
sysCarCacheService.remove(String.valueOf(id));
return rows;
}
@Override
public int updateSysCar(SysCar sysCar) {
int rows = sysCarMapper.updateById(sysCar);
sysCarCacheService.put(String.valueOf(sysCar.getId()), sysCar);
return rows;
}
@ -90,11 +67,6 @@ public class SysCarServiceImpl extends ServiceImpl<SysCarMapper, SysCar> impleme
QueryWrapper<SysCar> sysCarQueryWrapper = new QueryWrapper<>();
sysCarQueryWrapper.eq("car_vin", carVin);
List<SysCar> sysCars = sysCarMapper.selectList(sysCarQueryWrapper);
sysCars.forEach(sysCar -> {
sysCarCacheService.put(String.valueOf(sysCar.getId()), sysCar);
});
return sysCars.isEmpty() ? null : sysCars.get(0);
}

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

@ -1,6 +1,5 @@
package com.muyu.server.service.impl;
import com.muyu.cache.MessageTemplateCacheService;
import com.muyu.cache.MessageTemplateTypeCacheService;
import com.muyu.common.domain.MessageTemplateType;
import com.muyu.server.mapper.TemplateNeedMapper;
@ -23,19 +22,9 @@ public class TemplateNeedServiceImpl implements TemplateNeedService {
@Autowired
private TemplateNeedMapper templateNeedMapper;
@Autowired
private MessageTemplateTypeCacheService messageTemplateTypeCacheService;
@Override
public List<MessageTemplateType> selectByTemplateId(Long templateId) {
List<MessageTemplateType> messageTemplateTypes = templateNeedMapper.selectByTemplateId(templateId);
messageTemplateTypes.forEach(messageTemplateType -> {
messageTemplateTypeCacheService.put(messageTemplateType.getMessageTemplateTypeId(),messageTemplateType);
});
return messageTemplateTypes;
}
}

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

@ -43,10 +43,6 @@ public class TemplateServiceImpl extends ServiceImpl<TemplateMapper, Template> i
@Autowired
private RedisTemplate redisTemplate;
@Autowired
private SysCarCacheService sysCarCacheService;
@Override
public void messageParsing(String templateMessage) throws SQLException, IoTDBConnectionException, ClassNotFoundException, StatementExecutionException, ExecutionException, InterruptedException {
@ -69,11 +65,6 @@ public class TemplateServiceImpl extends ServiceImpl<TemplateMapper, Template> i
//根据VIN码获取车辆信息
SysCar carByVin = sysCarService.findCarByVin(carVin);
log.info("车辆信息为:" + carByVin);
sysCarCacheService.put(carVin,carByVin);
//对应车辆所对应的报文模版
Integer templateId = carByVin.getTemplateId();
List<MessageTemplateType> templateTypeList;

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

@ -25,11 +25,9 @@ public class WarnRuleServiceImpl
@Autowired
private WarnRuleMapper warnRuleMapper;
@Autowired
private WarnRuleCacheService warnRuleCacheService;
/**
* 精确查询预警规则
*
@ -40,9 +38,6 @@ public class WarnRuleServiceImpl
public WarnRule selectWarnRuleById(Long id)
{
WarnRule warnRule = warnRuleMapper.selectById(id);
warnRuleCacheService.put(String.valueOf(warnRule.getId()), warnRule);
return warnRule;
}
@ -57,44 +52,26 @@ public class WarnRuleServiceImpl
public List<WarnRuleResp> selectWarnRuleRespList()
{
List<WarnRuleResp> warnRuleResps = warnRuleMapper.selectWarnRuleRespList();
warnRuleResps.forEach(warnRuleResp -> {
warnRuleCacheService.put(warnRuleCacheService.keyPre() + warnRuleResp.getId(), warnRuleResp);
});
warnRuleCacheService.put("List",warnRuleResps);
return warnRuleResps;
}
@Override
public Integer addWarnRule(WarnRule warnRule) {
int rows = warnRuleMapper.insert(warnRule);
if (rows>0){
warnRuleCacheService.put(String.valueOf(warnRule.getId()), warnRule);
}
return rows;
}
@Override
public Integer updWarnRule(WarnRule warnRule) {
LambdaQueryWrapper<WarnRule> queryWrapper = new LambdaQueryWrapper<>();
Integer update = warnRuleMapper.update(queryWrapper);
warnRuleCacheService.put(String.valueOf(warnRule.getId()), warnRule);
return update;
}
@Override
public List<WarnRuleResp> selectListByStrategyId(Long strategyId) {
List<WarnRuleResp> warnRuleResps = warnRuleMapper.selectListByStrategyId(strategyId);
warnRuleResps.forEach(warnRuleResp -> {
warnRuleCacheService.put(warnRuleCacheService.keyPre() + warnRuleResp.getId(), warnRuleResp);
});
return warnRuleResps;
}

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

@ -39,9 +39,6 @@ public class WarnStrategyServiceImpl
public WarnStrategy selectWarnStrategyById(Long id)
{
WarnStrategy warnStrategy = warnStrategyMapper.selectById(id);
warnStrategyCacheService.put(String.valueOf(warnStrategy.getId()), warnStrategy);
return warnStrategy;
}
@ -56,21 +53,13 @@ public class WarnStrategyServiceImpl
public List<WarnStrategyResp> selectWarnStrategyList(WarnStrategyReq warnStrategyReq)
{
List<WarnStrategyResp> warnStrategyResps = warnStrategyMapper.selectWarnStrategyList(warnStrategyReq);
warnStrategyResps.forEach(warnStrategyResp -> {
warnStrategyCacheService.put(warnStrategyCacheService.keyPre() + warnStrategyResp.getId(), warnStrategyResp);
});
warnStrategyCacheService.put("List",warnStrategyResps);
return warnStrategyResps;
}
@Override
public Integer deleteWarnStrategy(Long id) {
int rows = warnStrategyMapper.deleteById(id);
warnStrategyCacheService.remove(String.valueOf(id));
return rows;
}
@ -81,11 +70,7 @@ public class WarnStrategyServiceImpl
@Override
public Integer updWarnStrategy(WarnStrategy warnStrategy){
QueryWrapper<WarnStrategy> wrapper = new QueryWrapper<>(warnStrategy);
Integer update = warnStrategyMapper.update(wrapper);
warnStrategyCacheService.remove(String.valueOf(warnStrategy.getId()));
return update;
}
@ -94,11 +79,7 @@ public class WarnStrategyServiceImpl
*/
@Override
public Integer addWarnStrategy(WarnStrategy warnStrategy){
int rows = warnStrategyMapper.insert(warnStrategy);
warnStrategyCacheService.put(String.valueOf(warnStrategy.getId()), warnStrategy);
return rows;
}
@ -109,13 +90,7 @@ public class WarnStrategyServiceImpl
*/
@Override
public List<WarnStrategyResp> selectListByCarType(Long carTypeId) {
List<WarnStrategyResp> warnStrategyResps = warnStrategyMapper.selectListByCarType(carTypeId);
warnStrategyResps.forEach(warnStrategyResp -> {
warnStrategyCacheService.put(warnStrategyCacheService.keyPre() + warnStrategyResp.getId(), warnStrategyResp);
});
return warnStrategyResps;
}