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 d396c23..b1c0ed8 100644 --- a/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageGroupConsumer.java +++ b/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageGroupConsumer.java @@ -47,6 +47,13 @@ public class CountDTOMessageGroupConsumer implements WorkHandler 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 addedCustomerUserIds = privilageCpUserDOMapper.selectCpUserCustomerRelationByCpId(cpUserId);