Skip to content

G
goods
Commit 588a47cd authored by luhongguang's avatar luhongguang
Browse files
Options

update:tcc 下单 confirm

parent 2edd23df
Hide whitespace changes
Inline Side-by-side
Showing with 95 additions and 50 deletions
application/services/tcc/TccService.php
View file @ 588a47cd
...@@ -61,7 +61,8 @@ class TccService ...@@ -61,7 +61,8 @@ class TccService
return self::TCC_RESULT_FAIL; return self::TCC_RESULT_FAIL;
} }
$skus = GoodsSku::getRecords(["goods_sku_id" => $goodsSkuIds]); $skus = GoodsSku::getRecords(["goods_sku_id" => $goodsSkuIds
, ["goods_sku_id", "inventory_rest", "inventory_lock", "online_status"]]);
if (!empty($skus)) { if (!empty($skus)) {
GoodsSku::beginTransaction(); GoodsSku::beginTransaction();
foreach ($skus as $sku) { foreach ($skus as $sku) {
...@@ -71,9 +72,8 @@ class TccService ...@@ -71,9 +72,8 @@ class TccService
if (empty($numList[$goodsSkuId])) { if (empty($numList[$goodsSkuId])) {
return self::TCC_RESULT_FAIL; return self::TCC_RESULT_FAIL;
} }
$num = $numList[$sku["goods_sku_id"]]; $num = $numList[$goodsSkuId];
GoodsSku::beginTransaction();
GoodsSku::save([ GoodsSku::save([
"inventory_lock" => $sku["inventory_lock"] + $num, "inventory_lock" => $sku["inventory_lock"] + $num,
"inventory_rest" => $sku["inventory_rest"] - $num, "inventory_rest" => $sku["inventory_rest"] - $num,
...@@ -117,74 +117,119 @@ class TccService ...@@ -117,74 +117,119 @@ class TccService
/** /**
* 下单 商品tcc confirm * 下单 商品tcc confirm
* @param $goodsSkuId * @param $keys
* @param $tid * @param $tid
* @return int * @return int
*/ */
public static function placeAnOrderConfirm($goodsSkuId, $tid) public static function placeAnOrderConfirm($keys, $tid)
{ {
$tccInfo = Tcc::getRecordMaster(["t_id" => $tid, "goods_sku_id" => $goodsSkuId, "status" => Tcc::STATUS_CONFIRM]); $goodsInfoList = json_decode($keys, true);
//有结果返回原来的结果，幂等 if (empty($goodsInfoList)) {
if (!empty($tccInfo)) { return self::TCC_RESULT_FAIL;
if ($tccInfo[0]["operator_result"] == Tcc::OPERATOR_RESULT_FAIL) { }
$goodsSkuIds = $numList = [];
foreach ($goodsInfoList as $item) {
if (empty($item["goods_sku_id"]) || empty($item["num"])) {
return self::TCC_RESULT_FAIL; return self::TCC_RESULT_FAIL;
} else {
return self::TCC_RESULT_SUCCESS;
} }
$goodsSkuIds[] = $item["goods_sku_id"];
$numList[$item["goods_sku_id"]] = $item["num"];
}
//有结果返回原来的结果，幂等
$tccInfoList = Tcc::getRecordMaster([
"t_id" => $tid,
"goods_sku_id" => $goodsSkuIds,
"status" => Tcc::STATUS_CONFIRM
]);
if (!empty($tccInfoList)) {
foreach ($tccInfoList as $tccInfo) {
if ($tccInfo["operator_result"] == Tcc::OPERATOR_RESULT_FAIL) {
return self::TCC_RESULT_FAIL;
}
}
return self::TCC_RESULT_SUCCESS;
} }
//在confirm时候必须已经有try，如果没有就直接返回fail //在confirm时候必须已经有try，如果没有就直接返回fail
$tryTccInfo = Tcc::getRecordMaster(["t_id" => $tid, "goods_sku_id" => $goodsSkuId, "status" => Tcc::STATUS_TRY, "operator_result" => Tcc::OPERATOR_RESULT_SUCCESS]); $cTccInfoList = Tcc::getRecordMaster([
if (empty($tryTccInfo)) { "t_id" => $tid,
Tcc::save([ "goods_sku_id" => $goodsSkuIds,
"t_id" => $tid, "status" => Tcc::STATUS_TRY,
"goods_sku_id" => $goodsSkuId, "operator_result" => Tcc::OPERATOR_RESULT_SUCCESS
"status" => Tcc::STATUS_CONFIRM, ]);
"operator_result" => Tcc::OPERATOR_RESULT_FAIL, if (!empty($cTccInfoList)) {
]); foreach ($goodsSkuIds as $goodsSkuId) {
Tcc::save([
"t_id" => $tid,
"goods_sku_id" => $goodsSkuId,
"status" => Tcc::STATUS_TRY,
"operator_result" => Tcc::OPERATOR_RESULT_FAIL,
]);
}
return self::TCC_RESULT_FAIL; return self::TCC_RESULT_FAIL;
} }
//如果已经 cancel 成功, 则失败
//如果已经 cancel 成功 $cTccInfoList = Tcc::getRecordMaster([
$cancelTccInfo = Tcc::getRecordMaster(["t_id" => $tid, "goods_sku_id" => $goodsSkuId, "status" => Tcc::STATUS_CANCEL, "operator_result" => Tcc::OPERATOR_RESULT_SUCCESS]); "t_id" => $tid,
if (!empty($cancelTccInfo)) { "goods_sku_id" => $goodsSkuIds,
"status" => Tcc::STATUS_CANCEL,
"operator_result" => Tcc::OPERATOR_RESULT_SUCCESS
]);
if (!empty($cTccInfoList)) {
return self::TCC_RESULT_FAIL; return self::TCC_RESULT_FAIL;
} }
$sku = GoodsSku::getRecord(["goods_sku_id" => $goodsSkuId]); $skus = GoodsSku::getRecords(["goods_sku_id" => $goodsSkuIds
if (!empty($sku["inventory_rest"]) && $sku["online_status"] == GoodsSku::ONLINE_STATUS_ONLINE) { , ["goods_sku_id", "total_amount_order", "inventory_lock", "online_status"]]);
if (!empty($skus)) {
GoodsSku::beginTransaction(); GoodsSku::beginTransaction();
GoodsSku::save([ foreach ($skus as $sku) {
"inventory_lock" => $sku["inventory_lock"] - 1, $goodsSkuId = $sku["goods_sku_id"];
"total_amount_order" => $sku["total_amount_order"] + 1,
], ["goods_sku_id" => $goodsSkuId]);
Tcc::save([ if (!empty($sku["inventory_lock"]) && $sku["online_status"] == GoodsSku::ONLINE_STATUS_ONLINE) {
"t_id" => $tid, if (empty($numList[$goodsSkuId])) {
"goods_sku_id" => $goodsSkuId, return self::TCC_RESULT_FAIL;
"status" => Tcc::STATUS_CONFIRM, }
"operator_result" => Tcc::OPERATOR_RESULT_SUCCESS, $num = $numList[$goodsSkuId];
]);
GoodsSku::save([
"inventory_lock" => $sku["inventory_lock"] - $num,
"total_amount_order" => $sku["total_amount_order"] + $num,
], ["goods_sku_id" => $goodsSkuId]);
Tcc::save([
"t_id" => $tid,
"goods_sku_id" => $goodsSkuId,
"status" => Tcc::STATUS_CONFIRM,
"operator_result" => Tcc::OPERATOR_RESULT_SUCCESS,
]);
} else {
GoodsSku::rollback();
Tcc::save([
"t_id" => $tid,
"goods_sku_id" => $goodsSkuId,
"status" => Tcc::STATUS_CONFIRM,
"operator_result" => Tcc::OPERATOR_RESULT_FAIL,
]);
return self::TCC_RESULT_FAIL;
}
}
if (!GoodsSku::commit()) { if (!GoodsSku::commit()) {
GoodsSku::rollback(); GoodsSku::rollback();
Tcc::save([ foreach ($skus as $sku) {
"t_id" => $tid, Tcc::save([
"goods_sku_id" => $goodsSkuId, "t_id" => $tid,
"status" => Tcc::STATUS_CONFIRM, "goods_sku_id" => $sku["goods_sku_id"],
"operator_result" => Tcc::OPERATOR_RESULT_FAIL, "status" => Tcc::STATUS_CONFIRM,
]); "operator_result" => Tcc::OPERATOR_RESULT_FAIL,
return self::TCC_RESULT_FAIL; ]);
}
} }
} else {
Tcc::save([
"t_id" => $tid,
"goods_sku_id" => $goodsSkuId,
"status" => Tcc::STATUS_CONFIRM,
"operator_result" => Tcc::OPERATOR_RESULT_FAIL,
]);
return self::TCC_RESULT_FAIL;
} }
return self::TCC_RESULT_SUCCESS; return self::TCC_RESULT_SUCCESS;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment