hbp/application/admin/service/PurchaseDao.php

<?php
/**
 * Created by PhpStorm.
 * User: nizongfeng
 * Date: 2021/10/27
 * Time: 16:38
 */

namespace app\admin\service;


use app\admin\command\Util;
use app\admin\model\Purchase;
use app\admin\model\PurchasePrice;
use think\Exception;

class PurchaseDao
{
    /**
     * 添加酒店项目采购单
     * @param $param
     * @param $hotelOrder
     * @return array
     */
    public function saveHotelPurchase($param,$hotelOrder):array {
        try {
            $data = [
                "order_id" => $hotelOrder['order_id'],
                "prod_type" => 'hotel',
                "order_detail_id" => $hotelOrder['id'],
                "group_id" => $param['group_id'],
                "pro_name" => $hotelOrder['hotel_name'],
                "item_name" => $hotelOrder['room_name'],
                "item_unit" => $hotelOrder['plan_name'],
                "check_in_date" => $param['check_in_date'],
                "check_out_date" => $param['check_out_date'],
                "supplier_id" => $param['supplier_id'],
                "supplier_name" => $param['supplier_name'],
                "purchase_user_id" => $param['purchase_user_id'],
                "purchase_user" => $param['purchase_user'],
                "del_flag"=>0
            ];
            $model = new Purchase();
            if (empty($param['purchase_id'])) {
                $id = $model->insertGetId($data);
                return Util::returnArrSu($id);
            }else {
                $model->save($data,["id"=>$param['purchase_id']]);
                return Util::returnArrSu($param['purchase_id']);
            }
        }catch (Exception $e){
            return Util::returnArrEr("新增采购都失败".$e->getMessage());
        }
    }

    /**
     * 添加附加项目采购单
     * @param $param
     * @param $itemOrder
     * @return array
     */
    public function saveItemPurchase($param, $itemOrder):array {
        try {
            $data = [
                "order_id" => $itemOrder['order_id'],
                "prod_type" => 'hotel',
                "order_detail_id" => $itemOrder['id'],
                "group_id" => $param['group_id'],
                "pro_name" => $itemOrder['hotel_name'],
                "item_name" => $itemOrder['item_name'],
                "item_unit" => $itemOrder['item_unit'],
                "check_in_date" => $param['check_in_date'],
                "check_out_date" => $param['check_out_date'],
                "supplier_id" => $param['supplier_id'],
                "supplier_name" => $param['supplier_name'],
                "purchase_user_id" => $param['purchase_user_id'],
                "purchase_user" => $param['purchase_user'],
                "del_flag"=>0
            ];
            $model = new Purchase();
            if (empty($param['purchase_id'])) {
                $id = $model->insertGetId($data);
                return Util::returnArrSu($id);
            }else {
                $model->save($data,["id"=>$param['purchase_id']]);
                return Util::returnArrSu($param['purchase_id']);
            }
        }catch (Exception $e){
            return Util::returnArrEr("新增采购都失败".$e->getMessage());
        }
    }

    /**
     * 设置采购单 金额
     * @param  $purchaseId
     * @return array
     */
    public function setPurchaseAmount(int $purchaseId){
        try{
            $purchasePrice = new PurchasePrice();
            $purchasePriceList = $purchasePrice->where(["purchase_id"=>$purchaseId,"del_flag"=>0])->select()->toArray();
            $cost = 0;
            $amount = 0;
            $cnt = 0;
            foreach ($purchasePriceList as $price) {
                $cost += $price['cost'] * $price["cnt"];
                $amount += $price['price'] * $price["cnt"];
                $cnt += $price['cnt'];
            }
            Purchase::update(["total_price"=>$amount,"total_cost"=>$cost,"count"=>$cnt])->where(["id"=>$purchaseId]);
            return Util::returnArrSu();
        }catch (Exception $e){
            return Util::returnArrEr("更新采购单金额失败".$e->getMessage());
        }

    }

    /**
     * 删除记录
     * @param $order_id
     */
    public function delete($order_id){
        $model = new Purchase();
        $model->save(["del_flag"=>1],["order_id"=>$order_id]);
    }
}