huahuibao/common/services/xhMerchantAssetService.php

<?php

namespace common\services;

use biz\merchant\services\MerchantExtendService;
use biz\message\services\InformAdminService;
use biz\stat\services\StatIncomeCategoryService;
use biz\stat\services\StatIncomeSourceService;
use biz\wx\services\WxOpenService;
use Yii;
use common\components\configDict;
use common\components\stringUtil;
use common\components\wxUtil;
use common\services\xhGoodsService;
use common\models\xhMerchantAsset;
use common\models\xhUser;
use common\models\xhMerchantCapital;
use common\services\xhAdminService;
use common\services\xhTMessageService;
use common\services\xhOrderGoodsService;

class xhMerchantAssetService
{
	
	public static function getByMerchantId($id)
	{
		$condition = ['merchantId' => $id];
		$merchant = xhMerchantAsset::getByCondition($condition);
		return $merchant;
	}
	
	/**
	 * 资产初始化，计算总量保存到xhMerchantAsset
	 */
	public static function assetInit($merchantId)
	{
		set_time_limit(0);
		//计算总收入
		$income = Yii::$app->db->createCommand("SELECT SUM(amount) as totalIncome FROM xhMerchantCapital WHERE io=1 and merchantId={$merchantId}")->queryOne();
		$totalIncome = $income['totalIncome'];
		//计算总粉丝数
		$totalFans = xhUser::find()->andWhere(['subscribe' => 1, 'merchantId' => $merchantId])->count('id');
		//计算访问总量
		$visit = Yii::$app->db->createCommand("SELECT SUM(riseNum) as num FROM xhStatVisitByDay WHERE merchantId={$merchantId}")->queryOne();
		$totalVisit = $visit['num'];
		//计算总交易量
		$totalDeal = xhMerchantCapital::find()->andWhere(['io' => 1, 'merchantId' => $merchantId])->count('id');
		$data = ['totalDeal' => $totalDeal, 'totalVisit' => $totalVisit, 'totalFans' => $totalFans, 'totalIncome' => $totalIncome];
		self::updateByMerchantId($merchantId, $data);
	}
	
	public static function updateByMerchantId($merchantId, $data)
	{
		xhMerchantAsset::updateByCondition(['merchantId' => $merchantId], $data);
		return self::refreshByMerchantId($merchantId);
	}
	
	public static function refreshByMerchantId($merchantId)
	{
		$key = configDict::getCacheKey('merchantAsset') . $merchantId;
		Yii::$app->redis->executeCommand('DEL', [$key]);
		return self::getByMerchantId($merchantId);
	}
	
	//收入后资产变更 shish 2019.12.24
	public static function incomeChangeAsset($merchant, $merchantAsset, $shopId, $updateData, $order, $capitalType, $isRecharge = false)
	{
		$merchantId = $merchant['id'];
		$openMerchant = WxOpenService::getWxInfo();
		$orderId = $order['id'];
		$date = date("Y-m-d H:i");
		$totalFee = 0;
		$payWayList = configDict::getConfig('payWayName');
		$payWay = isset($order['payWay']) ? $order['payWay'] : 0;
		$payWay = $payWayList[$payWay];
		$userId = isset($order['userId']) ? $order['userId'] : 0;
		$user = xhUserService::getById($userId);
		$userName = isset($user['userName']) ? $user['userName'] : '游客';
		//充值支付涉及的流水类型列表
		$typeList = configDict::getConfig('capitalType');
		//根据流水类型定制通知内容
		switch ($capitalType) {
			//购买商品
			case $typeList['xhOrder']['id']:
				$totalFee = $order['actPrice'];
				$goodsList = xhOrderGoodsService::getAllByOrderId($orderId);
				if (!empty($goodsList)) {
					foreach ($goodsList as $goodsKey => $goodsVal) {
						$goodsId = $goodsVal['goodsId'];
						$goods = xhGoodsService::getById($goodsId);
						if (!empty($goods)) {
							$actualSold = stringUtil::calcAdd($goods['actualSold'], 1);
							xhGoodsService::updateById($goodsId, ['actualSold' => $actualSold]);//商品被售出数量+1
						}
					}
				}
				//sourceType 0商城 1门店 2微信朋友圈 3美团
				//收入提醒 shish 2020.1.30
				$params = ['sourceType' => $order['sourceType'], 'miniAppId' => $openMerchant['miniAppId'], 'orderId' => $orderId];
				$type = 'income';
				InformAdminService::addInform($shopId, $type, $params);
				break;
			default:
		}
		self::updateByMerchantId($merchantId, $updateData);
		
		if ($isRecharge == false) {
			//数据统计，以下一定要排后面，否则数据不准确
			xhStatIncomeService::replace($merchantId, $totalFee, $order['payWay']);
			xhStatIncomeMonthService::replace($merchantId, $totalFee, $order['payWay']);
			StatIncomeSourceService::replaceData([
				'merchantId' => $order['merchantId'],
				'sourceType' => $order['sourceType'],
				'amount' => $totalFee,
				'payWay' => $order['payWay']
			]);
		}
	}
	
