update:tcc 下单 cancel

application/services/tcc/TccService.php

@@ -159,12 +159,12 @@ class TccService
             "status" => Tcc::STATUS_TRY,
             "operator_result" => Tcc::OPERATOR_RESULT_SUCCESS
         ]);
-        if (!empty($cTccInfoList)) {
+        if (empty($cTccInfoList)) {
             foreach ($goodsSkuIds as $goodsSkuId) {
                 Tcc::save([
                     "t_id" => $tid,
                     "goods_sku_id" => $goodsSkuId,
-                    "status" => Tcc::STATUS_TRY,
+                    "status" => Tcc::STATUS_CONFIRM,
                     "operator_result" => Tcc::OPERATOR_RESULT_FAIL,
                 ]);
             }
@@ -237,46 +237,86 @@ class TccService
 
     /**
      * 下单 商品tcc cancel
-     * @param $goodsSkuId
+     * @param $keys
      * @param $tid
      * @return int
      */
-    public static function placeAnOrderCancel($goodsSkuId, $tid)
+    public static function placeAnOrderCancel($keys, $tid)
     {
-        $tccInfo = Tcc::getRecordMaster(["t_id" => $tid, "goods_sku_id" => $goodsSkuId, "status" => Tcc::STATUS_CANCEL]);
+        $goodsInfoList = json_decode($keys, true);
+        if (empty($goodsInfoList)) {
+            return self::TCC_RESULT_FAIL;
+        }
+
+        $goodsSkuIds = $numList = [];
+        foreach ($goodsInfoList as $item) {
+            if (empty($item["goods_sku_id"]) || empty($item["num"])) {
+                return self::TCC_RESULT_FAIL;
+            }
+            $goodsSkuIds[] = $item["goods_sku_id"];
+            $numList[$item["goods_sku_id"]] = $item["num"];
+        }
+
         //有结果返回原来的结果，幂等
-        if (!empty($tccInfo)) {
-            if ($tccInfo[0]["operator_result"] == Tcc::OPERATOR_RESULT_FAIL) {
+        $tccInfoList = Tcc::getRecordMaster([
+            "t_id" => $tid,
+            "goods_sku_id" => $goodsSkuIds,
+            "status" => Tcc::STATUS_CANCEL
+        ]);
+        if (!empty($tccInfoList)) {
+            foreach ($tccInfoList as $tccInfo) {
+                if ($tccInfo["operator_result"] == Tcc::OPERATOR_RESULT_FAIL) {
                     return self::TCC_RESULT_FAIL;
-            } else {
-                return self::TCC_RESULT_SUCCESS;
                 }
             }
+            return self::TCC_RESULT_SUCCESS;
+        }
 
         //在cancel时候必须已经有try，如果没有就直接返回fail
-        $tryTccInfo = Tcc::getRecordMaster(["t_id" => $tid, "goods_sku_id" => $goodsSkuId, "status" => Tcc::STATUS_TRY, "operator_result" => Tcc::OPERATOR_RESULT_SUCCESS]);
-        if (empty($tryTccInfo)) {
+        $cTccInfoList = Tcc::getRecordMaster([
+            "t_id" => $tid,
+            "goods_sku_id" => $goodsSkuIds,
+            "status" => Tcc::STATUS_TRY,
+            "operator_result" => Tcc::OPERATOR_RESULT_SUCCESS
+        ]);
+        if (empty($cTccInfoList)) {
+            foreach ($goodsSkuIds as $goodsSkuId) {
                 Tcc::save([
                     "t_id" => $tid,
                     "goods_sku_id" => $goodsSkuId,
                     "status" => Tcc::STATUS_CANCEL,
                     "operator_result" => Tcc::OPERATOR_RESULT_FAIL,
                 ]);
+            }
+            return self::TCC_RESULT_FAIL;
+        }
+        //如果已经 confirm 成功, 则失败
+        $cTccInfoList = Tcc::getRecordMaster([
+            "t_id" => $tid,
+            "goods_sku_id" => $goodsSkuIds,
+            "status" => Tcc::STATUS_CONFIRM,
+            "operator_result" => Tcc::OPERATOR_RESULT_SUCCESS
+        ]);
+        if (!empty($cTccInfoList)) {
             return self::TCC_RESULT_FAIL;
         }
 
-        //如果已经 confirm 成功
-        $confirmTccInfo = Tcc::getRecordMaster(["t_id" => $tid, "goods_sku_id" => $goodsSkuId, "status" => Tcc::STATUS_CONFIRM, "operator_result" => Tcc::OPERATOR_RESULT_SUCCESS]);
-        if (!empty($confirmTccInfo)) {
+        $skus = GoodsSku::getRecords(["goods_sku_id" => $goodsSkuIds
+            , ["goods_sku_id", "inventory_rest", "inventory_lock", "online_status"]]);
+        if (!empty($skus)) {
+            GoodsSku::beginTransaction();
+            foreach ($skus as $sku) {
+                $goodsSkuId = $sku["goods_sku_id"];
+
+                if (!empty($sku["inventory_lock"]) && $sku["online_status"] == GoodsSku::ONLINE_STATUS_ONLINE) {
+                    if (empty($numList[$goodsSkuId])) {
                         return self::TCC_RESULT_FAIL;
                     }
+                    $num = $numList[$goodsSkuId];
 
-        $sku = GoodsSku::getRecord(["goods_sku_id" => $goodsSkuId]);
-        if (!empty($sku["inventory_rest"]) && $sku["online_status"] == GoodsSku::ONLINE_STATUS_ONLINE) {
-            GoodsSku::beginTransaction();
                     GoodsSku::save([
-                "inventory_lock" => $sku["inventory_lock"] - 1,
-                "inventory_rest" => $sku["inventory_rest"] + 1,
+                        "inventory_lock" => $sku["inventory_lock"] - $num,
+                        "inventory_rest" => $sku["inventory_rest"] + $num,
                     ], ["goods_sku_id" => $goodsSkuId]);
 
                     Tcc::save([
@@ -285,8 +325,7 @@ class TccService
                         "status" => Tcc::STATUS_CANCEL,
                         "operator_result" => Tcc::OPERATOR_RESULT_SUCCESS,
                     ]);
-
-            if (!GoodsSku::commit()) {
+                } else {
                     GoodsSku::rollback();
 
                     Tcc::save([
@@ -297,14 +336,20 @@ class TccService
                     ]);
                     return self::TCC_RESULT_FAIL;
                 }
-        } else {
+            }
+
+            if (!GoodsSku::commit()) {
+                GoodsSku::rollback();
+
+                foreach ($skus as $sku) {
                     Tcc::save([
                         "t_id" => $tid,
-                "goods_sku_id" => $goodsSkuId,
+                        "goods_sku_id" => $sku["goods_sku_id"],
                         "status" => Tcc::STATUS_CANCEL,
                         "operator_result" => Tcc::OPERATOR_RESULT_FAIL,
                     ]);
-            return self::TCC_RESULT_FAIL;
+                }
+            }
         }
 
         return self::TCC_RESULT_SUCCESS;