Skip to content

G
goods
Commit 898c4e52 authored by jianghaiming's avatar jianghaiming
Browse files
Options

update:修改批量退款退库存

parent 5d6b8571
Hide whitespace changes
Inline Side-by-side
Showing with 50 additions and 40 deletions
application/exception/custom/GoodsException.php
View file @ 898c4e52
...@@ -19,6 +19,7 @@ class GoodsException extends BaseException ...@@ -19,6 +19,7 @@ class GoodsException extends BaseException
const LABEL_PRINTER_ALREADY_EXIST = 53; const LABEL_PRINTER_ALREADY_EXIST = 53;
const PRINTER_BIND_ERROR = 54; const PRINTER_BIND_ERROR = 54;
const PRINTER_SN_ERROR = 55; const PRINTER_SN_ERROR = 55;
const PARAMS_NULL_ERROR = 56;
protected $cus = [ protected $cus = [
0 => '商品创建失败，请稍后重试', 0 => '商品创建失败，请稍后重试',
...@@ -77,5 +78,6 @@ class GoodsException extends BaseException ...@@ -77,5 +78,6 @@ class GoodsException extends BaseException
self::LABEL_PRINTER_ALREADY_EXIST => '标签打印机已被%s绑定', self::LABEL_PRINTER_ALREADY_EXIST => '标签打印机已被%s绑定',
self::PRINTER_BIND_ERROR => '打印机绑定失败：%s', self::PRINTER_BIND_ERROR => '打印机绑定失败：%s',
self::PRINTER_SN_ERROR => '打印机sn号码有误', self::PRINTER_SN_ERROR => '打印机sn号码有误',
self:: PARAMS_NULL_ERROR => '参数不能为空',
]; ];
} }
\ No newline at end of file
application/modules/Goods/controllers/Goods.php
View file @ 898c4e52
...@@ -314,7 +314,7 @@ class GoodsController extends Base ...@@ -314,7 +314,7 @@ class GoodsController extends Base
*/ */
public function refundAction() public function refundAction()
{ {
(new RefundGoodsValidate())->validate(); //(new RefundGoodsValidate())->validate();
$params = $this->params; $params = $this->params;
$res = GoodsService::refundGoods($params); $res = GoodsService::refundGoods($params);
$this->success(["result" => $res]); $this->success(["result" => $res]);
......
application/services/goods/GoodsService.php
View file @ 898c4e52
...@@ -1936,18 +1936,26 @@ class GoodsService ...@@ -1936,18 +1936,26 @@ class GoodsService
* @return bool * @return bool
* @throws GoodsException * @throws GoodsException
*/ */
public static function refundGoods($params) public static function refundGoods($dataJson)
{ {
$goodsSukParams = GoodsSkuId::getGoodsSkuIdParams($params["goods_sku_id"]); if (empty($dataJson)){
if (!empty($goodsSukParams)) { throw new GoodsException(["cus" => GoodsException::PARAMS_NULL_ERROR]);
if (isset($goodsSukParams["table_tag"]) && ($goodsSukParams["table_tag"] == GoodsSkuId::TABLE_TAG_PINDAN }
|| $goodsSukParams["category_1_id"] == "00")) { foreach ($dataJson as $params){
return MarketingPindanGoodsService::refundGoods($params); $goodsSukParams = GoodsSkuId::getGoodsSkuIdParams($params["goods_sku_id"]);
if (!empty($goodsSukParams)) {
if (isset($goodsSukParams["table_tag"]) && ($goodsSukParams["table_tag"] == GoodsSkuId::TABLE_TAG_PINDAN
|| $goodsSukParams["category_1_id"] == "00")) {
$refundGoodsData[] = $params;
}
} else {
throw new GoodsException(["cus" => 41]);
} }
} else {
throw new GoodsException(["cus" => 41]);
} }
return true; if (empty($refundGoodsData)){
return true;
}
return MarketingPindanGoodsService::refundGoods($refundGoodsData);
} }
/** /**
......
application/services/goods/MarketingPindanGoodsService.php
View file @ 898c4e52
...@@ -471,55 +471,55 @@ class MarketingPindanGoodsService ...@@ -471,55 +471,55 @@ class MarketingPindanGoodsService
} }
/** /**
* 退款拼单商品，库存调整 * 退款拼单商品，库存调整 （批量退库存）
* @param $params * @param $params
* @return bool * @return bool
* @throws GoodsException * @throws GoodsException
*/ */
public static function refundGoods($params) public static function refundGoods($dataJson)
{ {
$sku = PindanGoodsSku::get("*", ["goods_sku_id" => $params["goods_sku_id"]]); if (empty($dataJson)){
if (empty($sku)) { throw new GoodsException(["cus" => GoodsException::PARAMS_NULL_ERROR]);
throw new GoodsException(["cus" => 15]);
} }
PindanGoodsSku::beginTransaction(); PindanGoodsSku::beginTransaction();
foreach ($dataJson as $params){
$records = GoodsRefundRecord::getRecordMaster([ $sku = PindanGoodsSku::get("*", ["goods_sku_id" => $params["goods_sku_id"]]);
"goods_sku_id" => $params["goods_sku_id"], if (empty($sku)) {
"order_item_id" => $params["order_item_id"], throw new GoodsException(["cus" => 15]);
"operator_result" => GoodsRefundRecord::OPERATOR_RESULT_SUCCESS }
]); $records = GoodsRefundRecord::getRecordMaster([
if (empty($records)) {
GoodsRefundRecord::save([
"goods_sku_id" => $params["goods_sku_id"], "goods_sku_id" => $params["goods_sku_id"],
"order_id" => $params["order_id"],
"order_item_id" => $params["order_item_id"], "order_item_id" => $params["order_item_id"],
"num" => $params["num"],
"operator_result" => GoodsRefundRecord::OPERATOR_RESULT_SUCCESS "operator_result" => GoodsRefundRecord::OPERATOR_RESULT_SUCCESS
]); ]);
if (empty($records)) {
$row = PindanGoodsSku::save([
"total_amount_sold[-]" => $params["num"],
"total_amount_order[-]" => $params["num"],
"inventory_rest[+]" => $params["num"],
], ["goods_sku_id" => $sku["goods_sku_id"], "total_amount_sold[>=]" => $params["num"], "total_amount_order[>=]" => $params["num"]]);
FileLog::info('goods_refund_log', 'json decode error raw:' . json_encode($params));
if ($row < 1){
PindanGoodsSku::rollback();
GoodsRefundRecord::save([ GoodsRefundRecord::save([
"goods_sku_id" => $params["goods_sku_id"], "goods_sku_id" => $params["goods_sku_id"],
"order_id" => $params["order_id"], "order_id" => $params["order_id"],
"order_item_id" => $params["order_item_id"], "order_item_id" => $params["order_item_id"],
"num" => $params["num"], "num" => $params["num"],
"operator_result" => GoodsRefundRecord::OPERATOR_RESULT_FAILURE "operator_result" => GoodsRefundRecord::OPERATOR_RESULT_SUCCESS
]); ]);
throw new GoodsException(["cus" => 0]);
$row = PindanGoodsSku::save([
"total_amount_sold[-]" => $params["num"],
"total_amount_order[-]" => $params["num"],
"inventory_rest[+]" => $params["num"],
], ["goods_sku_id" => $sku["goods_sku_id"], "total_amount_sold[>=]" => $params["num"], "total_amount_order[>=]" => $params["num"]]);
FileLog::info('goods_refund_log', 'json decode error raw:' . json_encode($params));
if ($row < 1){
PindanGoodsSku::rollback();
GoodsRefundRecord::save([
"goods_sku_id" => $params["goods_sku_id"],
"order_id" => $params["order_id"],
"order_item_id" => $params["order_item_id"],
"num" => $params["num"],
"operator_result" => GoodsRefundRecord::OPERATOR_RESULT_FAILURE
]);
throw new GoodsException(["cus" => 0]);
}
} }
} }
if (!PindanGoodsSku::commit()) { if (!PindanGoodsSku::commit()) {
PindanGoodsSku::rollback(); PindanGoodsSku::rollback();
throw new GoodsException(["cus" => 0]); throw new GoodsException(["cus" => 0]);
......
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