QiFeng.ZWY.Dal/DalExt/CollectionExtDal.cs

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

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

using QiFeng.LMSD.DBUtility;
using QiFeng.LMSD.Model;
using QiFeng.LMSD.Model.EnumModel;
using QiFeng.LMSD.Utility;
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace QiFeng.LMSD.Dal.DalExt
{
    public class CollectionExtDal : BaseDal<CollectionExtDal>
    {
        public bool TransAddCollections(int collectionType, int consumerId, string collectedIds)
        {
            if (consumerId == 0 || string.IsNullOrEmpty(collectedIds))
                throw new FormatException("非法请求参数");

            var type = new CollectionType();
            if (Enum.IsDefined(typeof(CollectionType), collectionType))
            {
                type = (CollectionType)Enum.ToObject(typeof(CollectionType), collectionType);
            }
            else
                throw new FormatException("收藏类型错误");

            var ds = CollectionDal.Instance.GetList(" CollectionType = " + (int)type + " AND ConsumerId = " + consumerId + " AND CollectedId IN (" + collectedIds + ") ");
            var list = ServicesHelper.DataSetToIList<Collection>(ds).ToList();

            var result = false;
            using (var connection = new SqlConnection(DbHelperSQL.ConnectionString))
            {
                connection.Open();
                using (var sqlTrans = connection.BeginTransaction())
                {
                    try
                    {
                        var collectionIdList = collectedIds.Split(',').ToList();
                        collectionIdList.ForEach(u =>
                        {
                            if (!list.Any(c => c.CollectedId.ToString() == u))
                            {
                                var model = new Collection()
                                {
                                    CollectedId = Convert.ToInt32(u),
                                    CollectionType = (int)type,
                                    ConsumerId = consumerId,
                                    IsDelete = false,
                                    AddDate = DateTime.Now
                                };

                                if (Add(connection, sqlTrans, model) <= 0)
                                    throw new Exception();
                            }
                        });