seaBlueApi/Model/Finance/MReceive.Class.php

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

namespace JinDouYun\Model\Finance;

use JinDouYun\Dao\Finance\DReceived;
use JinDouYun\Dao\Finance\DReceiveOffset;
use JinDouYun\Model\Order\MOrder;
use function FastRoute\TestFixtures\empty_options_cached;
use JinDouYun\Model\MBaseModel;
use Mall\Framework\Core\ErrorCode;
use Mall\Framework\Core\StatusCode;
use Mall\Framework\Core\ResultWrapper;

use JinDouYun\Dao\Finance\DReceive;
use JinDouYun\Dao\Finance\DReceiveReceiptIndex;
use JinDouYun\Model\Finance\MCustomerBalanceDetail;
use JinDouYun\Model\Finance\MCustomerBalance;
use JinDouYun\Cache\FinanceCache;

class MReceive extends MBaseModel
{
    private $objDReceive;
    private $objDReceiveReceiptIndex;
    private $objMCustomerBalanceDetail;
    private $objMCustomerBalance;
    private $objFinanceCache;
    private $objDReceived;
    private $objDReceiveOffset;
    private $enterpriseId;
    private $userCenterId;

    public function __construct($enterpriseId, $userCenterId)
    {
        parent::__construct($enterpriseId, $userCenterId);
        $this->enterpriseId = $enterpriseId;
        $this->userCenterId = $userCenterId;

        $this->objMCustomerBalanceDetail = new MCustomerBalanceDetail($enterpriseId, $userCenterId);
        $this->objMCustomerBalance = new MCustomerBalance($enterpriseId, $userCenterId);
        $this->objDReceive = new DReceive('finance');
        $this->objDReceiveReceiptIndex = new DReceiveReceiptIndex('finance');
        $this->objFinanceCache = new FinanceCache();
        $this->objDReceived = new DReceived('finance');
        $this->objDReceiveOffset = new DReceiveOffset('finance');

        $this->objDReceiveOffset->setTable('qianniao_receive_offset_'. $enterpriseId);

        $this->objDReceive->setTable('qianniao_receive_receipt_' . $enterpriseId . '_' . date('Y') . '_' . ceil(date('m') / 3));
        $this->objDReceiveReceiptIndex->setTable('qianniao_receive_receipt_index_' . $enterpriseId);

        $this->objDReceive->setSearchIndex('should_receive_receipt_search')->setType('should_receive_receipt');
    }

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

        foreach ($result as $key => $value){
            $suffix = date('Y', $value['createTime']) . '_' . ceil(date('m', $value['createTime']) / 3);
            $this->objDReceive->setTable('qianniao_receive_receipt_' . $this->enterpriseId . '_' . $suffix);
            $dbResult = $this->objDReceive->get($value['receiveReceiptId']);
            if ($dbResult === false) {
                return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
            }
            
            // 把应收单id改成索引表的自增id
            $dbResult = $this->objDReceive->update(['id'=>$value['id']], $value['receiveReceiptId']);
            if ($dbResult === false) {
                return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
            }

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

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

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

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

        //索引表数据
        $indexData = [
            'receiveReceiptId' => 0,
            'customerId'       => $params['customerId'],
            'sourceNo'         => $params['sourceNo'],
            'originId'         => $params['originId'],
            'auditStatus'      => $params['auditStatus'],
            'offsetStatus'      =>($params['receiveMoney']<0) ? 5 : 4,
            'financeTypeId'    => $params['financeTypeId'],
            'financeType'      => $params['financeType'],
            'shopId'           => $params['shopId'],
            'createTime'       => $params['createTime'],
            'updateTime'       => $params['updateTime'],

        ];
        $receiveReceiptId = $this->objDReceiveReceiptIndex->insert($indexData);
        if ($receiveReceiptId === false) {
            $this->objDReceive->rollBack();
            return ResultWrapper::fail($this->objDReceiveReceiptIndex->error(), ErrorCode::$dberror);
        }

        //应付单检测重复数据
        $allResult = $this->objDReceive->get(['sourceNo'=>$params['sourceNo'],'receiveMoney'=>$params['receiveMoney']]);
        if( $allResult === false  ){
            return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
        }
        if( !empty($allResult) ){
            return ResultWrapper::fail('应收单已经创建过了',ErrorCode::$notAllowAccess);
        }

        $params['id'] = $receiveReceiptId;
        $ReceiveId = $this->objDReceive->insert($params);
        if ($ReceiveId === false) {
            $this->objDReceive->rollBack();
            return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
        }
        $this->objDReceive->commit();

        /*
        $_id = self::createEsDocumentId($ReceiveId, $params['createTime']);
        $esData = $params;
        $esData['id'] = $ReceiveId;
        $esData['enterpriseId'] = $this->enterpriseId;
        $result = $this->objDReceive->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/api.junhailan.com/elasticsearch.log',date('Y-m-d H:i:s').'生成应收单es错误，错误原因'.var_export($result,true).PHP_EOL,FILE_APPEND);
        }*/
        return ResultWrapper::success($receiveReceiptId);
    }

