cp

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