baoshi-was/app/Services/OwnerStoreOutFeeReportService.php

<?php

namespace App\Services;

use App\Interfaces\SettlementBillReportInterface;
use App\OwnerBillReport;
use App\OwnerBillReportArchive;
use App\OwnerFeeDetail;
use App\OwnerStoreFeeReport;
use App\OwnerStoreOutFeeDetail;
use App\Traits\ServiceAppAop;
use App\OwnerStoreOutFeeReport;
use Carbon\Carbon;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Support\Facades\DB;

class OwnerStoreOutFeeReportService implements SettlementBillReportInterface
{
    const TYPE = '出库费-合计';

    use ServiceAppAop;

    use \App\Traits\SettlementBillServiceTrait;

    protected $modelClass = OwnerStoreOutFeeReport::class;
    /** @var $detailService OwnerBillReportArchiveService */
    private $archiveService;

    /** @var $detailService OwnerStoreOutFeeDetailService */
    private $detailService;

    public function recordReport($counting_month = null)
    {
        $this->detailService = app('OwnerStoreOutFeeDetailService');
        if (is_null($counting_month)) {
            //默认统计上个月的数据
            $counting_month = now()->subMonth()->startOfMonth()->toDateString();
        }
        $this->reportDate = $counting_month;
        $start = $this->reportDate;
        $end = Carbon::parse($this->reportDate)->endOfMonth()->toDateString();
        $details = OwnerStoreOutFeeDetail::query()
            ->selectRaw("
                DATE_FORMAT(owner_store_out_fee_details.created_at,'%Y-%m') as counting_month,
                step,
                unit_id,
                unit_price,
                sum(amount) as  amount ,
                sum(fee) as  fee ,
                owner_id,
                work_name
            ")
            ->whereBetween('created_at', [$start, $end])
            ->groupBy(
                'counting_month',
                'step',
                'unit_id',
                'unit_price',
                'owner_id',
                'work_name'
            )->get();

        $reports = [];
        foreach ($details as $detail) {
            $counting_month = Carbon::parse($detail->counting_month)->startOfMonth()->toDateString();
            $ownerBillReport = OwnerBillReport::query()
                ->selectRaw("id")
                ->where('owner_id', $detail->owner_id)
                ->where('counting_month', $counting_month)->first();
            $reports[] = [
                'owner_bill_report_id' => $ownerBillReport->id ?? null,
                'owner_id' => $detail->owner_id,
                'counting_month' => $counting_month,
                'step' => $detail->step,
                'unit_id' => $detail->unit_id,
                'unit_price' => $detail->unit_price,
                'amount' => $detail->amount,
                'fee' => $detail->fee,
                'work_name' => $detail->work_name,
            ];
        }

        //保证幂等性 插入前删除该月的统计数据
        OwnerStoreOutFeeReport::query()->where('counting_month', $counting_month)->delete();

        foreach (array_chunk($reports, 1000) as $reports_chunked) {
            OwnerStoreOutFeeReport::query()->insertOrIgnore($reports_chunked);
        }
    }

    public function getSql($owner_id, $counting_month): Builder
    {
        // TODO: Implement getSql() method.
    }


    public function buildExport($details): array
    {
        // TODO: Implement buildExport() method.
    }


    public function switchType($type)
    {
        // TODO: Implement switchType() method.
    }

    function get(array $kvPairs)
    {
        $this->archiveService = app('OwnerBillReportArchiveService');
        list($start, $end) = $this->getStartAndEnd($kvPairs['counting_month']);
        if ($this->archiveService->isArchived($kvPairs['counting_month'], $kvPairs['owner_id'], $kvPairs['type']) == 1) {
            //查询存档数据
            $archived = $this->archiveService->get($kvPairs);
            $reports = collect($archived->information['reports']);
            $work_name_fee_total = collect($archived->information['work_name_fee_total']);
            $fee_total = $archived->information['fee_total'];
        } else {
            $reports = OwnerStoreOutFeeReport::query()
                ->with(['unit:id,name'])
                ->where('owner_id', $kvPairs['owner_id'])
                ->where('counting_month', $kvPairs['counting_month'])
                ->get();

            $work_name_fee_total = OwnerStoreOutFeeReport::query()
                ->selectRaw("
                    sum(fee) as fee,
                    work_name
                ")
                ->where('counting_month' , $kvPairs['counting_month'])
                ->where('owner_id', $kvPairs['owner_id'])
                ->groupBy('work_name')
                ->get();
            $fee_total = $work_name_fee_total->sum('fee');
        }
        return array($reports, $work_name_fee_total, $fee_total);
    }

    public function confirmBill($counting_month, $owner_id)
    {
        $billReport = OwnerBillReport::query()
            ->select('storage_fee', 'id')
            ->where('owner_id', $owner_id)
            ->where('counting_month', $counting_month)
            ->firstOr(function () {
                return new OwnerBillReport();
            });
        list($reports, $work_name_fee_total, $fee_total) = $this->get([
            'owner_id' => $owner_id,
            'counting_month' => $counting_month,
            'type' => $this::TYPE,
        ]);
        OwnerBillReportArchive::query()->create([
            'owner_bill_report_id' => $billReport->id ?? null,
            'owner_id' => $owner_id,
            'counting_month' => $counting_month,
            'type' => $this::TYPE,
            'archiver_id' => auth()->id(),
            'archived_at' => now(),
            'information' => [
                'reports' => $reports,
                'work_name_fee_total' => $work_name_fee_total,
                'fee_total' => $fee_total,
            ],
        ]);
        $this->confirmBillFeeTotal($counting_month, $owner_id);

    }


}