From 783f0a3125ad9500ff55e6e352dca4da7e8f8c7b Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期日, 19 六月 2022 10:41:57 +0800
Subject: [PATCH] 优化广告调整为cmd 模式
---
service-common/src/main/java/com/java110/common/cmd/advert/ListAdvertPhotoAndVediosCmd.java | 107 +++++++++++------------------------------------------
1 files changed, 22 insertions(+), 85 deletions(-)
diff --git a/service-api/src/main/java/com/java110/api/listener/advert/ListAdvertPhotoAndVediosListener.java b/service-common/src/main/java/com/java110/common/cmd/advert/ListAdvertPhotoAndVediosCmd.java
old mode 100755
new mode 100644
similarity index 75%
rename from service-api/src/main/java/com/java110/api/listener/advert/ListAdvertPhotoAndVediosListener.java
rename to service-common/src/main/java/com/java110/common/cmd/advert/ListAdvertPhotoAndVediosCmd.java
index 191bef6..419aff0
--- a/service-api/src/main/java/com/java110/api/listener/advert/ListAdvertPhotoAndVediosListener.java
+++ b/service-common/src/main/java/com/java110/common/cmd/advert/ListAdvertPhotoAndVediosCmd.java
@@ -1,36 +1,31 @@
-package com.java110.api.listener.advert;
+package com.java110.common.cmd.advert;
import com.alibaba.fastjson.JSONArray;
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.common.IAdvertInnerServiceSMO;
-import com.java110.intf.common.IAdvertItemInnerServiceSMO;
-import com.java110.intf.common.IMachineInnerServiceSMO;
-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.UnitDto;
import com.java110.dto.advert.AdvertDto;
import com.java110.dto.advert.AdvertItemDto;
import com.java110.dto.machine.MachineDto;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.constant.ServiceCodeAdvertConstant;
+import com.java110.intf.common.IAdvertInnerServiceSMO;
+import com.java110.intf.common.IAdvertItemInnerServiceSMO;
+import com.java110.intf.common.IMachineInnerServiceSMO;
+import com.java110.intf.community.IRoomInnerServiceSMO;
+import com.java110.intf.community.IUnitInnerServiceSMO;
+import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
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.List;
-
-/**
- * 鏌ヨ骞垮憡淇℃伅
- */
-@Java110Listener("listAdvertPhotoAndVediosListener")
-public class ListAdvertPhotoAndVediosListener extends AbstractServiceApiListener {
+@Java110Cmd(serviceCode = "advert.listAdvertPhotoAndVedios")
+public class ListAdvertPhotoAndVediosCmd extends Cmd {
@Autowired
private IAdvertInnerServiceSMO advertInnerServiceSMOImpl;
@@ -49,40 +44,14 @@
private IMachineInnerServiceSMO machineInnerServiceSMOImpl;
@Override
- public String getServiceCode() {
- return ServiceCodeAdvertConstant.LIST_ADVERT_PHOTO_VEDIOS;
- }
-
- @Override
- public HttpMethod getHttpMethod() {
- return HttpMethod.GET;
- }
-
-
- @Override
- public int getOrder() {
- return DEFAULT_ORDER;
- }
-
-
- public IAdvertInnerServiceSMO getAdvertInnerServiceSMOImpl() {
- return advertInnerServiceSMOImpl;
- }
-
- public void setAdvertInnerServiceSMOImpl(IAdvertInnerServiceSMO advertInnerServiceSMOImpl) {
- this.advertInnerServiceSMOImpl = advertInnerServiceSMOImpl;
- }
-
- @Override
- protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
+ public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
//super.validatePageInfo(reqJson);
Assert.hasKeyAndValue(reqJson, "machineCode", "璇锋眰鎶ユ枃涓湭鍖呭惈璁惧缂栫爜");
Assert.hasKeyAndValue(reqJson, "communityId", "璇锋眰鎶ユ枃涓湭鍖呭惈灏忓尯淇℃伅");
}
@Override
- protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
+ public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
ResponseEntity<String> responseEntity = null;
MachineDto machineDto = new MachineDto();
@@ -115,20 +84,20 @@
//鏌ヨ 鍗曞厓鐨勫箍鍛婏紝娌℃湁鎵� 妤兼爧锛屽啀鎵炬壘涓嶅埌 灏辫鏌ュ皬鍖�
if (getUnitAdvert(reqJson.getString("communityId"), locationObjId, advertPhotoAndVideos)) {
responseEntity = new ResponseEntity<String>(advertPhotoAndVideos.toJSONString(), HttpStatus.OK);
- context.setResponseEntity(responseEntity);
+ cmdDataFlowContext.setResponseEntity(responseEntity);
return;
}
// 鏌ヨ妤兼爧骞垮憡
if (getFloorAdvert(reqJson.getString("communityId"), locationObjId, advertPhotoAndVideos)) {
responseEntity = new ResponseEntity<String>(advertPhotoAndVideos.toJSONString(), HttpStatus.OK);
- context.setResponseEntity(responseEntity);
+ cmdDataFlowContext.setResponseEntity(responseEntity);
return;
}
if (getCommunityAdvert(reqJson.getString("communityId"), advertPhotoAndVideos)) {
responseEntity = new ResponseEntity<String>(advertPhotoAndVideos.toJSONString(), HttpStatus.OK);
- context.setResponseEntity(responseEntity);
+ cmdDataFlowContext.setResponseEntity(responseEntity);
return;
}
;
@@ -142,7 +111,7 @@
if (advertDtos != null && advertDtos.size() != 0) {
this.getAdvertItem(advertDtos, advertPhotoAndVideos);
responseEntity = new ResponseEntity<String>(advertPhotoAndVideos.toJSONString(), HttpStatus.OK);
- context.setResponseEntity(responseEntity);
+ cmdDataFlowContext.setResponseEntity(responseEntity);
return;
}
//鎴垮眿鎵句笉鍒帮紝鎵� 鍗曞厓
@@ -153,14 +122,14 @@
Assert.listOnlyOne(roomDtos, "鏈壘鍒版埧灞嬫垨鏌ヨ澶氭潯鎴垮眿淇℃伅");
if (getUnitAdvert(reqJson.getString("communityId"), roomDtos.get(0).getUnitId(), advertPhotoAndVideos)) {
responseEntity = new ResponseEntity<String>(advertPhotoAndVideos.toJSONString(), HttpStatus.OK);
- context.setResponseEntity(responseEntity);
+ cmdDataFlowContext.setResponseEntity(responseEntity);
return;
}
// 鏌ヨ妤兼爧骞垮憡
if (getFloorAdvert(reqJson.getString("communityId"), roomDtos.get(0).getUnitId(), advertPhotoAndVideos)) {
responseEntity = new ResponseEntity<String>(advertPhotoAndVideos.toJSONString(), HttpStatus.OK);
- context.setResponseEntity(responseEntity);
+ cmdDataFlowContext.setResponseEntity(responseEntity);
return;
}
@@ -170,7 +139,7 @@
responseEntity = new ResponseEntity<String>(advertPhotoAndVideos.toJSONString(), HttpStatus.OK);
- context.setResponseEntity(responseEntity);
+ cmdDataFlowContext.setResponseEntity(responseEntity);
}
@@ -267,37 +236,5 @@
}
}
- }
-
- public IAdvertItemInnerServiceSMO getAdvertItemInnerServiceSMOImpl() {
- return advertItemInnerServiceSMOImpl;
- }
-
- public void setAdvertItemInnerServiceSMOImpl(IAdvertItemInnerServiceSMO advertItemInnerServiceSMOImpl) {
- this.advertItemInnerServiceSMOImpl = advertItemInnerServiceSMOImpl;
- }
-
- public IMachineInnerServiceSMO getMachineInnerServiceSMOImpl() {
- return machineInnerServiceSMOImpl;
- }
-
- public void setMachineInnerServiceSMOImpl(IMachineInnerServiceSMO machineInnerServiceSMOImpl) {
- this.machineInnerServiceSMOImpl = machineInnerServiceSMOImpl;
- }
-
- public IUnitInnerServiceSMO getUnitInnerServiceSMOImpl() {
- return unitInnerServiceSMOImpl;
- }
-
- public void setUnitInnerServiceSMOImpl(IUnitInnerServiceSMO unitInnerServiceSMOImpl) {
- this.unitInnerServiceSMOImpl = unitInnerServiceSMOImpl;
- }
-
- public IRoomInnerServiceSMO getRoomInnerServiceSMOImpl() {
- return roomInnerServiceSMOImpl;
- }
-
- public void setRoomInnerServiceSMOImpl(IRoomInnerServiceSMO roomInnerServiceSMOImpl) {
- this.roomInnerServiceSMOImpl = roomInnerServiceSMOImpl;
}
}
--
Gitblit v1.8.0