qianniaoApis/Model/Finance/MPay.Class.php

<?php
/**
 * 应付单管理模块
 * Created by PhpStorm.
 * User: wxj
 * Date: 2019/10/30
 * Time: 14:02
 */

namespace JinDouYun\Model\Finance;

use JinDouYun\Dao\Finance\DPaid;
use JinDouYun\Dao\Finance\DPaidOffset;
use JinDouYun\Model\MBaseModel;
use Mall\Framework\Core\ErrorCode;
use Mall\Framework\Core\StatusCode;
use Mall\Framework\Core\ResultWrapper;

use JinDouYun\Dao\Finance\DPay;
use JinDouYun\Dao\Finance\DPayReceiptIndex;

use JinDouYun\Model\Finance\MSupplierBalanceDetail;
use JinDouYun\Model\Finance\MSupplierBalance;

class MPay extends MBaseModel
{

    private $objDPay;
    private $objDPaid;
    private $objDPaidOffset;
    private $objDPayReceiptIndex;
    private $objMSupplierBalanceDetail;
    private $objMSupplierBalance;
    private $enterpriseId;
    private $userCenterId;

    public function __construct($enterpriseId, $userCenterId)
    {
        parent::__construct($enterpriseId, $userCenterId);
        $this->enterpriseId = $enterpriseId;
        $this->userCenterId = $userCenterId;
        $this->objMSupplierBalanceDetail = new MSupplierBalanceDetail($enterpriseId, $userCenterId);
        $this->objMSupplierBalance = new MSupplierBalance($enterpriseId, $userCenterId);
        $this->objDPay = new DPay('finance');
        $this->objDPayReceiptIndex = new DPayReceiptIndex('finance');
        $this->objDPaid = new DPaid('finance');
        $this->objDPaidOffset = new DPaidOffset('finance');
        $this->objDPaidOffset->setTable('qianniao_paid_offset_'.$enterpriseId);
        $this->objDPay->setTable('qianniao_pay_receipt_' . $enterpriseId . '_' . date('Y') . '_' . ceil(date('m') / 3));
        $this->objDPayReceiptIndex->setTable('qianniao_pay_receipt_index_' . $enterpriseId);

        //$this->objDPay->setSearchIndex('should_pay_receipt_search')->setType('should_pay_receipt');
    }

    /**
     * 临时财务脚本解决索引表id重复问题
     */
    public function tmp1()
    {
        // 查询应付索引表
        $result = $this->objDPayReceiptIndex->select('id > 273');
        if ($result === false) {
            return ResultWrapper::fail($this->objDPayReceiptIndex->error(), ErrorCode::$dberror);
        }

        foreach ($result as $key => $value){
            $suffix = date('Y', $value['createTime']) . '_' . ceil(date('m', $value['createTime']) / 3);
            $this->objDPay->setTable('qianniao_pay_receipt_' . $this->enterpriseId . '_' . $suffix);
            echo 'qianniao_pay_receipt_' . $this->enterpriseId . '_' . $suffix.PHP_EOL;
            $dbResult = $this->objDPay->get($value['payReceiptId']);
            if ($dbResult === false) {
                return ResultWrapper::fail($this->objDPay->error(), ErrorCode::$dberror);
            }
            if(empty($dbResult)){
                return ResultWrapper::fail($value['payReceiptId'].'对应应付不存在', ErrorCode::$contentNotExists);
            }

            // 把应付单id改成索引表的自增id
            $dbResult = $this->objDPay->update(['id'=>$value['id']], $value['payReceiptId']);
            if ($dbResult === false) {
                return ResultWrapper::fail($this->objDPay->error(), ErrorCode::$dberror);
            }

            // 把索引表应付id改成空
            $result = $this->objDPayReceiptIndex->update(['payReceiptId'=>0], $value['id']);
            if ($result === false) {
                return ResultWrapper::fail($this->objDPayReceiptIndex->error(), ErrorCode::$dberror);
            }

            echo $value['id'].'操作完成'.PHP_EOL;
        }

        return ResultWrapper::success('全部更新完成');
    }

