Compare commits

...

12 Commits

Author SHA1 Message Date
YangPeng 1468206f1d Merge branch 'dev' of https://gitea.qinmian.online/wuzudaniu/cloud-plus-server into dev.saas.yp 2024-10-08 16:34:34 +08:00
DongZeLiang 47222f5f68 fix(): 修复包名等格式规范问题 2024-10-08 16:25:15 +08:00
王鑫 0c8a13439f fix():重新构建结构 2024-10-08 16:17:38 +08:00
YangPeng 492be37314 feat():添加剩余注释 2024-10-08 16:08:45 +08:00
王鑫 5a0f5e28d2 fix():重新构建结构 2024-10-08 16:05:18 +08:00
YangPeng e1d45db36e Merge branch 'dev.saas.yp' into dev
# Conflicts:
#	cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-modules-parse/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-modules-vehicle-gateway/src/main/resources/bootstrap.yml
2024-10-08 16:02:04 +08:00
YangPeng e50219f9fb feat():添加缓存注释 2024-10-08 15:58:28 +08:00
王鑫 54d216b144 fix():重新构建结构 2024-10-08 15:58:18 +08:00
王鑫 293cb42bcf Merge remote-tracking branch 'origin/dev' into dev 2024-10-08 15:56:00 +08:00
YangPeng 83756518ad fix():bootstrap.yml其他名字改成yp启动,防止端口占用 2024-10-07 22:37:39 +08:00
YangPeng 44ec3e9eed Merge branch 'dev.saas.yp' into dev 2024-10-07 22:10:46 +08:00
YangPeng 45cb6b2a17 fix():添加车辆全部缓存 2024-10-07 22:05:38 +08:00
35 changed files with 88 additions and 134 deletions

View File

@ -4,7 +4,7 @@ server:
# nacos线上地址 # nacos线上地址
nacos: nacos:
addr: 127.0.0.1:8848 addr: 123.57.152.124:8848
user-name: nacos user-name: nacos
password: nacos password: nacos
namespace: wx namespace: wx

View File

@ -27,11 +27,6 @@
<groupId>com.muyu</groupId> <groupId>com.muyu</groupId>
<artifactId>cloud-common-redis</artifactId> <artifactId>cloud-common-redis</artifactId>
</dependency> </dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterpise-common</artifactId>
<version>${muyu.version}</version>
</dependency>
</dependencies> </dependencies>
</project> </project>

View File

@ -4,7 +4,7 @@ server:
# nacos线上地址 # nacos线上地址
nacos: nacos:
addr: 127.0.0.1:8848 addr: 123.57.152.124:8848
user-name: nacos user-name: nacos
password: nacos password: nacos
namespace: wx namespace: wx

View File

