Browse Source

fix(jd): 修复京东API数据同步事务处理问题

- 将数据库异常处理从startTrans改为rollback确保事务正确回滚
- 添加API错误日志记录便于问题排查
- 添加API结果日志记录用于监控数据同步状态
shichen 3 months ago
parent
commit
b3c6d73a6c
1 changed files with 3 additions and 2 deletions
  1. 3 2
      app/controller/api/store/product/Jd.php

+ 3 - 2
app/controller/api/store/product/Jd.php

@@ -557,7 +557,8 @@ class Jd extends BaseController
557
                 } while ($page <= $maxPage);
557
                 } while ($page <= $maxPage);
558
                 Db::commit();
558
                 Db::commit();
559
             } catch (DbException $e) {
559
             } catch (DbException $e) {
560
-                Db::startTrans();
560
+                Db::rollback();
561
+                Log::info("JD API error : " . $e->getMessage());
561
             }
562
             }
562
         }
563
         }
563
 
564
 
@@ -576,7 +577,7 @@ class Jd extends BaseController
576
         ];
577
         ];
577
         $result = $this->getUrlResult($apiName, $params);
578
         $result = $this->getUrlResult($apiName, $params);
578
         $result = json_decode($result, true);
579
         $result = json_decode($result, true);
579
-
580
+        Log::info("JD API result (eliteId:{$eliteId}, page:{$page}): " . json_encode($result));
580
         $result = json_decode($result['jd_union_open_goods_jingfen_query_responce']['queryResult'], true);
581
         $result = json_decode($result['jd_union_open_goods_jingfen_query_responce']['queryResult'], true);
581
         //        $result = $result['data'] ?? [];
582
         //        $result = $result['data'] ?? [];
582
         return $result;
583
         return $result;