群更新

.gitignore

@@ -61,3 +61,4 @@ target
 /toolset/audit-log/src/main/java/com/yonge/toolset/log/interceptor/AuditLogInterceptor.java
 /log/
 cooleshow-cms/src/main/resources/bootstrap-local.yaml
+/cooleshow-app/src/main/resources/logback-local.xml

cooleshow-app/src/main/java/com/yonge/cooleshow/admin/controller/ImGroupController.java

@@ -1,6 +1,8 @@
 package com.yonge.cooleshow.admin.controller;
 
 
+import com.alibaba.fastjson.JSONObject;
+import com.microsvc.toolkit.common.response.template.R;
 import com.yonge.cooleshow.biz.dal.dto.ImGroupSearchDto;
 import com.yonge.cooleshow.biz.dal.entity.ImGroup;
 import com.yonge.cooleshow.biz.dal.entity.ImHistoryMessage;
@@ -197,6 +199,15 @@ public class ImGroupController extends BaseController {
     }
 
 
+    @ApiOperation("群头像更新")
+    @PostMapping(value = "/groupAvatarUpdate")
+    public R<JSONObject> groupAvatarUpdate() {
+        CompletableFuture.runAsync(() -> {
+            imGroupService.groupAvatarUpdate();
+        });
+        return R.defaultR();
+    }
+
 
 }
 

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/ImGroupService.java

@@ -209,5 +209,7 @@ public interface ImGroupService extends IService<ImGroup> {
     Boolean updateImGroup(ImGroup imGroup);
 
     void clearImportIm(List<ImHistoryMessage> info);
+
+    void groupAvatarUpdate();
 }
 

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/ImGroupServiceImpl.java

@@ -1348,6 +1348,33 @@ public class ImGroupServiceImpl extends ServiceImpl<ImGroupDao, ImGroup> impleme
         }
     }
 
+    @Override
+    public void groupAvatarUpdate() {
+        int page = 1;
+        int size = 100;
+        List<ImGroup> imGroups = this.lambdaQuery().orderByDesc(ImGroup::getCreateTime)
+            .last("limit " + ((page - 1) * size) + "," + size).list();
+        while (!imGroups.isEmpty()) {
+            groupAvatarUpdate(imGroups);
+
+            page++;
+            imGroups = this.lambdaQuery().orderByDesc(ImGroup::getCreateTime)
+                .last("limit " + ((page - 1) * size) + "," + size).list();
+        }
+    }
+
+    private void groupAvatarUpdate(List<ImGroup> records) {
+
+        for (ImGroup imGroup : records) {
+
+            try {
+                imGroupCoreService.modifyGroupInfo(imGroup.getId(), imGroup.getName(), imGroup.getImg());
+            } catch (Exception e) {
+                log.error("群头像更新失败：" + JSON.toJSONString(imGroup), e);
+            }
+        }
+    }
+
 
     private void groupTransfer(List<ImGroup> records) {
         String fansIcon = sysConfigService.findConfigValue(SysConfigConstant.ICON_FANS_GROUP_DEFAULT);