提现额度-原来只有共富区有提现额度，现需要全平台消费都发放提现额度，把提现额度从共富区奖励表拆出，单独建表；

app/command/PensionTasks.php

@@ -4,6 +4,7 @@ declare (strict_types=1);
 namespace app\command;
 
 use app\common\enum\CommonEnum;
+use app\common\enum\user\UserWithdrawalLimitRecordEnum;
 use app\common\model\merchant\order\OrderMerchant;
 use app\common\model\store\order\StoreOrder;
 use app\common\model\user\User;
@@ -15,6 +16,7 @@ use app\common\repositories\store\order\StoreOrderStatusRepository;
 use app\common\repositories\store\product\ProductRepository;
 use app\common\repositories\user\UserBillRepository;
 use app\common\repositories\user\UserRepository;
+use app\common\repositories\user\UserWithdrawalLimitRecordRepository;
 use app\entity\data\shared\SharedProsperityUserEntity;
 use app\traits\GzcApiRequest;
 use Carbon\Carbon;
@@ -1798,6 +1800,17 @@ class PensionTasks extends Command
      */
     public function settleAward($online,$order_type)
     {
+        /** 结算 提现佣金 */
+        /** @var UserWithdrawalLimitRecordRepository $userWithdrawalLimitRecordRepository */
+        $userWithdrawalLimitRecordRepository = app()->make(UserWithdrawalLimitRecordRepository::class);
+        $userWithdrawalLimitRecordEntityList = $userWithdrawalLimitRecordRepository->getUserWithdrawalLimitRecordEntityListByOrderSnListAndPending((string)$order_type, [$online['order_sn']]);
+        if (!empty($userWithdrawalLimitRecordEntityList)) {
+            $userWithdrawalLimitRecordIdList = array_map(function ($userWithdrawalLimitRecordEntity) {
+                return $userWithdrawalLimitRecordEntity->getId();
+            }, $userWithdrawalLimitRecordEntityList);
+            $userWithdrawalLimitRecordRepository->executeByIdList($userWithdrawalLimitRecordIdList);
+        }
+
         // 结算积分
         $user_sign_score_list = Db::name('user_sign_score')
             ->where('status', -1)

app/common/dao/user/UserWithdrawalLimitRecordDao.php

@@ -0,0 +1,92 @@
+<?php
+
+namespace app\common\dao\user;
+
+use app\common\dao\BaseDao;
+use app\common\enum\user\UserWithdrawalLimitRecordEnum;
+use app\common\model\BaseModel;
+use app\common\model\user\UserWithdrawalLimitRecord;
+use app\entity\data\user\UserWithdrawalLimitRecordEntity;
+use think\db\exception\DataNotFoundException;
+use think\db\exception\DbException;
+use think\db\exception\ModelNotFoundException;
+
+class UserWithdrawalLimitRecordDao extends BaseDao
+{
+    /**
+     * @return BaseModel
+     */
+    protected function getModel(): string
+    {
+        return UserWithdrawalLimitRecord::class;
+    }
+
+    /**
+     * @param array $idList
+     * @return UserWithdrawalLimitRecordEntity[]
+     */
+    public function getUserWithdrawalLimitRecordEntityListByIdList(array $idList): array
+    {
+        $entityList = [];
+        try {
+            /** @var UserWithdrawalLimitRecord $model */
+            $model = $this->getModel();
+            $dataRes = $model::getDB()
+                ->whereIn('id', $idList)
+                ->select()
+                ->toArray();
+            if (!empty($dataRes)) {
+                $entityList = array_map(function ($data) {
+                    return UserWithdrawalLimitRecordEntity::newInstance($data);
+                }, $dataRes);
+            }
+        } catch (\Exception $e) {
+
+        }
+        return $entityList;
+    }
+
+    /**
+     * 批量更新
+     * @param $dataList
+     * @return array
+     */
+    public function saveAll($dataList): array
+    {
+        try {
+            return $this->getModel()::getInstance()->allowField(array_keys(reset($dataList)))->saveAll($dataList)->toArray();
+        } catch (\Exception $e) {
+            return [];
+        }
+    }
+
+    /**
+     * @param string $typeShop
+     * @param array $orderSnList
+     * @return UserWithdrawalLimitRecordEntity[]
+     */
+    public function getUserWithdrawalLimitRecordEntityListByOrderSnListAndPending(string $typeShop, array $orderSnList): array
+    {
+        $entityList = [];
+        try {
+            /** @var UserWithdrawalLimitRecord $model */
+            $model = $this->getModel();
+            $dataList = $model::getDB()
+                ->where('type_shop', '=', $typeShop)
+                ->whereIn('order_sn', $orderSnList)
+                ->where('status', '=', UserWithdrawalLimitRecordEnum::STATUS['PENDING']['code'])
+                ->select()
+                ->toArray();
+
+            if (!empty($dataList)) {
+                $entityList = array_map(function ($data) {
+                    return UserWithdrawalLimitRecordEntity::newInstance($data);
+                }, $dataList);
+            }
+        } catch (DataNotFoundException|ModelNotFoundException|DbException $e) {
+
+        }
+        return $entityList;
+    }
+
+}

app/common/enum/CommonEnum.php

@@ -82,6 +82,9 @@ class CommonEnum
     // 平台手续费(汇付通道服务费)
     const HUIFU_COMMISSION_CHARGE = 0.0038;
 
+    // 提现额度比例 ['SharedProsperity']['Self']['WithdrawalLimit']['Ratio']['code']
+    const WITHDRAWAL_LIMIT_RATIO = 5;
+
     // 订单 收益 的分配
     const ORDER_EARNING_ALLOCATION = [
         // 精彩生活区

app/common/enum/user/UserWithdrawalLimitRecordEnum.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace app\common\enum\user;
+
+use app\common\enum\CommonEnum;
+
+class UserWithdrawalLimitRecordEnum extends CommonEnum
+{
+    // 收支类型
+    const PM = [
+        'EXPEND' => ['code' => 0, 'name' => '支出'],
+        'INCOME' => ['code' => 1, 'name' => '获得'],
+    ];
+
+    // 状态
+    const STATUS = [
+        'PENDING' => ['code' => 0, 'name' => '待确定'],
+        'VALID' => ['code' => 1, 'name' => '有效'],
+        'INVALID' => ['code' => -1, 'name' => '无效'],
+    ];
+
+    // 类型商店
+    const TYPE_SHOP = parent::ORDER_TYPE;
+}

app/common/model/user/UserWithdrawalLimitRecord.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace app\common\model\user;
+
+use app\common\model\BaseModel;
+
+class UserWithdrawalLimitRecord extends BaseModel
+{
+    public static function tablePk(): ?string
+    {
+        return 'id';
+    }
+
+    public static function tableName(): string
+    {
+        return 'user_withdrawal_limit_records';
+    }
+}

app/common/repositories/store/order/StoreOrderRepository.php

@@ -42,6 +42,7 @@ use app\common\enum\user\UserSignHongbaoEnum;
 use app\common\enum\user\UserSignJingdouEnum;
 use app\common\enum\user\UserSignScoreEnum;
 use app\common\enum\user\UserSignVrEnum;
+use app\common\enum\user\UserWithdrawalLimitRecordEnum;
 use app\common\model\store\order\StoreGroupOrder;
 use app\common\model\store\order\StoreOrder;
 use app\common\model\store\order\StoreRefundOrder;
@@ -86,6 +87,7 @@ use app\common\repositories\user\UserSignJingdouRepository;
 use app\common\repositories\user\UserSignScoreRepository;
 use app\common\repositories\user\UserSignVrRepository;
 use app\common\repositories\user\UserThirdRepository;
+use app\common\repositories\user\UserWithdrawalLimitRecordRepository;
 use app\common\repositories\wechat\RoutineQrcodeRepository;
 use app\common\repositories\wechat\WechatUserRepository;
 use app\controller\api\user\Volunteer;
@@ -11671,19 +11673,19 @@ class StoreOrderRepository extends BaseRepository
                 '购买共富区商品获得消费股'
             );
 
-            // 发放提现额度
-            $withdrawalLimit = bcmul($storeOrderEntity->getTotalPrice(), CommonEnum::ORDER_EARNING_ALLOCATION['SharedProsperity']['Self']['WithdrawalLimit']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
-            /** @var SharedProsperityRewardRecordRepository $sharedProsperityRewardRecordRepository */
-            $sharedProsperityRewardRecordRepository = app()->make(SharedProsperityRewardRecordRepository::class);
-            $sharedProsperityRewardRecordRepository->addSharedProsperityRewardRecord(
-                $sharedProsperityUserEntity->getUserId(),
-                SharedProsperityRewardRecordEnum::TYPE['WITHDRAWAL_LIMIT']['code'],
-                SharedProsperityRewardRecordEnum::PM['INCOME']['code'],
-                $withdrawalLimit,
-                SharedProsperityRewardRecordEnum::TYPE_SHOP['Platform']['code'],
-                $storeOrderEntity->getOrderSn(),
-                '购买共富区商品获得提现额度'
-            );
+            // 发放提现额度 此处不再发放，原来只有购买共富区商品才发放该奖励，现在单独把他查出一张表来，每个区域购买商品 都发放提现额度，所以把他放在最外边
+            // $withdrawalLimit = bcmul($storeOrderEntity->getTotalPrice(), CommonEnum::ORDER_EARNING_ALLOCATION['SharedProsperity']['Self']['WithdrawalLimit']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
+            // /** @var SharedProsperityRewardRecordRepository $sharedProsperityRewardRecordRepository */
+            // $sharedProsperityRewardRecordRepository = app()->make(SharedProsperityRewardRecordRepository::class);
+            // $sharedProsperityRewardRecordRepository->addSharedProsperityRewardRecord(
+            //     $sharedProsperityUserEntity->getUserId(),
+            //     SharedProsperityRewardRecordEnum::TYPE['WITHDRAWAL_LIMIT']['code'],
+            //     SharedProsperityRewardRecordEnum::PM['INCOME']['code'],
+            //     $withdrawalLimit,
+            //     SharedProsperityRewardRecordEnum::TYPE_SHOP['Platform']['code'],
+            //     $storeOrderEntity->getOrderSn(),
+            //     '购买共富区商品获得提现额度'
+            // );
 
             // 发放共富区PV
             /** @var SharedProsperityRecommendConfigRepository $sharedProsperityRecommendConfigRepository */
@@ -12028,6 +12030,18 @@ class StoreOrderRepository extends BaseRepository
                 );
             }
         }
