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.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainExceptionList(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: //onuFamilyType = Ia.Ngn.Cl.Model.Data.Huawei.Default.HuaweiSpecialOnuFamilyTypesForAccessNames(accessName);
134: // if (flatTermIdOrTelPort == 0) flatTermIdOrTelPort = Ia.Ngn.Cl.Model.Business.Ims.NextVacantFlatTermIdFromAgcfEndpointUsingGwIdForOnu(onuFamilyType, gatewayId);
135:
136: if (!isSip) // if H.248
137: {
138: gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
139:
140: if (gatewayId > 0)
141: {
142: port = (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown) ? port : Ia.Ngn.Cl.Model.Data.Default.NextVacantFlatTermIdForHuaweiEmsOntEquipmentTypeIdAndNokiaGatewayId(emsOnt.EquipmentType, gatewayId);
143:
144: if (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown)
145: {
146: Ia.Ngn.Cl.Model.Data.Nokia.Ims.CreateH248SubscriberAndSubPartyAndAgcfEndpoint(ims, gatewayId, service, port, nddOnt, out r);
147: result += r + ",";
148:
149: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(ims, gatewayId, out r);
150: result += r + ",";
151:
152: executed = true;
153: }
154: else
155: {
156: result += "port is invalid or does not exist,";
157: }
158: }
159: else
160: {
161: result += "gatewayId is invalid or does not exist,";
162: }
163: }
164: else // if IsSip == true
165: {
166: Ia.Ngn.Cl.Model.Data.Nokia.Ims.CreateSipSubscriber(ims, service, nddOnt, out r);
167: result += r + ",";
168:
169: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(ims, service, nddOnt, out r);
170: result += r + ",";
171:
172: executed = true;
173: }
174: }
175: else
176: {
177: result += "EmsOnt is null, does not exist for access:" + nddOnt.Access.Name + ",";
178: }
179: }
180: else
181: {
182: throw new Exception("accessVendor is unknown. ");
183: }
184: }
185: else result += "Service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
186: }
187: else result += "nddOnt is null, does not exist for access:" + accessName + ",";
188: }
189: else result += "service number does not belong to a Nokia switch.";
190: }
191: else
192: {
193: throw new Exception("switchVendor is null or not Nokia. ");
194: }
195:
196: return executed;
197: }
198:
199: ////////////////////////////////////////////////////////////////////////////
200:
201: /// <summary>
202: ///
203: /// </summary>
204: 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)
205: {
206: bool executed, isSip;
207: int gatewayId;
208: string r;
209: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
210: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor, accessVendor;
211: Ia.Ngn.Cl.Model.Ont ont;
212:
213: executed = false;
214: result = string.Empty;
215:
216: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
217:
218: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
219: {
220: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedNokiaSwitchDomainList(service))
221: {
222: nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByAccessName(accessName);
223:
224: if (nddOnt != null)
225: {
226: if (protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd) isSip = nddOnt.Pon.PonGroup.Olt.IsSip;
227: else isSip = protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.Sip;
228:
229: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainExceptionList(nddOnt, service) || overrideRouterDomainRestriction)
230: {
231: accessVendor = nddOnt.Pon.PonGroup.Olt.Odf.Vendor;
232:
233: if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
234: {
235: ont = Ia.Ngn.Cl.Model.Data.Nokia.Ont.Read(nddOnt.Id);
236:
237: if (ont != null)
238: {
239: if (!isSip) // if H.248
240: {
241: gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
242:
243: if (gatewayId > 0)
244: {
245: Ia.Ngn.Cl.Model.Data.Nokia.Ims.DeleteAgcfEndpointAndH248SubscriberAndSubParty(ims, service, nddOnt, out r);
246: result += r + ",";
247:
248: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(ims, gatewayId, out r);
249: result += r + ",";
250:
251: executed = true;
252: }
253: else
254: {
255: result += "gatewayId is invalid or does not exist,";
256: }
257: }
258: else // if IsSip == true
259: {
260: result += "No procedure defined for a SIP Nokia-Nokia IMS-Access setting,";
261: }
262: }
263: else
264: {
265: result += "ont is null for access:" + nddOnt.Access.Name + ",";
266: }
267: }
268: else if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
269: {
270: if (!isSip) // if H.248
271: {
272: gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
273:
274: if (gatewayId > 0)
275: {
276: Ia.Ngn.Cl.Model.Data.Nokia.Ims.DeleteAgcfEndpointAndH248SubscriberAndSubParty(ims, service, nddOnt, out r);
277: result += r + ",";
278:
279: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(ims, gatewayId, out r);
280: result += r + ",";
281:
282: executed = true;
283: }
284: else
285: {
286: result += "gatewayId is invalid or does not exist,";
287: }
288: }
289: else // if IsSip == true
290: {
291: Ia.Ngn.Cl.Model.Data.Nokia.Ims.DeleteSipSubscriber(ims, service, nddOnt, out r);
292: result += r + ",";
293:
294: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(ims, service, nddOnt, out r);
295: result += r + ",";
296: }
297: }
298: else
299: {
300: throw new Exception("accessVendor is unknown. ");
301: }
302: }
303: else
304: {
305: result += "Service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
306: }
307: }
308: else
309: {
310: result += "nddOnt is null, does not exist for access:" + accessName + ",";
311: }
312: }
313: else result += "service number does not belong to a Nokia switch.";
314: }
315: else
316: {
317: throw new Exception("switchVendor is null or not Nokia. ");
318: }
319:
320: return executed;
321: }
322:
323: ////////////////////////////////////////////////////////////////////////////
324: ////////////////////////////////////////////////////////////////////////////
325:
326: /// <summary>
327: ///
328: /// </summary>
329: public static bool DeleteReadNokiaSwitchAgcfEndpointAndH248SubscriberFromAnyFsdb(Ia.Ngn.Cl.Model.Client.Nokia.Ims ims, string service, out string result)
330: {
331: bool executed;
332: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor;
333:
334: executed = false;
335: result = string.Empty;
336:
337: if (Ia.Ngn.Cl.Model.Business.Service.ServiceHasEightDigitsAndIsWithinAllowedDomainList(service))
338: {
339: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
340:
341: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
342: {
343: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedNokiaSwitchDomainList(service))
344: {
345: foreach (Ia.Ngn.Cl.Model.Business.Nokia.Ims.ImsBasicService ibs in Ia.Ngn.Cl.Model.Business.Nokia.Ims.ImsBasicServiceList)
346: {
347: Ia.Ngn.Cl.Model.Data.Nokia.Ims.DeleteAgcfEndpointAndH248SubscriberAndSubParty(ims, service, ibs.PrimarySwitch, ibs.Fsdb, out string r);
348: result += r + ",";
349:
350: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadSubPartyAndSubscriber(ims, service, ibs.PrimarySwitch, ibs.Fsdb, ibs.Service, out r);
351: result += r + ",";
352: }
353:
354: executed = true;
355: }
356: else result += "Error: service number does not belong to a valid Nokia switch. ";
357: }
358: else result += "Error: switchVendor is null or not Nokia. ";
359: }
360: else result += "Error: service \"" + service + "\" does not belong to the network.";
361:
362: return executed;
363: }
364:
365: ////////////////////////////////////////////////////////////////////////////
366: ////////////////////////////////////////////////////////////////////////////
367:
368: /// <summary>
369: ///
370: /// </summary>
371: 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)
372: {
373: bool executed;
374: int gatewayId;
375: string r;
376: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor, accessVendor;
377: Ia.Ngn.Cl.Model.Ont ont;
378: Ia.Ngn.Cl.Model.Huawei.EmsOnt emsOnt;
379:
380: executed = false;
381: result = string.Empty;
382:
383: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
384:
385: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
386: {
387: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedNokiaSwitchDomainList(service))
388: {
389: if (nddOnt != null)
390: {
391: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainExceptionList(nddOnt, service))
392: {
393: accessVendor = nddOnt.Pon.PonGroup.Olt.Odf.Vendor;
394:
395: if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
396: {
397: ont = Ia.Ngn.Cl.Model.Data.Nokia.Ont.Read(nddOnt.Id);
398:
399: if (ont != null)
400: {
401: if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
402: {
403: gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
404:
405: if (gatewayId > 0)
406: {
407: //Ia.Ngn.Cl.Model.Data.Nokia.Ims.Modify248SubscriberAndSubPartyAndAgcfEndpointToSip(ims, gatewayId, service, nddOnt, out r);
408: //result += r + ",";
409:
410: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(ims, gatewayId, out r);
411: result += r + ",";
412:
413: executed = true;
414: }
415: else
416: {
417: result += "gatewayId is invalid or does not exist,";
418: }
419: }
420: else // if IsSip == true
421: {
422: result += "error: OLT is already SIP,";
423: }
424: }
425: else
426: {
427: result += "ONT is null for access:" + nddOnt.Access.Name + ",";
428: }
429: }
430: else if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
431: {
432: emsOnt = Ia.Ngn.Cl.Model.Data.Huawei.Ont.Read(nddOnt.Id);
433:
434: if (emsOnt != null)
435: {
436: if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
437: {
438: gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
439:
440: if (gatewayId > 0)
441: {
442: Ia.Ngn.Cl.Model.Data.Nokia.Ims.Modify248SubscriberAndSubPartyAndDeleteAgcfEndpointToSip(ims, service, nddOnt, out r);
443: result += r + ",";
444:
445: Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(ims, gatewayId, out r);
446: result += r + ",";
447:
448: executed = true;
449: }
450: else
451: {
452: result += "gatewayId is invalid or does not exist,";
453: }
454: }
455: else // if IsSip == true
456: {
457: result += "error: OLT is already SIP,";
458: }
459: }
460: else
461: {
462: result += "EmsOnt is null, does not exist for access:" + nddOnt.Access.Name + ",";
463: }
464: }
465: else
466: {
467: throw new Exception("accessVendor is unknown. ");
468: }
469: }
470: else
471: {
472: result += "Service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
473: }
474: }
475: else
476: {
477: result += "nddOnt is null,";
478: }
479: }
480: else result += "service number does not belong to a Nokia switch.";
481: }
482: else
483: {
484: throw new Exception("switchVendor is null or not Nokia. ");
485: }
486:
487: return executed;
488: }
489:
490: ////////////////////////////////////////////////////////////////////////////
491: ////////////////////////////////////////////////////////////////////////////
492:
493: /// <summary>
494: ///
495: /// </summary>
496: 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)
497: {
498: bool executed, created, isSip;
499: string r;
500: Ia.Ngn.Cl.Model.Business.Huawei.Default.FnSnPnPort fnSnPnPort;
501: Ia.Ngn.Cl.Model.Business.Huawei.Dev.MduDev mdu;
502: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
503: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor, accessVendor;
504: Ia.Ngn.Cl.Model.Huawei.EmsOnt emsOnt;
505: Ia.Ngn.Cl.Model.Ont ont;
506:
507: executed = false;
508: result = string.Empty;
509:
510: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
511:
512: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
513: {
514: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedHuaweiSwitchDomainList(service))
515: {
516: nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByAccessName(accessName);
517:
518: if (nddOnt != null)
519: {
520: if (protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd) isSip = nddOnt.Pon.PonGroup.Olt.IsSip;
521: else isSip = protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.Sip;
522:
523: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainExceptionList(nddOnt, service) || overrideRouterDomainRestriction)
524: {
525: accessVendor = nddOnt.Pon.PonGroup.Olt.Odf.Vendor;
526:
527: if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
528: {
529: ont = Ia.Ngn.Cl.Model.Data.Nokia.Ont.Read(nddOnt.Id);
530:
531: if (ont != null)
532: {
533: if (isSip) // if SIP
534: {
535: result += "No procedure defined for a SIP Huawei-Nokia IMS-Access setting,";
536: }
537: else // if fsSip == false
538: {
539: port = (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown) ? port : Ia.Ngn.Cl.Model.Data.Nokia.Ams.NextVacantFlatTermIdForOnt(ont.FamilyTypeId, ont);
540:
541: if (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown)
542: {
543: Ia.Ngn.Cl.Model.Data.Huawei.Ims.CreateSubscriber(ims, service, out r);
544: result += r + ",";
545:
546: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadSbrForService(ims, service, out r);
547: result += r + ",";
548:
549: // other commands will be issued through NCE NBI to configure H.248 in SKB and TEC softswitch
550:
551: executed = true;
552: }
553: else
554: {
555: result += "Port is invalid or does not exist,";
556: }
557: }
558: }
559: else
560: {
561: result += "Ont is null, does not exist for access:" + nddOnt.Access.Name + ",";
562: }
563: }
564: else if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
565: {
566: emsOnt = Ia.Ngn.Cl.Model.Data.Huawei.Ont.Read(nddOnt.Id);
567:
568: if (emsOnt != null)
569: {
570: if (isSip)
571: {
572: if (emsOnt.FamilyType == Ia.Ngn.Cl.Model.Business.Huawei.Ont.FamilyType.Mdu)
573: {
574: var accessNameToMduDevDictionary = Ia.Ngn.Cl.Model.Data.Huawei.Default.AccessNameToMduDevDictionary;
575:
576: if (accessNameToMduDevDictionary.ContainsKey(nddOnt.Access.Name))
577: {
578: var pn = port;
579:
580: mdu = accessNameToMduDevDictionary[nddOnt.Access.Name];
581:
582: var vacantFnSnPnList = Ia.Ngn.Cl.Model.Data.Huawei.Ems.VacantMduFnSnPnForOntList(mdu, emsOnt);
583:
584: if (pn != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown) fnSnPnPort = vacantFnSnPnList.Where(f => f.Pn == pn).SingleOrDefault();
585: else fnSnPnPort = Ia.Ngn.Cl.Model.Data.Huawei.Ems.NextVacantMduFnSnPnForOnt(mdu, emsOnt);
586:
587: if (fnSnPnPort != null)
588: {
589: port = (port < 0) ? fnSnPnPort.Pn : port;
590:
591: created = Ia.Ngn.Cl.Model.Data.Huawei.Ims.CreateSubscriber(ims, service, out r);
592:
593: result += r + ",";
594: }
595: else result += "MDU sn and/or tel is invalid or does not exist. ";
596: }
597: else result += "emsOnt.FamilyType is MDU but AccessNameToMduDevDictionary does not contain key: " + nddOnt.Access.Name + " for service: " + service + ", and access: " + nddOnt.Access.Name;
598: }
599: else // if not MDU
600: {
601: port = (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown) ? port : Ia.Ngn.Cl.Model.Data.Huawei.Ems.NextVacantTelForOnt(emsOnt);
602:
603: if (port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown)
604: {
605: created = Ia.Ngn.Cl.Model.Data.Huawei.Ims.CreateSubscriber(ims, service, out r);
606:
607: result += r + ",";
608: }
609: else result += "Port is invalid or does not exist,";
610: }
611: }
612: else // if H.248
613: {
614: result += "No procedure defined for an H.248 non-SIP Huawei-Huawei IMS-Access setting,";
615: }
616: }
617: else
618: {
619: result += "emsOnt is null, does not exist for access:" + nddOnt.Access.Name + ",";
620: }
621:
622: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(ims, service, nddOnt.Access.Id, out r);
623: result += r + ",";
624: }
625: else
626: {
627: throw new Exception("accessVendor is unknown. ");
628: }
629: }
630: else
631: {
632: result += "Service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
633: }
634: }
635: else
636: {
637: Ia.Ngn.Cl.Model.Data.Huawei.Ims.CreateSubscriber(ims, service, out r);
638: result += r + ",";
639:
640: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadSbrForService(ims, service, out r);
641: result += r + ",";
642:
643: executed = true;
644: }
645: }
646: else result += "service number does not belong to a Huawei switch.";
647: }
648: else
649: {
650: throw new Exception("switchVendor is null or not Huawei. ");
651: }
652:
653: return executed;
654: }
655:
656: ////////////////////////////////////////////////////////////////////////////
657:
658: /// <summary>
659: ///
660: /// </summary>
661: 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)
662: {
663: bool executed, isSip;
664: string r;
665: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
666: Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor, accessVendor;
667: Ia.Ngn.Cl.Model.Ont ont;
668:
669: executed = false;
670: result = string.Empty;
671:
672: switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
673:
674: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
675: {
676: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedHuaweiSwitchDomainList(service))
677: {
678: nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByAccessName(accessName);
679:
680: if (nddOnt != null)
681: {
682: if (protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd) isSip = nddOnt.Pon.PonGroup.Olt.IsSip;
683: else isSip = protocol == Ia.Ngn.Cl.Model.Business.Default.Protocol.Sip;
684:
685: if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainExceptionList(nddOnt, service) || overrideRouterDomainRestriction)
686: {
687: accessVendor = nddOnt.Pon.PonGroup.Olt.Odf.Vendor;
688:
689: if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
690: {
691: ont = Ia.Ngn.Cl.Model.Data.Nokia.Ont.Read(nddOnt.Id);
692:
693: if (ont != null)
694: {
695: if (isSip)
696: {
697: result += "No procedure defined for a SIP Huawei-Nokia IMS-Access setting,";
698: }
699: else // if H.248
700: {
701: Ia.Ngn.Cl.Model.Data.Huawei.Ims.DeleteSubscriber(ims, service, out r);
702: result += r + ",";
703:
704: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(ims, service, nddOnt.Access.Id, out r);
705: result += r + ",";
706:
707: // other commands will be issued through NCE NBI to configure H.248 in SKB and TEC softswitch
708: }
709: }
710: else
711: {
712: result += "ont is null,";
713: }
714: }
715: else if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
716: {
717: if (isSip)
718: {
719: Ia.Ngn.Cl.Model.Data.Huawei.Ims.DeleteSubscriber(ims, service, out r);
720: result += r + ",";
721:
722: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(ims, service, nddOnt.Access.Id, out r);
723: result += r + ",";
724: }
725: else // if H.248
726: {
727: result += "No procedure defined for an H.248 non-SIP Huawei-Huawei IMS-Access setting,";
728: }
729: }
730: else
731: {
732: throw new Exception("accessVendor is unknown. ");
733: }
734: }
735: else
736: {
737: result += "Service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
738: }
739: }
740: else
741: {
742: Ia.Ngn.Cl.Model.Data.Huawei.Ims.DeleteSubscriber(ims, service, out r);
743: result += r + ",";
744:
745: Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(ims, service, string.Empty, out r);
746: result += r + ",";
747: }
748: }
749: else result += "service number does not belong to a Huawei switch.";
750: }
751: else
752: {
753: throw new Exception("switchVendor is null or not Huawei. ");
754: }
755:
756: return executed;
757: }
758:
759: ////////////////////////////////////////////////////////////////////////////
760: ////////////////////////////////////////////////////////////////////////////
761:
762: /// <summary>
763: ///
764: /// </summary>
765: public static string ImsServiceMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceListItem(out int serviceRequestAdministrativeIssueQueueCount, out string progressCounterString)
766: {
767: string service;
768:
769: if (imsServiceRequestAdministrativeIssueQueue.Count == 0)
770: {
771: imsServiceRequestAdministrativeIssueQueue = new Queue<string>(Ia.Ngn.Cl.Model.Data.Provision.ImsServiceMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceList());
772:
773: imsServiceRequestAdministrativeIssueQueueOriginalCount = imsServiceRequestAdministrativeIssueQueue.Count;
774: }
775:
776: if (imsServiceRequestAdministrativeIssueQueue.Count > 0) service = imsServiceRequestAdministrativeIssueQueue.Dequeue();
777: else service = null;
778:
779: progressCounterString = "(" + imsServiceRequestAdministrativeIssueQueue.Count + "/" + imsServiceRequestAdministrativeIssueQueueOriginalCount + ") ";
780:
781: serviceRequestAdministrativeIssueQueueCount = imsServiceRequestAdministrativeIssueQueue.Count;
782:
783: return service;
784: }
785:
786: /*
787: ////////////////////////////////////////////////////////////////////////////
788:
789: /// <summary>
790: ///
791: /// </summary>
792: public static string SequentialEricssonAxePstnServiceSuspensionMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceList(out int serviceSuspensionQueueCount, out string result)
793: {
794: string service;
795:
796: if (axePstnServiceSuspensionQueue.Count == 0)
797: {
798: axePstnServiceSuspensionQueue = new Queue<string>(Ia.Ngn.Cl.Model.Data.Provision.EricssonAxePstnServiceSuspensionMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceList());
799:
800: axePstnServiceSuspensionQueueOriginalCount = axePstnServiceSuspensionQueue.Count;
801: }
802:
803: if (axePstnServiceSuspensionQueue.Count > 0) service = axePstnServiceSuspensionQueue.Dequeue();
804: else service = null;
805:
806: result = "(" + axePstnServiceSuspensionQueue.Count + "/" + axePstnServiceSuspensionQueueOriginalCount + ") ";
807:
808: serviceSuspensionQueueCount = axePstnServiceSuspensionQueue.Count;
809:
810: return service;
811: }
812:
813: ////////////////////////////////////////////////////////////////////////////
814:
815: /// <summary>
816: ///
817: /// </summary>
818: public static string SequentialSiemensEwsdPstnServiceSuspensionMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceList(out int serviceSuspensionQueueCount, out string result)
819: {
820: string service;
821:
822: if (ewsdPstnServiceSuspensionQueue.Count == 0)
823: {
824: ewsdPstnServiceSuspensionQueue = new Queue<string>(Ia.Ngn.Cl.Model.Data.Provision.SiemensEwsdPstnServiceSuspensionMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceList());
825:
826: ewsdPstnServiceSuspensionQueueOriginalCount = ewsdPstnServiceSuspensionQueue.Count;
827: }
828:
829: if (ewsdPstnServiceSuspensionQueue.Count > 0) service = ewsdPstnServiceSuspensionQueue.Dequeue();
830: else service = null;
831:
832: result = "(" + ewsdPstnServiceSuspensionQueue.Count + "/" + ewsdPstnServiceSuspensionQueueOriginalCount + ") ";
833:
834: serviceSuspensionQueueCount = ewsdPstnServiceSuspensionQueue.Count;
835:
836: return service;
837: }
838: */
839:
840: ////////////////////////////////////////////////////////////////////////////
841: ////////////////////////////////////////////////////////////////////////////
842:
843: /// <summary>
844: ///
845: /// </summary>
846: public static KeyValuePair<string, string> DiscrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceItem(Ia.Ngn.Cl.Model.Business.Default.Procedure procedure, out int discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceQueueCount, out string progressCounterString)
847: {
848: return DiscrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceItem(procedure, 0, out discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceQueueCount, out progressCounterString);
849: }
850:
851: ////////////////////////////////////////////////////////////////////////////
852:
853: /// <summary>
854: ///
855: /// </summary>
856: public static KeyValuePair<string, string> DiscrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceItem(Ia.Ngn.Cl.Model.Business.Default.Procedure procedure, int provisionWithinLastNDays, out int discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceServiceIdQueueCount, out string progressCounterString)
857: {
858: KeyValuePair<string, string> serviceIdAccessId;
859:
860: if (discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue.Count == 0 && procedure == Ia.Ngn.Cl.Model.Business.Default.Procedure.InitializeOrIterate)
861: {
862: var dictionary1 = DiscrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceServiceIdAccessIdDictionary(provisionWithinLastNDays);
863: var dictionary2 = DiscrepancyBetweenServiceRequestServiceAndServiceServiceIdDictionary(provisionWithinLastNDays);
864:
865: var dictionary = new Dictionary<string, string>();
866:
867: foreach (var kvp in dictionary1) dictionary[kvp.Key] = kvp.Value;
868:
869: foreach (var kvp in dictionary2)
870: {
871: if (!dictionary.ContainsKey(kvp.Key))
872: {
873: dictionary[kvp.Key] = kvp.Value;
874: }
875: }
876:
877: discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue = new Queue<KeyValuePair<string, string>>(dictionary);
878:
879: discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueueOriginalCount = discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue.Count;
880: }
881:
882: if (discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue.Count > 0) serviceIdAccessId = discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue.Dequeue();
883: else serviceIdAccessId = new KeyValuePair<string, string>();
884:
885: progressCounterString = "(" + discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue.Count + "/" + discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueueOriginalCount + ")";
886:
887: discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceServiceIdQueueCount = discrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceQueue.Count;
888:
889: return serviceIdAccessId;
890: }
891:
892: ////////////////////////////////////////////////////////////////////////////
893:
894: /// <summary>
895: ///
896: /// </summary>
897: public static Dictionary<string, string> DiscrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceServiceIdAccessIdDictionary(int provisionWithinLastNDays)
898: {
899: 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);
900:
901: var dictionary = new Dictionary<string, string>();
902:
903: foreach (KeyValuePair<string, string> s in serviceToUpdateServiceIdAccessIdDictionary) dictionary.Add(s.Key, s.Value);
904: foreach (KeyValuePair<string, string> s in serviceToCreateServiceIdAccessIdDictionary) dictionary.Add(s.Key, s.Value);
905: foreach (KeyValuePair<string, string> s in serviceToDeleteServiceIdAccessIdDictionary) dictionary.Add(s.Key, s.Value);
906:
907: return dictionary;
908: }
909:
910: ////////////////////////////////////////////////////////////////////////////
911:
912: /// <summary>
913: ///
914: /// </summary>
915: public static Dictionary<string, string> DiscrepancyBetweenServiceRequestServiceAndServiceServiceIdDictionary(int provisionWithinLastNDays)
916: {
917: Ia.Ngn.Cl.Model.Data.Provision.ServiceToCreateServiceIdDictionary_ServiceToDeleteServiceIdDictionary(provisionWithinLastNDays, out Dictionary<string, string> serviceToCreateServiceIdDictionary, out Dictionary<string, string> serviceToDeleteServiceIdDictionary);
918:
919: var dictionary = new Dictionary<string, string>();
920:
921: foreach (KeyValuePair<string, string> s in serviceToCreateServiceIdDictionary) dictionary.Add(s.Key, s.Value);
922: foreach (KeyValuePair<string, string> s in serviceToDeleteServiceIdDictionary) dictionary.Add(s.Key, s.Value);
923:
924: //return dictionary.Where(u => u.Key.StartsWith("2390")).ToDictionary(u => u.Key, u => u.Value); // to work with || s.Name == "RKK"
925: return dictionary;
926: }
927:
928: ////////////////////////////////////////////////////////////////////////////
929:
930: /// <summary>
931: ///
932: /// </summary>
933: public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> ServiceOntToCreateAndToDeleteInEmsOntSipInfoOrVoipPstnUserListFromThePastNHourList(int provisioningWithinPastNHours, List<string> priorityServiceList)
934: {
935: DateTime pastNHoursDateTime;
936: List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList, laterProcessList;
937:
938: processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
939: laterProcessList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
940:
941: pastNHoursDateTime = (provisioningWithinPastNHours > 0) ? DateTime.UtcNow.AddHours(3).AddHours(-provisioningWithinPastNHours) : DateTime.MinValue;
942:
943: 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);
944:
945: foreach (var serviceOnt in serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList)
946: {
947: if (serviceOnt.CreatedDateTime >= pastNHoursDateTime || priorityServiceList.Contains(serviceOnt.Service))
948: {
949: 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 };
950: processList.Add(p);
951:
952: 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 };
953: processList.Add(p);
954: laterProcessList.Add(p);
955: }
956: }
957:
958: foreach (var serviceOnt in serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList)
959: {
960: if (serviceOnt.CreatedDateTime >= pastNHoursDateTime || priorityServiceList.Contains(serviceOnt.Service))
961: {
962: 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 };
963: processList.Add(p);
964:
965: 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 };
966: processList.Add(p);
967: laterProcessList.Add(p);
968: }
969: }
970:
971: processList = processList.OrderByDescending(l => l.DateTime).ToList();
972:
973: processList.AddRange(laterProcessList);
974:
975: return processList;
976: }
977:
978: ////////////////////////////////////////////////////////////////////////////
979:
980: /// <summary>
981: ///
982: /// </summary>
983: public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> _ServiceOntToCreateAndToDeleteInEmsOntSipInfoOrVoipPstnUserListFromThePastNHourList(int provisioningWithinPastNHours, List<string> priorityServiceList)
984: {
985: DateTime pastNHoursDateTime;
986: List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList, laterProcessList;
987:
988: processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
989: laterProcessList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
990:
991: pastNHoursDateTime = (provisioningWithinPastNHours > 0) ? DateTime.UtcNow.AddHours(3).AddHours(-provisioningWithinPastNHours) : DateTime.MinValue;
992:
993: /*
994: 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);
995:
996: foreach (var serviceOnt in serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList)
997: {
998: if (serviceOnt.CreatedDateTime >= pastNHoursDateTime || priorityServiceList.Contains(serviceOnt.Service))
999: {
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 };
processList.Add(p);
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 };
processList.Add(p);
laterProcessList.Add(p);
}
}
foreach (var serviceOnt in serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList)
{
if (serviceOnt.CreatedDateTime >= pastNHoursDateTime || priorityServiceList.Contains(serviceOnt.Service))
{
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 };
processList.Add(p);
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 };
processList.Add(p);
laterProcessList.Add(p);
}
}
processList = processList.OrderByDescending(l => l.DateTime).ToList();
processList.AddRange(laterProcessList);
*/
return processList;
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> MsanServiceEmsVoipPstnUserDidFnSnPnDnToDeleteBecauseItHasProvisionedImsServiceOrHasNoEquivalentInServiceList()
{
string dn;
List<string> serviceExemptionList;
List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList, laterProcessList;
processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
laterProcessList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
var list1 = Ia.Ngn.Cl.Model.Business.Provision.MsanServicesThatHaveProvisionedImsServiceExceptWhereEmsOntSipInfoEmsOntIsOfflineOrDeviceOfflineErrorAndExceptWhereEmsVoipPstnUserEmsDevHasDeviceOfflineErrorAndIgnoringNonSipNokiaOntList();
var list2 = Ia.Ngn.Cl.Model.Business.Provision.MsanServiceInVoipPstnUserThatHaveNoEquivalentInServiceList();
var list = list1.Union(list2).ToList();
// will exclude exempt numbers
serviceExemptionList = Ia.Ngn.Cl.Model.Data.Provision.ServiceOfServiceExemptFromProvisionProcessingList();
foreach (string service in serviceExemptionList) list.Remove(service);
var voipPstnUserDidFnSnPnDnMsanList = Ia.Ngn.Cl.Model.Data.Huawei.VoipPstnUser.DidFnSnPnDnMsanList();
foreach (var service in list)
{
dn = Ia.Ngn.Cl.Model.Business.NumberFormatConverter.ImpuAid(service);
var voipPstnUserDidFnSnPnDnMsan = (from vpudfspdm in voipPstnUserDidFnSnPnDnMsanList
where vpudfspdm.Dn == dn
select vpudfspdm).FirstOrDefault();
if (voipPstnUserDidFnSnPnDnMsan != null)
{
var p = new Ia.Ngn.Cl.Model.Business.Procedure.Process { Service = service, EmsVoipPstnUserDidFnSnPnDn = voipPstnUserDidFnSnPnDnMsan, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Delete };
processList.Add(p);
p = new Ia.Ngn.Cl.Model.Business.Procedure.Process { Service = service, EmsVoipPstnUserDidFnSnPnDn = voipPstnUserDidFnSnPnDnMsan, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Read };
processList.Add(p);
laterProcessList.Add(p);
}
}
processList = processList.OrderByDescending(l => l.DateTime).ToList();
processList.AddRange(laterProcessList);
return processList;
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> ServiceOntToAddAndToRemoveInAsbrList()
{
List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList;
processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
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);
// issue read, execute, then read again commands
foreach (var serviceOnt in serviceOntToAddToAsbrList)
{
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 });
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 });
}
foreach (var serviceOnt in serviceOntToRemoveFromAsbrList)
{
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 });
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 });
}
return processList;
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
/// 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.
/// </summary>
private static void ServiceOntToCreateInEmsOntSipInfoOrVoipPstnUserList_ServiceOntToAnnulInEmsOntSipInfoOrVoipPstnUserList(out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList, out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList)
{
Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated serviceOnt2;
List<string> serviceIdExemptionList;
List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntList, serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList;
List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> ontSipInfoServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList, voipPstnUserServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList;
serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList = new List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated>();
serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList = new List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated>();
serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList = Ia.Ngn.Cl.Model.Data.Service2.ServiceOntWithinAllowedSipOltToBeProvisionedOrMigratedList;
serviceOntList = Ia.Ngn.Cl.Model.Data.Service2.ServiceOntList;
ontSipInfoServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList = Ia.Ngn.Cl.Model.Data.Huawei.OntSipInfo.ServiceOntWithinAllowedSipOltToBeProvisionedOrMigratedList();
voipPstnUserServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList = Ia.Ngn.Cl.Model.Data.Huawei.VoipPstnUser.ServiceOntWithinAllowedSipOltToBeProvisionedOrMigratedList();
foreach (var serviceOnt in serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList)
{
if (!ontSipInfoServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId)
&& !voipPstnUserServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId))
{
if (!serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
{
serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList.Add(serviceOnt);
}
}
}
// In serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList I must make sure that serviceId does not belong to any current service in serviceOntList
// 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.
foreach (var ontSipInfoServiceOnt in ontSipInfoServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList)
{
if (!serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList.Any(u => u.ServiceId == ontSipInfoServiceOnt.ServiceId && u.AccessId == ontSipInfoServiceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
{
if (!serviceOntList.Any(u => u.ServiceId == ontSipInfoServiceOnt.ServiceId /*&& u.AccessId == serviceOnt.AccessId*/)) // .Contains(serviceOnt) is disastrous here
{
if (!serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Any(u => u.ServiceId == ontSipInfoServiceOnt.ServiceId && u.AccessId == ontSipInfoServiceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
{
serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Add(ontSipInfoServiceOnt);
}
}
}
/*
else if (serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList.Any(u => u.ServiceId == ontSipInfoServiceOnt.ServiceId && u.CreatedDateTime > ontSipInfoServiceOnt.CreatedDateTime))
{
// below: we will check for and add all NCE records that were created *before* the IMS records
if (!serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Any(u => u.ServiceId == ontSipInfoServiceOnt.ServiceId))
{
serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Add(ontSipInfoServiceOnt);
}
}
*/
}
foreach (var voipPstnUserServiceOnt in voipPstnUserServiceOntWithinAllowedToBeProvisionedOrMigratedSipOltList)
{
if (!serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList.Any(u => u.ServiceId == voipPstnUserServiceOnt.ServiceId && u.AccessId == voipPstnUserServiceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
{
if (!serviceOntList.Any(u => u.ServiceId == voipPstnUserServiceOnt.ServiceId /*&& u.AccessId == serviceOnt.AccessId*/)) // .Contains(serviceOnt) is disastrous here
{
if (!serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Any(u => u.ServiceId == voipPstnUserServiceOnt.ServiceId && u.AccessId == voipPstnUserServiceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
{
serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Add(voipPstnUserServiceOnt);
}
}
}
/*
else if (serviceOntWithinAllowedToBeProvisionedOrMigratedSipOltList.Any(u => u.ServiceId == voipPstnUserServiceOnt.ServiceId && u.CreatedDateTime > voipPstnUserServiceOnt.CreatedDateTime))
{
// below: we will check for and add all NCE records that were created *before* the IMS records
if (!serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Any(u => u.ServiceId == voipPstnUserServiceOnt.ServiceId))
{
serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Add(voipPstnUserServiceOnt);
}
}
*/
}
// will exclude exempt numbers
serviceIdExemptionList = Ia.Ngn.Cl.Model.Data.Provision.ServiceIdOfServiceExemptFromProvisionProcessingList();
foreach (string serviceId in serviceIdExemptionList)
{
serviceOnt2 = serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList.SingleOrDefault(u => u.ServiceId == serviceId);
if (serviceOnt2 != null) serviceOntToCreateInEmsOntSipInfoOrVoipPstnUserList.Remove(serviceOnt2);
serviceOnt2 = serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.SingleOrDefault(u => u.ServiceId == serviceId);
if (serviceOnt2 != null) serviceOntToAnnulInEmsOntSipInfoOrVoipPstnUseList.Remove(serviceOnt2);
}
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
public static List<string> MsanServicesThatHaveProvisionedImsServiceExceptWhereEmsOntSipInfoEmsOntIsOfflineOrDeviceOfflineErrorAndExceptWhereEmsVoipPstnUserEmsDevHasDeviceOfflineErrorAndIgnoringNonSipNokiaOntList()
{
var serviceList = Ia.Ngn.Cl.Model.Data.Service2.ImsServiceInAllowedToBeMigratedOltList;
var msanServiceList = Ia.Ngn.Cl.Model.Data.Service2.MsanServiceList;
var serviceWhereEmsOntIsOfflineList = Ia.Ngn.Cl.Model.Data.Huawei.OntSipInfo.ServiceWithinEmsOntSipInfoWhereEmsOntResultCodeOntIsOfflineOrDeviceOfflineErrorList();
var serviceWhereEmsDevDeviceOfflineError = Ia.Ngn.Cl.Model.Data.Huawei.VoipPstnUser.ServiceWithinEmsVoipPstnUserWhereEmsDevResultCodeDeviceOfflineError();
//var serviceWhereOntIsOfflineList = Ia.Ngn.Cl.Model.Data.Nokia.Ont.ServiceWhereOntIsOfflineList();
var list = msanServiceList.Intersect(serviceList).ToList();
list = list.Except(serviceWhereEmsOntIsOfflineList).ToList();
list = list.Except(serviceWhereEmsDevDeviceOfflineError).ToList();
return list;
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
public static List<string> MsanServiceInVoipPstnUserThatHaveNoEquivalentInServiceList()
{
List<string> list;
var serviceList = Ia.Ngn.Cl.Model.Data.Service2.ServiceList;
var msanServiceList = Ia.Ngn.Cl.Model.Data.Huawei.VoipPstnUser.MsanServiceList;
list = msanServiceList.Except(serviceList).ToList();
return list;
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
public static void ServiceOntToAddToAsbrList_ServiceOntToRemoveFromAsbrList(out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> addList, out List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> removeList)
{
Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated serviceOnt2;
List<string> serviceIdExemptionList;
List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> serviceOntList, serviceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList;
List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated> asbrServiceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList;
addList = new List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated>();
removeList = new List<Ia.Ngn.Cl.Model.Business.ServiceAccessIpOntCreated>();
//List<string> list;
/*
select s.Service from Service2 s
inner join ServiceRequestServices srs on s.Id = srs.Id
inner join Accesses a on a.Id = srs.Access_Id
inner join HuSbrs sb on 'sip:+965'+ s.Service +'@ims.moc.kw' = sb.IMPU
left outer join Asbrs asb on sb.IMPU = asb.PUI
where (a.Olt = 102010101 or a.Olt = 102010201) -- OLT ids MUB:102010101 QRN:102010201
and srs.Provisioned = 1
and asb.Id is null
order by s.Service
*/
/*
// for oltId intersect AllowedToBeMigrated with Hu-No OLTs
var oltIdList = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.HuaweiSwitchNokiaAccessOltIdList;
//var i = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntAccessIdToOntAccessNameDictionary;
using (var db = new Ia.Ngn.Cl.Model.Ngn())
{
var list = (from s in db.Service2s
join srs in db.ServiceRequestServices on s.Id equals srs.Id
join a in db.Accesses on srs.Access.Id equals a.Id
//join sbr in db.HuSbrs on "sip:+965" + s.Service + "@ims.moc.kw" equals sbr.IMPU
//join asbr in db.Asbrs on sbr.IMPU equals asbr.PUI into gj
//from u in gj.DefaultIfEmpty()
where oltIdList.Contains(a.Olt) && srs.Provisioned == true //&& u == null
orderby s.Service
select new { s.Service, AccessId = a.Id }).ToList();
//var l = (from a in list select i[a.AccessId]).Distinct().ToList();
var l = (from a in list select a.AccessId).Distinct().ToList();
}
//return list;
*/
serviceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList = Ia.Ngn.Cl.Model.Data.Service2.ServiceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList();
serviceOntList = Ia.Ngn.Cl.Model.Data.Service2.ServiceOntList;
asbrServiceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList = Ia.Ngn.Cl.Model.Data.Huawei.Asbr.ServiceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList();
foreach (var serviceOnt in serviceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList)
{
if (!asbrServiceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId))
{
if (!addList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
{
addList.Add(serviceOnt);
}
}
}
foreach (var serviceOnt in asbrServiceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList)
{
if (!serviceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
{
if (!serviceOntList.Any(u => u.ServiceId == serviceOnt.ServiceId /*&& u.AccessId == serviceOnt.AccessId*/)) // .Contains(serviceOnt) is disastrous here
{
if (!removeList.Any(u => u.ServiceId == serviceOnt.ServiceId && u.AccessId == serviceOnt.AccessId)) // .Contains(serviceOnt) is disastrous here
{
removeList.Add(serviceOnt);
}
}
}
else if (serviceOntWithinAllowedToBeProvisionedOrMigratedHuaweiSwitchNokiaAccessOltList.Any(u => u.ServiceId == serviceOnt.ServiceId /*&& u.AccessId == serviceOnt.AccessId*/ && u.CreatedDateTime > serviceOnt.CreatedDateTime))
{
// below: we will check for and add all NCE records that were created *before* the IMS records
if (!removeList.Any(u => u.ServiceId == serviceOnt.ServiceId /*&& u.AccessId == serviceOnt.AccessId*/))
{
removeList.Add(serviceOnt);
}
}
}
// will exclude exempt numbers
serviceIdExemptionList = Ia.Ngn.Cl.Model.Data.Provision.ServiceIdOfServiceExemptFromProvisionProcessingList();
foreach (string serviceId in serviceIdExemptionList)
{
serviceOnt2 = addList.SingleOrDefault(u => u.ServiceId == serviceId);
if (serviceOnt2 != null) addList.Remove(serviceOnt2);
serviceOnt2 = removeList.SingleOrDefault(u => u.ServiceId == serviceId);
if (serviceOnt2 != null) removeList.Remove(serviceOnt2);
}
}
/*
////////////////////////////////////////////////////////////////////////////
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
public static List<string> ServiceSuspendedInServiceRequestServiceButNotInServiceStringNumberList
{
get
{
List<string> list, sList, srsList;
SortedList sl;
sList = Ia.Ngn.Cl.Model.Data.Service2.ServiceSuspensionIsTrueStringNumberList;
srsList = Ia.Ngn.Cl.Model.Data.ServiceRequestService.ServiceSuspensionIsTrueAndProvisionedIsTrueStringNumberList;
if (sList != null && sList.Count > 0)
{
if (srsList != null && srsList.Count > 0)
{
list = new List<string>(sList.Count);
sl = new SortedList(sList.ToDictionary(s => s));
foreach (string s in srsList)
{
if (!sl.ContainsKey(s)) list.Add(s);
}
}
else
{
list = new List<string>();
}
}
else
{
if (srsList != null && srsList.Count > 0) list = sList;
else list = new List<string>();
}
return list;
}
}
*/
/*
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
public static List<string> ServiceActiveInServiceRequestServiceButNotInServiceStringNumberList
{
get
{
List<string> list, sList, srsList;
SortedList sl;
sList = Ia.Ngn.Cl.Model.Data.Service2.ServiceSuspensionIsFalseStringNumberList;
srsList = Ia.Ngn.Cl.Model.Data.ServiceRequestService.ServiceSuspensionIsFalseStringNumberList;
if (sList != null && sList.Count > 0)
{
if (srsList != null && srsList.Count > 0)
{
list = new List<string>(sList.Count);
sl = new SortedList(sList.ToDictionary(s => s));
foreach (string s in srsList)
{
if (!sl.ContainsKey(s)) list.Add(s);
}
}
else
{
list = new List<string>();
}
}
else
{
if (srsList != null && srsList.Count > 0) list = sList;
else list = new List<string>();
}
return list;
}
}
*/
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> EmsOntToBeUpdatedFromH248ToSipList()
{
List<string> oltSymbolList;
List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList;
processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
oltSymbolList = Ia.Ngn.Cl.Model.Business.Default.H248ToSipUpdateOltSymbolList;
var list = Ia.Ngn.Cl.Model.Data.Default.DistinctNddOntWhereVaprofIsNotAluSipBAndIgnoreMduForOltSymbolListList(oltSymbolList);
foreach (var l in list)
{
processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { Ont = l.Ont, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Update });
processList.Add(new Ia.Ngn.Cl.Model.Business.Procedure.Process { Ont = l.Ont, Type = Ia.Ngn.Cl.Model.Business.Procedure.ProcessType.Read });
}
return processList;
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> OntSipInfoOrOntVoipPstnUserToBeCreatedForAnOntUpdatedFromH248ToSipList()
{
int pn;
List<string> oltSymbolList;
List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList;
processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
oltSymbolList = Ia.Ngn.Cl.Model.Business.Default.H248ToSipUpdateOltSymbolList;
var list = Ia.Ngn.Cl.Model.Data.Default.ServiceAndNddOntAndEmsOntFamilyTypeAndPortWhereAgcfEndpointPortIsNot0AndVaprofIsAluSipBAndSfuEmsOntSipInfoTelDoesNotExistOrMduEmsVagIsSipAndMduEmsVoipPstnUserPnDoesNotExistForOltSymbolListList(oltSymbolList);
/*
* All Nokia ONTs (SFUs and MDUs) start at port position 1.
* Huawei ONTs (SFUs) start at port position 1, while Huawei MDUs start at port position 0.
*/
// issue update then read commands
foreach (var l in list)
{
if (l.EmsOntFamilyType == Ia.Ngn.Cl.Model.Business.Huawei.Ont.FamilyType.Sfu)
{
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 });
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 });
}
else if (l.EmsOntFamilyType == Ia.Ngn.Cl.Model.Business.Huawei.Ont.FamilyType.Mdu)
{
pn = Ia.Ngn.Cl.Model.Business.Service.ConvertFlatTermIdPositionToEmsVoipPstnUsersPn(l.Port);
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 });
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 });
}
else
{
throw new Exception("EmsOntFamilyType is not concedered. ");
}
}
return processList;
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
public static List<Ia.Ngn.Cl.Model.Business.Procedure.Process> NokiaImsSubscriberToBeUpdatedFromH248ToSipList()
{
List<string> oltSymbolList;
List<Ia.Ngn.Cl.Model.Business.Procedure.Process> processList;
processList = new List<Ia.Ngn.Cl.Model.Business.Procedure.Process>();
oltSymbolList = Ia.Ngn.Cl.Model.Business.Default.H248ToSipUpdateOltSymbolList;
var list = Ia.Ngn.Cl.Model.Data.Default.ServiceAndNddOntWherePrimaryPuidcpeProfileNumberIsNot10AndEmsOntVaprofIsAluSipBAndSfuEmsOntSipInfoTelExistsOrAndMduEmsOntVagIsSipAndMduEmsVoipPstnUserPnExistsForOltSymbolListList(oltSymbolList);
// issue delete then create commands
foreach (var l in list)
{
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 });
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 });
}
return processList;
}
////////////////////////////////////////////////////////////////////////////
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
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)
{
int gatewayId, port;
long number;
string partyId, r;
string accessId, service;
Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
Ia.Ngn.Cl.Model.Service2 service2;
Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor, accessVendor;
result = new Ia.Cl.Model.Result();
if (!string.IsNullOrEmpty(input))
{
input = input.Trim();
//input = input.ToLower();
number = long.Parse(input);
if (Ia.Ngn.Cl.Model.Business.Service.ServiceHasEightDigitsAndIsWithinAllowedDomainList(number))
{
service = number.ToString();
result.AddSuccess("Service: " + service + " ");
/*
* Note that in find.aspx (Ia.Ngn.Cl.Model.Ui.Default) I actually hide access name if port is undefined.
* case "service2AccessNameHyperLink":
* {
* if (service2.AccessName != null && service2.Port != Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown)
* {
* hl.Text = service2.AccessName;
* hl.NavigateUrl = Ia.Ngn.Cl.Model.Business.Maintenance.Find.Url(service2.AccessName);
* }
* break;
* }
*/
Ia.Ngn.Cl.Model.Data.Service.AccessIdAndPortByService(service, out accessId, out port);
// below: I should remove the whole section within if(){} below
if (string.IsNullOrEmpty(accessId))
{
var serviceType = Ia.Ngn.Cl.Model.Business.Service.ServiceType.ImsService;
var serviceId = Ia.Ngn.Cl.Model.Business.Service.ServiceToServiceId(service, serviceType);
// attempt a read from Service2
service2 = Ia.Ngn.Cl.Model.Data.Service2.ReadByIdIncludeAccess(serviceId);
if (service2 != null && service2.Access != null) accessId = service2.Access.Id;
else
{
// attempt a read from ServiceRequestService
var serviceRequestService = Ia.Ngn.Cl.Model.Data.ServiceRequestService.ReadIncludeAccess(serviceId);
if (serviceRequestService != null && serviceRequestService.Access != null) accessId = serviceRequestService.Access.Id;
else accessId = string.Empty;
}
}
if (!string.IsNullOrEmpty(accessId))
{
// get service information using accessId
nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(accessId);
if (nddOnt != null)
{
switchVendor = nddOnt.Pon.PonGroup.Olt.Odf.Router.Vendor;
accessVendor = nddOnt.Pon.PonGroup.Olt.Odf.Vendor;
try
{
if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
{
partyId = Ia.Ngn.Cl.Model.Business.NumberFormatConverter.PartyId(service);
gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromPartyId(partyId);
if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
{
if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
{
Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(nokiaIms, gatewayId, out r);
result.AddSuccess(r);
}
else // if IsSip == true
{
result.AddSuccess("SIP process is undefined for No/No");
}
}
else if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
{
if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
{
Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(nokiaIms, gatewayId, out r);
}
else // if IsSip == true
{
Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(nokiaIms, service, nddOnt, out r);
}
result.AddSuccess(r);
}
else throw new Exception("AccessVendor is undefined");
}
else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
{
Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadSbrForService(huaweiIms, service, out string readHuaweiResult);
result.AddSuccess(readHuaweiResult);
if (accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia || accessVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
{
Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, accessId, out r);
result.AddSuccess(r);
}
else throw new Exception("accessVendor is undefined");
}
else throw new Exception("switchVendor is undefined");
}
catch (Exception ex)
{
result.AddError("Exception: " + ex.ToString());
}
}
else result.AddError("NDD ONT is null, does not exist for service: " + service);
}
else
{
// get service without knowing accessId
if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedNokiaSwitchDomainList(service))
{
/*
partyId = Ia.Ngn.Cl.Model.Business.NumberFormatConverter.PartyId(service);
gatewayId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromPartyId(partyId);
Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(nokiaIms, gatewayId, out r);
Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(nokiaIms, service, null, out r);
*/
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);
}
else if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedHuaweiSwitchDomainList(service))
{
Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, string.Empty, out r);
result.AddSuccess(r);
}
else
{
throw new Exception("switchVendor is undefined");
}
}
// this is a sensitive issue. later I will allow storing empty accessId
Ia.Ngn.Cl.Model.Data.Service.AccessIdAndPortByService(service, out accessId, out port);
//if (!string.IsNullOrEmpty(accessId))
//{
Ia.Ngn.Cl.Model.Data.Service2.UpdateImsServiceAccessAndPort(service, accessId, port, Guid.Empty, out Ia.Cl.Model.Result updateServiceAccessResult);
result.AddResult(updateServiceAccessResult);
//}
}
else result.AddError("Number \"" + number + "\" does not belong to the network.");
}
else result.AddError("No input was entered.");
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
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)
{
long number;
string r, r0, r2;
string accessId, service;
Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor;
result = new Ia.Cl.Model.Result();
if (!string.IsNullOrEmpty(input))
{
input = input.Trim();
//input = input.ToLower();
number = long.Parse(input);
if (Ia.Ngn.Cl.Model.Business.Service.ServiceHasEightDigitsAndIsWithinAllowedDomainList(number))
{
service = number.ToString();
switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
result.AddSuccess("Service: " + service + " ");
Ia.Ngn.Cl.Model.Data.Service.AccessIdAndPortByService(service, out accessId, out int port);
if (!string.IsNullOrEmpty(accessId))
{
nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntAccessIdToOntDictionary.ContainsKey(accessId) ? Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntAccessIdToOntDictionary[accessId] : null;
if (nddOnt != null)
{
switchVendor = nddOnt.Pon.PonGroup.Olt.Odf.Router.Vendor;
try
{
if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
{
Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, supplementaryService, supplementaryServiceState, out r);
result.AddSuccess(r);
if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
{
var gwId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
if (gwId > 0)
{
Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(nokiaIms/*, sNddOnt*/, gwId, out r2);
}
else
{
r2 = "gwId: zero";
}
}
else // if IsSip == true
{
Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(nokiaIms, service, nddOnt, out r2);
}
result.AddSuccess("updated:" + r + ", read:" + r2);
}
else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
{
Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, supplementaryService, supplementaryServiceState, out r);
Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, string.Empty, out r2);
result.AddSuccess("updated:" + r + ", read:" + r2);
}
else
{
throw new Exception("switchVendor is undefined.");
}
}
catch (Exception ex)
{
result.AddError("Exception: " + ex.ToString());
}
}
else result.AddError("NDD ONT is null, does not exist for service: " + service);
}
else
{
if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
{
Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, supplementaryService, supplementaryServiceState, out r);
Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, string.Empty, out r2);
result.AddSuccess("updated:" + r + ", read:" + r2);
}
else
{
result.AddError("AccessId is null and switchVendor is not Huawei for service: " + service);
}
}
}
else result.AddError("Number \"" + number + "\" does not belong to the network");
}
else result.AddError("No input was entered");
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
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)
{
int number;
string r0, r1, r2, r3, service;
Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor;
r0 = r1 = r2 = r3 = string.Empty;
var result = new Ia.Cl.Model.Result();
var kvp = Ia.Ngn.Cl.Model.Business.Provision.DiscrepancyAndComplementaryServiceMismatchBetweenServiceRequestServiceAndServiceItem(procedure, out int serviceQueueCount, out string progressCounterString);
var serviceId = kvp.Key;
var serviceRequestAdministrativeIssueType = Ia.Ngn.Cl.Model.Business.ServiceRequestAdministrativeIssue.ServiceRequestAdministrativeIssueTypeByDisconnectionType(Ia.Ngn.Cl.Model.Business.ServiceRequestAdministrativeIssue.DisconnectionType.None);
if (!string.IsNullOrEmpty(serviceId))
{
var synchronized = false;
r0 = "service: " + serviceId.Replace(":1:965", "") + " " + progressCounterString + ": ";
service = Ia.Ngn.Cl.Model.Business.Service.ServiceIdToService(serviceId);
if (Ia.Ngn.Cl.Model.Business.Service.ServiceHasEightDigitsAndIsWithinAllowedDomainList(service))
{
var service2 = Ia.Ngn.Cl.Model.Data.Service2.ReadByIdIncludeAccess(serviceId);
var serviceRequestService = Ia.Ngn.Cl.Model.Data.ServiceRequestService.ReadIncludeAccess(serviceId);
try
{
if (serviceRequestService != null)
{
service = serviceRequestService.Service;
if (serviceRequestService.Provisioned)
{
if (int.TryParse(service, out number))
{
switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
if (service2 == null)
{
// create service
r0 += "create: ";
nddOnt = (serviceRequestService.Access != null) ? Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(serviceRequestService.Access.Id) : null;
if (nddOnt != null)
{
if (Ia.Ngn.Cl.Model.Business.Service.OltIsWithinAllowedToBeProvisionedOltList(nddOnt.Pon.PonGroup.Olt))
{
if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainExceptionList(nddOnt, service))
{
if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
{
r0 += "Nokia: ";
// make sure the number is not suspended before creating it
Ia.Ngn.Cl.Model.Data.ServiceRequestAdministrativeIssue.Update(service, serviceRequestAdministrativeIssueType, false, out _);
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);
synchronized = true;
r0 += r1 + ",";
}
else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
{
r0 += "Huawei: ";
// make sure the number is not suspend before creating it
Ia.Ngn.Cl.Model.Data.ServiceRequestAdministrativeIssue.Update(service, serviceRequestAdministrativeIssueType, false, out _);
// I will completely remove any existing number before installing it again to make sure it installs fresh
// maybe I shouldn't
// Ia.Ngn.Cl.Model.Business.Provision.DeleteReadHuaweiSwitchSubscriber(huaweiIms, nddOnt.Access.Name, service, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r1);
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);
synchronized = true;
r0 += r1 + "," + r2 + ",";
}
else
{
throw new Exception("switchVendor is undefined.");
}
}
else
{
r0 += "service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
}
}
else
{
r0 += "Access is not in an allowed to be provisioned OLT. ";
}
}
else
{
if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
{
// see above
r0 += "Huawei: ";
// make sure the number is not suspend before creating it
Ia.Ngn.Cl.Model.Data.ServiceRequestAdministrativeIssue.Update(service, serviceRequestAdministrativeIssueType, false, out _);
// I will completely remove any existing number before installing it again to make sure it installs fresh
// maybe I shouldn't
//Ia.Ngn.Cl.Model.Business.Provision.DeleteReadHuaweiSwitchSubscriber(huaweiIms, string.Empty, service, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r1);
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);
synchronized = true;
//r0 += r4.Message + "," + r1 + "," + r2 + ","; too much info
r0 += r2 + ",";
}
else
{
r0 += "serviceNddOnt is null and switchVendor is not Huawei. ";
}
}
}
else
{
// update service
r0 += "update: ";
if (service2.Access != null) nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(service2.Access.Id);
else if (serviceRequestService.Access != null) nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(serviceRequestService.Access.Id);
else nddOnt = null;
if (nddOnt != null)
{
if (Ia.Ngn.Cl.Model.Business.Service.OltIsWithinAllowedToBeProvisionedOltList(nddOnt.Pon.PonGroup.Olt))
{
// To make things easier, I will skip checking for NumberIsWithinAllowedRouterDomainList in updates because it is already checked when the number is installed
//if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainList(nddOnt, service))
//{
r0 += "service: ";
if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
{
r0 += "Nokia: ";
// below: send change command to IMS
if (service2.CallerId != serviceRequestService.CallerId) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallerId, serviceRequestService.CallerId, out r2);
else if (service2.CallForwarding != serviceRequestService.CallForwarding) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallForwarding, serviceRequestService.CallForwarding, out r2);
else if (service2.ConferenceCall != serviceRequestService.ConferenceCall) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.ConferenceCall, serviceRequestService.ConferenceCall, out r2);
else if (service2.AlarmCall != serviceRequestService.AlarmCall) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.WakeupCall, serviceRequestService.AlarmCall, out r2); // do not change
else if (service2.WakeupCall != serviceRequestService.WakeupCall) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.WakeupCall, serviceRequestService.WakeupCall, out r2);
else if (service2.AbbriviatedCalling != serviceRequestService.AbbriviatedCalling) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.AbbriviatedCalling, serviceRequestService.AbbriviatedCalling, out r2);
else if (service2.InternationalCalling != serviceRequestService.InternationalCalling) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, serviceRequestService.InternationalCalling, out r2);
else if (service2.InternationalCallingUserControlled != serviceRequestService.InternationalCallingUserControlled) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCallingUserControlled, serviceRequestService.InternationalCallingUserControlled, out r2);
// 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
else if (service2.CallWaiting != serviceRequestService.CallWaiting) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallWaiting, serviceRequestService.CallWaiting, out r2);
//else if (Ia.Ngn.Cl.Model.Business.Administration.ServiceSuspensionIsEnabled && service2.ServiceSuspension != serviceRequestService.CallBarring) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.ServiceSuspension, serviceRequestService.CallBarring, out r2);
else r2 = "no difference in services. ";
if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
{
var gwId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
if (gwId > 0)
{
Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(nokiaIms/*, sNddOnt*/, gwId, out r3);
r0 += r2 + "," + r3 + ",";
}
else
{
r0 += "gwId: 0," + r2 + "," + r3 + ",";
}
}
else // if IsSip == true
{
Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(nokiaIms, service, nddOnt, out r3);
r0 += r2 + "," + r3 + ",";
}
}
else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
{
r0 += "Huawei: ";
// See below
if (service2.CallerId != serviceRequestService.CallerId) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallerId, serviceRequestService.CallerId, out r2);
else if (service2.CallForwarding != serviceRequestService.CallForwarding) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallForwarding, serviceRequestService.CallForwarding, out r2);
else if (service2.CallWaiting != serviceRequestService.CallWaiting) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallWaiting, serviceRequestService.CallWaiting, out r2);
else if (service2.ConferenceCall != serviceRequestService.ConferenceCall) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.ConferenceCall, serviceRequestService.ConferenceCall, out r2);
else if (service2.AlarmCall != serviceRequestService.AlarmCall) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.WakeupCall, serviceRequestService.AlarmCall, out r2); // do not change
else if (service2.WakeupCall != serviceRequestService.WakeupCall) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.WakeupCall, serviceRequestService.WakeupCall, out r2);
else if (service2.AbbriviatedCalling != serviceRequestService.AbbriviatedCalling) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.AbbriviatedCalling, serviceRequestService.AbbriviatedCalling, out r2);
else if (service2.InternationalCalling != serviceRequestService.InternationalCalling) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, serviceRequestService.InternationalCalling, out r2);
else if (service2.InternationalCallingUserControlled != serviceRequestService.InternationalCallingUserControlled) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCallingUserControlled, serviceRequestService.InternationalCallingUserControlled, out r2);
//else if (Ia.Ngn.Cl.Model.Business.Administration.ServiceSuspensionIsEnabled && service2.ServiceSuspension != serviceRequestService.CallBarring) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.ServiceSuspension, serviceRequestService.CallBarring, out r2);
else r2 = "no difference in services. ";
Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, nddOnt.Access.Id, out r3);
r0 += r2 + "," + r3 + ",";
}
else
{
throw new Exception("switchVendor is undefined.");
}
//}
//else
//{
// r0 += "service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
//}
}
else
{
r0 += "Access is not in an allowed to be provisioned OLT. ";
}
}
else
{
if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
{
r0 += "Huawei: ";
// See above
if (service2.CallerId != serviceRequestService.CallerId) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallerId, serviceRequestService.CallerId, out r2);
else if (service2.CallForwarding != serviceRequestService.CallForwarding) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallForwarding, serviceRequestService.CallForwarding, out r2);
else if (service2.CallWaiting != serviceRequestService.CallWaiting) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.CallWaiting, serviceRequestService.CallWaiting, out r2);
else if (service2.ConferenceCall != serviceRequestService.ConferenceCall) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.ConferenceCall, serviceRequestService.ConferenceCall, out r2);
else if (service2.AlarmCall != serviceRequestService.AlarmCall) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.WakeupCall, serviceRequestService.AlarmCall, out r2); // do not change
else if (service2.WakeupCall != serviceRequestService.WakeupCall) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.WakeupCall, serviceRequestService.WakeupCall, out r2);
else if (service2.AbbriviatedCalling != serviceRequestService.AbbriviatedCalling) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.AbbriviatedCalling, serviceRequestService.AbbriviatedCalling, out r2);
else if (service2.InternationalCalling != serviceRequestService.InternationalCalling) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, serviceRequestService.InternationalCalling, out r2);
else if (service2.InternationalCallingUserControlled != serviceRequestService.InternationalCallingUserControlled) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCallingUserControlled, serviceRequestService.InternationalCallingUserControlled, out r2);
//else if (Ia.Ngn.Cl.Model.Business.Administration.ServiceSuspensionIsEnabled && service2.ServiceSuspension != serviceRequestService.CallBarring) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.ServiceSuspension, serviceRequestService.CallBarring, out r2);
else r2 = "no difference in services. ";
Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, string.Empty, out r3);
r0 += r2 + "," + r3 + ",";
}
else
{
r0 += "serviceNddOnt is null and switchVendor is not Huawei. ";
}
}
}
}
else
{
r0 += "service is not a valid number. ";
}
}
else
{
if (int.TryParse(service, out number))
{
switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
if (service2 != null)
{
// delete service
r0 += "delete: ";
nddOnt = (service2.Access != null) ? Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(service2.Access.Id) : null;
if (nddOnt != null)
{
if (Ia.Ngn.Cl.Model.Business.Service.OltIsWithinAllowedToBeProvisionedOltList(nddOnt.Pon.PonGroup.Olt))
{
if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainExceptionList(nddOnt, service))
{
if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
{
r0 += "Nokia: ";
Ia.Ngn.Cl.Model.Business.Provision.DeleteReadNokiaSwitchSubscriber(nokiaIms, nddOnt.Access.Name, service, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r1);
synchronized = true;
r0 += r1;
}
else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
{
r0 += "Huawei: ";
Ia.Ngn.Cl.Model.Business.Provision.DeleteReadHuaweiSwitchSubscriber(huaweiIms, nddOnt.Access.Name, service, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r1);
synchronized = true;
r0 += r1;
}
else
{
throw new Exception("switchVendor is undefined.");
}
}
else
{
r0 += "service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.";
}
}
else
{
r0 += "Access is not in an allowed to be provisioned OLT. ";
}
}
else
{
if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
{
r0 += "Nokia: ";
//Ia.Ngn.Cl.Model.Business.Provision.DeleteReadNokiaSwitchSubscriber(nokiaIms, string.Empty, service, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r1);
//r0 += "serviceNddOnt is null and switchVendor is not Huawei. ";
Ia.Ngn.Cl.Model.Business.Provision.DeleteReadNokiaSwitchAgcfEndpointAndH248SubscriberFromAnyFsdb(nokiaIms, service, out r1);
synchronized = true;
r0 += r1;
}
else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
{
// see above
r0 += "Huawei: ";
Ia.Ngn.Cl.Model.Business.Provision.DeleteReadHuaweiSwitchSubscriber(huaweiIms, string.Empty, service, Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd, false, out r1);
synchronized = true;
r0 += r1;
}
else
{
throw new Exception("switchVendor is undefined.");
}
}
}
else
{
throw new Exception("service2 is null. ");
}
}
else
{
r0 += "service is not a valid number. ";
}
}
}
else
{
r0 += "serviceRequestService is null. ";
}
}
catch (Exception ex)
{
r0 += "Exception: " + ex.ToString();
}
if (synchronized) Ia.Ngn.Cl.Model.Data.Msmq.SecretaryApplication.SynchronizeCompleted(Ia.Ngn.Cl.Model.Business.Msmq.Application.ProvisionApplication, serviceRequestService.Service);
}
else r0 += "The service number " + service + " does not have eight digits and/or is not within allowed domain list.";
}
else r0 = "No numbers in service discrepancy and complementary service mismatch list. ";
result.AddSuccess(r0);
return result;
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
public static Ia.Cl.Model.Result ManageServiceRequestAdministrativeIssue(Ia.Ngn.Cl.Model.Client.Nokia.Ims nokiaIms, Ia.Ngn.Cl.Model.Client.Huawei.Ims huaweiIms)
{
string r2, r3;
Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Ont nddOnt;
Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor switchVendor;
var result = new Ia.Cl.Model.Result();
if (Ia.Ngn.Cl.Model.Business.Administration.ServiceSuspensionIsEnabled)
{
var programmedAccountingDisconnectionType = Ia.Ngn.Cl.Model.Business.ServiceRequestAdministrativeIssue.DisconnectionType.ProgrammedAccounting;
var programmedInternationalCallingDisconnectionType = Ia.Ngn.Cl.Model.Business.ServiceRequestAdministrativeIssue.DisconnectionType.ProgrammedInternationalCalling;
//var ontAccessIdToOntDictionary = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntAccessIdToOntDictionary;
var service = Ia.Ngn.Cl.Model.Business.Provision.ImsServiceMismatchBetweenServiceRequestAdministrativeIssueAndServiceServiceListItem(out int serviceRequestAdministrativeIssueQueueCount, out string progressCounterString);
var serviceType = Ia.Ngn.Cl.Model.Business.Service.ServiceType.ImsService;
var serviceId = Ia.Ngn.Cl.Model.Business.Service.ServiceToServiceId(service, serviceType);
if (!string.IsNullOrEmpty(service))
{
result.AddSuccess("service: " + service + " " + progressCounterString);
r2 = serviceId;
var service2 = Ia.Ngn.Cl.Model.Data.Service2.ReadByIdIncludeAccess(serviceId);
var serviceRequestService = Ia.Ngn.Cl.Model.Data.ServiceRequestService.ReadIncludeAccess(serviceId);
var serviceRequestAdministrativeIssue = Ia.Ngn.Cl.Model.Data.ServiceRequestAdministrativeIssue.Read(service, out _);
if (service2 != null)
{
switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(service);
if (service2.Access != null) nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(service2.Access.Id);
else if (serviceRequestService.Access != null) nddOnt = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.OntByOntAccessId(serviceRequestService.Access.Id);
else nddOnt = null;
if (nddOnt != null)
{
if (Ia.Ngn.Cl.Model.Business.Service.OltIsWithinAllowedToBeProvisionedOltList(nddOnt.Pon.PonGroup.Olt))
{
if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedRouterDomainListOrIsWithinSymbolDomainExceptionList(nddOnt, service))
{
var accessId = nddOnt.Access.Id;
result.AddSuccess("service: ");
if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia)
{
/*
if (nddOnt.Pon.PonGroup.Olt.IsSip == false) // if H.248
{
var gwId = Ia.Ngn.Cl.Model.Data.Nokia.AgcfGatewayRecord.GwIdFromIp(nddOnt.Ip);
if (gwId > 0)
{
if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedAccountingDisconnectionType && service2.ServiceSuspension == false) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignServiceSuspensionStateToServiceSubscriber(nokiaIms, service, nddOnt, true, out r2);
else if (serviceRequestAdministrativeIssue == null && service2.ServiceSuspension == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignServiceSuspensionStateToServiceSubscriber(nokiaIms, service, nddOnt, false, out r2);
else if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedInternationalCallingDisconnectionType && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, false, out r2);
else if (serviceRequestAdministrativeIssue == null && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == false) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, true, out r2);
else result.AddError("unrecognized serviceRequestAdministrativeIssue");
Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateAgcfGatewayRecordAndAgcfEndpointListAndSubPartyAndSubscriberAndServiceForGwId(nokiaIms, gwId, out r3);
result.AddSuccess(r2 + "," + r3);
}
else result.AddError("gwId is 0.");
}
else // if IsSip == true
{
if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedAccountingDisconnectionType && service2.ServiceSuspension == false) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignServiceSuspensionStateToServiceSubscriber(nokiaIms, service, nddOnt, true, out r2);
else if (serviceRequestAdministrativeIssue == null && service2.ServiceSuspension == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignServiceSuspensionStateToServiceSubscriber(nokiaIms, service, nddOnt, false, out r2);
else if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedInternationalCallingDisconnectionType && service2.InternationalCalling == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, false, out r2);
else if (serviceRequestAdministrativeIssue == null && service2.InternationalCalling == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, true, out r2);
else result.AddError("unrecognized serviceRequestAdministrativeIssue");
Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(nokiaIms, service, nddOnt, out r3);
result.AddSuccess(r2 + "," + r3);
}
*/
if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedAccountingDisconnectionType && service2.ServiceSuspension == false) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignServiceSuspensionStateToServiceSubscriber(nokiaIms, service, nddOnt, true, out r2);
else if (serviceRequestAdministrativeIssue == null && service2.ServiceSuspension == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignServiceSuspensionStateToServiceSubscriber(nokiaIms, service, nddOnt, false, out r2);
else if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedInternationalCallingDisconnectionType && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == true) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, false, out r2);
else if (serviceRequestAdministrativeIssue == null && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == false) Ia.Ngn.Cl.Model.Data.Nokia.Ims.AssignSupplementaryService(nokiaIms, service, nddOnt, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, true, out r2);
else result.AddError("unrecognized serviceRequestAdministrativeIssue");
Ia.Ngn.Cl.Model.Data.Nokia.Ims.ReadUpdateSubPartyAndSubscriberAndServiceForService(nokiaIms, service, nddOnt, out r3);
result.AddSuccess(r2 + "," + r3);
}
else if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
{
if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedAccountingDisconnectionType && service2.ServiceSuspension == false) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignServiceSuspensionStateToServiceSubscriber(huaweiIms, service, true, out r2);
else if (serviceRequestAdministrativeIssue == null && service2.ServiceSuspension == true) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignServiceSuspensionStateToServiceSubscriber(huaweiIms, service, false, out r2);
else if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedInternationalCallingDisconnectionType && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == true) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, false, out r2);
else if (serviceRequestAdministrativeIssue == null && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == false) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, true, out r2);
else result.AddError("unrecognized serviceRequestAdministrativeIssue.");
Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadSbrForService(huaweiIms, service, out r3);
result.AddSuccess(r2 + "," + r3);
}
else result.AddError("switchVendor is undefined.");
}
else result.AddError("service " + service + " is not within allowed router domain list for access " + nddOnt.Access.Name + ". To override restrictions contact department.");
}
else result.AddError("access is not in an allowed to be provisioned OLT.");
}
else
{
if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
{
if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedAccountingDisconnectionType && service2.ServiceSuspension == false) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignServiceSuspensionStateToServiceSubscriber(huaweiIms, service, true, out r2);
else if (serviceRequestAdministrativeIssue == null && service2.ServiceSuspension == true) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignServiceSuspensionStateToServiceSubscriber(huaweiIms, service, false, out r2);
else if (serviceRequestAdministrativeIssue != null && serviceRequestAdministrativeIssue.Type == (int)programmedInternationalCallingDisconnectionType && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == true) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, false, out r2);
else if (serviceRequestAdministrativeIssue == null && serviceRequestService.InternationalCalling == true && service2.InternationalCalling == false) Ia.Ngn.Cl.Model.Data.Huawei.Ims.AssignSupplementaryService(huaweiIms, service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService.InternationalCalling, true, out r2);
else result.AddError("unrecognized serviceRequestAdministrativeIssue.");
Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadSbrForService(huaweiIms, service, out r3);
result.AddSuccess(r2 + "," + r3);
}
else result.AddError("nddOnt is null and switchVendor is not Huawei.");
}
}
else result.AddError("service2 is null.");
}
else result.AddWarning("No numbers in service request administrative issue mismatch list.");
}
else result.AddWarning("service request administrative issue is disabled.");
return result;
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
public static Ia.Cl.Model.Result ManageMsmqQueue(Ia.Ngn.Cl.Model.Client.Nokia.Ims nokiaIms, Ia.Ngn.Cl.Model.Client.Huawei.Ims huaweiIms)
{
string r;
var result = new Ia.Cl.Model.Result();
var queueCount = Ia.Ngn.Cl.Model.Data.Msmq.ProvisionApplication.Count;
if (queueCount > 0)
{
var message = Ia.Ngn.Cl.Model.Data.Msmq.ProvisionApplication.Dequeue;
if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.ServiceRequestAndOrServiceRequestTypeUpdated)
{
if (Ia.Ngn.Cl.Model.Business.Administration.NowIsOfficialWorkingTime)
{
var r2 = Ia.Ngn.Cl.Model.Business.Provision.ManageServiceProvisioning(Ia.Ngn.Cl.Model.Business.Default.Procedure.InitializeOrIterate, nokiaIms, huaweiIms);
result.AddSuccess("Provision service: " + r2.MessageWithoutCaption);
}
else
{
}
}
else if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.Synchronize)
{
if (Ia.Ngn.Cl.Model.Business.Administration.NowIsOfficialWorkingTime)
{
var r2 = Ia.Ngn.Cl.Model.Business.Provision.ManageServiceProvisioning(Ia.Ngn.Cl.Model.Business.Default.Procedure.InitializeOrIterate, nokiaIms, huaweiIms);
result.AddSuccess("Provision (from sync) service: " + r2.MessageWithoutCaption);
}
else
{
}
}
else if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.CreateReadServiceAccessPort)
{
var service = message.Service;
var accessName = message.AccessName;
var port = (message.Port > 0) ? message.Port : Ia.Ngn.Cl.Model.Business.Default.PortUndefinedOrInvalidOrUnknown;
var overrideRouterDomainRestriction = message.OverrideRouterDomainRestriction;
var protocol = Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd;
Ia.Ngn.Cl.Model.Business.Provision.CreateReadService(nokiaIms, huaweiIms, accessName, service, port, protocol, overrideRouterDomainRestriction, out r);
result.AddSuccess("Create/Read: " + service + "|" + accessName + "|" + port + ": " + r);
}
else if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.DeleteReadServiceAccess)
{
var service = message.Service;
var accessName = message.AccessName;
var overrideRouterDomainRestriction = message.OverrideRouterDomainRestriction;
var protocol = Ia.Ngn.Cl.Model.Business.Default.Protocol.DefaultAsInNdd;
Ia.Ngn.Cl.Model.Business.Provision.DeleteReadService(nokiaIms, huaweiIms, accessName, service, protocol, overrideRouterDomainRestriction, out r);
result.AddSuccess("Delete/Read: " + service + "|" + accessName + ": " + r);
}
else if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.UpdateReadServiceSupplementaryService)
{
var service = message.Service;
var serviceSupplementaryService = message.ServiceSupplementaryService;
var serviceSupplementaryServiceState = message.ServiceSupplementaryServiceState;
Ia.Ngn.Cl.Model.Business.Provision.UpdateReadSupplementaryService(nokiaIms, huaweiIms, service, serviceSupplementaryService, serviceSupplementaryServiceState, out Ia.Cl.Model.Result r2);
result.AddSuccess("Set/Reset/Read Service Supplementary Service: " + service + ": " + r2.Message);
}
else if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.AccessCreated)
{
Ia.Ngn.Cl.Model.Data.Huawei.Default.AccessNameToMduDevDictionaryReset();
var result0 = Ia.Ngn.Cl.Model.Business.Nokia.Ims.CreateMissingAgcfGatewayRecordForNokiaSwitchOntInNonSipOlt(nokiaIms);
result.AddSuccess("Access created: AccessNameToMduDevDictionary reset. CreateMissingAgcfGatewayRecordForNokiaSwitchOntInNonSipOlt(): " + result0.Message);
}
else if (message.Process == Ia.Ngn.Cl.Model.Business.Msmq.Process.ServiceInServiceRequestAdministrativeIssuesUpdated)
{
var r1 = Ia.Ngn.Cl.Model.Business.Provision.ManageServiceRequestAdministrativeIssue(nokiaIms, huaweiIms);
result.AddResult("Manage Service Request Administrative Issue: ", r1);
}
else
{
throw new ArgumentOutOfRangeException("MSMQ process " + message.Process.ToString() + " is undefined");
}
}
return result;
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
public static Ia.Cl.Model.Result ManageAperiodicProcedure(Ia.Ngn.Cl.Model.Client.Nokia.Ims nokiaIms, Ia.Ngn.Cl.Model.Client.Huawei.Ims huaweiIms)
{
int aperiodicQueueCount;
string service;
var result = new Ia.Cl.Model.Result();
if (aperiodicQueue.Count == 0)
{
List<string> list;
using (var db = new Ia.Ngn.Cl.Model.Ngn())
{
list = (from s in db.Service2
where s.Service.StartsWith("24825") || s.Service.StartsWith("24826") || s.Service.StartsWith("24827") || s.Service.StartsWith("24828") || s.Service.StartsWith("24829")
select s.Service).ToList();
}
aperiodicQueue = new Queue<string>(list);
aperiodicQueueOriginalCount = aperiodicQueue.Count;
}
if (aperiodicQueue.Count > 0) service = aperiodicQueue.Dequeue();
else service = string.Empty;
if (!string.IsNullOrEmpty(service))
{
Ia.Ngn.Cl.Model.Data.Huawei.Ims.DeleteSubscriber(huaweiIms, service, out string deleteString);
Ia.Ngn.Cl.Model.Business.Huawei.Ims.ReadUpdateSbrAndServiceForService(huaweiIms, service, string.Empty, out string readString);
result.AddSuccess(service + " (" + aperiodicQueue.Count + "/" + aperiodicQueueOriginalCount + "): delete:" + deleteString + ", read:" + readString);
}
else
{
result.AddSuccess("service is null");
}
aperiodicQueueCount = aperiodicQueue.Count;
return result;
}
////////////////////////////////////////////////////////////////////////////
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
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)
{
if (!string.IsNullOrEmpty(service))
{
if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedNokiaSwitchDomainList(service))
{
if (!string.IsNullOrEmpty(accessName))
{
Ia.Ngn.Cl.Model.Business.Provision.CreateReadNokiaSwitchSubscriber(nokiaIms, accessName, service, port, protocol, overrideRouterDomainRestriction, out result);
}
else result = "Error: Can't create a Nokia service without an access. AccessName is null or empty. ";
}
else if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedHuaweiSwitchDomainList(service))
{
Ia.Ngn.Cl.Model.Business.Provision.CreateReadHuaweiSwitchSubscriber(huaweiIms, accessName, service, port, protocol, overrideRouterDomainRestriction, out result);
}
else result = "Error: service number does not belong to a valid vendor switch. ";
}
else result = "Error: service null or empty. ";
}
////////////////////////////////////////////////////////////////////////////
/// <summary>
///
/// </summary>
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)
{
bool b;
if (!string.IsNullOrEmpty(service))
{
if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedNokiaSwitchDomainList(service))
{
if (!string.IsNullOrEmpty(accessName))
{
b = Ia.Ngn.Cl.Model.Business.Provision.DeleteReadNokiaSwitchSubscriber(nokiaIms, accessName, service, protocol, overrideRouterDomainRestriction, out result);
}
else
{
b = Ia.Ngn.Cl.Model.Business.Provision.DeleteReadNokiaSwitchAgcfEndpointAndH248SubscriberFromAnyFsdb(nokiaIms, service, out result);
}
}
else if (Ia.Ngn.Cl.Model.Business.Service.NumberIsWithinAllowedHuaweiSwitchDomainList(service))
{
b = Ia.Ngn.Cl.Model.Business.Provision.DeleteReadHuaweiSwitchSubscriber(huaweiIms, accessName, service, protocol, overrideRouterDomainRestriction, out result);
}
else result = "Error: service number does not belong to a valid vendor switch. ";
}
else
{
result = "Error: service null or empty. ";
}
}
////////////////////////////////////////////////////////////////////////////
////////////////////////////////////////////////////////////////////////////
}
////////////////////////////////////////////////////////////////////////////
////////////////////////////////////////////////////////////////////////////
}