    /**
     * 生成es的文档id
     * @param $receiveId
     * @param $time
     * @return string
     */
    private function createEsDocumentId($receiveId, $time)
    {
        $t = date('Y', $time) . '_' . ceil(date('m', $time) / 3);
        return 'EnterpriseId_' . $this->enterpriseId . '_' . $t . '_receiveId_' . $receiveId;
    }

    /**
     * 获取应收单数据
     * @param $params
     * @return ResultWrapper
     */
    public function getReceiveInfo($params) {
        $suffix = date('Y', $params['createTime']) . '_' . ceil(date('m', $params['createTime']) / 3);
        $this->objDReceive->setTable('qianniao_receive_receipt_' . $this->enterpriseId . '_' . $suffix);
        $dbResult = $this->objDReceive->get($params['id']);
        if ($dbResult === false) {
            return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
        }
        if(!empty($dbResult)){
            $dbResult['no'] = StatusCode::$noPrefix[16] . '-' . $dbResult['no'];
            $dbResult['sourceNo'] = StatusCode::$noPrefix[1] .'-'.$dbResult['sourceNo'];

            $dbResult['customerCode'] = createCode(StatusCode::$code['customer']['prefix'], $dbResult['customerId'], StatusCode::$code['customer']['length']);
        }
        return ResultWrapper::success($dbResult);

    }

    /**
     * 更新应收单核销状态
     * @param $id
     * @param $offsetMoney
     * @param $createTime
     * @return ResultWrapper
     */
    public function updateOffsetStatus($id,$offsetMoney,$createTime)
    {
        $suffix = date('Y', $createTime) . '_' . ceil(date('m', $createTime) / 3);
        $this->objDReceive->setTable('qianniao_receive_receipt_' . $this->enterpriseId . '_' . $suffix);
        $shouldReceiveData = $this->objDReceive->get($id);
        if ($shouldReceiveData === false) {
            $this->objDReceive->rollBack();
            return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
        }
        if( empty($shouldReceiveData) ){
            return ResultWrapper::fail('要审核的单据不存在', ErrorCode::$contentNotExists);
        }
//        $notOffsetMoney = bcsub($shouldReceiveData['receiveMoney'], $offsetMoney, 4);
        //判断该单据是否
        $updateData = [
            'offsetMoney'    => bcadd(abs($offsetMoney), abs($shouldReceiveData['offsetMoney']),4),
            'notOffsetMoney' => bcsub($shouldReceiveData['notOffsetMoney'], abs($offsetMoney),4),
            'offsetStatus'  => StatusCode::$delete
        ];
        switch (true)
        {
            case $updateData['notOffsetMoney'] == 0;
                $updateData['offsetStatus'] = StatusCode::$standard;
                break;
            case $updateData['notOffsetMoney'] == $shouldReceiveData['receiveMoney'];
                $updateData['offsetStatus'] = StatusCode::$delete;
                break;
            case $updateData['notOffsetMoney'] > 0 && $updateData['notOffsetMoney'] < $shouldReceiveData['receiveMoney'];
                $updateData['offsetStatus'] = StatusCode::$partion;
                break;
        }
        $beginTransactionStatus = $this->objDReceive->beginTransaction();
        unset($dbResult);
        $dbResult = $this->objDReceive->update($updateData, $id);
        if ($dbResult === false) {
            $this->objDReceive->rollBack();
            return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
        }

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

        return ResultWrapper::success($dbResult);
    }

