From d33e2d4a6e82487532251e8ec6e32b06de442d9f Mon Sep 17 00:00:00 2001
From: Your Name <you@example.com>
Date: 星期一, 07 八月 2023 21:57:27 +0800
Subject: [PATCH] 优化代码

---
 service-job/src/main/java/com/java110/job/adapt/Repair/MachineReturnRepairAdapt.java |  287 +++++++++++++++++++++++++++++++++------------------------
 1 files changed, 167 insertions(+), 120 deletions(-)

diff --git a/service-job/src/main/java/com/java110/job/adapt/Repair/MachineReturnRepairAdapt.java b/service-job/src/main/java/com/java110/job/adapt/Repair/MachineReturnRepairAdapt.java
old mode 100644
new mode 100755
index f1bb56b..751dea5
--- a/service-job/src/main/java/com/java110/job/adapt/Repair/MachineReturnRepairAdapt.java
+++ b/service-job/src/main/java/com/java110/job/adapt/Repair/MachineReturnRepairAdapt.java
@@ -1,33 +1,40 @@
 package com.java110.job.adapt.Repair;
 
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.java110.core.factory.WechatFactory;
-import com.java110.dto.basePrivilege.BasePrivilegeDto;
 import com.java110.dto.community.CommunityDto;
 import com.java110.dto.owner.OwnerAppUserDto;
+import com.java110.dto.owner.OwnerRoomRelDto;
 import com.java110.dto.repair.RepairDto;
+import com.java110.dto.repair.RepairSettingDto;
 import com.java110.dto.repair.RepairUserDto;
-import com.java110.dto.smallWeChat.SmallWeChatDto;
-import com.java110.dto.smallWechatAttr.SmallWechatAttrDto;
-import com.java110.dto.staffAppAuth.StaffAppAuthDto;
-import com.java110.dto.user.UserDto;
-import com.java110.entity.order.Business;
-import com.java110.entity.wechat.Content;
-import com.java110.entity.wechat.Data;
-import com.java110.entity.wechat.PropertyFeeTemplateMessage;
+import com.java110.dto.wechat.SmallWeChatDto;
+import com.java110.dto.wechat.SmallWechatAttrDto;
+import com.java110.dto.user.StaffAppAuthDto;
+import com.java110.dto.system.Business;
+import com.java110.dto.wechat.Content;
+import com.java110.dto.wechat.Data;
+import com.java110.dto.wechat.PropertyFeeTemplateMessage;
 import com.java110.intf.community.ICommunityInnerServiceSMO;
 import com.java110.intf.community.IRepairInnerServiceSMO;
+import com.java110.intf.community.IRepairSettingInnerServiceSMO;
 import com.java110.intf.community.IRepairUserInnerServiceSMO;
-import com.java110.intf.order.IPrivilegeInnerServiceSMO;
 import com.java110.intf.store.ISmallWeChatInnerServiceSMO;
 import com.java110.intf.store.ISmallWechatAttrInnerServiceSMO;
 import com.java110.intf.user.*;
 import com.java110.job.adapt.DatabusAdaptImpl;
+import com.java110.job.msgNotify.MsgNotifyFactory;
+import com.java110.po.owner.RepairUserPo;
 import com.java110.utils.cache.MappingCache;
+import com.java110.utils.cache.UrlCache;
+import com.java110.utils.constant.MappingConstant;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.DateUtil;
 import com.java110.utils.util.StringUtil;
 import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import com.java110.core.log.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Component;
@@ -70,20 +77,50 @@
     private RestTemplate outRestTemplate;
 
     @Autowired
-    private IPrivilegeInnerServiceSMO privilegeInnerServiceSMO;
+    private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMO;
 
     @Autowired
-    private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMO;
+    private IRepairSettingInnerServiceSMO repairSettingInnerServiceSMO;
+
+    @Autowired
+    private IOwnerRoomRelInnerServiceSMO ownerRoomRelInnerServiceSMO;
 
     //妯℃澘淇℃伅鎺ㄩ�佸湴鍧�
     private static String sendMsgUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=";
 
     @Override