    /**
     * 添加应付单
     *
     * @param array $params 应付单数据
     *
     * @return ResultWrapper
     */
    public function addPay($params)
    {
        $this->objDPay->beginTransaction();
        // 生成编号
        $dbResult =  $this->objDPay->get('createTime >='.strtotime(date('Ymd'.'0:0:0')), 'no', 'createTime desc');
        if ($dbResult === false) {
            return ResultWrapper::fail($this->objDPay->error(), ErrorCode::$dberror);
        }
        if(empty($dbResult)){
            $params['no'] = createSerialNumberByDate('');
        }else{
            $params['no'] =createSerialNumberByDate($dbResult['no']);
        }

        //索引表数据
        $indexData = [
            'payReceiptId'  => 0,
            'customerId'    => $params['customerId'],
            'sourceNo'      => $params['sourceNo'],
            'auditStatus'   => $params['auditStatus'],
            'offsetStatus'   => ($params['PayMoney']<0) ? 5 : 4,
            'financeTypeId' => $params['financeTypeId'],
            'financeType'   => $params['financeType'],
            'shopId'        => $params['shopId'],
            'createTime'    => $params['createTime'],
            'updateTime'    => $params['updateTime'],
        ];
        $payReceiptId = $this->objDPayReceiptIndex->insert($indexData);
        if ($payReceiptId === false) {
            $this->objDPay->rollBack();
            return ResultWrapper::fail($this->objDPayReceiptIndex->error(), ErrorCode::$dberror);
        }

        $params['offsetStatus'] = ($params['PayMoney']<0) ? 5 : 4;
        $params['id'] = $payReceiptId;
        $payId = $this->objDPay->insert($params);
        if ($payId === false) {
            $this->objDPay->rollBack();
            return ResultWrapper::fail($this->objDPay->error(), ErrorCode::$dberror);
        }

        $this->objDPay->commit();

//        $_id = self::createEsDocumentId($payId, $params['createTime']);
//        $esData = $params;
//        $esData['id'] = $payId;
//        $esData['enterpriseId'] = $this->enterpriseId;
//        $result = $this->objDPay->addUpSearchIndexDocument($esData, $_id);
//        if (isset($result['_shards']) && isset($result['_shards']['successful']) && $result['_shards']['successful'] == 1) {
//            //echo "es操作成功";die;
//        }else {
//            file_put_contents('/www/wwwroot/logs/apiqnys.liuniukj.com/elasticsearch.log',date('Y-m-d H:i:s').'生成应付单es错误，错误原因'.var_export($result,true).PHP_EOL,FILE_APPEND);
//        }

        return ResultWrapper::success($payId);
    }

    private function createEsDocumentId($payId, $time)
    {
        $t = date('Y', $time) . '_' . ceil(date('m', $time) / 3);
        return 'EnterpriseId_' . $this->enterpriseId . '_' . $t .'_payId_' . $payId;
    }

    public function getPayInfo($params)
    {
        $suffix = date('Y', $params['createTime']) . '_' . ceil(date('m', $params['createTime']) / 3);
        $this->objDPay->setTable('qianniao_pay_receipt_' . $this->enterpriseId . '_' . $suffix);
        unset($params['createTime']);

        $dbResult = $this->objDPay->get($params);
        if ($dbResult === false) {
            return ResultWrapper::fail($this->objDPay->error(), ErrorCode::$dberror);
        }
        if(!empty($dbResult)){
            //渲染前缀
            $dbResult['no'] = StatusCode::$noPrefix[18] . '-' . $dbResult['no'];
            $dbResult['purchaseNo'] = StatusCode::$noPrefix[2] . '-' . $dbResult['purchaseNo'];
            $dbResult['supplierCode'] = createCode(StatusCode::$code['supplier']['prefix'], $dbResult['supplierId'], StatusCode::$code['supplier']['length']);
        }
        return ResultWrapper::success($dbResult);

    }

