From 7935724516cb699835da888d59cd5b7bec5c6049 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期四, 12 九月 2024 12:07:29 +0800
Subject: [PATCH] 完成业主功能的优化

---
 service-user/src/main/java/com/java110/user/cmd/owner/EditOwnerCmd.java |  160 +++++++++++++----------------------------------------
 1 files changed, 39 insertions(+), 121 deletions(-)

diff --git a/service-user/src/main/java/com/java110/user/cmd/owner/EditOwnerCmd.java b/service-user/src/main/java/com/java110/user/cmd/owner/EditOwnerCmd.java
index 58dfc2c..d9e8642 100644
--- a/service-user/src/main/java/com/java110/user/cmd/owner/EditOwnerCmd.java
+++ b/service-user/src/main/java/com/java110/user/cmd/owner/EditOwnerCmd.java
@@ -113,66 +113,52 @@
     public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
         Assert.jsonObjectHaveKey(reqJson, "memberId", "璇锋眰鎶ユ枃涓湭鍖呭惈ownerId");
         Assert.jsonObjectHaveKey(reqJson, "name", "璇锋眰鎶ユ枃涓湭鍖呭惈name");
-//        Assert.jsonObjectHaveKey(reqJson, "age", "璇锋眰鎶ユ枃涓湭鍖呭惈age");
         Assert.jsonObjectHaveKey(reqJson, "link", "璇锋眰鎶ユ枃涓湭鍖呭惈link");
-        Assert.jsonObjectHaveKey(reqJson, "sex", "璇锋眰鎶ユ枃涓湭鍖呭惈sex");
-        Assert.jsonObjectHaveKey(reqJson, "ownerTypeCd", "璇锋眰鎶ユ枃涓湭鍖呭惈ownerTypeCd");
         Assert.jsonObjectHaveKey(reqJson, "communityId", "璇锋眰鎶ユ枃涓湭鍖呭惈communityId");
-        // Assert.jsonObjectHaveKey(paramIn, "idCard", "璇锋眰鎶ユ枃涓湭鍖呭惈韬唤璇佸彿");
         Assert.judgeAttrValue(reqJson);
         //鑾峰彇鎵嬫満鍙�(鍒ゆ柇鎵嬫満鍙锋槸鍚﹂噸澶�)
         String link = reqJson.getString("link");
         if (!StringUtil.isEmpty(link) && link.contains("*")) {
-            OwnerDto ownerDto = new OwnerDto();
-            ownerDto.setOwnerId(reqJson.getString("ownerId"));
-            //涓氫富
-            ownerDto.setOwnerTypeCd("1001");
-            List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryOwners(ownerDto);
-            Assert.listOnlyOne(ownerDtos, "鏌ヨ涓氫富淇℃伅閿欒锛�");
-            link = ownerDtos.get(0).getLink();
-            reqJson.put("link", link);
+            reqJson.put("link", "");
         }
         //鑾峰彇韬唤璇佸彿(鍒ゆ柇韬唤璇佸彿鏄惁閲嶅)
         String idCard = reqJson.getString("idCard");
         if (!StringUtil.isEmpty(idCard) && idCard.contains("*")) {
-            OwnerDto owner = new OwnerDto();
-            owner.setOwnerId(reqJson.getString("ownerId"));
-            //涓氫富
-            owner.setOwnerTypeCd("1001");
-            List<OwnerDto> owners = ownerInnerServiceSMOImpl.queryOwners(owner);
-            Assert.listOnlyOne(owners, "鏌ヨ涓氫富淇℃伅閿欒锛�");
-            idCard = owners.get(0).getIdCard();
-            reqJson.put("idCard", idCard);
+            reqJson.put("idCard", "");
         }
+
+        if (reqJson.containsKey("ownerPhotoUrl")) {
+            String ownerPhotoUrl = reqJson.getString("ownerPhotoUrl");
+            if (!StringUtil.isEmpty(ownerPhotoUrl) && ownerPhotoUrl.length() > 500) {
+                throw new CmdException("鍥剧墖鍦板潃澶暱");
+            }
+            if (!StringUtil.isEmpty(ownerPhotoUrl)) {
+                reqJson.put("faceUrl", ownerPhotoUrl);
+            }
+        }
+
+
         String userValidate = MappingCache.getValue("USER_VALIDATE");
         if (!"ON".equals(userValidate)) {
             return;
         }
+
+        OwnerDto curOwner = new OwnerDto();
+        curOwner.setMemberId(reqJson.getString("memberId"));
+
+        List<OwnerDto> curOwners = ownerInnerServiceSMOImpl.queryOwners(curOwner);
+        Assert.listOnlyOne(curOwners, "鏈煡璇㈠埌涓氫富淇℃伅鎴栨煡璇㈠埌澶氭潯");
+
         OwnerDto ownerDto = new OwnerDto();
