|
|
|
@ -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);
|
|
|
|
|