    /**
     * 修改应付单核销状态
     */
    public function updateOffsetStatus($id,$offsetMoney,$createTime)
    {
        $suffix = date('Y', $createTime) . '_' . ceil(date('m', $createTime) / 3);
        $this->objDPay->setTable('qianniao_pay_receipt_' . $this->enterpriseId . '_' . $suffix);
        $shouldPayData = $this->objDPay->get($id);
        if ($shouldPayData === false) {
            $this->objDPay->rollBack();
            return ResultWrapper::fail($this->objDPay->error(), ErrorCode::$dberror);
        }
        if( empty($shouldPayData) ){
            return ResultWrapper::fail('要审核的单据不存在', ErrorCode::$contentNotExists);
        }

//        $notOffsetMoney = bcsub($shouldPayData['payMoney'], $offsetMoney, 4);
        $updateData = [
            'offsetMoney'    => bcadd($shouldPayData['offsetMoney'],abs($offsetMoney),4),
            'notOffsetMoney' => bcsub($shouldPayData['notOffsetMoney'], abs($offsetMoney),4),
            'offsetStatus'  => StatusCode::$delete
        ];
        switch (true)
        {
            case $updateData['notOffsetMoney'] == 0;
                $updateData['offsetStatus'] = StatusCode::$standard;
                break;
            case $updateData['notOffsetMoney'] == $shouldPayData['payMoney'];
                $updateData['offsetStatus'] = StatusCode::$delete;
                break;
            case $updateData['notOffsetMoney'] > 0 && $updateData['notOffsetMoney'] < $shouldPayData['payMoney'];
                $updateData['offsetStatus'] = StatusCode::$partion;
                break;
        }
        $beginTransactionStatus = $this->objDPay->beginTransaction();
        unset($dbResult);
        $dbResult = $this->objDPay->update($updateData, $id);
        if ($dbResult === false) {
            $this->objDPay->rollBack();
            return ResultWrapper::fail($this->objDPay->error(), ErrorCode::$dberror);
        }

        //修改索引表状态
        unset($dbResult);
        $dbResult = $this->objDPayReceiptIndex->update(['offsetStatus' => $updateData['offsetStatus']], ['payReceiptId' => $id, 'createTime'=>$createTime]);
        if ($dbResult === false) {
            $this->objDPay->rollBack();
            return ResultWrapper::fail($this->objDPayReceiptIndex->error(), ErrorCode::$dberror);
        }
        if($beginTransactionStatus){
            $this->objDPay->commit();
        }

        return ResultWrapper::success($dbResult);
    }

    /**
     * 应付单启用和禁用
     * @param array $params
     * @return ResultWrapper
     * @throws \Exception
     */
    public function updatePayStatus($params)
    {
        $suffix = date('Y', $params['createTime']) . '_' . ceil(date('m', $params['createTime']) / 3);
        $this->objDPay->setTable('qianniao_pay_receipt_' . $this->enterpriseId . '_' . $suffix);

        $shouldPayData = $this->objDPay->get($params['id']);
        if ($shouldPayData === false) {
            return ResultWrapper::fail($this->objDPay->error(), ErrorCode::$dberror);
        }
        if( empty($shouldPayData) ){
            return ResultWrapper::fail('要审核的单据不存在', ErrorCode::$contentNotExists);
        }
        if( $shouldPayData['auditStatus'] == StatusCode::$auditStatus['auditPass'] ){
            return ResultWrapper::fail('该单据已经审核过了', ErrorCode::$notAllowAccess);
        }

        $this->objDPay->beginTransaction();
        $dbResult = $this->objDPay->update(['auditStatus' => StatusCode::$auditStatus['auditPass']], $params['id']);
        if ($dbResult === false) {
            $this->objDPay->rollBack();
            return ResultWrapper::fail($this->objDPay->error(), ErrorCode::$dberror);
        }

        //修改索引表状态
        $dbResult = $this->objDPayReceiptIndex->update(['auditStatus' => StatusCode::$auditStatus['auditPass']], ['payReceiptId' => $params['id']]);
        if ($dbResult === false) {
            $this->objDPay->rollBack();
            return ResultWrapper::fail($this->objDPayReceiptIndex->error(), ErrorCode::$dberror);
        }

        //供应商余额明细
        $supplierMoney = $this->objMSupplierBalance->getSupplierBalance($shouldPayData['supplierId']);
        //自动核销
        $autoOffset = self::autoOffset($supplierMoney,$params['id'],$params['createTime']);
        if (!$autoOffset->isSuccess()) {
            $this->objDPay->rollBack();
            return ResultWrapper::fail($autoOffset->getData(), $autoOffset->getErrorCode());
        }
        $detailData = [
            'supplierId'       => $shouldPayData['supplierId'],
            'receiptTime'      => $shouldPayData['createTime'],//'单据日期',
            'no'               => $shouldPayData['no'],//'单据编号',
            'financeType'      => $shouldPayData['financeType'],//'财务类型名称',
            'financeTypeId'    => $shouldPayData['financeTypeId'],//'财务类型id',
            'sourceNo'         => $shouldPayData['sourceNo'],
            'salesAmount'      => bcadd($shouldPayData['payMoney'], $shouldPayData['discountMoney'], 4),
            'discountMoney'    => $shouldPayData['discountMoney'],// '优惠金额',
            'supplierAmount'   => 0.00,
            'shouldPayAmount'  => $shouldPayData['payMoney'],//实际应付金额
            'actualPaidAmount' => 0.00,
            'shouldPayBalance' => bcadd($supplierMoney,$shouldPayData['payMoney'],2),//应付款余额
            'remark'           => '应付单审核通过，应付供应商'.$shouldPayData['payMoney'].'元',//'备注',
            'createTime'       => time(),//'创建日期',
            'updateTime'       => time(),//'修改日期',
        ];

        //供应商余额明细
        $result = $this->objMSupplierBalanceDetail->addSupplierBalanceDetail($detailData);
        if ($result->isSuccess() === false) {
            $this->objDPay->rollBack();
            return ResultWrapper::fail($result->getData(), $result->getErrorCode());
        }

        //供应商余额
        //$changedMoney = $shouldPayData['payMoney'] > 0 ? $shouldPayData['payMoney'] : -1*$shouldPayData['payMoney'];
        $changedMoney = $shouldPayData['payMoney'];
        $result = $this->objMSupplierBalance->addSupplierBalance($shouldPayData['supplierId'], $changedMoney);
        if ($result->isSuccess() === false) {
            $this->objDPay->rollBack();
            return ResultWrapper::fail($result->getData(), $result->getErrorCode());
        }

        $this->objDPay->commit();

        /*
        $_id = self::createEsDocumentId($params['id'], $params['createTime']);
        $this->objDPay->esupdateTypeFieldVaule(['auditStatus'=>StatusCode::$auditStatus['auditPass']], $_id);
        */
        return ResultWrapper::success($dbResult);

    }

