five-groups
/
five-groups-couplet
4
0
Fork 0
Code Issues Pull Requests 2 Packages Projects Releases Wiki Activity

Compare commits

base: five-groups:2affa40686f2e9a419db4051a86f81b0ae6269ca
Branches Tags
five-groups:server_five_fufanrui
five-groups:server_five_dongxiaodong
five-groups:server_five
five-groups:server_five_liuyunhu
...
compare: five-groups:ab079c7daf2b613a37e1628bed98a8ebcebaf377
Branches Tags
five-groups:server_five_fufanrui
five-groups:server_five_dongxiaodong
five-groups:server_five
five-groups:server_five_liuyunhu

2 Commits
2affa40686 ... ab079c7daf

Author SHA1 Message Date
lijiayao ab079c7daf Merge remote-tracking branch 'origin/server_five' into server_five 2024-04-04 08:58:50 +08:00
lijiayao ad5626f0af refactor: 修改框架 2024-04-04 08:58:43 +08:00
9 changed files with 118 additions and 113 deletions
Show Stats Expand all files Collapse all files

2
couplet-auth/src/main/resources/bootstrap.yml
View File

@ -17,11 +17,9 @@ spring:
discovery: discovery:
# 服务注册地址 # 服务注册地址
server-addr: 121.89.211.230:8848 server-addr: 121.89.211.230:8848
namespace: 172469
config: config:
# 配置中心地址 # 配置中心地址
server-addr: 121.89.211.230:8848 server-addr: 121.89.211.230:8848
namespace: 172469
# 配置文件格式 # 配置文件格式
file-extension: yml file-extension: yml
# 共享配置 # 共享配置

2
couplet-gateway/src/main/resources/bootstrap.yml
View File

@ -15,11 +15,9 @@ spring:
discovery: discovery:
# 服务注册地址 # 服务注册地址
server-addr: 121.89.211.230:8848 server-addr: 121.89.211.230:8848
namespace: 172469
config: config:
# 配置中心地址 # 配置中心地址
server-addr: 121.89.211.230:8848 server-addr: 121.89.211.230:8848
namespace: 172469
# 配置文件格式 # 配置文件格式
file-extension: yml file-extension: yml
# 共享配置 # 共享配置

2
couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelMessage.java
View File

@ -108,7 +108,7 @@ public class ModelMessage {
}); });
mqttClient.subscribe("test",0); mqttClient.subscribe("test",0);
Thread.sleep(1000*60*10); Thread.sleep(1000*6*10);
} catch (Exception e) { } catch (Exception e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }

76
couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/BreakdownServiceImpl.java
View File

@ -1,38 +1,38 @@
//package com.couplet.analyze.msg.service.impl; package com.couplet.analyze.msg.service.impl;
//
//import com.couplet.analyze.msg.domain.CoupletMsgData; import com.couplet.analyze.msg.domain.CoupletMsgData;
//import com.couplet.analyze.msg.service.IncidentService; import com.couplet.analyze.msg.service.IncidentService;
//import com.couplet.common.log.annotation.Log; import com.couplet.common.log.annotation.Log;
//import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
//import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
//
///** /**
// * @Author: LiJiaYao * @Author: LiJiaYao
// * @Date: 2024/4/2 * @Date: 2024/4/2
// * @Description: 故障事件 * @Description: 故障事件
// */ */
//@Service("breakdown") @Service("breakdown")
//@Log4j2 @Log4j2
//public class BreakdownServiceImpl implements IncidentService { public class BreakdownServiceImpl implements IncidentService {
// /** /**
// * 故障事件 * 故障事件
// * *
// * @param coupletMsgData * @param coupletMsgData
// */ */
// @Override @Override
// public void incident(CoupletMsgData coupletMsgData) { public void incident(CoupletMsgData coupletMsgData) {
//
// log.info("故障事件开始....."); log.info("故障事件开始.....");
// log.info("故障事件结束....."); log.info("故障事件结束.....");
//
//
// } }
//
// /** /**
// * @return 获取事件名称 * @return 获取事件名称
// */ */
// @Override @Override
// public String getName() { public String getName() {
// return "breakdown"; return "breakdown";
// } }
//} }

73
couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/ElectronicFenceServiceImpl.java
View File

