diff --git a/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageGroupConsumer.java b/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageGroupConsumer.java
index 346c7ae..d396c23 100644
--- a/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageGroupConsumer.java
+++ b/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageGroupConsumer.java
@@ -47,16 +47,9 @@ public class CountDTOMessageGroupConsumer implements WorkHandler<CountDTOMessage
         }
         QueryWrapper<PrivilageCpUserDO> qw = new QueryWrapper<>();
         qw.eq("cp_user_id",cpUserId).last("limit 1");
-        PrivilageCpUserDO privilageCpUserDO = privilageCpUserDOMapper.selectOne(qw);
-        if (privilageCpUserDO == null){
-            //企业微信账号不存在，创建一个账号
-            privilageCpUserDO = new PrivilageCpUserDO();
-            privilageCpUserDO.setCpUserId(cpUserId);
-            privilageCpUserDO.setStatus(1);
-            privilageCpUserDOMapper.insert(privilageCpUserDO);
-        }
+        
         //批量添加账号
-        List<String> addedCustomerUserIds = privilageCpUserDOMapper.selectCpUserCustomerRelationByCpId(privilageCpUserDO.getCpUserId());
+        List<String> addedCustomerUserIds = privilageCpUserDOMapper.selectCpUserCustomerRelationByCpId(cpUserId);
         for (String customerStr : customerStrs) {
             if (CollectionUtils.isEmpty(addedCustomerUserIds) || !addedCustomerUserIds.contains(customerStr)){
                 privilageCpUserDOMapper.insertCpUserCustomerRelation(customerStr,cpUserId);