    /**
     * 获取所有应付单数据
     * @param array $selectParams 过滤条件
     * @return ResultWrapper
     * @throws \Exception
     */
    public function getAllPay($selectParams, $isExport = false)
    {
   
            $limit = $selectParams['limit'];
            $offset = $selectParams['offset'];
            unset($selectParams['limit']);
            unset($selectParams['offset']);
            // 导出动作
            if($isExport){
                $limit = 9999;
                $offset = 0;
            }
            $whereSql = '';
            if (isset($selectParams['supplierId']) && !empty($selectParams['supplierId'])) {
                $where = empty($whereSql) ? ' WHERE ' : ' AND ';
                $whereSql .= $where . ' supplierId = ' . $selectParams['supplierId'];
            }
            // 原单据搜索
            if (isset($selectParams['sourceNo']) && !empty($selectParams['sourceNo'])) {
                $tmpNo = explode('-',$selectParams['sourceNo']);
                if(count($tmpNo) == 3){
                    $where = empty($whereSql) ? ' WHERE ' : ' AND ';
                    $whereSql .= $where . ' sourceNo like "%' . $tmpNo[1].'-'.$tmpNo[2].'%"';
                }else{
                    $where = empty($whereSql) ? ' WHERE ' : ' AND ';
                    $whereSql .= $where . ' sourceNo like "%' . $selectParams['sourceNo'].'%"';
                }

            }

            if (isset($selectParams['offsetStatus']) && !empty($selectParams['offsetStatus'])) {
//                if(is_array($selectParams['offsetStatus'])){
                    // 数组转字符串
                    $selectParams['offsetStatus'] = implode(',',$selectParams['offsetStatus']);
                    $where = empty($whereSql) ? ' WHERE ' : ' AND ';
                    $whereSql .= $where . ' offsetStatus in( ' . $selectParams['offsetStatus'].')';
//                }

            }
            if (isset($selectParams['payReceiptIds']) && !empty($selectParams['payReceiptIds'])) {
                $where = empty($whereSql) ? ' WHERE ' : ' AND ';
                $whereSql .= $where . ' payReceiptId in (' . implode(',', $selectParams['payReceiptIds']).')';
            }
            if (isset($selectParams['auditStatus']) && !empty($selectParams['auditStatus'])) {
                $where = empty($whereSql) ? ' WHERE ' : ' AND ';
                $whereSql .= $where . ' auditStatus = ' . $selectParams['auditStatus'];
            }
            if (isset($selectParams['warehouseId']) && !empty($selectParams['warehouseId'])) {
                $where = empty($whereSql) ? ' WHERE ' : ' AND ';
                $whereSql .= $where . ' warehouseId = ' . $selectParams['warehouseId'];
            }
            if ( (isset($selectParams['start']) && !empty($selectParams['start']))&&(isset($selectParams['end']) && !empty($selectParams['end'])) ) {
                $where = empty($whereSql) ? ' WHERE ' : '  AND ';
                $whereSql .= $where . ' createTime BETWEEN ' . $selectParams['start'] . ' AND '. $selectParams['end'];
            }

            $sql = 'SELECT * FROM ' .$this->objDPayReceiptIndex->get_Table().$whereSql . ' ORDER BY createTime DESC LIMIT ' . $offset . ' , ' . $limit;
            $PayReceiptIndexResult = $this->objDPayReceiptIndex->query($sql);

        if($PayReceiptIndexResult === false){
            return ResultWrapper::fail($this->objDPayReceiptIndex->error(), ErrorCode::$dberror);
        }

        $tableSuffix = [];
        foreach ($PayReceiptIndexResult as $PayReceiptIndex) {
            $k = date('Y', $PayReceiptIndex['createTime']) . '_' . ceil(date('m', $PayReceiptIndex['createTime']) / 3);
            $tableSuffix[$k][] = $PayReceiptIndex['id'];

        }

        $PayReceiptResult = [];
        foreach ($tableSuffix as $suffix => $payReceiptIds) {
            $this->objDPay->setTable('qianniao_pay_receipt_' . $this->enterpriseId . '_' . $suffix);

            if($isExport){
                $dbResult = $this->objDPay->exportSelect($payReceiptIds, '*', 'createTime desc');
                $tmpArray = [];
                foreach($dbResult as $key => $value){
                    $tmpArray[] = $value;
                }
                $dbResult = $tmpArray;
            }else{
                $dbResult = $this->objDPay->select(['id'=>$payReceiptIds], '*', 'createTime desc');
                //$dbResult = $this->objDPay->select(['supplierId' => $selectParams['supplierId']], '*', 'createTime desc');
            }
            if ($dbResult === false) {
                return ResultWrapper::fail($this->objDPay->error(), ErrorCode::$dberror);
            }

            if(!empty($dbResult)){
                //渲染前缀
                foreach ($dbResult as $key => $value){
                    $dbResult[$key]['no'] = StatusCode::$noPrefix[18] . '-' . $value['no'];
                    $dbResult[$key]['sourceNo'] = StatusCode::$noPrefix[3] . '-' . $value['sourceNo'];
                    $dbResult[$key]['purchaseNo'] = StatusCode::$noPrefix[2] . '-' . $value['purchaseNo'];
                }
                $PayReceiptResult = array_merge($PayReceiptResult, self::format($dbResult));
            }
        }

        

        //$total = $this->objDPayReceiptIndex->count($selectParams);
        $totalSql = 'SELECT COUNT(1) as count FROM ' .$this->objDPayReceiptIndex->get_Table() . $whereSql;
        $dbTotalResult = $this->objDPayReceiptIndex->query($totalSql);
        if ($dbTotalResult === false) {
            return ResultWrapper::fail($this->objDPayReceiptIndex->error(), ErrorCode::$dberror);
        }
        if(empty($dbTotalResult)){
            return ResultWrapper::success([]);
        }

        $return = [
            'data'  => $PayReceiptResult,
            'total' => ($dbTotalResult[0]['count']) ? intval($dbTotalResult[0]['count']) : 0,
        ];
        if($isExport){
            self::export($return['data']);
        }
        return ResultWrapper::success($return);
    }

