d

im-center/app/base/db/impl/msg/msguserDao.js

-const system = require("../../../system");
-const Dao = require("../../dao.base");
-class MsguserDao extends Dao {
-    constructor() {
-        super(Dao.getModelName(MsguserDao));
-    }
-}
-module.exports = MsguserDao;

im-center/app/base/db/models/msg/msgnotice.js

 module.exports = (db, DataTypes) => {
   return db.define("msgnotice", {
     fromuser: DataTypes.STRING,//需要在后台补充
-    fromId:DataTypes.INTEGER,
+    fromId: DataTypes.INTEGER,
     touser: DataTypes.STRING,//需要在后台补充
-    toId:DataTypes.INTEGER,
-    isAccepted:DataTypes.BOOLEAN,
-    lastMsgId:DataTypes.INTEGER,
-  },{
-     paranoid: true,//假的删除
-     underscored: true,
-     version: true,
-     freezeTableName: true,
-     //freezeTableName: true,
-     // define the table's name
-     tableName: 'msgnotice',
-     validate: {
+    toId: DataTypes.INTEGER,
+    isAccepted: DataTypes.BOOLEAN,
+    lastMsgId: DataTypes.INTEGER,
+  }, {
+      paranoid: true,//假的删除
+      underscored: true,
+      version: true,
+      freezeTableName: true,
+      //freezeTableName: true,
+      // define the table's name
+      tableName: 'msgnotice',
+      validate: {
 
-     },
-     indexes:[
-       // Create a unique index on email
+      },
+      indexes: [
+        // Create a unique index on email
         //  {
         //    unique: true,
         //    fields: ['email']
         //  },
-         //
+        //
         //  // Creates a gin index on data with the jsonb_path_ops operator
         //  {
         //    fields: ['data'],
         //    using: 'gin',
         //    operator: 'jsonb_path_ops'
         //  },
-         //
+        //
         //  // By default index name will be [table]_[fields]
         //  // Creates a multi column partial index
         //  {
@@ -40,13 +40,13 @@ module.exports = (db, DataTypes) => {
         //      status: 'public'
         //    }
         //  },
-         //
+        //
         //  // A BTREE index with a ordered field
         //  {
         //    name: 'title_index',
         //    method: 'BTREE',
         //    fields: ['author', {attribute: 'title', collate: 'en_US', order: 'DESC', length: 5}]
         //  }
-     ]
-  });
+      ]
+    });
 }

im-center/app/base/service/impl/msg/msgSve.js

-const system = require("../../../system");
-const ServiceBase = require("../../sve.base");
-const moment = require("moment");
-
-class MsgService extends ServiceBase {
-    constructor() {
-        super("msg", ServiceBase.getDaoName(MsgService));
-        this.msguserDao = system.getObject("db.msg.msguserDao");
-
-    }
-    async create(pobj, qobj, req) {
-        let {
-            msgType, app_id, app_key, sender, sender_id, title,
-            content, jump_address, other, target, company_id
-        } = pobj;
-
-        let msg = {
-            msgType,
-            app_id,
-            app_key,
-            sender: sender,
-            sender_id: sender_id,
-            title,
-            content,
-            jump_address,
-            other,
-            company_id
-        }
-        return this.db.transaction(async (t) => {
-            const msgData = await this.dao.create(msg, t);
-            if (msgType !== system.Msg.SYS && Object.prototype.toString.call(target) === '[object Object]') {
-                await this.msguserDao.create({
-                    user_id: target.id,
-                    user: target.name,
-                    msg_id: msgData.id
-                }, t);
-            }
-            if (msgType !== system.Msg.SYS && Object.prototype.toString.call(target) === "[object Array]") {
-                let msgusers = [];
-                for (let val of target) {
-                    msgusers.push({
-                        user_id: val.id,
-                        user: val.name,
-                        msg_id: msgData.id
-                    })
-                }
-                await this.msguserDao.bulkCreate(msgusers, t);
-            }
-            return 'SUCCESS'
-        })
-    }
-
-    async findRemindMessage(pobj, qobj, req) {
-        let { userid } = pobj;
-        const msgData = await this.msguserDao.findAll({
-            user_id: userid,
-            is_remind: false
-        }, [
-            {
-                model: this.db.models.msg,
-                where: {
-                    is_undo: false
-                },
-            }
-        ]);
-        const ids = msgData.map(item => item.id)
-        if (ids.length > 0) {
-            this.msguserDao.updateByWhere({
-                is_remind: true
-            }, {
-                id: {
-                    $in: ids
-                }
-            });
-        }
-        return msgData;
-    }
-
-    async findUnreadCount(pobj, qobj, req) {
-        let { userid, is_read } = pobj;
-        const msgCount = await this.msguserDao.findCount({
-            where: {
-                user_id: userid,
-                is_read
-            }, include: [
-                {
-                    model: this.db.models.msg,
-                    where: {
-                        is_undo: false
-                    },
-                    attributes: ["id"]
-                }
-            ]
-        });
-        return { count: msgCount };
-    }
-
-    async updateStatus(pobj, qobj, req) {
-        let { id, userid, all } = pobj;
-        let where = {
-            is_read: false,
-            user_id: userid
-        };
-        if (!all) {
-            where.id = id
-        }
-        await this.msguserDao.updateByWhere({
-            is_read: true
-        }, where);
-        return "SUCESS"
-    }
-
-    async findSystemMsgCount(pobj, qobj, req) {
-        let { type, company_id } = pobj;
-
-        let where = {
-            msgType: system.Msg.SYS,
-            is_undo: false,
-            company_id: {
-                $in: [1, company_id]
-            }
-        }
-        if (type === "recently") {
-            // 查询 三天内的
-            where.created_at = {
-                $between: [
-                    moment().subtract('days', 3).endOf('day').format('YYYY-MM-DD HH:mm:ss'),
-                    moment().endOf('day').format('YYYY-MM-DD HH:mm:ss')
-                ]
-            }
-        }
-        const msgCount = await this.dao.findCount({
-            where
-        });
-        return { count: msgCount };
-    }
-
-    async groupCount(pobj, qobj, req) {
-        let { userid } = pobj;
-        let [read, unRead, system] = await Promise.all(
-            [
-                this.findUnreadCount({ userid, is_read: true }),
-                this.findUnreadCount({ userid, is_read: false }),
-                this.findSystemMsgCount({ type: "all" })
-            ]
-        );
-        return {
-            read: read.count, unRead: unRead.count, system: system.count
-        }
-    }
-
-    async list(pobj, qobj, req) {
-        let { userid, msgType, pageSize = 10, pageNo = 1, company_id } = pobj;
-        let msgData = [];
-        let other = {
-            limit: pageSize,
-            offset: (pageNo - 1) * pageSize,
-            order: [["created_at", "DESC"]]
-        };
-        if (["readed", "unread"].includes(msgType)) {
-            msgData = await this.msguserDao.findAll({
-                user_id: userid,
-                is_read: msgType === "readed"
-            }, [
-                {
-                    model: this.db.models.msg,
-                    where: {
-                        is_undo: false
-                    }
-                }
-            ], other);
-        }
-        if (msgType === "sys") {
-            msgData = await this.dao.findAll({
-                msgType: system.Msg.SYS,
-                is_undo: false,
-                company_id: {
-                    $in: [1, company_id]
-                }
-            }, [], other);
-            msgData = msgData.map(item => {
-                return {
-                    msg: item
-                }
-            })
-        }
-        return msgData;
-    }
-}
-module.exports = MsgService;