From 9fc6c6db5ac1488f9dc1d3d3d036336b7df61596 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期一, 03 十月 2022 02:54:06 +0800
Subject: [PATCH] 优化代码
---
service-community/src/main/java/com/java110/community/cmd/communitySpace/SaveCommunitySpacePersonCmd.java | 109 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 108 insertions(+), 1 deletions(-)
diff --git a/service-community/src/main/java/com/java110/community/cmd/communitySpace/SaveCommunitySpacePersonCmd.java b/service-community/src/main/java/com/java110/community/cmd/communitySpace/SaveCommunitySpacePersonCmd.java
index 4e2941f..be39650 100644
--- a/service-community/src/main/java/com/java110/community/cmd/communitySpace/SaveCommunitySpacePersonCmd.java
+++ b/service-community/src/main/java/com/java110/community/cmd/communitySpace/SaveCommunitySpacePersonCmd.java
@@ -15,6 +15,7 @@
*/
package com.java110.community.cmd.communitySpace;
+import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.annotation.Java110Transactional;
@@ -22,15 +23,61 @@
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.communitySpacePerson.CommunitySpacePersonDto;
+import com.java110.dto.communitySpacePersonTime.CommunitySpacePersonTimeDto;
+import com.java110.intf.community.ICommunitySpacePersonTimeV1InnerServiceSMO;
import com.java110.intf.community.ICommunitySpacePersonV1InnerServiceSMO;
import com.java110.po.communitySpacePerson.CommunitySpacePersonPo;
+import com.java110.po.communitySpacePersonTime.CommunitySpacePersonTimePo;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
+import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
+
+
+@Java110CmdDoc(title = "棰勭害鍦哄湴",
+ description = "绯荤粺涓殑棰勭害鍦哄湴",
+ httpMethod = "post",
+ url = "http://{ip}:{port}/app/communitySpace.saveCommunitySpacePerson",
+ resource = "communityDoc",
+ author = "鍚村鏂�",
+ serviceCode = "communitySpace.saveCommunitySpacePerson"
+)
+
+@Java110ParamsDoc(params = {
+ @Java110ParamDoc(name = "page",type = "int",length = 11, remark = "鍒嗛〉椤垫暟"),
+ @Java110ParamDoc(name = "row",type = "int", length = 11, remark = "鍒嗛〉琛屾暟"),
+ @Java110ParamDoc(name = "communityId", length = 30, remark = "灏忓尯ID"),
+ @Java110ParamDoc(name = "appointmentDate", length = 30, remark = "棰勭害鏃ユ湡 YYYY-MM-DD"),
+ @Java110ParamDoc(name = "appointmentTime", length = 30, remark = "棰勭害鏃堕棿 HH24:MI"),
+ @Java110ParamDoc(name = "payWay", length = 12, remark = "鏀粯鏂瑰紡"),
+ @Java110ParamDoc(name = "personName", length = 64, remark = "棰勭害浜�"),
+ @Java110ParamDoc(name = "personTel", length = 30, remark = "棰勭害浜虹數璇�"),
+ @Java110ParamDoc(name = "receivableAmount", length = 30, remark = "搴旀敹閲戦"),
+ @Java110ParamDoc(name = "receivedAmount", length = 30, remark = "瀹炴敹閲戦"),
+ @Java110ParamDoc(name = "spaceId", length = 30, remark = "鍦哄湴ID"),
+ @Java110ParamDoc(name = "openTimes",type="Array", length = 30, remark = "鍦哄湴ID"),
+ @Java110ParamDoc(parentNodeName = "openTimes",name = "hours", length = 30, remark = "棰勭害鏃堕棿"),
+
+})
+
+@Java110ResponseDoc(
+ params = {
+ @Java110ParamDoc(name = "code", type = "int", length = 11, defaultValue = "0", remark = "杩斿洖缂栧彿锛�0 鎴愬姛 鍏朵粬澶辫触"),
+ @Java110ParamDoc(name = "msg", type = "String", length = 250, defaultValue = "鎴愬姛", remark = "鎻忚堪"),
+
+ }
+)
+
+@Java110ExampleDoc(
+ reqBody="{\"spaceId\":\"102022093043260007\",\"personName\":\"wuxw\",\"personTel\":\"18909711443\",\"appointmentTime\":\"01:00\",\"receivableAmount\":\"10\",\"receivedAmount\":\"10\",\"payWay\":\"2\",\"state\":\"S\",\"remark\":\"123\",\"appointmentDate\":\"2022-09-01\",\"communityId\":\"2022081539020475\"}",
+ resBody="{\"code\":0,\"msg\":\"鎴愬姛\"}"
+)
/**
* 绫昏〃杩帮細淇濆瓨
@@ -52,6 +99,9 @@
@Autowired
private ICommunitySpacePersonV1InnerServiceSMO communitySpacePersonV1InnerServiceSMOImpl;
+ @Autowired
+ private ICommunitySpacePersonTimeV1InnerServiceSMO communitySpacePersonTimeV1InnerServiceSMOImpl;
+
@Override
public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
Assert.hasKeyAndValue(reqJson, "spaceId", "璇锋眰鎶ユ枃涓湭鍖呭惈spaceId");
@@ -62,7 +112,34 @@
Assert.hasKeyAndValue(reqJson, "receivedAmount", "璇锋眰鎶ユ枃涓湭鍖呭惈receivedAmount");
Assert.hasKeyAndValue(reqJson, "payWay", "璇锋眰鎶ユ枃涓湭鍖呭惈payWay");
Assert.hasKeyAndValue(reqJson, "communityId", "璇锋眰鎶ユ枃涓湭鍖呭惈communityId");
- Assert.hasKeyAndValue(reqJson, "state", "璇锋眰鎶ユ枃涓湭鍖呭惈state");
+
+ if(!reqJson.containsKey("openTimes")){
+ cmdDataFlowContext.setResponseEntity(ResultVo.success());
+ return ;
+ }
+
+ JSONArray openTimes = reqJson.getJSONArray("openTimes");
+
+ if(openTimes == null || openTimes.size() <1){
+ cmdDataFlowContext.setResponseEntity(ResultVo.success());
+ return ;
+ }
+ CommunitySpacePersonTimeDto communitySpacePersonTimeDto = null;
+ int flag = 0;
+ for(int timeIndex = 0 ;timeIndex < openTimes.size(); timeIndex++) {
+ if("N".equals(openTimes.getJSONObject(timeIndex).getString("isOpen"))){
+ continue;
+ }
+ communitySpacePersonTimeDto = new CommunitySpacePersonTimeDto();
+ communitySpacePersonTimeDto.setCommunityId(reqJson.getString("communityId"));
+ communitySpacePersonTimeDto.setAppointmentTime(reqJson.getString("appointmentTime"));
+ communitySpacePersonTimeDto.setHours(openTimes.getJSONObject(timeIndex).getString("hours"));
+ communitySpacePersonTimeDto.setSpaceId(reqJson.getString("spaceId"));
+ flag = communitySpacePersonTimeV1InnerServiceSMOImpl.queryCommunitySpacePersonTimesCount(communitySpacePersonTimeDto);
+ if(flag > 0){
+ throw new CmdException(reqJson.getString("appointmentTime")+","+openTimes.getJSONObject(timeIndex).getString("hours")+"宸茬粡琚绾�");
+ }
+ }
}
@@ -70,14 +147,44 @@
@Java110Transactional
public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
+
+
CommunitySpacePersonPo communitySpacePersonPo = BeanConvertUtil.covertBean(reqJson, CommunitySpacePersonPo.class);
communitySpacePersonPo.setCspId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
+ if(StringUtil.isEmpty(communitySpacePersonPo.getState())){
+ communitySpacePersonPo.setState(CommunitySpacePersonDto.STATE_W);
+ }
int flag = communitySpacePersonV1InnerServiceSMOImpl.saveCommunitySpacePerson(communitySpacePersonPo);
if (flag < 1) {
throw new CmdException("淇濆瓨鏁版嵁澶辫触");
}
+ if(!reqJson.containsKey("openTimes")){
+ cmdDataFlowContext.setResponseEntity(ResultVo.success());
+ return ;
+ }
+
+ JSONArray openTimes = reqJson.getJSONArray("openTimes");
+
+ if(openTimes == null || openTimes.size() <1){
+ cmdDataFlowContext.setResponseEntity(ResultVo.success());
+ return ;
+ }
+ CommunitySpacePersonTimePo communitySpacePersonTimePo = null;
+ for(int timeIndex = 0 ;timeIndex < openTimes.size(); timeIndex++) {
+ if("N".equals(openTimes.getJSONObject(timeIndex).getString("isOpen"))){
+ continue;
+ }
+ communitySpacePersonTimePo = new CommunitySpacePersonTimePo();
+ communitySpacePersonTimePo.setCommunityId(communitySpacePersonPo.getCommunityId());
+ communitySpacePersonTimePo.setCspId(communitySpacePersonPo.getCspId());
+ communitySpacePersonTimePo.setHours(openTimes.getJSONObject(timeIndex).getString("hours"));
+ communitySpacePersonTimePo.setSpaceId(communitySpacePersonPo.getSpaceId());
+ communitySpacePersonTimePo.setTimeId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
+ communitySpacePersonTimeV1InnerServiceSMOImpl.saveCommunitySpacePersonTime(communitySpacePersonTimePo);
+ }
+
cmdDataFlowContext.setResponseEntity(ResultVo.success());
}
}
--
Gitblit v1.8.0