大屏接口

src/main/java/com/kiisoo/ic/employee/mapper/PrivilageCpUserDOMapper.java

@@ -14,7 +14,7 @@ public interface PrivilageCpUserDOMapper extends BaseMapper<PrivilageCpUserDO> {
 
     CpUserCustomerRelationDO selectCpUserCustomerRelation(@Param("customerUserId")String custeromUserId, @Param("cpUserId")String cpUserId, @Param("cpId")Long cpId);
 
-    List<String> selectCpUserCustomerRelationByCpId(@Param("cpId")Long cpId);
+    List<String> selectCpUserCustomerRelationByCpId(@Param("cpUserId")String cpUserId);
 
     Long selectAllCount();
 

src/main/java/com/kiisoo/ic/job/count/CountDTOMessageGroupConsumer.java

@@ -56,7 +56,7 @@ public class CountDTOMessageGroupConsumer implements WorkHandler<CountDTOMessage
             privilageCpUserDOMapper.insert(privilageCpUserDO);
         }
         //批量添加账号
-        List<String> addedCustomerUserIds = privilageCpUserDOMapper.selectCpUserCustomerRelationByCpId(privilageCpUserDO.getId());
+        List<String> addedCustomerUserIds = privilageCpUserDOMapper.selectCpUserCustomerRelationByCpId(privilageCpUserDO.getCpUserId());
         for (String customerStr : customerStrs) {
             if (CollectionUtils.isEmpty(addedCustomerUserIds) || !addedCustomerUserIds.contains(customerStr)){
                 privilageCpUserDOMapper.insertCpUserCustomerRelation(customerStr,cpUserId,privilageCpUserDO.getId());

src/main/resources/mapper/PrivilageCpUserDOMapper.xml

@@ -17,7 +17,7 @@
     <select id="selectCpUserCustomerRelationByCpId" resultType="java.lang.String">
         select customer_user_id as customerUserId
         from op_cp_user_customer_relation
-        where cp_id = #{cpId}
+        where cp_user_id = #{cpUserId}
     </select>
 
     <select id="selectAllCount" resultType="java.lang.Long">