From 75072002f353a34ca0de4f8aaad04c8d1841407c Mon Sep 17 00:00:00 2001
From: zhanzhiqin <895896009@qq.com>
Date: 星期五, 27 五月 2022 17:57:22 +0800
Subject: [PATCH] fix
---
ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java | 100 ++++++++++++++++++++++++++++++++++++++------------
1 files changed, 76 insertions(+), 24 deletions(-)
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java
index ca03876..4462dd5 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java
@@ -35,6 +35,7 @@
import com.sandu.ximon.dao.domain.LightTaskPoleRelation;
import com.sandu.ximon.dao.domain.Pole;
import com.sandu.ximon.dao.enums.DeviceRespStatusEnums;
+import com.sandu.ximon.dao.enums.OrderByEnums;
import com.sandu.ximon.dao.mapper.LightTaskMapper;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@@ -137,7 +138,7 @@
}
@Transactional(rollbackFor = Exception.class)
- public int updateLightTask(Long taskId, LightTaskParam param) {
+ public String updateLightTask(Long taskId, LightTaskParam param) {
if (StrUtil.length(param.getControlOrder()) % LightTaskParam.REQUEST_ORDER_LENGTH != 0) {
throw new BusinessException("鐏帶鍛戒护鏍煎紡涓嶆纭�");
}
@@ -215,12 +216,16 @@
closePoleSuccess = closePoleMap.getOrDefault("success", new ArrayList<>());
}
- //鏈夊け鏁楃殑闇�瑕佷繚瀛樻棫鐨勪换鍕�
+
if (closePoleFail.size() == 0 && oldPoleFail.size() == 0) {
+ //鏃т换鍔′腑鍏ㄩ儴鍙戦�佹寚浠ゆ垚鍔燂紝鏇存柊鍘熸湰浠诲姟涓殑鏁版嵁
newLightTask.setTaskId(lightTask.getTaskId());
updateById(newLightTask);
} else {
- save(newLightTask);
+ if (!newPoleSuccess.isEmpty() || !oldPoleSuccess.isEmpty()) {
+ //鏈夊け鏁楃殑闇�瑕佷繚瀛樻棫鐨勪换鍕欙紝鏂板鏂扮殑浠诲姟鏁版嵁杩涜淇濆瓨
+ save(newLightTask);
+ }
}
/**
@@ -239,7 +244,7 @@
* 缂栬緫璺伅浠诲姟鏃ュ織璁板綍缁撴潫
*/
- for (LightTaskPoleRelation bean : newPoleAll) {
+ for (LightTaskPoleRelation bean : newPoleSuccess) {
bean.setTaskId(newLightTask.getTaskId());
}
//鎴愬姛鐢ㄦ柊鐨勪换鍔D
@@ -257,20 +262,33 @@
}
List<LightTaskPoleRelation> all = new ArrayList<>();
- all.addAll(newPoleAll);
+ all.addAll(newPoleSuccess);
all.addAll(oldPoleSuccess);
all.addAll(oldPoleFail);
all.addAll(closePoleFail);
-
-
-
List<Long> allPoleId = new ArrayList<>();
- allPoleId.addAll(poleIdList);
- allPoleId.addAll(oldList);
- lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, allPoleId));
- lightTaskPoleRelationService.saveBatch(all);
+ for (LightTaskPoleRelation bean : newPoleSuccess) {
+ allPoleId.add(bean.getPoleId());
+ }
+ for (LightTaskPoleRelation bean : oldPoleSuccess) {
+ allPoleId.add(bean.getPoleId());
+ }
+ for (LightTaskPoleRelation bean : oldPoleFail) {
+ allPoleId.add(bean.getPoleId());
+ }
+ for (LightTaskPoleRelation bean : closePoleSuccess) {
+ allPoleId.add(bean.getPoleId());
+ }
+
+ if (!allPoleId.isEmpty()) {
+ lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, allPoleId));
+
+ }
+ if (!all.isEmpty()) {
+ lightTaskPoleRelationService.saveBatch(all);
+ }
/**
@@ -300,21 +318,30 @@
// //缂栬緫鎴愬姛
// return 0;
// } else if (newPoleSuccess.isEmpty() && oldPoleSuccess.isEmpty() && closePoleSuccess.isEmpty()) {
-// //缂栬緫澶辫触, 鏂版棫浠诲姟閮芥湁
+// //缂栬緫澶辫触
// return 1;
-// } else if ((newPoleSuccess.isEmpty() && newPoleFail.isEmpty())) {
-// if (oldPoleSuccess.isEmpty() && closePoleSuccess.isEmpty()) {
-// //缂栬緫澶辫触,淇濈暀鍘熷厛浠诲姟娌℃湁鏀瑰彉,鍙湁鏃т换鍔�
+// } else {
+// //鍦ㄦ棫浠诲姟鍩虹涓婄紪杈�
+// if (lightTask.getTaskId().equals(newLightTask.getTaskId())) {
+// //鍙湁鏃т换鍔�
// return 2;
-// } else {
-// //缂栬緫閮ㄥ垎鎴愬姛閮ㄥ垎澶辫触,鏂版棫浠诲姟鍚屾椂瀛樺湪
+// } else {
+// //鏈夋柊浠诲姟锛屾湁鏃т换鍔�
// return 3;
// }
-// } else {
-// return -1;
// }
- return 0;
+ if (newPoleFail.isEmpty() && oldPoleFail.isEmpty() && closePoleFail.isEmpty()) {
+ return "缂栬緫鎴愬姛";
+ } else if (newPoleSuccess.isEmpty() && oldPoleSuccess.isEmpty() && closePoleSuccess.isEmpty()) {
+ throw new BusinessException("缂栬緫澶辫触");
+ } else if (!closePoleFail.isEmpty() || !oldPoleFail.isEmpty()) {
+ return "鍘熶换鍔′腑瀛樺湪涓嬪彂寮傚父锛屽師浠诲姟淇濈暀锛屽垱寤烘柊浠诲姟杩涜淇濆瓨";
+ } else if (!newPoleFail.isEmpty()) {
+ return "鏂颁换鍔′腑瀛樺湪涓嬪彂寮傚父锛屽拷鐣ュ紓甯告搷浣滅殑鐏潌";
+ } else {
+ return "鎿嶄綔寮傚父";
+ }
}
@@ -334,7 +361,7 @@
return Optional.ofNullable(responseCommonFrame).map(WrapResponseCommonFrame::getResponseInnerFrame).orElse(null);
}
- public List<LightTaskDto> listLightTask(BaseConditionVO conditionVO, String keyword) {
+ public List<LightTaskDto> listLightTask(BaseConditionVO conditionVO, String keyword, Integer order, Integer seq) {
LambdaQueryWrapper<LightTask> wrapper = Wrappers.lambdaQuery(LightTask.class);
if (StrUtil.isNotBlank(keyword)) {
wrapper.like(LightTask::getTaskName, keyword);
@@ -346,9 +373,34 @@
});
}
- if (conditionVO != null) {
- PageHelper.startPage(conditionVO.getPageNo(), conditionVO.getPageSize());
+ //鎺掑簭瀛楁
+ String orderByResult = OrderByEnums.LIGHT_TASK_UPDATE_TIME.getCode();
+ //姝ｅ簭銆佸�掑彊
+ String orderBySeq = OrderByEnums.ASC.getCode();
+ if (order != null) {
+ switch (order) {
+ case 1:
+ orderByResult = OrderByEnums.LIGHT_TASK_UPDATE_TIME.getCode();
+ break;
+ default:
+ }
}
+ if (seq != null) {
+ switch (seq) {
+ case 1:
+ orderBySeq = OrderByEnums.ASC.getCode();
+ break;
+ case 2:
+ orderBySeq = OrderByEnums.DESC.getCode();
+ break;
+ default:
+ break;
+ }
+ }
+ //鎺掑簭鏂瑰紡
+ String orderBy = orderByResult + " " + orderBySeq;
+
+ PageHelper.startPage(conditionVO.getPageNo(), conditionVO.getPageSize(), orderBy);
List<LightTask> list = list(wrapper);
Page<LightTaskDto> page = new Page<>();
--
Gitblit v1.9.3