1: using Ia.Ngn.Cl.Model.Data;
2: using System;
3: using System.Collections;
4: using System.Collections.Generic;
5: using System.Data;
6: using System.Linq;
7: using System.Text.RegularExpressions;
8:
9: namespace Ia.Ngn.Cl.Model.Business
10: {
11: ////////////////////////////////////////////////////////////////////////////
12:
13: /// <summary publish="true">
14: /// Provision support class of Optical Fiber Network (OFN) business model.
15: /// </summary>
16: ///
17: /// <remarks>
18: /// Copyright © 2006-2022 Jasem Y. Al-Shamlan (info@ia.com.kw), Integrated Applications - Kuwait. All Rights Reserved.
19: ///
20: /// This library is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by
21: /// the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
22: ///
23: /// This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
24: /// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
25: ///
26: /// You should have received a copy of the GNU General Public License along with this library. If not, see http://www.gnu.org/licenses.
27: ///
28: /// Copyright notice: This notice may not be removed or altered from any source distribution.
29: /// </remarks>
30: public class Provision
31: {
32: private static int imsServiceRequestAdministrativeIssueQueueOriginalCount, axePstnServiceSuspensionQueueOriginalCount, ewsdPstnServiceSuspensionQueueOriginalCount, aperiodicQueueOriginalCount;
33: private static int discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueueOriginalCount;
34:
35: private static Queue<KeyValuePair<string, string>> discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue = new Queue<KeyValuePair<string, string>>();
36: private static Queue<string> imsServiceRequestAdministrativeIssueQueue = new Queue<string>();
37: private static Queue<string> axePstnServiceSuspensionQueue = new Queue<string>();
38: private static Queue<string> ewsdPstnServiceSuspensionQueue = new Queue<string>();
39: private static Queue<string> aperiodicQueue = new Queue<string>();
40:
41: ////////////////////////////////////////////////////////////////////////////
42:
43: /// <summary>
44: ///
45: /// </summary>
46: public Provision() { }
47:
48: ////////////////////////////////////////////////////////////////////////////
49:
50: /// <summary>
51: ///
52: /// </summary>
53: public static bool CreateReadNokiaSwitchSubscriber(Ia.Ngn.Cl.Model.Client.Nokia.Ims ims, string accessName, string service, int port, Ia.Ngn.Cl.Model.Business.Default.Protocol protocol, bool overrideRouterDomainRestriction, out string result)
54: {
55: bool executed, isSip;
56: int gatewayId;
57: string r;
58: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
59: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor, accessVendor;
60: Ia.Ngn.Cl.Model.Ont ont;
61: Ia.Ngn.Cl.Model.Huawei.EmsOnt emsOnt;
62:
63: executed = false;
64: result = string.Empty;
65:
66: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
67:
68: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
69: {
70: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedNokiaSwitchDomainList(service))
71: {
72: nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByAccessName(accessName);
73:
74: if (nddOnt != null)
75: {
76: if (protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd) isSip = nddOnt.Pon.PonGroup.Olt.IsSip;
77: else isSip = protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.Sip;
78:
79: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainSameSwitchVendorButDifferentSiteExceptionList(nddOnt, service) || overrideRouterDomainRestriction)
80: {
81: accessVendor = nddOnt.Pon.PonGroup.Olt.Odf.Vendor;
82:
83: if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
84: {
85: ont = Ia.Ngn.Cl.Model.Data.Nokia.Ont.Read(nddOnt.Id);
86:
87: if (ont != null)
88: {
89: if (!isSip) // if H.248
90: {
91: gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
92:
93: if (gatewayId > 0)
94: {
95: port = (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown) ? port : Ia.Ngn.Cl.Model.Data.Nokia.Ams.NextVacantFlatTermIdForOnt(ont.FamilyTypeId, ont);
96:
97: if (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown)
98: {
99: Ia.Ngn.Cl.Model.Data.Nokia.Ims.CreateH248SubscriberAndSubPartyAndAgcfEndpoint(ims, gatewayId, service, port, nddOnt, out r);
100: result += r + ",";
101:
102: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(ims, gatewayId, out r);
103: result += r + ",";
104:
105: executed = true;
106: }
107: else
108: {
109: result += "port is invalid or does not exist,";
110: }
111: }
112: else
113: {
114: result += "gatewayId is invalid or does not exist,";
115: }
116: }
117: else // if IsSip == true
118: {
119: result += "No procedure defined for a SIP Nokia-Nokia IMS-Access setting,";
120: }
121: }
122: else
123: {
124: result += "ONT is null for access:" + nddOnt.Access.Name + ",";
125: }
126: }
127: else if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
128: {
129: emsOnt = Ia.Ngn.Cl.Model.Data.Huawei.Ont.Read(nddOnt.Id);
130:
131: if (emsOnt != null)
132: {
133: if (!isSip) // if H.248
134: {
135: gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
136:
137: if (gatewayId > 0)
138: {
139: port = (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown) ? port : Ia.Ngn.Cl.Model.Data.Default.NextVacantFlatTermIdForHuaweiEmsOntEquipmentTypeIdAndNokiaGatewayId(emsOnt.EquipmentType, gatewayId);
140:
141: if (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown)
142: {
143: Ia.Ngn.Cl.Model.Data.Nokia.Ims.CreateH248SubscriberAndSubPartyAndAgcfEndpoint(ims, gatewayId, service, port, nddOnt, out r);
144: result += r + ",";
145:
146: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(ims, gatewayId, out r);
147: result += r + ",";
148:
149: executed = true;
150: }
151: else
152: {
153: result += "port is invalid or does not exist,";
154: }
155: }
156: else
157: {
158: result += "gatewayId is invalid or does not exist,";
159: }
160: }
161: else // if IsSip == true
162: {
163: Ia.Ngn.Cl.Model.Data.Nokia.Ims.CreateSipSubscriber(ims, service, nddOnt, out r);
164: result += r + ",";
165:
166: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(ims, service, nddOnt, out r);
167: result += r + ",";
168:
169: executed = true;
170: }
171: }
172: else
173: {
174: result += "EmsOnt is null, does not exist for access:" + nddOnt.Access.Name + ",";
175: }
176: }
177: else
178: {
179: throw new Exception("accessVendor is unknown. ");
180: }
181: }
182: else result += "Service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
183: }
184: else result += "nddOnt is null, does not exist for access:" + accessName + ",";
185: }
186: else result += "service number does not belong to a Nokia switch.";
187: }
188: else
189: {
190: throw new Exception("switchVendor is null or not Nokia. ");
191: }
192:
193: return executed;
194: }
195:
196: ////////////////////////////////////////////////////////////////////////////
197:
198: /// <summary>
199: ///
200: /// </summary>
201: public static bool DeleteReadNokiaSwitchSubscriber(Ia.Ngn.Cl.Model.Client.Nokia.Ims ims, string accessName, string service, Ia.Ngn.Cl.Model.Business.Default.Protocol protocol, bool overrideRouterDomainRestriction, out string result)
202: {
203: bool executed, isSip;
204: int gatewayId;
205: string r;
206: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
207: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor, accessVendor;
208: Ia.Ngn.Cl.Model.Ont ont;
209:
210: executed = false;
211: result = string.Empty;
212:
213: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
214:
215: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
216: {
217: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedNokiaSwitchDomainList(service))
218: {
219: nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByAccessName(accessName);
220:
221: if (nddOnt != null)
222: {
223: if (protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd) isSip = nddOnt.Pon.PonGroup.Olt.IsSip;
224: else isSip = protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.Sip;
225:
226: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainSameSwitchVendorButDifferentSiteExceptionList(nddOnt, service) || overrideRouterDomainRestriction)
227: {
228: accessVendor = nddOnt.Pon.PonGroup.Olt.Odf.Vendor;
229:
230: if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
231: {
232: ont = Ia.Ngn.Cl.Model.Data.Nokia.Ont.Read(nddOnt.Id);
233:
234: if (ont != null)
235: {
236: if (!isSip) // if H.248
237: {
238: gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
239:
240: if (gatewayId > 0)
241: {
242: Ia.Ngn.Cl.Model.Data.Nokia.Ims.DeleteAgcfEndpointAndH248SubscriberAndSubParty(ims, service, nddOnt, out r);
243: result += r + ",";
244:
245: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(ims, gatewayId, out r);
246: result += r + ",";
247:
248: executed = true;
249: }
250: else
251: {
252: result += "gatewayId is invalid or does not exist,";
253: }
254: }
255: else // if IsSip == true
256: {
257: result += "No procedure defined for a SIP Nokia-Nokia IMS-Access setting,";
258: }
259: }
260: else
261: {
262: result += "ont is null for access:" + nddOnt.Access.Name + ",";
263: }
264: }
265: else if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
266: {
267: if (!isSip) // if H.248
268: {
269: gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
270:
271: if (gatewayId > 0)
272: {
273: Ia.Ngn.Cl.Model.Data.Nokia.Ims.DeleteAgcfEndpointAndH248SubscriberAndSubParty(ims, service, nddOnt, out r);
274: result += r + ",";
275:
276: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(ims, gatewayId, out r);
277: result += r + ",";
278:
279: executed = true;
280: }
281: else
282: {
283: result += "gatewayId is invalid or does not exist,";
284: }
285: }
286: else // if IsSip == true
287: {
288: Ia.Ngn.Cl.Model.Data.Nokia.Ims.DeleteSipSubscriber(ims, service, nddOnt, out r);
289: result += r + ",";
290:
291: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(ims, service, nddOnt, out r);
292: result += r + ",";
293: }
294: }
295: else
296: {
297: throw new Exception("accessVendor is unknown. ");
298: }
299: }
300: else
301: {
302: result += "Service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
303: }
304: }
305: else
306: {
307: result += "nddOnt is null, does not exist for access:" + accessName + ",";
308: }
309: }
310: else result += "service number does not belong to a Nokia switch.";
311: }
312: else
313: {
314: throw new Exception("switchVendor is null or not Nokia. ");
315: }
316:
317: return executed;
318: }
319:
320: ////////////////////////////////////////////////////////////////////////////
321: ////////////////////////////////////////////////////////////////////////////
322:
323: /// <summary>
324: ///
325: /// </summary>
326: public static bool DeleteReadNokiaSwitchAgcfEndpointAndH248SubscriberFromAnyFsdb(Ia.Ngn.Cl.Model.Client.Nokia.Ims ims, string service, out string result)
327: {
328: bool executed;
329: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor;
330:
331: executed = false;
332: result = string.Empty;
333:
334: if (Ia.Ngn.Cl.Model.Business.Service.ServiceHasEightDigitsAndIsWithinAllowedDomainList(service))
335: {
336: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
337:
338: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
339: {
340: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedNokiaSwitchDomainList(service))
341: {
342: foreach (Ia.Ngn.Cl.Model.Business.Nokia.Ims.ImsBasicService ibs in Ia.Ngn.Cl.Model.Business.Nokia.Ims.ImsBasicServiceList)
343: {
344: Ia.Ngn.Cl.Model.Data.Nokia.Ims.DeleteAgcfEndpointAndH248SubscriberAndSubParty(ims, service, ibs.PrimarySwitch, ibs.Fsdb, out string r);
345: result += r + ",";
346:
347: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadSubPartyAndSubscriber(ims, service, ibs.PrimarySwitch, ibs.Fsdb, ibs.Service, out r);
348: result += r + ",";
349: }
350:
351: executed = true;
352: }
353: else result += "Error: service number does not belong to a valid Nokia switch. ";
354: }
355: else result += "Error: switchVendor is null or not Nokia. ";
356: }
357: else result += "Error: service \"" + service + "\" does not belong to the network.";
358:
359: return executed;
360: }
361:
362: ////////////////////////////////////////////////////////////////////////////
363: ////////////////////////////////////////////////////////////////////////////
364:
365: /// <summary>
366: ///
367: /// </summary>
368: public static bool ModifyReadNokiaSwitchSubscriberH248ToSip(Ia.Ngn.Cl.Model.Client.Nokia.Ims ims, string service, Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt, out string result)
369: {
370: bool executed;
371: int gatewayId;
372: string r;
373: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor, accessVendor;
374: Ia.Ngn.Cl.Model.Ont ont;
375: Ia.Ngn.Cl.Model.Huawei.EmsOnt emsOnt;
376:
377: executed = false;
378: result = string.Empty;
379:
380: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
381:
382: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
383: {
384: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedNokiaSwitchDomainList(service))
385: {
386: if (nddOnt != null)
387: {
388: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainSameSwitchVendorButDifferentSiteExceptionList(nddOnt, service))
389: {
390: accessVendor = nddOnt.Pon.PonGroup.Olt.Odf.Vendor;
391:
392: if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
393: {
394: ont = Ia.Ngn.Cl.Model.Data.Nokia.Ont.Read(nddOnt.Id);
395:
396: if (ont != null)
397: {
398: if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
399: {
400: gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
401:
402: if (gatewayId > 0)
403: {
404: //Ia.Ngn.Cl.Model.Data.Nokia.Ims.Modify248SubscriberAndSubPartyAndAgcfEndpointToSip(ims, gatewayId, service, nddOnt, out r);
405: //result += r + ",";
406:
407: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(ims, gatewayId, out r);
408: result += r + ",";
409:
410: executed = true;
411: }
412: else
413: {
414: result += "gatewayId is invalid or does not exist,";
415: }
416: }
417: else // if IsSip == true
418: {
419: result += "error: OLT is already SIP,";
420: }
421: }
422: else
423: {
424: result += "ONT is null for access:" + nddOnt.Access.Name + ",";
425: }
426: }
427: else if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
428: {
429: emsOnt = Ia.Ngn.Cl.Model.Data.Huawei.Ont.Read(nddOnt.Id);
430:
431: if (emsOnt != null)
432: {
433: if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
434: {
435: gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
436:
437: if (gatewayId > 0)
438: {
439: Ia.Ngn.Cl.Model.Data.Nokia.Ims.Modify248SubscriberAndSubPartyAndDeleteAgcfEndpointToSip(ims, service, nddOnt, out r);
440: result += r + ",";
441:
442: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(ims, gatewayId, out r);
443: result += r + ",";
444:
445: executed = true;
446: }
447: else
448: {
449: result += "gatewayId is invalid or does not exist,";
450: }
451: }
452: else // if IsSip == true
453: {
454: result += "error: OLT is already SIP,";
455: }
456: }
457: else
458: {
459: result += "EmsOnt is null, does not exist for access:" + nddOnt.Access.Name + ",";
460: }
461: }
462: else
463: {
464: throw new Exception("accessVendor is unknown. ");
465: }
466: }
467: else
468: {
469: result += "Service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
470: }
471: }
472: else
473: {
474: result += "nddOnt is null,";
475: }
476: }
477: else result += "service number does not belong to a Nokia switch.";
478: }
479: else
480: {
481: throw new Exception("switchVendor is null or not Nokia. ");
482: }
483:
484: return executed;
485: }
486:
487: ////////////////////////////////////////////////////////////////////////////
488: ////////////////////////////////////////////////////////////////////////////
489:
490: /// <summary>
491: ///
492: /// </summary>
493: public static bool CreateReadHuaweiSwitchSubscriber(Ia.Ngn.Cl.Model.Client.Huawei.Ims ims, string accessName, string service, int port, Ia.Ngn.Cl.Model.Business.Default.Protocol protocol, bool overrideRouterDomainRestriction, out string result)
494: {
495: bool executed, created, isSip;
496: string r;
497: Ia.Ngn.Cl.Model.Business.Huawei.Default.FnSnPnPort fnSnPnPort;
498: Ia.Ngn.Cl.Model.Business.Huawei.Dev.MduDev mdu;
499: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
500: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor, accessVendor;
501: Ia.Ngn.Cl.Model.Huawei.EmsOnt emsOnt;
502: Ia.Ngn.Cl.Model.Ont ont;
503:
504: executed = false;
505: result = string.Empty;
506:
507: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
508:
509: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
510: {
511: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedHuaweiSwitchDomainList(service))
512: {
513: nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByAccessName(accessName);
514:
515: if (nddOnt != null)
516: {
517: if (protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd) isSip = nddOnt.Pon.PonGroup.Olt.IsSip;
518: else isSip = protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.Sip;
519:
520: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainSameSwitchVendorButDifferentSiteExceptionList(nddOnt, service) || overrideRouterDomainRestriction)
521: {
522: accessVendor = nddOnt.Pon.PonGroup.Olt.Odf.Vendor;
523:
524: if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
525: {
526: ont = Ia.Ngn.Cl.Model.Data.Nokia.Ont.Read(nddOnt.Id);
527:
528: if (ont != null)
529: {
530: if (isSip) // if SIP
531: {
532: result += "No procedure defined for a SIP Huawei-Nokia IMS-Access setting,";
533: }
534: else // if fsSip == false
535: {
536: port = (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown) ? port : Ia.Ngn.Cl.Model.Data.Nokia.Ams.NextVacantFlatTermIdForOnt(ont.FamilyTypeId, ont);
537:
538: if (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown)
539: {
540: Ia.Ngn.Cl.Model.Data.Huawei.Ims.CreateSubscriber(ims, service, out r);
541: result += r + ",";
542:
543: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadSbrForService(ims, service, out r);
544: result += r + ",";
545:
546: // other commands will be issued through NCE NBI to configure H.248 in SKB and TEC softswitch
547:
548: executed = true;
549: }
550: else
551: {
552: result += "Port is invalid or does not exist,";
553: }
554: }
555: }
556: else
557: {
558: result += "Ont is null, does not exist for access:" + nddOnt.Access.Name + ",";
559: }
560: }
561: else if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
562: {
563: emsOnt = Ia.Ngn.Cl.Model.Data.Huawei.Ont.Read(nddOnt.Id);
564:
565: if (emsOnt != null)
566: {
567: if (isSip)
568: {
569: if (emsOnt.FamilyType == Ia.Ngn.Cl.Model.Business.Huawei.Ont.FamilyType.Mdu)
570: {
571: var accessNameToMduDevDictionary = Ia.Ngn.Cl.Model.Data.Huawei.Default.AccessNameToMduDevDictionary;
572:
573: if (accessNameToMduDevDictionary.ContainsKey(nddOnt.Access.Name))
574: {
575: var pn = port;
576:
577: mdu = accessNameToMduDevDictionary[nddOnt.Access.Name];
578:
579: var vacantFnSnPnList = Ia.Ngn.Cl.Model.Data.Huawei.Ems.VacantMduFnSnPnForOntList(mdu, emsOnt);
580:
581: if (pn != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown) fnSnPnPort = vacantFnSnPnList.Where(f => f.Pn == pn).SingleOrDefault();
582: else fnSnPnPort = Ia.Ngn.Cl.Model.Data.Huawei.Ems.NextVacantMduFnSnPnForOnt(mdu, emsOnt);
583:
584: if (fnSnPnPort != null)
585: {
586: port = (port < 0) ? fnSnPnPort.Pn : port;
587:
588: created = Ia.Ngn.Cl.Model.Data.Huawei.Ims.CreateSubscriber(ims, service, out r);
589:
590: result += r + ",";
591: }
592: else result += "MDU sn and/or tel is invalid or does not exist. ";
593: }
594: else result += "emsOnt.FamilyType is MDU but AccessNameToMduDevDictionary does not contain key: " + nddOnt.Access.Name + " for service: " + service + ", and access: " + nddOnt.Access.Name;
595: }
596: else // if not MDU
597: {
598: port = (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown) ? port : Ia.Ngn.Cl.Model.Data.Huawei.Ems.NextVacantTelForOnt(emsOnt);
599:
600: if (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown)
601: {
602: created = Ia.Ngn.Cl.Model.Data.Huawei.Ims.CreateSubscriber(ims, service, out r);
603:
604: result += r + ",";
605: }
606: else result += "Port is invalid or does not exist,";
607: }
608: }
609: else // if H.248
610: {
611: result += "No procedure defined for an H.248 non-SIP Huawei-Huawei IMS-Access setting,";
612: }
613: }
614: else
615: {
616: result += "emsOnt is null, does not exist for access:" + nddOnt.Access.Name + ",";
617: }
618:
619: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(ims, service, nddOnt.Access.Id, out r);
620: result += r + ",";
621: }
622: else
623: {
624: throw new Exception("accessVendor is unknown. ");
625: }
626: }
627: else
628: {
629: result += "Service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
630: }
631: }
632: else
633: {
634: Ia.Ngn.Cl.Model.Data.Huawei.Ims.CreateSubscriber(ims, service, out r);
635: result += r + ",";
636:
637: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadSbrForService(ims, service, out r);
638: result += r + ",";
639:
640: executed = true;
641: }
642: }
643: else result += "service number does not belong to a Huawei switch.";
644: }
645: else
646: {
647: throw new Exception("switchVendor is null or not Huawei. ");
648: }
649:
650: return executed;
651: }
652:
653: ////////////////////////////////////////////////////////////////////////////
654:
655: /// <summary>
656: ///
657: /// </summary>
658: public static bool DeleteReadHuaweiSwitchSubscriber(Ia.Ngn.Cl.Model.Client.Huawei.Ims ims, string accessName, string service, Ia.Ngn.Cl.Model.Business.Default.Protocol protocol, bool overrideRouterDomainRestriction, out string result)
659: {
660: bool executed, isSip;
661: string r;
662: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
663: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor, accessVendor;
664: Ia.Ngn.Cl.Model.Ont ont;
665:
666: executed = false;
667: result = string.Empty;
668:
669: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
670:
671: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
672: {
673: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedHuaweiSwitchDomainList(service))
674: {
675: nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByAccessName(accessName);
676:
677: if (nddOnt != null)
678: {
679: if (protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd) isSip = nddOnt.Pon.PonGroup.Olt.IsSip;
680: else isSip = protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.Sip;
681:
682: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainSameSwitchVendorButDifferentSiteExceptionList(nddOnt, service) || overrideRouterDomainRestriction)
683: {
684: accessVendor = nddOnt.Pon.PonGroup.Olt.Odf.Vendor;
685:
686: if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
687: {
688: ont = Ia.Ngn.Cl.Model.Data.Nokia.Ont.Read(nddOnt.Id);
689:
690: if (ont != null)
691: {
692: if (isSip)
693: {
694: result += "No procedure defined for a SIP Huawei-Nokia IMS-Access setting,";
695: }
696: else // if H.248
697: {
698: Ia.Ngn.Cl.Model.Data.Huawei.Ims.DeleteSubscriber(ims, service, out r);
699: result += r + ",";
700:
701: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(ims, service, nddOnt.Access.Id, out r);
702: result += r + ",";
703:
704: // other commands will be issued through NCE NBI to configure H.248 in SKB and TEC softswitch
705: }
706: }
707: else
708: {
709: result += "ont is null,";
710: }
711: }
712: else if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
713: {
714: if (isSip)
715: {
716: Ia.Ngn.Cl.Model.Data.Huawei.Ims.DeleteSubscriber(ims, service, out r);
717: result += r + ",";
718:
719: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(ims, service, nddOnt.Access.Id, out r);
720: result += r + ",";
721: }
722: else // if H.248
723: {
724: result += "No procedure defined for an H.248 non-SIP Huawei-Huawei IMS-Access setting,";
725: }
726: }
727: else
728: {
729: throw new Exception("accessVendor is unknown. ");
730: }
731: }
732: else
733: {
734: result += "Service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
735: }
736: }
737: else
738: {
739: Ia.Ngn.Cl.Model.Data.Huawei.Ims.DeleteSubscriber(ims, service, out r);
740: result += r + ",";
741:
742: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(ims, service, string.Empty, out r);
743: result += r + ",";
744: }
745: }
746: else result += "service number does not belong to a Huawei switch.";
747: }
748: else
749: {
750: throw new Exception("switchVendor is null or not Huawei. ");
751: }
752:
753: return executed;
754: }
755:
756: ////////////////////////////////////////////////////////////////////////////
757: ////////////////////////////////////////////////////////////////////////////
758:
759: /// <summary>
760: ///
761: /// </summary>
762: public static string ImsServiceMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceListItem(out int serviceRequestAdministrativeIssueQueueCount, out string progressCounterString)
763: {
764: string service;
765:
766: if (imsServiceRequestAdministrativeIssueQueue.Count == 0)
767: {
768: imsServiceRequestAdministrativeIssueQueue = new Queue<string>(Ia.Ngn.Cl.Model.Data.Provision.ImsServiceMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceList());
769:
770: imsServiceRequestAdministrativeIssueQueueOriginalCount = imsServiceRequestAdministrativeIssueQueue.Count;
771: }
772:
773: if (imsServiceRequestAdministrativeIssueQueue.Count > 0) service = imsServiceRequestAdministrativeIssueQueue.Dequeue();
774: else service = null;
775:
776: progressCounterString = "(" + imsServiceRequestAdministrativeIssueQueue.Count + "/" + imsServiceRequestAdministrativeIssueQueueOriginalCount + ") ";
777:
778: serviceRequestAdministrativeIssueQueueCount = imsServiceRequestAdministrativeIssueQueue.Count;
779:
780: return service;
781: }
782:
783: /*
784: ////////////////////////////////////////////////////////////////////////////
785:
786: /// <summary>
787: ///
788: /// </summary>
789: public static string SequentialEricssonAxePstnServiceSuspensionMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceList(out int serviceSuspensionQueueCount, out string result)
790: {
791: string service;
792:
793: if (axePstnServiceSuspensionQueue.Count == 0)
794: {
795: axePstnServiceSuspensionQueue = new Queue<string>(Ia.Ngn.Cl.Model.Data.Provision.EricssonAxePstnServiceSuspensionMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceList());
796:
797: axePstnServiceSuspensionQueueOriginalCount = axePstnServiceSuspensionQueue.Count;
798: }
799:
800: if (axePstnServiceSuspensionQueue.Count > 0) service = axePstnServiceSuspensionQueue.Dequeue();
801: else service = null;
802:
803: result = "(" + axePstnServiceSuspensionQueue.Count + "/" + axePstnServiceSuspensionQueueOriginalCount + ") ";
804:
805: serviceSuspensionQueueCount = axePstnServiceSuspensionQueue.Count;
806:
807: return service;
808: }
809:
810: ////////////////////////////////////////////////////////////////////////////
811:
812: /// <summary>
813: ///
814: /// </summary>
815: public static string SequentialSiemensEwsdPstnServiceSuspensionMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceList(out int serviceSuspensionQueueCount, out string result)
816: {
817: string service;
818:
819: if (ewsdPstnServiceSuspensionQueue.Count == 0)
820: {
821: ewsdPstnServiceSuspensionQueue = new Queue<string>(Ia.Ngn.Cl.Model.Data.Provision.SiemensEwsdPstnServiceSuspensionMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceList());
822:
823: ewsdPstnServiceSuspensionQueueOriginalCount = ewsdPstnServiceSuspensionQueue.Count;
824: }
825:
826: if (ewsdPstnServiceSuspensionQueue.Count > 0) service = ewsdPstnServiceSuspensionQueue.Dequeue();
827: else service = null;
828:
829: result = "(" + ewsdPstnServiceSuspensionQueue.Count + "/" + ewsdPstnServiceSuspensionQueueOriginalCount + ") ";
830:
831: serviceSuspensionQueueCount = ewsdPstnServiceSuspensionQueue.Count;
832:
833: return service;
834: }
835: */
836:
837: ////////////////////////////////////////////////////////////////////////////
838: ////////////////////////////////////////////////////////////////////////////
839:
840: /// <summary>
841: ///
842: /// </summary>
843: public static KeyValuePair<string, string> DiscrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceItem(Ia.Ngn.Cl.Model.Business.Default.Procedure procedure, out int discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceQueueCount, out string progressCounterString)
844: {
845: return DiscrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceItem(procedure, 0, out discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceQueueCount, out progressCounterString);
846: }
847:
848: ////////////////////////////////////////////////////////////////////////////
849:
850: /// <summary>
851: ///
852: /// </summary>
853: public static KeyValuePair<string, string> DiscrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceItem(Ia.Ngn.Cl.Model.Business.Default.Procedure procedure, int provisionWithinLastNDays, out int discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceServiceIdQueueCount, out string progressCounterString)
854: {
855: KeyValuePair<string, string> serviceIdAccessId;
856:
857: if (discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue.Count == 0 && procedure == Ia.Ngn.Cl.Model.Business.Default.Procedure.InitializeOrIterate)
858: {
859: var dictionary1 = DiscrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceServiceIdAccessIdDictionary(provisionWithinLastNDays);
860: var dictionary2 = DiscrepancyBetweenServiceRequestServiceAndServiceServiceIdDictionary(provisionWithinLastNDays);
861:
862: var dictionary = new Dictionary<string, string>();
863:
864: foreach (var kvp in dictionary1) dictionary[kvp.Key] = kvp.Value;
865:
866: foreach (var kvp in dictionary2)
867: {
868: if (!dictionary.ContainsKey(kvp.Key))
869: {
870: dictionary[kvp.Key] = kvp.Value;
871: }
872: }
873:
874: discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue = new Queue<KeyValuePair<string, string>>(dictionary);
875:
876: discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueueOriginalCount = discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue.Count;
877: }
878:
879: if (discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue.Count > 0) serviceIdAccessId = discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue.Dequeue();
880: else serviceIdAccessId = new KeyValuePair<string, string>();
881:
882: progressCounterString = "(" + discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue.Count + "/" + discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueueOriginalCount + ")";
883:
884: discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceServiceIdQueueCount = discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue.Count;
885:
886: return serviceIdAccessId;
887: }
888:
889: ////////////////////////////////////////////////////////////////////////////
890:
891: /// <summary>
892: ///
893: /// </summary>
894: public static Dictionary<string, string> DiscrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceServiceIdAccessIdDictionary(int provisionWithinLastNDays)
895: {
896: Ia.Ngn.Cl.Model.Data.Provision.ServiceToUpdateServiceIdAccessIdDictionary_ServiceToCreateServiceIdAccessIdDictionary_ServiceToDeleteServiceIdAccessIdDictionary(provisionWithinLastNDays, out Dictionary<string, string> serviceToUpdateServiceIdAccessIdDictionary, out Dictionary<string, string> serviceToCreateServiceIdAccessIdDictionary, out Dictionary<string, string> serviceToDeleteServiceIdAccessIdDictionary);
897:
898: var dictionary = new Dictionary<string, string>();
899:
900: foreach (KeyValuePair<string, string> s in serviceToUpdateServiceIdAccessIdDictionary) dictionary.Add(s.Key, s.Value);
901: foreach (KeyValuePair<string, string> s in serviceToCreateServiceIdAccessIdDictionary) dictionary.Add(s.Key, s.Value);
902: foreach (KeyValuePair<string, string> s in serviceToDeleteServiceIdAccessIdDictionary) dictionary.Add(s.Key, s.Value);
903:
904: return dictionary;
905: }
906:
907: ////////////////////////////////////////////////////////////////////////////
908:
909: /// <summary>
910: ///
911: /// </summary>
912: public static Dictionary<string, string> DiscrepancyBetweenServiceRequestServiceAndServiceServiceIdDictionary(int provisionWithinLastNDays)
913: {
914: Ia.Ngn.Cl.Model.Data.Provision.ServiceToCreateServiceIdDictionary_ServiceToDeleteServiceIdDictionary(provisionWithinLastNDays, out Dictionary<string, string> serviceToCreateServiceIdDictionary, out Dictionary<string, string> serviceToDeleteServiceIdDictionary);
915:
916: var dictionary = new Dictionary<string, string>();
917:
918: foreach (KeyValuePair<string, string> s in serviceToCreateServiceIdDictionary) dictionary.Add(s.Key, s.Value);
919: foreach (KeyValuePair<string, string> s in serviceToDeleteServiceIdDictionary) dictionary.Add(s.Key, s.Value);
920:
921: //return dictionary.Where(u => u.Key.StartsWith("2390")).ToDictionary(u => u.Key, u => u.Value); // to work with || s.Name == "RKK"
922: return dictionary;
923: }
924:
925: ////////////////////////////////////////////////////////////////////////////
926:
927: /// <summary>
928: ///
929: /// </summary>
930: public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> ServiceOntToCreateAndToDeleteInEmsOntSipInfoOrVoipPstnUserListFromThePastNHourList(int provisioningWithinPastNHours, List<string> priorityServiceList)
931: {
932: DateTime pastNHoursDateTime;
933: List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList, laterProcessList;
934:
935: processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
936: laterProcessList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
937:
938: pastNHoursDateTime = (provisioningWithinPastNHours > 0) ? DateTime.UtcNow.AddHours(3).AddHours(-provisioningWithinPastNHours) : DateTime.MinValue;
939:
940: Ia.Ngn.Cl.Model.Business.Provision.ServiceOntToCreateInEmsOntSipInfoOrVoipPstnUserList_ServiceOntToAnnulInEmsOntSipInfoOrVoipPstnUserList(out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList, out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList);
941:
942: foreach (var serviceOnt in serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList)
943: {
944: if (serviceOnt.CreatedDateTime >= pastNHoursDateTime || priorityServiceList.Contains(serviceOnt.Service))
945: {
946: var p = new Ia.Ngn.Cl.Model.Business.Procedure.Process { ServiceId = serviceOnt.ServiceId, Service = serviceOnt.Service, Ont = serviceOnt.Ont, Port = Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Create, DateTime = serviceOnt.CreatedDateTime };
947: processList.Add(p);
948:
949: p = new Ia.Ngn.Cl.Model.Business.Procedure.Process { ServiceId = serviceOnt.ServiceId, Service = serviceOnt.Service, Ont = serviceOnt.Ont, Port = Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Read, DateTime = serviceOnt.CreatedDateTime };
950: processList.Add(p);
951: laterProcessList.Add(p);
952: }
953: }
954:
955: foreach (var serviceOnt in serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList)
956: {
957: if (serviceOnt.CreatedDateTime >= pastNHoursDateTime || priorityServiceList.Contains(serviceOnt.Service))
958: {
959: var p = new Ia.Ngn.Cl.Model.Business.Procedure.Process { ServiceId = serviceOnt.ServiceId, Service = serviceOnt.Service, Ont = serviceOnt.Ont, Port = Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Delete, DateTime = serviceOnt.CreatedDateTime };
960: processList.Add(p);
961:
962: p = new Ia.Ngn.Cl.Model.Business.Procedure.Process { ServiceId = serviceOnt.ServiceId, Service = serviceOnt.Service, Ont = serviceOnt.Ont, Port = Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Read, DateTime = serviceOnt.CreatedDateTime };
963: processList.Add(p);
964: laterProcessList.Add(p);
965: }
966: }
967:
968: processList = processList.OrderByDescending(l => l.DateTime).ToList();
969:
970: processList.AddRange(laterProcessList);
971:
972: return processList;
973: }
974:
975: ////////////////////////////////////////////////////////////////////////////
976:
977: /// <summary>
978: ///
979: /// </summary>
980: public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> _ServiceOntToCreateAndToDeleteInEmsOntSipInfoOrVoipPstnUserListFromThePastNHourList(int provisioningWithinPastNHours, List<string> priorityServiceList)
981: {
982: DateTime pastNHoursDateTime;
983: List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList, laterProcessList;
984:
985: processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
986: laterProcessList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
987:
988: pastNHoursDateTime = (provisioningWithinPastNHours > 0) ? DateTime.UtcNow.AddHours(3).AddHours(-provisioningWithinPastNHours) : DateTime.MinValue;
989:
990: /*
991: Ia.Ngn.Cl.Model.Business.Provision.ServiceOntToCreateInEmsOntSipInfoOrVoipPstnUserList_ServiceOntToAnnulInEmsOntSipInfoOrVoipPstnUserList(out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList, out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList);
992:
993: foreach (var serviceOnt in serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList)
994: {
995: if (serviceOnt.CreatedDateTime >= pastNHoursDateTime || priorityServiceList.Contains(serviceOnt.Service))
996: {
997: var p = new Ia.Ngn.Cl.Model.Business.Procedure.Process { ServiceId = serviceOnt.ServiceId, Service = serviceOnt.Service, Ont = serviceOnt.Ont, Port = Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Create, DateTime = serviceOnt.CreatedDateTime };
998: processList.Add(p);
999:
1000: p = new Ia.Ngn.Cl.Model.Business.Procedure.Process { ServiceId = serviceOnt.ServiceId, Service = serviceOnt.Service, Ont = serviceOnt.Ont, Port = Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Read, DateTime = serviceOnt.CreatedDateTime };
1001: processList.Add(p);
1002: laterProcessList.Add(p);
1003: }
1004: }
1005:
1006: foreach (var serviceOnt in serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList)
1007: {
1008: if (serviceOnt.CreatedDateTime >= pastNHoursDateTime || priorityServiceList.Contains(serviceOnt.Service))
1009: {
1010: var p = new Ia.Ngn.Cl.Model.Business.Procedure.Process { ServiceId = serviceOnt.ServiceId, Service = serviceOnt.Service, Ont = serviceOnt.Ont, Port = Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Delete, DateTime = serviceOnt.CreatedDateTime };
1011: processList.Add(p);
1012:
1013: p = new Ia.Ngn.Cl.Model.Business.Procedure.Process { ServiceId = serviceOnt.ServiceId, Service = serviceOnt.Service, Ont = serviceOnt.Ont, Port = Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Read, DateTime = serviceOnt.CreatedDateTime };
1014: processList.Add(p);
1015: laterProcessList.Add(p);
1016: }
1017: }
1018:
1019: processList = processList.OrderByDescending(l => l.DateTime).ToList();
1020:
1021: processList.AddRange(laterProcessList);
1022: */
1023:
1024: return processList;
1025: }
1026:
1027: ////////////////////////////////////////////////////////////////////////////
1028:
1029: /// <summary>
1030: ///
1031: /// </summary>
1032: public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> MsanServiceEmsVoipPstnUserDidFnSnPnDnToDeleteBecauseItHasProvisionedImsServiceOrHasNoEquivalentInServiceList()
1033: {
1034: string dn;
1035: List<string> serviceExemptionList;
1036: List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList, laterProcessList;
1037:
1038: processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
1039: laterProcessList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
1040:
1041: var list1 = Ia.Ngn.Cl.Model.Business.Provision.MsanServicesThatHaveProvisionedImsServiceExceptWhereEmsOntSipInfoEmsOntIsOfflineOrDeviceOfflineErrorAndExceptWhereEmsVoipPstnUserEmsDevHasDeviceOfflineErrorAndIgnoringNonSipNokiaOntList();
1042: var list2 = Ia.Ngn.Cl.Model.Business.Provision.MsanServiceInVoipPstnUserThatHaveNoEquivalentInServiceList();
1043:
1044: var list = list1.Union(list2).ToList();
1045:
1046: // will exclude exempt numbers
1047: serviceExemptionList = Ia.Ngn.Cl.Model.Data.Provision.ServiceOfServiceExemptFromProvisionProcessingList();
1048:
1049: foreach (string service in serviceExemptionList) list.Remove(service);
1050:
1051: var voipPstnUserDidFnSnPnDnMsanList = Ia.Ngn.Cl.Model.Data.Huawei.VoipPstnUser.DidFnSnPnDnMsanList();
1052:
1053: foreach (var service in list)
1054: {
1055: dn = Ia.Ngn.Cl.Model.Business.NumberFormatConverter.ImpuAid(service);
1056:
1057: var voipPstnUserDidFnSnPnDnMsan = (from vpudfspdm in voipPstnUserDidFnSnPnDnMsanList
1058: where vpudfspdm.Dn == dn
1059: select vpudfspdm).FirstOrDefault();
1060:
1061: if (voipPstnUserDidFnSnPnDnMsan != null)
1062: {
1063: var p = new Ia.Ngn.Cl.Model.Business.Procedure.Process { Service = service, EmsVoipPstnUserDidFnSnPnDn = voipPstnUserDidFnSnPnDnMsan, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Delete };
1064: processList.Add(p);
1065:
1066: p = new Ia.Ngn.Cl.Model.Business.Procedure.Process { Service = service, EmsVoipPstnUserDidFnSnPnDn = voipPstnUserDidFnSnPnDnMsan, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Read };
1067: processList.Add(p);
1068: laterProcessList.Add(p);
1069: }
1070: }
1071:
1072: processList = processList.OrderByDescending(l => l.DateTime).ToList();
1073:
1074: processList.AddRange(laterProcessList);
1075:
1076: return processList;
1077: }
1078:
1079: ////////////////////////////////////////////////////////////////////////////
1080:
1081: /// <summary>
1082: ///
1083: /// </summary>
1084: public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> ServiceOntToAddAndToRemoveInAsbrList()
1085: {
1086: List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList;
1087:
1088: processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
1089:
1090: Ia.Ngn.Cl.Model.Business.Provision.ServiceOntToAddToAsbrList_ServiceOntToRemoveFromAsbrList(out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntToAddToAsbrList, out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntToRemoveFromAsbrList);
1091:
1092: // issue read, execute, then read again commands
1093: foreach (var serviceOnt in serviceOntToAddToAsbrList)
1094: {
1095: processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { ServiceId = serviceOnt.ServiceId, Service = serviceOnt.Service, Ont = serviceOnt.Ont, Port = Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Create, DateTime = serviceOnt.CreatedDateTime });
1096: processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { ServiceId = serviceOnt.ServiceId, Service = serviceOnt.Service, Ont = serviceOnt.Ont, Port = Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Read, DateTime = serviceOnt.CreatedDateTime });
1097: }
1098:
1099: foreach (var serviceOnt in serviceOntToRemoveFromAsbrList)
1100: {
1101: processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { ServiceId = serviceOnt.ServiceId, Service = serviceOnt.Service, Ont = serviceOnt.Ont, Port = Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Delete, DateTime = serviceOnt.CreatedDateTime });
1102: processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { ServiceId = serviceOnt.ServiceId, Service = serviceOnt.Service, Ont = serviceOnt.Ont, Port = Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Read, DateTime = serviceOnt.CreatedDateTime });
1103: }
1104:
1105: return processList;
1106: }
1107:
1108: ////////////////////////////////////////////////////////////////////////////
1109:
1110: /// <summary>
1111: /// Find the provisioned services within SIP OLTs that do not have equivalent OntSipInfo or VoipPstnUser records, and all OntSipInfo and VoipPstnUser records that do note have equivalent services within SIP OLTs.
1112: /// </summary>
1113: private static void ServiceOntToCreateInEmsOntSipInfoOrVoipPstnUserList_ServiceOntToAnnulInEmsOntSipInfoOrVoipPstnUserList(out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList, out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList)
1114: {
1115: Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated serviceOnt2;
1116: List<string> serviceIdExemptionList;
1117: List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntList, serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList;
1118: List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> ontSipInfoServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList, voipPstnUserServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList;
1119:
1120: serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList = new List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated>();
1121: serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList = new List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated>();
1122:
1123: serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList = Ia.Ngn.Cl.Model.Data.Service2.ServiceOntWithinAllowedSipOltToBeProvisionedOrMigratedList;
1124: serviceOntList = Ia.Ngn.Cl.Model.Data.Service2.ServiceOntList;
1125: ontSipInfoServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList = Ia.Ngn.Cl.Model.Data.Huawei.OntSipInfo.ServiceOntWithinAllowedSipOltToBeProvisionedOrMigratedList();
1126: voipPstnUserServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList = Ia.Ngn.Cl.Model.Data.Huawei.VoipPstnUser.ServiceOntWithinAllowedSipOltToBeProvisionedOrMigratedList();
1127:
1128: foreach (var serviceOnt in serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList)
1129: {
1130: if (!ontSipInfoServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId)
1131: && !voipPstnUserServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId))
1132: {
1133: if (!serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
1134: {
1135: serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList.Add(serviceOnt);
1136: }
1137: }
1138: }
1139:
1140:
1141: // In serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList I must make sure that serviceId does not belong to any current service in serviceOntList
1142: // this is to allow NCE and POTS to Access migration without interruption or feedback from the vendor. Any number deleted from IMS will be deleted from NCE.
1143:
1144: foreach (var ontSipInfoServiceOnt in ontSipInfoServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList)
1145: {
1146: if (!serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList.Any(u => u.ServiceId == ontSipInfoServiceOnt.ServiceId && u.AccessId == ontSipInfoServiceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
1147: {
1148: if (!serviceOntList.Any(u => u.ServiceId == ontSipInfoServiceOnt.ServiceId /*&& u.AccessId == serviceOnt.AccessId*/)) // .Contains(serviceOnt) is disastrous here
1149: {
1150: if (!serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Any(u => u.ServiceId == ontSipInfoServiceOnt.ServiceId && u.AccessId == ontSipInfoServiceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
1151: {
1152: serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Add(ontSipInfoServiceOnt);
1153: }
1154: }
1155: }
1156: /*
1157: else if (serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList.Any(u => u.ServiceId == ontSipInfoServiceOnt.ServiceId && u.CreatedDateTime > ontSipInfoServiceOnt.CreatedDateTime))
1158: {
1159: // below: we will check for and add all NCE records that were created *before* the IMS records
1160:
1161: if (!serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Any(u => u.ServiceId == ontSipInfoServiceOnt.ServiceId))
1162: {
1163: serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Add(ontSipInfoServiceOnt);
1164: }
1165: }
1166: */
1167: }
1168:
1169: foreach (var voipPstnUserServiceOnt in voipPstnUserServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList)
1170: {
1171: if (!serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList.Any(u => u.ServiceId == voipPstnUserServiceOnt.ServiceId && u.AccessId == voipPstnUserServiceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
1172: {
1173: if (!serviceOntList.Any(u => u.ServiceId == voipPstnUserServiceOnt.ServiceId /*&& u.AccessId == serviceOnt.AccessId*/)) // .Contains(serviceOnt) is disastrous here
1174: {
1175: if (!serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Any(u => u.ServiceId == voipPstnUserServiceOnt.ServiceId && u.AccessId == voipPstnUserServiceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
1176: {
1177: serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Add(voipPstnUserServiceOnt);
1178: }
1179: }
1180: }
1181: /*
1182: else if (serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList.Any(u => u.ServiceId == voipPstnUserServiceOnt.ServiceId && u.CreatedDateTime > voipPstnUserServiceOnt.CreatedDateTime))
1183: {
1184: // below: we will check for and add all NCE records that were created *before* the IMS records
1185:
1186: if (!serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Any(u => u.ServiceId == voipPstnUserServiceOnt.ServiceId))
1187: {
1188: serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Add(voipPstnUserServiceOnt);
1189: }
1190: }
1191: */
1192: }
1193:
1194: // will exclude exempt numbers
1195: serviceIdExemptionList = Ia.Ngn.Cl.Model.Data.Provision.ServiceIdOfServiceExemptFromProvisionProcessingList();
1196: foreach (string serviceId in serviceIdExemptionList)
1197: {
1198: serviceOnt2 = serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList.SingleOrDefault(u => u.ServiceId == serviceId);
1199: if (serviceOnt2 != null) serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList.Remove(serviceOnt2);
1200:
1201: serviceOnt2 = serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.SingleOrDefault(u => u.ServiceId == serviceId);
1202: if (serviceOnt2 != null) serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Remove(serviceOnt2);
1203: }
1204: }
1205:
1206: ////////////////////////////////////////////////////////////////////////////
1207:
1208: /// <summary>
1209: ///
1210: /// </summary>
1211: public static List<string> MsanServicesThatHaveProvisionedImsServiceExceptWhereEmsOntSipInfoEmsOntIsOfflineOrDeviceOfflineErrorAndExceptWhereEmsVoipPstnUserEmsDevHasDeviceOfflineErrorAndIgnoringNonSipNokiaOntList()
1212: {
1213: var serviceList = Ia.Ngn.Cl.Model.Data.Service2.ImsServiceInAllowedToBeMigratedOltList;
1214: var msanServiceList = Ia.Ngn.Cl.Model.Data.Service2.MsanServiceList;
1215:
1216: var serviceWhereEmsOntIsOfflineList = Ia.Ngn.Cl.Model.Data.Huawei.OntSipInfo.ServiceWithinEmsOntSipInfoWhereEmsOntResultCodeOntIsOfflineOrDeviceOfflineErrorList();
1217: var serviceWhereEmsDevDeviceOfflineError = Ia.Ngn.Cl.Model.Data.Huawei.VoipPstnUser.ServiceWithinEmsVoipPstnUserWhereEmsDevResultCodeDeviceOfflineError();
1218:
1219: //var serviceWhereOntIsOfflineList = Ia.Ngn.Cl.Model.Data.Nokia.Ont.ServiceWhereOntIsOfflineList();
1220:
1221: var list = msanServiceList.Intersect(serviceList).ToList();
1222:
1223: list = list.Except(serviceWhereEmsOntIsOfflineList).ToList();
1224: list = list.Except(serviceWhereEmsDevDeviceOfflineError).ToList();
1225:
1226: return list;
1227: }
1228:
1229: ////////////////////////////////////////////////////////////////////////////
1230:
1231: /// <summary>
1232: ///
1233: /// </summary>
1234: public static List<string> MsanServiceInVoipPstnUserThatHaveNoEquivalentInServiceList()
1235: {
1236: List<string> list;
1237:
1238: var serviceList = Ia.Ngn.Cl.Model.Data.Service2.ServiceList;
1239: var msanServiceList = Ia.Ngn.Cl.Model.Data.Huawei.VoipPstnUser.MsanServiceList;
1240:
1241: list = msanServiceList.Except(serviceList).ToList();
1242:
1243: return list;
1244: }
1245:
1246: ////////////////////////////////////////////////////////////////////////////
1247:
1248: /// <summary>
1249: ///
1250: /// </summary>
1251: public static void ServiceOntToAddToAsbrList_ServiceOntToRemoveFromAsbrList(out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> addList, out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> removeList)
1252: {
1253: Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated serviceOnt2;
1254: List<string> serviceIdExemptionList;
1255: List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntList, serviceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList;
1256: List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> asbrServiceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList;
1257:
1258: addList = new List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated>();
1259: removeList = new List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated>();
1260:
1261: //List<string> list;
1262:
1263: /*
1264: select s.Service from Service2 s
1265: inner join ServiceRequestServices srs on s.Id = srs.Id
1266: inner join Accesses a on a.Id = srs.Access_Id
1267: inner join HuSbrs sb on 'sip:+965'+ s.Service +'@ims.moc.kw' = sb.IMPU
1268: left outer join Asbrs asb on sb.IMPU = asb.PUI
1269: where (a.Olt = 102010101 or a.Olt = 102010201) -- OLT ids MUB:102010101 QRN:102010201
1270: and srs.Provisioned = 1
1271: and asb.Id is null
1272: order by s.Service
1273: */
1274:
1275: /*
1276: // for oltId intersect AllowedToBeMigrated with Hu-No OLTs
1277: var oltIdList = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.HuaweiSwitchNokiaAccessOltIdList;
1278:
1279: //var i = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntAccessIdToOntAccessNameDictionary;
1280:
1281: using (var db = new Ia.Ngn.Cl.Model.Ngn())
1282: {
1283: var list = (from s in db.Service2s
1284: join srs in db.ServiceRequestServices on s.Id equals srs.Id
1285: join a in db.Accesses on srs.Access.Id equals a.Id
1286: //join sbr in db.HuSbrs on "sip:+965" + s.Service + "@ims.moc.kw" equals sbr.IMPU
1287: //join asbr in db.Asbrs on sbr.IMPU equals asbr.PUI into gj
1288: //from u in gj.DefaultIfEmpty()
1289: where oltIdList.Contains(a.Olt) && srs.Provisioned == true //&& u == null
1290: orderby s.Service
1291: select new { s.Service, AccessId = a.Id }).ToList();
1292:
1293: //var l = (from a in list select i[a.AccessId]).Distinct().ToList();
1294: var l = (from a in list select a.AccessId).Distinct().ToList();
1295: }
1296:
1297:
1298: //return list;
1299: */
1300:
1301: serviceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList = Ia.Ngn.Cl.Model.Data.Service2.ServiceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList();
1302: serviceOntList = Ia.Ngn.Cl.Model.Data.Service2.ServiceOntList;
1303: asbrServiceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList = Ia.Ngn.Cl.Model.Data.Huawei.Asbr.ServiceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList();
1304:
1305: foreach (var serviceOnt in serviceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList)
1306: {
1307: if (!asbrServiceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId))
1308: {
1309: if (!addList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
1310: {
1311: addList.Add(serviceOnt);
1312: }
1313: }
1314: }
1315:
1316: foreach (var serviceOnt in asbrServiceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList)
1317: {
1318: if (!serviceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
1319: {
1320: if (!serviceOntList.Any(u => u.ServiceId == serviceOnt.ServiceId /*&& u.AccessId == serviceOnt.AccessId*/)) // .Contains(serviceOnt) is disastrous here
1321: {
1322: if (!removeList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
1323: {
1324: removeList.Add(serviceOnt);
1325: }
1326: }
1327: }
1328: else if (serviceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList.Any(u => u.ServiceId == serviceOnt.ServiceId /*&& u.AccessId == serviceOnt.AccessId*/ && u.CreatedDateTime > serviceOnt.CreatedDateTime))
1329: {
1330: // below: we will check for and add all NCE records that were created *before* the IMS records
1331:
1332: if (!removeList.Any(u => u.ServiceId == serviceOnt.ServiceId /*&& u.AccessId == serviceOnt.AccessId*/))
1333: {
1334: removeList.Add(serviceOnt);
1335: }
1336: }
1337: }
1338:
1339: // will exclude exempt numbers
1340: serviceIdExemptionList = Ia.Ngn.Cl.Model.Data.Provision.ServiceIdOfServiceExemptFromProvisionProcessingList();
1341: foreach (string serviceId in serviceIdExemptionList)
1342: {
1343: serviceOnt2 = addList.SingleOrDefault(u => u.ServiceId == serviceId);
1344: if (serviceOnt2 != null) addList.Remove(serviceOnt2);
1345:
1346: serviceOnt2 = removeList.SingleOrDefault(u => u.ServiceId == serviceId);
1347: if (serviceOnt2 != null) removeList.Remove(serviceOnt2);
1348: }
1349: }
1350:
1351: /*
1352: ////////////////////////////////////////////////////////////////////////////
1353: ////////////////////////////////////////////////////////////////////////////
1354:
1355: /// <summary>
1356: ///
1357: /// </summary>
1358: public static List<string> ServiceSuspendedInServiceRequestServiceButNotInServiceStringNumberList
1359: {
1360: get
1361: {
1362: List<string> list, sList, srsList;
1363: SortedList sl;
1364:
1365: sList = Ia.Ngn.Cl.Model.Data.Service2.ServiceSuspensionIsTrueStringNumberList;
1366: srsList = Ia.Ngn.Cl.Model.Data.ServiceRequestService.ServiceSuspensionIsTrueAndProvisionedIsTrueStringNumberList;
1367:
1368: if (sList != null && sList.Count > 0)
1369: {
1370: if (srsList != null && srsList.Count > 0)
1371: {
1372: list = new List<string>(sList.Count);
1373:
1374: sl = new SortedList(sList.ToDictionary(s => s));
1375:
1376: foreach (string s in srsList)
1377: {
1378: if (!sl.ContainsKey(s)) list.Add(s);
1379: }
1380: }
1381: else
1382: {
1383: list = new List<string>();
1384: }
1385: }
1386: else
1387: {
1388: if (srsList != null && srsList.Count > 0) list = sList;
1389: else list = new List<string>();
1390: }
1391:
1392: return list;
1393: }
1394: }
1395: */
1396:
1397: /*
1398: ////////////////////////////////////////////////////////////////////////////
1399:
1400: /// <summary>
1401: ///
1402: /// </summary>
1403: public static List<string> ServiceActiveInServiceRequestServiceButNotInServiceStringNumberList
1404: {
1405: get
1406: {
1407: List<string> list, sList, srsList;
1408: SortedList sl;
1409:
1410: sList = Ia.Ngn.Cl.Model.Data.Service2.ServiceSuspensionIsFalseStringNumberList;
1411: srsList = Ia.Ngn.Cl.Model.Data.ServiceRequestService.ServiceSuspensionIsFalseStringNumberList;
1412:
1413: if (sList != null && sList.Count > 0)
1414: {
1415: if (srsList != null && srsList.Count > 0)
1416: {
1417: list = new List<string>(sList.Count);
1418:
1419: sl = new SortedList(sList.ToDictionary(s => s));
1420:
1421: foreach (string s in srsList)
1422: {
1423: if (!sl.ContainsKey(s)) list.Add(s);
1424: }
1425: }
1426: else
1427: {
1428: list = new List<string>();
1429: }
1430: }
1431: else
1432: {
1433: if (srsList != null && srsList.Count > 0) list = sList;
1434: else list = new List<string>();
1435: }
1436:
1437: return list;
1438: }
1439: }
1440: */
1441:
1442: ////////////////////////////////////////////////////////////////////////////
1443:
1444: /// <summary>
1445: ///
1446: /// </summary>
1447: public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> EmsOntToBeUpdatedFromH248ToSipList()
1448: {
1449: List<string> oltSymbolList;
1450: List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList;
1451:
1452: processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
1453:
1454: oltSymbolList = Ia.Ngn.Cl.Model.Business.Default.H248ToSipUpdateOltSymbolList;
1455:
1456: var list = Ia.Ngn.Cl.Model.Data.Default.DistinctNddOntWhereVaprofIsNotAluSipBAndIgnoreMduForOltSymbolListList(oltSymbolList);
1457:
1458: foreach (var l in list)
1459: {
1460: processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { Ont = l.Ont, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Update });
1461: processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { Ont = l.Ont, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Read });
1462: }
1463:
1464: return processList;
1465: }
1466:
1467: ////////////////////////////////////////////////////////////////////////////
1468:
1469: /// <summary>
1470: ///
1471: /// </summary>
1472: public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> OntSipInfoOrOntVoipPstnUserToBeCreatedForAnOntUpdatedFromH248ToSipList()
1473: {
1474: int pn;
1475: List<string> oltSymbolList;
1476: List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList;
1477:
1478: processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
1479:
1480: oltSymbolList = Ia.Ngn.Cl.Model.Business.Default.H248ToSipUpdateOltSymbolList;
1481:
1482: var list = Ia.Ngn.Cl.Model.Data.Default.ServiceAndNddOntAndEmsOntFamilyTypeAndPortWhereAgcfEndpointPortIsNot0AndVaprofIsAluSipBAndSfuEmsOntSipInfoTelDoesNotExistOrMduEmsVagIsSipAndMduEmsVoipPstnUserPnDoesNotExistForOltSymbolListList(oltSymbolList);
1483:
1484: /*
1485: * All Nokia ONTs (SFUs and MDUs) start at port position 1.
1486: * Huawei ONTs (SFUs) start at port position 1, while Huawei MDUs start at port position 0.
1487: */
1488:
1489: // issue update then read commands
1490: foreach (var l in list)
1491: {
1492: if (l.EmsOntFamilyType == Ia.Ngn.Cl.Model.Business.Huawei.Ont.FamilyType.Sfu)
1493: {
1494: processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { Service = l.Service, Ont = l.Ont, EmsOntFamilyType = Ia.Ngn.Cl.Model.Business.Huawei.Ont.FamilyType.Sfu, Port = l.Port, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Update });
1495: processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { Service = l.Service, Ont = l.Ont, EmsOntFamilyType = Ia.Ngn.Cl.Model.Business.Huawei.Ont.FamilyType.Sfu, Port = l.Port, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Read });
1496: }
1497: else if (l.EmsOntFamilyType == Ia.Ngn.Cl.Model.Business.Huawei.Ont.FamilyType.Mdu)
1498: {
1499: pn = Ia.Ngn.Cl.Model.Business.Service.ConvertFlatTermIdPositionToEmsVoipPstnUsersPn(l.Port);
1500:
1501: processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { Service = l.Service, Ont = l.Ont, EmsOntFamilyType = Ia.Ngn.Cl.Model.Business.Huawei.Ont.FamilyType.Mdu, Port = pn, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Update });
1502: processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { Service = l.Service, Ont = l.Ont, EmsOntFamilyType = Ia.Ngn.Cl.Model.Business.Huawei.Ont.FamilyType.Mdu, Port = pn, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Read });
1503: }
1504: else
1505: {
1506: throw new Exception("EmsOntFamilyType is not concedered. ");
1507: }
1508: }
1509:
1510: return processList;
1511: }
1512:
1513: ////////////////////////////////////////////////////////////////////////////
1514:
1515: /// <summary>
1516: ///
1517: /// </summary>
1518: public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> NokiaImsSubscriberToBeUpdatedFromH248ToSipList()
1519: {
1520: List<string> oltSymbolList;
1521: List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList;
1522:
1523: processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
1524:
1525: oltSymbolList = Ia.Ngn.Cl.Model.Business.Default.H248ToSipUpdateOltSymbolList;
1526:
1527: var list = Ia.Ngn.Cl.Model.Data.Default.ServiceAndNddOntWherePrimaryPuidcpeProfileNumberIsNot10AndEmsOntVaprofIsAluSipBAndSfuEmsOntSipInfoTelExistsOrAndMduEmsOntVagIsSipAndMduEmsVoipPstnUserPnExistsForOltSymbolListList(oltSymbolList);
1528:
1529: // issue delete then create commands
1530: foreach (var l in list)
1531: {
1532: processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { Service = l.Service, Ont = l.Ont, Protocol = Ia.Ngn.Cl.Model.Business.Default.Protocol.H248, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.DeleteRead });
1533:
1534: processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { Service = l.Service, Ont = l.Ont, Protocol = Ia.Ngn.Cl.Model.Business.Default.Protocol.Sip, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.CreateRead });
1535: }
1536:
1537: return processList;
1538: }
1539:
1540: ////////////////////////////////////////////////////////////////////////////
1541: ////////////////////////////////////////////////////////////////////////////
1542:
1543: /// <summary>
1544: ///
1545: /// </summary>
1546: public static void ReadService(Ia.Ngn.Cl.Model.Client.Nokia.Ims nokiaIms, Ia.Ngn.Cl.Model.Client.Huawei.Ims huaweiIms, string input, out Ia.Cl.Model.Result result)
1547: {
1548: int gatewayId, port;
1549: long number;
1550: string partyId, r;
1551: string accessId, service;
1552: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
1553: Ia.Ngn.Cl.Model.Service2 service2;
1554: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor, accessVendor;
1555:
1556: result = new Ia.Cl.Model.Result();
1557:
1558: if (!string.IsNullOrEmpty(input))
1559: {
1560: input = input.Trim();
1561: //input = input.ToLower();
1562:
1563: number = long.Parse(input);
1564:
1565: if (Ia.Ngn.Cl.Model.Business.Service.ServiceHasEightDigitsAndIsWithinAllowedDomainList(number))
1566: {
1567: service = number.ToString();
1568:
1569: result.AddSuccess("Service: " + service + " ");
1570:
1571: /*
1572: * Note that in find.aspx (Ia.Ngn.Cl.Model.Ui.Default) I actually hide access name if port is undefined.
1573: * case "service2AccessNameHyperLink":
1574: * {
1575: * if (service2.AccessName != null && service2.Port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown)
1576: * {
1577: * hl.Text = service2.AccessName;
1578: * hl.NavigateUrl = Ia.Ngn.Cl.Model.Business.Maintenance.Find.Url(service2.AccessName);
1579: * }
1580: * break;
1581: * }
1582:
1583: */
1584:
1585: Ia.Ngn.Cl.Model.Data.Service.AccessIdAndPortByService(service, out accessId, out port);
1586:
1587: // below: I should remove the whole section within if(){} below
1588: if (string.IsNullOrEmpty(accessId))
1589: {
1590: var serviceType = Ia.Ngn.Cl.Model.Business.Service.ServiceType.ImsService;
1591: var serviceId = Ia.Ngn.Cl.Model.Business.Service.ServiceToServiceId(service, serviceType);
1592:
1593: // attempt a read from Service2
1594: service2 = Ia.Ngn.Cl.Model.Data.Service2.ReadByIdIncludeAccess(serviceId);
1595:
1596: if (service2 != null && service2.Access != null) accessId = service2.Access.Id;
1597: else
1598: {
1599: // attempt a read from ServiceRequestService
1600: var serviceRequestService = Ia.Ngn.Cl.Model.Data.ServiceRequestService.ReadIncludeAccess(serviceId);
1601:
1602: if (serviceRequestService != null && serviceRequestService.Access != null) accessId = serviceRequestService.Access.Id;
1603: else accessId = string.Empty;
1604: }
1605: }
1606:
1607: if (!string.IsNullOrEmpty(accessId))
1608: {
1609: // get service information using accessId
1610:
1611: nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(accessId);
1612:
1613: if (nddOnt != null)
1614: {
1615: switchVendor = nddOnt.Pon.PonGroup.Olt.Odf.Router.Vendor;
1616: accessVendor = nddOnt.Pon.PonGroup.Olt.Odf.Vendor;
1617:
1618: try
1619: {
1620: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
1621: {
1622: partyId = Ia.Ngn.Cl.Model.Business.NumberFormatConverter.PartyId(service);
1623: gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromPartyId(partyId);
1624:
1625: if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
1626: {
1627: if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
1628: {
1629: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(nokiaIms, gatewayId, out r);
1630:
1631: result.AddSuccess(r);
1632: }
1633: else // if IsSip == true
1634: {
1635: result.AddSuccess("SIP process is undefined for No/No");
1636: }
1637: }
1638: else if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
1639: {
1640: if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
1641: {
1642: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(nokiaIms, gatewayId, out r);
1643: }
1644: else // if IsSip == true
1645: {
1646: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(nokiaIms, service, nddOnt, out r);
1647: }
1648:
1649: result.AddSuccess(r);
1650: }
1651: else throw new Exception("AccessVendor is undefined");
1652: }
1653: else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
1654: {
1655: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadSbrForService(huaweiIms, service, out string readHuaweiResult);
1656:
1657: result.AddSuccess(readHuaweiResult);
1658:
1659: if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia || accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
1660: {
1661: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, accessId, out r);
1662:
1663: result.AddSuccess(r);
1664: }
1665: else throw new Exception("accessVendor is undefined");
1666: }
1667: else throw new Exception("switchVendor is undefined");
1668: }
1669: catch (Exception ex)
1670: {
1671: result.AddError("Exception: " + ex.ToString());
1672: }
1673: }
1674: else result.AddError("NDD ONT is null, does not exist for service: " + service);
1675: }
1676: else
1677: {
1678: // get service without knowing accessId
1679:
1680: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedNokiaSwitchDomainList(service))
1681: {
1682: /*
1683: partyId = Ia.Ngn.Cl.Model.Business.NumberFormatConverter.PartyId(service);
1684: gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromPartyId(partyId);
1685:
1686: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(nokiaIms, gatewayId, out r);
1687: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(nokiaIms, service, null, out r);
1688: */
1689:
1690: result.AddError("(Service2 is null or service.Access is null) and (serviceRequestService is null or serviceRequestService.Access is null) and (number is not within allowed Huawei switch domain list) for service: " + service);
1691: }
1692: else if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedHuaweiSwitchDomainList(service))
1693: {
1694: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, string.Empty, out r);
1695:
1696: result.AddSuccess(r);
1697: }
1698: else
1699: {
1700: throw new Exception("switchVendor is undefined");
1701: }
1702: }
1703:
1704: // this is a sensitive issue. later I will allow storing empty accessId
1705: Ia.Ngn.Cl.Model.Data.Service.AccessIdAndPortByService(service, out accessId, out port);
1706:
1707: //if (!string.IsNullOrEmpty(accessId))
1708: //{
1709: Ia.Ngn.Cl.Model.Data.Service2.UpdateImsServiceAccessAndPort(service, accessId, port, Guid.Empty, out Ia.Cl.Model.Result updateServiceAccessResult);
1710:
1711: result.AddResult(updateServiceAccessResult);
1712: //}
1713: }
1714: else result.AddError("Number \"" + number + "\" does not belong to the network.");
1715: }
1716: else result.AddError("No input was entered.");
1717: }
1718:
1719: ////////////////////////////////////////////////////////////////////////////
1720:
1721: /// <summary>
1722: ///
1723: /// </summary>
1724: public static void UpdateReadSupplementaryService(Ia.Ngn.Cl.Model.Client.Nokia.Ims nokiaIms, Ia.Ngn.Cl.Model.Client.Huawei.Ims huaweiIms, string input, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService supplementaryService, bool supplementaryServiceState, out Ia.Cl.Model.Result result)
1725: {
1726: long number;
1727: string r, r0, r2;
1728: string accessId, service;
1729: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
1730: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor;
1731:
1732: result = new Ia.Cl.Model.Result();
1733:
1734: if (!string.IsNullOrEmpty(input))
1735: {
1736: input = input.Trim();
1737: //input = input.ToLower();
1738:
1739: number = long.Parse(input);
1740:
1741: if (Ia.Ngn.Cl.Model.Business.Service.ServiceHasEightDigitsAndIsWithinAllowedDomainList(number))
1742: {
1743: service = number.ToString();
1744:
1745: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
1746:
1747: result.AddSuccess("Service: " + service + " ");
1748:
1749: Ia.Ngn.Cl.Model.Data.Service.AccessIdAndPortByService(service, out accessId, out int port);
1750:
1751: if (!string.IsNullOrEmpty(accessId))
1752: {
1753: nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntAccessIdToOntDictionary.ContainsKey(accessId) ? Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntAccessIdToOntDictionary[accessId] : null;
1754:
1755: if (nddOnt != null)
1756: {
1757: switchVendor = nddOnt.Pon.PonGroup.Olt.Odf.Router.Vendor;
1758:
1759: try
1760: {
1761: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
1762: {
1763: Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, supplementaryService, supplementaryServiceState, out r);
1764:
1765: result.AddSuccess(r);
1766:
1767: if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
1768: {
1769: var gwId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
1770:
1771: if (gwId > 0)
1772: {
1773: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(nokiaIms/*, sNddOnt*/, gwId, out r2);
1774: }
1775: else
1776: {
1777: r2 = "gwId: zero";
1778: }
1779: }
1780: else // if IsSip == true
1781: {
1782: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(nokiaIms, service, nddOnt, out r2);
1783: }
1784:
1785: result.AddSuccess("updated:" + r + ", read:" + r2);
1786: }
1787: else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
1788: {
1789: Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, supplementaryService, supplementaryServiceState, out r);
1790:
1791: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, string.Empty, out r2);
1792:
1793: result.AddSuccess("updated:" + r + ", read:" + r2);
1794: }
1795: else
1796: {
1797: throw new Exception("switchVendor is undefined.");
1798: }
1799: }
1800: catch (Exception ex)
1801: {
1802: result.AddError("Exception: " + ex.ToString());
1803: }
1804: }
1805: else result.AddError("NDD ONT is null, does not exist for service: " + service);
1806: }
1807: else
1808: {
1809: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
1810: {
1811: Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, supplementaryService, supplementaryServiceState, out r);
1812:
1813: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, string.Empty, out r2);
1814:
1815: result.AddSuccess("updated:" + r + ", read:" + r2);
1816: }
1817: else
1818: {
1819: result.AddError("AccessId is null and switchVendor is not Huawei for service: " + service);
1820: }
1821: }
1822: }
1823: else result.AddError("Number \"" + number + "\" does not belong to the network");
1824: }
1825: else result.AddError("No input was entered");
1826: }
1827:
1828: ////////////////////////////////////////////////////////////////////////////
1829:
1830: /// <summary>
1831: ///
1832: /// </summary>
1833: public static Ia.Cl.Model.Result ManageServiceProvisioning(Ia.Ngn.Cl.Model.Business.Default.Procedure procedure, Ia.Ngn.Cl.Model.Client.Nokia.Ims nokiaIms, Ia.Ngn.Cl.Model.Client.Huawei.Ims huaweiIms)
1834: {
1835: int number;
1836: string r0, r1, r2, r3, service;
1837: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
1838: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor;
1839:
1840: r0 = r1 = r2 = r3 = string.Empty;
1841: var result = new Ia.Cl.Model.Result();
1842:
1843: var kvp = Ia.Ngn.Cl.Model.Business.Provision.DiscrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceItem(procedure, out int serviceQueueCount, out string progressCounterString);
1844:
1845: var serviceId = kvp.Key;
1846:
1847: var serviceRequestAdministrativeIssueType = Ia.Ngn.Cl.Model.Business.ServiceRequestAdministrativeIssue.ServiceRequestAdministrativeIssueTypeByDisconnectionType(Ia.Ngn.Cl.Model.Business.ServiceRequestAdministrativeIssue.DisconnectionType.None);
1848:
1849: if (!string.IsNullOrEmpty(serviceId))
1850: {
1851: var synchronized = false;
1852:
1853: r0 = "service: " + serviceId.Replace(":1:965", "") + " " + progressCounterString + ": ";
1854:
1855: service = Ia.Ngn.Cl.Model.Business.Service.ServiceIdToService(serviceId);
1856:
1857: if (Ia.Ngn.Cl.Model.Business.Service.ServiceHasEightDigitsAndIsWithinAllowedDomainList(service))
1858: {
1859: var service2 = Ia.Ngn.Cl.Model.Data.Service2.ReadByIdIncludeAccess(serviceId);
1860: var serviceRequestService = Ia.Ngn.Cl.Model.Data.ServiceRequestService.ReadIncludeAccess(serviceId);
1861:
1862: try
1863: {
1864: if (serviceRequestService != null)
1865: {
1866: service = serviceRequestService.Service;
1867:
1868: if (serviceRequestService.Provisioned)
1869: {
1870: if (int.TryParse(service, out number))
1871: {
1872: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
1873:
1874: if (service2 == null)
1875: {
1876: // create service
1877: r0 += "create: ";
1878:
1879: nddOnt = (serviceRequestService.Access != null) ? Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(serviceRequestService.Access.Id) : null;
1880:
1881: if (nddOnt != null)
1882: {
1883: if (Ia.Ngn.Cl.Model.Business.Service.OltIsWithinAllowedToBeProvisionedOltList(nddOnt.Pon.PonGroup.Olt))
1884: {
1885: if (switchVendor == nddOnt.Pon.PonGroup.Olt.Odf.Router.Vendor)
1886: {
1887: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainSameSwitchVendorButDifferentSiteExceptionList(nddOnt, service))
1888: {
1889: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
1890: {
1891: r0 += "Nokia: ";
1892:
1893: // make sure the number is not suspended before creating it
1894: Ia.Ngn.Cl.Model.Data.ServiceRequestAdministrativeIssue.Update(service, serviceRequestAdministrativeIssueType, false, out _);
1895:
1896: Ia.Ngn.Cl.Model.Business.Provision.CreateReadNokiaSwitchSubscriber(nokiaIms, nddOnt.Access.Name, service, Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r1);
1897:
1898: synchronized = true;
1899:
1900: r0 += r1 + ",";
1901: }
1902: else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
1903: {
1904: r0 += "Huawei: ";
1905:
1906: // make sure the number is not suspend before creating it
1907: Ia.Ngn.Cl.Model.Data.ServiceRequestAdministrativeIssue.Update(service, serviceRequestAdministrativeIssueType, false, out _);
1908:
1909: // I will completely remove any existing number before installing it again to make sure it installs fresh
1910: // maybe I shouldn't
1911: // Ia.Ngn.Cl.Model.Business.Provision.DeleteReadHuaweiSwitchSubscriber(huaweiIms, nddOnt.Access.Name, service, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r1);
1912:
1913: Ia.Ngn.Cl.Model.Business.Provision.CreateReadHuaweiSwitchSubscriber(huaweiIms, nddOnt.Access.Name, service, Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r2);
1914:
1915: synchronized = true;
1916:
1917: r0 += r1 + "," + r2 + ",";
1918: }
1919: else
1920: {
1921: throw new Exception("switchVendor is undefined.");
1922: }
1923: }
1924: else r0 += "service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
1925: }
1926: else r0 += "switchVendor of service " + service + " is not equal to switch vendor of access " + nddOnt.Access.Name + ".";
1927: }
1928: else r0 += "Access is not in an allowed to be provisioned OLT. ";
1929: }
1930: else
1931: {
1932: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
1933: {
1934: // see above
1935: r0 += "Huawei: ";
1936:
1937: // make sure the number is not suspend before creating it
1938: Ia.Ngn.Cl.Model.Data.ServiceRequestAdministrativeIssue.Update(service, serviceRequestAdministrativeIssueType, false, out _);
1939:
1940: // I will completely remove any existing number before installing it again to make sure it installs fresh
1941: // maybe I shouldn't
1942: //Ia.Ngn.Cl.Model.Business.Provision.DeleteReadHuaweiSwitchSubscriber(huaweiIms, string.Empty, service, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r1);
1943:
1944: Ia.Ngn.Cl.Model.Business.Provision.CreateReadHuaweiSwitchSubscriber(huaweiIms, string.Empty, service, Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r2);
1945:
1946: synchronized = true;
1947:
1948: //r0 += r4.Message + "," + r1 + "," + r2 + ","; too much info
1949: r0 += r2 + ",";
1950: }
1951: else r0 += "serviceNddOnt is null and switchVendor is not Huawei. ";
1952: }
1953: }
1954: else
1955: {
1956: // update service
1957: r0 += "update: ";
1958:
1959: if (service2.Access != null) nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(service2.Access.Id);
1960: else if (serviceRequestService.Access != null) nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(serviceRequestService.Access.Id);
1961: else nddOnt = null;
1962:
1963: if (nddOnt != null)
1964: {
1965: if (Ia.Ngn.Cl.Model.Business.Service.OltIsWithinAllowedToBeProvisionedOltList(nddOnt.Pon.PonGroup.Olt))
1966: {
1967: if (switchVendor == nddOnt.Pon.PonGroup.Olt.Odf.Router.Vendor)
1968: {
1969: // To make things easier, I will skip checking for NumberIsWithinAllowedRouterDomainList in updates because it is already checked when the number is installed
1970: //if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainList(nddOnt, service))
1971: //{
1972: r0 += "service: ";
1973:
1974: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
1975: {
1976: r0 += "Nokia: ";
1977:
1978: // below: send change command to IMS
1979: if (service2.CallerId != serviceRequestService.CallerId) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallerId, serviceRequestService.CallerId, out r2);
1980: else if (service2.CallForwarding != serviceRequestService.CallForwarding) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallForwarding, serviceRequestService.CallForwarding, out r2);
1981: else if (service2.ConferenceCall != serviceRequestService.ConferenceCall) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.ConferenceCall, serviceRequestService.ConferenceCall, out r2);
1982: else if (service2.AlarmCall != serviceRequestService.AlarmCall) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.WakeupCall, serviceRequestService.AlarmCall, out r2); // do not change
1983: else if (service2.WakeupCall != serviceRequestService.WakeupCall) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.WakeupCall, serviceRequestService.WakeupCall, out r2);
1984: else if (service2.AbbriviatedCalling != serviceRequestService.AbbriviatedCalling) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.AbbriviatedCalling, serviceRequestService.AbbriviatedCalling, out r2);
1985: else if (service2.InternationalCalling != serviceRequestService.InternationalCalling) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, serviceRequestService.InternationalCalling, out r2);
1986: else if (service2.InternationalCallingUserControlled != serviceRequestService.InternationalCallingUserControlled) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCallingUserControlled, serviceRequestService.InternationalCallingUserControlled, out r2);
1987:
1988: // below: CallWaiting is not provisioned for PBX keys. It is placed last in the execution logic so that it does not prevention the flow of logic to other services
1989: else if (service2.CallWaiting != serviceRequestService.CallWaiting) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallWaiting, serviceRequestService.CallWaiting, out r2);
1990:
1991: //else if (Ia.Ngn.Cl.Model.Business.Administration.ServiceSuspensionIsEnabled && service2.ServiceSuspension != serviceRequestService.CallBarring) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.ServiceSuspension, serviceRequestService.CallBarring, out r2);
1992: else r2 = "no difference in services. ";
1993:
1994: if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
1995: {
1996: var gwId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
1997:
1998: if (gwId > 0)
1999: {
2000: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(nokiaIms/*, sNddOnt*/, gwId, out r3);
2001:
2002: r0 += r2 + "," + r3 + ",";
2003: }
2004: else r0 += "gwId: 0," + r2 + "," + r3 + ",";
2005: }
2006: else // if IsSip == true
2007: {
2008: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(nokiaIms, service, nddOnt, out r3);
2009:
2010: r0 += r2 + "," + r3 + ",";
2011: }
2012: }
2013: else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
2014: {
2015: r0 += "Huawei: ";
2016:
2017: // See below
2018: if (service2.CallerId != serviceRequestService.CallerId) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallerId, serviceRequestService.CallerId, out r2);
2019: else if (service2.CallForwarding != serviceRequestService.CallForwarding) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallForwarding, serviceRequestService.CallForwarding, out r2);
2020: else if (service2.CallWaiting != serviceRequestService.CallWaiting) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallWaiting, serviceRequestService.CallWaiting, out r2);
2021: else if (service2.ConferenceCall != serviceRequestService.ConferenceCall) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.ConferenceCall, serviceRequestService.ConferenceCall, out r2);
2022: else if (service2.AlarmCall != serviceRequestService.AlarmCall) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.WakeupCall, serviceRequestService.AlarmCall, out r2); // do not change
2023: else if (service2.WakeupCall != serviceRequestService.WakeupCall) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.WakeupCall, serviceRequestService.WakeupCall, out r2);
2024: else if (service2.AbbriviatedCalling != serviceRequestService.AbbriviatedCalling) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.AbbriviatedCalling, serviceRequestService.AbbriviatedCalling, out r2);
2025: else if (service2.InternationalCalling != serviceRequestService.InternationalCalling) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, serviceRequestService.InternationalCalling, out r2);
2026: else if (service2.InternationalCallingUserControlled != serviceRequestService.InternationalCallingUserControlled) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCallingUserControlled, serviceRequestService.InternationalCallingUserControlled, out r2);
2027:
2028: //else if (Ia.Ngn.Cl.Model.Business.Administration.ServiceSuspensionIsEnabled && service2.ServiceSuspension != serviceRequestService.CallBarring) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.ServiceSuspension, serviceRequestService.CallBarring, out r2);
2029:
2030: else r2 = "no difference in services. ";
2031:
2032: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, nddOnt.Access.Id, out r3);
2033:
2034: r0 += r2 + "," + r3 + ",";
2035: }
2036: else
2037: {
2038: throw new Exception("switchVendor is undefined.");
2039: }
2040: //}
2041: //else
2042: //{
2043: // r0 += "service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
2044: //}
2045: }
2046: else r0 += "Access is not in an allowed to be provisioned OLT. ";
2047: }
2048: else r0 += "switchVendor of service " + service + " is not equal to switch vendor of access " + nddOnt.Access.Name + ".";
2049: }
2050: else
2051: {
2052: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
2053: {
2054: r0 += "Huawei: ";
2055:
2056: // See above
2057: if (service2.CallerId != serviceRequestService.CallerId) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallerId, serviceRequestService.CallerId, out r2);
2058: else if (service2.CallForwarding != serviceRequestService.CallForwarding) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallForwarding, serviceRequestService.CallForwarding, out r2);
2059: else if (service2.CallWaiting != serviceRequestService.CallWaiting) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallWaiting, serviceRequestService.CallWaiting, out r2);
2060: else if (service2.ConferenceCall != serviceRequestService.ConferenceCall) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.ConferenceCall, serviceRequestService.ConferenceCall, out r2);
2061: else if (service2.AlarmCall != serviceRequestService.AlarmCall) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.WakeupCall, serviceRequestService.AlarmCall, out r2); // do not change
2062: else if (service2.WakeupCall != serviceRequestService.WakeupCall) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.WakeupCall, serviceRequestService.WakeupCall, out r2);
2063: else if (service2.AbbriviatedCalling != serviceRequestService.AbbriviatedCalling) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.AbbriviatedCalling, serviceRequestService.AbbriviatedCalling, out r2);
2064:
2065: else if (service2.InternationalCalling != serviceRequestService.InternationalCalling) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, serviceRequestService.InternationalCalling, out r2);
2066: else if (service2.InternationalCallingUserControlled != serviceRequestService.InternationalCallingUserControlled) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCallingUserControlled, serviceRequestService.InternationalCallingUserControlled, out r2);
2067:
2068: //else if (Ia.Ngn.Cl.Model.Business.Administration.ServiceSuspensionIsEnabled && service2.ServiceSuspension != serviceRequestService.CallBarring) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.ServiceSuspension, serviceRequestService.CallBarring, out r2);
2069:
2070: else r2 = "no difference in services. ";
2071:
2072: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, string.Empty, out r3);
2073:
2074: r0 += r2 + "," + r3 + ",";
2075: }
2076: else r0 += "serviceNddOnt is null and switchVendor is not Huawei. ";
2077: }
2078: }
2079: }
2080: else r0 += "service is not a valid number. ";
2081: }
2082: else
2083: {
2084: if (int.TryParse(service, out number))
2085: {
2086: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
2087:
2088: if (service2 != null)
2089: {
2090: // delete service
2091: r0 += "delete: ";
2092:
2093: nddOnt = (service2.Access != null) ? Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(service2.Access.Id) : null;
2094:
2095: if (nddOnt != null)
2096: {
2097: if (Ia.Ngn.Cl.Model.Business.Service.OltIsWithinAllowedToBeProvisionedOltList(nddOnt.Pon.PonGroup.Olt))
2098: {
2099: if (switchVendor == nddOnt.Pon.PonGroup.Olt.Odf.Router.Vendor)
2100: {
2101: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainSameSwitchVendorButDifferentSiteExceptionList(nddOnt, service))
2102: {
2103: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
2104: {
2105: r0 += "Nokia: ";
2106:
2107: Ia.Ngn.Cl.Model.Business.Provision.DeleteReadNokiaSwitchSubscriber(nokiaIms, nddOnt.Access.Name, service, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r1);
2108:
2109: synchronized = true;
2110:
2111: r0 += r1;
2112: }
2113: else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
2114: {
2115: r0 += "Huawei: ";
2116:
2117: Ia.Ngn.Cl.Model.Business.Provision.DeleteReadHuaweiSwitchSubscriber(huaweiIms, nddOnt.Access.Name, service, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r1);
2118:
2119: synchronized = true;
2120:
2121: r0 += r1;
2122: }
2123: else
2124: {
2125: throw new Exception("switchVendor is undefined.");
2126: }
2127: }
2128: else r0 += "service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
2129: }
2130: else r0 += "switchVendor of service " + service + " is not equal to switch vendor of access " + nddOnt.Access.Name + ".";
2131: }
2132: else r0 += "Access is not in an allowed to be provisioned OLT. ";
2133: }
2134: else
2135: {
2136: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
2137: {
2138: r0 += "Nokia: ";
2139:
2140: //Ia.Ngn.Cl.Model.Business.Provision.DeleteReadNokiaSwitchSubscriber(nokiaIms, string.Empty, service, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r1);
2141: //r0 += "serviceNddOnt is null and switchVendor is not Huawei. ";
2142:
2143: Ia.Ngn.Cl.Model.Business.Provision.DeleteReadNokiaSwitchAgcfEndpointAndH248SubscriberFromAnyFsdb(nokiaIms, service, out r1);
2144:
2145: synchronized = true;
2146:
2147: r0 += r1;
2148: }
2149: else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
2150: {
2151: // see above
2152: r0 += "Huawei: ";
2153:
2154: Ia.Ngn.Cl.Model.Business.Provision.DeleteReadHuaweiSwitchSubscriber(huaweiIms, string.Empty, service, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r1);
2155:
2156: synchronized = true;
2157:
2158: r0 += r1;
2159: }
2160: else
2161: {
2162: throw new Exception("switchVendor is undefined.");
2163: }
2164: }
2165: }
2166: else
2167: {
2168: throw new Exception("service2 is null. ");
2169: }
2170: }
2171: else r0 += "service is not a valid number. ";
2172: }
2173: }
2174: else r0 += "serviceRequestService is null. ";
2175: }
2176: catch (Exception ex)
2177: {
2178: r0 += "Exception: " + ex.ToString();
2179: }
2180:
2181: if (synchronized) Ia.Ngn.Cl.Model.Data.Msmq.SecretaryApplication.Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application.ProvisionApplication, Ia.Ngn.Cl.Model.Business.Msmq.Process.SynchronizeCompleted, serviceRequestService.Service);
2182: }
2183: else r0 += "The service number " + service + " does not have eight digits and/or is not within allowed domain list.";
2184: }
2185: else r0 = "No numbers in service discrepancy and complementary service mismatch list. ";
2186:
2187: result.AddSuccess(r0);
2188:
2189: return result;
2190: }
2191:
2192: ////////////////////////////////////////////////////////////////////////////
2193:
2194: /// <summary>
2195: ///
2196: /// </summary>
2197: public static Ia.Cl.Model.Result ManageServiceRequestAdministrativeIssue(Ia.Ngn.Cl.Model.Client.Nokia.Ims nokiaIms, Ia.Ngn.Cl.Model.Client.Huawei.Ims huaweiIms)
2198: {
2199: string r2, r3;
2200: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
2201: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor;
2202:
2203: var result = new Ia.Cl.Model.Result();
2204:
2205: if (Ia.Ngn.Cl.Model.Business.Administration.ServiceSuspensionIsEnabled)
2206: {
2207: var programmedAccountingDisconnectionType = Ia.Ngn.Cl.Model.Business.ServiceRequestAdministrativeIssue.DisconnectionType.ProgrammedAccounting;
2208: var programmedInternationalCallingDisconnectionType = Ia.Ngn.Cl.Model.Business.ServiceRequestAdministrativeIssue.DisconnectionType.ProgrammedInternationalCalling;
2209:
2210: //var ontAccessIdToOntDictionary = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntAccessIdToOntDictionary;
2211:
2212: var service = Ia.Ngn.Cl.Model.Business.Provision.ImsServiceMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceListItem(out int serviceRequestAdministrativeIssueQueueCount, out string progressCounterString);
2213:
2214: var serviceType = Ia.Ngn.Cl.Model.Business.Service.ServiceType.ImsService;
2215: var serviceId = Ia.Ngn.Cl.Model.Business.Service.ServiceToServiceId(service, serviceType);
2216:
2217: if (!string.IsNullOrEmpty(service))
2218: {
2219: result.AddSuccess("service: " + service + " " + progressCounterString);
2220: r2 = serviceId;
2221:
2222: var service2 = Ia.Ngn.Cl.Model.Data.Service2.ReadByIdIncludeAccess(serviceId);
2223: var serviceRequestService = Ia.Ngn.Cl.Model.Data.ServiceRequestService.ReadIncludeAccess(serviceId);
2224: var serviceRequestAdministrativeIssue = Ia.Ngn.Cl.Model.Data.ServiceRequestAdministrativeIssue.Read(service, out _);
2225:
2226: if (service2 != null)
2227: {
2228: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
2229:
2230: if (service2.Access != null) nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(service2.Access.Id);
2231: else if (serviceRequestService.Access != null) nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(serviceRequestService.Access.Id);
2232: else nddOnt = null;
2233:
2234: if (nddOnt != null)
2235: {
2236: if (Ia.Ngn.Cl.Model.Business.Service.OltIsWithinAllowedToBeProvisionedOltList(nddOnt.Pon.PonGroup.Olt))
2237: {
2238: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainSameSwitchVendorButDifferentSiteExceptionList(nddOnt, service))
2239: {
2240: var accessId = nddOnt.Access.Id;
2241:
2242: result.AddSuccess("service: ");
2243:
2244: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
2245: {
2246: /*
2247: if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
2248: {
2249: var gwId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
2250:
2251: if (gwId > 0)
2252: {
2253: if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedAccountingDisconnectionType && service2.ServiceSuspension == false) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignServiceSuspensionStateToServiceSubscriber(nokiaIms, service, nddOnt, true, out r2);
2254: else if (serviceRequestAdministrativeIssue == null && service2.ServiceSuspension == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignServiceSuspensionStateToServiceSubscriber(nokiaIms, service, nddOnt, false, out r2);
2255: else if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedInternationalCallingDisconnectionType && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, false, out r2);
2256: else if (serviceRequestAdministrativeIssue == null && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == false) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, true, out r2);
2257: else result.AddError("unrecognized serviceRequestAdministrativeIssue");
2258:
2259: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(nokiaIms, gwId, out r3);
2260:
2261: result.AddSuccess(r2 + "," + r3);
2262: }
2263: else result.AddError("gwId is 0.");
2264: }
2265: else // if IsSip == true
2266: {
2267: if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedAccountingDisconnectionType && service2.ServiceSuspension == false) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignServiceSuspensionStateToServiceSubscriber(nokiaIms, service, nddOnt, true, out r2);
2268: else if (serviceRequestAdministrativeIssue == null && service2.ServiceSuspension == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignServiceSuspensionStateToServiceSubscriber(nokiaIms, service, nddOnt, false, out r2);
2269: else if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedInternationalCallingDisconnectionType && service2.InternationalCalling == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, false, out r2);
2270: else if (serviceRequestAdministrativeIssue == null && service2.InternationalCalling == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, true, out r2);
2271: else result.AddError("unrecognized serviceRequestAdministrativeIssue");
2272:
2273: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(nokiaIms, service, nddOnt, out r3);
2274:
2275: result.AddSuccess(r2 + "," + r3);
2276: }
2277: */
2278:
2279: if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedAccountingDisconnectionType && service2.ServiceSuspension == false) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignServiceSuspensionStateToServiceSubscriber(nokiaIms, service, nddOnt, true, out r2);
2280: else if (serviceRequestAdministrativeIssue == null && service2.ServiceSuspension == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignServiceSuspensionStateToServiceSubscriber(nokiaIms, service, nddOnt, false, out r2);
2281: else if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedInternationalCallingDisconnectionType && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, false, out r2);
2282: else if (serviceRequestAdministrativeIssue == null && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == false) Ia.Ngn.Cl.Model.Data.Nokia.Ims.UpdateSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, true, out r2);
2283: else result.AddError("unrecognized serviceRequestAdministrativeIssue");
2284:
2285: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(nokiaIms, service, nddOnt, out r3);
2286:
2287: result.AddSuccess(r2 + "," + r3);
2288: }
2289: else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
2290: {
2291: if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedAccountingDisconnectionType && service2.ServiceSuspension == false) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignServiceSuspensionStateToServiceSubscriber(huaweiIms, service, true, out r2);
2292: else if (serviceRequestAdministrativeIssue == null && service2.ServiceSuspension == true) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignServiceSuspensionStateToServiceSubscriber(huaweiIms, service, false, out r2);
2293: else if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedInternationalCallingDisconnectionType && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == true) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, false, out r2);
2294: else if (serviceRequestAdministrativeIssue == null && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == false) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, true, out r2);
2295: else result.AddError("unrecognized serviceRequestAdministrativeIssue.");
2296:
2297: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadSbrForService(huaweiIms, service, out r3);
2298:
2299: result.AddSuccess(r2 + "," + r3);
2300: }
2301: else result.AddError("switchVendor is undefined.");
2302: }
2303: else result.AddError("service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.");
2304: }
2305: else result.AddError("access is not in an allowed to be provisioned OLT.");
2306: }
2307: else
2308: {
2309: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
2310: {
2311: if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedAccountingDisconnectionType && service2.ServiceSuspension == false) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignServiceSuspensionStateToServiceSubscriber(huaweiIms, service, true, out r2);
2312: else if (serviceRequestAdministrativeIssue == null && service2.ServiceSuspension == true) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignServiceSuspensionStateToServiceSubscriber(huaweiIms, service, false, out r2);
2313: else if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedInternationalCallingDisconnectionType && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == true) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, false, out r2);
2314: else if (serviceRequestAdministrativeIssue == null && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == false) Ia.Ngn.Cl.Model.Data.Huawei.Ims.UpdateSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, true, out r2);
2315: else result.AddError("unrecognized serviceRequestAdministrativeIssue.");
2316:
2317: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadSbrForService(huaweiIms, service, out r3);
2318:
2319: result.AddSuccess(r2 + "," + r3);
2320: }
2321: else result.AddError("nddOnt is null and switchVendor is not Huawei.");
2322: }
2323: }
2324: else result.AddError("service2 is null.");
2325: }
2326: else result.AddWarning("No numbers in service request administrative issue mismatch list.");
2327: }
2328: else result.AddWarning("service request administrative issue is disabled.");
2329:
2330: return result;
2331: }
2332:
2333: ////////////////////////////////////////////////////////////////////////////
2334:
2335: /// <summary>
2336: ///
2337: /// </summary>
2338: public static Ia.Cl.Model.Result ManageMsmqQueue(Ia.Ngn.Cl.Model.Client.Nokia.Ims nokiaIms, Ia.Ngn.Cl.Model.Client.Huawei.Ims huaweiIms)
2339: {
2340: string r;
2341:
2342: var result = new Ia.Cl.Model.Result();
2343:
2344: var queueCount = Ia.Ngn.Cl.Model.Data.Msmq.ProvisionApplication.Count;
2345:
2346: if (queueCount > 0)
2347: {
2348: var message = Ia.Ngn.Cl.Model.Data.Msmq.ProvisionApplication.Dequeue;
2349:
2350: if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.ServiceRequestAndOrServiceRequestTypeUpdated)
2351: {
2352: if (Ia.Ngn.Cl.Model.Business.Administration.NowIsOfficialWorkingTime)
2353: {
2354: var r2 = Ia.Ngn.Cl.Model.Business.Provision.ManageServiceProvisioning(Ia.Ngn.Cl.Model.Business.Default.Procedure.InitializeOrIterate, nokiaIms, huaweiIms);
2355:
2356: result.AddSuccess("Provision service: " + r2.MessageWithoutCaption);
2357: }
2358: else
2359: {
2360: }
2361: }
2362: else if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.Synchronize)
2363: {
2364: if (Ia.Ngn.Cl.Model.Business.Administration.NowIsOfficialWorkingTime)
2365: {
2366: var r2 = Ia.Ngn.Cl.Model.Business.Provision.ManageServiceProvisioning(Ia.Ngn.Cl.Model.Business.Default.Procedure.InitializeOrIterate, nokiaIms, huaweiIms);
2367:
2368: result.AddSuccess("Provision (from sync) service: " + r2.MessageWithoutCaption);
2369: }
2370: else
2371: {
2372: }
2373: }
2374: else if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.CreateReadServiceAccessPort)
2375: {
2376: var service = message.Service;
2377: var accessName = message.AccessName;
2378: var port = (message.Port > 0) ? message.Port : Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown;
2379: var overrideRouterDomainRestriction = message.OverrideRouterDomainRestriction;
2380:
2381: var protocol = Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd;
2382:
2383: Ia.Ngn.Cl.Model.Business.Provision.CreateReadService(nokiaIms, huaweiIms, accessName, service, port, protocol, overrideRouterDomainRestriction, out r);
2384:
2385: result.AddSuccess("Create/Read: " + service + "|" + accessName + "|" + port + ": " + r);
2386: }
2387: else if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.DeleteReadServiceAccess)
2388: {
2389: var service = message.Service;
2390: var accessName = message.AccessName;
2391: var overrideRouterDomainRestriction = message.OverrideRouterDomainRestriction;
2392:
2393: var protocol = Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd;
2394:
2395: Ia.Ngn.Cl.Model.Business.Provision.DeleteReadService(nokiaIms, huaweiIms, accessName, service, protocol, overrideRouterDomainRestriction, out r);
2396:
2397: result.AddSuccess("Delete/Read: " + service + "|" + accessName + ": " + r);
2398: }
2399: else if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.UpdateReadServiceSupplementaryService)
2400: {
2401: var service = message.Service;
2402: var serviceSupplementaryService = message.ServiceSupplementaryService;
2403: var serviceSupplementaryServiceState = message.ServiceSupplementaryServiceState;
2404:
2405: Ia.Ngn.Cl.Model.Business.Provision.UpdateReadSupplementaryService(nokiaIms, huaweiIms, service, serviceSupplementaryService, serviceSupplementaryServiceState, out Ia.Cl.Model.Result r2);
2406:
2407: result.AddSuccess("Set/Reset/Read Service Supplementary Service: " + service + ": " + r2.Message);
2408: }
2409: else if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.AccessCreated)
2410: {
2411: Ia.Ngn.Cl.Model.Data.Huawei.Default.AccessNameToMduDevDictionaryReset();
2412:
2413: var result0 = Ia.Ngn.Cl.Model.Business.Nokia.Ims.CreateMissingAgcfGatewayRecordForNokiaSwitchOntInNonSipOlt(nokiaIms);
2414:
2415: result.AddSuccess("Access created: AccessNameToMduDevDictionary reset. CreateMissingAgcfGatewayRecordForNokiaSwitchOntInNonSipOlt(): " + result0.Message);
2416: }
2417: else if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.ServiceInServiceRequestAdministrativeIssuesUpdated)
2418: {
2419: var r1 = Ia.Ngn.Cl.Model.Business.Provision.ManageServiceRequestAdministrativeIssue(nokiaIms, huaweiIms);
2420:
2421: result.AddResult("Manage Service Request Administrative Issue: ", r1);
2422: }
2423: else if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.ActiveApplicationRunningPermissionState)
2424: {
2425: Ia.Ngn.Cl.Model.Business.Default.PermitActiveApplicationsToRun = message.State;
2426:
2427: result.AddSuccess("PermitActiveApplicationsToRun: " + message.State);
2428: }
2429: else
2430: {
2431: throw new ArgumentOutOfRangeException("MSMQ process " + message.Process.ToString() + " is undefined");
2432: }
2433: }
2434:
2435: return result;
2436: }
2437:
2438: ////////////////////////////////////////////////////////////////////////////
2439:
2440: /// <summary>
2441: ///
2442: /// </summary>
2443: public static Ia.Cl.Model.Result ManageAperiodicProcedure(Ia.Ngn.Cl.Model.Client.Nokia.Ims nokiaIms, Ia.Ngn.Cl.Model.Client.Huawei.Ims huaweiIms)
2444: {
2445: int aperiodicQueueCount;
2446: string service;
2447:
2448: var result = new Ia.Cl.Model.Result();
2449:
2450: if (aperiodicQueue.Count == 0)
2451: {
2452: List<string> list;
2453:
2454: using (var db = new Ia.Ngn.Cl.Model.Ngn())
2455: {
2456: list = (from s in db.Service2
2457: where s.Service.StartsWith("24825") || s.Service.StartsWith("24826") || s.Service.StartsWith("24827") || s.Service.StartsWith("24828") || s.Service.StartsWith("24829")
2458: select s.Service).ToList();
2459: }
2460:
2461: aperiodicQueue = new Queue<string>(list);
2462:
2463: aperiodicQueueOriginalCount = aperiodicQueue.Count;
2464: }
2465:
2466: if (aperiodicQueue.Count > 0) service = aperiodicQueue.Dequeue();
2467: else service = string.Empty;
2468:
2469: if (!string.IsNullOrEmpty(service))
2470: {
2471: Ia.Ngn.Cl.Model.Data.Huawei.Ims.DeleteSubscriber(huaweiIms, service, out string deleteString);
2472: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, string.Empty, out string readString);
2473:
2474: result.AddSuccess(service + " (" + aperiodicQueue.Count + "/" + aperiodicQueueOriginalCount + "): delete:" + deleteString + ", read:" + readString);
2475: }
2476: else
2477: {
2478: result.AddSuccess("service is null");
2479: }
2480:
2481: aperiodicQueueCount = aperiodicQueue.Count;
2482:
2483: return result;
2484: }
2485:
2486: ////////////////////////////////////////////////////////////////////////////
2487: ////////////////////////////////////////////////////////////////////////////
2488:
2489: /// <summary>
2490: ///
2491: /// </summary>
2492: public static void CreateReadService(Ia.Ngn.Cl.Model.Client.Nokia.Ims nokiaIms, Ia.Ngn.Cl.Model.Client.Huawei.Ims huaweiIms, string accessName, string service, int port, Ia.Ngn.Cl.Model.Business.Default.Protocol protocol, bool overrideRouterDomainRestriction, out string result)
2493: {
2494: if (!string.IsNullOrEmpty(service))
2495: {
2496: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedNokiaSwitchDomainList(service))
2497: {
2498: if (!string.IsNullOrEmpty(accessName))
2499: {
2500: Ia.Ngn.Cl.Model.Business.Provision.CreateReadNokiaSwitchSubscriber(nokiaIms, accessName, service, port, protocol, overrideRouterDomainRestriction, out result);
2501: }
2502: else result = "Error: Can't create a Nokia service without an access. AccessName is null or empty. ";
2503: }
2504: else if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedHuaweiSwitchDomainList(service))
2505: {
2506: Ia.Ngn.Cl.Model.Business.Provision.CreateReadHuaweiSwitchSubscriber(huaweiIms, accessName, service, port, protocol, overrideRouterDomainRestriction, out result);
2507: }
2508: else result = "Error: service number does not belong to a valid vendor switch. ";
2509: }
2510: else result = "Error: service null or empty. ";
2511: }
2512:
2513: ////////////////////////////////////////////////////////////////////////////
2514:
2515: /// <summary>
2516: ///
2517: /// </summary>
2518: public static void DeleteReadService(Ia.Ngn.Cl.Model.Client.Nokia.Ims nokiaIms, Ia.Ngn.Cl.Model.Client.Huawei.Ims huaweiIms, string accessName, string service, Ia.Ngn.Cl.Model.Business.Default.Protocol protocol, bool overrideRouterDomainRestriction, out string result)
2519: {
2520: bool b;
2521:
2522: if (!string.IsNullOrEmpty(service))
2523: {
2524: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedNokiaSwitchDomainList(service))
2525: {
2526: if (!string.IsNullOrEmpty(accessName))
2527: {
2528: b = Ia.Ngn.Cl.Model.Business.Provision.DeleteReadNokiaSwitchSubscriber(nokiaIms, accessName, service, protocol, overrideRouterDomainRestriction, out result);
2529: }
2530: else
2531: {
2532: b = Ia.Ngn.Cl.Model.Business.Provision.DeleteReadNokiaSwitchAgcfEndpointAndH248SubscriberFromAnyFsdb(nokiaIms, service, out result);
2533: }
2534: }
2535: else if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedHuaweiSwitchDomainList(service))
2536: {
2537: b = Ia.Ngn.Cl.Model.Business.Provision.DeleteReadHuaweiSwitchSubscriber(huaweiIms, accessName, service, protocol, overrideRouterDomainRestriction, out result);
2538: }
2539: else result = "Error: service number does not belong to a valid vendor switch. ";
2540: }
2541: else
2542: {
2543: result = "Error: service null or empty. ";
2544: }
2545: }
2546:
2547: ////////////////////////////////////////////////////////////////////////////
2548: ////////////////////////////////////////////////////////////////////////////
2549: }
2550:
2551: ////////////////////////////////////////////////////////////////////////////
2552: ////////////////////////////////////////////////////////////////////////////
2553: }