From f29e6f31e4f2d533124fc68346b7cc072f427c9b Mon Sep 17 00:00:00 2001
From: chengf <cgf12138@163.com>
Date: 星期四, 11 十二月 2025 16:58:24 +0800
Subject: [PATCH] Z三导入逻辑
---
service-community/src/main/java/com/java110/community/cmd/community/SaveCommunityCmd.java | 64 +++++++++++++++++++++++++-------
1 files changed, 50 insertions(+), 14 deletions(-)
diff --git a/service-community/src/main/java/com/java110/community/cmd/community/SaveCommunityCmd.java b/service-community/src/main/java/com/java110/community/cmd/community/SaveCommunityCmd.java
index d1bf0e0..49b7988 100644
--- a/service-community/src/main/java/com/java110/community/cmd/community/SaveCommunityCmd.java
+++ b/service-community/src/main/java/com/java110/community/cmd/community/SaveCommunityCmd.java
@@ -15,9 +15,11 @@
*/
package com.java110.community.cmd.community;
+import com.alibaba.druid.util.StringUtils;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.community.bmo.community.ICommunityBMO;
+import com.java110.community.bmo.community.PropertyManagementRecords;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.annotation.Java110Transactional;
import com.java110.core.context.ICmdDataFlowContext;
@@ -25,10 +27,14 @@
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.doc.annotation.*;
-import com.java110.dto.workflow.WorkflowDto;
+import com.java110.dto.community.CommunityDto;
+import com.java110.dto.community.PropertyManagementRecordDto;
+import com.java110.dto.oaWorkflow.WorkflowDto;
import com.java110.intf.common.IWorkflowV1InnerServiceSMO;
import com.java110.intf.community.ICommunityV1InnerServiceSMO;
-import com.java110.po.workflow.WorkflowPo;
+import com.java110.intf.community.PropertyManagementRecordsServiceSMO;
+import com.java110.po.community.PropertyManagementRecordPo;
+import com.java110.po.oaWorkflow.WorkflowPo;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.vo.ResultVo;
@@ -97,6 +103,9 @@
@Autowired
private IWorkflowV1InnerServiceSMO workflowV1InnerServiceSMOImpl;
+ @Autowired
+ private PropertyManagementRecordsServiceSMO propertyManagementRecordsServiceSMO;
+
@Override
public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
Assert.hasKeyAndValue(reqJson, "name", "蹇呭～锛岃濉啓灏忓尯鍚嶇О");
@@ -104,6 +113,7 @@
Assert.hasKeyAndValue(reqJson, "cityCode", "璇锋眰鎶ユ枃涓湭鍖呭惈cityCode");
Assert.hasKeyAndValue(reqJson, "payFeeMonth", "璇锋眰鎶ユ枃涓湭鍖呭惈payFeeMonth");
Assert.hasKeyAndValue(reqJson, "feePrice", "璇锋眰鎶ユ枃涓湭鍖呭惈feePrice");
+ Assert.hasKeyAndValue(reqJson, "takeTime", "璇锋眰鎶ユ枃涓湭鍖呭惈鎺ョ鏃ユ湡");
//灞炴�ф牎楠�
Assert.judgeAttrValue(reqJson);
@@ -134,18 +144,18 @@
throw new IllegalArgumentException("娣诲姞娴佺▼澶辫触");
}
- WorkflowPo workflowPo1 = null;
- workflowPo1 = new WorkflowPo();
- workflowPo1.setCommunityId(reqJson.getString("communityId"));
- workflowPo1.setFlowId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_flowId));
- workflowPo1.setFlowName("鐗╁搧棰嗙敤");
- workflowPo1.setFlowType(WorkflowDto.FLOW_TYPE_COLLECTION);
- workflowPo1.setSkipLevel(WorkflowDto.DEFAULT_SKIP_LEVEL);
- workflowPo1.setStoreId(reqJson.getString("storeId"));
- flag = workflowV1InnerServiceSMOImpl.saveWorkflow(workflowPo1);
- if (flag < 1) {
- throw new IllegalArgumentException("娣诲姞娴佺▼澶辫触");
- }
+// WorkflowPo workflowPo1 = null;
+// workflowPo1 = new WorkflowPo();
+// workflowPo1.setCommunityId(reqJson.getString("communityId"));
+// workflowPo1.setFlowId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_flowId));
+// workflowPo1.setFlowName("鐗╁搧棰嗙敤");
+// workflowPo1.setFlowType(WorkflowDto.FLOW_TYPE_COLLECTION);
+// workflowPo1.setSkipLevel(WorkflowDto.DEFAULT_SKIP_LEVEL);
+// workflowPo1.setStoreId(reqJson.getString("storeId"));
+// flag = workflowV1InnerServiceSMOImpl.saveWorkflow(workflowPo1);
+// if (flag < 1) {
+// throw new IllegalArgumentException("娣诲姞娴佺▼澶辫触");
+// }
WorkflowPo workflowPo2 = new WorkflowPo();
workflowPo2.setCommunityId(reqJson.getString("communityId")); //琚皟鎷ㄥ皬鍖�
@@ -158,9 +168,35 @@
if (flag < 1) {
throw new IllegalArgumentException("娣诲姞娴佺▼澶辫触");
}
+ addPropertyManagementRecord(reqJson);
cmdDataFlowContext.setResponseEntity(ResultVo.createResponseEntity(reqJson.getString("communityId")));
}
+ private void addPropertyManagementRecord(JSONObject reqJson) {
+ // 浠庤姹傚弬鏁颁腑鑾峰彇蹇呰淇℃伅锛堟牴鎹疄闄呬笟鍔″弬鏁拌皟鏁磌ey锛�
+ String communityId = reqJson.getString("communityId");
+ CommunityDto communityDto = new CommunityDto();
+ communityDto.setCommunityId(communityId);
+ CommunityDto communityDto1 = communityV1InnerServiceSMOImpl.queryCommunitys(communityDto).get(0);
+
+ // 鏋勫缓绠＄悊璁板綍PO瀵硅薄
+ PropertyManagementRecordPo recordPo = new PropertyManagementRecordPo();
+ // 璁剧疆涓婚敭ID锛堝鏋滀娇鐢ㄨ嚜澧炰富閿彲鐪佺暐锛岀敱鏁版嵁搴撶敓鎴愶級
+ recordPo.setId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_commentId));
+ recordPo.setCommunityId(communityId);
+ recordPo.setCommunityName(communityDto1.getName());
+ recordPo.setManagementStartDate(communityDto1.getTakeTime()); // 鏍煎紡闇�涓庢暟鎹簱涓�鑷�
+ recordPo.setManagementEndDate(communityDto1.getOutTime() == null ? null : communityDto1.getOutTime()); // 鍒濆涓哄湪绠＄姸鎬侊紝閫�绠℃椂闂翠负null
+ recordPo.setStatus(0); // 0-鏈夋晥
+ recordPo.setRemark("灏忓尯鍒涘缓鏃惰嚜鍔ㄦ坊鍔犵殑鍒濆鍦ㄧ璁板綍"); // 澶囨敞淇℃伅
+ // 鍒涘缓鏃堕棿鍜屾洿鏂版椂闂村彲鐢辨暟鎹簱鑷姩鐢熸垚鎴栭�氳繃妗嗘灦濉厖
+
+ // 璋冪敤淇濆瓨鎺ュ彛
+ int saveFlag = propertyManagementRecordsServiceSMO.savePropertyManagementRecord(recordPo);
+ if (saveFlag < 1) {
+ throw new IllegalArgumentException("娣诲姞灏忓尯鍦ㄧ璁板綍澶辫触");
+ }
+ }
private void dealAttr(JSONObject paramObj, ICmdDataFlowContext context) {
--
Gitblit v1.8.0