diff --git a/app/common/dao/store/consumption/StoreConsumptionUserDao.php b/app/common/dao/store/consumption/StoreConsumptionUserDao.php index ae5e6564..7b12f9cd 100644 --- a/app/common/dao/store/consumption/StoreConsumptionUserDao.php +++ b/app/common/dao/store/consumption/StoreConsumptionUserDao.php @@ -9,7 +9,9 @@ use app\common\model\store\consumption\StoreConsumption; use app\common\model\store\consumption\StoreConsumptionUser; use app\common\model\store\order\StoreGroupOrder; use app\common\model\store\StoreActivityOrder; +use app\common\model\system\merchant\Merchant; use app\common\model\user\User; +use app\common\repositories\system\merchant\MerchantRepository; use think\facade\Db; class StoreConsumptionUserDao extends BaseDao @@ -65,7 +67,7 @@ class StoreConsumptionUserDao extends BaseDao } Db::startTrans(); try { - $isFirstOrder = $this->isFirstOrder($userId, $consumption['start_time']); + $isFirstOrder = $this->isFirstOrder($userId, $consumption['start_time'], $consumption['end_time']); $storeActivityOrderDao = new StoreActivityOrderDao(); $storeActivityOrderDao->save($groupOrder, $spreadUserId, $isFirstOrder); if ($consumption['type'] == StoreConsumption::TYPE_OWNER_CONSUMPTION) { @@ -108,7 +110,7 @@ class StoreConsumptionUserDao extends BaseDao } Db::startTrans(); try { - $isFirstOrder = $this->isFirstOrder($userId, $spreadConsumption['start_time']); + $isFirstOrder = $this->isFirstOrder($userId, $spreadConsumption['start_time'], $spreadConsumption['end_time']); $storeActivityOrderDao = new StoreActivityOrderDao(); $storeActivityOrderDao->save($groupOrder, $spreadUserId, $isFirstOrder); if ($spreadConsumption['type'] == StoreConsumption::TYPE_PULL_CONSUMPTION && $isFirstOrder) { @@ -178,7 +180,7 @@ class StoreConsumptionUserDao extends BaseDao /** * 发放消费金 - * @param array $consumption 消费金类型 + * @param $consumption 消费金类型 * @param float $rate 红包发放比例 * @param int $userId 用户id * @param string $groupOrderIds 订单id集合 @@ -187,7 +189,7 @@ class StoreConsumptionUserDao extends BaseDao * @return void * @throws \Exception */ - public function send(array $consumption, float $rate, int $userId, string $groupOrderIds, float $amount, $status = -2) + public function send($consumption, float $rate, int $userId, string $groupOrderIds, float $amount, $status = -2, $type = 1) { $model = new StoreConsumptionUser(); $model->coupon_id = $consumption['coupon_id']; @@ -196,10 +198,11 @@ class StoreConsumptionUserDao extends BaseDao $model->order_id_set = $groupOrderIds; $model->coupon_price = bcmul($amount, $rate, 2); $model->balance = $model->coupon_price; + $model->order_amount = $amount; $model->create_time = date('Y-m-d H:i:s'); $model->start_time = date('Y-m-d H:i:s', time() + 7 * 86400); $model->end_time = date('Y-m-d H:i:s', time() + 7 * 86400 + 365 * 86400); - $model->type = 'send'; + $model->type = $type; $model->status = $status; if (!$model->save()) { throw new \Exception('发放失败'); @@ -210,17 +213,67 @@ class StoreConsumptionUserDao extends BaseDao * 判断是否是首单 * @param int $userId 用户id * @param string $startTime 活动开始时间 + * @param string $endTime 活动结束时间 * @return int * @throws \think\db\exception\DbException */ - public function isFirstOrder(int $userId, string $startTime) + public function isFirstOrder(int $userId, string $startTime, string $endTime) { - $isNewUser = User::where('uid', $userId)->where('create_time', '>=', $startTime)->count(); + $isNewUser = User::where('uid', $userId)->whereBetweenTime('create_time', $startTime, $endTime)->count(); if ($isNewUser == 0) { return 0; } - $count = StoreGroupOrder::where('uid', $userId)->where('paid', 1)->where('pay_time', '>=', $startTime)->count(); + $count = StoreGroupOrder::where('uid', $userId)->where('paid', 1)->whereBetweenTime('pay_time', $startTime, $endTime)->count(); return intval($count == 1); } + /** + * 活动首单商户佣金 + * @param $order + * @param $finance + * @param $financeSn + * @return mixed + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function firstOrderCommission($order, $finance, $financeSn) + { + $consumption = StoreConsumption::where('status', 1)->where('type', StoreConsumption::TYPE_FIRST_ORDER_COMMISSION)->find(); + if (empty($consumption)) { + return $finance; + } + $isFirstOrder = $this->isFirstOrder($order['uid'], $consumption['start_time'], $consumption['end_time']); + if (!$isFirstOrder) { + return $finance; + } + $commission = bcmul($order['pay_price'], $consumption['config']['commission_rate'], 2); + if ($commission > 0) { + $finance[] = [ + 'order_id' => $order->order_id, + 'order_sn' => $order->order_sn, + 'user_info' => $order->user->nickname, + 'user_id' => $order['uid'], + 'financial_type' => 'first_order_commission', + 'financial_pm' => 0, + 'type' => 2, + 'number' => $commission, + 'mer_id' => $order->mer_id, + 'financial_record_sn' => $financeSn + ]; + app()->make(MerchantRepository::class)->addLockMoney($order['mer_id'], 'order', $order['order_id'], $commission); + } + $redPack = bcmul($order['pay_price'], $consumption['config']['red_pack_rate'], 2); + if ($redPack > 0) { + $userId = Merchant::where('mer_id', $order['mer_id'])->value('uid'); + $this->send($consumption, $consumption['config']['red_pack_rate'], $userId, $order['order_id'], $order['pay_price'], StoreConsumptionUser::STATUS_UNUSED, StoreConsumptionUser::TYPE_TWO); + $user = User::where('uid', $userId)->find(); + $user->red_pack_balance = bcadd($user->red_pack_balance, $redPack, 2); + if (!$user->save()) { + throw new \Exception('红包余额更新出错'); + } + } + return $finance; + } + } \ No newline at end of file diff --git a/app/common/model/store/consumption/StoreConsumption.php b/app/common/model/store/consumption/StoreConsumption.php index 8ccde0a9..85e00ac2 100644 --- a/app/common/model/store/consumption/StoreConsumption.php +++ b/app/common/model/store/consumption/StoreConsumption.php @@ -14,6 +14,7 @@ class StoreConsumption extends BaseModel const TYPE_OWNER_CONSUMPTION = 13; //个人消费金 const TYPE_PULL_CONSUMPTION = 14; //拉新消费金 + const TYPE_FIRST_ORDER_COMMISSION = 15; //首单佣金 public static function tablePk(): string { diff --git a/app/common/model/store/consumption/StoreConsumptionUser.php b/app/common/model/store/consumption/StoreConsumptionUser.php index 92002ddd..2cd1ee6f 100644 --- a/app/common/model/store/consumption/StoreConsumptionUser.php +++ b/app/common/model/store/consumption/StoreConsumptionUser.php @@ -12,6 +12,8 @@ class StoreConsumptionUser extends BaseModel const STATUS_UNUSED = 0; //未使用 const STATUS_USED = 1; //已使用 const STATUS_OVERDUE = 2; //过期的 + const TYPE_ONE = 1; //实物通用红包 + const TYPE_TWO = 2; //现金抵扣红包 public static function tablePk(): string { diff --git a/app/common/repositories/store/order/StoreOrderRepository.php b/app/common/repositories/store/order/StoreOrderRepository.php index 1dbbdc29..62cf0742 100644 --- a/app/common/repositories/store/order/StoreOrderRepository.php +++ b/app/common/repositories/store/order/StoreOrderRepository.php @@ -11,6 +11,7 @@ // +---------------------------------------------------------------------- namespace app\common\repositories\store\order; +use app\common\dao\store\consumption\StoreConsumptionUserDao; use app\common\dao\store\order\StoreCartDao; use app\common\dao\store\order\StoreOrderDao; use app\common\model\store\order\StoreGroupOrder; @@ -421,6 +422,8 @@ class StoreOrderRepository extends BaseRepository ], $order->mer_id); //自动打印订单 $this->autoPrinter($order->order_id, $order->mer_id); + // "惠农供销，谱写数字新篇章"活动首单分润 + $finance = (new StoreConsumptionUserDao())->firstOrderCommission($order, $finance, $financeSn . ($i++)); } //分销判断 // if ($groupOrder->user->spread_uid) { diff --git a/extend/AES.php b/extend/AES.php new file mode 100644 index 00000000..68773b70 --- /dev/null +++ b/extend/AES.php @@ -0,0 +1,44 @@ +cipher, $secret, OPENSSL_RAW_DATA, $iv); + } else { + $encryptedData = openssl_encrypt($plainText, $this->cipher, $secret); + } + return base64_encode($encryptedData); + } + + /** + * 使用对称秘钥解密 + * @param $plainText + * @param $secret + * @param $iv + * @return false|string + */ + function decrypt($plainText, $secret, $iv = null) { + $plainText = base64_decode($plainText); + if (!empty($iv)) { + $data = openssl_decrypt($plainText, $this->cipher, $secret, OPENSSL_RAW_DATA, $iv); + $data = json_decode($data, true); + return $data; + } + return openssl_decrypt($plainText, $this->cipher, $secret); + } + + +} \ No newline at end of file