实名列表逻辑调整

src/functional/mvc/service/mUserRealName.service.ts

@@ -41,6 +41,8 @@ export interface QueryVO {
     from_time?: Date | any
 
     to_time?: Date | any
+
+    condition?: string
 }
 
 export async function getRealNameByUserId(user_id: number | any) {
@@ -70,28 +72,49 @@ export async function getRealNameMapByUserIds(userIds: number[]) {
 
 
 export async function kycList(queryVO: QueryVO) {
-    let where = {}
-    if (queryVO.user_id) {
-        //uid 是否在受限范围内
-        if (isLimitUserId(queryVO.user_id)) {
-            throw ErrorCode.UID_LIMIT
+    let condition = queryVO.condition;
+    let uids: any = [];
+    let userMap = {};
+    if (condition) {
+        let orCondition = {
+            email: String(condition),
+            real_name: String(condition),
+            phone: String(condition),
+            identity: String(condition),
+        };
+
+        if (!isNaN(Number(condition))) {
+            orCondition['user_id'] = Number(condition)
         }
-        where["user_id"] = queryVO.user_id;
-    }
-    else {
-        if (UID_MIN && UID_LIMIT.length) {
-            where[ormDB.Op.and] = [{
-                user_id: { [ormDB.Op.gte]: UID_MIN }
-            },
-                {
-                    user_id: { [ormDB.Op.notIn]: UID_LIMIT },
-                }]
+
+        let dbUserList = await userInfo.prototype.findAll({
+            attributes: ['user_id', 'email', 'phone'],
+            where: { [ormDB.Op.or]: orCondition },
+            raw: true
+        });
+        if (!dbUserList.length) {
+            return {
+                count: 0,
+                rows: []
+            }
         }
-        else {
-            where["user_id"] = { [ormDB.Op.gte]: UID_MIN }
+        for (let one of dbUserList) {
+            uids.push(one.user_id)
+            userMap[one.user_id] = one.email;
+        }
+    }
+
+    let where = {}
+    if (uids.length) {
+        where['user_id'] = { [ormDB.Op.in]: uids }
+    }
+    if (condition && !isNaN(Number(condition))) {
+        where[ormDB.Op.or] = {
+            user_id: Number(condition),
+            identity: condition
         }
     }
-    if (!isNaN(Number(queryVO.status))) {
+    if (queryVO.status || queryVO.status === 0) {
         where["status"] = queryVO.status
     }
     if (queryVO.source) {
@@ -129,17 +152,18 @@ export async function kycList(queryVO: QueryVO) {
     });
 
     if (resList.rows.length) {
-        let uids = resList.rows.map(item => item.user_id);
-        let userMap = {};
-        let dbUserInfos = await userInfo.prototype.findAll({
-            attributes: ['user_id', 'email'],
-            where: {
-                user_id: { [ormDB.Op.in]: uids }
-            },
-            raw: true
-        });
-        for (let dbUserInfo of dbUserInfos) {
-            userMap[dbUserInfo.user_id] = dbUserInfo.email;
+        if (!uids.length) {
+            uids = resList.rows.map(item => item.user_id);
+            let dbUserInfos = await userInfo.prototype.findAll({
+                attributes: ['user_id', 'email'],
+                where: {
+                    user_id: { [ormDB.Op.in]: uids }
+                },
+                raw: true
+            });
+            for (let dbUserInfo of dbUserInfos) {
+                userMap[dbUserInfo.user_id] = dbUserInfo.email;
+            }
         }
         for (let item of resList.rows) {
             item.email = userMap[item.user_id] ? userMap[item.user_id] : ""