From 0ed7c3dfb5cbffe1a8b7a38e2a402dee7317d626 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期一, 29 四月 2024 01:23:09 +0800
Subject: [PATCH] 优化代码
---
service-common/src/main/java/com/java110/common/bmo/mall/impl/PrestoreAccountImpl.java | 58 +++++++++++++++++++++++++++++
service-common/src/main/java/com/java110/common/bmo/mall/impl/QueryOwnerCommunityImpl.java | 11 +++++
service-acct/src/main/java/com/java110/acct/smo/impl/AccountInnerServiceSMOImpl.java | 3 +
3 files changed, 70 insertions(+), 2 deletions(-)
diff --git a/service-acct/src/main/java/com/java110/acct/smo/impl/AccountInnerServiceSMOImpl.java b/service-acct/src/main/java/com/java110/acct/smo/impl/AccountInnerServiceSMOImpl.java
index 901c4d5..3818a6a 100644
--- a/service-acct/src/main/java/com/java110/acct/smo/impl/AccountInnerServiceSMOImpl.java
+++ b/service-acct/src/main/java/com/java110/acct/smo/impl/AccountInnerServiceSMOImpl.java
@@ -15,6 +15,7 @@
import com.java110.po.account.AccountDetailPo;
import com.java110.utils.lock.DistributedLock;
import com.java110.utils.util.BeanConvertUtil;
+import com.java110.utils.util.ListUtil;
import com.java110.utils.util.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestBody;
@@ -141,7 +142,7 @@
accountDto.setObjId(accountDetailPo.getObjId());
accountDto.setAcctId(accountDetailPo.getAcctId());
accounts = BeanConvertUtil.covertBeanList(accountServiceDaoImpl.getAccountInfo(BeanConvertUtil.beanCovertMap(accountDto)), AccountDto.class);
- if (accounts == null || accounts.size() < 1) {
+ if (ListUtil.isNull(accounts)) {
throw new IllegalArgumentException("璐︽埛涓嶅瓨鍦�");
}
//鍦ㄨ处鎴峰鍔�
diff --git a/service-common/src/main/java/com/java110/common/bmo/mall/impl/PrestoreAccountImpl.java b/service-common/src/main/java/com/java110/common/bmo/mall/impl/PrestoreAccountImpl.java
new file mode 100644
index 0000000..8f4ae79
--- /dev/null
+++ b/service-common/src/main/java/com/java110/common/bmo/mall/impl/PrestoreAccountImpl.java
@@ -0,0 +1,58 @@
+package com.java110.common.bmo.mall.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.common.bmo.mall.IMallCommonApiBmo;
+import com.java110.core.context.ICmdDataFlowContext;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.dto.account.AccountDto;
+import com.java110.intf.acct.IAccountInnerServiceSMO;
+import com.java110.po.account.AccountDetailPo;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.ListUtil;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service("prestoreAccountImpl")
+public class PrestoreAccountImpl implements IMallCommonApiBmo {
+
+ @Autowired
+ private IAccountInnerServiceSMO accountInnerServiceSMOImpl;
+
+ @Override
+ public void validate(ICmdDataFlowContext context, JSONObject reqJson) {
+ Assert.hasKeyAndValue(reqJson, "ownerId", "鏈寘鍚笟涓�");
+ Assert.hasKeyAndValue(reqJson, "link", "鏈寘鍚笟涓绘墜鏈哄彿");
+ Assert.hasKeyAndValue(reqJson, "amount", "鏈寘鍚噾棰�");
+ Assert.hasKeyAndValue(reqJson, "communityId", "鏈寘鍚皬鍖�");
+ }
+
+ @Override
+ public void doCmd(ICmdDataFlowContext context, JSONObject reqJson) {
+
+
+ AccountDto accountDto = new AccountDto();
+ accountDto.setObjId(reqJson.getString("ownerId"));
+ accountDto.setLink(reqJson.getString("link"));
+ accountDto.setPartId(reqJson.getString("communityId"));
+ List<AccountDto> accountDtos = accountInnerServiceSMOImpl.queryAccounts(accountDto);
+ if (ListUtil.isNull(accountDtos)) {
+ throw new CmdException("璐︽埛涓嶅瓨鍦�");
+ }
+
+ AccountDetailPo accountDetailPo = new AccountDetailPo();
+ accountDetailPo.setRemark("閲戝竵-鎶垫墸閲戝厖鍊�");
+ accountDetailPo.setAmount(reqJson.getString("amount"));
+ accountDetailPo.setOrderId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_orderId));
+ accountDetailPo.setAcctId(accountDtos.get(0).getAcctId());
+ accountDetailPo.setObjId(accountDtos.get(0).getObjId());
+ accountDetailPo.setObjType(accountDtos.get(0).getObjType());
+ accountInnerServiceSMOImpl.prestoreAccount(accountDetailPo);
+
+ context.setResponseEntity(ResultVo.createResponseEntity(ResultVo.CODE_OK, "鍏呭�兼垚鍔�"));
+
+ }
+}
diff --git a/service-common/src/main/java/com/java110/common/bmo/mall/impl/QueryOwnerCommunityImpl.java b/service-common/src/main/java/com/java110/common/bmo/mall/impl/QueryOwnerCommunityImpl.java
index f0eb086..16dbe6e 100644
--- a/service-common/src/main/java/com/java110/common/bmo/mall/impl/QueryOwnerCommunityImpl.java
+++ b/service-common/src/main/java/com/java110/common/bmo/mall/impl/QueryOwnerCommunityImpl.java
@@ -14,6 +14,7 @@
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.ListUtil;
+import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -38,7 +39,14 @@
@Override
public void validate(ICmdDataFlowContext context, JSONObject reqJson) {
- Assert.hasKeyAndValue(reqJson, "link", "鏈寘鍚墜鏈哄彿");
+
+ String link = reqJson.getString("link");
+
+ String ownerId = reqJson.getString("ownerId");
+
+ if (StringUtil.isEmpty(link) && StringUtil.isEmpty(ownerId)) {
+ throw new IllegalArgumentException("鏈寘鍚墜鏈哄彿鍜屼笟涓籌D");
+ }
}
@@ -46,6 +54,7 @@
public void doCmd(ICmdDataFlowContext context, JSONObject reqJson) {
OwnerDto ownerDto = new OwnerDto();
+ ownerDto.setMemberId(reqJson.getString("ownerId"));
ownerDto.setLink(reqJson.getString("link"));
ownerDto.setCommunityId(reqJson.getString("communityId"));
List<OwnerDto> ownerDtos = buildingOwnerV1InnerServiceSMOImpl.queryBuildingOwners(ownerDto);
--
Gitblit v1.8.0