    /**
     * 审核成功调用（预充余额）
     * @param array $params
     * @return ResultWrapper
     * @throws \Exception
     */

    public function autoOffset($supplierMoney, $payId, $createTime)
    {
        $suffix = date('Y', $createTime) . '_' . ceil(date('m', $createTime) / 3);
        $this->objDPay->setTable('qianniao_pay_receipt_' . $this->enterpriseId . '_' . $suffix);
        $this->objDPaid->setTable('qianniao_paid_' . $this->enterpriseId . '_' . date('Y', $createTime) . '_' . ceil(date('m', $createTime) / 3));
        //根据id查出客户id（查询客户表有无预付款）
        $shouldPayData = $this->objDPay->get($payId);
        if ($shouldPayData === false) {
            return ResultWrapper::fail($this->objDPay->error(), ErrorCode::$dberror);
        }
        if (empty($shouldPayData)) {
            return ResultWrapper::fail('应收单id'.$payId.'数据为空', ErrorCode::$dberror);
        }
        $offsetMoney = 0;
        $notOffsetMoney = 0;
        $offsetStatus = 5;
        if ($supplierMoney < 0 && $shouldPayData['payMoney'] > 0){//说明供应商是预收款进行自动核销
            switch (true)
            {
                case bcsub(abs($supplierMoney),$shouldPayData['payMoney'],4) > 0;//说明预收款完全核销应收单金额
                    $offsetMoney = $shouldPayData['payMoney'];
                    break;
                case bcsub(abs($supplierMoney),$shouldPayData['payMoney'],4) == 0;//说明预收款刚好完全核销
                    $offsetMoney = $shouldPayData['payMoney'];
                    break;
                case bcsub(abs($supplierMoney),$shouldPayData['payMoney'],4) < 0;//说明预收款不够核销应收单金额
                    $offsetMoney = abs($supplierMoney);
                    $notOffsetMoney = bcadd($supplierMoney,$shouldPayData['payMoney'],4);
                    $offsetStatus = StatusCode::$partion;
            }
            //更新应付单核销状态
            $updateOffsetStatus = $this->objDPay->update(['offsetMoney'=>$offsetMoney,'notOffsetMoney'=>$notOffsetMoney,'offsetStatus'=>$offsetStatus],['id'=>$payId]);
            if ($updateOffsetStatus === false) {
                $this->objDPay->rollBack();
                return ResultWrapper::fail($this->objDPay->error(), ErrorCode::$dberror);
            }
            //更新应付单索引表核销状态
            unset($dbResult);
            $dbResult = $this->objDPayReceiptIndex->update(['offsetStatus' => $offsetStatus], ['payReceiptId' => $payId,'createTime'=>$createTime]);
            if ($dbResult === false) {
                $this->objDPay->rollBack();
                return ResultWrapper::fail($this->objDPayReceiptIndex->error(), ErrorCode::$dberror);
            }
            unset($dbResult);
            //查询付款单，找到能核销的
            $dbResult = $this->objDPaid->query('select * from '.$this->objDPaid->get_Table().' where supplierId='.$shouldPayData['supplierId'].' and offsetStatus != '. StatusCode::$standard.' order by createTime asc');
            if ($dbResult === false) {
                return ResultWrapper::fail($this->objDPaid->error(), ErrorCode::$dberror);
            }
            $paidOffsetMoney = $shouldPayData['payMoney'];
            foreach ($dbResult as $key => $value){
                if($paidOffsetMoney<=0){
                    break;
                }
                switch (true){
                    case bcsub($value['notOffsetMoney'],$shouldPayData['payMoney'],2)>0: // 说明收款单能完全核销应收
                        $paidOffset = [
                            'offsetMoney' => bcadd($paidOffsetMoney,$value['offsetMoney'],2),
                            'notOffsetMoney' => bcsub($value['notOffsetMoney'],$paidOffsetMoney,2),
                            'offsetStatus' => StatusCode::$partion,
                        ];
                        $paidOffsetMoney = abs(bcsub($paidOffsetMoney,$paidOffset['offsetMoney'],2));
                        break;
                    case bcsub($value['notOffsetMoney'],$shouldPayData['payMoney'],2) == 0: // 说明收款单能完全核销应收
                        $paidOffset = [
                            'offsetMoney' => $value['totalFinalMoney'],
                            'notOffsetMoney' => 0,
                            'offsetStatus' => StatusCode::$standard,
                        ];
                        $paidOffsetMoney = abs(bcsub($value['totalFinalMoney'],$paidOffset['offsetMoney'],2));
                        break;
                    case bcsub($value['notOffsetMoney'],$shouldPayData['payMoney'],2) < 0: // 说明收款单不能完全核销应收
                        $paidOffset = [
                            'offsetMoney' => $value['totalFinalMoney'],
                            'notOffsetMoney' => 0,
                            'offsetStatus' => StatusCode::$standard,
                        ];
                        $paidOffsetMoney = abs(bcsub($value['totalFinalMoney'],$paidOffset['offsetMoney'],2));
                }
                // 更新核销
                $updatePaidOffset = $this->objDPaid->update($paidOffset,['id'=>$value['id']]);
                if ($updatePaidOffset === false) {
                    $this->objDPay->rollBack();
                    return ResultWrapper::fail($this->objDPaid->error(), ErrorCode::$dberror);
                }
                //记录核销明细
                $updateOffset = [
                    'payReceiptId' => $payId,
                    'paidId' => $value['id'],
                    'offsetMoney' => $offsetMoney,
                    'payCreateTime' => $shouldPayData['createTime'],
//                    'type'  => StatusCode::$delete
                ];
                $result = $this->objDPaidOffset->insert($updateOffset);
                if ($result === false) {
                    $this->objDPay->rollBack();
                    return ResultWrapper::fail($this->objDPaidOffset->error(), ErrorCode::$dberror);
                }


            }


        }
        //报错修改
        //return ResultWrapper::success($dbResult);
        return ResultWrapper::success(null);
    }