    /**
     * 应收单审核
     * @param array $params
     * @return ResultWrapper
     * @throws \Exception
     */
    public function updateReceiveStatus($params)
    {
        // 根据创建时间切表
        $suffix = date('Y', $params['createTime']) . '_' . ceil(date('m', $params['createTime']) / 3);
        $this->objDReceive->setTable('qianniao_receive_receipt_' . $this->enterpriseId . '_' . $suffix);

        // 判断是否已审核
        $shouldReceiveData = $this->objDReceive->get($params['id']);
        if( $shouldReceiveData === false ){
            return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
        }
        if(empty($shouldReceiveData)){
            return ResultWrapper::fail('要审核的单据不存在', ErrorCode::$contentNotExists);
        }
        if ($shouldReceiveData['auditStatus'] == StatusCode::$auditStatus['auditPass']) {
            return ResultWrapper::fail('单据已审核', ErrorCode::$actionIsDo);
        }

        $beginTransactionStatus = $this->objDReceive->beginTransaction();

        // 修改应收单审核状态
        $dbResult = $this->objDReceive->update(['auditStatus' => StatusCode::$auditStatus['auditPass']], $params['id']);
        if ($dbResult === false) {
            $this->objDReceive->rollBack();
            return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
        }

        // 修改应收单索引表审核状态
        $dbResult = $this->objDReceiveReceiptIndex->update(['auditStatus' => StatusCode::$auditStatus['auditPass']], ['id' => $params['id']]);
        if ($dbResult === false) {
            $this->objDReceive->rollBack();
            return ResultWrapper::fail($this->objDReceiveReceiptIndex->error(), ErrorCode::$dberror);
        }

        // 获取客户余额
        $customerBalance = $this->objMCustomerBalance->getCustomerBalance($shouldReceiveData['customerId']);

        // 自动核销
        $autoOffset = self::autoOffset($customerBalance,$params['id'],$params['createTime']);
        if (!$autoOffset->isSuccess()) {
            $this->objDReceive->rollBack();
            return ResultWrapper::fail($autoOffset->getData(), $autoOffset->getErrorCode());
        }
        $detailData = [
            'customerId'             => $shouldReceiveData['customerId'],//'客户id',
            'receiptTime'            => $shouldReceiveData['createTime'],//'单据日期',
            'sourceId'               => $shouldReceiveData['id'],//'单据编号',
            'sourceNo'               => $shouldReceiveData['no'],//'单据编号',
            'financeType'            => $shouldReceiveData['financeType'],//'财务类型名称',
            'financeTypeId'          => $shouldReceiveData['financeTypeId'],//'财务类型id',
            'originId'               => $shouldReceiveData['originId'],  // 订单id
            'originNo'               => $shouldReceiveData['sourceNo'], // 订单编号
            'salesAmount'            => bcadd($shouldReceiveData['receiveMoney'], $shouldReceiveData['discountMoney'], 4),//TODO:
            'discountMoney'          => $shouldReceiveData['discountMoney'],// '优惠金额',
            'customerAmount'         => $shouldReceiveData['receiveMoney'],// '客户承担金额',
            'receivableAmount'       => $shouldReceiveData['receiveMoney'],// '应收金额',
            'actualReceivableAmount' => 0.00,//'实际收款金额',
            'receivableBalance'      => $customerBalance + $shouldReceiveData['receiveMoney'],//'应收款余额',
            'remark'                 => '应收单审核通过，本单据应收'.$shouldReceiveData['receiveMoney'].'元',//'备注',
            'createTime'             => time(),//'创建日期',
            'updateTime'             => time(),//'修改日期',
        ];

        //添加客户余额明细
        $result = $this->objMCustomerBalanceDetail->addCustomerBalanceDetail($detailData);
        if ($result->isSuccess() === false) {
            $this->objDReceive->rollBack();
            return ResultWrapper::fail($result->getData(), $result->getErrorCode());
        }

        //编辑客户余额
        $result = $this->objMCustomerBalance->addCustomerBalance($shouldReceiveData['customerId'], $shouldReceiveData['receiveMoney']);
        if ($result->isSuccess() === false) {
            $this->objDReceive->rollBack();
            return ResultWrapper::fail($result->getData(), $result->getErrorCode());
        }
        // 判断该单据是否有已生成的应付单(根据orderId查找并且付款金额大于零)
//        if ($shouldReceiveData['receiveMoney']<0 && $shouldReceiveData['offsetMoney'] == 0){
//            $whereSql = ' WHERE orderId = ' . $shouldReceiveData['orderId'] . ' AND receiveMoney > 0';
//            $sql = 'SELECT * FROM ' .$this->objDReceive->get_Table().$whereSql;
//            $repeatReceiveData = $this->objDReceive->query($sql);
//            if ($repeatReceiveData === false) {
//                return ResultWrapper::fail('退款应付单不存在', ErrorCode::$dberror);
//            }
//            if(!empty($repeatReceiveData)){
//                foreach ($repeatReceiveData as $key =>$value){
//                    $value['notOffsetMoney'] = bcadd($value['notOffsetMoney'], $shouldReceiveData['receiveMoney'],4);
//                    $value['offsetMoney'] = abs($shouldReceiveData['receiveMoney']);
//                    //更新源应付单核销金额，未核销金额
//                    $updateDate = $this->objDReceive->update(['notOffsetMoney'=>$value['notOffsetMoney'],'offsetMoney'=>$value['offsetMoney']],['id'=>$value['id']]);
//                    if ($updateDate === false) {
//                        $this->objDReceive->rollBack();
//                        return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
//                    }
//                }
//            }
//        }
        if ($beginTransactionStatus){
            $this->objDReceive->commit();
        }

        //修改订单支付状态
        $objMOrder = new MOrder($this->userCenterId, $this->enterpriseId);

        $offsetDbResult = $this->objDReceiveOffset->select(['receiveReceiptId'=>$params['id'],'type'=>StatusCode::$delete]);
        if ($offsetDbResult === false) {
            return ResultWrapper::fail($this->objDReceiveOffset->error(), ErrorCode::$dberror);
        }
        if(!empty($offsetDbResult)){
            foreach ($offsetDbResult as $offsetDbResultKey => $offsetDbResultValue){
                $orderIdDbResult = $this->objDReceive->get(['id' => $offsetDbResult[$offsetDbResultKey]['receiveReceiptId']]);
                if ($orderIdDbResult === false) {
                    return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
                }
                if (empty($orderIdDbResult)) {
                    return ResultWrapper::fail('应付单不存在', ErrorCode::$notAllowAccess);
                }
                //判断核销金额，未核销金额，来计算payStatus的状态
                $updateOrderPayData1 = ['payStatus' => StatusCode::$standard, 'payTime' => time()];
                $updateOrderPayData2 = ['id' => $orderIdDbResult['originId']];
                switch (true) {
                    case $orderIdDbResult['offsetMoney'] == $orderIdDbResult['receiveMoney'];
                        $updateOrderPayData1['payStatus'] = StatusCode::$standard;
                        break;
                    case $orderIdDbResult['offsetMoney'] == 0;
                        $updateOrderPayData1['payStatus'] = StatusCode::$delete;
                        break;
                    case $orderIdDbResult['offsetMoney'] > 0 && $orderIdDbResult['offsetMoney'] < $orderIdDbResult['receiveMoney'];
                        $updateOrderPayData1['payStatus'] = StatusCode::$partion;
                        $updateOrderPayData1['notPayMoney'] = $orderIdDbResult['notOffsetMoney'];
                }
                $orderDbResult = $objMOrder->updateOrderPayData($updateOrderPayData1, $updateOrderPayData2);
                if ($orderDbResult->isSuccess() === false) {
                    return ResultWrapper::fail($orderDbResult->getData(), $orderDbResult->getErrorCode());
                }
            }
        }

        //更新es的审核状态

        //$_id = self::createEsDocumentId($params['id'], $params['createTime']);
        //$this->objDReceive->esupdateTypeFieldVaule(['auditStatus'=>StatusCode::$auditStatus['auditPass']], $_id);

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

        $this->objFinanceCache->delSalesOutReceive($this->enterpriseId, $params['id']);
        return ResultWrapper::success($dbResult);

    }

