From 444b1808d73d21f9df361e64f44381b910947792 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期五, 27 九月 2024 11:05:08 +0800
Subject: [PATCH] 去掉tdedgine，去掉一部分rocketmq，去掉dmplog模块
---
smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/WorkstationFeedbackServiceImpl.java | 36 ++++++++++++++++++++++++++----------
1 files changed, 26 insertions(+), 10 deletions(-)
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/WorkstationFeedbackServiceImpl.java b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/WorkstationFeedbackServiceImpl.java
index 24060e2..7f34e2c 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/WorkstationFeedbackServiceImpl.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/WorkstationFeedbackServiceImpl.java
@@ -130,7 +130,7 @@
@Override
public WorkstationFeedback getImmediateFeedback(Serializable workstationId) {
return getOne(Lambda.eq(WorkstationFeedback::getWorkstationId, workstationId)
- .eq(WorkstationFeedback::getFeedbackType, Integer.valueOf(FeedbackType.IMMEDIATE.getValue()))
+ .eq(WorkstationFeedback::getFeedbackType, FeedbackType.IMMEDIATE.getValue())
.isNull(WorkstationFeedback::getEndTime));
/*
return (WorkstationFeedback) getOne((Wrapper) ((ExtraLambdaQueryWrapper) Lambda.eq((v0) -> {
@@ -165,7 +165,7 @@
} else {
addFeedback.setFeedUser(getEmployeeById().getId());
}
- addFeedback.setFeedbackType(Integer.valueOf(FeedbackType.IMMEDIATE.getValue()));
+ addFeedback.setFeedbackType(FeedbackType.IMMEDIATE.getValue());
addFeedback.setStatus(FeedbackStatus.WAIT_SYNC.getValue());
addFeedback.setRemark(dto.getDescription());
addFeedback.setWcs(dto.getWcs());
@@ -188,28 +188,34 @@
this.redisLockClient.lockFair(ExtCacheConstant.WORK_FEEDBACK.concat(":").concat(workstationId), 30L, 100L, () -> {
existTimeOverImmediateFeedbackException(dto);
WorkstationFeedback addFeedback = new WorkstationFeedback();
- addFeedback.setWorkstationId(Long.valueOf(Long.parseLong(workstationId)));
+ addFeedback.setWorkstationId(Long.parseLong(workstationId));
addFeedback.setStartTime(dto.getStartTime());
addFeedback.setEndTime(dto.getEndTime());
addFeedback.setFeedbackTime(new Date());
if (Func.isNotEmpty(dto.getFeedUser())) {
- addFeedback.setFeedUser(Long.valueOf(Long.parseLong(dto.getFeedUser())));
- addFeedback.setEndFeedUser(Long.valueOf(Long.parseLong(dto.getFeedUser())));
+ addFeedback.setFeedUser(Long.parseLong(dto.getFeedUser()));
+ addFeedback.setEndFeedUser(Long.parseLong(dto.getFeedUser()));
} else {
addFeedback.setFeedUser(getEmployeeById().getId());
addFeedback.setEndFeedUser(getEmployeeById().getId());
}
- addFeedback.setFeedbackType(Integer.valueOf(FeedbackType.TIME_RANGE.getValue()));
+ addFeedback.setFeedbackType(FeedbackType.TIME_RANGE.getValue());
addFeedback.setStatus(FeedbackStatus.WAIT_SYNC.getValue());
addFeedback.setRemark(dto.getDescription());
addFeedback.setWcs(dto.getWcs());
- return Boolean.valueOf(save(addFeedback));
+ return save(addFeedback);//淇濆瓨鍒癿ysql
});
}
evictFeedback(dto.getStartTime(), dto.getEndTime(), dto.getWorkstationIds());
return true;
}
+ /**
+ * 鎵归噺娓呴櫎 鍙嶉
+ * @param startTime
+ * @param endTime
+ * @param workstationIds
+ */
private void evictFeedback(final Date startTime, final Date endTime, List<String> workstationIds) {
LocalDate start = startTime.toInstant().atZone(ZoneId.systemDefault()).toLocalDate();
LocalDate end = endTime.toInstant().atZone(ZoneId.systemDefault()).toLocalDate();
@@ -218,16 +224,26 @@
});
}
- private void evictFeedback(final LocalDate start, final LocalDate end, final Serializable workstationId) {
- long distance = ChronoUnit.DAYS.between(start, end);
+ /**
+ * 鍗曚釜娓呮缂撳瓨涓殑鍙嶉锛屼粠catcheName=WORK_FEEDBACK_EXP3缂撳瓨涓垹闄� 瀹為檯key涓� group:feedback:list:blade:feedback#259200${workstationId}:yyyy-MM-dd HH:mm:ss
+ * @param start
+ * @param end
+ * @param workstationId
+ */
+ private void evictFeedback(final LocalDate start, final LocalDate end, final String workstationId) {
+ long distance = ChronoUnit.DAYS.between(start, end);//涓�鍏眑imit鍑犲ぉ锛堝氨鏄彇鍑犱釜鏁帮級
Stream.iterate(start, d -> {
return d.plusDays(1L);
}).limit(distance + 1).forEach(date -> {
- String key = String.valueOf(workstationId).concat(":").concat(Func.formatDate(date));
+ String key = workstationId.concat(":").concat(Func.formatDate(date));
CacheUtil.evict(IWorkstationFeedbackService.WORK_FEEDBACK_EXP3, GROUP_FEEDBACK_CACHE_KEY, key, false);
});
}
+ /**
+ * 妫�鏌ユ槸鍚︽湁姝ｅ湪杩涜涓殑鐘舵�佸弽棣�
+ * @param dto
+ */
private void existTimeOverImmediateFeedbackException(WorkstationNoImmediateFeedBackDTO dto) {
if (dto.getWorkstationIds().stream().map(this.selfService::getImmediateFeedback).filter(Objects::nonNull).anyMatch(feedback ->
(dto.getStartTime().getTime() >= feedback.getStartTime().getTime() || dto.getEndTime().getTime() >= feedback.getStartTime().getTime())))
--
Gitblit v1.9.3