From cab3425bb92d01f3494eb25c1f299038dc634c65 Mon Sep 17 00:00:00 2001
From: Your Name <you@example.com>
Date: 星期三, 15 三月 2023 23:43:48 +0800
Subject: [PATCH] 优化保养转单功能
---
service-user/src/main/java/com/java110/user/cmd/owner/SaveOwnerCmd.java | 38 +++++---------------------------------
1 files changed, 5 insertions(+), 33 deletions(-)
diff --git a/service-user/src/main/java/com/java110/user/cmd/owner/SaveOwnerCmd.java b/service-user/src/main/java/com/java110/user/cmd/owner/SaveOwnerCmd.java
index eba7f89..936d9bf 100644
--- a/service-user/src/main/java/com/java110/user/cmd/owner/SaveOwnerCmd.java
+++ b/service-user/src/main/java/com/java110/user/cmd/owner/SaveOwnerCmd.java
@@ -32,6 +32,7 @@
import com.java110.po.owner.OwnerRoomRelPo;
import com.java110.po.user.UserPo;
import com.java110.utils.cache.MappingCache;
+import com.java110.utils.constant.MappingConstant;
import com.java110.utils.constant.UserLevelConstant;
import com.java110.utils.exception.CmdException;
import com.java110.utils.lock.DistributedLock;
@@ -130,8 +131,6 @@
@Autowired
private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl;
- @Autowired
- private IAccountInnerServiceSMO accountInnerServiceSMOImpl;
@Override
public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
@@ -155,7 +154,7 @@
smsDto.setTel(reqJson.getString("link"));
smsDto.setCode(reqJson.getString("msgCode"));
smsDto = smsInnerServiceSMOImpl.validateCode(smsDto);
- if (!smsDto.isSuccess() && "ON".equals(MappingCache.getValue(SendSmsFactory.SMS_SEND_SWITCH))) {
+ if (!smsDto.isSuccess() && "ON".equals(MappingCache.getValue(MappingConstant.SMS_DOMAIN,SendSmsFactory.SMS_SEND_SWITCH))) {
throw new IllegalArgumentException(smsDto.getMsg());
}
}
@@ -217,11 +216,10 @@
"10000");
dealOwnerAttr(reqJson, cmdDataFlowContext);
- //涓氫富 寮�閫� 鐜伴噾璐︽埛锛屼笉鐒堕厤鍚堝晢鍩� 浼氬瓨鍦╞ug
- addAccountDto(ownerPo.getMemberId(),ownerPo.getCommunityId());
- String autoUser = MappingCache.getValue("OWNER", "AUTO_GENERATOR_OWNER_USER");
+
+ String autoUser = MappingCache.getValue(MappingConstant.DOMAIN_SYSTEM_SWITCH, "AUTO_GENERATOR_OWNER_USER");
if (!"ON".equals(autoUser)) {
return;
@@ -268,33 +266,7 @@
}
}
- private void addAccountDto(String ownerId,String communityId) {
- if (StringUtil.isEmpty(ownerId)) {
- return ;
- }
- //寮�濮嬮攣浠ｇ爜
- String requestId = DistributedLock.getLockUUID();
- String key = this.getClass().getSimpleName() + "AddCountDto" +ownerId;
- try {
- DistributedLock.waitGetDistributedLock(key, requestId);
- AccountPo accountPo = new AccountPo();
- accountPo.setAmount("0");
- accountPo.setAcctId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_acctId));
- accountPo.setObjId(ownerId);
- accountPo.setObjType(AccountDto.OBJ_TYPE_PERSON);
- accountPo.setAcctType(AccountDto.ACCT_TYPE_CASH);
- OwnerDto tmpOwnerDto = new OwnerDto();
- tmpOwnerDto.setMemberId(ownerId);
- tmpOwnerDto.setCommunityId(communityId);
- List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryOwners(tmpOwnerDto);
- Assert.listOnlyOne(ownerDtos, "涓氫富涓嶅瓨鍦�");
- accountPo.setAcctName(ownerDtos.get(0).getName());
- accountPo.setPartId(communityId);
- accountInnerServiceSMOImpl.saveAccount(accountPo);
- } finally {
- DistributedLock.releaseDistributedLock(requestId, key);
- }
- }
+
/**
* 鐢熸垚灏忓尯妤糏D
--
Gitblit v1.8.0