From 65763d38cf9b6b8067a293d9c99297efea0de3e3 Mon Sep 17 00:00:00 2001
From: 928255095 <928255095@qq.com>
Date: 星期二, 07 九月 2021 22:04:15 +0800
Subject: [PATCH] Merge branch 'xinghong-dev' into 'master'
---
service-api/src/main/java/com/java110/api/listener/ownerRepair/RepairDispatchListener.java | 38 +++++++++++++++++++++++++++++++++-----
1 files changed, 33 insertions(+), 5 deletions(-)
diff --git a/service-api/src/main/java/com/java110/api/listener/ownerRepair/RepairDispatchListener.java b/service-api/src/main/java/com/java110/api/listener/ownerRepair/RepairDispatchListener.java
index 1bd604f..c6932f7 100755
--- a/service-api/src/main/java/com/java110/api/listener/ownerRepair/RepairDispatchListener.java
+++ b/service-api/src/main/java/com/java110/api/listener/ownerRepair/RepairDispatchListener.java
@@ -18,6 +18,7 @@
import com.java110.po.fee.FeeAttrPo;
import com.java110.po.fee.PayFeePo;
import com.java110.po.owner.RepairUserPo;
+import com.java110.utils.cache.MappingCache;
import com.java110.utils.constant.BusinessTypeConstant;
import com.java110.utils.constant.ServiceCodeRepairDispatchStepConstant;
import com.java110.utils.util.Assert;
@@ -67,18 +68,21 @@
@Autowired
private IFeeInnerServiceSMO feeInnerServiceSMOImpl;
+ //鍩�
+ public static final String DOMAIN_COMMON = "DOMAIN.COMMON";
+
+ //閿�(缁翠慨甯堝倕鏈鐞嗘渶澶у崟鏁�)
+ public static final String REPAIR_NUMBER = "REPAIR_NUMBER";
+
@Override
protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
//Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
-
Assert.hasKeyAndValue(reqJson, "staffId", "鏈寘鍚憳宸D淇℃伅");
Assert.hasKeyAndValue(reqJson, "staffName", "鏈寘鍚憳宸ュ悕绉颁俊鎭�");
Assert.hasKeyAndValue(reqJson, "repairId", "鏈寘鍚姤淇崟淇℃伅");
Assert.hasKeyAndValue(reqJson, "context", "鏈寘鍚淳鍗曞唴瀹�");
Assert.hasKeyAndValue(reqJson, "communityId", "鏈寘鍚皬鍖轰俊鎭�");
Assert.hasKeyAndValue(reqJson, "action", "鏈寘鍚鐞嗗姩浣�");
-
-
}
@Override
@@ -101,7 +105,6 @@
}
private void backRepair(DataFlowContext context, JSONObject reqJson) {
-
//鏌ヨ璁㈠崟鐘舵��
RepairDto repairDto = new RepairDto();
repairDto.setRepairId(reqJson.getString("repairId"));
@@ -232,9 +235,21 @@
* @param reqJson
*/
private void transferRepair(DataFlowContext context, JSONObject reqJson) {
+ //鑾峰彇鎺ュ彈杞崟鐨勫憳宸�
+ String staffId = reqJson.getString("staffId");
+ RepairUserDto repairUser = new RepairUserDto();
+ repairUser.setStaffId(staffId);
+ repairUser.setState("10001"); //澶勭悊涓�
+ int i = repairUserInnerServiceSMOImpl.queryRepairUsersCount(repairUser);
+ //鍙栧嚭寮�鍏虫槧灏勭殑鍊�(缁翠慨甯堝倕鏈鐞嗘渶澶у崟鏁�)
+ String repairNumber = MappingCache.getValue(DOMAIN_COMMON, REPAIR_NUMBER);
+ if (i >= Integer.parseInt(repairNumber)) {
+ ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_BUSINESS_VERIFICATION, "璇ュ憳宸ユ湁瓒呰繃" + Integer.parseInt(repairNumber) + "鏉℃湭澶勭悊鐨勮鍗曟�ラ渶澶勭悊锛岃瀹夋帓鍏朵粬缁翠慨浜哄憳澶勭悊锛�");
+ context.setResponseEntity(responseEntity);
+ return;
+ }
String userId = reqJson.getString("userId");
String userName = reqJson.getString("userName");
-
RepairUserDto repairUserDto = new RepairUserDto();
repairUserDto.setRepairId(reqJson.getString("repairId"));
repairUserDto.setCommunityId(reqJson.getString("communityId"));
@@ -283,6 +298,19 @@
* @param reqJson
*/
private void dispacthRepair(DataFlowContext context, JSONObject reqJson) {
+ //鑾峰彇鎺ュ彈娲惧崟鐨勫憳宸�
+ String staffId = reqJson.getString("staffId");
+ RepairUserDto repairUser = new RepairUserDto();
+ repairUser.setStaffId(staffId);
+ repairUser.setState("10001"); //澶勭悊涓�
+ int i = repairUserInnerServiceSMOImpl.queryRepairUsersCount(repairUser);
+ //鍙栧嚭寮�鍏虫槧灏勭殑鍊�(缁翠慨甯堝倕鏈鐞嗘渶澶у崟鏁�)
+ String repairNumber = MappingCache.getValue(DOMAIN_COMMON, REPAIR_NUMBER);
+ if (i >= Integer.parseInt(repairNumber)) {
+ ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_BUSINESS_VERIFICATION, "璇ュ憳宸ユ湁瓒呰繃" + Integer.parseInt(repairNumber) + "鏉℃湭澶勭悊鐨勮鍗曟�ラ渶澶勭悊锛岃瀹夋帓鍏朵粬缁翠慨浜哄憳澶勭悊锛�");
+ context.setResponseEntity(responseEntity);
+ return;
+ }
//鑾峰彇鎶ヤ慨id
String repairId = reqJson.getString("repairId");
RepairDto repairDto = new RepairDto();
--
Gitblit v1.8.0