+
+        $withdrawalLimit = bcmul($storeOrderEntity->getTotalPrice(), CommonEnum::WITHDRAWAL_LIMIT_RATIO, CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
+        /** @var UserWithdrawalLimitRecordRepository $userWithdrawalLimitRecordRepository */
+        $userWithdrawalLimitRecordRepository = app()->make(UserWithdrawalLimitRecordRepository::class);
+        $userWithdrawalLimitRecordRepository->addUserWithdrawalLimitRecord(
+            $userEntity->getUid(),
+            UserWithdrawalLimitRecordEnum::PM['INCOME']['code'],
+            $withdrawalLimit,
+            UserWithdrawalLimitRecordEnum::TYPE_SHOP['Platform']['code'],
+            $storeOrderEntity->getOrderSn(),
+            '消费获得提现额度'
+        );
     }
 
     /**
@@ -12157,6 +12171,17 @@ class StoreOrderRepository extends BaseRepository
                         $sharedProsperityUserRepository->identityUpgrade($affectedUserIdListBySharedProsperity);
                     }
                 }
+
+                /** 结算 提现佣金 */
+                /** @var UserWithdrawalLimitRecordRepository $userWithdrawalLimitRecordRepository */
+                $userWithdrawalLimitRecordRepository = app()->make(UserWithdrawalLimitRecordRepository::class);
+                $userWithdrawalLimitRecordEntityList = $userWithdrawalLimitRecordRepository->getUserWithdrawalLimitRecordEntityListByOrderSnListAndPending(UserWithdrawalLimitRecordEnum::TYPE_SHOP['Platform']['code'], $unsettledOrderSnList);
+                if (!empty($userWithdrawalLimitRecordEntityList)) {
+                    $userWithdrawalLimitRecordIdList = array_map(function ($userWithdrawalLimitRecordEntity) {
+                        return $userWithdrawalLimitRecordEntity->getId();
+                    }, $userWithdrawalLimitRecordEntityList);
+                    $userWithdrawalLimitRecordRepository->executeByIdList($userWithdrawalLimitRecordIdList);
+                }
             } catch (DbException $e) {
                 throw new ValidateException('订单结算失败');
             }

app/common/repositories/user/UserThirdRepository.php

@@ -11,7 +11,9 @@
 namespace app\common\repositories\user;
 
 use app\common\dao\user\UserThirdDao;
+use app\common\enum\CommonEnum;
 use app\common\enum\shared\SharedProsperityRewardRecordEnum;
+use app\common\enum\user\UserWithdrawalLimitRecordEnum;
 use app\common\model\user\User;
 use app\common\repositories\BaseRepository;
 
@@ -770,6 +772,19 @@ class UserThirdRepository extends BaseRepository
         Db::name('log')->insert(['data' => "type_shop:{$type_shop}, $order_sn, $order_sn, 赠送积分, $price"]);
 
         try {
+            // 所有第三方所下订单，消费者获得 提现额度
+            $withdrawalLimit = bcmul($price, CommonEnum::WITHDRAWAL_LIMIT_RATIO, CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
+            /** @var UserWithdrawalLimitRecordRepository $userWithdrawalLimitRecordRepository */
+            $userWithdrawalLimitRecordRepository = app()->make(UserWithdrawalLimitRecordRepository::class);
+            $userWithdrawalLimitRecordRepository->addUserWithdrawalLimitRecord(
+                (int)$user_id,
+                UserWithdrawalLimitRecordEnum::PM['INCOME']['code'],
+                (float)$withdrawalLimit,
+                (int)$type_shop,
+                $order_sn,
+                '消费获得提现额度'
+            );
+
             //更新用户积分
 
             $user = Db::name('user')->where('uid', $user_id)->find();

app/common/repositories/user/UserWithdrawalLimitRecordRepository.php

@@ -0,0 +1,248 @@
+<?php
+
+namespace app\common\repositories\user;
+
+use app\common\dao\user\UserWithdrawalLimitRecordDao;
+use app\common\enum\user\UserWithdrawalLimitRecordEnum;
+use app\common\repositories\BaseRepository;
+use app\common\repositories\store\order\StoreOrderRepository;
+use app\entity\data\user\UserEntity;
+use app\entity\data\user\UserWithdrawalLimitRecordEntity;
+use think\db\exception\DbException;
+use think\exception\ValidateException;
+
+class UserWithdrawalLimitRecordRepository extends BaseRepository
+{
+
+    protected $dao;
+
+    /**
+     * UserWithdrawalLimitRecordRepository constructor.
+     * @param UserWithdrawalLimitRecordDao $dao
+     */
+    public function __construct(UserWithdrawalLimitRecordDao $dao)
+    {
+        $this->dao = $dao;
+    }
+
+    /**
+     * @param int $id
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function getUserWithdrawalLimitRecordEntityById(int $id): UserWithdrawalLimitRecordEntity
+    {
+        $entityList = $this->getUserWithdrawalLimitRecordEntityListByIdList([$id]);
+        $entity = array_shift($entityList);
+        if ($entity instanceof UserWithdrawalLimitRecordEntity) {
+            return $entity;
+        } else {
+            /** @var UserWithdrawalLimitRecordEntity */
+            return UserWithdrawalLimitRecordEntity::newInstance();
+        }
+    }
+
+    /**
+     * @param array $idList
+     * @return UserWithdrawalLimitRecordEntity[]
+     */
+    public function getUserWithdrawalLimitRecordEntityListByIdList(array $idList): array
+    {
+        return $this->dao->getUserWithdrawalLimitRecordEntityListByIdList($idList);
+    }
+
+    public function create($data)
+    {
+        return $this->dao->create($data);
+    }
+
+    /**
+     * @param UserWithdrawalLimitRecordEntity $userWithdrawalLimitRecordEntity
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function createByEntity(UserWithdrawalLimitRecordEntity $userWithdrawalLimitRecordEntity): UserWithdrawalLimitRecordEntity
+    {
+        $result = $this->create($userWithdrawalLimitRecordEntity->toUnderlineArray())->toArray();
+        /** @var UserWithdrawalLimitRecordEntity $entity */
+        $entity = UserWithdrawalLimitRecordEntity::newInstance($result);
+        return $entity;
+    }
+
+    /**
+     * @param $id
+     * @param $data
+     * @return int
+     */
+    public function update($id, $data): int
+    {
+        try {
+            return $this->dao->update($id, $data);
+        } catch (DbException $e) {
+            return 0;
+        }
+    }
+
+    /**
+     * @param UserWithdrawalLimitRecordEntity $userWithdrawalLimitRecordEntity
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function updateByEntity(UserWithdrawalLimitRecordEntity $userWithdrawalLimitRecordEntity): UserWithdrawalLimitRecordEntity
+    {
+        if (empty($userWithdrawalLimitRecordEntity->getId())) {
+            return UserWithdrawalLimitRecordEntity::newInstance();
+        }
+        $result = $this->update($userWithdrawalLimitRecordEntity->getId(), $userWithdrawalLimitRecordEntity->toUnderlineArray());
+        if ($result > 0) {
+            return $this->getUserWithdrawalLimitRecordEntityById($userWithdrawalLimitRecordEntity->getId());
+        }
+        return UserWithdrawalLimitRecordEntity::newInstance();
+    }
+
+    /**
+     * 添加 提现额度
+     * @param int $uid
+     * @param int $pm
+     * @param float $number
+     * @param int $typeShop
+     * @param string $orderSn
+     * @param string $remark
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function addUserWithdrawalLimitRecord(int $uid, int $pm, float $number, int $typeShop = 0, string $orderSn = '', string $remark = ''): UserWithdrawalLimitRecordEntity
+    {
+        if ($typeShop == UserWithdrawalLimitRecordEnum::TYPE_SHOP['Platform']['code']) {
+            /** @var StoreOrderRepository $storeOrderRepository */
+            $storeOrderRepository = app()->make(StoreOrderRepository::class);
+            $storeOrderEntity = $storeOrderRepository->getStoreOrderEntityByOrderSn($orderSn);
+            if (empty($storeOrderEntity->getOrderId())) {
+                throw new ValidateException('未查询到订单信息');
+            }
+        }
+
+        /** @var UserWithdrawalLimitRecordEntity $userWithdrawalLimitRecordEntity */
+        $userWithdrawalLimitRecordEntity = UserWithdrawalLimitRecordEntity::newInstance();
+        $userWithdrawalLimitRecordEntity->setUserId($uid)
+            ->setPm($pm)
+            ->setNumber($number)
+            ->setStatus(UserWithdrawalLimitRecordEnum::STATUS['PENDING']['code'])
+            ->setTypeShop($typeShop)
+            ->setOrderSn($orderSn)
+            ->setRemark($remark);
+
+        return $this->createByEntity($userWithdrawalLimitRecordEntity);
+    }
+
+    /**
+     * @param string $typeShop
+     * @param array $orderSnList
+     * @return UserWithdrawalLimitRecordEntity[]
+     */
+    public function getUserWithdrawalLimitRecordEntityListByOrderSnListAndPending(string $typeShop, array $orderSnList): array
+    {
+        return $this->dao->getUserWithdrawalLimitRecordEntityListByOrderSnListAndPending($typeShop, $orderSnList);
+    }
+
+    /**
+     * @param $dataList
+     * @return array
+     */
+    public function batchUpdateUserWithdrawalLimitRecordDataByDataList($dataList): array
+    {
+        return $this->dao->saveAll($dataList);
+    }
+
+    /**
+     * 结算 提现额度
+     * @param array $idList
+     * @return array
+     */
+    public function executeByIdList(array $idList): array
+    {
+        $userWithdrawalLimitRecordEntityList = $this->getUserWithdrawalLimitRecordEntityListByIdList($idList);
+        // 忽略 已经生效的 记录
+        $userWithdrawalLimitRecordEntityList = array_filter($userWithdrawalLimitRecordEntityList, function ($entity) {
+            return $entity->getStatus() != UserWithdrawalLimitRecordEnum::STATUS['VALID']['code'];
+        });
+
+        if (!empty($userWithdrawalLimitRecordEntityList)) {
+            // 获取所有记录的 归属人
+            $userIdList = array_map(function ($userWithdrawalLimitRecordEntity) {
+                return $userWithdrawalLimitRecordEntity->getUserId();
+            }, $userWithdrawalLimitRecordEntityList);
+
+            // 获取用户 映射信息
+            /** @var UserRepository $userRepository */
+            $userRepository = app()->make(UserRepository::class);
+            /** @var UserEntity[] $userEntityMapByUserId */
+            $userEntityMapByUserId = [];
+            if (!empty($userIdList)) {
+                $userEntityMapByUserId = $userRepository->getUserEntityMapByUidList($userIdList);
+            }
+
+            $updateUserEntityList = [];
+            $updateUserWithdrawalLimitRecordEntityList = [];
+            foreach ($userWithdrawalLimitRecordEntityList as $userWithdrawalLimitRecordEntity) {
+                if (empty($userWithdrawalLimitRecordEntity->getId()) || empty($userWithdrawalLimitRecordEntity->getUserId())) {
+                    // throw new ValidateException('无效的账单记录');
+                    continue;
+                }
+                if (!empty($userWithdrawalLimitRecordEntity->getTakeTime())) {
+                    throw new ValidateException("该奖励记录已更新，请勿重复操作({$userWithdrawalLimitRecordEntity->getId()})");
+                }
+
+                $userEntity = $userEntityMapByUserId[$userWithdrawalLimitRecordEntity->getUserId()];
+                if (empty($userEntity) || empty($userEntity->getUid())) {
+                    throw new ValidateException("未查询到用户信息({$userWithdrawalLimitRecordEntity->getId()})");
+                }
+
+                // 更新 用户信息
+                /** @var UserEntity $updateUserEntity */
+                $updateUserEntity = $updateUserEntityList[$userEntity->getUid()] ?? UserEntity::newInstance();
+                $updateUserEntity->setUid($userEntity->getUid());
+                // 更新 账单 记录
+                /** @var UserWithdrawalLimitRecordEntity $updateUserWithdrawalLimitRecord */
+                $updateUserWithdrawalLimitRecord = $updateUserWithdrawalLimitRecordEntityList[$userWithdrawalLimitRecordEntity->getId()] ?? UserWithdrawalLimitRecordEntity::newInstance();
+
+                // 提现额度
+                if (is_null($updateUserEntity->getWithdrawalLimit())) {
+                    $updateUserEntity->setWithdrawalLimit($userEntity->getWithdrawalLimit());
+                }
+                // 更新用户 佣金 信息
+                if ($userWithdrawalLimitRecordEntity->getPm() == UserWithdrawalLimitRecordEnum::PM['EXPEND']['code']) {
+                    if ($updateUserEntity->getWithdrawalLimit() < $userWithdrawalLimitRecordEntity->getNumber()) {
+                        throw new ValidateException('用户剩余提现额度不足');
+                    }
+                    $updateUserEntity->setWithdrawalLimit(bcsub($updateUserEntity->getWithdrawalLimit(), $userWithdrawalLimitRecordEntity->getNumber(), 2));
+                } else {
+                    $updateUserEntity->setWithdrawalLimit(bcadd($updateUserEntity->getWithdrawalLimit(), $userWithdrawalLimitRecordEntity->getNumber(), 2));
+                }
+
+                // 更新 账单记录 状态
+                $updateUserWithdrawalLimitRecord
+                    ->setId($userWithdrawalLimitRecordEntity->getId())
+                    ->setStatus(UserWithdrawalLimitRecordEnum::STATUS['VALID']['code'])
+                    ->setTakeTime(date('Y-m-d H:i:s'))
+                    ->setBalance($updateUserEntity->getWithdrawalLimit());
+
+                $updateUserEntityList[$userEntity->getUid()] = $updateUserEntity;
+                $updateUserWithdrawalLimitRecordEntityList[$userWithdrawalLimitRecordEntity->getId()] = $updateUserWithdrawalLimitRecord;
+            }
+            if (!empty($updateUserEntityList)) {
+                $userRepository->batchUpdateUserDataByDataList(
+                    array_map(function (UserEntity $updateUserEntity) {
+                        return $updateUserEntity->toUnderlineArray();
+                    }, $updateUserEntityList)
+                );
+            }
+
+            if (!empty($updateUserWithdrawalLimitRecordEntityList)) {
+                $this->batchUpdateUserWithdrawalLimitRecordDataByDataList(
+                    array_map(function (UserWithdrawalLimitRecordEntity $updateUserWithdrawalLimitRecordEntity) {
+                        return $updateUserWithdrawalLimitRecordEntity->toUnderlineArray();
+                    }, $updateUserWithdrawalLimitRecordEntityList)
+                );
+            }
+        }
+
+        return $idList;
+    }
+}

