|
|
@@ -17,26 +17,25 @@ package com.java110.community.cmd.communitySpace;
|
|
|
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.java110.core.annotation.Java110Cmd;
|
|
|
-import com.java110.core.annotation.Java110Transactional;
|
|
|
import com.java110.core.context.ICmdDataFlowContext;
|
|
|
import com.java110.core.event.cmd.Cmd;
|
|
|
import com.java110.core.event.cmd.CmdEvent;
|
|
|
-import com.java110.core.factory.GenerateCodeFactory;
|
|
|
import com.java110.doc.annotation.*;
|
|
|
+import com.java110.dto.communitySpace.CommunitySpaceDto;
|
|
|
+import com.java110.dto.communitySpaceOpenTime.CommunitySpaceOpenTimeDto;
|
|
|
+import com.java110.intf.community.ICommunitySpaceOpenTimeV1InnerServiceSMO;
|
|
|
import com.java110.intf.community.ICommunitySpaceV1InnerServiceSMO;
|
|
|
-import com.java110.po.communitySpace.CommunitySpacePo;
|
|
|
import com.java110.utils.exception.CmdException;
|
|
|
-import com.java110.utils.util.Assert;
|
|
|
import com.java110.utils.util.BeanConvertUtil;
|
|
|
import com.java110.vo.ResultVo;
|
|
|
-import org.springframework.beans.factory.annotation.Autowired;
|
|
|
-import com.java110.dto.communitySpace.CommunitySpaceDto;
|
|
|
-import java.util.List;
|
|
|
-import java.util.ArrayList;
|
|
|
-import org.springframework.http.ResponseEntity;
|
|
|
-import org.springframework.http.HttpStatus;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.http.HttpStatus;
|
|
|
+import org.springframework.http.ResponseEntity;
|
|
|
+
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.List;
|
|
|
|
|
|
@Java110CmdDoc(title = "查询场地",
|
|
|
description = "查询系统中的查询场地",
|
|
|
@@ -48,8 +47,8 @@ import org.slf4j.LoggerFactory;
|
|
|
)
|
|
|
|
|
|
@Java110ParamsDoc(params = {
|
|
|
- @Java110ParamDoc(name = "page",type = "int",length = 11, remark = "分页页数"),
|
|
|
- @Java110ParamDoc(name = "row",type = "int", length = 11, remark = "分页行数"),
|
|
|
+ @Java110ParamDoc(name = "page", type = "int", length = 11, remark = "分页页数"),
|
|
|
+ @Java110ParamDoc(name = "row", type = "int", length = 11, remark = "分页行数"),
|
|
|
@Java110ParamDoc(name = "communityId", length = 30, remark = "小区ID"),
|
|
|
})
|
|
|
|
|
|
@@ -58,20 +57,23 @@ import org.slf4j.LoggerFactory;
|
|
|
@Java110ParamDoc(name = "code", type = "int", length = 11, defaultValue = "0", remark = "返回编号,0 成功 其他失败"),
|
|
|
@Java110ParamDoc(name = "msg", type = "String", length = 250, defaultValue = "成功", remark = "描述"),
|
|
|
@Java110ParamDoc(name = "data", type = "Array", remark = "有效数据"),
|
|
|
- @Java110ParamDoc(parentNodeName = "data",name = "communityId", type = "String", remark = "小区ID"),
|
|
|
- @Java110ParamDoc(parentNodeName = "data",name = "name", type = "String", remark = "场地名称"),
|
|
|
- @Java110ParamDoc(parentNodeName = "data",name = "state", type = "String", remark = "小区状态 1001 可预约状态 2002 不可以预约状态"),
|
|
|
- @Java110ParamDoc(parentNodeName = "data",name = "startTime", type = "String", remark = "预约开始时间"),
|
|
|
- @Java110ParamDoc(parentNodeName = "data",name = "endTime", type = "String", remark = "预约结束时间"),
|
|
|
- @Java110ParamDoc(parentNodeName = "data",name = "feeMoney", type = "String", remark = "每小时费用"),
|
|
|
- @Java110ParamDoc(parentNodeName = "data",name = "adminName", type = "String", remark = "管理员"),
|
|
|
- @Java110ParamDoc(parentNodeName = "data",name = "tel", type = "String", remark = "联系电话"),
|
|
|
+ @Java110ParamDoc(parentNodeName = "data", name = "communityId", type = "String", remark = "小区ID"),
|
|
|
+ @Java110ParamDoc(parentNodeName = "data", name = "name", type = "String", remark = "场地名称"),
|
|
|
+ @Java110ParamDoc(parentNodeName = "data", name = "state", type = "String", remark = "小区状态 1001 可预约状态 2002 不可以预约状态"),
|
|
|
+ @Java110ParamDoc(parentNodeName = "data", name = "startTime", type = "String", remark = "预约开始时间"),
|
|
|
+ @Java110ParamDoc(parentNodeName = "data", name = "endTime", type = "String", remark = "预约结束时间"),
|
|
|
+ @Java110ParamDoc(parentNodeName = "data", name = "feeMoney", type = "String", remark = "每小时费用"),
|
|
|
+ @Java110ParamDoc(parentNodeName = "data", name = "adminName", type = "String", remark = "管理员"),
|
|
|
+ @Java110ParamDoc(parentNodeName = "data", name = "tel", type = "String", remark = "联系电话"),
|
|
|
+ @Java110ParamDoc(parentNodeName = "data", name = "openTimes", type = "Array", remark = "联系电话"),
|
|
|
+ @Java110ParamDoc(parentNodeName = "openTimes", name = "hours", type = "String", remark = "小时"),
|
|
|
+ @Java110ParamDoc(parentNodeName = "openTimes", name = "isOpen", type = "String", remark = "是否预约 Y 可以预约 N 不能预约"),
|
|
|
}
|
|
|
)
|
|
|
|
|
|
@Java110ExampleDoc(
|
|
|
- reqBody="http://{ip}:{port}/app/communitySpace.listCommunitySpace?spaceId=&name=&state=&communityId=2022081539020475&page=1&row=10",
|
|
|
- resBody="{\"code\":0,\"data\":[{\"adminName\":\"无需文\",\"communityId\":\"2022081539020475\",\"endTime\":\"06:10\",\"feeMoney\":\"10.00\",\"name\":\"体育场\",\"page\":-1,\"records\":0,\"row\":0,\"spaceId\":\"102022093043260007\",\"startTime\":\"05:05\",\"state\":\"1001\",\"statusCd\":\"0\",\"tel\":\"18909711443\",\"total\":0}],\"msg\":\"成功\",\"page\":0,\"records\":1,\"rows\":0,\"total\":2}"
|
|
|
+ reqBody = "http://{ip}:{port}/app/communitySpace.listCommunitySpace?spaceId=&name=&state=&communityId=2022081539020475&page=1&row=10",
|
|
|
+ resBody = "{\"code\":0,\"data\":[{\"adminName\":\"无需文\",\"communityId\":\"2022081539020475\",\"endTime\":\"06:10\",\"feeMoney\":\"10.00\",\"name\":\"体育场\",\"page\":-1,\"records\":0,\"row\":0,\"spaceId\":\"102022093043260007\",\"startTime\":\"05:05\",\"state\":\"1001\",\"statusCd\":\"0\",\"tel\":\"18909711443\",\"total\":0,\"openTimes\":[{\"hours\":0,\"Y\"}]}],\"msg\":\"成功\",\"page\":0,\"records\":1,\"rows\":0,\"total\":2}"
|
|
|
)
|
|
|
/**
|
|
|
* 类表述:查询
|
|
|
@@ -86,10 +88,13 @@ import org.slf4j.LoggerFactory;
|
|
|
@Java110Cmd(serviceCode = "communitySpace.listCommunitySpace")
|
|
|
public class ListCommunitySpaceCmd extends Cmd {
|
|
|
|
|
|
- private static Logger logger = LoggerFactory.getLogger(ListCommunitySpaceCmd.class);
|
|
|
+ private static Logger logger = LoggerFactory.getLogger(ListCommunitySpaceCmd.class);
|
|
|
@Autowired
|
|
|
private ICommunitySpaceV1InnerServiceSMO communitySpaceV1InnerServiceSMOImpl;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private ICommunitySpaceOpenTimeV1InnerServiceSMO communitySpaceOpenTimeV1InnerServiceSMOImpl;
|
|
|
+
|
|
|
@Override
|
|
|
public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
|
|
|
super.validatePageInfo(reqJson);
|
|
|
@@ -98,22 +103,53 @@ public class ListCommunitySpaceCmd extends Cmd {
|
|
|
@Override
|
|
|
public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
|
|
|
|
|
|
- CommunitySpaceDto communitySpaceDto = BeanConvertUtil.covertBean(reqJson, CommunitySpaceDto.class);
|
|
|
+ CommunitySpaceDto communitySpaceDto = BeanConvertUtil.covertBean(reqJson, CommunitySpaceDto.class);
|
|
|
+
|
|
|
+ int count = communitySpaceV1InnerServiceSMOImpl.queryCommunitySpacesCount(communitySpaceDto);
|
|
|
+
|
|
|
+ List<CommunitySpaceDto> communitySpaceDtos = null;
|
|
|
+
|
|
|
+ if (count > 0) {
|
|
|
+ communitySpaceDtos = communitySpaceV1InnerServiceSMOImpl.queryCommunitySpaces(communitySpaceDto);
|
|
|
+
|
|
|
+ refreshOpenTimes(communitySpaceDtos);
|
|
|
+ } else {
|
|
|
+ communitySpaceDtos = new ArrayList<>();
|
|
|
+ }
|
|
|
+
|
|
|
+ ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) reqJson.getInteger("row")), count, communitySpaceDtos);
|
|
|
|
|
|
- int count = communitySpaceV1InnerServiceSMOImpl.queryCommunitySpacesCount(communitySpaceDto);
|
|
|
+ ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
|
|
|
|
|
|
- List<CommunitySpaceDto> communitySpaceDtos = null;
|
|
|
+ cmdDataFlowContext.setResponseEntity(responseEntity);
|
|
|
+ }
|
|
|
+
|
|
|
+ private void refreshOpenTimes(List<CommunitySpaceDto> communitySpaceDtos) {
|
|
|
|
|
|
- if (count > 0) {
|
|
|
- communitySpaceDtos = communitySpaceV1InnerServiceSMOImpl.queryCommunitySpaces(communitySpaceDto);
|
|
|
- } else {
|
|
|
- communitySpaceDtos = new ArrayList<>();
|
|
|
- }
|
|
|
+ if (communitySpaceDtos == null || communitySpaceDtos.size() < 1) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
|
|
|
- ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) reqJson.getInteger("row")), count, communitySpaceDtos);
|
|
|
+ List<String> spaceIds = new ArrayList<>();
|
|
|
|
|
|
- ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
|
|
|
+ for (CommunitySpaceDto communitySpaceDto : communitySpaceDtos) {
|
|
|
+ spaceIds.add(communitySpaceDto.getSpaceId());
|
|
|
+ }
|
|
|
+
|
|
|
+ CommunitySpaceOpenTimeDto communitySpaceOpenTimeDto = new CommunitySpaceOpenTimeDto();
|
|
|
+ communitySpaceOpenTimeDto.setSpaceIds(spaceIds.toArray(new String[spaceIds.size()]));
|
|
|
+ List<CommunitySpaceOpenTimeDto> communitySpaceOpenTimeDtos = communitySpaceOpenTimeV1InnerServiceSMOImpl.queryCommunitySpaceOpenTimes(communitySpaceOpenTimeDto);
|
|
|
+
|
|
|
+ List<CommunitySpaceOpenTimeDto> tmpCommunitySpaceOpenTimeDtos = null;
|
|
|
+ for (CommunitySpaceDto communitySpaceDto : communitySpaceDtos) {
|
|
|
+ tmpCommunitySpaceOpenTimeDtos = new ArrayList<>();
|
|
|
+ for (CommunitySpaceOpenTimeDto tmpCommunitySpaceOpenTimeDto : communitySpaceOpenTimeDtos) {
|
|
|
+ if (tmpCommunitySpaceOpenTimeDto.getSpaceId().equals(communitySpaceDto.getSpaceId())) {
|
|
|
+ tmpCommunitySpaceOpenTimeDtos.add(tmpCommunitySpaceOpenTimeDto);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ communitySpaceDto.setOpenTimes(tmpCommunitySpaceOpenTimeDtos);
|
|
|
+ }
|
|
|
|
|
|
- cmdDataFlowContext.setResponseEntity(responseEntity);
|
|
|
}
|
|
|
}
|