提交 | 用户 | age
|
d7a15c
|
1 |
using Newtonsoft.Json; |
D |
2 |
using SqlSugar; |
|
3 |
using System; |
90c6eb
|
4 |
using System.Collections.Generic; |
J |
5 |
using System.ComponentModel; |
|
6 |
using System.Data; |
|
7 |
using System.Drawing; |
|
8 |
using System.Drawing.Drawing2D; |
|
9 |
using System.Drawing.Imaging; |
|
10 |
using System.IO; |
|
11 |
using System.Linq; |
|
12 |
using System.Runtime.InteropServices; |
|
13 |
using System.Text; |
|
14 |
using System.Threading.Tasks; |
|
15 |
using System.Windows.Forms; |
4b8004
|
16 |
using uPLibrary.Networking.M2Mqtt; |
J |
17 |
using uPLibrary.Networking.M2Mqtt.Messages; |
d7a15c
|
18 |
using WindowsFormsApp1.Common; |
D |
19 |
using WindowsFormsApp1.Controllers; |
|
20 |
using WindowsFormsApp1.Entity; |
|
21 |
using WindowsFormsApp1.Helper; |
|
22 |
using WindowsFormsApp1.Item; |
90c6eb
|
23 |
|
J |
24 |
namespace WindowsFormsApp1 |
|
25 |
{ |
|
26 |
public partial class Form1 : Form |
|
27 |
{ |
d7a15c
|
28 |
private Metafile metafile1; |
D |
29 |
private Graphics.EnumerateMetafileProc metafileDelegate; |
|
30 |
private MqttClient client = null; |
|
31 |
|
90c6eb
|
32 |
public Form1() |
4b8004
|
33 |
{ |
90c6eb
|
34 |
InitializeComponent(); |
d7a15c
|
35 |
|
90c6eb
|
36 |
} |
d7a15c
|
37 |
|
D |
38 |
|
|
39 |
string _UserNo { get { return MqttconfigHelp.UserName.Trim(); } } |
|
40 |
string _PW { get { return MqttconfigHelp.Password.Trim(); } } |
90c6eb
|
41 |
private bool MetafileCallback(EmfPlusRecordType recordType, int flags, int dataSize, IntPtr data, PlayRecordCallback callbackData) |
J |
42 |
{ |
|
43 |
byte[] dataArray = null; |
|
44 |
if (data != IntPtr.Zero) |
|
45 |
{ |
|
46 |
|
|
47 |
dataArray = new byte[dataSize]; |
|
48 |
Marshal.Copy(data, dataArray, 0, dataSize); |
|
49 |
//GdipComment |
|
50 |
metafile1.PlayRecord(recordType, flags, dataSize, dataArray); |
|
51 |
switch (recordType) //记录类型 |
|
52 |
{ |
|
53 |
|
|
54 |
case EmfPlusRecordType.Object: //对象 |
|
55 |
case EmfPlusRecordType.DrawLines: //线 |
|
56 |
case EmfPlusRecordType.SetPageTransform: //设置页变换 |
|
57 |
break; |
|
58 |
} |
|
59 |
} |
|
60 |
Console.WriteLine(recordType.ToString()); |
|
61 |
return true; |
|
62 |
} |
|
63 |
|
|
64 |
protected override void OnPaint(PaintEventArgs e) |
|
65 |
{ |
d7a15c
|
66 |
//PointF destPoint = new PointF(e.ClipRectangle.X, e.ClipRectangle.Y); |
4b8004
|
67 |
//e.Graphics.EnumerateMetafile(metafile1, destPoint, metafileDelegate); |
90c6eb
|
68 |
|
J |
69 |
} |
|
70 |
protected override void OnClosed(EventArgs e) |
|
71 |
{ |
|
72 |
base.OnClosed(e); |
4b8004
|
73 |
//metafile1.Dispose(); |
90c6eb
|
74 |
} |
J |
75 |
string emf { get; set; } |
|
76 |
/// <summary> |
|
77 |
/// 导出为 Emf 或 Wmf 文件 |
|
78 |
/// </summary> |
|
79 |
/// <param name="filePath">文件路径</param> |
|
80 |
/// <returns>是否成功</returns> |
|
81 |
private bool Export(string filePath) |
|
82 |
{ |
|
83 |
|
d7a15c
|
84 |
filePath = @"D:\CompanyCode\DIXWeb\src\WindowsFormsApp1\imgs\imgup.jpg"; |
D |
85 |
//filePath = @"C:\Users\Administrator\Desktop\Debug\1.jpg"; |
90c6eb
|
86 |
FileInfo fi = new FileInfo(filePath); |
J |
87 |
emf = Path.GetDirectoryName(filePath) + "\\1.emf"; |
|
88 |
fi.CopyTo(emf,true); |
|
89 |
try |
|
90 |
{ |
|
91 |
Bitmap bmp = new Bitmap(2220, 2220); |
|
92 |
Graphics gs = Graphics.FromImage(bmp); |
|
93 |
Metafile mf = new Metafile(emf, gs.GetHdc()); |
|
94 |
|
|
95 |
Graphics g = Graphics.FromImage(mf); |
|
96 |
//string sf = System.IO.Path.GetDirectoryName(filePath) + "1.wmf"; |
|
97 |
//mf.Save(sf, ImageFormat.Wmf); |
|
98 |
Draw(g); |
|
99 |
g.Save(); |
|
100 |
|
|
101 |
g.Dispose(); |
|
102 |
mf.Dispose(); |
|
103 |
|
|
104 |
return true; |
|
105 |
} |
|
106 |
catch(Exception er) |
|
107 |
{ |
|
108 |
MessageBox.Show(er.Message); |
|
109 |
return false; |
|
110 |
} |
|
111 |
} |
|
112 |
/// <summary> |
|
113 |
/// 绘制图形 |
|
114 |
/// </summary> |
|
115 |
/// <param name="g">用于绘图的Graphics对象</param> |
|
116 |
private void Draw(Graphics g) |
|
117 |
{ |
|
118 |
HatchBrush hb = new HatchBrush(HatchStyle.LightUpwardDiagonal, Color.Black, Color.White); |
|
119 |
|
|
120 |
g.FillEllipse(Brushes.Gray, 10f, 10f, 200, 200); |
|
121 |
g.DrawEllipse(new Pen(Color.Black, 1f), 10f, 10f, 200, 200); |
|
122 |
|
|
123 |
g.FillEllipse(hb, 30f, 95f, 30, 30); |
|
124 |
g.DrawEllipse(new Pen(Color.Black, 1f), 30f, 95f, 30, 30); |
|
125 |
|
|
126 |
g.FillEllipse(hb, 160f, 95f, 30, 30); |
|
127 |
g.DrawEllipse(new Pen(Color.Black, 1f), 160f, 95f, 30, 30); |
|
128 |
|
|
129 |
g.FillEllipse(hb, 95f, 30f, 30, 30); |
|
130 |
g.DrawEllipse(new Pen(Color.Black, 1f), 95f, 30f, 30, 30); |
|
131 |
|
|
132 |
g.FillEllipse(hb, 95f, 160f, 30, 30); |
|
133 |
g.DrawEllipse(new Pen(Color.Black, 1f), 95f, 160f, 30, 30); |
|
134 |
|
|
135 |
g.FillEllipse(Brushes.Blue, 60f, 60f, 100, 100); |
|
136 |
g.DrawEllipse(new Pen(Color.Black, 1f), 60f, 60f, 100, 100); |
|
137 |
|
|
138 |
g.FillEllipse(Brushes.BlanchedAlmond, 95f, 95f, 30, 30); |
|
139 |
g.DrawEllipse(new Pen(Color.Black, 1f), 95f, 95f, 30, 30); |
|
140 |
|
|
141 |
g.DrawRectangle(new Pen(System.Drawing.Brushes.Blue, 0.1f), 6, 6, 208, 208); |
|
142 |
|
|
143 |
g.DrawLine(new Pen(Color.Black, 0.1f), 110f, 110f, 220f, 25f); |
|
144 |
g.DrawString("剖面图", new Font("宋体", 9f), Brushes.Green, 220f, 20f); |
|
145 |
} |
|
146 |
private void button1_Click(object sender, EventArgs e) |
|
147 |
{ |
d7a15c
|
148 |
|
D |
149 |
string MotifName=txtFilePath.Text.ToString(); |
|
150 |
var db = SqlSugarConnection.SugarClient(); |
|
151 |
List<Toprie_Motif> ToprieMotifList = db.SqlQueryable<Toprie_Motif>("select * from Toprie_Motif").Where(m => m.IsVal == 0).ToList(); |
|
152 |
|
|
153 |
if (ToprieMotifList.Where(m => m.MotifName == MotifName).ToList().Count() == 0) |
|
154 |
{ |
|
155 |
if (!string.IsNullOrEmpty(MotifName)) |
|
156 |
{ |
|
157 |
Toprie_Motif ToprieMotif = new Toprie_Motif(); |
|
158 |
ToprieMotif.Code = SnowFlakeSingle.Instance.NextId().ToString(); |
|
159 |
ToprieMotif.MotifName = MotifName; |
|
160 |
ToprieMotif.Address = ""; |
|
161 |
ToprieMotif.Remark = ""; |
|
162 |
ToprieMotif.IsVal = 0; |
|
163 |
ToprieMotif.CreateCode = "5105986045"; |
|
164 |
ToprieMotif.CreateTime = DateTime.Now; |
|
165 |
InsertToprieMotif(ToprieMotif); |
|
166 |
MessageBox.Show("新增成功", "提示"); |
|
167 |
|
|
168 |
}else { |
|
169 |
MessageBox.Show("请输入订阅主题", "提示"); |
|
170 |
} |
|
171 |
} |
|
172 |
else{ |
|
173 |
MessageBox.Show("当前主题已添加,无法重复添加", "提示"); |
|
174 |
} |
90c6eb
|
175 |
} |
60f582
|
176 |
|
J |
177 |
private void button2_Click(object sender, EventArgs e) |
|
178 |
{ |
|
179 |
|
|
180 |
} |
4b8004
|
181 |
|
J |
182 |
|
|
183 |
/// <summary> |
|
184 |
/// 发布消息成功后调用的事件 |
|
185 |
/// </summary> |
|
186 |
/// <param name="sender"></param> |
|
187 |
/// <param name="e"></param> |
|
188 |
private void client_MqttMsgPublished(object sender, MqttMsgPublishedEventArgs e) |
|
189 |
{ |
d7a15c
|
190 |
MessageBox.Show("发布消息成功。", "信息"); |
4b8004
|
191 |
} |
J |
192 |
|
|
193 |
/// <summary> |
|
194 |
/// 订阅主题成功后调用的事件 |
|
195 |
/// </summary> |
|
196 |
/// <param name="sender"></param> |
|
197 |
/// <param name="e"></param> |
|
198 |
private void client_MqttMsgSubscribed(object sender, MqttMsgSubscribedEventArgs e) |
|
199 |
{ |
d7a15c
|
200 |
|
4b8004
|
201 |
|
J |
202 |
} |
|
203 |
|
|
204 |
/// <summary> |
|
205 |
/// 取消订阅主题成功后调用的事件 |
|
206 |
/// </summary> |
|
207 |
/// <param name="sender"></param> |
|
208 |
/// <param name="e"></param> |
|
209 |
private void client_MqttMsgUnsubscribed(object sender, MqttMsgUnsubscribedEventArgs e) |
|
210 |
{ |
d7a15c
|
211 |
MessageBox.Show("取消订阅主题成功。", "信息"); |
4b8004
|
212 |
} |
J |
213 |
|
|
214 |
/// <summary> |
|
215 |
/// 当接收到订阅主题的消息时调用的事件 |
|
216 |
/// </summary> |
|
217 |
/// <param name="sender"></param> |
|
218 |
/// <param name="e"></param> |
|
219 |
private void client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e) |
|
220 |
{ |
d7a15c
|
221 |
SnowFlakeSingle.WorkId =1; |
D |
222 |
|
|
223 |
|
|
224 |
try { |
|
225 |
this.Invoke(new Action(() => |
|
226 |
{ |
|
227 |
txt_SubscribeMessage.Text += DateTime.Now.ToString("yyyy/MM/dd-HH:mm:ss") + " Received topic: " + e.Topic + ", message: " + Encoding.UTF8.GetString(e.Message) + "\n"; |
|
228 |
string Topic = e.Topic; |
|
229 |
string Message = Encoding.UTF8.GetString(e.Message); |
|
230 |
bool DupFlag = e.DupFlag; |
|
231 |
byte QosLevel = e.QosLevel; |
|
232 |
bool Retain = e.Retain; |
|
233 |
|
|
234 |
lbMsg.Items.Insert(0, Encoding.UTF8.GetString(e.Message)); |
|
235 |
lbMsg.Items.Insert(0, "订阅主题:"+ Topic+ "********************************************* --" + DateTime.Now.ToString("yyyy/MM/dd-HH:mm:ss")); |
|
236 |
|
|
237 |
if (Message!= "getParam"){ |
|
238 |
|
|
239 |
ToreieItem ToreieItem = JsonConvert.DeserializeObject<ToreieItem>(Encoding.UTF8.GetString(e.Message)); |
|
240 |
|
|
241 |
List<Toprie> ToprieList = new List<Toprie>(); |
|
242 |
|
|
243 |
if (ToreieItem.sensorDatas != null && ToreieItem.sensorDatas.Count() > 0) |
|
244 |
{ |
|
245 |
|
|
246 |
foreach (var item in ToreieItem.sensorDatas) |
|
247 |
{ |
|
248 |
|
|
249 |
Toprie obj = new Toprie(); |
|
250 |
obj.Code = SnowFlakeSingle.Instance.NextId().ToString(); |
|
251 |
obj.motif = Topic; |
|
252 |
obj.times = ToreieItem.times; |
|
253 |
obj.flag = item.flag; |
|
254 |
obj.CreateCode = "5105986045"; |
|
255 |
obj.CreateTime = DateTime.Now; |
|
256 |
|
|
257 |
switch (item.flag) |
|
258 |
{ |
|
259 |
case FlagHelp.flag1: |
|
260 |
case FlagHelp.flag2: |
|
261 |
case FlagHelp.flag3: |
|
262 |
case FlagHelp.flag4: |
|
263 |
case FlagHelp.flag5: |
|
264 |
case FlagHelp.flag7: |
|
265 |
obj.val = item.value; |
|
266 |
break; |
|
267 |
case FlagHelp.flag6: |
|
268 |
obj.switcher = item.switcher; |
|
269 |
break; |
|
270 |
|
|
271 |
case FlagHelp.flag8: |
|
272 |
obj.lat = item.lat; |
|
273 |
obj.lng = item.lng; |
|
274 |
break; |
|
275 |
case FlagHelp.flagICCID: |
|
276 |
obj.str = item.str; |
|
277 |
break; |
|
278 |
default: |
|
279 |
continue; |
|
280 |
} |
|
281 |
ToprieList.Add(obj); |
|
282 |
|
|
283 |
} |
|
284 |
} |
|
285 |
|
|
286 |
InsertListToprieList(ToprieList); |
|
287 |
|
|
288 |
} |
|
289 |
|
|
290 |
})); |
|
291 |
|
|
292 |
} |
|
293 |
catch (Exception ex) { |
|
294 |
|
|
295 |
string str = ex.ToString(); |
|
296 |
|
|
297 |
} |
4b8004
|
298 |
} |
J |
299 |
|
|
300 |
/// <summary> |
|
301 |
/// 当连接断开时调用的事件 |
|
302 |
/// </summary> |
|
303 |
/// <param name="sender"></param> |
|
304 |
/// <param name="e"></param> |
|
305 |
private void client_ConnectionClosed(object sender, EventArgs e) |
|
306 |
{ |
d7a15c
|
307 |
MessageBox.Show("连接已断开。", "信息"); |
4b8004
|
308 |
} |
J |
309 |
|
|
310 |
/// <summary> |
|
311 |
/// 连接 |
|
312 |
/// </summary> |
|
313 |
/// <param name="sender"></param> |
|
314 |
/// <param name="e"></param> |
|
315 |
private void btn_Connect_Click(object sender, EventArgs e) |
|
316 |
{ |
|
317 |
try |
|
318 |
{ |
d7a15c
|
319 |
string brokerAddress = MqttconfigHelp.BrokerAddress; |
D |
320 |
int brokerPort = MqttconfigHelp.BrokerPort; |
4b8004
|
321 |
client = new MqttClient(brokerAddress, brokerPort, false, null, null, MqttSslProtocols.None, null); //实例化mqtt客户端 |
812400
|
322 |
|
J |
323 |
string clientId = Guid.NewGuid().ToString("N"); //生成32位全球唯一标识符 |
|
324 |
client.Connect(clientId,"",""); //建立客户端连接 |
4b8004
|
325 |
|
J |
326 |
client.MqttMsgPublished += client_MqttMsgPublished; //发布消息成功后调用 |
|
327 |
client.MqttMsgSubscribed += client_MqttMsgSubscribed; //订阅主题成功后调用 |
|
328 |
client.MqttMsgUnsubscribed += client_MqttMsgUnsubscribed; //取消订阅主题成功后调用 |
|
329 |
client.MqttMsgPublishReceived += client_MqttMsgPublishReceived; //当接收到订阅主题的消息时调用 |
|
330 |
client.ConnectionClosed += client_ConnectionClosed; //连接断开后调用 |
e7761b
|
331 |
MessageBox.Show("连接成功。", "信息");// |
4b8004
|
332 |
} |
J |
333 |
catch (Exception ex) |
|
334 |
{ |
d7a15c
|
335 |
MessageBox.Show("连接失败!\n\r" + ex.Message.ToString(), "警告"); |
4b8004
|
336 |
} |
J |
337 |
} |
|
338 |
|
|
339 |
/// <summary> |
|
340 |
/// 断开连接 |
|
341 |
/// </summary> |
|
342 |
/// <param name="sender"></param> |
|
343 |
/// <param name="e"></param> |
|
344 |
private void btn_DisConnect_Click(object sender, EventArgs e) |
|
345 |
{ |
|
346 |
client.Disconnect(); |
|
347 |
} |
|
348 |
|
|
349 |
/// <summary> |
|
350 |
/// 发布消息 |
|
351 |
/// </summary> |
|
352 |
/// <param name="sender"></param> |
|
353 |
/// <param name="e"></param> |
|
354 |
private void btn_Publish_Click(object sender, EventArgs e) |
|
355 |
{ |
d7a15c
|
356 |
//string publishTopic = txt_PublishTopic.Text.ToString(); //发布的主题 |
D |
357 |
//string publishMessage = txt_PublishMessage.Text.ToString(); //发布的消息 |
|
358 |
//client.Publish(publishTopic, Encoding.UTF8.GetBytes(publishMessage)); //发布消息 |
4b8004
|
359 |
} |
J |
360 |
|
|
361 |
/// <summary> |
|
362 |
/// 订阅消息 |
|
363 |
/// </summary> |
|
364 |
/// <param name="sender"></param> |
|
365 |
/// <param name="e"></param> |
|
366 |
private void btn_Subscribe_Click(object sender, EventArgs e) |
|
367 |
{ |
d7a15c
|
368 |
|
D |
369 |
try { |
|
370 |
|
|
371 |
client = new MqttClient(MqttconfigHelp.BrokerAddress,MqttconfigHelp.BrokerPort, false, null, null, MqttSslProtocols.None, null); //实例化mqtt客户端 |
|
372 |
|
|
373 |
string clientId = Guid.NewGuid().ToString("N"); //生成32位全球唯一标识符 |
|
374 |
client.Connect(clientId, MqttconfigHelp.UserName, MqttconfigHelp.Password); //建立客户端连接 |
|
375 |
|
|
376 |
client.MqttMsgPublished += client_MqttMsgPublished; //发布消息成功后调用 |
|
377 |
client.MqttMsgSubscribed += client_MqttMsgSubscribed; //订阅主题成功后调用 |
|
378 |
client.MqttMsgUnsubscribed += client_MqttMsgUnsubscribed; //取消订阅主题成功后调用 |
|
379 |
client.MqttMsgPublishReceived += client_MqttMsgPublishReceived; //当接收到订阅主题的消息时调用 |
e7761b
|
380 |
client.ConnectionClosed += client_ConnectionClosed;//连接断开后调用 |
d7a15c
|
381 |
|
D |
382 |
string[] subscribeTopic = Toprie_MotifList().Split(','); //可以同时订阅多个主题的消息,各主题之间用逗号分隔 |
|
383 |
byte[] qosLevels = new byte[] { MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE }; |
|
384 |
|
e7761b
|
385 |
foreach (var item in subscribeTopic){ |
d7a15c
|
386 |
string[] MotifNameList ={ item }; |
D |
387 |
client.Subscribe(MotifNameList, qosLevels); |
|
388 |
} |
|
389 |
//this.Opacity = 0; |
|
390 |
MessageBox.Show("订阅主题成功。", "信息"); |
|
391 |
} |
|
392 |
catch (Exception ex){ |
e7761b
|
393 |
MessageBox.Show(ex.Message.ToString(),"异常"); |
d7a15c
|
394 |
} |
D |
395 |
|
4b8004
|
396 |
} |
J |
397 |
|
|
398 |
/// <summary> |
|
399 |
/// 取消订阅消息 |
|
400 |
/// </summary> |
|
401 |
/// <param name="sender"></param> |
|
402 |
/// <param name="e"></param> |
|
403 |
private void btn_UnSubscribe_Click(object sender, EventArgs e) |
|
404 |
{ |
d7a15c
|
405 |
string[] unSubscribeTopic =null; |
4b8004
|
406 |
client.Unsubscribe(unSubscribeTopic); |
J |
407 |
} |
|
408 |
|
|
409 |
/// <summary> |
|
410 |
/// 窗口关闭事件 |
|
411 |
/// </summary> |
|
412 |
/// <param name="sender"></param> |
|
413 |
/// <param name="e"></param> |
|
414 |
private void Window_Closed(object sender, EventArgs e) |
|
415 |
{ |
|
416 |
Environment.Exit(0); //强制退出,即使有其他的线程没有结束,因为M2Mqtt调用事件都是在单独的线程中进行的 |
|
417 |
} |
d7a15c
|
418 |
|
D |
419 |
private void txtFilePath_TextChanged(object sender, EventArgs e) |
|
420 |
{ |
|
421 |
|
|
422 |
|
|
423 |
} |
|
424 |
|
|
425 |
private void Form1_Load(object sender, EventArgs e) |
|
426 |
{ |
|
427 |
//this.Opacity = 0; |
|
428 |
////窗体最小化显示 |
|
429 |
//this.WindowState = FormWindowState.Minimized; |
|
430 |
////不显示在任务栏中 |
|
431 |
//this.ShowInTaskbar = false; |
|
432 |
|
|
433 |
} |
|
434 |
|
|
435 |
|
|
436 |
/// <summary> |
|
437 |
/// |
|
438 |
/// </summary> |
|
439 |
public void InsertToprie(Toprie Toprie) |
|
440 |
{ |
|
441 |
try |
|
442 |
{ |
|
443 |
var db = SqlSugarConnection.SugarClient(); |
|
444 |
int RowIndex = db.Insertable(Toprie).ExecuteReturnIdentity(); |
|
445 |
} |
|
446 |
catch (Exception ex) |
|
447 |
{ |
|
448 |
|
|
449 |
} |
|
450 |
} |
|
451 |
|
|
452 |
|
|
453 |
/// <summary> |
|
454 |
/// 批量添加数据 |
|
455 |
/// </summary> |
|
456 |
public void InsertListToprieList(List<Toprie> ToprieList) |
|
457 |
{ |
|
458 |
|
|
459 |
try |
|
460 |
{ |
|
461 |
|
|
462 |
var db = SqlSugarConnection.SugarClient(); |
|
463 |
int RowIndex = db.Insertable(ToprieList).ExecuteReturnIdentity(); |
|
464 |
} |
|
465 |
catch (Exception ex) |
|
466 |
{ |
|
467 |
|
|
468 |
} |
|
469 |
} |
|
470 |
|
|
471 |
/// <summary> |
|
472 |
/// 获取所有订阅主题 |
|
473 |
/// </summary> |
|
474 |
public string Toprie_MotifList(){ |
|
475 |
|
|
476 |
try { |
|
477 |
|
|
478 |
#region 初始化 |
|
479 |
|
|
480 |
string str = ""; |
|
481 |
|
|
482 |
#endregion |
|
483 |
|
|
484 |
#region 获取订阅主题 |
|
485 |
var db = SqlSugarConnection.SugarClient(); |
|
486 |
List<Toprie_Motif> ToprieMotifList = db.SqlQueryable<Toprie_Motif>("select * from Toprie_Motif").Where(m => m.IsVal == 0).ToList(); |
|
487 |
|
|
488 |
#endregion |
|
489 |
|
|
490 |
#region |
|
491 |
|
|
492 |
for (int i=0; ToprieMotifList !=null && i < ToprieMotifList.Count();i++){ |
|
493 |
|
|
494 |
if (i == ToprieMotifList.Count() - 1) |
|
495 |
{ |
|
496 |
str += ToprieMotifList[i].MotifName; |
|
497 |
} |
|
498 |
else { |
|
499 |
str += ToprieMotifList[i].MotifName + ","; |
|
500 |
} |
|
501 |
} |
|
502 |
|
|
503 |
|
|
504 |
#endregion |
|
505 |
|
|
506 |
return str; |
|
507 |
|
|
508 |
|
|
509 |
} |
|
510 |
catch (Exception ex){ |
|
511 |
|
|
512 |
return ""; |
|
513 |
|
|
514 |
} |
|
515 |
} |
|
516 |
|
|
517 |
|
|
518 |
|
|
519 |
/// <summary> |
|
520 |
/// 添加订阅主题 |
|
521 |
/// </summary> |
|
522 |
public void InsertToprieMotif(Toprie_Motif ToprieMotif) |
|
523 |
{ |
|
524 |
try |
|
525 |
{ |
|
526 |
var db = SqlSugarConnection.SugarClient(); |
|
527 |
int RowIndex = db.Insertable(ToprieMotif).ExecuteReturnIdentity(); |
|
528 |
} |
|
529 |
catch (Exception ex) |
|
530 |
{ |
|
531 |
|
|
532 |
} |
|
533 |
} |
|
534 |
|
|
535 |
private void txt_SubscribeMessage_TextChanged(object sender, EventArgs e) |
|
536 |
{ |
|
537 |
|
|
538 |
} |
|
539 |
|
|
540 |
private void txt_BrokerAddress_TextChanged(object sender, EventArgs e) |
|
541 |
{ |
|
542 |
|
|
543 |
} |
90c6eb
|
544 |
} |
J |
545 |
} |