|
|
@@ -41,34 +41,9 @@ class handleYzOrderData extends Command
|
|
|
Db::startTrans();
|
|
|
try {
|
|
|
|
|
|
-// //判断价格是否符合系统售价
|
|
|
-// $platform_yz_info = Db::name('platform_youzan')
|
|
|
-// ->field('id,sale_price,platform_id')
|
|
|
-// ->where(['skuCode' => $c_data['skuCode'], 'is_del' => 0])
|
|
|
-// ->findOrEmpty();
|
|
|
-
|
|
|
-// if ($c_data['discount_price'] < $platform_yz_info['sale_price'] && $c_data['is_approved'] == '0') {
|
|
|
-// Db::rollback();
|
|
|
-// $this->callbackYz(['status' => 2, 'id' => $c_data['id'], 'reason' => '价格低于系统售价' . $platform_yz_info['sale_price']]);
|
|
|
-// Cache::store('redis')->set("YzTimeLimit",0);
|
|
|
-// return false;//停止执行后续代码
|
|
|
-// }
|
|
|
|
|
|
$standing_book_data = [];
|
|
|
|
|
|
-// //先找用户确认信息
|
|
|
-// $extend_data = Db::name('order_import_from_c_extend')
|
|
|
-// ->where(['order_import_from_c_id' => $c_data['id'], 'is_del' => 0, 'type' => 2])
|
|
|
-// ->find();
|
|
|
-// if (empty($extend_data)) {
|
|
|
-// $extend_data = Db::name('order_import_from_c_extend')
|
|
|
-// ->where(['order_import_from_c_id' => $c_data['id'], 'is_del' => 0, 'type' => 1])
|
|
|
-// ->find();
|
|
|
-// }
|
|
|
-//
|
|
|
-// if (empty($extend_data)) throw new Exception('没有对应的解析数据');
|
|
|
-
|
|
|
- //复用sale::create()方法 -- start
|
|
|
|
|
|
$orderCode = makeNo("QR");
|
|
|
|
|
|
@@ -81,7 +56,7 @@ class handleYzOrderData extends Command
|
|
|
->leftJoin('customer_org1 co', 'co.name=p.platform_name AND co.is_del=0')
|
|
|
->leftJoin('good g', 'g.spuCode=py.spuCode AND g.is_del=0')
|
|
|
->where('py.skuCode', $c_data['skuCode'])
|
|
|
- ->where('py.exam_status', 3)//exam_status==3已上线
|
|
|
+ ->where('py.exam_status', 6)//exam_status==3已上线
|
|
|
->find();
|
|
|
|
|
|
if ($ct) {
|
|
|
@@ -94,22 +69,7 @@ class handleYzOrderData extends Command
|
|
|
|
|
|
} else throw new Exception('未找到商品数据');
|
|
|
|
|
|
-
|
|
|
-// $customer_code = $customer_code = Db::name('customer_info')
|
|
|
-// ->where(['itemid' => $ct['id'], 'companyName' => $ct['name'] . '客户', 'is_del' => 0])
|
|
|
-// ->value('companyNo', '');
|
|
|
-//
|
|
|
-// $customer = Db::name("customer_info")
|
|
|
-// ->where(["companyNo" => $customer_code])
|
|
|
-// ->find();
|
|
|
-
|
|
|
-// if ($customer == false) throw new Exception('未找到客户数据');
|
|
|
-
|
|
|
$supplierNo = $ct['companyNo'];
|
|
|
-// $supplier = Db::name("business")
|
|
|
-// ->where(["companyNo" => $supplierNo])
|
|
|
-// ->find();
|
|
|
-// if ($supplier == false) throw new Exception('未找到平台供应商数据');
|
|
|
|
|
|
$goodtype = 1;//1正常商品
|
|
|
|
|
|
@@ -119,15 +79,7 @@ class handleYzOrderData extends Command
|
|
|
$platform_order = $c_data['tid'];
|
|
|
$good_num = $c_data['num'];
|
|
|
$arrtime = $paytime = $c_data['addtime'];
|
|
|
-// $paytime = $c_data['addtime'];
|
|
|
-// $workNo = $extend_data['po_code'];
|
|
|
-// $ct = Db::name('good_platform')
|
|
|
-// ->alias('a')
|
|
|
-// ->join('good b', 'b.spuCode=a.spuCode', 'left')
|
|
|
-// ->where(['a.skuCode' => $extend_data['skuCode'], 'a.exam_status' => 6])//exam_status==6已上线
|
|
|
-// ->field("b.*,a.skuCode,a.spuCode,a.platform_code,a.plat_code")
|
|
|
-// ->find();
|
|
|
-// if ($ct == false) throw new Exception('未找到商品数据');
|
|
|
+
|
|
|
|
|
|
$goodinfo = $ct;
|
|
|
$is_stock = $ct['is_stock'];
|
|
|
@@ -135,26 +87,9 @@ class handleYzOrderData extends Command
|
|
|
$order_source = 5;//有赞
|
|
|
$spuCode = $ct['spuCode'];
|
|
|
$skuCode = $ct['skuCode'];
|
|
|
-// $is_activity = empty($extend_data['activity_name']) ? 0 : 1;
|
|
|
+
|
|
|
|
|
|
if ($is_stock == 1) {
|
|
|
-// $stock = Db::name("good_stock")
|
|
|
-// ->alias("a")
|
|
|
-// ->leftJoin("warehouse_info b", "a.wsm_code=b.wsm_code")
|
|
|
-// ->where(["spuCode" => $spuCode, "a.is_del" => 0, "a.status" => 1, 'b.wsm_type' => 5, "b.companyNo" => $supplierNo])
|
|
|
-// ->field("a.id,a.usable_stock,a.wait_out_stock")
|
|
|
-// ->find();
|
|
|
-//
|
|
|
-// if ($stock == false || $stock['usable_stock'] < $good_num) throw new Exception('库存数量不足');
|
|
|
-// $stock_num = Db::name("good_stock")
|
|
|
-// ->alias("a")
|
|
|
-// ->leftJoin("warehouse_info b", "a.wsm_code=b.wsm_code")
|
|
|
-// ->leftJoin("good_stock_info c", "a.id=c.stockid and c.balance_num>0")
|
|
|
-// ->where(["spuCode" => $spuCode, "a.is_del" => 0, "a.status" => 1, "b.wsm_type" => 5, "b.companyNo" => $supplierNo])
|
|
|
-// ->sum('balance_num');
|
|
|
-// if ($stock_num < $good_num) {
|
|
|
-// throw new Exception('bn库存数量不足');
|
|
|
-// }
|
|
|
if($ct['usable_stock'] < $good_num){
|
|
|
throw new Exception('商品库存数量不足');
|
|
|
}
|
|
|
@@ -171,26 +106,6 @@ class handleYzOrderData extends Command
|
|
|
|
|
|
}
|
|
|
|
|
|
-
|
|
|
- //活动相关信息
|
|
|
-// $act = Db::name('activity_info')
|
|
|
-// ->alias('ai')
|
|
|
-// ->field('ai.id,ai.activity_stock,ai.moq_num,ai.activity_stock')
|
|
|
-// ->join('good_activity ga', 'ga.activity_code=ai.activity_code')
|
|
|
-// ->where([
|
|
|
-// 'ai.skuCode' => $skuCode,
|
|
|
-// 'ai.spuCode' => $spuCode,
|
|
|
-// 'ai.is_del' => 0,
|
|
|
-// 'ai.status' => 1,
|
|
|
-// 'ga.status' => 6,
|
|
|
-// 'ga.is_del' => 0,
|
|
|
-// 'ga.platform_code' => $platform_id,
|
|
|
-// 'ga.is_stock' => $is_stock
|
|
|
-// ])
|
|
|
-// ->where(function ($query) {
|
|
|
-// return $query->where('ga.start', '<=', date('Y-m-d H:i:s'))->where('ga.end', '>=', date('Y-m-d H:i:s'));
|
|
|
-// })
|
|
|
-// ->find();
|
|
|
$is_activity = 0;
|
|
|
$sale_price = $c_data['discount_price'];
|
|
|
if (isset($c_data['coupon']) && is_discount($c_data['coupon'])) {
|
|
|
@@ -205,8 +120,6 @@ class handleYzOrderData extends Command
|
|
|
if (!empty($act)) {
|
|
|
$is_activity = 1;
|
|
|
$sale_price = $act['final_price'];//取活动的相关价格
|
|
|
-// if ($act['moq_num'] > $good_num) throw new Exception('商品不满足活动价起订量' . $act['moq_num']);
|
|
|
-// if ($act['activity_stock'] < $good_num) throw new Exception('商品活动库存剩余' . $act['activity_stock']);
|
|
|
}else{
|
|
|
|
|
|
if ($sale_price < $ct['sale_price'] && $c_data['is_approved'] == '0') {
|
|
|
@@ -218,51 +131,6 @@ class handleYzOrderData extends Command
|
|
|
|
|
|
}
|
|
|
|
|
|
-// $is_activity = (int)(!empty($act));
|
|
|
-
|
|
|
-// if ($is_activity == 1) {
|
|
|
-// $act = Db::name("activity_info")
|
|
|
-// ->alias("a")
|
|
|
-// ->leftJoin("good_activity b", "a.activity_code=b.activity_code")
|
|
|
-// ->where(["a.skuCode" => $skuCode, "a.activity_code" => $extend_data['activity_code'], "a.is_del" => 0, "a.status" => 1, "b.status" => 6, "b.is_del" => 0])
|
|
|
-// ->find();
|
|
|
-// if ($act == false) throw new Exception('未找到相关活动价');
|
|
|
-// if ($act['moq_num'] > $good_num) throw new Exception('商品不满足活动价起订量' . $act['moq_num']);
|
|
|
-// if ($act['activity_stock'] < $good_num) throw new Exception('商品活动库存剩余' . $act['activity_stock']);
|
|
|
- //$sale_price = $act['activity_price'];//不能改动价格
|
|
|
-// }
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-// if ($goodtype == 1) {
|
|
|
-// $good = Db::name("good_ladder")
|
|
|
-// ->where(["skuCode" => $skuCode, "is_del" => 0, "status" => 1])
|
|
|
-// ->where([["min_num", "<=", $good_num]])
|
|
|
-// ->order("min_num desc")
|
|
|
-// ->find();
|
|
|
-// if ($good == false) throw new Exception('未找到相关阶梯价格');
|
|
|
-
|
|
|
- //$sale_price = $good['sale_price']; //不改动售价
|
|
|
-
|
|
|
- //理论上不会出现实时金价的订单
|
|
|
-// if ($ct['is_gold_price'] == 1 && $is_stock != 1) {
|
|
|
-// $gold = Db::name("gold_price1")
|
|
|
-// ->field('id,price')
|
|
|
-// ->where(["type" => $ct['noble_metal'], "is_del" => 0, "status" => 1])
|
|
|
-// ->order("addtime desc")
|
|
|
-// ->find();
|
|
|
-//
|
|
|
-// //$saleprice(最终售价) = （打样费/购买数量 + 开模费/购买数量 + 商品重量* 最新金价 + 工艺费* 商品重量+包装费+加标费+证书费+产品裸价+物流费）/(1-成本售价/100);
|
|
|
-// $gold_sale_price = $ct['demo_fee'] / $good_num + $ct['open_fee'] / $good_num + $ct['noble_weight'] * $gold["price"] + $good['cost_fee'] * $ct['noble_weight'] + $origin['package_fee'] + $origin['mark_fee'] + $origin['cert_fee'] + $origin['nake_fee'] + $origin['delivery_fee'];
|
|
|
-// if ($sale_price < $gold_sale_price) throw new Exception('价格不符合根据实时金价计算出的最终售价');
|
|
|
-//
|
|
|
-// $ct['cgd_gold_price'] = $gold['price'];
|
|
|
-//
|
|
|
-// }
|
|
|
-
|
|
|
-
|
|
|
-// }
|
|
|
|
|
|
|
|
|
$remark = $c_data['buyer_messages'];
|
|
|
@@ -398,47 +266,7 @@ class handleYzOrderData extends Command
|
|
|
if ($bol == false) throw new Exception('订单创建失败');
|
|
|
|
|
|
} else {
|
|
|
- //库存品
|
|
|
-// $cgd = [
|
|
|
-// 'orderCode' => $orderCode,
|
|
|
-// "good_num" => $good_num,
|
|
|
-// "spuCode" => $spuCode,
|
|
|
-// "companyNo" => $supplierNo,
|
|
|
-// 'order_type' => $order_type,
|
|
|
-// 'order_source' => $order_source,
|
|
|
-// 'good_createrid' => $goodinfo['createrid'],
|
|
|
-// 'good_creater' => $goodinfo['creater'],//商品创建人
|
|
|
-// ];
|
|
|
-// $bol = $this->RelaCgd($cgd, $standing_book_data);
|
|
|
-// if ($bol == false) throw new Exception('库存商品关联采购单失败');
|
|
|
-
|
|
|
-// if (isset($stock)) {
|
|
|
-// $stck = [
|
|
|
-// "usable_stock" => $stock['usable_stock'] - $good_num,
|
|
|
-// "wait_out_stock" => $stock['wait_out_stock'] + $good_num,
|
|
|
-// "updatetime" => date("Y-m-d H:i:s")
|
|
|
-// ];
|
|
|
-// $upad = Db::name("good_stock")
|
|
|
-// ->where($stock)
|
|
|
-// ->update($stck);
|
|
|
-// if ($upad == false) throw new Exception('库存商品更新库存失败');
|
|
|
-// $stockinfo =GoodStockInfo::OrderBn($orderCode,$stock['id'],$good_num);
|
|
|
-// if($stockinfo==false){
|
|
|
-// Db::rollback();
|
|
|
-// return error_show(1002, "Bn库存更新库存失败");
|
|
|
-// }
|
|
|
-// //商品变动日志表，good_log_code字段存储采购单号
|
|
|
-// $good_data[] = ['good_log_code' => $orderCode, "stock_id" => $datainfo, "type" => 2, 'stock' => $good_num, "stock_name" => "usable_stock"];
|
|
|
-// $good_data[] = ['good_log_code' => $orderCode, "stock_id" => $datainfo, "type" => 1, 'stock' => $good_num, "stock_name" => "wait_out_stock"];
|
|
|
-// GoodLog::LogAdd(['id' => $rm, 'nickname' => $ri], $good_data, "XSQRD");
|
|
|
-// }
|
|
|
-// $stockid = Db::name("good_stock")->alias("a")
|
|
|
-// ->leftJoin("warehouse_info b", "a.wsm_code=b.wsm_code")
|
|
|
-// ->where(["spuCode" => $spuCode, "a.is_del" => 0, "a.status" => 1, "b.wsm_type" => 5, "b.companyNo" => $supplierNo])
|
|
|
-// ->column('a.id');
|
|
|
-// $stockinfo = GoodStockInfo::OrderBn($orderCode, $stockid, intval($good_num));
|
|
|
-// if ($stockinfo == false) throw new Exception('库存商品更新库存失败');
|
|
|
- //库存品
|
|
|
+
|
|
|
$stockUp =[
|
|
|
"usable_stock"=>$ct['usable_stock']-$good_num,
|
|
|
"updatetime"=>date("Y-m-d H:i:s"),
|
|
|
@@ -522,6 +350,7 @@ class handleYzOrderData extends Command
|
|
|
"wsm_code" => $is_stock==1? '':$cgdinfo['wsm_code'],
|
|
|
"order_type" => $order_type,
|
|
|
"status" => $is_stock == 1 ? 1 : 0,
|
|
|
+ "send_status" => $is_stock == 1 ? 1 : 0,
|
|
|
"addtime" => date("Y-m-d H:i:s"),
|
|
|
"updatetime" => date("Y-m-d H:i:s")
|
|
|
];
|
