diff --git a/domain/model/cp_m/cp_relation.go b/domain/model/cp_m/cp_relation.go
index 6d38893b7eac795fe216dd107ad15babb62ae47e..8b4319d2626ed06244193038b2a5dd418f8b94e7 100644
--- a/domain/model/cp_m/cp_relation.go
+++ b/domain/model/cp_m/cp_relation.go
@@ -105,7 +105,7 @@ func CreateCp(model *domain.Model, userId1, userId2 uint64) (int64, error) {
 		}
 	}
 
-	result, err := model.DB().Config.ConnPool.ExecContext(model, "insert into cp_relation(user_id1, user_id2, created_time) select ?,?,? where not exists (select user_id1 from cp_relation where user_id1 in (?) or user_id2 in (?));", userId1, userId2, createdTime.Format(utils.DATETIME_FORMAT), userIds, userIds)
+	result, err := model.DB().Config.ConnPool.ExecContext(model, "insert into cp_relation(user_id1, user_id2, created_time) select ?,?,? where not exists (select user_id1 from cp_relation where user_id1 in (?,?) or user_id2 in (?,?));", userId1, userId2, createdTime.Format(utils.DATETIME_FORMAT), userId1, userId2, userId1, userId2)
 	if err != nil {
 		model.Log.Errorf("CreateCp user1:%d, user2:%d, err:%v", userId1, userId2, err)
 		return 0, err