feat(order): 添加共富区订单幸福币发放和结算功能

- 新增 UserSignXfb 模型用于管理用户幸福币记录
- 新增 UserSignXfbDao 数据访问对象
- 新增 UserSignXfbRepository 仓库类实现幸福币创建和结算逻辑
- 在 StoreOrderRepository 中集成幸福币发放功能
- 实现订单结算时的幸福币结算处理
- 添加购买共富区商品获得幸福币的业务逻辑

app/common/dao/user/UserSignXfbDao.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace app\common\dao\user;
+
+use app\common\dao\BaseDao;
+use app\common\model\BaseModel;
+use app\common\model\user\UserSignVr;
+use app\entity\CommonEntity;
+use app\entity\data\user\UserSignVrEntity;
+
+class UserSignXfbDao extends BaseDao
+{
+    /**
+     * @return BaseModel
+     */
+    protected function getModel(): string
+    {
+        return UserSignVr::class;
+    }
+}

app/common/model/user/UserSignXfb.php

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

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

@@ -86,6 +86,7 @@ use app\common\repositories\user\UserSignHongbaoRepository;
 use app\common\repositories\user\UserSignJingdouRepository;
 use app\common\repositories\user\UserSignScoreRepository;
 use app\common\repositories\user\UserSignVrRepository;
+use app\common\repositories\user\UserSignXfbRepository;
 use app\common\repositories\user\UserThirdRepository;
 use app\common\repositories\user\UserWithdrawalLimitRecordRepository;
 use app\common\repositories\wechat\RoutineQrcodeRepository;
@@ -11735,6 +11736,24 @@ class StoreOrderRepository extends BaseRepository
                 '购买共富区商品获得PV'
             );
 
+            // 发放幸福币
+            $xfbData = [
+                'uid' => $sharedProsperityUserEntity->getUserId(),
+                'before' => 0,
+                'number' => $storeOrderEntity->getPayPrice(),
+                'after' => 0,
+                'mark' => '购买共富区商品获得幸福币：' . $storeOrderEntity->getPayPrice(),
+                'desc' => '购买共富区商品获得幸福币',
+                'order_sn' => $storeOrderEntity->getOrderSn(),
+                'order_type' => $storeOrderEntity->getOrderType(),
+                'type' => 1,
+                'addtime' => time()
+            ];
+            /** @var UserSignXfbRepository $xfbRepository */
+            $xfbRepository = app()->make(UserSignXfbRepository::class);
+            $xfbRepository->create($xfbData);
+
+
             if (!empty($sharedProsperityUserEntity->getParentId())) {
                 // 如果 共富区推荐人 不是平台，则为 推荐人发放 推荐奖励
                 $sharedProsperityUserEntityByParent = $sharedProsperityUserRepository->getSharedProsperityUserEntityByUserId($sharedProsperityUserEntity->getParentId());
@@ -12210,6 +12229,12 @@ class StoreOrderRepository extends BaseRepository
                     }, $userWithdrawalLimitRecordEntityList);
                     $userWithdrawalLimitRecordRepository->executeByIdList($userWithdrawalLimitRecordIdList);
                 }
+
+                // 结算幸福币
+                /** @var UserSignXfbRepository $xfbRepository */
+                $xfbRepository = app()->make(UserSignXfbRepository::class);
+                // 结算
+                $xfbRepository->settlement($unsettledOrderSnList);
             } catch (DbException $e) {
                 throw new ValidateException('订单结算失败');
             }

app/common/repositories/user/UserSignXfbRepository.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace app\common\repositories\user;
+
+use app\common\dao\user\UserDao;
+use app\common\dao\user\UserSignVrDao;
+use app\common\enum\user\UserSignVrEnum;
+use app\common\repositories\BaseRepository;
+use app\common\repositories\store\order\StoreOrderRepository;
+use app\entity\data\user\UserEntity;
+use app\entity\data\user\UserSignVrEntity;
+use think\db\exception\DbException;
+use think\exception\ValidateException;
+
+class UserSignXfbRepository extends BaseRepository
+{
+    public function __construct(UserSignVrDao $dao)
+    {
+        $this->dao = $dao;
+    }
+
+    public function create($data)
+    {
+        return $this->dao->create($data);
+    }
+
+    // 结算
+    public function settlement($orderSn)
+    {
+        foreach ($orderSn as $item) {
+            // 日志模型
+            $logModel = $this->dao->getWhere(['order_sn' => $item]);
+            // 用户模型
+            $userDao = new UserDao();
+            $userModel = $userDao->getWhere(['uid'=>$logModel->uid]);
+
+            // 修改日志表字段
+            $logModel->before = $userModel->xfb;
+            $logModel->after = $userModel->xfb + $logModel->number;;
+            $logModel->settlement_time = date('Y-m-d H:i:s');
+            $logModel->save();
+
+            // 修改用户表字段
+            $userModel->xfb = $userModel->xfb + $logModel->number;
+            $userModel->save();
+        }
+    }
+
+}