From 793a80e25c218d2a1c7078b6aeda8e0032b89efd Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期日, 31 五月 2020 23:22:44 +0800
Subject: [PATCH] 优化 钥匙类型 错误问题
---
Api/src/main/java/com/java110/api/bmo/floor/impl/FloorBMOImpl.java | 111 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 111 insertions(+), 0 deletions(-)
diff --git a/Api/src/main/java/com/java110/api/bmo/floor/impl/FloorBMOImpl.java b/Api/src/main/java/com/java110/api/bmo/floor/impl/FloorBMOImpl.java
index 79e4d6b..d1e7e2a 100644
--- a/Api/src/main/java/com/java110/api/bmo/floor/impl/FloorBMOImpl.java
+++ b/Api/src/main/java/com/java110/api/bmo/floor/impl/FloorBMOImpl.java
@@ -1,8 +1,20 @@
package com.java110.api.bmo.floor.impl;
+import com.alibaba.fastjson.JSONObject;
import com.java110.api.bmo.ApiBaseBMO;
import com.java110.api.bmo.floor.IFloorBMO;
+import com.java110.core.context.DataFlowContext;
+import com.java110.core.smo.community.ICommunityInnerServiceSMO;
+import com.java110.dto.CommunityMemberDto;
+import com.java110.po.community.CommunityMemberPo;
+import com.java110.po.floor.FloorPo;
+import com.java110.utils.constant.*;
+import com.java110.utils.exception.ListenerExecuteException;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+
+import java.util.List;
/**
* @ClassName FloorBMOImpl
@@ -14,4 +26,103 @@
**/
@Service("floorBMOImpl")
public class FloorBMOImpl extends ApiBaseBMO implements IFloorBMO {
+ @Autowired
+ private ICommunityInnerServiceSMO communityInnerServiceSMOImpl;
+
+ private static final int DEFAULT_SEQ_COMMUNITY_MEMBER = 2;
+
+ /**
+ * 娣诲姞灏忓尯妤间俊鎭�
+ *
+ * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
+ * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
+ */
+ public void deleteFloor(JSONObject paramInJson, DataFlowContext context) {
+
+ FloorPo floorPo = BeanConvertUtil.covertBean(paramInJson, FloorPo.class);
+ super.delete(context, floorPo, BusinessTypeConstant.BUSINESS_TYPE_DELETE_FLOOR_INFO);
+ }
+
+ /**
+ * 閫�鍑哄皬鍖烘垚鍛�
+ *
+ * @param paramInJson 鎺ュ彛浼犲叆鍏ュ弬
+ * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
+ */
+ public void exitCommunityMember(JSONObject paramInJson, DataFlowContext context) {
+
+ JSONObject businessCommunityMember = new JSONObject();
+ CommunityMemberDto communityMemberDto = new CommunityMemberDto();
+ communityMemberDto.setMemberId(paramInJson.getString("floorId"));
+ communityMemberDto.setCommunityId(paramInJson.getString("communityId"));
+ communityMemberDto.setStatusCd(StatusConstant.STATUS_CD_VALID);
+ communityMemberDto.setMemberTypeCd(CommunityMemberTypeConstant.FLOOR);
+ List<CommunityMemberDto> communityMemberDtoList = communityInnerServiceSMOImpl.getCommunityMembers(communityMemberDto);
+
+ if (communityMemberDtoList == null || communityMemberDtoList.size() != 1) {
+ throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_ERROR, "灏忓尯妤煎拰灏忓尯瀛樺湪鍏崇郴瀛樺湪寮傚父锛岃妫�鏌�");
+ }
+ businessCommunityMember.put("communityMemberId", communityMemberDtoList.get(0).getCommunityMemberId());
+ CommunityMemberPo communityMemberPo = BeanConvertUtil.covertBean(businessCommunityMember, CommunityMemberPo.class);
+ super.delete(context, communityMemberPo, BusinessTypeConstant.BUSINESS_TYPE_MEMBER_QUIT_COMMUNITY);
+
+ }
+
+ /**
+ * 娣诲姞灏忓尯妤间俊鎭�
+ *
+ * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
+ * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
+ */
+ public void editFloor(JSONObject paramInJson, DataFlowContext context) {
+
+ JSONObject businessFloor = new JSONObject();
+ businessFloor.put("floorId", paramInJson.getString("floorId"));
+ businessFloor.put("name", paramInJson.getString("name"));
+ businessFloor.put("remark", paramInJson.getString("remark"));
+ businessFloor.put("userId", paramInJson.getString("userId"));
+ businessFloor.put("floorNum", paramInJson.getString("floorNum"));
+ businessFloor.put("communityId", paramInJson.getString("communityId"));
+
+ FloorPo floorPo = BeanConvertUtil.covertBean(businessFloor, FloorPo.class);
+ super.update(context, floorPo, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_FLOOR_INFO);
+ }
+
+ /**
+ * 娣诲姞灏忓尯妤间俊鎭�
+ *
+ * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
+ * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
+ */
+ public void addFloor(JSONObject paramInJson, DataFlowContext context) {
+
+ JSONObject businessFloor = new JSONObject();
+ businessFloor.put("floorId", paramInJson.getString("floorId"));
+ businessFloor.put("name", paramInJson.getString("name"));
+ businessFloor.put("remark", paramInJson.getString("remark"));
+ businessFloor.put("userId", paramInJson.getString("userId"));
+ businessFloor.put("floorNum", paramInJson.getString("floorNum"));
+ businessFloor.put("communityId", paramInJson.getString("communityId"));
+ FloorPo floorPo = BeanConvertUtil.covertBean(businessFloor, FloorPo.class);
+ super.insert(context, floorPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_FLOOR_INFO);
+ }
+
+
+ /**
+ * 娣诲姞灏忓尯鎴愬憳
+ *
+ * @param paramInJson 缁勮 妤煎皬鍖哄叧绯�
+ * @return 灏忓尯鎴愬憳淇℃伅
+ */
+ public void addCommunityMember(JSONObject paramInJson, DataFlowContext context) {
+
+ JSONObject businessCommunityMember = new JSONObject();
+ businessCommunityMember.put("communityMemberId", "-1");
+ businessCommunityMember.put("communityId", paramInJson.getString("communityId"));
+ businessCommunityMember.put("memberId", paramInJson.getString("floorId"));
+ businessCommunityMember.put("memberTypeCd", CommunityMemberTypeConstant.FLOOR);
+ businessCommunityMember.put("auditStatusCd", StateConstant.AGREE_AUDIT);
+ CommunityMemberPo communityMemberPo = BeanConvertUtil.covertBean(businessCommunityMember, CommunityMemberPo.class);
+ super.insert(context, communityMemberPo, BusinessTypeConstant.BUSINESS_TYPE_MEMBER_JOINED_COMMUNITY);
+ }
}
--
Gitblit v1.8.0