Dao/RequestMsgRepository.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Domain;
using IDao;
using Entity.Common;
using System.Globalization;
using Common;
using PWMIS.DataMap.Entity;
using PWMIS.DataProvider.Data;
using System.Data;
using PWMIS.DataProvider.Adapter;

namespace Dao
{
    /// <summary>
    /// 接收信息表
    /// </summary>
    public class RequestMsgRepository : Repository<RequestMsgMdl>, IRequestMsgRepository
    {
        BaseHelper helper = new BaseHelper();
        /// <summary>
        /// 把用户发送的信息保存到接收信息表
        /// </summary>
        /// <param name="mol"></param>
        /// <returns></returns>
        public bool InsertRequestMsg(RequestMsgMdl mol)
        {


            //mol.ID = helper.GetGuid();
            mol.IsValid = (int)EnumCE.ValidEM.Valid;
            mol.Status = (int)EnumCE.MsgStatus.NoRead;
            mol.User_ID = null;
            mol.ReadTime = null;
            OQL q = new OQL(mol);
            OQL query = q.Insert(mol.ID, mol.OpenID, mol.Shop_ID, mol.Orders_ID, mol.MsgType, mol.Content, mol.CreateTime, mol.User_ID, mol.Status, mol.ReadTime, mol.IsValid).End;
            PWMIS.DataProvider.Data.AdoHelper db = PWMIS.DataProvider.Adapter.MyDB.GetDBHelper();
            int result = EntityQuery<RequestMsgMdl>.ExecuteOql(query, db);
            if (result <= 0)
            {
                return false;
            }
            else
            {
                return true;
            }
        }


        /// <summary>
        /// 取出用户发送的消息
        /// </summary>
        /// <param name="option"></param>
        /// <returns></returns>
        public List<RequestMsgMdl> GetRequestMsg(CommonQueryOption option)
        {
            RequestMsgMdl mdl = new RequestMsgMdl();