@ -7,7 +7,9 @@ import lombok.NoArgsConstructor;
import java.util.List; import java.util.List;
/** /**
*
* @version 1.0 * @version 1.0
* @Author xie ya ru * @Author xie ya ru
* @Date 2024/10/6 20:21 * @Date 2024/10/6 20:21

View File

@ -122,7 +122,7 @@
<!-- 获取缓存 --> <!-- 获取缓存 -->
<dependency> <dependency>
<groupId>com.muyu</groupId> <groupId>com.muyu</groupId>
<artifactId>enterprise-cache</artifactId> <artifactId>enterpise-cache</artifactId>
</dependency> </dependency>
</dependencies> </dependencies>

View File

@ -10,6 +10,10 @@ import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
/**
*IoTDB
*/
public class Iotdb { public class Iotdb {
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException { public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {

View File

@ -2,6 +2,9 @@ package com.muyu.data.util;
import org.eclipse.paho.client.mqttv3.*; import org.eclipse.paho.client.mqttv3.*;
/**
* MQTT
*/
public class Receive { public class Receive {
public static void main(String[] args) { public static void main(String[] args) {

View File

@ -1,15 +1,14 @@
package com.muyu.data.warn; package com.muyu.data.warn;
import com.muyu.domain.SysCar; import com.muyu.enterprise.cache.SysCarCacheService;
import com.muyu.enterpise.cache.SysCarCacheService; import com.muyu.enterprise.cache.SysCarTypeCacheService;
import com.muyu.enterpise.cache.SysCarTypeCacheService;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.apache.catalina.mapper.*;
import javax.annotation.PostConstruct; import javax.annotation.PostConstruct;
import javax.annotation.Resource; import javax.annotation.Resource;
/** /**
*
* @version 1.0 * @version 1.0
* @Author xie ya ru * @Author xie ya ru
* @Date 2024/10/6 15:21 * @Date 2024/10/6 15:21

View File

@ -4,7 +4,7 @@ server:
# nacos线上地址 # nacos线上地址
nacos: nacos:
addr: 127.0.0.1:8848 addr: 123.57.152.124:8848
user-name: nacos user-name: nacos
password: nacos password: nacos
namespace: wx namespace: wx

View File

@ -25,71 +25,12 @@
<version>${muyu.version}</version> <version>${muyu.version}</version>
</dependency> </dependency>
<!-- SpringCloud Alibaba Nacos -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- SpringCloud Alibaba Nacos Config -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<!-- SpringCloud Alibaba Sentinel -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<!-- SpringBoot Actuator -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!-- Mysql Connector -->
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
</dependency>
<!-- MuYu Common DataSource -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-datasource</artifactId>
</dependency>
<!-- 缓存公共模块 --> <!-- 缓存公共模块 -->
<dependency> <dependency>
<groupId>com.muyu</groupId> <groupId>com.muyu</groupId>
<artifactId>cloud-common-cache</artifactId> <artifactId>cloud-common-cache</artifactId>
</dependency> </dependency>
<!-- MuYu Common DataScope -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-datascope</artifactId>
</dependency>
<!-- MuYu Common Log -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-log</artifactId>
</dependency>
<!-- 接口模块 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-api-doc</artifactId>
</dependency>
<!-- XllJob定时任务 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-xxl</artifactId>
</dependency>
</dependencies> </dependencies>
</project> </project>

View File

@ -0,0 +1,33 @@
package com.muyu.enterprise.cache;
import com.muyu.common.cache.CacheAbsBasic;
import com.muyu.enterprise.cache.domain.InformationData;
import org.springframework.stereotype.Component;
import java.util.List;
/**
*
* @className: InformationDataService
* @author: Yang 🦅
* @date: 2024/10/7 21:50
* @Version: 1.0
* @description:
*/
@Component
public class InformationDataService extends CacheAbsBasic<String, List<InformationData>> {
@Override
public String keyPre() {
return "";
}
@Override
public String encode(String key) {
return super.encode(key);
}
@Override
public String decode(String key) {
return super.decode(key);
}
}

View File

@ -1,4 +1,4 @@
package com.muyu.enterpise.cache; package com.muyu.enterprise.cache;
import com.muyu.common.cache.CacheAbsBasic; import com.muyu.common.cache.CacheAbsBasic;
import com.muyu.domain.MessageValue; import com.muyu.domain.MessageValue;
@ -7,6 +7,7 @@ import org.springframework.stereotype.Component;
import java.util.List; import java.util.List;
/** /**
*
* @version 1.0 * @version 1.0
* @Author xie ya ru * @Author xie ya ru
* @Date 2024/9/29 20:04 * @Date 2024/9/29 20:04

View File

@ -1,4 +1,4 @@
package com.muyu.enterpise.cache; package com.muyu.enterprise.cache;
import com.muyu.common.cache.CacheAbsBasic; import com.muyu.common.cache.CacheAbsBasic;
import com.muyu.domain.SysCar; import com.muyu.domain.SysCar;
@ -7,6 +7,7 @@ import org.springframework.stereotype.Component;
import java.util.List; import java.util.List;
/** /**
*
* @version 1.0 * @version 1.0
* @Author xie ya ru * @Author xie ya ru
* @Date 2024/9/30 11:06 * @Date 2024/9/30 11:06

View File

@ -1,10 +1,11 @@
package com.muyu.enterpise.cache; package com.muyu.enterprise.cache;
import com.muyu.common.cache.CacheAbsBasic; import com.muyu.common.cache.CacheAbsBasic;
import com.muyu.domain.SysCarType; import com.muyu.domain.SysCarType;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
/** /**
*
* @version 1.0 * @version 1.0
* @Author xie ya ru * @Author xie ya ru
* @Date 2024/9/30 11:18 * @Date 2024/9/30 11:18

View File

@ -1,10 +1,11 @@
package com.muyu.enterpise.cache; package com.muyu.enterprise.cache;
import com.muyu.common.cache.CacheAbsBasic; import com.muyu.common.cache.CacheAbsBasic;
import com.muyu.domain.WarnStrategy; import com.muyu.domain.WarnStrategy;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
/** /**
*
* @Authoryan * @Authoryan
* @Packagecom.muyu.enterpise.cache * @Packagecom.muyu.enterpise.cache
* @Projectplus * @Projectplus

View File

@ -1,4 +1,4 @@
package com.muyu.common.domain; package com.muyu.enterprise.cache.domain;
import com.muyu.common.system.domain.SysDept; import com.muyu.common.system.domain.SysDept;
import com.muyu.domain.SysCar; import com.muyu.domain.SysCar;

View File

@ -1,5 +1,5 @@
com.muyu.enterpise.cache.MessageValueCacheService com.muyu.enterprise.cache.MessageValueCacheService
com.muyu.enterpise.cache.SysCarCacheService com.muyu.enterprise.cache.SysCarCacheService
com.muyu.enterpise.cache.SysCarTypeCacheService com.muyu.enterprise.cache.SysCarTypeCacheService
com.muyu.enterpise.cache.WarnStrategyCacjeService com.muyu.enterprise.cache.WarnStrategyCacjeService

View File

@ -46,10 +46,5 @@
<artifactId>cloud-common-system</artifactId> <artifactId>cloud-common-system</artifactId>
</dependency> </dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-saas</artifactId>
</dependency>
</dependencies> </dependencies>
</project> </project>

View File

@ -12,10 +12,10 @@ import org.springframework.web.bind.annotation.*;
import java.util.List; import java.util.List;
/** /**
* vin
* @version 1.0 * @version 1.0
* @Author xie ya ru * @Author xie ya ru
* @Date 2024/9/28 21:00 * @Date 2024/9/28 21:00
* @ vin
*/ */
@FeignClient(contextId = "remoteMessageValueService", value = ServiceNameConstants.ENTERPRISE_SERVICE, fallbackFactory = RemoteMessageValueFallbackFactory.class,path = "messageValue") @FeignClient(contextId = "remoteMessageValueService", value = ServiceNameConstants.ENTERPRISE_SERVICE, fallbackFactory = RemoteMessageValueFallbackFactory.class,path = "messageValue")
public interface RemoteMessageValueService { public interface RemoteMessageValueService {

View File

@ -10,10 +10,10 @@ import org.springframework.cloud.openfeign.FallbackFactory;
import java.util.List; import java.util.List;
/** /**
*
* @version 1.0 * @version 1.0
* @Author xie ya ru * @Author xie ya ru
* @Date 2024/9/28 21:04 * @Date 2024/9/28 21:04
* @
*/ */
@Log4j2 @Log4j2
public class RemoteMessageValueFallbackFactory implements FallbackFactory<RemoteMessageValueService> { public class RemoteMessageValueFallbackFactory implements FallbackFactory<RemoteMessageValueService> {

View File

@ -97,7 +97,11 @@
<artifactId>cloud-common-xxl</artifactId> <artifactId>cloud-common-xxl</artifactId>
</dependency> </dependency>
<!-- cache缓存框架 --> <dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-saas</artifactId>
</dependency>
<dependency> <dependency>
<groupId>com.muyu</groupId> <groupId>com.muyu</groupId>
<artifactId>enterpise-cache</artifactId> <artifactId>enterpise-cache</artifactId>

View File

@ -6,7 +6,7 @@ import com.muyu.domain.MessageValue;
import com.muyu.domain.req.MessageValueAddReq; import com.muyu.domain.req.MessageValueAddReq;
import com.muyu.domain.req.MessageValueReq; import com.muyu.domain.req.MessageValueReq;
import com.muyu.domain.resp.MessageValueListResp; import com.muyu.domain.resp.MessageValueListResp;
import com.muyu.enterpise.cache.MessageValueCacheService; import com.muyu.enterprise.cache.MessageValueCacheService;
import com.muyu.enterpise.service.MessageValueService; import com.muyu.enterpise.service.MessageValueService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
@ -33,7 +33,7 @@ public class MessageValueController extends BaseController {
private MessageValueService messageValueService; private MessageValueService messageValueService;
@Autowired @Autowired
private MessageValueCacheService enterpiseCacheService; private MessageValueCacheService enterpriseCacheService;
/** /**
* *

View File

@ -1,10 +1,10 @@
package com.muyu.enterpise.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.common.domain.InformationData;
import com.muyu.domain.SysCar; import com.muyu.domain.SysCar;
import com.muyu.domain.req.SysCarReq; import com.muyu.domain.req.SysCarReq;
import com.muyu.domain.resp.SysCarResp; import com.muyu.domain.resp.SysCarResp;
import com.muyu.enterprise.cache.domain.InformationData;
import java.util.List; import java.util.List;
@ -25,7 +25,7 @@ public interface SysCarService extends IService<SysCar> {
/** /**
* *
* *
* @param sysCar * @param sysCarReq
* @return * @return
*/ */
public List<SysCarResp> selectSysCarList(SysCarReq sysCarReq); public List<SysCarResp> selectSysCarList(SysCarReq sysCarReq);

View File

@ -7,10 +7,9 @@ import com.muyu.common.core.utils.StringUtils;
import com.muyu.domain.MessageValue; import com.muyu.domain.MessageValue;
import com.muyu.domain.req.MessageValueReq; import com.muyu.domain.req.MessageValueReq;
import com.muyu.domain.resp.MessageValueListResp; import com.muyu.domain.resp.MessageValueListResp;
import com.muyu.enterpise.cache.MessageValueCacheService; import com.muyu.enterprise.cache.MessageValueCacheService;
import com.muyu.enterpise.mapper.MessageValueMapper; import com.muyu.enterpise.mapper.MessageValueMapper;
import com.muyu.enterpise.service.MessageValueService; import com.muyu.enterpise.service.MessageValueService;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.annotation.Resource; import javax.annotation.Resource;

View File

@ -2,13 +2,13 @@ package com.muyu.enterpise.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.common.domain.InformationData;
import com.muyu.domain.SysCar; import com.muyu.domain.SysCar;
import com.muyu.domain.req.SysCarReq; import com.muyu.domain.req.SysCarReq;
import com.muyu.domain.resp.SysCarResp; import com.muyu.domain.resp.SysCarResp;
import com.muyu.enterpise.cache.SysCarCacheService; import com.muyu.enterprise.cache.SysCarCacheService;
import com.muyu.enterpise.mapper.SysCarMapper; import com.muyu.enterpise.mapper.SysCarMapper;
import com.muyu.enterpise.service.SysCarService; import com.muyu.enterpise.service.SysCarService;
import com.muyu.enterprise.cache.domain.InformationData;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;

View File

@ -4,7 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.common.core.utils.StringUtils; import com.muyu.common.core.utils.StringUtils;
import com.muyu.domain.WarnStrategy; import com.muyu.domain.WarnStrategy;
import com.muyu.enterpise.cache.WarnStrategyCacjeService; import com.muyu.enterprise.cache.WarnStrategyCacjeService;
import com.muyu.enterpise.mapper.WarnStrategyMapper; import com.muyu.enterpise.mapper.WarnStrategyMapper;
import com.muyu.enterpise.service.IWarnStrategyService; import com.muyu.enterpise.service.IWarnStrategyService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;

View File

@ -4,7 +4,7 @@ server:
# nacos线上地址 # nacos线上地址
nacos: nacos:
addr: 127.0.0.1:8848 addr: 123.57.152.124:8848
user-name: nacos user-name: nacos
password: nacos password: nacos
namespace: wx namespace: wx

View File

@ -4,7 +4,7 @@ server:
# nacos线上地址 # nacos线上地址
nacos: nacos:
addr: 127.0.0.1:8848 addr: 123.57.152.124:8848
user-name: nacos user-name: nacos
password: nacos password: nacos
namespace: wx namespace: wx

View File

@ -4,7 +4,7 @@ server:
# nacos线上地址 # nacos线上地址
nacos: nacos:
addr: 127.0.0.1:8848 addr: 123.57.152.124:8848
user-name: nacos user-name: nacos
password: nacos password: nacos
namespace: wx namespace: wx

View File

@ -5,9 +5,9 @@ import com.muyu.common.kafka.config.KafkaProducerConfig;
import com.muyu.domain.MessageValue; import com.muyu.domain.MessageValue;
import com.muyu.domain.SysCar; import com.muyu.domain.SysCar;
import com.muyu.domain.SysCarType; import com.muyu.domain.SysCarType;
import com.muyu.enterpise.cache.MessageValueCacheService; import com.muyu.enterprise.cache.MessageValueCacheService;
import com.muyu.enterpise.cache.SysCarCacheService; import com.muyu.enterprise.cache.SysCarCacheService;
import com.muyu.enterpise.cache.SysCarTypeCacheService; import com.muyu.enterprise.cache.SysCarTypeCacheService;
import com.muyu.parse.uitl.DataParseUtil; import com.muyu.parse.uitl.DataParseUtil;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.clients.producer.ProducerRecord;

View File

@ -4,7 +4,7 @@ server:
# nacos线上地址 # nacos线上地址
nacos: nacos:
addr: 127.0.0.1:8848 addr: 123.57.152.124:8848
user-name: nacos user-name: nacos
password: nacos password: nacos
namespace: wx namespace: wx

View File

@ -4,7 +4,7 @@ server:
# nacos线上地址 # nacos线上地址
nacos: nacos:
addr: 127.0.0.1:8848 addr: 123.57.152.124:8848
user-name: nacos user-name: nacos
password: nacos password: nacos
namespace: wx namespace: wx

View File

@ -4,10 +4,10 @@ server:
# nacos线上地址 # nacos线上地址
nacos: nacos:
addr: 150.158.33.234:8848 addr: 123.57.152.124:8848
user-name: nacos user-name: nacos
password: nacos password: nacos
namespace: dev namespace: wx
# SPRING_AMQP_DESERIALIZATION_TRUST_ALL=true spring.amqp.deserialization.trust.all # SPRING_AMQP_DESERIALIZATION_TRUST_ALL=true spring.amqp.deserialization.trust.all
# Spring # Spring
spring: spring:

View File

@ -4,7 +4,7 @@ server:
# nacos线上地址 # nacos线上地址
nacos: nacos:
addr: 127.0.0.1:8848 addr: 123.57.152.124:8848
user-name: nacos user-name: nacos
password: nacos password: nacos
namespace: wx namespace: wx

25
pom.xml
View File

@ -283,31 +283,6 @@
<version>${muyu.version}</version> <version>${muyu.version}</version>
</dependency> </dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterpise-remote</artifactId>
<version>${muyu.version}</version>
</dependency>
<!-- 实体类 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterpise-common</artifactId>
<version>${muyu.version}</version>
</dependency>
<!-- 缓存框架 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterprise-cache</artifactId>
<version>${muyu.version}</version>
</dependency>
<!-- kafka 公共配置 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-kafka</artifactId>
<version>${muyu.version}</version>
</dependency>
<!-- <dependency>--> <!-- <dependency>-->
<!-- <groupId>com.muyu</groupId>--> <!-- <groupId>com.muyu</groupId>-->
<!-- <artifactId>enterpise-c</artifactId>--> <!-- <artifactId>enterpise-c</artifactId>-->