    /**
     * 导出方法
     *
     * @param $exportData
     */
    private static function export($exportData)
    {
        //导出到本地
        header("Content-type:application/vnd.ms-excel");
        header("Content-Disposition:filename=应收单列表.csv");
        header('Cache-Control: max-age=0');
        $fp = fopen('php://output', 'a');
        $head = ['应付单编号', '源订单号', '供应商名称', '单据日期', '优惠金额', '实际应付金额', '商铺', '单据类型', '状态'];       //定义标题
        foreach ($head as $i => $v) {
            $head[$i] = mb_convert_encoding($v, 'GBK', 'utf-8');     //将中文标题转换编码，否则乱码
        }
        fputcsv($fp, $head);
        $limit = 10000;
        $num = 0;//计数器
        foreach ($exportData as $v) {
            //循环数据
            $num++;
            if ($num == $limit) {
                ob_flush();//释放内存
                flush();
            }
            $rows['no'] = $v['no'];
            $rows['sourceNo'] = $v['sourceNo'];
            $rows['supplierName'] = $v['supplierName'];
            $rows['createTime'] = date('Y-m-d H:i:s', $v['createTime']);
            $rows['discountMoney'] = $v['discountMoney'];
            $rows['payMoney'] = $v['payMoney'];
            $rows['shopName'] = $v['shopName'];
            $rows['receiptTypeName'] = $v['receiptTypeId'] ? '采购订单' : '采购退货单';
            $rows['auditStatus'] = StatusCode::$auditStatus[$v['auditStatus']];

            foreach ($rows as $kk => $vv) {
                $rs[$kk] = mb_convert_encoding($vv, 'GBK', 'utf-8');  //转译编码
            }
            fputcsv($fp, $rs);
            $rows = [];
        }
        exit;
    }

