From e46bfa3ff94a8a1b4daf37c7fcb79c2fab22a72c Mon Sep 17 00:00:00 2001
From: doum <doum>
Date: 星期五, 29 五月 2026 17:10:00 +0800
Subject: [PATCH] 新增智能电表、空调管理
---
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwElectricalActionsServiceImpl.java | 29 +++++++++++++++++++++++++++++
1 files changed, 29 insertions(+), 0 deletions(-)
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwElectricalActionsServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwElectricalActionsServiceImpl.java
index 999a070..bcfd258 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwElectricalActionsServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwElectricalActionsServiceImpl.java
@@ -2,6 +2,8 @@
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.doumee.core.constants.ResponseStatus;
+import com.doumee.core.exception.BusinessException;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Constants;
@@ -10,9 +12,13 @@
import com.doumee.dao.business.model.YwElectrical;
import com.doumee.dao.business.model.YwElectricalActions;
import com.doumee.service.business.YwElectricalActionsService;
+import com.doumee.service.business.YwElectricalBizService;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
+import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+
+import java.util.Objects;
/**
* 鐢佃〃杩滅▼鎿嶄綔璁板綍 Service 瀹炵幇
@@ -22,6 +28,8 @@
@Autowired
private YwElectricalActionsMapper ywElectricalActionsMapper;
+ @Autowired
+ private YwElectricalBizService ywElectricalBizService;
@Override
public PageData<YwElectricalActions> findPage(PageWrap<YwElectricalActions> pageWrap) {
@@ -39,6 +47,9 @@
if (model.getActionType() != null) {
queryWrapper.eq(YwElectricalActions::getActionType, model.getActionType());
}
+ if (model.getElectricalId() != null) {
+ queryWrapper.eq(YwElectricalActions::getElectricalId, model.getElectricalId());
+ }
if (model.getOperateTimeBegin() != null) {
queryWrapper.ge(YwElectricalActions::getCreateDate, Utils.Date.getStart(model.getOperateTimeBegin()));
}
@@ -50,4 +61,22 @@
IPage<YwElectricalActions> result = ywElectricalActionsMapper.selectJoinPage(page, YwElectricalActions.class, queryWrapper);
return PageData.from(result);
}
+
+ @Override
+ public String queryAsyncResult(Integer id) {
+ if (id == null) {
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ YwElectricalActions act = ywElectricalActionsMapper.selectById(id);
+ if (act == null || Objects.equals(act.getIsdeleted(), Constants.ONE)) {
+ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "鎿嶄綔璁板綍涓嶅瓨鍦�");
+ }
+ if (!Objects.equals(act.getStatus(), Constants.ZERO)) {
+ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "浠呭鐞嗕腑璁板綍鍙煡璇�");
+ }
+ if (StringUtils.isBlank(act.getOprId())) {
+ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "缂哄皯浠诲姟 ID");
+ }
+ return ywElectricalBizService.syncAsyncActionStatus(act.getOprId().trim());
+ }
}
--
Gitblit v1.9.3