diff --git a/src/main/java/com/kiisoo/ic/employee/mapper/PrivilageCpUserDOMapper.java b/src/main/java/com/kiisoo/ic/employee/mapper/PrivilageCpUserDOMapper.java index 4c5168f..d521160 100644 --- a/src/main/java/com/kiisoo/ic/employee/mapper/PrivilageCpUserDOMapper.java +++ b/src/main/java/com/kiisoo/ic/employee/mapper/PrivilageCpUserDOMapper.java @@ -14,7 +14,7 @@ public interface PrivilageCpUserDOMapper extends BaseMapper { CpUserCustomerRelationDO selectCpUserCustomerRelation(@Param("customerUserId")String custeromUserId, @Param("cpUserId")String cpUserId, @Param("cpId")Long cpId); - List selectCpUserCustomerRelationByCpId(@Param("cpId")Long cpId); + List selectCpUserCustomerRelationByCpId(@Param("cpUserId")String cpUserId); Long selectAllCount(); 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 a882130..9b6bc29 100644 --- a/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageGroupConsumer.java +++ b/src/main/java/com/kiisoo/ic/job/count/CountDTOMessageGroupConsumer.java @@ -56,7 +56,7 @@ public class CountDTOMessageGroupConsumer implements WorkHandler addedCustomerUserIds = privilageCpUserDOMapper.selectCpUserCustomerRelationByCpId(privilageCpUserDO.getId()); + List addedCustomerUserIds = privilageCpUserDOMapper.selectCpUserCustomerRelationByCpId(privilageCpUserDO.getCpUserId()); for (String customerStr : customerStrs) { if (CollectionUtils.isEmpty(addedCustomerUserIds) || !addedCustomerUserIds.contains(customerStr)){ privilageCpUserDOMapper.insertCpUserCustomerRelation(customerStr,cpUserId,privilageCpUserDO.getId()); diff --git a/src/main/resources/mapper/PrivilageCpUserDOMapper.xml b/src/main/resources/mapper/PrivilageCpUserDOMapper.xml index 5fed538..0471265 100644 --- a/src/main/resources/mapper/PrivilageCpUserDOMapper.xml +++ b/src/main/resources/mapper/PrivilageCpUserDOMapper.xml @@ -17,7 +17,7 @@