399 lines
10 KiB
PHP
399 lines
10 KiB
PHP
<?php
|
||
/**
|
||
* Created by PhpStorm.
|
||
* User: king/QQ:995265288
|
||
* Date: 2019-06-19
|
||
* Time: 16:56
|
||
*/
|
||
|
||
namespace app\backend\modules\excelRecharge\controllers;
|
||
|
||
|
||
use app\backend\models\excelRecharge\DetailModel;
|
||
use app\backend\models\excelRecharge\RecordsModel;
|
||
use app\common\helpers\Url;
|
||
use app\common\services\credit\ConstService;
|
||
use app\common\services\finance\BalanceChange;
|
||
use app\common\services\finance\PointService;
|
||
use Yunshop\Love\Common\Services\LoveChangeService;
|
||
use app\backend\modules\member\models\Member;
|
||
|
||
|
||
class ConfirmController extends PageController
|
||
{
|
||
private $fileContent;
|
||
|
||
/**
|
||
* @var int
|
||
*/
|
||
private $handleTotal = 0;
|
||
|
||
/**
|
||
* @var int
|
||
*/
|
||
private $failureTotal = 0;
|
||
|
||
/**
|
||
* @var string
|
||
*/
|
||
private $handAmount = '0';
|
||
|
||
|
||
/**
|
||
* @var string
|
||
*/
|
||
private $successAmount = '0';
|
||
|
||
/**
|
||
* @var string
|
||
*/
|
||
private $phone = '';
|
||
|
||
//批量充值提交
|
||
public function index()
|
||
{
|
||
if ($this->rechargeType() && $this->rechargeTypeValidator()) {
|
||
return $this->confirm();
|
||
}
|
||
return $this->typeError();
|
||
}
|
||
|
||
/**
|
||
* 确认充值
|
||
*
|
||
* @return mixed|void
|
||
*/
|
||
private function confirm()
|
||
{
|
||
$excelFile = $this->excelFile();
|
||
|
||
if ($excelFile
|
||
&& $excelFile->isValid()
|
||
&& in_array($excelFile->getClientOriginalExtension(), ['xls', 'xlsx'])
|
||
) {
|
||
return $this->rechargeStart();
|
||
}
|
||
return $this->excelError();
|
||
}
|
||
|
||
private function rechargeStart()
|
||
{
|
||
$recordsId = 0;
|
||
$positionId = &$recordsId;
|
||
|
||
$recordsModel = new RecordsModel();
|
||
|
||
$handleRechargeData = $this->handleRecharge($positionId);
|
||
$recordsModel->fill([
|
||
'uniacid' => \YunShop::app()->uniacid,
|
||
'total' => $this->handleTotal,
|
||
'amount' => $this->handAmount,
|
||
'failure' => $this->failureTotal,
|
||
'success' => $this->successAmount,
|
||
'source' => $this->rechargeType(),
|
||
'remark' => ''
|
||
]);
|
||
$recordsModel->save();
|
||
$positionId = $recordsModel->id;
|
||
|
||
//插入充值详细记录
|
||
DetailModel::insert($handleRechargeData);
|
||
|
||
return $this->successJson('充值成功');
|
||
}
|
||
|
||
/**
|
||
* @return string
|
||
*/
|
||
private function messageContent()
|
||
{
|
||
$successTotal = $this->handleTotal - $this->failureTotal;
|
||
|
||
return "执行数量{$this->handleTotal}，成功数量{$successTotal}，失败数量{$this->failureTotal}";
|
||
}
|
||
|
||
private function handleRecharge(&$recordsId)
|
||
{
|
||
// $this->uploadExcel();
|
||
// $values = $this->getRow();
|
||
|
||
$importData = \app\exports\ExcelService::importToArray($this->excelFile());
|
||
|
||
//表格数据
|
||
$values = $importData[0];
|
||
array_shift($values); // 删除标题
|
||
|
||
$data = [];
|
||
if($this->genre() == 2){ //1 是会员ID， 2 是手机号
|
||
$phones = array_column($values,null,0);
|
||
$phone = array_keys($phones);
|
||
$result = Member::uniacid()->select('uid','mobile')->whereIn('mobile',$phone)->get();
|
||
|
||
foreach ($result as $value){
|
||
$phones[$value->mobile][0] = $value->uid;
|
||
}
|
||
unset($phone);
|
||
unset($value);
|
||
unset($result);
|
||
$values = $phones;
|
||
}
|
||
|
||
foreach ($values as $key => $value) {
|
||
$this->phone = trim($value['0']);
|
||
$amount = trim($value[1]);
|
||
$memberId = trim($value[0]);
|
||
|
||
$data[] = $this->_handleRecharge($recordsId, $memberId, $amount);
|
||
}
|
||
return $data;
|
||
}
|
||
|
||
private function _handleRecharge(&$recordsId, $memberId, $amount)
|
||
{
|
||
$this->handleTotal += 1;
|
||
$this->handAmount += $amount;
|
||
|
||
|
||
try {
|
||
$rechargeFunc = $this->batchRechargeFunc();
|
||
|
||
$result = $this->$rechargeFunc($memberId, $amount);;
|
||
|
||
} catch (\Exception $exception) {
|
||
|
||
$result = $exception->getMessage();
|
||
}
|
||
|
||
if ($result === true) {
|
||
$status = 1;
|
||
$remark = '';
|
||
$this->successAmount += $amount;
|
||
} else {
|
||
$this->failureTotal += 1;
|
||
if($this->phone){
|
||
$remark = $this->phone."充值失败" ;
|
||
}else{
|
||
$remark = "充值失败" . $result;
|
||
}
|
||
$status = 0;
|
||
|
||
}
|
||
|
||
return [
|
||
'uniacid' => \YunShop::app()->uniacid,
|
||
'amount' => $amount,
|
||
'member_id' => $memberId,
|
||
'recharge_id' => &$recordsId,
|
||
'remark' => $remark,
|
||
'status' => $status,
|
||
'created_at' => time(),
|
||
'updated_at' => time()
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 充值类型错误
|
||
*
|
||
* @return mixed
|
||
*/
|
||
private function typeError()
|
||
{
|
||
return $this->errorJson("错误的批量充值类型");
|
||
}
|
||
|
||
/**
|
||
* Excel 错误
|
||
*
|
||
* @return mixed
|
||
*/
|
||
private function excelError()
|
||
{
|
||
return $this->errorJson("错误的Excel文件");
|
||
}
|
||
|
||
/**
|
||
* 错误
|
||
*
|
||
* @param $message
|
||
* @return mixed
|
||
*/
|
||
private function errorMessage($message)
|
||
{
|
||
$this->errorJson($message);
|
||
|
||
return parent::index();
|
||
}
|
||
|
||
/**
|
||
* 批量充值类型方法
|
||
*
|
||
* @return string
|
||
*/
|
||
private function batchRechargeFunc()
|
||
{
|
||
$batchType = $this->rechargeType();
|
||
|
||
$func = 'batchRecharge' . ucfirst(strtolower($batchType));
|
||
|
||
return $func;
|
||
}
|
||
|
||
/**
|
||
* 批量充值类型
|
||
*
|
||
* @return string
|
||
*/
|
||
private function rechargeType()
|
||
{
|
||
return request()->batch_type;
|
||
}
|
||
|
||
/**
|
||
* 第一列的值是手机号还是会员ID
|
||
* @return mixed
|
||
*/
|
||
private function genre()
|
||
{
|
||
return request()->genre;
|
||
}
|
||
|
||
/**
|
||
* 爱心值类型
|
||
*
|
||
* @return string
|
||
*/
|
||
private function rechargeTypeOfLove()
|
||
{
|
||
return request()->love_type;
|
||
}
|
||
|
||
/**
|
||
* 批量充值类型验证
|
||
*
|
||
* @return bool
|
||
*/
|
||
private function rechargeTypeValidator()
|
||
{
|
||
if (is_callable(static::class, $this->batchRechargeFunc())) {
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* 批量充值Excel文件
|
||
*
|
||
* @return array|\Illuminate\Http\UploadedFile|null
|
||
*/
|
||
private function excelFile()
|
||
{
|
||
return request()->file('batch_recharge');
|
||
}
|
||
|
||
/**
|
||
* 上传批量充值Excel文件
|
||
*/
|
||
private function uploadExcel()
|
||
{
|
||
$excelFile = $this->excelFile();
|
||
|
||
$realPath = $excelFile->getRealPath();
|
||
$extension = $excelFile->getClientOriginalExtension();
|
||
$originalName = $excelFile->getClientOriginalName();
|
||
|
||
$newOriginalName = md5($originalName . str_random(6)) . "." . $extension;
|
||
|
||
\Storage::disk('recharge')->put($newOriginalName, file_get_contents($realPath));
|
||
|
||
$this->fileContent = \Excel::load(storage_path($this->path) . '/' . $newOriginalName);
|
||
}
|
||
|
||
/**
|
||
* @return array
|
||
* @throws \PHPExcel_Exception
|
||
*/
|
||
private function getRow()
|
||
{
|
||
$sheet = $this->fileContent->getActiveSheet();
|
||
|
||
// $highestRow = $sheet->getHighestRow();
|
||
// $highestColumn = $sheet->getHighestColumn();
|
||
$highestRow = $sheet->getHighestDataRow();
|
||
$highestColumn = $sheet->getHighestDataColumn();
|
||
$highestColumnCount = \PHPExcel_Cell::columnIndexFromString($highestColumn);
|
||
$row = 2;
|
||
|
||
$values = [];
|
||
while ($row <= $highestRow) {
|
||
$rowValue = array();
|
||
$col = 0;
|
||
while ($col < $highestColumnCount) {
|
||
$rowValue[] = (string)$sheet->getCellByColumnAndRow($col, $row)->getValue();
|
||
++$col;
|
||
}
|
||
$values[] = $rowValue;
|
||
++$row;
|
||
}
|
||
return $values;
|
||
}
|
||
|
||
|
||
private function batchRechargeBalance($memberId, $rechargeValue)
|
||
{
|
||
|
||
if ($rechargeValue >= 0) {
|
||
return (new BalanceChange())->excelRecharge([
|
||
'member_id' => $memberId,
|
||
'change_value' => $rechargeValue,
|
||
'remark' => 'Excel批量充值' . $rechargeValue . "元",
|
||
'relation' => '',
|
||
'operator' => ConstService::OPERATOR_SHOP,
|
||
'operator_id' => \YunShop::app()->uid
|
||
]);
|
||
}
|
||
return (new BalanceChange())->excelRechargeSubtraction([
|
||
'member_id' => $memberId,
|
||
'change_value' => abs($rechargeValue),
|
||
'remark' => 'Excel批量充值' . $rechargeValue . "元",
|
||
'relation' => '',
|
||
'operator' => ConstService::OPERATOR_SHOP,
|
||
'operator_id' => \YunShop::app()->uid
|
||
]);
|
||
}
|
||
|
||
private function batchRechargePoint($memberId, $rechargeValue)
|
||
{
|
||
$result = (new PointService([
|
||
'point_mode' => PointService::POINT_MODE_EXCEL_RECHARGE,
|
||
'member_id' => $memberId,
|
||
'point' => $rechargeValue,
|
||
'remark' => 'Excel批量充值' . $rechargeValue,
|
||
'point_income_type' => $rechargeValue < 0 ? PointService::POINT_INCOME_LOSE : PointService::POINT_INCOME_GET
|
||
]))->changePoint();
|
||
|
||
return $result ? true : false;
|
||
}
|
||
|
||
|
||
private function batchRechargeLove($memberId, $rechargeValue)
|
||
{
|
||
if ($rechargeValue >= 0) {
|
||
return (new LoveChangeService($this->rechargeTypeOfLove()))->recharge([
|
||
'member_id' => $memberId,
|
||
'change_value' => $rechargeValue,
|
||
'operator' => ConstService::OPERATOR_MEMBER,
|
||
'operator_id' => 0,
|
||
'remark' => 'Excel批量充值' . $rechargeValue,
|
||
]);
|
||
}
|
||
return (new LoveChangeService($this->rechargeTypeOfLove()))->rechargeMinus([
|
||
'member_id' => $memberId,
|
||
'change_value' => abs($rechargeValue),
|
||
'operator' => ConstService::OPERATOR_MEMBER,
|
||
'operator_id' => 0,
|
||
'remark' => 'Excel批量充值' . $rechargeValue,
|
||
]);
|
||
}
|
||
|
||
}
|