hehele/hyperf_service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat : order list

Browse Source
This commit is contained in:
ctexthuang
2025-04-08 09:24:08 +08:00
parent 5e18a83065
commit 100e44ad02
1 changed files with 36 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
app/Service/Admin/System/DriverService.php
View File

@@ -124,20 +124,27 @@ class DriverService extends BaseService
$list = $this->driverSequenceModel->whereIn('driver_id',$driverArr)->pluck('driver_num','driver_id')->toArray(); $list = $this->driverSequenceModel->whereIn('driver_id',$driverArr)->pluck('driver_num','driver_id')->toArray();
$updateArr = []; // $updateArr = [];
// foreach ($driverArr as $key => $one) {
// $oneSequence = $key + 1;
// $updateArr[] = [
// 'driver_id' => $one,
// 'sequence' => $oneSequence,
// 'driver_num' => $list[$one] ?? 0,
// ];
// }
Db::transaction(function () use ($driverArr,$list) {
foreach ($driverArr as $key => $one) { foreach ($driverArr as $key => $one) {
$oneSequence = $key + 1; $update = $this->driverSequenceModel->where('driver_id', $one)->update([
$updateArr[] = [ 'sequence' => $key + 1,
'driver_id' => $one,
'sequence' => $oneSequence,
'driver_num' => $list[$one] ?? 0, 'driver_num' => $list[$one] ?? 0,
]; ]);
}
if (!empty($updateArr)) { if (!$update) throw new ErrException('设置失败,数据回滚');
Db::table('driver_sequence')->upsert($updateArr,['driver_id']);
} }
});
return $this->return->success(); return $this->return->success();
} }
@@ -197,16 +204,24 @@ class DriverService extends BaseService
if (count($list->toArray()) != count($siteArr)) throw new ErrException('站点数据不对，刷新后重新设置'); if (count($list->toArray()) != count($siteArr)) throw new ErrException('站点数据不对，刷新后重新设置');
$updateArr = []; // $updateArr = [];
foreach ($siteArr as $key => $one) { // foreach ($siteArr as $key => $one) {
$updateArr[] = [ // $updateArr[] = [
'id' => $one, // 'id' => $one,
'sequence' => $key + 1, // 'sequence' => $key + 1,
]; // ];
} // }
$updateHandle = (new Site)->update($updateArr); Db::transaction(function () use ($siteArr) {
if (!$updateHandle) throw new ErrException('设置失败'); foreach ($siteArr as $key => $one) {
$update = $this->siteModel->where('id', $one)->update(['sequence' => $key + 1]);
if (!$update) throw new ErrException('设置失败,数据回滚');
}
});
// $updateHandle = (new Site)->update($updateArr);
// if (!$updateHandle) throw new ErrException('设置失败');
return $this->return->success(); return $this->return->success();
} }