Skip to content
Toggle navigation
P
Projects
G
Groups
S
Snippets
Help
黄嘉阳
/
iot-platform-server
This project
Loading...
Sign in
Toggle navigation
Go to a project
Project
Repository
Issues
0
Merge Requests
0
Pipelines
Wiki
Snippets
Settings
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Commit
e67eeef2
authored
Dec 15, 2023
by
huangjy
Browse files
Options
_('Browse Files')
Download
Email Patches
Plain Diff
fix:去掉多余的日志打印
parent
befbc16d
Hide whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
8 additions
and
8 deletions
server-common/src/main/java/com/makeit/config/mybatis/interceptor/LogSqlExecutionTimePlugin.java
server-common/src/main/java/com/makeit/global/aspect/log/RedissonLogAspect.java
server-common/src/main/java/com/makeit/global/aspect/log/ServiceLogAspect.java
server-service/src/main/java/com/makeit/service/platform/elder/impl/PlatElderRealTimeServiceImpl.java
server-web/src/main/java/com/makeit/mqtt/PushCallback.java
server-common/src/main/java/com/makeit/config/mybatis/interceptor/LogSqlExecutionTimePlugin.java
View file @
e67eeef2
...
@@ -17,14 +17,14 @@ import java.util.Properties;
...
@@ -17,14 +17,14 @@ import java.util.Properties;
/**
/**
* @author Robert Hafner
* @author Robert Hafner
*/
*/
@Component
/*
@Component
@Intercepts({
@Intercepts({
@Signature(type = Executor.class, method = "query",
@Signature(type = Executor.class, method = "query",
args = { MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class }),
args = { MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class }),
@Signature(type = Executor.class, method = "query",
@Signature(type = Executor.class, method = "query",
args = { MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class, CacheKey.class, BoundSql.class }),
args = { MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class, CacheKey.class, BoundSql.class }),
@Signature(type= Executor.class, method = "update", args = { MappedStatement.class, Object.class})
@Signature(type= Executor.class, method = "update", args = { MappedStatement.class, Object.class})
})
})
*/
public
class
LogSqlExecutionTimePlugin
implements
Interceptor
{
public
class
LogSqlExecutionTimePlugin
implements
Interceptor
{
private
static
final
Logger
LOGGER
=
LoggerFactory
.
getLogger
(
LogSqlExecutionTimePlugin
.
class
);
private
static
final
Logger
LOGGER
=
LoggerFactory
.
getLogger
(
LogSqlExecutionTimePlugin
.
class
);
...
...
server-common/src/main/java/com/makeit/global/aspect/log/RedissonLogAspect.java
View file @
e67eeef2
...
@@ -12,8 +12,8 @@ import org.springframework.stereotype.Component;
...
@@ -12,8 +12,8 @@ import org.springframework.stereotype.Component;
import
java.util.Arrays
;
import
java.util.Arrays
;
import
java.util.List
;
import
java.util.List
;
@Aspect
//
@Aspect
@Component
//
@Component
public
class
RedissonLogAspect
{
public
class
RedissonLogAspect
{
private
static
final
Logger
logger
=
LoggerFactory
.
getLogger
(
RedissonLogAspect
.
class
);
private
static
final
Logger
logger
=
LoggerFactory
.
getLogger
(
RedissonLogAspect
.
class
);
...
...
server-common/src/main/java/com/makeit/global/aspect/log/ServiceLogAspect.java
View file @
e67eeef2
...
@@ -10,8 +10,8 @@ import org.slf4j.LoggerFactory;
...
@@ -10,8 +10,8 @@ import org.slf4j.LoggerFactory;
import
org.springframework.stereotype.Component
;
import
org.springframework.stereotype.Component
;
@Aspect
//
@Aspect
@Component
//
@Component
public
class
ServiceLogAspect
{
public
class
ServiceLogAspect
{
private
static
final
Logger
logger
=
LoggerFactory
.
getLogger
(
ServiceLogAspect
.
class
);
private
static
final
Logger
logger
=
LoggerFactory
.
getLogger
(
ServiceLogAspect
.
class
);
...
...
server-service/src/main/java/com/makeit/service/platform/elder/impl/PlatElderRealTimeServiceImpl.java
View file @
e67eeef2
...
@@ -282,7 +282,7 @@ public class PlatElderRealTimeServiceImpl implements PlatElderRealTimeService {
...
@@ -282,7 +282,7 @@ public class PlatElderRealTimeServiceImpl implements PlatElderRealTimeService {
}
}
boolean
fallNoPersonFlag
=
false
;
boolean
fallNoPersonFlag
=
false
;
for
(
PlatDevice
device
:
fallDeviceList
)
{
for
(
PlatDevice
device
:
fallDeviceList
)
{
Set
<
String
>
dataSet
=
redisTemplate
.
opsForZSet
().
rangeByScore
(
DEVICE_FALL_TEMP_DATA
+
device
.
getOriDeviceId
(),
currentSecond
-
10
,
currentSecond
);
Set
<
String
>
dataSet
=
redisTemplate
.
opsForZSet
().
rangeByScore
(
DEVICE_FALL_TEMP_DATA
+
device
.
getOriDeviceId
(),
currentSecond
-
10
,
currentSecond
);
if
(
CollectionUtils
.
isEmpty
(
dataSet
))
{
if
(
CollectionUtils
.
isEmpty
(
dataSet
))
{
log
.
info
(
"跌倒设备当前没有上报数据直接返回"
);
log
.
info
(
"跌倒设备当前没有上报数据直接返回"
);
fallNoPersonFlag
=
true
;
fallNoPersonFlag
=
true
;
...
...
server-web/src/main/java/com/makeit/mqtt/PushCallback.java
View file @
e67eeef2
...
@@ -161,7 +161,7 @@ public class PushCallback implements MqttCallback {
...
@@ -161,7 +161,7 @@ public class PushCallback implements MqttCallback {
List
<
HeaderInfo
.
Bind
>
bindings
=
headers
.
getBindings
();
List
<
HeaderInfo
.
Bind
>
bindings
=
headers
.
getBindings
();
Long
timestamp
=
device
.
getTimestamp
();
Long
timestamp
=
device
.
getTimestamp
();
long
currentSecond
=
timestamp
/
1000
;
long
currentSecond
=
System
.
currentTimeMillis
()
/
1000
;
// 先通过产品名称判断
// 先通过产品名称判断
if
(
REPORT_PROPERTY
.
equals
(
device
.
getMessageType
())
&&
headers
.
getProductName
().
contains
(
"呼吸"
))
{
if
(
REPORT_PROPERTY
.
equals
(
device
.
getMessageType
())
&&
headers
.
getProductName
().
contains
(
"呼吸"
))
{
cacheBrDeviceData
(
device
,
currentSecond
);
cacheBrDeviceData
(
device
,
currentSecond
);
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment