huahuibao/biz-hd/user/services/UserOldDataService.php

<?php

namespace bizHd\user\services;

use bizHd\base\services\BaseService;
use common\components\stringUtil;
use common\services\xhMerchantExtendService;
use common\services\xhMerchantService;
use common\services\xhUserAssetService;
use common\services\xhUserCapitalService;
use common\services\xhUserIntegralService;
use common\services\xhUserService;
use Yii;
use linslin\yii2\curl;


class UserOldDataService extends BaseService
{
	public static $baseFile = '\bizHd\user\classes\UserOldData';
	
	/**
	 * 判断是否可以添加
	 */
	public static function couldAdd($sjId, $mobile)
	{
		$class = self::$baseFile;
		$return = $class::getByCondition(['sjId' => $sjId, 'mobile' => $mobile]);
		if (!empty($return)) {
			return ['status' => false, 'msg' => '已经添加过了'];
		}
		$user = UserService::getByCondition(['sjId' => $sjId, 'mobile' => $mobile]);
		if (!empty($user)) {
			return ['status' => false, 'msg' => '已经是会员了，无法添加'];
		}
		return ['status' => true];
	}
	
	/**
	 * 添加老客户
	 */
	public static function addOldCustomer($data)
	{
		self::add($data);
		return true;
	}
	
	/**
	 * 老客户数据导入
	 */
	public static function import($sjId, $userId, $mobile)
	{
		$data = self::getByCondition(['sjId' => $sjId, 'mobile' => $mobile]);
		if (empty($data) || $data['status'] == 1) {
			return ['status' => 'false', 'msg' => '老客户数据导入失败'];
		}
		$userAsset				= xhUserAssetService::getByUserId($userId);
		$addIntegral = $data['integral'];
		$updateData = [];
		$date = date("Y-m-d H:i:s");
		$user = xhUserService::getById($userId);
		$merchant = xhMerchantService::getById($sjId);
		$adminId	= $merchant['adminId'];
		if(!empty($addIntegral)){
			$preIntegral			= $userAsset['integral'];
			$preLevel = $userAsset['member'];
			$integral = stringUtil::calcAdd($preIntegral,$addIntegral);
			$merchantExtend = xhMerchantExtendService::getBySjId($sjId);

			UserIntegralService::increaseToUpgrade($preIntegral,$integral, $preLevel, $userId, $sjId, $merchantExtend);

			$updateData['integral'] = $integral;
			
			$integralData = [
				'userId'		=> $userId,
				'userName'		=> $user['userName'],
				'sjId'	=> $sjId,
				'relateId'		=> (string)$data['id'],
				'integral'		=> $integral,
				'num'			=> $addIntegral,
				'io'			=> 1,
				'payWay'		=> 4,
				'event'			=> "店长操作",
				'operatorId'	=> $adminId,
				'createTime'	=> $date,
				'addTime'		=> time(),
				'capitalType'   => 0,
			];
			//用户兑换型积分流水增加
			xhUserIntegralService::add($integralData);
			//状态变更为已导入状态
			self::updateById($data['id'],['status'=>1]);
		}
		$balance = $data['balance'];
		if(!empty($balance)){
			$preBalance = $userAsset['balance'];
			$totalBalance = stringUtil::calcAdd($balance,$preBalance);
			$updateData['balance'] = $totalBalance;
			
			$userCapitalData = [
				'relateId'		=> (string)$data['id'],
				'balance'		=> $totalBalance,
				'totalIncome'	=> $userAsset['totalIncome'],
				'totalExpend'	=> $userAsset['totalExpend'],
				'amount'		=> $balance,
				'io'			=> 1,
				'payWay'		=> 4,
				'event'			=> "店长操作",
				'sjId'	=> $sjId,
				'userId'		=> $userId,
				'userName'		=> $user['userName'],
				'operateId'		=> $adminId,
				'createTime'	=> $date,
				'addTime'		=> time(),
			];
			xhUserCapitalService::add($userCapitalData);//用户资金流水增加
		}
		if(!empty($updateData)){
			xhUserAssetService::updateByUserId($userId,$updateData);
		}
		return ['status'=>true,'msg'=>'导入成功'];
	}
	
}