	public static function add($data)
	{
		$return = xhMerchantAsset::add($data);
		return $return;
	}
	
	public static function withdraw()
	{
		$all = xhMerchantService::getAllByCondition(['status' => 1]);
		if (empty($all)) {
			return false;
		}
		foreach ($all as $merchant) {
			$connection = Yii::$app->db;//事务处理
			$transaction = $connection->beginTransaction();
			try {
				$merchantId = $merchant['id'];
				$merchantAsset = self::getByMerchantId($merchantId);
				$amount = $merchantAsset['balance'];
				if ($amount <= 0) {
					Yii::info('余额不足');
					return false;
				}
				$mBalance = stringUtil::calcSub($merchantAsset['balance'], $amount);
				$newFreezeBalance = stringUtil::calcAdd($merchantAsset['freezeBalance'], $amount);
				$date = date("Y-m-d H:i:s");
				
				$id = stringUtil::generateMerchantCashOrderNo($merchantId);
				$cashData = ['id' => $id, 'amount' => $amount, 'merchantId' => $merchantId, 'balance' => $mBalance, 'addTime' => time(), 'createTime' => $date];
				$order = xhDrawCashService::add($cashData);
				$orderId = $order['id'];
				xhMerchantAssetService::updateByMerchantId($merchantId, ['balance' => $mBalance, 'freezeBalance' => $newFreezeBalance]);
				
				$now = time();
				$capitalTypeArray = configDict::getConfig('capitalType', 'xhDrawCash');
				$capitalType = $capitalTypeArray['id'];
				$mIncome = $merchantAsset['totalIncome'];
				$mExpend = $merchantAsset['totalExpend'];
				$payWay = configDict::getConfig('payWay', 'other');
				$capitalData = [
					'relateId' => (string)$orderId,
					'balance' => $mBalance,
					'totalIncome' => $mIncome,
					'totalExpend' => $mExpend,
					'amount' => $amount,
					'io' => 0,
					'payWay' => $payWay,
					'event' => '申请提现',
					'merchantId' => $merchantId,
					'userId' => 0,
					'userName' => '',
					'alipayId' => '',
					'affectBalance' => 1,//会影响商家的余额
					'createTime' => $date,
					'addTime' => $now,
					'capitalType' => $capitalType,
					'operateId' => 0,
				];
				xhMerchantCapitalService::add($capitalData);//商家资金流水记录增加

//				xhCommonService::sendMobileMsg('15280215347', '有客户申请提现，请及时处理');
				
				$id = $orderId;
				$draw = xhDrawCashService::getById($id);
				$drawAmount = isset($draw['amount']) ? floatval($draw['amount']) : 0;
				if ($draw['status'] == 1) {
					Yii::info('已经完成转账，请不要重复请求!');
					return;
				}
				$merchantId = isset($draw['merchantId']) ? $draw['merchantId'] : 0;
				//$admin = xhAdminToMerchantService::getAdminByMerchantId($merchantId);
				$time = strtotime(date("Y-m-d"));
				$income = xhStatIncomeService::getByIds($merchantId, $time);
				$amount = isset($income['amount']) ? $income['amount'] : 0;
				$merchantExtInfo = xhMerchantExtendService::getByMerchantId($merchantId);//取支付宝帐号
				
				$asset = xhMerchantAssetService::getByMerchantId($merchantId);
				
				if ($merchantExtInfo['alipayAccount'] == '') {
					Yii::info('转账接收方的支付宝帐号为空');
					return;
				}
				if ($drawAmount == 0) {
					Yii::info('转账金额为0');
					return;
				}
				$alipayWap = Yii::getAlias("@vendor/alipayWap");
				require_once($alipayWap . '/aop/AopClient.php');
				require_once($alipayWap . '/aop/request/AlipayFundTransToaccountTransferRequest.php');

				$extend = MerchantExtendService::getByMerchantId($merchantId);
				$config = [
					//应用ID,您的APPID。
					'app_id' => $extend['alipayPId'],
					//商户私钥，您的原始格式RSA私钥
					'merchant_private_key' => $extend['alipayKey'],
					//异步通知地址
					'notify_url' => Yii::$app->params['frontUrl'] . "/notice/alipay-async",
					//同步跳转
					'return_url' => "",
					//编码格式
					'charset' => "UTF-8",
					//签名方式
					'sign_type' => "RSA2",
					//支付宝网关
					'gatewayUrl' => "https://openapi.alipay.com/gateway.do",
					//支付宝公钥,查看地址：https://openhome.alipay.com/platform/keyManage.htm 对应APPID下的支付宝公钥。
					'alipay_public_key' => $extend['alipayPublicKey'],
				];

				$aop = new \AopClient();
				$aop->gatewayUrl = 'https://openapi.alipay.com/gateway.do';
				$aop->appId = $config['app_id'];
				$aop->rsaPrivateKey = $config['merchant_private_key'];
				$aop->alipayrsaPublicKey = $config['alipay_public_key'];
				$aop->apiVersion = '1.0';
				$aop->signType = 'RSA2';
				$aop->postCharset = 'UTF-8';
				$aop->format = 'json';
				$request = new \AlipayFundTransToaccountTransferRequest ();
				$request->setBizContent("{" .
					"\"out_biz_no\":\"" . $id . "\"," .
					"\"payee_type\":\"ALIPAY_LOGONID\"," .
					"\"payee_account\":\"" . $merchantExtInfo['alipayAccount'] . "\"," .
					"\"amount\":\"" . $drawAmount . "\"," .
					"\"payee_real_name\":\"" . $merchantExtInfo['alipayAccountName'] . "\"," .
					"\"payer_show_name\":\"厦门中花汇信息科技有限公司\"," .
					"\"remark\":\"提现申请\"" .
					"  }");
				$result = $aop->execute($request);
				$responseNode = str_replace(".", "_", $request->getApiMethodName()) . "_response";
				$resultCode = $result->$responseNode->code;
				$returnOrderId = $result->$responseNode->order_id;
				if (!empty($resultCode) && $resultCode == 10000) {
					xhDrawCashService::updateById($id, ['thirdSerialNumber' => $returnOrderId, 'status' => 1]);
					$remainAmount = stringUtil::calcSub($asset['freezeBalance'], $drawAmount);
					xhMerchantAssetService::updateByMerchantId($merchantId, ['freezeBalance' => $remainAmount]);
					$transaction->commit();
					/*
					$openId = $admin['openId'];
					$openMerchant = xhWxOpenService::getMerchant();//取平台绑定的商家
					$openMerchantId = $openMerchant['id'];
					$allTM = xhTMessageService::getList($openMerchantId);
					$shortTempId = 'OPENTM201319876';
					if(isset($allTM[$shortTempId])){
					$tempId =  $allTM[$shortTempId];
					$data = [
						"touser" => $openId,
						"template_id" => $tempId,
						"url" => Yii::$app->params['adminUrl'] . '/draw-cash/list',
						"data" => [
							"first" => ["value" => '已经完成结算。', "color" => "#173177"],
							"keyword1" => ["value" => '当天', "color" => "#173177"],
							"keyword2" => ["value" => $amount . '元', "color" => "#173177"],
							"remark" => ["value" => "支付宝收入：{$drawAmount}元，已汇入您的帐户。\n点击查看结算记录", "color" => "#173177"]
						]
					];
					}
					wxUtil::sendTaskInform($data, $openMerchant);
					*/
					//xhCommonService::sendMobileMsg($admin['mobile'], "您的提现金额：{$drawAmount}元已经到帐，请注意查收。");
				} else {
					$msg = $result->$responseNode->msg;
					$sub_code = $result->$responseNode->sub_code;
					$sub_msg = $result->$responseNode->sub_msg;
					Yii::info("转帐失败，原因：code:" . $resultCode . " msg:" . $msg . " sub_code:" . $sub_code . " sub_msg:" . $sub_msg);
					$transaction->rollBack();
				}
			} catch (Exception $e) {
				$transaction->rollBack();
			}
		}
		
	}
}