301 lines
11 KiB
PHP
301 lines
11 KiB
PHP
<?php
|
|
|
|
namespace app\admin\logic\operation;
|
|
|
|
use app\common\enum\OrderEnum;
|
|
use app\common\model\operation\Opurchaseclass;
|
|
use app\common\logic\BaseLogic;
|
|
use app\common\model\financial\FinancialRecord;
|
|
use app\common\model\goods\Goods;
|
|
use app\common\model\merchant\Merchant;
|
|
use app\common\model\opurchase\OpurchaseGoodsOffer;
|
|
use app\common\model\opurchase\Opurchaseinfo;
|
|
use app\common\model\order\Cart;
|
|
use app\common\model\retail\Cashierclass;
|
|
use app\common\model\supplier\Supplier;
|
|
use app\common\model\supplier\SupplierBindGoods;
|
|
use support\Log;
|
|
use think\facade\Db;
|
|
use app\common\service\JgPushService;
|
|
use app\Request;
|
|
|
|
/**
|
|
* 采购订单逻辑
|
|
* Class OpurchaseclassLogic
|
|
* @package app\admin\logic\operation
|
|
*/
|
|
class OpurchaseclassLogic extends BaseLogic
|
|
{
|
|
|
|
/**
|
|
* @notes 获取购货订单购物车商品信息
|
|
* @param $params
|
|
* @return array
|
|
*/
|
|
static public function cartIdByPurchaseOrderInfo($params)
|
|
{
|
|
|
|
$where1 = ['paid' => 1, 'is_opurchase' => 0, 'is_mer' => 1];
|
|
$arrs = Opurchaseclass::whereDay('create_time')->where($where1)->column('cart_id,id');
|
|
|
|
$cart_arr = [];
|
|
$order_id = [];
|
|
foreach ($arrs as $k => $v) {
|
|
if (empty($v['cart_id'])) {
|
|
self::setError('没有购物车信息');
|
|
return false;
|
|
}
|
|
$arr = explode(',', $v['cart_id']);
|
|
foreach ($arr as $kk => $vv) {
|
|
$cart_arr[] = $vv;
|
|
}
|
|
$order_id[] = $v['id'];
|
|
}
|
|
$where = ['is_pay' => 1, 'is_fail' => 0];
|
|
$cart_select = Cart::whereIn('cart_id', $cart_arr)->where($where)->field('goods_id as goods,cart_num')->select()->toArray();
|
|
if (empty($cart_select)) {
|
|
self::setError('今日采购订单的购物车没有商品');
|
|
return false;
|
|
}
|
|
/** 计算价格 */
|
|
foreach ($cart_select as $k => $v) {
|
|
$sell = Goods::where(['id' => $v['goods']])->value('sell');
|
|
$cart_select[$k]['total'] = bcmul($v['cart_num'], $sell, 2);
|
|
$cart_select[$k]['price'] = $sell;
|
|
$cart_select[$k]['is_mer'] = 2;
|
|
}
|
|
$order = [
|
|
'time' => time(),
|
|
'number' => getNewOrderId('CG'),
|
|
'total' => array_sum(array_column($cart_select, 'total')),
|
|
'pay_type' => $params['pay_type'] ?? 0,
|
|
'cart_id' => implode(',', $cart_arr),
|
|
'order_arr' => implode(',', $order_id)
|
|
];
|
|
return ['order' => $order, 'cart_list' => $cart_select];
|
|
}
|
|
/**
|
|
* 创建购货订单
|
|
* @return Object|bool
|
|
*/
|
|
static public function createOpurchaseOrder($user = null, $params = [])
|
|
{
|
|
|
|
$orderInfo = self::cartIdByPurchaseOrderInfo($user, $params);
|
|
if (!$orderInfo) {
|
|
return false;
|
|
}
|
|
$_order = $orderInfo['order'];
|
|
|
|
$_order['merchant'] = getenv('OPERATED');
|
|
$_order['money'] = $_order['total'];
|
|
$_order['actual'] = $_order['total'];
|
|
$_order['paid'] = 1;
|
|
$_order['is_mer'] = 2;
|
|
Db::startTrans();
|
|
try {
|
|
$order = Opurchaseclass::create($_order);
|
|
|
|
$goods_list = $orderInfo['cart_list'];
|
|
foreach ($goods_list as $k => $v) {
|
|
$goods_list[$k]['nums'] = $v['cart_num'];
|
|
$goods_list[$k]['pid'] = $order->id;
|
|
}
|
|
(new Opurchaseinfo())->saveAll($goods_list);
|
|
$order_arr = explode(',', $_order['order_arr']);
|
|
Opurchaseclass::where('id', 'in', $order_arr)->update(['is_opurchase' => 1]);
|
|
Db::commit();
|
|
return $order;
|
|
} catch (\Exception $e) {
|
|
Db::rollback();
|
|
self::setError($e->getMessage());
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @notes 获取采购订单详情
|
|
* @param $params
|
|
* @return array
|
|
* @author likeadmin
|
|
* @date 2024/04/27 11:26
|
|
*/
|
|
public static function detail($params): array
|
|
{
|
|
$id = $params['id'];
|
|
$data = Opurchaseclass::findOrEmpty($params['id'])->toArray();
|
|
if ($data) {
|
|
$data['goods_info'] = Opurchaseinfo::where('pid', $params['id'])->limit(25)->select()->each(function ($item) use ($id) {
|
|
$find = Goods::where('id', $item['goods'])->with('unitName')->find();
|
|
if ($find) {
|
|
$item['goods_name'] = $find['name'];
|
|
$item['unit_name'] = $find['unit_name'];
|
|
}
|
|
$where = [
|
|
'goods_id' => $item['goods'],
|
|
'order_id' => $id,
|
|
'is_adopt' => 1
|
|
];
|
|
$item['nums_count'] = OpurchaseGoodsOffer::where($where)->sum('nums');
|
|
});
|
|
$data['merchant_name'] = Merchant::where('mer_id', $data['merchant'])->value('mer_name');
|
|
}
|
|
return $data;
|
|
}
|
|
/**
|
|
* @notes 采购订单子订单详情
|
|
* @param $id
|
|
* @return array
|
|
* @author likeadmin
|
|
* @date 2024/04/27 11:26
|
|
*/
|
|
public static function sub_detail($id, $is_mer, $page_no): array
|
|
{
|
|
if ($is_mer == 1) {
|
|
$order_arr = Opurchaseclass::where('id', $id)->value('order_arr');
|
|
$data = [];
|
|
if ($order_arr) {
|
|
$order_arr = explode(',', $order_arr);
|
|
$order_arr_count = count($order_arr);
|
|
$offset = ($page_no - 1) * $order_arr_count;
|
|
$paged_items = array_slice($order_arr, $offset, $order_arr_count);
|
|
if (!$paged_items) {
|
|
return [];
|
|
}
|
|
$list = Cashierclass::whereIn('id', $order_arr)->select()?->toArray();
|
|
$data['count'] = $order_arr_count;
|
|
$data['lists'] = $list;
|
|
$data['page_no'] = $page_no;
|
|
$data['page_siz'] = 15;
|
|
}
|
|
} else {
|
|
$order_arr = Opurchaseclass::where('id', $id)->where('is_mer', $is_mer)->value('order_arr');
|
|
$data = [];
|
|
if ($order_arr) {
|
|
$order_arr = explode(',', $order_arr);
|
|
$order_arr_count = count($order_arr);
|
|
$offset = ($page_no - 1) * $order_arr_count;
|
|
$paged_items = array_slice($order_arr, $offset, $order_arr_count);
|
|
if (!$paged_items) {
|
|
return [];
|
|
}
|
|
$list = Opurchaseclass::whereIn('id', $order_arr)->select()?->toArray();
|
|
$data['count'] = $order_arr_count;
|
|
$data['lists'] = $list;
|
|
$data['page_no'] = $page_no;
|
|
$data['page_siz'] = 15;
|
|
}
|
|
}
|
|
|
|
return $data;
|
|
}
|
|
/**
|
|
* @notes 推送供应商商品
|
|
* @param $params
|
|
* @return bool
|
|
* @date 2024/04/27 11:26
|
|
*/
|
|
public static function createSupplierGoods($goods)
|
|
{
|
|
try {
|
|
$supplier_arr = SupplierBindGoods::where('goods_id', $goods['goods'])->column('supplier_id');
|
|
if ($supplier_arr) {
|
|
$supplier_arr = array_unique($supplier_arr);
|
|
$time = strtotime(date('Y-m-d', time()));
|
|
foreach ($supplier_arr as $k => $v) {
|
|
$goods_offer[] = [
|
|
'supplier_id' => $v,
|
|
'goods_id' => $goods['goods'],
|
|
'order_id' => $goods['pid'],
|
|
'price' => 0,
|
|
'need_num' => $goods['nums'],
|
|
'create_time' => time()
|
|
];
|
|
$find = Db::name('opurchase_goods_offer_date')->where('supplier_id', $v)->where('create_time', $time)->find();
|
|
if ($find) {
|
|
Db::name('opurchase_goods_offer_date')->where('id', $find['id'])->inc('nums')->update();
|
|
} else {
|
|
$data = ['supplier_id' => $v, 'nums' => 1, 'create_time' => $time];
|
|
Db::name('opurchase_goods_offer_date')->insert($data);
|
|
}
|
|
}
|
|
if (count($goods_offer) >= 1) {
|
|
$res = OpurchaseGoodsOffer::insertAll($goods_offer);
|
|
if ($res) {
|
|
Opurchaseinfo::where('id', $goods['id'])->update(['is_push' => 1]);
|
|
return $goods_offer;
|
|
}
|
|
}
|
|
}
|
|
} catch (\Exception $e) {
|
|
self::setError($e->getMessage());
|
|
Log::error('添加采购订单报价失败:' . $e->getMessage());
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @notes 设置采纳商品
|
|
* @param $params
|
|
* @return bool
|
|
* @date 2024/04/27 11:26
|
|
*/
|
|
public static function goodsOfferUpdate($id, $type = 0, $notes = '', $nums = 0)
|
|
{
|
|
try {
|
|
$find = OpurchaseGoodsOffer::where('id', $id)->find();
|
|
if ($type == 0) {
|
|
if ($find && $find['price'] == 0) {
|
|
self::setError('报价未设置');
|
|
return false;
|
|
}
|
|
$find->is_adopt = 2;
|
|
} else {
|
|
$find->is_storage = 1;
|
|
$find->notes = $notes;
|
|
$find->before_nums = $find->nums;
|
|
$find->nums = $nums;
|
|
$find->storage_admin_id = Request()->adminId;
|
|
$price = 0;
|
|
if ($nums != 0) {
|
|
$price = bcmul($find['price'], $nums, 2);
|
|
Supplier::where('id', $find['supplier_id'])->inc('mer_money', $price)->update();
|
|
}
|
|
$number = Opurchaseclass::where('id', $find['order_id'])->value('number');
|
|
$time = time();
|
|
//供应链获得流水
|
|
$record = [
|
|
'financial_record_sn' => $time,
|
|
'order_id' => $find['order_id'],
|
|
'number_sn' => $number,
|
|
'user_id' => 0,
|
|
'financial_type' => OrderEnum::PLATFORM_ORDER_OBTAINS,
|
|
'financial_pm' => OrderEnum::INCOME,
|
|
'number' => $price,
|
|
'status' => 1,
|
|
'type' => OrderEnum::SUPPLIER,
|
|
'mer_id' => $find['supplier_id'],
|
|
];
|
|
FinancialRecord::create($record);
|
|
}
|
|
$res = $find->save();
|
|
$jg_register_id = Db::name('user_auth_shop')->where('pid', $find['supplier_id'])->where('type', 2)->value('jg_register_id');
|
|
if ($jg_register_id) {
|
|
$jg = (new JgPushService())->sendMsg($jg_register_id, '平台提醒：您的商品已被采纳,请尽快发货', '/pages/quote/list');
|
|
if ($jg !== true) {
|
|
Db::rollback();
|
|
self::setError('设置成功。但极光推送失败:' . $jg);
|
|
return false;
|
|
}
|
|
}
|
|
if ($res) {
|
|
return true;
|
|
}
|
|
return false;
|
|
} catch (\Exception $e) {
|
|
self::setError($e->getMessage());
|
|
return false;
|
|
}
|
|
}
|
|
}
|