    /**
     * 获取所有应收单数据
     * @param array $selectParams 过滤条件
     * @return ResultWrapper
     * @throws \Exception
     */
    public function getAllReceive($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['customerId']) && !empty($selectParams['customerId'])) {
            $where = empty($whereSql) ? ' WHERE ' : ' AND ';
            $whereSql .= $where . ' customerId = ' . $selectParams['customerId'];
        }
        if (isset($selectParams['offsetStatus']) && !empty($selectParams['offsetStatus'])) {
            // 数组转字符串
            $selectParams['offsetStatus'] = implode(',',$selectParams['offsetStatus']);
            $where = empty($whereSql) ? ' WHERE ' : ' AND ';
            $whereSql .= $where . ' offsetStatus in( ' . $selectParams['offsetStatus'].')';
        }
        if (isset($selectParams['receiveReceiptIds']) && !empty($selectParams['receiveReceiptIds'])) {
            $where = empty($whereSql) ? ' WHERE ' : ' AND ';
            $whereSql .= $where . ' receiveReceiptId in (' . implode(',', $selectParams['receiveReceiptIds']).')';
        }
        if (isset($selectParams['auditStatus']) && !empty($selectParams['auditStatus'])) {
            $where = empty($whereSql) ? ' WHERE ' : ' AND ';
            $whereSql .= $where . ' auditStatus = ' . $selectParams['auditStatus'];
        }
        if (isset($selectParams['shopId']) && !empty($selectParams['shopId'])) {
            $where = empty($whereSql) ? ' WHERE ' : ' AND ';
            $whereSql .= $where . ' shopId = ' . $selectParams['shopId'];
        }
        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->objDReceiveReceiptIndex->get_Table().$whereSql . ' ORDER BY createTime DESC LIMIT ' . $offset . ' , ' . $limit;
        $receiveReceiptIndexResult = $this->objDReceiveReceiptIndex->query($sql);
        if ($receiveReceiptIndexResult === false) {
            return ResultWrapper::fail($this->objDReceiveReceiptIndex->error(), ErrorCode::$dberror);
        }

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

        $receiveReceiptResult = [];
        foreach ($tableSuffix as $suffix => $receiveReceiptIds) {
            $this->objDReceive->setTable('qianniao_receive_receipt_' . $this->enterpriseId . '_' . $suffix);
          
            if($isExport){
                $dbResult = $this->objDReceive->exportSelect($receiveReceiptIds, '*', 'createTime desc');
                $tmpArray = [];
                foreach($dbResult as $key => $value){
                    $tmpArray[] = $value;
                }
                $dbResult = $tmpArray;
            }else{
                $dbResult = $this->objDReceive->select($receiveReceiptIds, '*', 'createTime desc');
                
            }

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

            if(!empty($dbResult)){
                $receiveReceiptResult = array_merge($receiveReceiptResult, self::format($dbResult));
            }
        }
    
        
        $totalSql = 'SELECT COUNT(1) as count FROM ' .$this->objDReceiveReceiptIndex->get_Table() . $whereSql;
        $dbTotalResult = $this->objDReceive->query($totalSql);
        $return = [
            'data'  => $receiveReceiptResult,
            '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($customerBalance, $receiveId, $createTime)
    {
        // 切换应收单表
        $suffix = date('Y', $createTime) . '_' . ceil(date('m', $createTime) / 3);
        $this->objDReceive->setTable('qianniao_receive_receipt_' . $this->enterpriseId . '_' . $suffix);

        // 获取应收单数据
        $shouldReceiveData = $this->objDReceive->get($receiveId);
        if ($shouldReceiveData === false) {
            return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
        }
        if (empty($shouldReceiveData)) {
            return ResultWrapper::fail('应收单id'.$receiveId.'数据为空', ErrorCode::$dberror);
        }

        // 查询这笔应收对应的订单是否有收款记录
        $this->objDReceived->setTable('qianniao_received_' . $this->enterpriseId . '_' . date('Y', $createTime) . '_' . ceil(date('m', $createTime) / 3));
        $receivedDbResult = $this->objDReceived->query('select * from '.$this->objDReceived->get_Table().' where sourceId ='.$shouldReceiveData['originId'].' and sourceId !=0 limit 1');
        if ($receivedDbResult === false) {
            $this->objDReceive->rollBack();
            return ResultWrapper::fail($this->objDReceived->error(), ErrorCode::$dberror);
        }
        if (!empty($receivedDbResult)){ //说明该应收是在线支付 现货后款
            $receiveOffsetMoney = $shouldReceiveData['receiveMoney'];
            foreach ($receivedDbResult as $receivedKey => $receivedValue){
                switch (true){
                    case bcsub($receiveOffsetMoney,$receivedValue['totalFinalMoney'],2) == 0; // 应收金额 = 收款金额
                        $receiveOffsetDate = [
                            'offsetMoney'       =>$receiveOffsetMoney,
                            'notOffsetMoney'    =>0,
                            'offsetStatus'      =>StatusCode::$standard
                        ];
                        $receiveIndexOffsetDate = [
                            'offsetStatus' => StatusCode::$standard
                        ];
                        $receivedOffsetDate = [
                            'offsetMoney'       =>$receiveOffsetMoney,
                            'notOffsetMoney'    =>0,
                            'offsetStatus'      =>StatusCode::$standard
                        ];
                        break;
                    case bcsub($receiveOffsetMoney,$receivedValue['totalFinalMoney'],2) > 0; // 应收金额 > 收款金额
                        $receiveOffsetDate = [
                            'offsetMoney'       =>$receivedValue['totalFinalMoney'],
                            'notOffsetMoney'    =>bcsub($receiveOffsetMoney,$receivedValue['totalFinalMoney'],2),
                            'offsetStatus'      =>StatusCode::$partion
                        ];
                        $receiveIndexOffsetDate = [
                            'offsetStatus' => StatusCode::$partion
                        ];
                        $receivedOffsetDate = [
                            'offsetMoney'       =>$receivedValue['totalFinalMoney'],
                            'notOffsetMoney'    =>0,
                            'offsetStatus'      =>StatusCode::$standard
                        ];
                        break;
                    case bcsub($receiveOffsetMoney,$receivedValue['totalFinalMoney'],2) < 0; // 应收金额 < 收款金额
                        $receiveOffsetDate = [
                            'offsetMoney'       =>$receiveOffsetMoney,
                            'notOffsetMoney'    =>0,
                            'offsetStatus'      =>StatusCode::$standard
                        ];
                        $receiveIndexOffsetDate = [
                            'offsetStatus' => StatusCode::$standard
                        ];
                        $receivedOffsetDate = [
                            'offsetMoney'       =>$receiveOffsetMoney,
                            'notOffsetMoney'    =>bcsub($receivedValue['totalFinalMoney'],$receiveOffsetMoney,2),
                            'offsetStatus'      =>StatusCode::$partion
                        ];
                }
                $updateOffsetStatus = $this->objDReceive->update($receiveOffsetDate,['id'=>$receiveId]);
                if ($updateOffsetStatus === false) {
                    $this->objDReceive->rollBack();
                    return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
                }

                $dbResult = $this->objDReceiveReceiptIndex->update($receiveIndexOffsetDate, ['id' => $receiveId,'createTime'=>$createTime]);
                if ($dbResult === false) {
                    $this->objDReceive->rollBack();
                    return ResultWrapper::fail($this->objDReceiveReceiptIndex->error(), ErrorCode::$dberror);
                }
                //在线支付的收款单直接核销
                $updateReceivedOffset = $this->objDReceived->update($receivedOffsetDate,['id'=>$receivedValue['id']]);
                if ($updateReceivedOffset === false) {
                    $this->objDReceive->rollBack();
                    return ResultWrapper::fail($this->objDReceived->error(), ErrorCode::$dberror);
                }
                // 记录核销明细
                //核销完成，记录核销明细
                $updateOffset = [
                    'receiveReceiptId' => $receiveId,
                    'receivedId' => $receivedValue['id'],
                    'offsetMoney' => $receiveOffsetDate['offsetMoney'],
                    'receiveCreateTime' => $shouldReceiveData['createTime'],
                    'type'  => StatusCode::$delete
                ];
                $result = $this->objDReceiveOffset->insert($updateOffset);
                if ($result === false) {
                    $this->objDReceived->rollBack();
                    return ResultWrapper::fail($this->objDReceiveOffset->error(), ErrorCode::$dberror);
                }
            }
        }else{
            $offsetMoney = 0;
            $notOffsetMoney = 0;
            $offsetStatus = 5;
            if ($customerBalance < 0 && $shouldReceiveData['receiveMoney'] > 0){//说明客户是预收款进行自动核销
                switch (true)
                {
                    case bcsub(abs($customerBalance),$shouldReceiveData['receiveMoney'],4) > 0;//说明预收款完全核销应收单金额
                        $offsetMoney = $shouldReceiveData['receiveMoney'];
                        break;
                    case bcsub(abs($customerBalance),$shouldReceiveData['receiveMoney'],4) == 0;//说明预收款刚好完全核销
                        $offsetMoney = $shouldReceiveData['receiveMoney'];
                        break;
                    case bcsub(abs($customerBalance),$shouldReceiveData['receiveMoney'],4) < 0;//说明预收款不够核销应收单金额
                        $offsetMoney = abs($customerBalance);
                        $notOffsetMoney = bcadd($customerBalance,$shouldReceiveData['receiveMoney'],4);
                        $offsetStatus = StatusCode::$partion;
                }
                //更新应付单核销状态
                $updateOffsetStatus = $this->objDReceive->update(['offsetMoney'=>$offsetMoney,'notOffsetMoney'=>$notOffsetMoney,'offsetStatus'=>$offsetStatus],['id'=>$receiveId]);
                if ($updateOffsetStatus === false) {
                    $this->objDReceive->rollBack();
                    return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
                }
                //更新应付单索引表核销状态
                unset($dbResult);
                $dbResult = $this->objDReceiveReceiptIndex->update(['offsetStatus' => $offsetStatus], ['id' => $receiveId,'createTime'=>$createTime]);
                if ($dbResult === false) {
                    $this->objDReceive->rollBack();
                    return ResultWrapper::fail($this->objDReceiveReceiptIndex->error(), ErrorCode::$dberror);
                }
                unset($dbResult);
                // 查询收款单，根据收款单找能核销的
//                $dbResult =  $this->objDReceived->select(['offsetStatus'!=StatusCode::$standard],'*','createTime asc');
                $dbResult =  $this->objDReceived->query('select * from '.$this->objDReceived->get_Table().' where customerId = '.$shouldReceiveData['customerId'].' and offsetStatus !='.StatusCode::$standard.' order by createTime asc');
                if ($dbResult === false) {
                    return ResultWrapper::fail($this->objDReceived->error(), ErrorCode::$dberror);
                }
                $receiveOffsetMoney = $shouldReceiveData['receiveMoney'];
                foreach ($dbResult as $key => $value){
                    if($receiveOffsetMoney>0){
                        switch (true){
                            case bcsub($value['notOffsetMoney'],$shouldReceiveData['receiveMoney'],2)>0: // 说明收款单能完全核销应收
                                $receivedOffset = [
                                    'offsetMoney' => bcadd($receiveOffsetMoney,$value['offsetMoney'],2),
                                    'notOffsetMoney' => bcsub($value['notOffsetMoney'],$receiveOffsetMoney,2),
                                    'offsetStatus' => StatusCode::$partion,
                                ];
                                $receiveOffsetMoney = abs(bcsub($receiveOffsetMoney,$receivedOffset['offsetMoney'],2));
                                break;
                            case bcsub($value['notOffsetMoney'],$shouldReceiveData['receiveMoney'],2) == 0: // 说明收款单能完全核销应收
                                $receivedOffset = [
                                    'offsetMoney' => $value['totalFinalMoney'],
                                    'notOffsetMoney' => 0,
                                    'offsetStatus' => StatusCode::$standard,
                                ];
                                $receiveOffsetMoney = abs(bcsub($value['totalFinalMoney'],$receivedOffset['offsetMoney'],2));
                                break;
                            case bcsub($value['notOffsetMoney'],$shouldReceiveData['receiveMoney'],2) < 0: // 说明收款单不能完全核销应收
                                $receivedOffset = [
                                    'offsetMoney' => $value['totalFinalMoney'],
                                    'notOffsetMoney' => 0,
                                    'offsetStatus' => StatusCode::$standard,
                                ];
                                $receiveOffsetMoney = abs(bcsub($value['totalFinalMoney'],$receivedOffset['offsetMoney'],2));
                        }
                        // 更新核销
                        $updateReceivedOffset = $this->objDReceived->update($receivedOffset,['id'=>$value['id']]);
                        if ($updateReceivedOffset === false) {
                            $this->objDReceive->rollBack();
                            return ResultWrapper::fail($this->objDReceived->error(), ErrorCode::$dberror);
                        }
                        //记录核销明细
                        $updateOffset = [
                            'receiveReceiptId' => $receiveId,
                            'receivedId' => $value['id'],
                            'offsetMoney' => $offsetMoney,
                            'receiveCreateTime' => $shouldReceiveData['createTime'],
                            'type'  => StatusCode::$delete
                        ];
                        $result = $this->objDReceiveOffset->insert($updateOffset);
                        if ($result === false) {
                            $this->objDReceived->rollBack();
                            return ResultWrapper::fail($this->objDReceiveOffset->error(), ErrorCode::$dberror);
                        }
                    }
                }

                return ResultWrapper::success($dbResult);

            }
        }
        return ResultWrapper::success([]);
    }

    /**
     * 导出方法
     * @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 = ['ID', '应收单编号', '客户名称', '源订单号', '创建时间', '应收类型', '优惠金额', '实际应收金额', '商铺', '状态'];       //定义标题
        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['id'] = $v['id'];
            $rows['no'] = $v['no'];
            $rows['customerName'] = $v['customerName'];
            $rows['sourceNo'] = $v['sourceNo'];
            $rows['createTime'] = date('Y-m-d H:i:s', $v['createTime']);
            $rows['financeType'] = $v['financeType'];
            $rows['discountMoney'] = $v['discountMoney'];
            $rows['receiveMoney'] = $v['receiveMoney'];
            $rows['shopName'] = $v['shopName'];
            $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;
    }

    /**
     * @param $data
     * @return mixed
     */
    public function format($data)
    {
        foreach ($data as $k => $v) {
            $data[$k]['customerCode'] = createCode(StatusCode::$code['customer']['prefix'], $v['customerId'], StatusCode::$code['customer']['length']);
            $data[$k]['no'] = StatusCode::$noPrefix[16] . '-' . $v['no'];

            switch ($v['financeType']){
                case '销售退货单':
                    $data[$k]['originNo'] = StatusCode::$noPrefix[6].'-'.$v['originNo'];
                    break;
                case '销售单':
                    $data[$k]['originNo'] = StatusCode::$noPrefix[1].'-'.$v['originNo'];
                    break;
            }
        }
        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->objDReceive->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->objDReceive->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);
    }
}