Проблема параллелизма PHP, множественные одновременные запросы; мьютексы?

Итак, я только что понял, что PHP потенциально выполняет несколько запросов одновременно. Журналы прошлой ночи, кажется, показывают, что два запроса поступили, были обработаны параллельно; каждый запускает импорт данных с другого сервера; каждый пытался вставить запись в базу данных. Один запрос не удался, когда он попытался вставить запись, которую только что вставил другой поток (импортированные данные поставляются с PK; я не использую увеличивающиеся идентификаторы): SQLSTATE[23000]: Integrity constraint violation: 1062 Duplicate entry '865020' for key 'PRIMARY' ...,

1. Правильно ли я диагностировал эту проблему?
2. Как мне это решить?

Ниже приведен фрагмент кода. Я удалил большую часть этого (регистрация, создание других сущностей за пределами Пациента из данных), но следующее должно включать соответствующие фрагменты. Запросы попадают в метод import (), который вызывает importOne () для каждой импортируемой записи. Обратите внимание на метод сохранения в importOne (); это метод Eloquent (использующий Laravel и Eloquent), который генерирует SQL для вставки / обновления записи в зависимости от ситуации.

public function import()
{
$now = Carbon::now();
// Get data from the other server in the time range from last import to current import
$calls = $this->getCalls($this->getLastImport(), $now);
// For each call to import, insert it into the DB (or update if it already exists)
foreach ($calls as $call) {
$this->importOne($call);
}
// Update the last import time to now so that the next import uses the correct range
$this->setLastImport($now);
}

private function importOne($call)
{
// Get the existing patient for the call, or create a new one
$patient = Patient::where('id', '=', $call['PatientID'])->first();
$isNewPatient = $patient === null;
if ($isNewPatient) {
$patient = new Patient(array('id' => $call['PatientID']));
}
// Set the fields
$patient->given_name = $call['PatientGivenName'];
$patient->family_name = $call['PatientFamilyName'];
// Save; will insert/update appropriately
$patient->save();
}

Я думаю, что решение потребует мьютекс вокруг всего блока импорта? И если запрос не может получить мьютекс, он просто переходит к остальной части запроса. Мысли?

РЕДАКТИРОВАТЬ: просто чтобы заметить, это не критический сбой. Исключение перехватывается и регистрируется, а затем на запрос реагируется, как обычно. И импорт успешно выполняется по другому запросу, и затем на этот запрос поступают ответы, как обычно. Пользователи не мудры; они даже не знают об импорте, и это не является главной целью поступающего запроса. Так что на самом деле, я мог бы просто оставить все как есть, и кроме случайного исключения, ничего плохого не происходит. Но если есть исправление для предотвращения дополнительной работы / ненужных отправок нескольких запросов на этот другой сервер, это может быть оправдано.

РЕДАКТИРОВАТЬ 2: Хорошо, я принял решение о реализации механизма блокировки с помощью flock (). Мысли? Будет ли следующая работа? И как бы я протестировал это дополнение?

public function import()
{
try {
$fp = fopen('/tmp/lock.txt', 'w+');
if (flock($fp, LOCK_EX)) {
$now = Carbon::now();
$calls = $this->getCalls($this->getLastImport(), $now);
foreach ($calls as $call) {
$this->importOne($call);
}
$this->setLastImport($now);
flock($fp, LOCK_UN);
// Log success.
} else {
// Could not acquire file lock. Log this.
}
fclose($fp);
} catch (Exception $ex) {
// Log failure.
}
}

EDIT3: Мысли о следующей альтернативной реализации блокировки:

public function import()
{
try {
if ($this->lock()) {
$now = Carbon::now();
$calls = $this->getCalls($this->getLastImport(), $now);
foreach ($calls as $call) {
$this->importOne($call);
}
$this->setLastImport($now);
$this->unlock();
// Log success
} else {
// Could not acquire DB lock. Log this.
}
} catch (Exception $ex) {
// Log failure
}
}

/**
* Get a DB lock, returns true if successful.
*
* @return boolean
*/
public function lock()
{
return DB::SELECT("SELECT GET_LOCK('lock_name', 1) AS result")[0]->result === 1;
}

/**
* Release a DB lock, returns true if successful.
*
* @return boolean
*/
public function unlock()
{
return DB::select("SELECT RELEASE_LOCK('lock_name') AS result")[0]->result === 1;
}