<?php
/**
* Created by PhpStorm.
* User: Gss
* Date: 2021/4/8 0008
* Time: 19:35
*/
namespace JinDouYun\Model\Finance;
use Jindouyun\Cache\EnterpriseCache;
use JinDouYun\Dao\Customer\DCustomer;
use JinDouYun\Dao\Order\DOrderIndex;
use JinDouYun\Model\System\MSystemPushMessage;
use Mall\Framework\Core\ErrorCode;
use Mall\Framework\Core\StatusCode;
use Mall\Framework\Core\ResultWrapper;
use JinDouYun\Model\Order\MPay;
use JinDouYun\Dao\Finance\DRefund;
use JinDouYun\Dao\Finance\DRefundAccount;
use JinDouYun\Dao\Finance\DRefundIndex;
use JinDouYun\Dao\Order\DOrder;
use JinDouYun\Dao\Finance\DPay;
use JinDouYun\Dao\Finance\DPayReceiptIndex;
use JinDouYun\Dao\Finance\DReceive;
use JinDouYun\Dao\Finance\DReceiveReceiptIndex;
use Util\WeiXin\Pay;
class MRefund
{
private $enterpriseId;
private $userCenterId;
private $objDReceiveReceiptIndex;
private $objDReceive;
private $objDay;
private $objDPayReceiptIndex;
private $objDOrder;
private $objDRefund;
private $objDRefundIndex;
private $objDRefundAccount;
private $objMFinanceType;
private $objMCustomerBalance;
private $objMCustomerBalanceDetail;
private $objMSupplierBalanceDetail;
private $objMSupplierBalance;
private $cutTable = 200000;
/**
* @param $enterpriseId
* @param $userCenterId
* @throws \Exception
*/
public function __construct($enterpriseId, $userCenterId)
{
$this->userCenterId = $userCenterId;
$this->enterpriseId = $enterpriseId;
$this->objDReceive = new DReceive('finance');
$this->objDReceiveReceiptIndex = new DReceiveReceiptIndex('finance');
$this->objDay = new DPay('finance');
$this->objDPayReceiptIndex = new DPayReceiptIndex('finance');
$this->objDOrder = new DOrder();
$this->objDRefund = new DRefund('finance');
$this->objDRefundIndex = new DRefundIndex('finance');
$this->objDRefundAccount = new DRefundAccount('finance');
$this->objMFinanceType = new MFinanceType($enterpriseId, $userCenterId);
$this->objMCustomerBalance = new MCustomerBalance($enterpriseId, $userCenterId);
$this->objMCustomerBalanceDetail = new MCustomerBalanceDetail($enterpriseId,$userCenterId);
$this->objMSupplierBalance = new MSupplierBalance($enterpriseId, $userCenterId);
$this->objMSupplierBalanceDetail = new MSupplierBalanceDetail($enterpriseId, $userCenterId);
// $this->objDReceiveOffset->setTable('qianniao_receive_offset_'. $enterpriseId);
$this->objDRefund->setTable('qianniao_refund_' . $enterpriseId . '_' . date('Y') . '_' . ceil(date('m') / 3));
$this->objDRefundAccount->setTable('qianniao_refund_account_' . $enterpriseId . '_' . date('Y') . '_' . ceil(date('m') / 3));
$this->objDRefundIndex->setTable('qianniao_refund_index_' . $enterpriseId);
$this->objDPayReceiptIndex->setTable('qianniao_pay_receipt_index_'.$this->enterpriseId);
$this->objDReceiveReceiptIndex->setTable('qianniao_receive_receipt_index_'.$this->enterpriseId);
}
/**
* 添加退款单
*/
public function addRefund($params, $autoCheck= false)
{
$accountList = $params['accountList'];
unset($params['accountList']);
$beginTransactionStatus = $this->objDRefund->beginTransaction();
// 生成编号
$dbResult = $this->objDRefund->get('createTime >='.strtotime(date('Ymd'.'0:0:0')), 'no', 'createTime desc');
if ($dbResult === false) {
return ResultWrapper::fail($this->objDRefund->error(), ErrorCode::$dberror);
}
if(empty($dbResult)){
$params['no'] = createSerialNumberByDate('');
}else{
$params['no'] = createSerialNumberByDate($dbResult['no']);
}
$refundId = $this->objDRefund->insert($params);
if ($refundId === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($this->objDRefund->error(), ErrorCode::$dberror);
}
//索引表数据
$indexData = [
'no' => $params['no'],
'refundId' => $refundId,
'unitId' => isset($params['unitId']) ? isset($params['unitId']): '',
'originId' => isset($params['originId']) ? isset($params['originId']): '',
'originNo' => isset($params['originNo']) ? isset($params['originNo']): '',
'type' => getArrayItem($params,'type',''),
'payType' => getArrayItem($params,'payType',''),
'currentAccountName' => $params['currentAccountName'],//制单人
'sourceNo' => $params['sourceNo'],
'auditStatus' => $params['auditStatus'],
'financeTypeId' => $params['financeTypeId'],
'financeType' => $params['financeType'],
'createTime' => $params['createTime'],
'updateTime' => $params['updateTime'],
'refundTime' => $params['refundTime'],
];
$result = $this->objDRefundIndex->insert($indexData);
if ($result === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($this->objDRefundIndex->error(), ErrorCode::$dberror);
}
unset($result);
//收款账户数据
foreach ($accountList as $account) {
$account['operatorId'] = $this->userCenterId;
$account['refundId'] = $refundId;
$account = self::buildAccountData($account);
$result = $this->objDRefundAccount->insert($account);
if ($result === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($this->objDRefundAccount->error(), ErrorCode::$dberror);
}
unset($result);
}
if( $beginTransactionStatus ){
$this->objDRefund->commit();
}
return ResultWrapper::success($refundId);
}
public static function buildAccountData(array $params)
{
return [
'refundId' => isset($params['refundId']) ? $params['refundId'] : 0,
'accountId' => isset($params['accountId']) ? $params['accountId'] : 0,
'accountNumber' => isset($params['accountNumber']) ? $params['accountNumber'] : 0,
'accountName' => getArrayItem($params, 'accountName', ''),
'money' => isset($params['money']) ? $params['money'] : 0,
'payWay' => isset($params['payWay']) ? $params['payWay'] : 0,
'remark' => isset($params['remark']) ? $params['remark'] : '',
'createTime' => time(),
'updateTime' => time(),
'operatorId' => isset($params['operatorId']) ? $params['operatorId'] : 0,
];
}
/**
* 修改退款单
*/
public function editRefund($params)
{
$this->objDRefund->setTable('qianniao_refund_' . $this->enterpriseId . '_' . date('Y', $params['createTime']) . '_' . ceil(date('m', $params['createTime']) / 3));
$this->objDRefundAccount->setTable('qianniao_refund_account_' . $this->enterpriseId . '_' . date('Y', $params['createTime']) . '_' . ceil(date('m', $params['createTime']) / 3));
$beginTransactionstatus = $this->objDRefund->beginTransaction();
$accountList = $params['accountList'];
unset($params['accountList']);
$params['money'] = 0;
foreach ($accountList as $account) {
$params['money'] += $account['money'];
}
$refundId = $params['id'];
unset($params['id']);
$dbResult = $this->objDRefund->update($params, $refundId);
if ($dbResult === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($this->objDRefund->error(), ErrorCode::$dberror);
}
//索引表数据
$indexData = [
'refundId' => $refundId,
'unitId' => isset($params['unitId']) ? isset($params['unitId']): '',
'originId' => isset($params['originId']) ? isset($params['originId']): '',
'originNo' => isset($params['originNo']) ? isset($params['originNo']): '',
'type' => getArrayItem($params,'type',''),
'currentAccountName' => $params['currentAccountName'],
'no' => $params['no'],
'sourceNo' => $params['sourceNo'],
'auditStatus' => $params['auditStatus'],
'financeTypeId' => $params['financeTypeId'],
'financeType' => $params['financeType'],
'createTime' => $params['createTime'],
'updateTime' => $params['updateTime'],
'refundTime' => $params['refundTime'],
];
$result = $this->objDRefundIndex->update($indexData,['refundId'=>$refundId]);
if ($result === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($this->objDRefundIndex->error(), ErrorCode::$dberror);
}
unset($result);
//收款账户数据
foreach ($accountList as $account) {
if (isset($account['id'])) {
$account['refundId'] = $refundId;
$account['operatorId'] = $this->userCenterId;
$account['updateTime'] = $params['updateTime'];
$result = $this->objDRefundAccount->update($account, $account['id']);
if ($result === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($this->objDRefundAccount->error(), ErrorCode::$dberror);
}
unset($result);
}
}
if($beginTransactionstatus){
$this->objDRefund->commit();
}
return ResultWrapper::success($dbResult);
}
/**
* 退款单审核
*/
public function updateRefundStatus($params)
{
$this->objDRefund->setTable('qianniao_refund_' . $this->enterpriseId . '_' . date('Y', $params['createTime']) . '_' . ceil(date('m', $params['createTime']) / 3));
$this->objDRefundAccount->setTable('qianniao_refund_account_' . $this->enterpriseId . '_' . date('Y', $params['createTime']) . '_' . ceil(date('m', $params['createTime']) / 3));
// 查询退款单数据
$refundData = $this->objDRefund->get(['id' => $params['id']]);
if ($refundData === false) {
return ResultWrapper::fail($this->objDRefund->error(), ErrorCode::$dberror);
}
if(empty($refundData)){
return ResultWrapper::fail('要操作得单据不存在', ErrorCode::$contentNotExists);
}
if($refundData['auditStatus'] == StatusCode:: $auditStatus['auditPass']){
return ResultWrapper::fail('当前退款单已经审核过了', ErrorCode::$notAllowAccess);
}
// 1,根据退款单中的originId（来源订单id）查询订单的source来源是否为销售订单
$orderIndexId = $refundData['originId'];
$objDOrderIndex = new DOrderIndex('default');
$objDOrderIndex->setTable('qianniao_order_index_' . $this->enterpriseId);
$orderData = $objDOrderIndex->get($orderIndexId);
if($orderData === false){
return ResultWrapper::fail($objDOrderIndex->error(), ErrorCode::$dberror);
}
if( empty($orderData) ){
return ResultWrapper::fail('该订单为空', ErrorCode::$contentNotExists);
}
// 根据订单的来源判断是否为销售订单
if($orderData['source'] == StatusCode::$orderType['saleOrder']){
// 根据客户id (customerId) 获取 openId
$customerId = $orderData['customerId'];
$objDCustomer = new DCustomer('default');
$objDCustomer->setTable('qianniao_customer_' . $this->enterpriseId);
$customerData = $objDCustomer->get($customerId);
if($customerData === false){
return ResultWrapper::fail($objDCustomer->error(), ErrorCode::$dberror);
}
if( empty($customerData) ){
return ResultWrapper::fail('查找不到该客户数据', ErrorCode::$contentNotExists);
}
// 小程序订阅消息退款通知
if (isset($customerData['openId']) && !empty($customerData['openId'])) {
// 发送小程序订阅消息
$sendMessageData = [
'time8' => ['value' => date('Y-m-d H:i:s',$orderData['createTime'])], // 下单时间
'character_string7' => ['value' => StatusCode::$noPrefix[1].'-'.$orderData['no']], // 订单编号
'amount9' => ['value' => '￥'.$refundData['money']], // 支付金额
'amount3' => ['value' => '￥'.$refundData['money']], // 退款金额
'thing1' => ['value' =>'退款成功(店主已同意退款)'], // 退款状态
];
$objMSystemPushMessage = new MSystemPushMessage($this->userCenterId,$this->enterpriseId);
$result = $objMSystemPushMessage->sendWeiXinPushMessage(7,$customerData['openId'],$sendMessageData);
if (!$result->isSuccess()) {
file_put_contents('/www/wwwroot/logs/api.junhailan.com/sendMessageError.log', date('Y-m-d H:i:s') . 'bb' . var_export($result->getData(), true) . PHP_EOL, FILE_APPEND);
}
}
}
$beginTransactionStatus = $this->objDRefund->beginTransaction();
// 更新退款单审核状态
$dbResult = $this->objDRefund->update(['auditStatus' => StatusCode:: $auditStatus['auditPass']], ['id' => $params['id']]);
if ($dbResult === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($this->objDRefund->error(), ErrorCode::$dberror);
}
// 更新退款单索引表审核状态
$dbResult = $this->objDRefundIndex->update(['auditStatus' => StatusCode:: $auditStatus['auditPass']], ['refundId' => $params['id']]);
if ($dbResult === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($this->objDRefundIndex->error(), ErrorCode::$dberror);
}
if (isset($refundData['offsetId'])){//有核销id说明有应收单id
//自动核销
//self::autoMoney($refundData['offsetId'],$refundData['money'],$refundData['createTime'],$refundData['type']);
}
if ($refundData['type'] == StatusCode::$standard){//客户
// 获取客户往来余额
$customerBalance = $this->objMCustomerBalance->getCustomerBalance($refundData['unitId']);
$detailData = [
'customerId' => $refundData['unitId'],//'客户id',
'receiptTime' => $refundData['createTime'],//'单据日期',
'sourceNo' => $refundData['no'],//'单据编号',
'sourceId' => $refundData['id'],//'单据编号',
'financeType' => $refundData['financeType'],//'财务类型名称',
'financeTypeId' => $refundData['financeTypeId'],//'财务类型id',
'originId' => $refundData['sourceId'], //
'originNo' => $refundData['sourceNo'],//
'salesAmount' => 0,//总金额
'discountMoney' => 0,// '优惠金额',
'customerAmount' => 0,// '客户承担金额',
'receivableAmount' => 0,// '应收金额',
'actualReceivableAmount' => 0,//'实际收款金额',
'refundMoney' => $refundData['money'],
'receivableBalance' => bcadd($customerBalance , $refundData['money'], 4),//'应收后余额',
'remark' => '退款单审核通过，本次退款' . $refundData['money'] . '元',//'备注',
'createTime' => time(),//'创建日期',
'updateTime' => time(),//'修改日期',
];
// 添加客户往来余额明细
$result = $this->objMCustomerBalanceDetail->addCustomerBalanceDetail($detailData);
if (!$result->isSuccess()) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($result->getData(), $result->getErrorCode());
}
// 编辑客户往来余额
$changedMoney = $refundData['money'] < 0 ? -1 * $refundData['money'] : abs($refundData['money']);
$result = $this->objMCustomerBalance->addCustomerBalance($refundData['unitId'], $changedMoney);
if (!$result->isSuccess()) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($result->getData(), $result->getErrorCode());
}
// 如果是订单生成的退款单，同步操作订单
if ( !empty($refundData['originId']) && !empty($refundData['payType'])){
// 获取订单outerTradeNo
$tableName = $this->objDOrder->getTableName('qianniao_order_' . $this->enterpriseId, $this->userCenterId, $this->cutTable);
$this->objDOrder->setTable($tableName);
$orderDate = $this->objDOrder->get($refundData['originId']);
if( $orderDate === false ){
return ResultWrapper::fail($this->objDOrder->error(), ErrorCode::$dberror);
}
if( empty($orderDate) ){
return ResultWrapper::fail('查询指定订单数据为空', ErrorCode::$contentNotExists);
}
// 读取后台设置的退款返还方式
$refundWay = StatusCode::$standard;
$objEnterpriseCache = new EnterpriseCache();
$enterSettingData = $objEnterpriseCache->getEnterpriseSetting($this->enterpriseId);
if( isset($enterSettingData['returnWay'])){
$refundWay = $enterSettingData['returnWay'];
}
// 进行退款操作
$objMPay = new MPay($this->enterpriseId, $this->userCenterId);
$result = $objMPay->refund($orderDate, false, $refundData, $refundWay);
if(!$result->isSuccess()){
$this->objDRefund->rollBack();
return ResultWrapper::fail($result->getData(), $result->getErrorCode());
}
//判断退款金额
if($refundData['money'] < $orderDate['payAmount']){
$payStatus = StatusCode::$payStatus['partRefund'];
}else{
$payStatus = StatusCode::$payStatus['refund'];
}
// 修改订单支付状态为已经退款
$updateData = [
'isRet' => StatusCode::$standard,
'retTime' => time(),
'retMoney' => $refundData['money'],
'payStatus' => $payStatus
];
$dbResult = $this->objDOrder->update($updateData, $orderDate['id']);
if($dbResult == false){
return ResultWrapper::fail($this->objDOrder->error(), ErrorCode::$dberror);
}
$objDOrderIndex = new DOrderIndex('default');
$objDOrderIndex->setTable('qianniao_order_index_'.$this->enterpriseId);
$updateData = [
'isRet' => StatusCode::$standard,
'payStatus' => $payStatus
];
$orderIndex = $objDOrderIndex->update($updateData, $orderDate['id']);
if ($orderIndex===false){
return ResultWrapper::fail($objDOrderIndex->error(),ErrorCode::$dberror);
}
}
}
if($refundData['type'] == StatusCode::$delete){
// 查询供应商当前的余额
$supplierMoney = $this->objMSupplierBalance->getSupplierBalance($refundData['unitId']);
// 组装供应商余额明细数据
$detailData = [
'supplierId' => $refundData['unitId'],
'receiptTime' => $refundData['createTime'],//'单据日期',
'no' => $refundData['no'],//'单据编号',
'financeType' => $refundData['financeType'],//'财务类型名称',
'financeTypeId' => $refundData['financeTypeId'],//'财务类型id',
'sourceId' => $refundData['sourceId'], //
'sourceNo' => $refundData['sourceNo'],
'salesAmount' => $refundData['money'],
'discountMoney' => 0.00,// '优惠金额',
'supplierAmount' => 0.00,
'shouldPayAmount' => 0.00,//实际应付金额
'actualPaidAmount' => 0,
'refundMoney' => $refundData['money'],
// 'actualPaidAmount' => $refundData['money'],
// 'shouldPayBalance' => bcadd($supplierMoney,$refundData['money'],2),//应付款余额 当前供应商余额 + 退款金额
'shouldPayBalance' => 0, // 退款直接记录退款金额
'remark' => '退款单审核通过，应付供应商'.$refundData['payMoney'].'元',//'备注',
'createTime' => time(),//'创建日期',
'updateTime' => time(),//'修改日期',
];
//供应商余额明细
$result = $this->objMSupplierBalanceDetail->addSupplierBalanceDetail($detailData);
if ($result->isSuccess() === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($result->getData(), $result->getErrorCode());
}
//供应商余额
$changedMoney = $refundData['money'];
$changedMoney = $changedMoney > 0 ? -1 * $refundData['money'] : abs($refundData['money']);
$result = $this->objMSupplierBalance->addSupplierBalance($refundData['unitId'], $changedMoney);
if ($result->isSuccess() === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($result->getData(), $result->getErrorCode());
}
}
if ($beginTransactionStatus){
$this->objDRefund->commit();
}
return ResultWrapper::success($dbResult);
}
/**
* 自动核销退款单
*/
public function autoMoney($offsetId,$money,$createTime,$type)
{
if($type == StatusCode::$standard){//type 5 说明是订单退款
//查询负应收
$suffix = date('Y', $createTime) . '_' . ceil(date('m', $createTime) / 3);
$this->objDReceive->setTable('qianniao_receive_receipt_' . $this->enterpriseId . '_' . $suffix);
$receiveDate = $this->objDReceive->get(['id'=>$offsetId]);
if ($receiveDate === false) {
return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
}
if(empty($receiveDate)){
return ResultWrapper::fail('要操作得应收单据不存在', ErrorCode::$contentNotExists);
}
//判断如果金额为负
if($receiveDate['receiveMoney'] < 0){
$updata = [ // 负应收没有核销金额一说
// $offsetMoney = $money,
// $notOffsetMoney = 0,
'offsetStatus' => StatusCode::$standard,
];
$updataIndex = [
'offsetStatus' => StatusCode::$standard,
];
$updataReceive = $this->objDReceive->update($updata,['id'=>$receiveDate['id']]);
if ($updataReceive === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($this->objDReceive->error(), ErrorCode::$dberror);
}
//更新index表核销状态
$updataReceivesIndex = $this->objDReceiveReceiptIndex->update($updataIndex,['id'=>$receiveDate['id']]);
if ($updataReceivesIndex === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($this->objDReceiveReceiptIndex->error(), ErrorCode::$dberror);
}
}
}else{// 说明是采购单
//查询负应付
$suffix = date('Y', $createTime) . '_' . ceil(date('m', $createTime) / 3);
$this->objDay->setTable('qianniao_pay_receipt_' . $this->enterpriseId . '_' . $suffix);
$payDate = $this->objDay->get(['id'=>$offsetId]);
if ($payDate === false) {
return ResultWrapper::fail($this->objDay->error(), ErrorCode::$dberror);
}
if(empty($payDate)){
return ResultWrapper::fail('要操作得单据不存在', ErrorCode::$contentNotExists);
}
//判断如果金额为负，并且财务类型为采购退款单
if($payDate['financeType'] == '采购退款单' && $payDate['payMoney'] == $money){
$updata = [
$offsetMoney = $money,
$notOffsetMoney = 0,
$offsetStatus = StatusCode::$standard,
];
$updataIndex = [
$offsetStatus = StatusCode::$standard,
];
$updataPay = $this->objDay->update($updata,['id'=>$payDate['id']]);
if ($updataPay === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($this->objDay->error(), ErrorCode::$dberror);
}
//更新index表核销状态
$updataPayIndex = $this->objDPayReceiptIndex->update($updataIndex,['id'=>$payDate['id']]);
if ($updataPayIndex === false) {
$this->objDRefund->rollBack();
return ResultWrapper::fail($this->objDPayReceiptIndex->error(), ErrorCode::$dberror);
}
}
}
return ResultWrapper::success([]);
}
/**
* 获取指定退款单信息
* @throws \Exception
*/
public function getRefundInfo($refundParams)
{
$this->objDRefund->setTable('qianniao_refund_' . $this->enterpriseId . '_' . date('Y', $refundParams['createTime']) . '_' . ceil(date('m', $refundParams['createTime']) / 3));
$this->objDRefundAccount->setTable('qianniao_refund_account_' . $this->enterpriseId . '_' . date('Y', $refundParams['createTime']) . '_' . ceil(date('m', $refundParams['createTime']) / 3));
$dbResult = $this->objDRefund->get($refundParams['id']);
if ($dbResult === false) {
return ResultWrapper::fail($this->objDRefund->error(), ErrorCode::$dberror);
}
//渲染前缀
// $dbResult['no'] = StatusCode::$noPrefix[17] . '-' . $dbResult['no'];
$accountData = $this->objDRefundAccount->select(['refundId' => $refundParams['id']]);
if ($accountData === false) {
return ResultWrapper::fail($this->objDRefundAccount->error(), ErrorCode::$dberror);
}
$accountData = array_shift($accountData);
$dbResult['accountList'] = $accountData;
//查出客户当前余额
$dbResult['currentBalanceMoney'] = !empty($dbResult['unitId']) && $dbResult['type'] == 1 ? $this->objMCustomerBalance->getCustomerBalance($dbResult['unitId']) : 0;
return ResultWrapper::success($dbResult);
}
/**
* 后台所有收款单列表
*/
public function getAllRefund($selectParams)
{
$limit = $selectParams['limit'];
unset($selectParams['limit']);
$offset = $selectParams['offset'];
unset($selectParams['offset']);
$type = $selectParams['type'];
unset($selectParams['type']);
//组装sql where条件
$whereSql = '';
if (isset($selectParams['no']) && !empty($selectParams['no'])) {
//no编号切割
$explodeNo = explode("-",$selectParams['no']);
$where = empty($whereSql) ? ' WHERE ' : ' AND ';
$whereSql .= $where . ' no = "' . $explodeNo[1] . '-' . $explodeNo[2] . '"';
}
if (isset($selectParams['financeTypeId']) && !empty($selectParams['financeTypeId'])) {
$where = empty($whereSql) ? ' WHERE ' : ' AND ';
$whereSql .= $where . ' financeTypeId = ' . $selectParams['financeTypeId'];
}
if (isset($selectParams['auditStatus']) && !empty($selectParams['auditStatus'])) {
$where = empty($whereSql) ? ' WHERE ' : ' AND ';
$whereSql .= $where . ' auditStatus = ' . $selectParams['auditStatus'];
}
if (isset($selectParams['unitId']) && !empty($selectParams['unitId'])) {
$where = empty($whereSql) ? ' WHERE ' : ' AND ';
$whereSql .= $where . ' unitId = ' . $selectParams['unitId'];
}
if (isset($selectParams['type']) && !empty($selectParams['type'])) {
$where = empty($whereSql) ? ' WHERE ' : ' AND ';
$whereSql .= $where . ' type = ' . $selectParams['type'];
}
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->objDRefundIndex->get_Table(). $whereSql . ' ORDER BY createTime DESC LIMIT ' . $offset . ' , ' . $limit;
$refundIndexResult = $this->objDRefundIndex->query($sql);
$tableSuffix = [];
foreach ($refundIndexResult as $refundIndex) {
$k = date('Y', $refundIndex['createTime']) . '_' . ceil(date('m', $refundIndex['createTime']) / 3);
$tableSuffix[$k][] = $refundIndex['refundId'];
}
$refundResult = [];
foreach ($tableSuffix as $suffix => $refundIds) {
$this->objDRefund->setTable('qianniao_refund_' . $this->enterpriseId . '_' . $suffix);
$dbResult = $this->objDRefund->select($refundIds, '*', 'createTime desc');
if ($dbResult === false) {
return ResultWrapper::fail($this->objDRefund->error(), ErrorCode::$dberror);
}
// if (!empty($dbResult)){
// //渲染前缀
// foreach ($dbResult as $key => $value){
// $dbResult[$key]['no'] = StatusCode::$noPrefix[17] . '-' . $value['no'];
// }
// }
$refundResult = array_merge($refundResult, $dbResult);
}
$totalSql = 'SELECT COUNT(1) as count FROM ' .$this->objDRefundIndex->get_Table() . $whereSql;
$dbTotalResult = $this->objDRefundIndex->query($totalSql);
if ($dbTotalResult === false) {
return ResultWrapper::fail($this->objDRefundIndex->error(), ErrorCode::$dberror);
}
if(empty($dbTotalResult)){
return ResultWrapper::success([]);
}
$return = [
'data' => self::format($refundResult),
'total' => $dbTotalResult[0]['count']
];
return ResultWrapper::success($return);
}
public function format($data)
{
foreach( $data as $k => $v ){
$data[$k]['no'] = StatusCode::$noPrefix[20].'-'.$v['no'];
switch ($v['financeType']){
case '订单退货退款':
$data[$k]['originNo'] = StatusCode::$noPrefix[1].'-'.$v['originNo'];
$data[$k]['sourceNo'] = StatusCode::$noPrefix[15].'-'.$v['sourceNo'];
break;
case '采购退货收款':
$data[$k]['originNo'] = StatusCode::$noPrefix[2].'-'.$v['originNo'];
$data[$k]['sourceNo'] = StatusCode::$noPrefix[4].'-'.$v['sourceNo'];
break;
case '订单完结退款':
$data[$k]['originNo'] = StatusCode::$noPrefix[1].'-'.$v['originNo'];
$data[$k]['sourceNo'] = StatusCode::$noPrefix[1].'-'.$v['sourceNo'];
break;
case '订单取消退款':
$data[$k]['originNo'] = StatusCode::$noPrefix[1].'-'.$v['originNo'];
$data[$k]['sourceNo'] = StatusCode::$noPrefix[1].'-'.$v['sourceNo'];
}
}
return $data;
}
}