大屏接口

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

@@ -14,6 +14,8 @@ 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);
+
     Long selectAllCount();
 
     Long selectDistinctAllCount();

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

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

src/main/resources/mapper/PrivilageCpUserDOMapper.xml

@@ -14,6 +14,11 @@
         </if>
         limit 1
     </select>
+    <select id="selectCpUserCustomerRelationByCpId" resultType="java.lang.String">
+        select customer_user_id as customerUserId
+        from op_cp_user_customer_relation
+        where cp_id = #{cpId}
+    </select>
 
     <select id="selectAllCount" resultType="java.lang.Long">
         select count(id) from op_cp_user_customer_relation