From e62a227ec48c9ee1f738a469480c6e59d436ed3d Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期二, 21 六月 2022 09:02:21 +0800
Subject: [PATCH] 业主相关 功能 从listener 迁移为 cmd 模式
---
service-user/src/main/java/com/java110/user/cmd/owner/ListOwnerMachinesCmd.java | 91 +++++++--------------------------------------
1 files changed, 15 insertions(+), 76 deletions(-)
diff --git a/service-api/src/main/java/com/java110/api/listener/owner/ListOwnerMachines.java b/service-user/src/main/java/com/java110/user/cmd/owner/ListOwnerMachinesCmd.java
old mode 100755
new mode 100644
similarity index 75%
rename from service-api/src/main/java/com/java110/api/listener/owner/ListOwnerMachines.java
rename to service-user/src/main/java/com/java110/user/cmd/owner/ListOwnerMachinesCmd.java
index a38c5f5..7f7e822
--- a/service-api/src/main/java/com/java110/api/listener/owner/ListOwnerMachines.java
+++ b/service-user/src/main/java/com/java110/user/cmd/owner/ListOwnerMachinesCmd.java
@@ -1,38 +1,34 @@
-package com.java110.api.listener.owner;
+package com.java110.user.cmd.owner;
import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.intf.community.ICommunityInnerServiceSMO;
-import com.java110.intf.common.IMachineInnerServiceSMO;
-import com.java110.intf.user.IOwnerInnerServiceSMO;
-import com.java110.intf.community.IRoomInnerServiceSMO;
-import com.java110.intf.community.IUnitInnerServiceSMO;
+import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.context.ICmdDataFlowContext;
+import com.java110.core.event.cmd.Cmd;
+import com.java110.core.event.cmd.CmdEvent;
import com.java110.dto.RoomDto;
import com.java110.dto.community.CommunityDto;
import com.java110.dto.machine.MachineDto;
import com.java110.dto.owner.OwnerDto;
import com.java110.dto.unit.FloorAndUnitDto;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.constant.ServiceCodeConstant;
+import com.java110.intf.common.IMachineInnerServiceSMO;
+import com.java110.intf.community.ICommunityInnerServiceSMO;
+import com.java110.intf.community.IRoomInnerServiceSMO;
+import com.java110.intf.community.IUnitInnerServiceSMO;
+import com.java110.intf.user.IOwnerInnerServiceSMO;
+import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import com.java110.vo.api.machine.ApiMachineDataVo;
import com.java110.vo.api.machine.ApiMachineVo;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import java.util.ArrayList;
import java.util.List;
-/**
- * 鏌ヨ涓氫富鎴栨垚鍛� 瀵瑰簲闂ㄧ璁惧锛屼竴鑸槸鎴垮眿闂紝鍗曞厓闂� 灏忓尯澶ч棬
- */
-@Java110Listener("listOwnerMachines")
-public class ListOwnerMachines extends AbstractServiceApiListener {
+@Java110Cmd(serviceCode = "owner.listOwnerMachines")
+public class ListOwnerMachinesCmd extends Cmd {
@Autowired
private IRoomInnerServiceSMO roomInnerServiceSMOImpl;
@@ -50,15 +46,13 @@
private IUnitInnerServiceSMO unitInnerServiceSMOImpl;
@Override
- protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-
+ public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
Assert.hasKeyAndValue(reqJson, "memberId", "璇锋眰鎶ユ枃涓湭鍖呭惈涓氫富淇℃伅");
Assert.hasKeyAndValue(reqJson, "communityId", "璇锋眰鎶ユ枃涓湭鍖呭惈灏忓尯淇℃伅");
-
}
@Override
- protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
+ public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
String communityId = reqJson.getString("communityId");
String memberId = reqJson.getString("memberId");
@@ -221,60 +215,5 @@
}
}
}
- }
-
- @Override
- public String getServiceCode() {
- return ServiceCodeConstant.LIST_OWNER_MACHINES;
- }
-
- @Override
- public HttpMethod getHttpMethod() {
- return HttpMethod.GET;
- }
-
- @Override
- public int getOrder() {
- return DEFAULT_ORDER;
- }
-
- public IRoomInnerServiceSMO getRoomInnerServiceSMOImpl() {
- return roomInnerServiceSMOImpl;
- }
-
- public void setRoomInnerServiceSMOImpl(IRoomInnerServiceSMO roomInnerServiceSMOImpl) {
- this.roomInnerServiceSMOImpl = roomInnerServiceSMOImpl;
- }
-
- public IMachineInnerServiceSMO getMachineInnerServiceSMOImpl() {
- return machineInnerServiceSMOImpl;
- }
-
- public void setMachineInnerServiceSMOImpl(IMachineInnerServiceSMO machineInnerServiceSMOImpl) {
- this.machineInnerServiceSMOImpl = machineInnerServiceSMOImpl;
- }
-
- public IOwnerInnerServiceSMO getOwnerInnerServiceSMOImpl() {
- return ownerInnerServiceSMOImpl;
- }
-
- public void setOwnerInnerServiceSMOImpl(IOwnerInnerServiceSMO ownerInnerServiceSMOImpl) {
- this.ownerInnerServiceSMOImpl = ownerInnerServiceSMOImpl;
- }
-
- public ICommunityInnerServiceSMO getCommunityInnerServiceSMOImpl() {
- return communityInnerServiceSMOImpl;
- }
-
- public void setCommunityInnerServiceSMOImpl(ICommunityInnerServiceSMO communityInnerServiceSMOImpl) {
- this.communityInnerServiceSMOImpl = communityInnerServiceSMOImpl;
- }
-
- public IUnitInnerServiceSMO getUnitInnerServiceSMOImpl() {
- return unitInnerServiceSMOImpl;
- }
-
- public void setUnitInnerServiceSMOImpl(IUnitInnerServiceSMO unitInnerServiceSMOImpl) {
- this.unitInnerServiceSMOImpl = unitInnerServiceSMOImpl;
}
}
--
Gitblit v1.8.0