    public function format($data)
    {
        foreach ($data as $k => $v) {
            $data[$k]['supplierCode'] = createCode(StatusCode::$code['supplier']['prefix'], $v['supplierId'], StatusCode::$code['supplier']['length']);
        }
        return $data;
    }

    //搜索的where条件拼接
    public function setWhere($selectParams)
    {
        $defaultDSL = [
            'from' => $selectParams['offset'],
            'size' => $selectParams['limit'],
            'sort' => [
                'createTime' => [
                    'order' => 'desc'
                ],
            ],
        ];

        $dsl = [];
        $dsl['query']['bool']['must'][] = [
            'term' => ['enterpriseId' => $this->enterpriseId],
        ];

        if (isset($selectParams['keyword'])) {
            if (!empty($selectParams['keyword'])) {
                $dsl['query']['bool']['must'][] = [
                    'multi_match' => [
                        'fields'    => ['no', 'sourceNo', 'customerName'],
                        'query'     => $selectParams['keyword'],
                        'fuzziness' => 'AUTO',
                    ]
                ];
            }
        }

        if (!empty($selectParams['shopId'])) {
            $dsl['query']['bool']['must'][] = [
                'term' => ['shopId' => $selectParams['shopId']],
            ];
        }

        if (!empty($selectParams['start']) && !empty($selectParams['end'])) {
            $dsl['query']['bool']['must'][] = [
                'range' => [
                    'createTime' => [
                        'gte' => $selectParams['start'],
                        'lte' => strtotime(date('Y-m-d',$selectParams['end']).'23:59:59'),
                    ]
                ]
            ];
        } else {
            if (!empty($selectParams['start'])) {
                $dsl['query']['bool']['must'][] = [
                    'range' => [
                        'createTime' => [
                            'gte' => $selectParams['start'],
                        ]
                    ]
                ];
            }

            if (!empty($selectParams['end'])) {
                $dsl['query']['bool']['must'][] = [
                    'range' => [
                        'createTime' => [
                            'lte' => strtotime(date('Y-m-d',$selectParams['end']).'23:59:59'),
                        ]
                    ]
                ];
            }
        }

        if (isset($selectParams['receiptTypeId'])) {
            if (!empty($selectParams['receiptTypeId'])) {
                $dsl['query']['bool']['filter'][] =
                    ['term' => ['receiptTypeId' => $selectParams['receiptTypeId']]];
            }
        }

        if (isset($selectParams['auditStatus'])) {
            if (!empty($selectParams['auditStatus'])) {
                $dsl['query']['bool']['filter'][] =
                    ['term' => ['auditStatus' => $selectParams['auditStatus']]];
            }
        }

        $dsl = array_merge($defaultDSL, $dsl);
        return $dsl;
    }

