共富体系-用户查询方法

app/common/dao/shared/SharedProsperityUserDao.php

@@ -4,6 +4,7 @@ namespace app\common\dao\shared;
 
 use app\common\dao\BaseDao;
 use app\common\model\shared\SharedProsperityUser;
+use app\entity\data\shared\SharedProsperityUserEntity;
 
 class SharedProsperityUserDao extends BaseDao
 {
@@ -12,4 +13,29 @@ class SharedProsperityUserDao extends BaseDao
     {
         return SharedProsperityUser::class;
     }
+
+    /**
+     * @param array $userIdList
+     * @return SharedProsperityUserEntity[]
+     */
+    public function getSharedProsperityUserEntityListByUserIdList(array $userIdList): array
+    {
+        $entityList = [];
+        try {
+            /** @var SharedProsperityUser $model */
+            $model = $this->getModel();
+            $dataRes = $model::getDB()
+                ->whereIn('user_id', $userIdList)
+                ->select()
+                ->toArray();
+            if (!empty($dataRes)) {
+                $entityList = array_map(function ($data) {
+                    return SharedProsperityUserEntity::newInstance($data);
+                }, $dataRes);
+            }
+        } catch (\Exception $e) {
+
+        }
+        return $entityList;
+    }
 }

app/common/repositories/shared/SharedProsperityUserRepository.php

@@ -20,6 +20,31 @@ class SharedProsperityUserRepository extends BaseRepository
         $this->dao = $dao;
     }
 
+    /**
+     * @param int $userId
+     * @return SharedProsperityUserEntity
+     */
+    public function getSharedProsperityUserEntityByUserId(int $userId): SharedProsperityUserEntity
+    {
+        $entityList = $this->getSharedProsperityUserEntityListByUserIdList([$userId]);
+        $entity = array_shift($entityList);
+        if ($entity instanceof SharedProsperityUserEntity) {
+            return $entity;
+        } else {
+            /** @var SharedProsperityUserEntity */
+            return SharedProsperityUserEntity::newInstance();
+        }
+    }
+
+    /**
+     * @param array $userIdList
+     * @return SharedProsperityUserEntity[]
+     */
+    public function getSharedProsperityUserEntityListByUserIdList(array $userIdList): array
+    {
+        return $this->dao->getSharedProsperityUserEntityListByUserIdList($userIdList);
+    }
+
     public function create($data)
     {
         return $this->dao->create($data);