-    public void execute(Business business, List<Business> businesses) {
+    public void execute(Business business, List<Business> businesses) throws Exception {
+        JSONObject data = business.getData();
+        JSONArray businessRepairUsers = new JSONArray();
+        System.out.println("鏀跺埌鏃ュ織锛�>>>>>>>>>>>>>" + data.toJSONString());
+        if (data.containsKey(RepairUserPo.class.getSimpleName())) {
+            Object bObj = data.get(RepairUserPo.class.getSimpleName());
+
+            if (bObj instanceof JSONObject) {
+                businessRepairUsers.add(bObj);
+            } else if (bObj instanceof List) {
+                businessRepairUsers = JSONArray.parseArray(JSONObject.toJSONString(bObj));
+            } else {
+                businessRepairUsers = (JSONArray) bObj;
+            }
+        } else {
+            if (data instanceof JSONObject) {
+                businessRepairUsers.add(data);
+            }
+        }
+        //JSONObject businessOwnerCar = data.getJSONObject("businessOwnerCar");
+        for (int bOwnerRepairIndex = 0; bOwnerRepairIndex < businessRepairUsers.size(); bOwnerRepairIndex++) {
+            JSONObject businessRepairUser = businessRepairUsers.getJSONObject(bOwnerRepairIndex);
+            doDealOwnerRepair(business, businessRepairUser);
+        }
+    }
+
+    private void doDealOwnerRepair(Business business, JSONObject businessRepairUser) {
         RepairUserDto repairUserDto = new RepairUserDto();
-        repairUserDto.setbId(business.getbId());
+        repairUserDto.setRuId(businessRepairUser.getString("ruId"));
         repairUserDto.setStatusCd("0");
         List<RepairUserDto> repairUserDtos = repairUserInnerServiceSMO.queryRepairUsers(repairUserDto);
+        Assert.listOnlyOne(repairUserDtos, "褰撳墠鐢ㄦ埛娌℃湁闇�瑕佸鐞嗚鍗�");
         //鑾峰彇鐘舵��
         String state = repairUserDtos.get(0).getState();
         //鑾峰彇鎶ヤ慨id
@@ -92,6 +129,7 @@
         repairDto.setRepairId(repairId);
         repairDto.setStatusCd("0");
         List<RepairDto> repairDtos = repairInnerServiceSMO.queryRepairs(repairDto);
+        Assert.listOnlyOne(repairDtos, "涓嶅瓨鍦ㄨ繖鏉℃姤淇俊鎭�");
         //鑾峰彇鎶ヤ慨浜哄鍚�
         String repairName = repairDtos.get(0).getRepairName();
         //鑾峰彇鎶ヤ慨鍐呭
@@ -106,19 +144,32 @@
         CommunityDto communityDto = new CommunityDto();
         communityDto.setCommunityId(communityId);
         List<CommunityDto> communityDtos = communityInnerServiceSMO.queryCommunitys(communityDto);
+        //鑾峰彇鎶ヤ慨绫诲瀷
+        String repairType = repairDtos.get(0).getRepairType();
+        RepairSettingDto repairSettingDto = new RepairSettingDto();
+        repairSettingDto.setSettingId(repairType);
+        List<RepairSettingDto> repairSettingDtos = repairSettingInnerServiceSMO.queryRepairSettings(repairSettingDto);
+        Assert.listOnlyOne(repairSettingDtos, "淇℃伅閿欒");
         JSONObject paramIn = new JSONObject();
-        if (state.equals("10003")) {   //閫�鍗曠姸鎬�
+        if (RepairUserDto.STATE_BACK.equals(state)) {   //閫�鍗曠姸鎬�
             //閫�鍗曚汉
             String staffName = repairUserDtos.get(0).getStaffName();
             //閫�鍗曞娉�
             String returnContext = repairUserDtos.get(0).getContext();
+            //涓婄骇鎿嶄綔浜�
+            String preStaffId = repairUserDtos.get(0).getPreStaffId();
+            //涓婄骇鎿嶄綔浜哄鍚�
+            String preStaffName = repairUserDtos.get(0).getPreStaffName();
             paramIn.put("repairTypeName", repairTypeName);
             paramIn.put("repairObjName", repairObjName);
             paramIn.put("staffName", staffName);
             paramIn.put("context", context);
             paramIn.put("returnContext", returnContext);
+            paramIn.put("preStaffId", preStaffId);
+            paramIn.put("preStaffName", preStaffName);
+            paramIn.put("repairName", repairUserDtos.get(0).getRepairName());
             sendReturnMessage(paramIn, communityDtos.get(0));
-        } else if (state.equals("10002")) {     //缁撳崟
+        } else if (RepairUserDto.STATE_CLOSE.equals(state)) {     //缁撳崟
             //鑾峰彇鐢ㄦ埛id
             String preStaffId = repairUserDtos.get(0).getPreStaffId();
             //鑾峰彇缁翠慨甯堝倕濮撳悕
@@ -129,6 +180,8 @@
             Date endTime = repairUserDtos.get(0).getEndTime();
             SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
             String time = format.format(endTime);
+            //鑾峰彇浠锋牸
+            String price = "";
             paramIn.put("repairName", repairName);
             paramIn.put("repairObjName", repairObjName);
             paramIn.put("context", context);
@@ -136,7 +189,27 @@
             paramIn.put("time", time);
             paramIn.put("repairObjId", repairObjId);
             paramIn.put("preStaffId", preStaffId);
-            publishReturnMsg(paramIn, communityDtos.get(0));
+            RepairUserDto repairUser = new RepairUserDto();
+            repairUser.setRepairId(repairId);
+            repairUser.setState("10005");
+            //鏌ヨ鎶ヤ慨鐢ㄦ埛璁板綍
+            List<RepairUserDto> repairUserDtoList = repairUserInnerServiceSMO.queryRepairUsers(repairUser);
+            //鑾峰彇鎶ヤ慨鐢ㄦ埛id
+            String staffId = repairUserDtoList.get(0).getStaffId();
+            paramIn.put("userId", staffId);
+            sendFinishRepairOwnerMsg(paramIn, communityDtos.get(0));
+            if (!StringUtil.isEmpty(price)) {
+                paramIn.put("price", price);
+                paramIn.put("feeState", "鏈即璐�");
+                //鑾峰彇浠樻鏂筰d
+                String roomId = repairDtos.get(0).getRepairObjId();
+                //鑾峰彇浠樻鏂瑰悕绉�
+                String roomName = repairDtos.get(0).getRepairObjName();
+                paramIn.put("roomId", roomId);
+                paramIn.put("roomName", roomName);
+                //鐢熸垚璐圭敤缁欎笟涓诲彂閫佷俊鎭�
+                sendMessage(paramIn, communityDtos.get(0));
+            }
         }
     }
 
@@ -147,73 +220,29 @@
      * @param communityDto
      */
     private void sendReturnMessage(JSONObject paramIn, CommunityDto communityDto) {
-        //鏌ヨ鍏紬鍙烽厤缃�
-        SmallWeChatDto smallWeChatDto = new SmallWeChatDto();
-        smallWeChatDto.setWeChatType("1100");
-        smallWeChatDto.setObjType(SmallWeChatDto.OBJ_TYPE_COMMUNITY);
-        smallWeChatDto.setObjId(communityDto.getCommunityId());
-        List<SmallWeChatDto> smallWeChatDtos = smallWeChatInnerServiceSMOImpl.querySmallWeChats(smallWeChatDto);
-        if (smallWeChatDto == null || smallWeChatDtos.size() <= 0) {
-            logger.info("鏈厤缃井淇″叕浼楀彿淇℃伅,瀹氭椂浠诲姟鎵ц缁撴潫");
-            return;
+
+        JSONObject content = new JSONObject();
+        content.put("repairTypeName", paramIn.getString("repairTypeName"));
+        if (communityDto.getName().equals(paramIn.getString("repairObjName"))) {
+            content.put("repairObjName", paramIn.getString("repairObjName"));
+        } else {
+            content.put("repairObjName", communityDto.getName() + paramIn.getString("repairObjName"));
         }
-        SmallWeChatDto weChatDto = smallWeChatDtos.get(0);
-        SmallWechatAttrDto smallWechatAttrDto = new SmallWechatAttrDto();
-        smallWechatAttrDto.setCommunityId(communityDto.getCommunityId());
-        smallWechatAttrDto.setWechatId(weChatDto.getWeChatId());
-        smallWechatAttrDto.setSpecCd(SmallWechatAttrDto.SPEC_CD_WECHAT_WORK_ORDER_REMIND_TEMPLATE);
-        List<SmallWechatAttrDto> smallWechatAttrDtos = smallWechatAttrInnerServiceSMOImpl.querySmallWechatAttrs(smallWechatAttrDto);
-        if (smallWechatAttrDtos == null || smallWechatAttrDtos.size() <= 0) {
-            logger.info("鏈厤缃井淇″叕浼楀彿娑堟伅妯℃澘");
-            return;
-        }
-        String templateId = smallWechatAttrDtos.get(0).getValue();
-        String accessToken = WechatFactory.getAccessToken(weChatDto.getAppId(), weChatDto.getAppSecret());
-        if (StringUtil.isEmpty(accessToken)) {
-            logger.info("鎺ㄩ�佸井淇℃ā鏉�,鑾峰彇accessToken澶辫触:{}", accessToken);
-            return;
-        }
-        // 鏍规嵁鐗瑰畾鏉冮檺鏌ヨ 鏈夎鏉冮檺鐨� 鍛樺伐
-        BasePrivilegeDto basePrivilegeDto = new BasePrivilegeDto();
-        basePrivilegeDto.setResource("/wechatRepairRegistration");
-        List<UserDto> userDtos = privilegeInnerServiceSMO.queryPrivilegeUsers(basePrivilegeDto);
-        String url = sendMsgUrl + accessToken;
-        for (UserDto userDto : userDtos) {
-            //鏍规嵁 userId 鏌ヨ鍒皁penId
-            StaffAppAuthDto staffAppAuthDto = new StaffAppAuthDto();
-            staffAppAuthDto.setStaffId(userDto.getUserId());
-            staffAppAuthDto.setAppType("WECHAT");
-            List<StaffAppAuthDto> staffAppAuthDtos = staffAppAuthInnerServiceSMO.queryStaffAppAuths(staffAppAuthDto);
-            String openId = staffAppAuthDtos.get(0).getOpenId();
-            Data data = new Data();
-            PropertyFeeTemplateMessage templateMessage = new PropertyFeeTemplateMessage();
-            templateMessage.setTemplate_id(templateId);
-            templateMessage.setTouser(openId);
-            data.setFirst(new Content(paramIn.getString("staffName") + "杩涜缁翠慨宸ュ崟閫�鍗曟搷浣滐紝璇峰強鏃跺鐞嗭紝淇℃伅濡備笅锛�"));
-            data.setKeyword1(new Content(paramIn.getString("repairTypeName")));
-            if (communityDto.getName().equals(paramIn.getString("repairObjName"))) {
-                data.setKeyword2(new Content(paramIn.getString("repairObjName")));
-            } else {
-                data.setKeyword2(new Content(communityDto.getName() + paramIn.getString("repairObjName")));
-            }
-            data.setKeyword3(new Content(paramIn.getString("context")));
-            data.setRemark(new Content(paramIn.getString("returnContext")));
-            templateMessage.setData(data);
-            String wechatUrl = MappingCache.getValue("OWNER_WECHAT_URL");
-            templateMessage.setUrl(wechatUrl);
-            logger.info("鍙戦�佹ā鏉挎秷鎭唴瀹�:{}", JSON.toJSONString(templateMessage));
-            ResponseEntity<String> responseEntity = outRestTemplate.postForEntity(url, JSON.toJSONString(templateMessage), String.class);
-            logger.info("寰俊妯℃澘杩斿洖鍐呭:{}", responseEntity);
-        }
+        content.put("repairName", paramIn.getString("repairName"));
+        String wechatUrl = MappingCache.getValue(MappingConstant.URL_DOMAIN, "STAFF_WECHAT_URL");
+        content.put("url", wechatUrl);
+
+        MsgNotifyFactory.sendReturnRepairMsg(communityDto.getCommunityId(), paramIn.getString("preStaffId"), content);
+
     }
 
     /**
-     * 缁撳崟缁欑鐞嗗憳鎺ㄩ�佷俊鎭�
+     * 缁撳崟缁欎笟涓绘帹閫佷俊鎭�
      *
      * @param paramIn
      * @param communityDto
      */
-    private void publishReturnMsg(JSONObject paramIn, CommunityDto communityDto) {
+    private void sendFinishRepairOwnerMsg(JSONObject paramIn, CommunityDto communityDto) {
         //鏌ヨ鍏紬鍙烽厤缃�
         SmallWeChatDto smallWeChatDto = new SmallWeChatDto();
         smallWeChatDto.setWeChatType("1100");
@@ -224,53 +253,71 @@
             logger.info("鏈厤缃井淇″叕浼楀彿淇℃伅,瀹氭椂浠诲姟鎵ц缁撴潫");
             return;
         }
-        SmallWeChatDto weChatDto = smallWeChatDtos.get(0);
-        SmallWechatAttrDto smallWechatAttrDto = new SmallWechatAttrDto();
-        smallWechatAttrDto.setCommunityId(communityDto.getCommunityId());
-        smallWechatAttrDto.setWechatId(weChatDto.getWeChatId());
-        smallWechatAttrDto.setSpecCd(SmallWechatAttrDto.SPEC_CD_WECHAT_WORK_ORDER_END_TEMPLATE);
-        List<SmallWechatAttrDto> smallWechatAttrDtos = smallWechatAttrInnerServiceSMOImpl.querySmallWechatAttrs(smallWechatAttrDto);
-        if (smallWechatAttrDtos == null || smallWechatAttrDtos.size() <= 0) {
-            logger.info("鏈厤缃井淇″叕浼楀彿娑堟伅妯℃澘");
+
+        JSONObject content = new JSONObject();
+        content.put("repairObjName", paramIn.getString("repairObjName"));
+        content.put("staffName", paramIn.getString("staffName"));
+        content.put("time", paramIn.getString("time"));
+        String wechatUrl = UrlCache.getOwnerUrl();
+        if (!StringUtil.isEmpty(wechatUrl) && wechatUrl.contains("?")) {
+            wechatUrl += ("&wAppId=" + smallWeChatDtos.get(0).getAppId());
+        } else {
+            wechatUrl += ("?wAppId=" + smallWeChatDtos.get(0).getAppId());
+        }
+        content.put("url", wechatUrl);
+
+        MsgNotifyFactory.sendFinishRepairOwnerMsg(communityDto.getCommunityId(), paramIn.getString("userId"), content);
+
+
+    }
+
+    /**
+     * 缁撳崟鐢熸垚璐圭敤缁欎笟涓绘帹閫佷俊鎭�
+     *
+     * @param paramIn
+     * @param communityDto
+     */
+    private void sendMessage(JSONObject paramIn, CommunityDto communityDto) {
+
+        //鏌ヨ鍏紬鍙烽厤缃�
+        SmallWeChatDto smallWeChatDto = new SmallWeChatDto();
+        smallWeChatDto.setWeChatType("1100");
+        smallWeChatDto.setObjType(SmallWeChatDto.OBJ_TYPE_COMMUNITY);
+        smallWeChatDto.setObjId(communityDto.getCommunityId());
+        List<SmallWeChatDto> smallWeChatDtos = smallWeChatInnerServiceSMOImpl.querySmallWeChats(smallWeChatDto);
+        if (smallWeChatDto == null || smallWeChatDtos.size() <= 0) {
+            logger.info("鏈厤缃井淇″叕浼楀彿淇℃伅,瀹氭椂浠诲姟鎵ц缁撴潫");
             return;
         }
-        String templateId = smallWechatAttrDtos.get(0).getValue();
-        String accessToken = WechatFactory.getAccessToken(weChatDto.getAppId(), weChatDto.getAppSecret());
-        if (StringUtil.isEmpty(accessToken)) {
-            logger.info("鎺ㄩ�佸井淇℃ā鏉�,鑾峰彇accessToken澶辫触:{}", accessToken);
+
+        //鑾峰彇鎴垮眿鎵�灞炰笟涓�
+        OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
+        ownerRoomRelDto.setRoomId(paramIn.getString("roomId"));
+        List<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelInnerServiceSMO.queryOwnerRoomRels(ownerRoomRelDto);
+        Assert.listOnlyOne(ownerRoomRelDtos, "褰撳墠鎴垮眿娌℃湁鎵�灞炰笟涓�");
+        //鑾峰彇涓氫富id
+        String ownerId = ownerRoomRelDtos.get(0).getOwnerId();
+        //鏌ヨ缁戝畾涓氫富
+        OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();
+        ownerAppUserDto.setMemberId(ownerId);
+        ownerAppUserDto.setAppType("WECHAT");
+        List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMO.queryOwnerAppUsers(ownerAppUserDto);
+        if (ownerAppUserDtos == null || ownerAppUserDtos.size() < 1) {
             return;
         }
-        //鑾峰彇鐢ㄦ埛id
-        String preStaffId = paramIn.getString("preStaffId");
-        if (!StringUtil.isEmpty(preStaffId)) {
-            OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();
-            ownerAppUserDto.setUserId(preStaffId);
-            ownerAppUserDto.setAppType("WECHAT");
-            //鏌ヨ缁戝畾涓氫富
-            List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMO.queryOwnerAppUsers(ownerAppUserDto);
-            //鑾峰彇openId
-            String openId = ownerAppUserDtos.get(0).getOpenId();
-            String url = sendMsgUrl + accessToken;
-            Data data = new Data();
-            PropertyFeeTemplateMessage templateMessage = new PropertyFeeTemplateMessage();
-            templateMessage.setTemplate_id(templateId);
-            templateMessage.setTouser(openId);
-            data.setFirst(new Content("灏婃暚鐨�" + paramIn.getString("repairName") + "鍏堢敓/濂冲+锛屾偍鐨勬姤淇棶棰橈紝宸茬粡涓烘偍澶勭悊瀹屾瘯銆�"));
-            if (communityDto.getName().equals(paramIn.getString("repairObjName"))) {
-                data.setKeyword1(new Content(paramIn.getString("repairObjName")));
-            } else {
-                data.setKeyword1(new Content(communityDto.getName() + paramIn.getString("repairObjName")));
-            }
-            data.setKeyword2(new Content(paramIn.getString("context")));
-            data.setKeyword3(new Content(paramIn.getString("staffName")));
-            data.setKeyword4(new Content(paramIn.getString("time")));
-            data.setRemark(new Content("璇风偣鍑绘煡鐪嬭鎯咃紝瀵规垜浠殑宸ヤ綔杩涜璇勪环锛屼互渚挎彁渚涙洿浼樿川鐨勬湇鍔★紝鎰熻阿鎮ㄧ殑閰嶅悎鍜屼娇鐢紝绁濇偍鐢熸椿鎰夊揩锛岄槚瀹舵涔愶紒"));
-            templateMessage.setData(data);
-            String wechatUrl = MappingCache.getValue("OWNER_WECHAT_URL");
-            templateMessage.setUrl(wechatUrl);
-            logger.info("鍙戦�佹ā鏉挎秷鎭唴瀹�:{}", JSON.toJSONString(templateMessage));
-            ResponseEntity<String> responseEntity = outRestTemplate.postForEntity(url, JSON.toJSONString(templateMessage), String.class);
-            logger.info("寰俊妯℃澘杩斿洖鍐呭:{}", responseEntity);
+        JSONObject content = new JSONObject();
+        content.put("feeTypeName", "缁翠慨璐�");
+        content.put("payerObjName", paramIn.getString("roomName"));
+        content.put("billAmountOwed", paramIn.getString("price") + "鍏�");
+        content.put("date", DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B));
+        String wechatUrl = UrlCache.getOwnerUrl();
+        if (!StringUtil.isEmpty(wechatUrl) && wechatUrl.contains("?")) {
+            wechatUrl += ("&wAppId=" + smallWeChatDtos.get(0).getAppId());
+        } else {
+            wechatUrl += ("?wAppId=" + smallWeChatDtos.get(0).getAppId());
         }
+        content.put("url", wechatUrl);
+        MsgNotifyFactory.sendOweFeeMsg(communityDto.getCommunityId(), ownerAppUserDtos.get(0).getUserId(), content);
+
     }
 }

--
Gitblit v1.8.0