@ -1,33 +1,40 @@
//package com.couplet.analyze.msg.service.impl; package com.couplet.analyze.msg.service.impl;
//
//import com.couplet.analyze.msg.domain.CoupletMsgData; import com.couplet.analyze.msg.domain.CoupletMsgData;
//import com.couplet.analyze.msg.service.IncidentService; import com.couplet.analyze.msg.service.IncidentService;
//import org.springframework.stereotype.Service; import lombok.extern.log4j.Log4j2;
// import org.springframework.stereotype.Service;
///**
// * @Author: LiJiaYao /**
// * @Date: 2024/4/2 * @Author: LiJiaYao
// * @Description: 电子围栏事件服务实现类 * @Date: 2024/4/2
// */ * @Description: 电子围栏事件服务实现类
//@Service("electronic-fence") */
//public class ElectronicFenceServiceImpl implements IncidentService { @Service("electronic-fence")
// @Log4j2
// public class ElectronicFenceServiceImpl implements IncidentService {
// /**
// * 电子围栏事件
// * /**
// * @param coupletMsgData * 电子围栏事件
// */ *
// @Override * @param coupletMsgData
// public void incident(CoupletMsgData coupletMsgData) { */
// @Override
// } public void incident(CoupletMsgData coupletMsgData) {
//
// /** log.info("电子围栏事件开始.......");
// * @return 电子围栏service 名称 log.info("电子围栏事件结束.......");
// */
// @Override
// public String getName() {
// return "electronic-fence"; }
// }
//} /**
* @return 电子围栏service 名称
*/
@Override
public String getName() {
return "electronic-fence";
}
}

71
couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/RealTimeDataServiceImpl.java
View File

@ -1,33 +1,38 @@
//package com.couplet.analyze.msg.service.impl; package com.couplet.analyze.msg.service.impl;
//
//import com.couplet.analyze.msg.domain.CoupletMsgData; import com.couplet.analyze.msg.domain.CoupletMsgData;
//import com.couplet.analyze.msg.service.IncidentService; import com.couplet.analyze.msg.service.IncidentService;
//import org.springframework.stereotype.Service; import lombok.extern.log4j.Log4j2;
// import org.springframework.stereotype.Service;
///**
// * @Author: LiJiaYao /**
// * @Date: 2024/4/2 * @Author: LiJiaYao
// * @Description: 实时数据事件 * @Date: 2024/4/2
// */ * @Description: 实时数据事件
//@Service("real-time-data") */
//public class RealTimeDataServiceImpl implements IncidentService { @Service("real-time-data")
// @Log4j2
// /** public class RealTimeDataServiceImpl implements IncidentService {
// * 实时数据事件
// * /**
// * @param coupletMsgData * 实时数据事件
// */ *
// @Override * @param coupletMsgData
// public void incident(CoupletMsgData coupletMsgData) { */
// @Override
// } public void incident(CoupletMsgData coupletMsgData) {
//
// /** log.info("实时数据事件开始.....");
// * 实时数据事件 log.info("实时数据事件结束.....");
// * @return
// */ }
// @Override
// public String getName() { /**
// return "real-time-data"; * 实时数据事件
// } * @return
//} */
@Override
public String getName() {
return "real-time-data";
}
}

1
couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
View File

@ -1 +0,0 @@
com.couplet.analyze.msg.config.RabbitMQConfig

2
couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/resources/mapper/incident/SysIncidentMapper.xml
View File

@ -6,7 +6,7 @@
<insert id="reportMapper"> <insert id="reportMapper">
INSERT INTO `vehicle-resolver`.`resolver_report_data` INSERT INTO `couplet-cloud`.`couplet_msg_data`
(`vin`, `create_time`, `longitude`, `latitude`, (`vin`, `create_time`, `longitude`, `latitude`,
`speed`, `mileage`, `voltage`, `current`, `resistance`, `gear`, `speed`, `mileage`, `voltage`, `current`, `resistance`, `gear`,
`acceleration_pedal`, `fuel_consumption_rate`, `acceleration_pedal`, `fuel_consumption_rate`,

2
couplet-modules/couplet-system/src/main/resources/bootstrap.yml
View File

@ -16,11 +16,9 @@ spring:
discovery: discovery:
# 服务注册地址 # 服务注册地址
server-addr: 121.89.211.230:8848 server-addr: 121.89.211.230:8848
namespace: 172469
config: config:
# 配置中心地址 # 配置中心地址
server-addr: 121.89.211.230:8848 server-addr: 121.89.211.230:8848
namespace: 172469
# 配置文件格式 # 配置文件格式
file-extension: yml file-extension: yml
# 共享配置 # 共享配置