From c477fd85e3caff3aab128790f21e556dd924db3c Mon Sep 17 00:00:00 2001 From: LegnaYet <1023868505@qq.com> Date: Thu, 21 May 2020 15:20:43 +0800 Subject: [PATCH] =?UTF-8?q?=E9=97=A8=E5=BA=97=E5=8F=B7=E7=AE=A1=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ic/job/count/CountDTOMessageGroupConsumer.java | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) 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 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(privilageCpUserDO.getCpUserId()); + List addedCustomerUserIds = privilageCpUserDOMapper.selectCpUserCustomerRelationByCpId(cpUserId); for (String customerStr : customerStrs) { if (CollectionUtils.isEmpty(addedCustomerUserIds) || !addedCustomerUserIds.contains(customerStr)){ privilageCpUserDOMapper.insertCpUserCustomerRelation(customerStr,cpUserId);