xing/goodsnotices
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix bug

Browse Source
This commit is contained in:
xing 2024-05-26 22:49:03 +08:00
parent 074b630679
commit 535c2bee95
2 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
app/Jobs/notice.php
View File

@ -66,6 +66,7 @@ public function addGoods(): void
$goods = $goodsItems = $noticeIds = []; $goods = $goodsItems = $noticeIds = [];
$this->client = new Client(); $this->client = new Client();
$apiToken = env('API_TOKEN'); $apiToken = env('API_TOKEN');
$now = date('Y-m-d H:i:s');
foreach ($this->data as $item) { foreach ($this->data as $item) {
$product = apiRequest::requests($this->client, $this->goodsUrl, [ $product = apiRequest::requests($this->client, $this->goodsUrl, [
'token' => $apiToken, 'token' => $apiToken,
@ -79,18 +80,22 @@ public function addGoods(): void
$product['itemid'] = $product['itemId']; $product['itemid'] = $product['itemId'];
$good = new Good(); $good = new Good();
$good->fill($product); $good->fill($product);
$goods[] = $good->toArray(); $goodsData = $good->toArray();
$goodsData['created_at'] = $now;
$goods[] = $goodsData;
$goodsItem = new GoodsItem(); $goodsItem = new GoodsItem();
$product['item_id'] = $product['itemid']; $product['item_id'] = $product['itemid'];
$product['specifications'] = json_encode($product['specifications']); $product['specifications'] = json_encode($product['specifications']);
$goodsItem->fill($product); $goodsItem->fill($product);
$goodsItems[] = $goodsItem->toArray(); $itemData = $goodsItem->toArray();
$itemData['created_at'] = $now;
$goodsItems[] = $itemData;
} }
try { try {
DB::transaction(function () use ($goods, $goodsItems, $noticeIds) { DB::transaction(function () use ($goods, $goodsItems, $noticeIds) {
if (!Good::insert($goods) || !GoodsItem::insert($goodsItems) || !\App\Models\Notice::query()->whereIn('notice_id', $noticeIds)->update(['state' => 3])) { if (!Good::insert($goods) || !GoodsItem::insert($goodsItems) || !\App\Models\Notice::query()->whereIn('notice_id', $noticeIds)->update(['state' => 3])) {
throw new Exception('insert failed'); throw new Exception('insert failed');
}; }
}); });
} catch (Throwable $throwable) { } catch (Throwable $throwable) {
\App\Models\Notice::query()->whereIn('notice_id', $noticeIds) \App\Models\Notice::query()->whereIn('notice_id', $noticeIds)

2
database/migrations/2024_05_24_033401_create_notices_table.php
View File

@ -18,7 +18,7 @@ public function up()
$table->integer('notice_id')->unique()->comment('通知id'); $table->integer('notice_id')->unique()->comment('通知id');
$table->integer('notice_type')->comment('通知type'); $table->integer('notice_type')->comment('通知type');
$table->text('raw_content')->comment('原始消息内容'); $table->text('raw_content')->comment('原始消息内容');
$table->string('err_message')->default('')->comment('处理时错误信息'); $table->text('err_message')->comment('处理时错误信息');
$table->tinyInteger('state')->default(1)->comment('消息状态，1待消费，2消费进行中,3处理完成'); $table->tinyInteger('state')->default(1)->comment('消息状态，1待消费，2消费进行中,3处理完成');
$table->timestamps(); $table->timestamps();
}); });