修改 DataDocking4Socket 对接程序

ningshuxia

2022-10-28 3ccb7c60e1ed8b6748ed7fb8b64b1dbe50d62abf

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using IStation.Entity;
using System.Data.SqlClient;
using SqlSugar;
using System.Threading.Tasks;
using System.Data;
 
namespace IStation.DAL
{
    /// <summary>
    /// 用户关注
    /// </summary>
    public partial class UserAttention : BaseDAL<Entity.UserAttention>
    {
        /// <summary>
        /// 
        /// </summary>
        public override ConnectionConfig ConnectionConfig
        {
            get { return ConfigHelper.DefaultConnectionConfig; }
        }
 
        /// <summary>
        /// 通过 UserID 获取
        /// </summary>
        public List<Entity.UserAttention> GetByUserID(long UserID)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.UserAttention>()
                    .Where(x => x.UserID == UserID).ToList();
            }
        }
 
        /// <summary>
        /// 通过 Object 获取
        /// </summary>
        public List<Entity.UserAttention> GetByObject(long CorpID, string ObjectType, long ObjectID)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.UserAttention>()
                    .Where(x => x.CorpID == CorpID&&x.ObjectType==ObjectType&&x.ObjectID==ObjectID).ToList();
            }
        }
 
        /// <summary>
        /// 设置
        /// </summary>
        public bool Set(long UserID, List<Entity.AttentionObjectSelected> list)
        {
            if (list == null || list.Count() < 1)
                return default;
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                try
                {
                    db.BeginTran();
                    foreach (var item in list)
                    {
                        var bol = db.Queryable<Entity.UserAttention>()
                            .Where(x => x.UserID == UserID && x.CorpID==item.CorpID&& x.ObjectType == item.ObjectType && x.ObjectID == item.ObjectID)
                            .Count() > 0;
                        if (bol)//已存在
                        {
                            if (!item.Selected)//未选择
                            {
                                var result = db.Deleteable<Entity.UserAttention>()
                                    .Where(x => x.UserID == UserID && x.CorpID==item.CorpID&& x.ObjectType == item.ObjectType && x.ObjectID == item.ObjectID)
                                    .ExecuteCommandHasChange();
                                if (!result)
                                {
                                    db.RollbackTran();
                                    return false;
                                }
                            }
                        }
                        else//不存在
                        {
                            if (item.Selected)//选择
                            {
                                var entity = new Entity.UserAttention();
                                entity.UserID = UserID;
                                entity.CorpID = item.CorpID;
                                entity.ObjectType = item.ObjectType;
                                entity.ObjectID = item.ObjectID;
                                entity.AttentionTime = DateTime.Now;
                                var id = db.Insertable(entity).ExecuteReturnSnowflakeId();
                                if (id < 1)
                                {
                                    db.RollbackTran();
                                    return false;
                                }
                            }
                        }
                    }
                    db.CommitTran();
                    return true;
                }
                catch
                {
                    db.RollbackTran();
                    throw;
                }
            }
        }
 
        /// <summary>
        /// 通过 UserID 删除
        /// </summary>
        public bool DeleteByUserID(long UserID)
        {
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Deleteable<Entity.UserAttention>()
                    .Where(x => x.UserID == UserID)
                    .ExecuteCommandHasChange();
            }
        }
 
        /// <summary>
        /// 通过 ObjectType 和 ObjectID 删除
        /// </summary>
        public bool DeleteByObject(long CorpID, string ObjectType, long ObjectID)
        {
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Deleteable<Entity.UserAttention>()
                    .Where(x =>x.CorpID==CorpID&& x.ObjectType == ObjectType && x.ObjectID == ObjectID)
                    .ExecuteCommandHasChange();
            }
        }
 
 
    }
}