app/entity/data/user/UserEntity.php

@@ -108,6 +108,7 @@ class UserEntity extends DataEntity
     public $perContribute = null;  // 个人贡献值中的直推贡献值(用于计算业务经理之前的身份升级)
     public $withdrawQuotaOld = null;  // 提现额度
     public $identityUpTime = null;  // 身份升级成业务员的时间
+    public $withdrawalLimit = null;  // 用户的提现额度
 
     /**
      * @return mixed
@@ -1962,4 +1963,22 @@ class UserEntity extends DataEntity
         $this->identityUpTime = $identityUpTime;
         return $this;
     }
+
+    /**
+     * @return mixed
+     */
+    public function getWithdrawalLimit()
+    {
+        return $this->withdrawalLimit;
+    }
+
+    /**
+     * @param mixed $withdrawalLimit
+     * @return UserEntity
+     */
+    public function setWithdrawalLimit($withdrawalLimit): UserEntity
+    {
+        $this->withdrawalLimit = $withdrawalLimit;
+        return $this;
+    }
 }

app/entity/data/user/UserWithdrawalLimitRecordEntity.php

@@ -0,0 +1,237 @@
+<?php
+
+namespace app\entity\data\user;
+
+use app\entity\data\DataEntity;
+
+class UserWithdrawalLimitRecordEntity extends DataEntity
+{
+    public $id = null;           // 记录ID
+    public $userId = null;       // 用户ID
+    public $pm = null;           // 0 = 支出 1 = 获得
+    public $number = null;       // 明细数字
+    public $balance = null;      // 剩余
+    public $status = null;       // 0 = 待确定 1 = 有效 -1 = 无效
+    public $typeShop = null;     // 0平台1多多进宝2唯品会3苏宁易购4网易考拉5淘宝客6京东联盟7饿了么8线上9话费
+    public $orderSn = null;      // 订单号
+    public $takeTime = null;     // 结算时间
+    public $remark = null;       // 备注
+    public $createTime = null;   // 添加时间
+    public $updateTime = null;   // 更新时间
+
+    /**
+     * @return mixed
+     */
+    public function getId()
+    {
+        return $this->id;
+    }
+
+    /**
+     * @param mixed $id
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function setId($id): UserWithdrawalLimitRecordEntity
+    {
+        $this->id = $id;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getUserId()
+    {
+        return $this->userId;
+    }
+
+    /**
+     * @param mixed $userId
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function setUserId($userId): UserWithdrawalLimitRecordEntity
+    {
+        $this->userId = $userId;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getPm()
+    {
+        return $this->pm;
+    }
+
+    /**
+     * @param mixed $pm
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function setPm($pm): UserWithdrawalLimitRecordEntity
+    {
+        $this->pm = $pm;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getNumber()
+    {
+        return $this->number;
+    }
+
+    /**
+     * @param mixed $number
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function setNumber($number): UserWithdrawalLimitRecordEntity
+    {
+        $this->number = $number;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getBalance()
+    {
+        return $this->balance;
+    }
+
+    /**
+     * @param mixed $balance
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function setBalance($balance): UserWithdrawalLimitRecordEntity
+    {
+        $this->balance = $balance;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getStatus()
+    {
+        return $this->status;
+    }
+
+    /**
+     * @param mixed $status
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function setStatus($status): UserWithdrawalLimitRecordEntity
+    {
+        $this->status = $status;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getTypeShop()
+    {
+        return $this->typeShop;
+    }
+
+    /**
+     * @param mixed $typeShop
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function setTypeShop($typeShop): UserWithdrawalLimitRecordEntity
+    {
+        $this->typeShop = $typeShop;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getOrderSn()
+    {
+        return $this->orderSn;
+    }
+
+    /**
+     * @param mixed $orderSn
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function setOrderSn($orderSn): UserWithdrawalLimitRecordEntity
+    {
+        $this->orderSn = $orderSn;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getTakeTime()
+    {
+        return $this->takeTime;
+    }
+
+    /**
+     * @param mixed $takeTime
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function setTakeTime($takeTime): UserWithdrawalLimitRecordEntity
+    {
+        $this->takeTime = $takeTime;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getRemark()
+    {
+        return $this->remark;
+    }
+
+    /**
+     * @param mixed $remark
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function setRemark($remark): UserWithdrawalLimitRecordEntity
+    {
+        $this->remark = $remark;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getCreateTime()
+    {
+        return $this->createTime;
+    }
+
+    /**
+     * @param mixed $createTime
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function setCreateTime($createTime): UserWithdrawalLimitRecordEntity
+    {
+        $this->createTime = $createTime;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getUpdateTime()
+    {
+        return $this->updateTime;
+    }
+
+    /**
+     * @param mixed $updateTime
+     * @return UserWithdrawalLimitRecordEntity
+     */
+    public function setUpdateTime($updateTime): UserWithdrawalLimitRecordEntity
+    {
+        $this->updateTime = $updateTime;
+        return $this;
+    }
+}