-        ownerDto.setLink(link);
+        ownerDto.setLink(curOwners.get(0).getLink());
         ownerDto.setCommunityId(reqJson.getString("communityId"));
         List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryAllOwners(ownerDto);
         if (ownerDtos != null && ownerDtos.size() > 1) {
             throw new IllegalArgumentException("鎵嬫満鍙烽噸澶嶏紝璇烽噸鏂拌緭鍏�");
         } else if (ownerDtos != null && ownerDtos.size() == 1) {
             for (OwnerDto owner : ownerDtos) {
-                if ((!StringUtil.isEmpty(reqJson.getString("ownerId")) && !owner.getOwnerId().equals(reqJson.getString("ownerId"))) || (!StringUtil.isEmpty(reqJson.getString("memberId")) && !owner.getMemberId().equals(reqJson.getString("memberId")))) {
+                if (!reqJson.getString("memberId").equals(owner.getMemberId())) {
                     throw new IllegalArgumentException("鎵嬫満鍙烽噸澶嶏紝璇烽噸鏂拌緭鍏�");
-                }
-            }
-        }
-        if (!StringUtil.isEmpty(idCard)) {
-            OwnerDto owner = new OwnerDto();
-            owner.setIdCard(idCard);
-            owner.setCommunityId(reqJson.getString("communityId"));
-            List<OwnerDto> owners = ownerInnerServiceSMOImpl.queryAllOwners(owner);
-            if (owners != null && owners.size() > 1) {
-                throw new IllegalArgumentException("韬唤璇佸彿閲嶅锛岃閲嶆柊杈撳叆");
-            } else if (owners != null && owners.size() == 1) {
-                for (OwnerDto ownerDto1 : owners) {
-                    if ((!StringUtil.isEmpty(reqJson.getString("ownerId")) && !ownerDto1.getOwnerId().equals(reqJson.getString("ownerId"))) || (!StringUtil.isEmpty(reqJson.getString("memberId")) && !ownerDto1.getMemberId().equals(reqJson.getString("memberId")))) {
-                        throw new IllegalArgumentException("韬唤璇佸彿閲嶅锛岃閲嶆柊杈撳叆");
-                    }
                 }
             }
         }
@@ -181,24 +167,23 @@
     @Override
     @Java110Transactional
     public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
-        if (!reqJson.containsKey("ownerId") || OwnerDto.OWNER_TYPE_CD_OWNER.equals(reqJson.getString("ownerTypeCd"))) {
-            reqJson.put("ownerId", reqJson.getString("memberId"));
-        }
-        //杩欓噷娉ㄩ噴 鍥犱负 鏈夊浗澶栫殑鎵嬫満鍙� 涓嶆槸11浣�
-//        if (link.length() != 11) {
-//            throw new IllegalArgumentException("鎵嬫満鍙疯緭鍏ヤ笉姝g‘锛�");
-//        }
-        if (reqJson.containsKey("ownerPhoto") && !StringUtils.isEmpty(reqJson.getString("ownerPhoto"))) {
-            editOwnerPhoto(reqJson);
-        }
+
+
         //todo 淇敼 涓氫富淇℃伅
-        editOwner(reqJson);
+        OwnerPo ownerPo = BeanConvertUtil.covertBean(reqJson, OwnerPo.class);
+        int flag = ownerV1InnerServiceSMOImpl.updateOwner(ownerPo);
+        if (flag < 1) {
+            throw new CmdException("淇敼涓氫富澶辫触");
+        }
+
+        //todo 淇敼璐︽埛
+        updateAccount(reqJson);
+
         JSONArray attrs = reqJson.getJSONArray("attrs");
-        if (attrs == null || attrs.size() < 1) {
+        if (ListUtil.isNull(attrs)) {
             return;
         }
         JSONObject attr = null;
-        int flag = 0;
         for (int attrIndex = 0; attrIndex < attrs.size(); attrIndex++) {
             attr = attrs.getJSONObject(attrIndex);
             attr.put("memberId", reqJson.getString("memberId"));
@@ -222,30 +207,12 @@
         updateOwnerAppUser(reqJson);
     }
 
-    public void editOwner(JSONObject paramInJson) {
-        OwnerDto ownerDto = new OwnerDto();
-        ownerDto.setMemberId(paramInJson.getString("memberId"));
-        List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryOwnerMembers(ownerDto);
-        Assert.listOnlyOne(ownerDtos, "鏈煡璇㈠埌涓氫富淇℃伅鎴栨煡璇㈠埌澶氭潯");
-        JSONObject businessOwner = new JSONObject();
-        businessOwner.putAll(BeanConvertUtil.beanCovertMap(ownerDtos.get(0)));
-        businessOwner.putAll(paramInJson);
-        if (paramInJson.containsKey("wxPhoto")) {
-            businessOwner.put("link", paramInJson.getString("wxPhoto"));
-        }
-        businessOwner.put("state", ownerDtos.get(0).getState());
-        OwnerPo ownerPo = BeanConvertUtil.covertBean(businessOwner, OwnerPo.class);
-        if (StringUtil.isEmpty(ownerPo.getIdCard())) {
-            ownerPo.setAge(null);
-        }
-        int flag = ownerV1InnerServiceSMOImpl.updateOwner(ownerPo);
-        if (flag < 1) {
-            throw new CmdException("淇敼涓氫富澶辫触");
-        }
+    public void updateAccount(JSONObject paramInJson) {
+
         //todo 鍒ゆ柇涓氫富鎵嬫満鍙峰拰璐︽埛鎵嬫満鍙锋槸鍚︾浉鍚岋紝涓嶇浉鍚屼慨鏀硅处鎴锋墜鏈哄彿
         AccountDto accountDto = new AccountDto();
-        accountDto.setObjId(ownerDtos.get(0).getMemberId());
-        accountDto.setPartId(ownerDtos.get(0).getCommunityId());
+        accountDto.setObjId(paramInJson.getString("memberId"));
+        accountDto.setPartId(paramInJson.getString("communityId"));
         List<AccountDto> accountDtos = accountInnerServiceSMOImpl.queryAccounts(accountDto);
         if (ListUtil.isNull(accountDtos)) {
             return;
@@ -255,61 +222,12 @@
         owner.setMemberId(paramInJson.getString("memberId"));
         List<OwnerDto> owners = ownerInnerServiceSMOImpl.queryOwnerMembers(owner);
         Assert.listOnlyOne(owners, "鏈煡璇㈠埌涓氫富淇℃伅鎴栨煡璇㈠埌澶氭潯");
-        /*if (accountDtos.get(0).getLink().equals(ownerDtos.get(0).getLink())) {
-            return;
-        }*/
         if (!accountDtos.get(0).getLink().equals(owners.get(0).getLink()) || !accountDtos.get(0).getAcctName().equals(owners.get(0).getName())) {
             AccountPo accountPo = new AccountPo();
             accountPo.setAcctName(owners.get(0).getName());
             accountPo.setoLink(owners.get(0).getLink());
             accountPo.setAcctId(accountDtos.get(0).getAcctId());
             accountInnerServiceSMOImpl.updateAccount(accountPo);
-        }
-        /*AccountPo accountPo = new AccountPo();
-        accountPo.setoLink(ownerDtos.get(0).getLink());
-        accountPo.setAcctId(accountDtos.get(0).getAcctId());
-        accountInnerServiceSMOImpl.updateAccount(accountPo);*/
-    }
-
-    public void editOwnerPhoto(JSONObject paramInJson) {
-        String _photo = paramInJson.getString("ownerPhoto");
-        if (_photo.length() > 512) {
-            FileDto fileDto = new FileDto();
-            fileDto.setFileId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_file_id));
-            fileDto.setFileName(fileDto.getFileId());
-            fileDto.setContext(_photo);
-            fileDto.setSuffix("jpeg");
-            fileDto.setCommunityId(paramInJson.getString("communityId"));
-            _photo = fileInnerServiceSMOImpl.saveFile(fileDto);
-        }
-        FileRelDto fileRelDto = new FileRelDto();
-        fileRelDto.setRelTypeCd("10000");
-        fileRelDto.setObjId(paramInJson.getString("memberId"));
-        int flag = 0;
-        List<FileRelDto> fileRelDtos = fileRelInnerServiceSMOImpl.queryFileRels(fileRelDto);
-        if (fileRelDtos == null || fileRelDtos.size() == 0) {
-            JSONObject businessUnit = new JSONObject();
-            businessUnit.put("fileRelId", GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_fileRelId));
-            businessUnit.put("relTypeCd", "10000");
-            businessUnit.put("saveWay", "table");
-            businessUnit.put("objId", paramInJson.getString("memberId"));
-            businessUnit.put("fileRealName", _photo);
-            businessUnit.put("fileSaveName", _photo);
-            FileRelPo fileRelPo = BeanConvertUtil.covertBean(businessUnit, FileRelPo.class);
-            flag = fileRelInnerServiceSMOImpl.saveFileRel(fileRelPo);
-            if (flag < 1) {
-                throw new CmdException("淇濆瓨鏂囦欢澶辫触");
-            }
-            return;
-        }
-        JSONObject businessUnit = new JSONObject();
-        businessUnit.putAll(BeanConvertUtil.beanCovertMap(fileRelDtos.get(0)));
-        businessUnit.put("fileRealName", _photo);
-        businessUnit.put("fileSaveName", _photo);
-        FileRelPo fileRelPo = BeanConvertUtil.covertBean(businessUnit, FileRelPo.class);
-        flag = fileRelInnerServiceSMOImpl.updateFileRel(fileRelPo);
-        if (flag < 1) {
-            throw new CmdException("淇濆瓨鏂囦欢澶辫触");
         }
     }
 

--
Gitblit v1.8.0