群主群数量

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/chat/impl/GroupChatDataServiceImpl.java

@@ -87,7 +87,7 @@ public class GroupChatDataServiceImpl implements GroupChatDataService {
                     this.getDataFormQw(item.getWxEnterpriseId());
                 } catch (Exception e) {
                     logger.info("统计异常,wxeid={}", item.getWxEnterpriseId());
-                    e.printStackTrace();
+                    logger.info("异常",e);
                 }
             }
         } else {

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/chat/impl/GroupChatPlanServiceImpl.java

@@ -130,7 +130,7 @@ public class GroupChatPlanServiceImpl implements GroupChatPlanService {
                     "com.gic.haoban.manage.api.service.chat.GroupChatPlanApiService", "doPlanTimer");
         } catch (Exception e) {
             logger.error("发送MQ异常");
-            e.printStackTrace();
+            logger.info("异常",e);
         }
     }
 
@@ -141,7 +141,7 @@ public class GroupChatPlanServiceImpl implements GroupChatPlanService {
                     "com.gic.haoban.manage.api.service.chat.GroupChatPlanApiService", "doPlanSendInfoTimer");
         } catch (Exception e) {
             logger.error("发送MQ异常");
-            e.printStackTrace();
+            logger.info("异常",e);
         }
     }
 
@@ -454,7 +454,7 @@ public class GroupChatPlanServiceImpl implements GroupChatPlanService {
             try {
                 this.doPlanSendInfo(ownerLogId);
             } catch (Exception e) {
-                e.printStackTrace();
+                logger.info("异常",e);
             }
         }
     }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/chat/impl/GroupChatServiceImpl.java

@@ -142,8 +142,7 @@ public class GroupChatServiceImpl implements GroupChatService {
             mqClient.sendCommonMessage("haobanChatMQ", params,
                     "com.gic.haoban.manage.api.service.chat.GroupChatApiService", "refreshChatInfoFromMQ");
         } catch (Exception e) {
-            logger.error("发送MQ异常");
-            e.printStackTrace();
+            logger.info("异常",e);
         }
     }
 
@@ -153,8 +152,7 @@ public class GroupChatServiceImpl implements GroupChatService {
             mqClient.sendCommonMessage("haobanChatMQ", params,
                     "com.gic.haoban.manage.api.service.chat.GroupChatApiService", "refreshChatInfoFromMQ");
         } catch (Exception e) {
-            logger.error("发送MQ异常");
-            e.printStackTrace();
+            logger.info("异常",e);
         }
     }
 
@@ -330,11 +328,11 @@ public class GroupChatServiceImpl implements GroupChatService {
                         this.updateGroupChatDetail(qwDTO, groupChatId, true);
                     }
                 } catch (Exception e) {
-                    e.printStackTrace();
+                    logger.info("异常",e);
                 }
             }
         } catch (Exception e) {
-            e.printStackTrace();
+            logger.info("异常",e);
         } finally {
             RedisUtil.delCache(key);
         }
@@ -361,7 +359,7 @@ public class GroupChatServiceImpl implements GroupChatService {
                         WxEnterpriseQwDTO qwDTO = this.wxEnterpriseService.getQwInfo(wxEnterpriseId);
                         this.updateGroupChatDetail(qwDTO, groupChatId, true);
                     } catch (Exception e) {
-                        e.printStackTrace();
+                        logger.info("异常",e);
                     }
                 }
             }
@@ -373,11 +371,11 @@ public class GroupChatServiceImpl implements GroupChatService {
                     String staffId = item.getStaffId();
                     this.updateWxChatIdDk(wxEnterpriseId, staffId);
                 } catch (Exception e) {
-                    e.printStackTrace();
+                    logger.info("异常",e);
                 }
             }
         } catch (Exception e) {
-            e.printStackTrace();
+            logger.info("异常",e);
         } finally {
             RedisUtil.delCache(key);
         }
@@ -450,12 +448,12 @@ public class GroupChatServiceImpl implements GroupChatService {
                     } catch (Exception e) {
                         logger.info("初始化异常,wxEid={}", init.getWxEnterpriseId());
                         this.groupChatInitMapper.update(init.getWxEnterpriseId(), 4);
-                        e.printStackTrace();
+                        logger.info("异常",e);
                     }
                 }
             }
         } catch (Exception e) {
-            e.printStackTrace();
+            logger.info("异常",e);
         } finally {
             RedisUtil.delCache(key);
         }
@@ -481,14 +479,14 @@ public class GroupChatServiceImpl implements GroupChatService {
                 logger.info("群主离职,群状态处理={}", JSON.toJSONString(dto));
                 this.dimissionOwner(dto.getWxEnterpriseId(), dto.getWxUserId(), dto.getWxOpenUserId());
             } catch (Exception e) {
-                e.printStackTrace();
+                logger.info("异常",e);
             }
         }
         try {
             logger.info("转移群的状态");
             this.updateChatStatusTimer();
         } catch (Exception e) {
-            e.printStackTrace();
+            logger.info("异常",e);
         }
     }
 
@@ -616,7 +614,7 @@ public class GroupChatServiceImpl implements GroupChatService {
                 }
                 RedisUtil.unlock(lockKey);
             } catch (Exception e) {
-                e.printStackTrace();
+                logger.info("异常",e);
             }
         }
         if (syncDetailFlag) {
@@ -678,16 +676,17 @@ public class GroupChatServiceImpl implements GroupChatService {
                 chat.setStaffId(staff.getStaffId());
                 // 判断是否更新群主
                 this.saveOwnerHistory(wxEnterpriseId, groupChatId, newStaffId, oldStaffId);
-                chat.setOriginalStaffId(oldStaffId);
-                this.groupChatMapper.update(chat);
-                if (StringUtils.isBlank(chat.getWxChatIdDk())) {
-                    //this.updateWxChatIdDk(wxEnterpriseId, staff.getStaffId());
+                if(null != oldStaffId && oldStaffId.equals(newStaffId)) {
+                    chat.setOriginalStaffId(chat.getOriginalStaffId());
+                }else {
+                    chat.setOriginalStaffId(oldStaffId);
                 }
+                this.groupChatMapper.update(chat);
                 this.saveOwner(wxEnterpriseId, staff.getStaffId());
                 RedisUtil.unlock(lockKey);
             }
         } catch (Exception e) {
-            e.printStackTrace();
+            logger.info("异常",e);
         }
         if (!syncMember) {
             logger.info("不同步群成员");
@@ -781,7 +780,7 @@ public class GroupChatServiceImpl implements GroupChatService {
             this.updateData(groupChatId, totalCount, totalMemberCount, addMemberCount, addCount, quitCount,
                     quitMemberCount);
         } catch (Exception e) {
-            e.printStackTrace();
+            logger.info("异常",e);
         } finally {
             RedisUtil.unlock(lockKeyDetail);
         }
@@ -1186,7 +1185,7 @@ public class GroupChatServiceImpl implements GroupChatService {
                 }
                 this.groupChatHmService.handleChatOff(wxEnterpriseId, groupChatId);
             } catch (Exception e) {
-                e.printStackTrace();
+                logger.info("异常",e);
             }
         }
     }