    public function search($selectParams)
    {
        $is_export = $selectParams['isExport'];
        unset($selectParams['isExport']);

        if($is_export){
            unset($selectParams['limit']);
            unset($selectParams['offset']);
        }

        $dsl = $this->setWhere($selectParams);

        //导出
        if ($is_export) self::exportSearch($dsl);

        $result = $this->objDPay->getSearchQueryDsl($dsl);

        if (isset($result['status']) && $result['status'] == 400) {
            if ($result['error']['reason'] == 'all shards failed') {
                return ResultWrapper::success([
                    'data'  => [],
                    'total' => 0
                ]);
            }
            return ResultWrapper::fail('获取应付数据失败' . $result['error']['reason'], ErrorCode::$apiNotResult);
        }

        if (!isset($result['hits']) || $result['hits']['total'] == 0) {
            return ResultWrapper::success([
                'data'  => [],
                'total' => 0
            ]);
        }
        $total = $result['hits']['total'];
        $dbResult = $result['hits']['hits'];

        $list = [];
        foreach ($dbResult as $key => &$value) {
            $data = [];
            $data = $value['_source'];
            $list[] = $data;
        }

        $return = [
            'data'  => self::format($list),
            'total' => ($total) ? intval($total) : 0,
        ];
        return ResultWrapper::success($return);
    }

    /**
     * 检索导出(ES)
     *
     * @param $dsl
     * @return ResultWrapper
     * @throws \Exception
     */
    private function exportSearch($dsl)
    {
        $result = $this->objDPay->getScrollSearchQueryDsl($dsl);
        if (isset($result['status']) && $result['status'] == 400) {
            return ResultWrapper::fail('获取数据失败' . $result['error']['reason'], ErrorCode::$apiNotResult);
        }

        if (!isset($result['hits']) && $result['hits']['total'] == 0) {
            return ResultWrapper::fail('导出数据为空' . $result['error']['reason'], ErrorCode::$apiNotResult);
        }
        $dbResult = $result['hits']['hits'];

        $list = [];
        foreach ($dbResult as $key => &$value) {
            $list[] = $value['_source'];
        }
        self::export($list);
    }

    /**
     * 查询所有未审核的应付单
     */
    public function getAllAuditingPay()
    {
        $condition = [
            'deleteStatus' => StatusCode::$standard,
            'auditStatus'  => StatusCode::$auditStatus['auditing'],
        ];
        $result = $this->objDPayReceiptIndex->select($condition);
        if ($result === false) {
            return ResultWrapper::fail($this->objDPayReceiptIndex->error(), ErrorCode::$dberror);
        }
        if(empty($result)){
            return ResultWrapper::success([]);
        }
        return ResultWrapper::success($result);
    }
}