71 Commits

Author SHA1 Message Date
Gaurav Kumar
c5d730ae22 Update editnewdash.component.ts 2025-11-05 10:49:53 +05:30
Gaurav Kumar
40438fcc1b unified 2025-11-04 19:11:00 +05:30
Gaurav Kumar
71be18b21f unified 2025-11-04 18:47:53 +05:30
Gaurav Kumar
1263805d61 chart 2025-11-04 18:37:45 +05:30
Gaurav Kumar
0e6e4899e5 unifield 2025-11-04 17:41:18 +05:30
Gaurav Kumar
29e50253af edit new dash 2025-11-04 13:02:23 +05:30
Gaurav Kumar
68b793ea60 property 2025-11-04 11:55:49 +05:30
Gaurav Kumar
5f0594c93c dynamic field 2025-11-03 23:37:57 +05:30
Gaurav Kumar
e7ee226b66 chart type 2025-11-03 23:29:13 +05:30
Gaurav Kumar
ff2f5a1c34 hartc 2025-11-03 19:25:02 +05:30
Gaurav Kumar
fc36794b22 chart type 2025-11-03 18:19:58 +05:30
Gaurav Kumar
75ccca8caf config 2025-11-03 16:50:53 +05:30
Gaurav Kumar
c4dfb0283c new 2025-11-03 15:01:46 +05:30
Gaurav Kumar
57acdb0300 chart config 2025-11-03 12:52:53 +05:30
Gaurav Kumar
aee28f604f Update chart-type.service.ts 2025-11-03 10:48:55 +05:30
Gaurav Kumar
8375e53fdf service 2025-11-03 09:58:44 +05:30
Gaurav Kumar
db7a9c727d Update chart-type-manager.component.ts 2025-11-03 09:54:49 +05:30
Gaurav Kumar
6e91af551e routing 2025-11-03 09:06:52 +05:30
Gaurav Kumar
de5479cc07 chart 2025-11-03 09:06:04 +05:30
Gaurav Kumar
807058e40d chart 2025-11-01 16:20:59 +05:30
Gaurav Kumar
c6022b0e22 bar chart 2025-11-01 12:34:16 +05:30
Gaurav Kumar
9aed6e0d43 Update unified-chart.component.html 2025-11-01 12:18:01 +05:30
Gaurav Kumar
64b664e625 Update editnewdash.component.ts 2025-11-01 11:00:10 +05:30
Gaurav Kumar
49f1a2fbf2 Update unified-chart.component.ts 2025-11-01 10:54:41 +05:30
Gaurav Kumar
6bfe890cd9 Update editnewdash.component.ts 2025-11-01 10:03:00 +05:30
Gaurav Kumar
3e70f85644 dashboard 2025-10-31 17:19:18 +05:30
Gaurav Kumar
482805b5cf Update editnewdash.component.ts 2025-10-31 17:17:01 +05:30
Gaurav Kumar
ffda17e6b1 unified 2025-10-31 16:35:15 +05:30
Gaurav Kumar
7396843bc6 Update report-build2all.component.html 2025-10-31 16:03:37 +05:30
Gaurav Kumar
4f75ecb3e0 builder 2025-10-31 15:51:28 +05:30
Gaurav Kumar
7c1a487114 dashboard 2025-10-31 10:47:43 +05:30
Gaurav Kumar
47e9fb92e3 Update compact-filter.component.ts 2025-10-30 12:46:39 +05:30
Gaurav Kumar
7f735dcada Update editnewdash.component.ts 2025-10-30 12:29:22 +05:30
Gaurav Kumar
bd315f42a3 compact 2025-10-29 17:55:05 +05:30
Gaurav Kumar
e8c1f46430 Update editnewdash.component.html 2025-10-29 17:30:13 +05:30
Gaurav Kumar
fa96ca81bd runner 2025-10-29 17:18:26 +05:30
Gaurav Kumar
c384f44c0c doughnut 2025-10-29 17:01:50 +05:30
Gaurav Kumar
50df914ca9 pie 2025-10-29 16:52:45 +05:30
Gaurav Kumar
e0bd888c45 polr 2025-10-29 16:14:45 +05:30
Gaurav Kumar
02b82fcaf8 Update polar-chart.component.ts 2025-10-29 16:07:59 +05:30
Gaurav Kumar
557afc348f bubble 2025-10-29 15:55:01 +05:30
Gaurav Kumar
1dec787062 Update bubble-chart.component.ts 2025-10-29 15:50:08 +05:30
Gaurav Kumar
8853cf75cf Update bubble-chart.component.ts 2025-10-29 15:42:21 +05:30
Gaurav Kumar
ad57f11f8a bubble 2025-10-29 15:34:10 +05:30
Gaurav Kumar
9b775a8c63 fin 2025-10-29 12:59:20 +05:30
Gaurav Kumar
cf4fc1be93 todo 2025-10-29 12:21:24 +05:30
Gaurav Kumar
4c135c4901 to do 2025-10-29 12:16:54 +05:30
Gaurav Kumar
0b738ca7ca scatter 2025-10-29 11:35:09 +05:30
Gaurav Kumar
1b17bb706d scatter 2025-10-29 11:11:36 +05:30
Gaurav Kumar
f740076d60 bar chart 2025-10-28 17:04:02 +05:30
Gaurav Kumar
bedcc0822d chart 2025-10-28 16:31:45 +05:30
Gaurav Kumar
87810acc9e line 2025-10-28 15:41:36 +05:30
Gaurav Kumar
96b90e5dbd barchart 2025-10-28 15:32:37 +05:30
Gaurav Kumar
ced99e0940 grid view 2025-10-28 15:11:40 +05:30
Gaurav Kumar
4f82ae8698 grid view 2025-10-28 12:40:01 +05:30
Gaurav Kumar
e6779e8f34 filter 2025-10-28 12:29:10 +05:30
Gaurav Kumar
82425d5377 Update editnewdash.component.html 2025-10-28 12:13:15 +05:30
Gaurav Kumar
2995328ec1 compact filter 2025-10-27 20:36:22 +05:30
Gaurav Kumar
afc2c1f8a1 filter with runner 2025-10-27 20:12:22 +05:30
Gaurav Kumar
418b02acd7 checkbox multislect filter, in edit new dash 2025-10-27 19:02:47 +05:30
Gaurav Kumar
cdd752469c builder 2025-10-27 18:48:16 +05:30
Gaurav Kumar
cdcf1e07c7 Update compact-filter.component.ts 2025-10-25 21:57:10 +05:30
Gaurav Kumar
c6ad8b5c2f filter 2025-10-25 21:46:54 +05:30
Gaurav Kumar
98e0908920 sheild 2025-10-25 20:15:06 +05:30
Gaurav Kumar
8266bfdc01 dashboard 2025-10-25 20:08:04 +05:30
Gaurav Kumar
f2b6a4d145 dashboard 2025-10-25 19:28:03 +05:30
Gaurav Kumar
02f37a1bc5 shield 2025-10-25 17:55:46 +05:30
Gaurav Kumar
f24138cfbd shield dashboard 2025-10-25 16:15:16 +05:30
Gaurav Kumar
aade12d6ff filter 2025-10-25 15:02:26 +05:30
Gaurav Kumar
6c01e71d04 dashboard 2025-10-25 14:43:42 +05:30
Gaurav Kumar
f60657ca64 filter 2025-10-25 10:33:16 +05:30
20 changed files with 648 additions and 1712 deletions

View File

@@ -97,6 +97,7 @@ export class LoginPageComponent implements OnInit {
.subscribe( .subscribe(
resp => { resp => {
console.log('API Response received:', resp); console.log('API Response received:', resp);
// Always reset loading state when response is received
this.isLoading = false; this.isLoading = false;
// Handle different response formats // Handle different response formats
@@ -106,7 +107,7 @@ export class LoginPageComponent implements OnInit {
return; return;
} }
// Handle different response formats // Handle different response formats
if (resp.success === 'false') { if (resp.success === 'false' || resp.success === false) {
this.isError = true; this.isError = true;
this.errMsg = resp.message || 'Login failed'; this.errMsg = resp.message || 'Login failed';
return; return;
@@ -123,6 +124,7 @@ export class LoginPageComponent implements OnInit {
}, },
(errResponse: HttpErrorResponse) => { (errResponse: HttpErrorResponse) => {
console.log('API Error received:', errResponse); console.log('API Error received:', errResponse);
// Always reset loading state when error occurs
this.isLoading = false; this.isLoading = false;
this.isError = true; this.isError = true;

View File

@@ -71,19 +71,13 @@
Calculated Fields Calculated Fields
</ng-container></clr-dg-column> </ng-container></clr-dg-column>
<!-- Webhook Status Column -->
<clr-dg-column>
<ng-container *clrDgHideableColumn="{hidden: false}">
Webhook Status
</ng-container>
</clr-dg-column>
<!-- who column --> <!-- who column -->
<clr-dg-column> <clr-dg-column>
<ng-container *clrDgHideableColumn="{hidden: false}"> <ng-container *clrDgHideableColumn="{hidden: false}">
<clr-icon shape="bars"></clr-icon> Action <clr-icon shape="bars"></clr-icon> Action
</ng-container> </ng-container></clr-dg-column>
</clr-dg-column>
<!-- end --> <!-- end -->
<clr-dg-row *clrDgItems="let user of product" [clrDgItem]="user"> <clr-dg-row *clrDgItems="let user of product" [clrDgItem]="user">
@@ -110,7 +104,7 @@
<span <span
style="margin-right: 8px; overflow: hidden; text-overflow: ellipsis; white-space: nowrap; flex-grow: 1;" style="margin-right: 8px; overflow: hidden; text-overflow: ellipsis; white-space: nowrap; flex-grow: 1;"
title="{{user.url_endpoint}}" (click)="showFullUrl(user.url_endpoint)"> title="{{user.url_endpoint}}" (click)="showFullUrl(user.url_endpoint)">
{{user.url | slice:0:30}}{{user?.url_endpoint?.length > 30 ? '...' : ''}} {{user.url | slice:0:30}}{{user.url_endpoint.length > 30 ? '...' : ''}}
</span> </span>
<button class="btn btn-icon btn-sm" (click)="copyToClipboard(user.url_endpoint)" title="Copy URL"> <button class="btn btn-icon btn-sm" (click)="copyToClipboard(user.url_endpoint)" title="Copy URL">
<clr-icon shape="copy-to-clipboard"></clr-icon> <clr-icon shape="copy-to-clipboard"></clr-icon>
@@ -144,14 +138,11 @@
style="cursor: pointer; align-items: center;"><clr-icon shape="details" style="cursor: pointer; align-items: center;"><clr-icon shape="details"
*ngIf="user.calculated_field_json"></clr-icon></clr-dg-cell> *ngIf="user.calculated_field_json"></clr-icon></clr-dg-cell>
<!-- Webhook Status Cell -->
<clr-dg-cell>
<span *ngIf="user.webhook_url && user.webhook_url.trim() !== ''" class="webhook-enabled">Enabled</span>
<span *ngIf="!user.webhook_url || user.webhook_url.trim() === ''" class="webhook-disabled">Disabled</span>
</clr-dg-cell>
<!-- who column --> <!-- who column -->
<clr-dg-cell> <clr-dg-cell>
<div style="display: flex; align-items: center; gap: 1px; flex-wrap: nowrap;">
<clr-signpost> <clr-signpost>
<span style="cursor: pointer;" clrSignpostTrigger><clr-icon shape="help" class="success" <span style="cursor: pointer;" clrSignpostTrigger><clr-icon shape="help" class="success"
style="color: rgb(0, 130, 236);"></clr-icon></span> style="color: rgb(0, 130, 236);"></clr-icon></span>
@@ -166,47 +157,20 @@
</clr-signpost> </clr-signpost>
<!-- New JSON Update button --> <!-- New JSON Update button -->
<button class="btn btn-icon" (click)="updateJson(user.id)" title="Update JSON"> <button class="btn btn-icon btn-sm" (click)="updateJson(user.id)" title="Update JSON">
<clr-icon shape="refresh"></clr-icon> <clr-icon shape="refresh"></clr-icon>
</button> </button>
<!-- Calculated Field button --> <!-- Calculated Field button -->
<button class="btn btn-icon" (click)="fetchAvailableKeys(user)" title="Create Calculated Field"> <button class="btn btn-icon btn-sm" (click)="fetchAvailableKeys(user, false)" title="Create Calculated Field">
<clr-icon shape="calculator"></clr-icon> <clr-icon shape="calculator"></clr-icon>
</button> </button>
<!-- Group By button --> <!-- Group By button -->
<button class="btn btn-icon" (click)="openGroupByModal(user)" title="Group By Configuration"> <button class="btn btn-icon btn-sm" (click)="openGroupByModal(user)" title="Group By Configuration">
<clr-icon shape="group"></clr-icon> <clr-icon shape="group"></clr-icon>
</button> </button>
</div>
<!-- Blending Keys button (only shown for blending type with non-empty blending_lakeids) -->
<button class="btn btn-icon" (click)="fetchBlendingKeys(user)" title="Configure Blending Query"
*ngIf="canShowBlendingAction(user)">
<clr-icon shape="code"></clr-icon>
</button>
<!-- Field Mapping button -->
<button class="btn btn-icon" (click)="openFieldMappingModal(user)" title="Field Mapping"
*ngIf="user.url && user.sure_connect_id">
<clr-icon shape="map"></clr-icon>
</button>
<!-- Scheduler button -->
<button class="btn btn-icon" (click)="openSchedulerModal(user)" title="Scheduler">
<clr-icon shape="clock"></clr-icon>
</button>
<!-- Webhook toggle button -->
<button class="btn btn-icon" (click)="toggleWebhook(user)" title="Toggle Webhook">
<clr-icon shape="network-globe"></clr-icon>
</button>
<!-- Copy Webhook URL button -->
<button class="btn btn-icon" (click)="copyWebhookUrl(user.webhook_url)" title="Copy Webhook URL"
*ngIf="user.webhook_url && user.webhook_url.trim() !== ''">
<clr-icon shape="copy-to-clipboard"></clr-icon>
</button>
</clr-dg-cell> </clr-dg-cell>
<!-- who colmn --> <!-- who colmn -->
@@ -445,16 +409,16 @@
instanceId="edit-form-{{rowSelected.id}}"></app-cron-job-builder> instanceId="edit-form-{{rowSelected.id}}"></app-cron-job-builder>
</div> </div>
<!-- <div class="clr-col-sm-12"> <div class="clr-col-sm-12">
<label> json</label> <label> json</label>
<input id="name" type="Text" class="form-control" style="border: none; outline: none; height:33px !important;" <input id="name" type="Text" class="form-control" style="border: none; outline: none; height:33px !important;"
[(ngModel)]="rowSelected.json" name=" json " /> [(ngModel)]="rowSelected.json" name=" json " />
</div> </div>
<div class="clr-col-sm-12"> <div class="clr-col-sm-12">
<label>Url Endpoint</label> <label>Url</label>
<input class="clr-input" type="text" [(ngModel)]="rowSelected.url_endpoint" name="url_endpoint" /> <input class="clr-input" type="text" [(ngModel)]="rowSelected.url_endpoint" name="url_endpoint" />
</div> --> </div>
<div class="clr-col-sm-12"> <div class="clr-col-sm-12">
<label>Batch Volume</label> <label>Batch Volume</label>
@@ -470,30 +434,8 @@
</select> </select>
</div> </div>
<!-- Data Lake Type --> <!-- Add ref_datalake_id dropdown -->
<div class="clr-col-sm-12"> <div class="clr-col-sm-12">
<label>Data Lake Type</label>
<select class="clr-input" [(ngModel)]="rowSelected.datalake_type" name="datalake_type">
<option *ngFor="let type of dataLakeTypes" [value]="type.value">{{ type.label }}</option>
</select>
</div>
<!-- Blending Data Lakes (only show when blending type is selected) -->
<div class="clr-col-sm-12" *ngIf="rowSelected.datalake_type === 'blending'">
<label>Blending Data Lakes</label>
<div class="checkbox-container">
<div *ngFor="let dataLake of dataLakeList" class="checkbox-item">
<input type="checkbox" [value]="dataLake.id"
(change)="onEditBlendingLakeCheckboxChange($event, dataLake.id)"
[checked]="isEditBlendingLakeSelected(dataLake.id)">
<label>{{ dataLake.name }}</label>
</div>
</div>
<small class="clr-subtext">Select data lakes to blend</small>
</div>
<!-- Reference Data Lake (only show when normal type is selected) -->
<div class="clr-col-sm-12" *ngIf="rowSelected.datalake_type === 'normal'">
<label>Reference Data Lake</label> <label>Reference Data Lake</label>
<select class="clr-input" [(ngModel)]="rowSelected.ref_datalake_id" name="ref_datalake_id"> <select class="clr-input" [(ngModel)]="rowSelected.ref_datalake_id" name="ref_datalake_id">
<option value="">Select Data Lake</option> <option value="">Select Data Lake</option>
@@ -596,16 +538,16 @@
(cronExpressionChange)="onAddCronExpressionChange($event)" instanceId="add-form"></app-cron-job-builder> (cronExpressionChange)="onAddCronExpressionChange($event)" instanceId="add-form"></app-cron-job-builder>
</div> </div>
<!-- <div class="clr-col-sm-12"> <div class="clr-col-sm-12">
<label>json</label> <label>json</label>
<input class="form-control" type="Text" formControlName="json" <input class="form-control" type="Text" formControlName="json"
style="border: none; outline: none; height:33px !important;" /> style="border: none; outline: none; height:33px !important;" />
</div> --> </div>
<!-- <div class="clr-col-sm-12"> <div class="clr-col-sm-12">
<label> Url Endpoint</label> <label> Url Endpoint</label>
<input class="clr-input" type="text" formControlName="url_endpoint" /> <input class="clr-input" type="text" formControlName="url_endpoint" />
</div> --> </div>
<div class="clr-col-sm-12"> <div class="clr-col-sm-12">
<label> Batch Volume</label> <label> Batch Volume</label>
@@ -621,29 +563,8 @@
</select> </select>
</div> </div>
<!-- Data Lake Type --> <!-- Add ref_datalake_id dropdown -->
<div class="clr-col-sm-12"> <div class="clr-col-sm-12">
<label>Data Lake Type</label>
<select formControlName="datalake_type">
<option *ngFor="let type of dataLakeTypes" [value]="type.value">{{ type.label }}</option>
</select>
</div>
<!-- Blending Data Lakes (only show when blending type is selected) -->
<div class="clr-col-sm-12" *ngIf="entryForm.get('datalake_type')?.value === 'blending'">
<label>Blending Data Lakes</label>
<div class="checkbox-container">
<div *ngFor="let dataLake of dataLakeList" class="checkbox-item">
<input type="checkbox" [value]="dataLake.id" (change)="onBlendingLakeCheckboxChange($event, dataLake.id)"
[checked]="isBlendingLakeSelected(dataLake.id)">
<label>{{ dataLake.name }}</label>
</div>
</div>
<small class="clr-subtext">Select data lakes to blend</small>
</div>
<!-- Reference Data Lake (only show when normal type is selected) -->
<div class="clr-col-sm-12" *ngIf="entryForm.get('datalake_type')?.value === 'normal'">
<label>Reference Data Lake</label> <label>Reference Data Lake</label>
<select formControlName="ref_datalake_id"> <select formControlName="ref_datalake_id">
<option value="">Select Data Lake</option> <option value="">Select Data Lake</option>
@@ -995,195 +916,4 @@
</div> </div>
</clr-modal> </clr-modal>
<!-- Blending Keys Panel --> <!-- htmlpopup -->
<div class="blending-keys-panel" *ngIf="showBlendingKeys">
<div class="panel-header">
<h3>Blending Configuration</h3>
<button class="btn btn-icon" (click)="closeBlendingKeys()" title="Close">
<clr-icon shape="close"></clr-icon>
</button>
</div>
<div class="panel-content">
<!-- Display keys for each blending lake -->
<div class="keys-container" *ngFor="let keyData of blendingKeysData">
<h4>Data Lake {{ keyData.lakeId }} - Table: {{ keyData.tableName }}</h4>
<div class="headers-container">
<span class="header-tag" *ngFor="let header of keyData.headers">{{ header }}</span>
</div>
</div>
<!-- SQL Query Editor -->
<div class="sql-editor-container">
<h4>SQL Query Builder</h4>
<textarea class="clr-textarea sql-textarea" [(ngModel)]="sqlQueryText"
placeholder="Enter your SQL query here using the available headers..." rows="6"></textarea>
<div class="editor-actions">
<button class="btn btn-primary" (click)="updateSqlQuery()">Update SQL Query</button>
</div>
</div>
</div>
</div>
<!-- Blending Configuration Modal -->
<clr-modal [(clrModalOpen)]="showBlendingKeys" [clrModalSize]="'xl'" [clrModalStaticBackdrop]="true">
<h3 class="modal-title">Blending Configuration</h3>
<div class="modal-body">
<div class="blending-config-container">
<!-- Display keys for each blending lake -->
<div class="keys-section" *ngIf="blendingKeysData && blendingKeysData.length > 0">
<h4 class="section-title">
<clr-icon shape="data-field" class="section-icon"></clr-icon>
Available Data Sources
</h4>
<div class="keys-container">
<div class="key-card" *ngFor="let keyData of blendingKeysData">
<div class="key-header">
<h5>Data Lake {{ keyData.lakeId }} - Table: {{ keyData.tableName }}</h5>
</div>
<div class="headers-container">
<span class="header-tag" *ngFor="let header of keyData.headers" (click)="insertHeaderIntoQuery(header)">
{{ header }}
</span>
</div>
</div>
</div>
</div>
<!-- SQL Query Editor -->
<div class="sql-editor-section">
<h4 class="section-title">
<clr-icon shape="code" class="section-icon"></clr-icon>
SQL Query Builder
</h4>
<div class="sql-editor-container">
<textarea class="clr-textarea sql-textarea" [(ngModel)]="sqlQueryText"
placeholder="Enter your SQL query here using the available headers. Click on header names above to insert them into your query."
rows="8"></textarea>
<div class="editor-hint">
<small class="clr-subtext">Tip: Click on header names above to automatically insert them into your
query</small>
</div>
</div>
</div>
</div>
</div>
<div class="modal-footer">
<button type="button" class="btn btn-outline" (click)="closeBlendingKeys()">Cancel</button>
<button type="button" class="btn btn-primary" (click)="updateSqlQuery()">Update SQL Query</button>
</div>
</clr-modal>
<!-- Field Mapping Modal -->
<clr-modal [(clrModalOpen)]="showFieldMappingModal" [clrModalSize]="'lg'" [clrModalStaticBackdrop]="true">
<h3 class="modal-title">Field Mapping Configuration</h3>
<div class="modal-body">
<div class="field-mapping-container">
<div class="instructions">
<p>Map original field names to new names. Leave mapping blank to exclude field from mapping.</p>
</div>
<div class="mapping-table-container" *ngIf="fieldMappingData && fieldMappingData.length > 0">
<table class="table mapping-table">
<thead>
<tr>
<th width="50%">Original Field Name</th>
<th width="50%">Mapped Field Name</th>
</tr>
</thead>
<tbody>
<tr *ngFor="let field of fieldMappingData; let i = index">
<td class="original-field">
<span class="field-tag">{{ field.original }}</span>
</td>
<td>
<input type="text" class="clr-input mapping-input" [(ngModel)]="field.mapped"
placeholder="Enter new field name" (ngModelChange)="updateFieldMapping(i, $event)">
</td>
</tr>
</tbody>
</table>
</div>
<div class="no-data-message" *ngIf="fieldMappingData && fieldMappingData.length === 0">
<p>No fields available for mapping. Please check the data source configuration.</p>
</div>
</div>
</div>
<div class="modal-footer">
<button type="button" class="btn btn-outline" (click)="closeFieldMappingModal()">Cancel</button>
<button type="button" class="btn btn-primary" (click)="updateFieldMappings()"
[disabled]="!fieldMappingData || fieldMappingData.length === 0">Update Field Mappings</button>
</div>
</clr-modal>
<!-- Scheduler Modal -->
<clr-modal [(clrModalOpen)]="showSchedulerModal" [clrModalSize]="'md'" [clrModalStaticBackdrop]="true">
<h3 class="modal-title">Job Scheduler</h3>
<div class="modal-body">
<div class="scheduler-container">
<div class="data-lake-info">
<h4>Data Lake: {{ selectedSchedulerItem?.name }}</h4>
</div>
<!-- Job Information -->
<div class="job-info-section" *ngIf="schedulerJob">
<div class="job-header">
<h5>Job Information</h5>
<span class="badge" [ngClass]="getStatusBadgeClass(schedulerJob.status)">
{{ schedulerJob.status }}
</span>
</div>
<div class="job-details">
<div class="detail-row">
<label>Job Name:</label>
<span>{{ schedulerJob.name }}</span>
</div>
<div class="detail-row">
<label>Job Type:</label>
<span>{{ schedulerJob.jobType }}</span>
</div>
<div class="detail-row">
<label>Description:</label>
<span>{{ schedulerJob.description }}</span>
</div>
</div>
<!-- Job Actions -->
<div class="job-actions">
<button class="btn btn-warning" (click)="pauseJob()" *ngIf="schedulerJob.status === 'RUNNING'">
<clr-icon shape="pause"></clr-icon> Pause Job
</button>
<button class="btn btn-success" (click)="resumeJob()" *ngIf="schedulerJob.status === 'PAUSED'">
<clr-icon shape="play"></clr-icon> Resume Job
</button>
<button class="btn btn-danger" (click)="stopJob()" *ngIf="schedulerJob.status !== 'STOPPED'">
<clr-icon shape="stop"></clr-icon> Stop Job
</button>
<button class="btn btn-primary" (click)="restartJob()" *ngIf="schedulerJob.status === 'STOPPED'">
<clr-icon shape="play"></clr-icon> Restart Job
</button>
</div>
</div>
<!-- No Job Found -->
<div class="no-job-section" *ngIf="schedulerJob === null">
<div class="no-job-message">
<p>No scheduled job found for this Data Lake.</p>
<p>Would you like to create a new job?</p>
</div>
<div class="create-job-actions">
<button class="btn btn-primary" (click)="createJob()">
<clr-icon shape="plus"></clr-icon> Create Job
</button>
</div>
</div>
</div>
</div>
<div class="modal-footer">
<button type="button" class="btn btn-outline" (click)="closeSchedulerModal()">Close</button>
</div>
</clr-modal>

View File

@@ -384,494 +384,3 @@
border: 1px solid #ccc; border: 1px solid #ccc;
border-radius: 4px; border-radius: 4px;
} }
/* Data Lake Type Styles */
.clr-subtext {
display: block;
margin-top: 5px;
font-size: 12px;
color: #666;
}
[data-multiple] {
height: auto !important;
min-height: 80px;
}
/* Checkbox Styles for Blending Data Lakes */
.checkbox-container {
border: 1px solid #ccc;
border-radius: 4px;
padding: 10px;
max-height: 200px;
overflow-y: auto;
background-color: #f9f9f9;
}
.checkbox-item {
display: flex;
align-items: center;
margin-bottom: 8px;
}
.checkbox-item input[type="checkbox"] {
margin-right: 8px;
}
.checkbox-item label {
margin-bottom: 0;
cursor: pointer;
}
/* Blending Keys Panel Styles */
.blending-keys-panel {
position: fixed;
bottom: 0;
left: 0;
right: 0;
background-color: white;
border-top: 1px solid #ccc;
box-shadow: 0 -2px 4px rgba(0,0,0,0.1);
z-index: 1000;
max-height: 50vh;
overflow-y: auto;
}
.panel-header {
display: flex;
justify-content: space-between;
align-items: center;
padding: 15px;
border-bottom: 1px solid #eee;
background-color: #f5f5f5;
}
.panel-header h3 {
margin: 0;
color: #333;
}
.panel-content {
padding: 15px;
}
.keys-container {
margin-bottom: 20px;
padding: 10px;
border: 1px solid #eee;
border-radius: 4px;
background-color: #fafafa;
}
.keys-container h4 {
margin-top: 0;
color: #555;
}
.headers-container {
display: flex;
flex-wrap: wrap;
gap: 8px;
margin-top: 10px;
}
.header-tag {
display: inline-block;
background-color: #e3f2fd;
border: 1px solid #bbdefb;
border-radius: 12px;
padding: 4px 10px;
font-size: 12px;
font-family: monospace;
}
.sql-editor-container {
margin-top: 20px;
}
.sql-textarea {
width: 100%;
font-family: 'Courier New', monospace;
font-size: 14px;
}
.editor-actions {
margin-top: 10px;
text-align: right;
}
/* Blending Configuration Modal Styles */
.blending-config-container {
display: flex;
flex-direction: column;
gap: 20px;
}
.section-title {
color: #0072a0;
font-weight: 600;
margin-bottom: 15px;
display: flex;
align-items: center;
}
.section-icon {
margin-right: 10px;
}
.keys-section {
padding: 15px;
border-radius: 8px;
background-color: #f9f9f9;
box-shadow: 0 2px 4px rgba(0,0,0,0.05);
}
.key-card {
background-color: white;
border: 1px solid #e0e0e0;
border-radius: 6px;
padding: 15px;
margin-bottom: 15px;
box-shadow: 0 1px 3px rgba(0,0,0,0.1);
}
.key-header h5 {
margin: 0 0 10px 0;
color: #333;
font-weight: 500;
}
.headers-container {
display: flex;
flex-wrap: wrap;
gap: 8px;
}
.header-tag {
display: inline-flex;
align-items: center;
background-color: #e3f2fd;
border: 1px solid #bbdefb;
border-radius: 20px;
padding: 6px 12px;
margin: 4px;
font-size: 13px;
font-family: monospace;
cursor: pointer;
transition: all 0.2s;
}
.header-tag:hover {
background-color: #bbdefb;
transform: translateY(-2px);
box-shadow: 0 2px 4px rgba(0,0,0,0.1);
}
.sql-editor-section {
padding: 15px;
border-radius: 8px;
background-color: #f9f9f9;
box-shadow: 0 2px 4px rgba(0,0,0,0.05);
}
.sql-editor-container {
background-color: white;
border: 1px solid #e0e0e0;
border-radius: 6px;
padding: 15px;
}
.sql-textarea {
width: 100%;
font-family: 'Courier New', monospace;
font-size: 14px;
min-height: 150px;
}
.editor-hint {
margin-top: 10px;
}
.modal-footer {
display: flex;
justify-content: flex-end;
gap: 10px;
padding: 15px;
border-top: 1px solid #eee;
}
/* Field Mapping Modal Styles */
.field-mapping-container {
padding: 10px;
}
.instructions {
background-color: #e3f2fd;
border: 1px solid #bbdefb;
border-radius: 4px;
padding: 15px;
margin-bottom: 20px;
}
.instructions p {
margin: 0;
color: #1976d2;
}
.mapping-table-container {
overflow-x: auto;
}
.mapping-table {
width: 100%;
border-collapse: collapse;
}
.mapping-table th {
background-color: #f5f5f5;
padding: 12px 15px;
text-align: left;
font-weight: 600;
color: #333;
border-bottom: 2px solid #ddd;
}
.mapping-table td {
padding: 12px 15px;
border-bottom: 1px solid #eee;
}
.original-field {
vertical-align: middle;
}
.field-tag {
display: inline-block;
background-color: #e0e0e0;
border: 1px solid #bdbdbd;
border-radius: 4px;
padding: 6px 10px;
font-family: monospace;
font-size: 13px;
}
.mapping-input {
width: 100%;
padding: 8px 12px;
border: 1px solid #ccc;
border-radius: 4px;
font-size: 14px;
}
.mapping-input:focus {
outline: none;
border-color: #0072a0;
box-shadow: 0 0 0 2px rgba(0, 114, 160, 0.2);
}
.no-data-message {
text-align: center;
padding: 30px;
color: #666;
font-style: italic;
}
.modal-footer {
display: flex;
justify-content: flex-end;
gap: 10px;
padding: 15px;
border-top: 1px solid #eee;
}
/* Scheduler Modal Styles */
.scheduler-container {
padding: 10px;
}
.data-lake-info h4 {
margin: 0 0 20px 0;
color: #333;
border-bottom: 1px solid #eee;
padding-bottom: 10px;
}
.job-info-section {
background-color: #f9f9f9;
border: 1px solid #e0e0e0;
border-radius: 6px;
padding: 20px;
margin-bottom: 20px;
}
.job-header {
display: flex;
justify-content: space-between;
align-items: center;
margin-bottom: 15px;
}
.job-header h5 {
margin: 0;
color: #333;
}
.badge {
padding: 5px 10px;
border-radius: 12px;
font-size: 12px;
font-weight: bold;
}
.badge-success {
background-color: #4caf50;
color: white;
}
.badge-warning {
background-color: #ff9800;
color: white;
}
.badge-danger {
background-color: #f44336;
color: white;
}
.badge-light {
background-color: #e0e0e0;
color: #333;
}
.job-details {
margin-bottom: 20px;
}
.detail-row {
display: flex;
margin-bottom: 10px;
}
.detail-row label {
font-weight: 500;
width: 120px;
color: #555;
}
.detail-row span {
flex: 1;
}
.job-actions {
display: flex;
gap: 10px;
flex-wrap: wrap;
}
.job-actions .btn {
display: flex;
align-items: center;
gap: 5px;
}
.no-job-section {
text-align: center;
padding: 30px 20px;
}
.no-job-message p {
margin: 10px 0;
color: #666;
}
.no-job-message p:first-child {
font-size: 18px;
color: #333;
}
.create-job-actions {
margin-top: 20px;
}
.create-job-actions .btn {
display: inline-flex;
align-items: center;
gap: 5px;
}
.modal-footer {
display: flex;
justify-content: flex-end;
gap: 10px;
padding: 15px;
border-top: 1px solid #eee;
}
/* Webhook Status Styles */
.webhook-enabled {
display: inline-block;
padding: 4px 8px;
border-radius: 12px;
font-size: 12px;
font-weight: bold;
background-color: #4caf50;
color: white;
}
.webhook-disabled {
display: inline-block;
padding: 4px 8px;
border-radius: 12px;
font-size: 12px;
font-weight: bold;
background-color: #f44336;
color: white;
}
/* Webhook Status Styles */
.webhook-status {
display: inline-block;
padding: 4px 8px;
border-radius: 12px;
font-size: 12px;
font-weight: bold;
}
.webhook-status.enabled {
background-color: #4caf50;
color: white;
}
.webhook-status.disabled {
background-color: #f44336;
color: white;
}
/* Webhook Modal Styles */
.webhook-container {
padding: 10px;
}
.webhook-container .data-lake-info h4 {
margin: 0 0 20px 0;
color: #333;
border-bottom: 1px solid #eee;
padding-bottom: 10px;
}
.webhook-form {
margin-bottom: 20px;
}
.webhook-info {
background-color: #e3f2fd;
border: 1px solid #bbdefb;
border-radius: 4px;
padding: 15px;
margin-top: 20px;
}
.webhook-info p {
margin: 0;
color: #1976d2;
}

View File

@@ -2,7 +2,6 @@ import { Component, OnInit } from '@angular/core';
import { ToastrService } from 'ngx-toastr'; import { ToastrService } from 'ngx-toastr';
import { AlertService } from 'src/app/services/alert.service'; import { AlertService } from 'src/app/services/alert.service';
import { Data_lakeservice } from './Data_lake.service'; import { Data_lakeservice } from './Data_lake.service';
import { SchedulerService } from 'src/app/services/scheduler.service';
import { AbstractControl, FormArray, FormBuilder, FormGroup, Validators, ValidationErrors } from '@angular/forms'; import { AbstractControl, FormArray, FormBuilder, FormGroup, Validators, ValidationErrors } from '@angular/forms';
import { ExtensionService } from 'src/app/services/fnd/extension.service'; import { ExtensionService } from 'src/app/services/fnd/extension.service';
import { DashboardContentModel2 } from 'src/app/models/builder/dashboard'; import { DashboardContentModel2 } from 'src/app/models/builder/dashboard';
@@ -11,7 +10,6 @@ import { UserInfoService } from 'src/app/services/user-info.service';
import { SureconnectService } from '../sureconnect/sureconnect.service'; import { SureconnectService } from '../sureconnect/sureconnect.service';
import { HttpClient } from '@angular/common/http'; import { HttpClient } from '@angular/common/http';
import { ApiRequestService } from 'src/app/services/api/api-request.service'; import { ApiRequestService } from 'src/app/services/api/api-request.service';
import { DataLakeSchedulerService } from './dataLakescheduler.service';
declare var JsBarcode: any; declare var JsBarcode: any;
@Component({ @Component({
selector: 'app-Data_lake', selector: 'app-Data_lake',
@@ -68,12 +66,6 @@ export class Data_lakeComponent implements OnInit {
dataLakeList: any[] = []; dataLakeList: any[] = [];
selectedDataLake: any = null; selectedDataLake: any = null;
// New properties for data lake type
dataLakeTypes = [
{ value: 'normal', label: 'Normal' },
{ value: 'blending', label: 'Blending' }
];
// Calculated field properties // Calculated field properties
calculatedFieldModalOpen = false; calculatedFieldModalOpen = false;
availableKeys: string[] = []; availableKeys: string[] = [];
@@ -107,36 +99,10 @@ export class Data_lakeComponent implements OnInit {
selectedAggregationFields: { field: string; operation: string }[] = []; selectedAggregationFields: { field: string; operation: string }[] = [];
// New property to store selected blending lake IDs as string
selectedBlendingLakeIds: string[] = [];
editSelectedBlendingLakeIds: string[] = [];
// New properties for blending functionality
showBlendingKeys = false;
blendingKeysData: any[] = [];
sqlQueryText = '';
selectedBlendingItem: any = null;
// New properties for field mapping
showFieldMappingModal = false;
fieldMappingData: any[] = [];
fieldMappings: { [key: string]: string } = {};
selectedMappingItem: any = null;
// New properties for scheduler functionality
showSchedulerModal = false;
schedulerJob: any = null;
selectedSchedulerItem: any = null;
// New properties for webhook functionality
showWebhookModal = false;
selectedWebhookItem: any = null;
constructor( constructor(
private extensionService: ExtensionService, private extensionService: ExtensionService,
private userInfoService: UserInfoService, private userInfoService: UserInfoService,
private mainService: Data_lakeservice, private mainService: Data_lakeservice,
private schedulerService: DataLakeSchedulerService,
private alertService: AlertService, private alertService: AlertService,
private toastr: ToastrService, private toastr: ToastrService,
private _fb: FormBuilder, private _fb: FormBuilder,
@@ -158,25 +124,23 @@ export class Data_lakeComponent implements OnInit {
this.getDataLakeList(); // Fetch Data Lake list for reference dropdown this.getDataLakeList(); // Fetch Data Lake list for reference dropdown
this.entryForm = this._fb.group({ this.entryForm = this._fb.group({
name: [null], name: [null],
url: [null], url: [null],
schedule: [null], schedule: [null],
cron_job: [null], cron_job: [null],
json: [null], json: [null],
url_endpoint: [null], url_endpoint: [null],
batch_volume: [null], batch_volume: [null],
sure_connect_id: [null],
ref_datalake_id: [null],
datalake_type: ['normal'], // Default to normal
blending_lakeids: [[]], // Array for multiple selections
webhook_url: [null] // Add webhook_url field
});
// Set default SureConnect value after form initialization if list is already loaded sure_connect_id: [null], // Add SureConnect field
if (this.sureConnectList && this.sureConnectList.length > 0) { ref_datalake_id: [null], // Add Data Lake reference field
const defaultSureConnectId = this.sureConnectList[0].id;
this.entryForm.get('sure_connect_id')?.setValue(defaultSureConnectId);
}
}); // component_button200
// form code start // form code start
this.extensionService.getJsonObjectsByFormCodeList(this.formcode).subscribe(data => { this.extensionService.getJsonObjectsByFormCodeList(this.formcode).subscribe(data => {
console.log(data); console.log(data);
@@ -268,20 +232,6 @@ export class Data_lakeComponent implements OnInit {
this.sureConnectService.getAll().subscribe((data: any[]) => { this.sureConnectService.getAll().subscribe((data: any[]) => {
this.sureConnectList = data; this.sureConnectList = data;
console.log('SureConnect List:', this.sureConnectList); console.log('SureConnect List:', this.sureConnectList);
// Set default SureConnect value if list is not empty
if (this.sureConnectList && this.sureConnectList.length > 0) {
// Set the first SureConnect item as default
const defaultSureConnectId = this.sureConnectList[0].id;
// Set default for ADD form if it exists
if (this.entryForm && this.entryForm.get('sure_connect_id')) {
// Only set default if no value is already selected
if (!this.entryForm.get('sure_connect_id')?.value) {
this.entryForm.get('sure_connect_id')?.setValue(defaultSureConnectId);
}
}
}
}, (error) => { }, (error) => {
console.log('Error fetching SureConnect list:', error); console.log('Error fetching SureConnect list:', error);
}); });
@@ -290,7 +240,8 @@ export class Data_lakeComponent implements OnInit {
// Fetch Data Lake list for reference dropdown // Fetch Data Lake list for reference dropdown
getDataLakeList() { getDataLakeList() {
this.mainService.getAll().subscribe((data: any[]) => { this.mainService.getAll().subscribe((data: any[]) => {
this.dataLakeList = data; // Filter out the current item to avoid self-reference
this.dataLakeList = data.filter(item => item.id !== (this.rowSelected?.id || 0));
console.log('Data Lake List:', this.dataLakeList); console.log('Data Lake List:', this.dataLakeList);
}, (error) => { }, (error) => {
console.log('Error fetching Data Lake list:', error); console.log('Error fetching Data Lake list:', error);
@@ -735,22 +686,8 @@ export class Data_lakeComponent implements OnInit {
this.editCronExpression = row.cron_job || ''; this.editCronExpression = row.cron_job || '';
// Set the selected SureConnect for edit form // Set the selected SureConnect for edit form
this.selectedSureConnect = row.sure_connect_id || null; this.selectedSureConnect = row.sure_connect_id || null;
// Set the selected Data Lake for edit form
// If no SureConnect is selected, set the first one as default this.selectedDataLake = row.ref_datalake_id || null;
if (!this.rowSelected.sure_connect_id && this.sureConnectList && this.sureConnectList.length > 0) {
this.rowSelected.sure_connect_id = this.sureConnectList[0].id;
this.selectedSureConnect = this.sureConnectList[0].id;
}
// Initialize blending lake IDs for edit form from string
if (row.blending_lakeids && typeof row.blending_lakeids === 'string') {
this.editSelectedBlendingLakeIds = row.blending_lakeids.split(',').filter(id => id.trim() !== '');
} else if (row.blending_lakeids && Array.isArray(row.blending_lakeids)) {
this.editSelectedBlendingLakeIds = row.blending_lakeids.map(id => id.toString());
} else {
this.editSelectedBlendingLakeIds = [];
}
// Use setTimeout to ensure the component has time to initialize // Use setTimeout to ensure the component has time to initialize
setTimeout(() => { setTimeout(() => {
this.modalEdit = true; this.modalEdit = true;
@@ -901,33 +838,18 @@ export class Data_lakeComponent implements OnInit {
} }
goToAdd(row) { goToAdd(row) {
this.modalAdd = false; this.modalAdd = true;
this.addCronExpression = ''; this.addCronExpression = '';
this.selectedSureConnect = null; // Reset SureConnect selection this.selectedSureConnect = null; // Reset SureConnect selection
this.selectedDataLake = null; // Reset Data Lake selection
this.submitted = false; this.submitted = false;
// Reset blending lake IDs for add form
this.selectedBlendingLakeIds = [];
// Reset the form control for cron_job and sure_connect_id // Reset the form control for cron_job and sure_connect_id
if (this.entryForm) { if (this.entryForm) {
if (this.entryForm.get('cron_job')) { if (this.entryForm.get('cron_job')) {
this.entryForm.get('cron_job')?.setValue(''); this.entryForm.get('cron_job')?.setValue('');
} }
// Reset blending_lakeids to empty string
this.entryForm.get('blending_lakeids')?.setValue('');
// Set default SureConnect value if available
if (this.sureConnectList && this.sureConnectList.length > 0) {
const defaultSureConnectId = this.sureConnectList[0].id;
// Only set default if no value is already selected
if (!this.entryForm.get('sure_connect_id')?.value) {
this.entryForm.get('sure_connect_id')?.setValue(defaultSureConnectId);
} }
} else {
this.entryForm.get('sure_connect_id')?.setValue('');
}
}
this.modalAdd = true;
} }
submitted = false; submitted = false;
onSubmit() { onSubmit() {
@@ -1368,433 +1290,4 @@ export class Data_lakeComponent implements OnInit {
return []; return [];
} }
} }
// Method to check if blending action should be available
canShowBlendingAction(item: any): boolean {
return item.datalake_type === 'blending' &&
item.blending_lakeids &&
item.blending_lakeids.trim() !== '';
}
// Method to insert header into SQL query at cursor position
insertHeaderIntoQuery(header: string) {
const textarea = document.querySelector('.sql-textarea') as HTMLTextAreaElement;
if (textarea) {
const start = textarea.selectionStart;
const end = textarea.selectionEnd;
const text = textarea.value;
const before = text.substring(0, start);
const after = text.substring(end, text.length);
// Insert the header at cursor position
this.sqlQueryText = before + header + after;
// Set cursor position after the inserted text
setTimeout(() => {
textarea.selectionStart = start + header.length;
textarea.selectionEnd = start + header.length;
textarea.focus();
}, 0);
} else {
// Fallback: append to end of text
this.sqlQueryText += header;
}
}
// Method to fetch blending keys
fetchBlendingKeys(item: any) {
this.selectedBlendingItem = item;
this.blendingKeysData = [];
this.showBlendingKeys = true;
// Initialize SQL query text from existing data
if (item.sqlquery_json) {
this.sqlQueryText = item.sqlquery_json;
} else {
this.sqlQueryText = '';
}
// Parse blending_lakeids string to array
const lakeIds = item.blending_lakeids.split(',').map(id => id.trim()).filter(id => id !== '');
// Fetch keys for each lake ID
lakeIds.forEach(lakeId => {
this.mainService.fetchBlendingKeys(Number(lakeId)).subscribe(
(data: any) => {
this.blendingKeysData.push({
lakeId: lakeId,
tableName: data.tableName,
headers: data.headers
});
},
(error) => {
console.error('Error fetching keys for lake ID:', lakeId, error);
this.toastr.error(`Failed to fetch keys for Data Lake ${lakeId}`);
}
);
});
}
// Method to update SQL query
updateSqlQuery() {
if (!this.selectedBlendingItem) {
this.toastr.error('No blending item selected');
return;
}
// Update the SQL query JSON field
this.selectedBlendingItem.sqlquery_json = this.sqlQueryText;
// Call update service
this.mainService.update(this.selectedBlendingItem.id, this.selectedBlendingItem).subscribe(
(response) => {
this.toastr.success('SQL query updated successfully');
// Update the local data
const index = this.product.findIndex(p => p.id === this.selectedBlendingItem.id);
if (index !== -1) {
this.product[index] = {...this.selectedBlendingItem};
}
},
(error) => {
console.error('Error updating SQL query:', error);
this.toastr.error('Failed to update SQL query');
}
);
}
// Method to close blending keys panel
closeBlendingKeys() {
this.showBlendingKeys = false;
this.blendingKeysData = [];
this.sqlQueryText = '';
this.selectedBlendingItem = null;
}
// Method to handle checkbox change for blending lakes (ADD form)
onBlendingLakeCheckboxChange(event: any, lakeId: number) {
const lakeIdStr = lakeId.toString();
if (event.target.checked) {
// Add to selected blending lake IDs
if (!this.selectedBlendingLakeIds.includes(lakeIdStr)) {
this.selectedBlendingLakeIds.push(lakeIdStr);
}
} else {
// Remove from selected blending lake IDs
const index = this.selectedBlendingLakeIds.indexOf(lakeIdStr);
if (index > -1) {
this.selectedBlendingLakeIds.splice(index, 1);
}
}
// Update the form control value as a comma-separated string
this.entryForm.get('blending_lakeids')?.setValue(this.selectedBlendingLakeIds.join(','));
}
// Method to check if a blending lake is selected (ADD form)
isBlendingLakeSelected(lakeId: number): boolean {
return this.selectedBlendingLakeIds.includes(lakeId.toString());
}
// Method to handle checkbox change for blending lakes (EDIT form)
onEditBlendingLakeCheckboxChange(event: any, lakeId: number) {
const lakeIdStr = lakeId.toString();
if (event.target.checked) {
// Add to selected blending lake IDs
if (!this.editSelectedBlendingLakeIds.includes(lakeIdStr)) {
this.editSelectedBlendingLakeIds.push(lakeIdStr);
}
} else {
// Remove from selected blending lake IDs
const index = this.editSelectedBlendingLakeIds.indexOf(lakeIdStr);
if (index > -1) {
this.editSelectedBlendingLakeIds.splice(index, 1);
}
}
// Update the rowSelected value as a comma-separated string
this.rowSelected.blending_lakeids = this.editSelectedBlendingLakeIds.join(',');
}
// Method to check if a blending lake is selected (EDIT form)
isEditBlendingLakeSelected(lakeId: number): boolean {
return this.editSelectedBlendingLakeIds.includes(lakeId.toString());
}
// Method to open field mapping modal
openFieldMappingModal(item: any) {
this.selectedMappingItem = item;
this.fieldMappingData = [];
this.fieldMappings = {};
this.showFieldMappingModal = true;
// Fetch available keys using the same API as calculated fields
this.mainService.fetchAvailableKeys(item.url, item.sure_connect_id).subscribe(
(keys: string[]) => {
// Initialize field mappings with empty values
this.fieldMappingData = keys.map(key => ({
original: key,
mapped: ''
}));
// If there's existing mapping data, populate it
if (item.mapping_json) {
try {
const existingMappings = JSON.parse(item.mapping_json);
this.fieldMappingData.forEach(field => {
if (existingMappings[field.original]) {
field.mapped = existingMappings[field.original];
}
});
} catch (e) {
console.error('Error parsing existing mapping JSON:', e);
}
}
},
(error) => {
console.error('Error fetching keys for field mapping:', error);
this.toastr.error('Failed to fetch available keys for field mapping');
}
);
}
// Method to update field mappings
updateFieldMappings() {
if (!this.selectedMappingItem) {
this.toastr.error('No item selected for mapping');
return;
}
// Create mapping object
const mappings: { [key: string]: string } = {};
this.fieldMappingData.forEach(field => {
if (field.mapped && field.mapped.trim() !== '') {
mappings[field.original] = field.mapped.trim();
}
});
// Convert to JSON string
const mappingJson = JSON.stringify(mappings);
// Update the mapping JSON field
this.selectedMappingItem.mapping_json = mappingJson;
// Call update service
this.mainService.update(this.selectedMappingItem.id, this.selectedMappingItem).subscribe(
(response) => {
this.toastr.success('Field mappings updated successfully');
// Update the local data
const index = this.product.findIndex(p => p.id === this.selectedMappingItem.id);
if (index !== -1) {
this.product[index] = {...this.selectedMappingItem};
}
this.closeFieldMappingModal();
},
(error) => {
console.error('Error updating field mappings:', error);
this.toastr.error('Failed to update field mappings');
}
);
}
// Method to close field mapping modal
closeFieldMappingModal() {
this.showFieldMappingModal = false;
this.fieldMappingData = [];
this.fieldMappings = {};
this.selectedMappingItem = null;
}
// Method to update individual field mapping
updateFieldMapping(index: number, value: string) {
if (index >= 0 && index < this.fieldMappingData.length) {
this.fieldMappingData[index].mapped = value;
}
}
// Method to open scheduler modal
openSchedulerModal(item: any) {
this.selectedSchedulerItem = item;
this.schedulerJob = null;
this.showSchedulerModal = true;
// Fetch job by lake ID
this.schedulerService.getJobByLakeId(item.id).subscribe(
(job: any) => {
this.schedulerJob = job;
},
(error) => {
// If job not found, it's expected - we'll show create option
if (error.status === 404) {
this.schedulerJob = null;
} else {
console.error('Error fetching scheduler job:', error);
this.toastr.error('Failed to fetch scheduler job information');
}
}
);
}
// Method to create a new job
createJob() {
if (!this.selectedSchedulerItem) {
this.toastr.error('No data lake selected');
return;
}
const jobData = {
name: this.selectedSchedulerItem.name,
status: 'RUNNING',
description: `Scheduled job for ${this.selectedSchedulerItem.name}`,
jobType: 'DATALAKE',
lakeid: this.selectedSchedulerItem.id
};
this.schedulerService.createJob(jobData).subscribe(
(job: any) => {
this.schedulerJob = job;
this.toastr.success('Job created successfully');
},
(error) => {
console.error('Error creating job:', error);
this.toastr.error('Failed to create job');
}
);
}
// Method to pause a job
pauseJob() {
if (!this.schedulerJob || !this.schedulerJob.id) {
this.toastr.error('No job selected');
return;
}
this.schedulerService.pauseJob(this.schedulerJob.id).subscribe(
(response: any) => {
this.schedulerJob.status = 'PAUSED';
this.toastr.success('Job paused successfully');
},
(error) => {
console.error('Error pausing job:', error);
this.toastr.error('Failed to pause job');
}
);
}
// Method to resume a job
resumeJob() {
if (!this.schedulerJob || !this.schedulerJob.id) {
this.toastr.error('No job selected');
return;
}
this.schedulerService.resumeJob(this.schedulerJob.id).subscribe(
(response: any) => {
this.schedulerJob.status = 'RUNNING';
this.toastr.success('Job resumed successfully');
},
(error) => {
console.error('Error resuming job:', error);
this.toastr.error('Failed to resume job');
}
);
}
// Method to stop a job
stopJob() {
if (!this.schedulerJob || !this.schedulerJob.id) {
this.toastr.error('No job selected');
return;
}
this.schedulerService.stopJob(this.schedulerJob.id).subscribe(
(response: any) => {
this.schedulerJob.status = 'STOPPED';
this.toastr.success('Job stopped successfully');
},
(error) => {
console.error('Error stopping job:', error);
this.toastr.error('Failed to stop job');
}
);
}
// Method to restart a stopped job
restartJob() {
if (!this.schedulerJob || !this.schedulerJob.id) {
this.toastr.error('No job selected');
return;
}
// To restart a job, we need to create a new job with the same parameters
const jobData = {
name: this.schedulerJob.name,
status: 'RUNNING',
description: this.schedulerJob.description,
jobType: this.schedulerJob.jobType,
lakeid: this.schedulerJob.lakeid
};
this.schedulerService.createJob(jobData).subscribe(
(job: any) => {
this.schedulerJob = job;
this.toastr.success('Job restarted successfully');
},
(error) => {
console.error('Error restarting job:', error);
this.toastr.error('Failed to restart job');
}
);
}
// Method to close scheduler modal
closeSchedulerModal() {
this.showSchedulerModal = false;
this.schedulerJob = null;
this.selectedSchedulerItem = null;
}
// Method to get status badge class
getStatusBadgeClass(status: string): string {
switch (status) {
case 'RUNNING':
return 'badge-success';
case 'PAUSED':
return 'badge-warning';
case 'STOPPED':
return 'badge-danger';
default:
return 'badge-light';
}
}
// Method to toggle webhook for a data lake item
toggleWebhook(item: any) {
// Call the enableWebhook service method
this.mainService.enableWebhook(item.id).subscribe(
(updatedItem: any) => {
// Update the local data with the response from the server
const index = this.product.findIndex(p => p.id === item.id);
if (index !== -1) {
this.product[index] = {...updatedItem};
}
// Show success message based on the new webhook status
if (updatedItem.webhook_url && updatedItem.webhook_url.trim() !== '') {
this.toastr.success('Webhook enabled successfully');
} else {
this.toastr.success('Webhook disabled successfully');
}
},
(error) => {
console.error('Error toggling webhook:', error);
this.toastr.error('Failed to toggle webhook');
}
);
}
// Method to copy webhook URL to clipboard
copyWebhookUrl(webhookUrl: string) {
this.copyToClipboard(webhookUrl);
}
} }

View File

@@ -42,12 +42,6 @@ export class Data_lakeservice{
return this.apiRequest.get(apiUrl); return this.apiRequest.get(apiUrl);
} }
// Method to fetch blending keys for a specific lake ID
fetchBlendingKeys(lakeId: number): Observable<any> {
const _http = `${this.baseURL}/keys/${lakeId}`;
return this.apiRequest.get(_http);
}
// Method to update calculated fields for a data lake item // Method to update calculated fields for a data lake item
updateCalculatedFields(id: number, calculatedFieldJson: string, isCalculatedField: boolean): Observable<any> { updateCalculatedFields(id: number, calculatedFieldJson: string, isCalculatedField: boolean): Observable<any> {
const _http = this.baseURL + "/" + id; const _http = this.baseURL + "/" + id;
@@ -57,11 +51,5 @@ export class Data_lakeservice{
}; };
return this.apiRequest.put(_http, data); return this.apiRequest.put(_http, data);
} }
// Method to enable webhook for a data lake item
enableWebhook(id: number): Observable<any> {
const _http = `${this.baseURL}/webhook/${id}`;
return this.apiRequest.get(_http);
}
// updateaction // updateaction
} }

View File

@@ -1,15 +1,6 @@
<div class="cron-job-builder"> <div class="cron-job-builder">
<h4>Cron Job Builder</h4> <h4>Cron Job Builder</h4>
<div class="clr-row"> <div class="clr-row">
<div class="clr-col-lg-2 clr-col-md-4 clr-col-sm-6 clr-col-12">
<div class="form-group">
<label>Second</label>
<select class="form-control" [(ngModel)]="second" (change)="onFieldChange()">
<option *ngFor="let option of secondOptions" [value]="option.value">{{ option.label }}</option>
</select>
</div>
</div>
<div class="clr-col-lg-2 clr-col-md-4 clr-col-sm-6 clr-col-12"> <div class="clr-col-lg-2 clr-col-md-4 clr-col-sm-6 clr-col-12">
<div class="form-group"> <div class="form-group">
<label>Minute</label> <label>Minute</label>
@@ -37,7 +28,7 @@
</div> </div>
</div> </div>
<div class="clr-col-lg-2 clr-col-md-4 clr-col-sm-6 clr-col-12"> <div class="clr-col-lg-3 clr-col-md-6 clr-col-sm-6 clr-col-12">
<div class="form-group"> <div class="form-group">
<label>Month</label> <label>Month</label>
<select class="form-control" [(ngModel)]="month" (change)="onFieldChange()"> <select class="form-control" [(ngModel)]="month" (change)="onFieldChange()">
@@ -46,7 +37,7 @@
</div> </div>
</div> </div>
<div class="clr-col-lg-2 clr-col-md-4 clr-col-sm-6 clr-col-12"> <div class="clr-col-lg-3 clr-col-md-6 clr-col-sm-12 clr-col-12">
<div class="form-group"> <div class="form-group">
<label>Day of Week</label> <label>Day of Week</label>
<select class="form-control" [(ngModel)]="dayOfWeek" (change)="onFieldChange()"> <select class="form-control" [(ngModel)]="dayOfWeek" (change)="onFieldChange()">

View File

@@ -10,8 +10,7 @@ export class CronJobBuilderComponent implements OnInit, OnChanges {
@Input() instanceId: string = ''; // Unique identifier for each instance @Input() instanceId: string = ''; // Unique identifier for each instance
@Output() cronExpressionChange = new EventEmitter<string>(); @Output() cronExpressionChange = new EventEmitter<string>();
// Cron job fields (now starting with seconds) // Cron job fields
second: string = '*';
minute: string = '*'; minute: string = '*';
hour: string = '*'; hour: string = '*';
dayOfMonth: string = '*'; dayOfMonth: string = '*';
@@ -22,7 +21,6 @@ export class CronJobBuilderComponent implements OnInit, OnChanges {
cronDescription: string = ''; cronDescription: string = '';
// Options for selectors // Options for selectors
secondOptions: any[] = [];
minuteOptions: any[] = []; minuteOptions: any[] = [];
hourOptions: any[] = []; hourOptions: any[] = [];
dayOfMonthOptions: any[] = []; dayOfMonthOptions: any[] = [];
@@ -31,10 +29,9 @@ export class CronJobBuilderComponent implements OnInit, OnChanges {
ngOnInit() { ngOnInit() {
// Initialize options for each instance // Initialize options for each instance
this.secondOptions = this.generateOptions(0, 59, 'second'); this.minuteOptions = this.generateOptions(0, 59);
this.minuteOptions = this.generateOptions(0, 59, 'minute'); this.hourOptions = this.generateOptions(0, 23);
this.hourOptions = this.generateOptions(0, 23, 'hour'); this.dayOfMonthOptions = this.generateOptions(1, 31);
this.dayOfMonthOptions = this.generateOptions(1, 31, 'day');
this.monthOptions = [ this.monthOptions = [
{ value: '*', label: 'Every month' }, { value: '*', label: 'Every month' },
{ value: '1', label: 'January' }, { value: '1', label: 'January' },
@@ -76,8 +73,8 @@ export class CronJobBuilderComponent implements OnInit, OnChanges {
} }
} }
generateOptions(start: number, end: number, type: string): any[] { generateOptions(start: number, end: number): any[] {
const options = [{ value: '*', label: `Every ${type} (${start === 0 ? '0' : start}-${end})` }]; const options = [{ value: '*', label: `Every (${start === 0 ? '0' : start}-${end})` }];
for (let i = start; i <= end; i++) { for (let i = start; i <= end; i++) {
options.push({ value: i.toString(), label: i.toString() }); options.push({ value: i.toString(), label: i.toString() });
} }
@@ -86,16 +83,7 @@ export class CronJobBuilderComponent implements OnInit, OnChanges {
parseCronExpression(expression: string) { parseCronExpression(expression: string) {
const parts = expression.split(' '); const parts = expression.split(' ');
if (parts.length >= 6) { // Now expecting 6 parts with seconds if (parts.length >= 5) {
this.second = parts[0];
this.minute = parts[1];
this.hour = parts[2];
this.dayOfMonth = parts[3];
this.month = parts[4];
this.dayOfWeek = parts[5];
} else if (parts.length >= 5) { // For backward compatibility with 5-part cron expressions
// Default seconds to 0 if not provided
this.second = '0';
this.minute = parts[0]; this.minute = parts[0];
this.hour = parts[1]; this.hour = parts[1];
this.dayOfMonth = parts[2]; this.dayOfMonth = parts[2];
@@ -107,33 +95,19 @@ export class CronJobBuilderComponent implements OnInit, OnChanges {
generateDescription() { generateDescription() {
let description = 'Runs '; let description = 'Runs ';
// Second description
if (this.second === '*') {
description += 'every second';
} else if (this.second.includes('/')) {
const interval = this.second.split('/')[1];
description += `every ${interval} seconds`;
} else {
description += `at second ${this.second}`;
}
// Minute description // Minute description
if (this.minute === '*') { if (this.minute === '*') {
if (this.second === '*') { description += 'every minute';
description += '';
} else {
description += ' of every minute';
}
} else if (this.minute.includes('/')) { } else if (this.minute.includes('/')) {
const interval = this.minute.split('/')[1]; const interval = this.minute.split('/')[1];
description += ` of every ${interval} minutes`; description += `every ${interval} minutes`;
} else { } else {
description += `at minute ${this.minute}`; description += `at minute ${this.minute}`;
} }
// Hour description // Hour description
if (this.hour === '*') { if (this.hour === '*') {
if (this.minute === '*' && this.second === '*') { if (this.minute === '*') {
description += ''; description += '';
} else { } else {
description += ' past every hour'; description += ' past every hour';
@@ -172,23 +146,21 @@ export class CronJobBuilderComponent implements OnInit, OnChanges {
} }
// Special case for simple patterns // Special case for simple patterns
if (this.second === '0' && this.minute === '0' && this.hour === '0' && this.dayOfMonth === '1' && this.month === '*' && this.dayOfWeek === '*') { if (this.minute === '0' && this.hour === '0' && this.dayOfMonth === '1' && this.month === '*' && this.dayOfWeek === '*') {
description = 'Runs at midnight on the first day of every month'; description = 'Runs at midnight on the first day of every month';
} else if (this.second === '0' && this.minute === '0' && this.hour === '0' && this.dayOfMonth === '*' && this.month === '*' && this.dayOfWeek === '*') { } else if (this.minute === '0' && this.hour === '0' && this.dayOfMonth === '*' && this.month === '*' && this.dayOfWeek === '*') {
description = 'Runs at midnight every day'; description = 'Runs at midnight every day';
} else if (this.second === '0' && this.minute === '0' && this.hour === '*' && this.dayOfMonth === '*' && this.month === '*' && this.dayOfWeek === '*') { } else if (this.minute === '0' && this.hour === '*' && this.dayOfMonth === '*' && this.month === '*' && this.dayOfWeek === '*') {
description = 'Runs at the top of every hour'; description = 'Runs at the top of every hour';
} else if (this.second === '0' && this.minute === '*' && this.hour === '*' && this.dayOfMonth === '*' && this.month === '*' && this.dayOfWeek === '*') { } else if (this.minute === '*' && this.hour === '*' && this.dayOfMonth === '*' && this.month === '*' && this.dayOfWeek === '*') {
description = 'Runs at the top of every minute'; description = 'Runs every minute';
} else if (this.second === '*' && this.minute === '*' && this.hour === '*' && this.dayOfMonth === '*' && this.month === '*' && this.dayOfWeek === '*') {
description = 'Runs every second';
} }
this.cronDescription = description; this.cronDescription = description;
} }
buildCronExpression() { buildCronExpression() {
const expression = `${this.second} ${this.minute} ${this.hour} ${this.dayOfMonth} ${this.month} ${this.dayOfWeek}`; const expression = `${this.minute} ${this.hour} ${this.dayOfMonth} ${this.month} ${this.dayOfWeek}`;
this.cronExpressionChange.emit(expression); this.cronExpressionChange.emit(expression);
this.generateDescription(); // Update description when expression changes this.generateDescription(); // Update description when expression changes
return expression; return expression;

View File

@@ -1,47 +0,0 @@
import { Injectable } from '@angular/core';
import { Observable } from "rxjs";
import { HttpClient } from "@angular/common/http";
import { ApiRequestService } from "src/app/services/api/api-request.service";
@Injectable({
providedIn: 'root'
})
export class DataLakeSchedulerService {
private baseURL = "scheduler";
constructor(
private http: HttpClient,
private apiRequest: ApiRequestService,
) { }
// Get job by lake ID
getJobByLakeId(lakeId: number): Observable<any> {
const _http = `${this.baseURL}/lake/${lakeId}`;
return this.apiRequest.get(_http);
}
// Create a new job
createJob(jobData: any): Observable<any> {
const _http = `${this.baseURL}/create`;
return this.apiRequest.post(_http, jobData);
}
// Pause a job
pauseJob(jobId: number): Observable<any> {
const _http = `${this.baseURL}/pause/${jobId}`;
return this.apiRequest.post(_http, {});
}
// Resume a job
resumeJob(jobId: number): Observable<any> {
const _http = `${this.baseURL}/resume/${jobId}`;
return this.apiRequest.post(_http, {});
}
// Stop a job
stopJob(jobId: number): Observable<any> {
const _http = `${this.baseURL}/stop/${jobId}`;
return this.apiRequest.delete(_http);
}
}

View File

@@ -127,7 +127,6 @@ export class ChartTypeFieldsComponent implements OnInit {
return; return;
} }
console.log('Updating dynamic field:', this.selectedDynamicField);
this.loadingState = ClrLoadingState.LOADING; this.loadingState = ClrLoadingState.LOADING;
this.dynamicFieldService.updateDynamicField(this.selectedDynamicField.id, this.selectedDynamicField).subscribe({ this.dynamicFieldService.updateDynamicField(this.selectedDynamicField.id, this.selectedDynamicField).subscribe({
next: (data) => { next: (data) => {

View File

@@ -42,8 +42,7 @@
</ul> </ul>
</nav> </nav>
<div style="width: 100%;"> <div style="width: 100%;">
<!-- Remove the (drop) event binding since it's already handled by gridster's emptyCellDropCallback --> <gridster [options]="options" (drop)="onDrop($event)" style="background-color: transparent;">
<gridster [options]="options" style="background-color: transparent;">
<gridster-item [item]="item" *ngFor="let item of dashboardArray"> <gridster-item [item]="item" *ngFor="let item of dashboardArray">
<!-- <ng-container *ngIf="addToDashboard && item.addToDashboard"> --> <!-- <ng-container *ngIf="addToDashboard && item.addToDashboard"> -->
<button class="btn btn-icon btn-danger" style="margin-left: 10px; margin-top: 10px;" (click)="removeItem(item)" *ngIf="!fromRunner"> <button class="btn btn-icon btn-danger" style="margin-left: 10px; margin-top: 10px;" (click)="removeItem(item)" *ngIf="!fromRunner">

View File

@@ -66,18 +66,18 @@ export class EditnewdashComponent implements OnInit {
name: 'Common Filter', name: 'Common Filter',
identifier: 'common_filter' identifier: 'common_filter'
}, },
// { {
// name: 'Radar Chart', name: 'Radar Chart',
// identifier: 'radar_chart' identifier: 'radar_chart'
// }, },
// { {
// name: 'Doughnut Chart', name: 'Doughnut Chart',
// identifier: 'doughnut_chart' identifier: 'doughnut_chart'
// }, },
// { {
// name: 'Line Chart', name: 'Line Chart',
// identifier: 'line_chart' identifier: 'line_chart'
// }, },
// { // {
// name: 'Bar Chart', // name: 'Bar Chart',
// identifier: 'bar_chart' // identifier: 'bar_chart'
@@ -98,22 +98,22 @@ export class EditnewdashComponent implements OnInit {
// name: 'Scatter Chart', // name: 'Scatter Chart',
// identifier: 'scatter_chart' // identifier: 'scatter_chart'
// }, // },
// { {
// name: 'Dynamic Chart', name: 'Dynamic Chart',
// identifier: 'dynamic_chart' identifier: 'dynamic_chart'
// }, },
// { {
// name: 'Financial Chart', name: 'Financial Chart',
// identifier: 'financial_chart' identifier: 'financial_chart'
// }, },
// { {
// name: 'To Do', name: 'To Do',
// identifier: 'to_do_chart' identifier: 'to_do_chart'
// }, },
// { {
// name: 'Grid View', name: 'Grid View',
// identifier: 'grid_view' identifier: 'grid_view'
// }, },
{ {
name: 'Compact Filter', name: 'Compact Filter',
identifier: 'compact_filter' identifier: 'compact_filter'
@@ -489,7 +489,6 @@ export class EditnewdashComponent implements OnInit {
'polar': 'Polar Area Chart', 'polar': 'Polar Area Chart',
'bubble': 'Bubble Chart', 'bubble': 'Bubble Chart',
'scatter': 'Scatter Chart' 'scatter': 'Scatter Chart'
// Removed hardcoded heatmap entry to make it fully dynamic
}; };
// If this is a unified chart, set the name back to the appropriate chart name // If this is a unified chart, set the name back to the appropriate chart name
@@ -546,11 +545,9 @@ export class EditnewdashComponent implements OnInit {
//this._ds.updateDashboard(this.dashboardId, parsed).subscribe(); //this._ds.updateDashboard(this.dashboardId, parsed).subscribe();
} }
onDrop = (ev) => { onDrop(ev) {
console.log("on drop event ", ev);
const componentType = ev.dataTransfer.getData("widgetIdentifier"); const componentType = ev.dataTransfer.getData("widgetIdentifier");
// Safely calculate maxChartId, handling cases where chartid might be NaN or missing // Safely calculate maxChartId, handling cases where chartid might be NaN or missing
console.log("on drop ", componentType);
let maxChartId = 0; let maxChartId = 0;
if (this.dashboardArray && this.dashboardArray.length > 0) { if (this.dashboardArray && this.dashboardArray.length > 0) {
const validChartIds = this.dashboardArray const validChartIds = this.dashboardArray
@@ -564,26 +561,143 @@ export class EditnewdashComponent implements OnInit {
switch (componentType) { switch (componentType) {
// Handle all chart types by converting them to unified charts // Handle all chart types by converting them to unified charts
case "radar_chart": case "radar_chart":
// Use dynamic chart creation for all chart types return this.dashboardArray.push({
return this.createDynamicChart('radar', maxChartId); cols: 5,
rows: 6,
x: 0,
y: 0,
chartid: maxChartId + 1,
component: UnifiedChartComponent,
name: "Radar Chart",
chartType: 'radar',
xAxis: '',
yAxis: '',
table: '',
connection: undefined
});
case "line_chart": case "line_chart":
return this.createDynamicChart('line', maxChartId); return this.dashboardArray.push({
cols: 5,
rows: 7,
x: 0,
y: 0,
chartid: maxChartId + 1,
component: UnifiedChartComponent,
name: "Line Chart",
chartType: 'line',
xAxis: '',
yAxis: '',
table: '',
connection: undefined
});
case "doughnut_chart": case "doughnut_chart":
return this.createDynamicChart('doughnut', maxChartId); return this.dashboardArray.push({
cols: 5,
rows: 6,
x: 0,
y: 0,
chartid: maxChartId + 1,
component: UnifiedChartComponent,
name: "Doughnut Chart",
chartType: 'doughnut',
xAxis: '',
yAxis: '',
table: '',
connection: undefined
});
case "bar_chart": case "bar_chart":
// Use dynamic chart creation for bar charts
return this.createDynamicChart('bar', maxChartId); return this.createDynamicChart('bar', maxChartId);
case "pie_chart": case "pie_chart":
return this.createDynamicChart('pie', maxChartId); return this.dashboardArray.push({
cols: 5,
rows: 6,
x: 0,
y: 0,
chartid: maxChartId + 1,
component: UnifiedChartComponent,
name: "Pie Chart",
chartType: 'pie',
xAxis: '',
yAxis: '',
table: '',
connection: undefined
});
case "polar_area_chart": case "polar_area_chart":
return this.createDynamicChart('polar', maxChartId); return this.dashboardArray.push({
cols: 5,
rows: 6,
x: 0,
y: 0,
chartid: maxChartId + 1,
component: UnifiedChartComponent,
name: "Polar Area Chart",
chartType: 'polar',
xAxis: '',
yAxis: '',
table: '',
connection: undefined
});
case "bubble_chart": case "bubble_chart":
return this.createDynamicChart('bubble', maxChartId); return this.dashboardArray.push({
cols: 5,
rows: 6,
x: 0,
y: 0,
chartid: maxChartId + 1,
component: UnifiedChartComponent,
name: "Bubble Chart",
chartType: 'bubble',
xAxis: '',
yAxis: '',
table: '',
connection: undefined
});
case "scatter_chart": case "scatter_chart":
return this.createDynamicChart('scatter', maxChartId); return this.dashboardArray.push({
cols: 5,
rows: 6,
x: 0,
y: 0,
chartid: maxChartId + 1,
component: UnifiedChartComponent,
name: "Scatter Chart",
chartType: 'scatter',
xAxis: '',
yAxis: '',
table: '',
connection: undefined
});
case "dynamic_chart": case "dynamic_chart":
return this.createDynamicChart('line', maxChartId); // Default to line for dynamic chart return this.dashboardArray.push({
cols: 5,
rows: 6,
x: 0,
y: 0,
chartid: maxChartId + 1,
component: UnifiedChartComponent,
name: "Dynamic Chart",
chartType: 'line', // Default to line for dynamic chart
xAxis: '',
yAxis: '',
table: '',
connection: undefined
});
case "financial_chart": case "financial_chart":
return this.createDynamicChart('line', maxChartId); // Default to line for financial chart return this.dashboardArray.push({
cols: 5,
rows: 6,
x: 0,
y: 0,
chartid: maxChartId + 1,
component: UnifiedChartComponent,
name: "Financial Chart",
chartType: 'line', // Default to line for financial chart
xAxis: '',
yAxis: '',
table: '',
connection: undefined
});
case "to_do_chart": case "to_do_chart":
return this.dashboardArray.push({ return this.dashboardArray.push({
cols: 5, cols: 5,
@@ -630,16 +744,42 @@ export class EditnewdashComponent implements OnInit {
name: "Grid View" name: "Grid View"
}); });
case "unified_chart": case "unified_chart":
return this.createDynamicChart('bar', maxChartId); // Default to bar for unified chart return this.dashboardArray.push({
cols: 5,
rows: 6,
x: 0,
y: 0,
chartid: maxChartId + 1,
component: UnifiedChartComponent,
name: "Unified Chart",
// Add default configuration for unified chart
chartType: 'bar',
xAxis: '',
yAxis: '',
table: '',
connection: undefined
});
default: default:
// Handle any other chart types dynamically // Handle any other chart types dynamically
// Extract chart type name from identifier (e.g., "heatmap_chart" -> "heatmap") // Extract chart type name from identifier (e.g., "heatmap_chart" -> "heatmap")
const chartTypeName = componentType.replace('_chart', ''); const chartTypeName = componentType.replace('_chart', '');
console.log('Creating dynamic chart of type:', chartTypeName); const displayName = chartTypeName.charAt(0).toUpperCase() + chartTypeName.slice(1) + ' Chart';
console.log('Display name for chart:', this.getChartDisplayName(chartTypeName));
// Use dynamic chart creation for all chart types // Create a unified chart with the dynamic chart type
return this.createDynamicChart(chartTypeName, maxChartId); return this.dashboardArray.push({
cols: 5,
rows: 6,
x: 0,
y: 0,
chartid: maxChartId + 1,
component: UnifiedChartComponent,
name: displayName,
chartType: chartTypeName,
xAxis: '',
yAxis: '',
table: '',
connection: undefined
});
} }
} }
removeItem(item) { removeItem(item) {
@@ -1053,10 +1193,14 @@ export class EditnewdashComponent implements OnInit {
} }
// For UnifiedChartComponent, pass chart properties with chartType // For UnifiedChartComponent, pass chart properties with chartType
// Check if the component is UnifiedChartComponent dynamically // Check for specific chart names that use UnifiedChartComponent
if (item.component === UnifiedChartComponent || const unifiedChartNames = [
(item.component && item.component.name === 'UnifiedChartComponent') || 'Radar Chart', 'Line Chart', 'Doughnut Chart', 'Bar Chart',
item.name === 'Unified Chart') { 'Pie Chart', 'Polar Area Chart', 'Bubble Chart', 'Scatter Chart',
'Dynamic Chart', 'Financial Chart', 'Unified Chart'
];
if (unifiedChartNames.includes(item.name)) {
const unifiedChartInputs = { const unifiedChartInputs = {
chartType: item.chartType || 'bar', chartType: item.chartType || 'bar',
xAxis: item.xAxis, xAxis: item.xAxis,
@@ -1865,7 +2009,7 @@ export class EditnewdashComponent implements OnInit {
// Add method to handle item resize events // Add method to handle item resize events
itemResize(item: any, itemComponent: any) { itemResize(item: any, itemComponent: any) {
// console.log('Item resized:', item); console.log('Item resized:', item);
// Trigger a window resize event to notify charts to resize // Trigger a window resize event to notify charts to resize
window.dispatchEvent(new Event('resize')); window.dispatchEvent(new Event('resize'));
@@ -2069,7 +2213,7 @@ export class EditnewdashComponent implements OnInit {
// Add method to create a dynamic chart with configuration from database // Add method to create a dynamic chart with configuration from database
createDynamicChart = (chartTypeName: string, maxChartId: number) => { createDynamicChart(chartTypeName: string, maxChartId: number) {
console.log(`Creating dynamic chart of type: ${chartTypeName}`); console.log(`Creating dynamic chart of type: ${chartTypeName}`);
// First, get the chart type by name // First, get the chart type by name
@@ -2110,34 +2254,31 @@ export class EditnewdashComponent implements OnInit {
this.dashboardArray.push(chartItem); this.dashboardArray.push(chartItem);
console.log(`Created dynamic chart:`, chartItem); console.log(`Created dynamic chart:`, chartItem);
// Update the dashboard collection and trigger refresh
this.itemChange();
}, },
error: (error) => { error: (error) => {
console.error(`Error loading configuration for ${chartTypeName}:`, error); console.error(`Error loading configuration for ${chartTypeName}:`, error);
// Fallback to default configuration // Fallback to default configuration
this.createDefaultChart(chartTypeName, this.getChartDisplayName(chartTypeName)); // this.createDefaultChart(chartTypeName, maxChartId);
} }
}); });
} else { } else {
console.warn(`Chart type ${chartTypeName} not found, using default configuration`); console.warn(`Chart type ${chartTypeName} not found, using default configuration`);
this.createDefaultChart(chartTypeName, this.getChartDisplayName(chartTypeName)); // this.createDefaultChart(chartTypeName, maxChartId);
} }
}, },
error: (error) => { error: (error) => {
console.error('Error loading configuration for chart type:', error); console.error('Error loading configuration for chart type:', error);
// Fallback to default configuration // Fallback to default configuration
this.createDefaultChart(chartTypeName, this.getChartDisplayName(chartTypeName)); // this.createDefaultChart(chartType.name, chartType.displayName || chartType.name);
} }
}); });
} }
// Fallback method to create default chart configuration // Fallback method to create default chart configuration
createDefaultChart = (chartTypeName: string, chartDisplayName: string) => { createDefaultChart(chartTypeName: string, chartDisplayName: string) {
console.log(`Creating default chart for ${chartTypeName}`); console.log(`Creating default chart for ${chartTypeName}`);
// Map chart type names to chart types - making it fully dynamic // Map chart type names to chart types
const chartTypeMap = { const chartTypeMap = {
'bar': 'bar', 'bar': 'bar',
'line': 'line', 'line': 'line',
@@ -2147,11 +2288,10 @@ export class EditnewdashComponent implements OnInit {
'polar': 'polar', 'polar': 'polar',
'bubble': 'bubble', 'bubble': 'bubble',
'scatter': 'scatter' 'scatter': 'scatter'
// Removed hardcoded heatmap entry to make it fully dynamic
}; };
// Get the chart type from the name - default to bubble for unknown chart types // Get the chart type from the name
const chartType = chartTypeMap[chartTypeName.toLowerCase()] || 'bubble'; const chartType = chartTypeMap[chartTypeName.toLowerCase()] || 'bar';
// Safely calculate maxChartId, handling cases where chartid might be NaN or missing // Safely calculate maxChartId, handling cases where chartid might be NaN or missing
let maxChartId = 0; let maxChartId = 0;
@@ -2183,12 +2323,17 @@ export class EditnewdashComponent implements OnInit {
this.dashboardArray.push(chartItem); this.dashboardArray.push(chartItem);
console.log('Created default chart:', chartItem); console.log('Created default chart:', chartItem);
// Update the dashboard collection and trigger refresh // Update the dashboard collection
this.itemChange(); this.dashboardCollection.dashboard = this.dashboardArray.slice();
// Force gridster to refresh
if (this.options && this.options.api) {
this.options.api.optionsChanged();
}
} }
// Helper method to get display name for chart type - making it fully dynamic // Helper method to get display name for chart type
getChartDisplayName = (chartTypeName: string): string => { getChartDisplayName(chartTypeName: string): string {
const displayNameMap = { const displayNameMap = {
'bar': 'Bar Chart', 'bar': 'Bar Chart',
'line': 'Line Chart', 'line': 'Line Chart',
@@ -2198,17 +2343,9 @@ export class EditnewdashComponent implements OnInit {
'polar': 'Polar Area Chart', 'polar': 'Polar Area Chart',
'bubble': 'Bubble Chart', 'bubble': 'Bubble Chart',
'scatter': 'Scatter Chart' 'scatter': 'Scatter Chart'
// Removed hardcoded heatmap entry to make it fully dynamic
}; };
// For unknown chart types, create a display name by capitalizing the first letter and adding ' Chart' return displayNameMap[chartTypeName.toLowerCase()] || chartTypeName;
const displayName = displayNameMap[chartTypeName.toLowerCase()];
if (displayName) {
return displayName;
} else {
// Capitalize first letter and add ' Chart'
return chartTypeName.charAt(0).toUpperCase() + chartTypeName.slice(1) + ' Chart';
}
} }
} }

View File

@@ -33,7 +33,7 @@
[labels]="chartLabels" [labels]="chartLabels"
[options]="chartOptions" [options]="chartOptions"
[legend]="chartLegend" [legend]="chartLegend"
[type]="chartType || 'bar'" [chartType]="chartType || 'bar'"
(chartClick)="chartClicked($event)" (chartClick)="chartClicked($event)"
(chartHover)="chartHovered($event)"> (chartHover)="chartHovered($event)">
</canvas> </canvas>
@@ -46,7 +46,7 @@
[labels]="chartLabels" [labels]="chartLabels"
[options]="chartOptions" [options]="chartOptions"
[legend]="chartLegend" [legend]="chartLegend"
[type]="'bar'" [chartType]="'bar'"
(chartClick)="chartClicked($event)" (chartClick)="chartClicked($event)"
(chartHover)="chartHovered($event)"> (chartHover)="chartHovered($event)">
</canvas> </canvas>

View File

@@ -546,7 +546,7 @@ export class UnifiedChartComponent implements OnInit, OnChanges, OnDestroy {
// Check if filters are available // Check if filters are available
hasFilters(): boolean { hasFilters(): boolean {
const hasBaseFilters = this.baseFilters && this.baseFilters.length > 0; const hasBaseFilters = this.baseFilters && this.baseFilters.length > 0;
// console.log('Checking for filters - baseFilters:', this.baseFilters, 'hasBaseFilters:', hasBaseFilters); console.log('Checking for filters - baseFilters:', this.baseFilters, 'hasBaseFilters:', hasBaseFilters);
return hasBaseFilters; return hasBaseFilters;
} }
@@ -682,30 +682,30 @@ export class UnifiedChartComponent implements OnInit, OnChanges, OnDestroy {
} }
switch (this.chartType) { switch (this.chartType) {
// case 'bar': case 'bar':
// this.initializeBarChartOptions(); this.initializeBarChartOptions();
// break; break;
// case 'line': case 'line':
// this.initializeLineChartOptions(); this.initializeLineChartOptions();
// break; break;
// case 'pie': case 'pie':
// this.initializePieChartOptions(); this.initializePieChartOptions();
// break; break;
// case 'doughnut': case 'doughnut':
// this.initializeDoughnutChartOptions(); this.initializeDoughnutChartOptions();
// break; break;
// case 'bubble': case 'bubble':
// this.initializeBubbleChartOptions(); this.initializeBubbleChartOptions();
// break; break;
// case 'radar': case 'radar':
// this.initializeRadarChartOptions(); this.initializeRadarChartOptions();
// break; break;
// case 'polar': case 'polar':
// this.initializePolarChartOptions(); this.initializePolarChartOptions();
// break; break;
// case 'scatter': case 'scatter':
// this.initializeScatterChartOptions(); this.initializeScatterChartOptions();
// break; break;
default: default:
this.initializeDefaultChartOptions(); this.initializeDefaultChartOptions();
} }

View File

@@ -1,3 +1,25 @@
import { Ad10Component } from './BuilderComponents/angulardatatype/Ad10/Ad10.component';
import { DefatestComponent } from './BuilderComponents/defu/Defatest/Defatest.component';
import { ChildformComponent } from './BuilderComponents/stpkg/Childform/Childform.component';
import { DistrictComponent } from './BuilderComponents/testdata/District/District.component';
import { StateComponent } from './BuilderComponents/testdata/State/State.component';
import { CountryComponent } from './BuilderComponents/testdata/Country/Country.component';
import { Ad9Component } from './BuilderComponents/angulardatatype/Ad9/Ad9.component';
import { Ad8Component } from './BuilderComponents/angulardatatype/Ad8/Ad8.component';
import { Ad7Component } from './BuilderComponents/angulardatatype/Ad7/Ad7.component';
import { Ad6Component } from './BuilderComponents/angulardatatype/Ad6/Ad6.component';
import { Adv5Component } from './BuilderComponents/angulardatatype/Adv5/Adv5.component';
import { Adv4Component } from './BuilderComponents/angulardatatype/Adv4/Adv4.component';
import { SupportComponent } from './BuilderComponents/angulardatatype/Support/Support.component';
import { Adv3Component } from './BuilderComponents/angulardatatype/Adv3/Adv3.component';
import { Dv2Component } from './BuilderComponents/angulardatatype/Dv2/Dv2.component';
import { Adv1Component } from './BuilderComponents/angulardatatype/Adv1/Adv1.component';
import { Basicp3Component } from './BuilderComponents/angulardatatype/Basicp3/Basicp3.component';
import { Basicp2Component } from './BuilderComponents/angulardatatype/Basicp2/Basicp2.component';
import { Basicp1Component } from './BuilderComponents/angulardatatype/Basicp1/Basicp1.component';
import { SequencegenaratorComponent } from './fnd/sequencegenarator/sequencegenarator.component'; import { SequencegenaratorComponent } from './fnd/sequencegenarator/sequencegenarator.component';
@@ -38,7 +60,10 @@ import { AccesstypeComponent } from './admin/accesstype/accesstype.component';
import { ModulesComponent } from './admin/modules/modules.component'; import { ModulesComponent } from './admin/modules/modules.component';
import { SessionloggerComponent } from './admin/sessionlogger/sessionlogger.component'; import { SessionloggerComponent } from './admin/sessionlogger/sessionlogger.component';
import { ReportRunnerComponent } from './builder/report-runner/report-runner.component';
import { ReportrunnerallComponent } from './builder/report-runner/reportrunnerall/reportrunnerall.component'; import { ReportrunnerallComponent } from './builder/report-runner/reportrunnerall/reportrunnerall.component';
import { Reportrunneredit2Component } from './builder/report-runner/reportrunneredit2/reportrunneredit2.component';
import { ReportrunnereditComponent } from './builder/report-runner/reportrunneredit/reportrunneredit.component';
import { ReportBuildComponent } from './builder/report-build/report-build.component'; import { ReportBuildComponent } from './builder/report-build/report-build.component';
import { ReportbuildallComponent } from './builder/report-build/reportbuildall/reportbuildall.component'; import { ReportbuildallComponent } from './builder/report-build/reportbuildall/reportbuildall.component';
import { ReportbuildaddComponent } from './builder/report-build/reportbuildadd/reportbuildadd.component'; import { ReportbuildaddComponent } from './builder/report-build/reportbuildadd/reportbuildadd.component';
@@ -84,6 +109,13 @@ import { AllapiregisteryComponent } from './fnd/apiregistery/allapiregistery/all
import { AddapiregisteryComponent } from './fnd/apiregistery/addapiregistery/addapiregistery.component'; import { AddapiregisteryComponent } from './fnd/apiregistery/addapiregistery/addapiregistery.component';
import { EditapiregisteryComponent } from './fnd/apiregistery/editapiregistery/editapiregistery.component'; import { EditapiregisteryComponent } from './fnd/apiregistery/editapiregistery/editapiregistery.component';
import { ApiregisterylineComponent } from './fnd/apiregistery/Apiregisteryline/Apiregisteryline.component'; import { ApiregisterylineComponent } from './fnd/apiregistery/Apiregisteryline/Apiregisteryline.component';
import { Customer_informationComponent } from './BuilderComponents/angulardatatype/Customer_information/Customer_information.component';
import { Deployment_typeComponent } from './BuilderComponents/angulardatatype/Deployment_type/Deployment_type.component';
import { ManufacturerComponent } from './BuilderComponents/angulardatatype/Manufacturer/Manufacturer.component';
import { Order_summaryComponent } from './BuilderComponents/angulardatatype/Order_summary/Order_summary.component';
import { ProductComponent } from './BuilderComponents/angulardatatype/Product/Product.component';
import { TypesComponent } from './BuilderComponents/angulardatatype/Types/Types.component';
import { Test2Component } from './BuilderComponents/testdata/Test2/Test2.component';
import { Token_registeryComponent } from './fnd/Token_registery/Token_registery.component'; import { Token_registeryComponent } from './fnd/Token_registery/Token_registery.component';
import { MyworkspaceComponent } from './admin/myworkspace/myworkspace.component'; import { MyworkspaceComponent } from './admin/myworkspace/myworkspace.component';
import { ThemeCustomizationComponent } from './theme-customization/theme-customization.component'; import { ThemeCustomizationComponent } from './theme-customization/theme-customization.component';
@@ -95,14 +127,10 @@ import { QueryComponent } from './superadmin/query/query.component';
import { QueryaddComponent } from './superadmin/queryadd/queryadd.component'; import { QueryaddComponent } from './superadmin/queryadd/queryadd.component';
import { QueryeditComponent } from './superadmin/queryedit/queryedit.component'; import { QueryeditComponent } from './superadmin/queryedit/queryedit.component';
import { ChartTypePageComponent } from './builder/dashboardnew/chart-type-manager/chart-type-page.component'; import { ChartTypePageComponent } from './builder/dashboardnew/chart-type-manager/chart-type-page.component';
import { AddChartTypeComponent } from './builder/dashboardnew/chart-type-manager/add-chart-type.component';
import { EditChartTypeComponent } from './builder/dashboardnew/chart-type-manager/edit-chart-type.component';
import { ChartTypeUiComponentsComponent } from './builder/dashboardnew/chart-type-manager/chart-type-ui-components.component';
import { ChartTypeTemplatesComponent } from './builder/dashboardnew/chart-type-manager/chart-type-templates.component';
import { ChartTypeFieldsComponent } from './builder/dashboardnew/chart-type-manager/chart-type-fields.component';
import { ReportRunnerComponent } from './builder/report-runner/report-runner.component';
import { ReportrunnereditComponent } from './builder/report-runner/reportrunneredit/reportrunneredit.component';
import { Reportrunneredit2Component } from './builder/report-runner/reportrunneredit2/reportrunneredit2.component';
const routes: Routes = [ const routes: Routes = [
//Important: The sequence of path is important as the router go over then in sequential manner //Important: The sequence of path is important as the router go over then in sequential manner
{ path: '', redirectTo: '/cns-portal/dashboard', pathMatch: 'full' }, { path: '', redirectTo: '/cns-portal/dashboard', pathMatch: 'full' },
@@ -196,11 +224,6 @@ const routes: Routes = [
{ path: 'editdashn/:id', component: EditnewdashComponent }, { path: 'editdashn/:id', component: EditnewdashComponent },
{ path: 'schedule/:id', component: ScheduleComponent }, { path: 'schedule/:id', component: ScheduleComponent },
{ path: 'chart-types', component: ChartTypePageComponent }, { path: 'chart-types', component: ChartTypePageComponent },
{ path: 'chart-types/add', component: AddChartTypeComponent },
{ path: 'chart-types/edit/:id', component: EditChartTypeComponent },
{ path: 'chart-types/:id/ui-components', component: ChartTypeUiComponentsComponent },
{ path: 'chart-types/:id/templates', component: ChartTypeTemplatesComponent },
{ path: 'chart-types/:id/fields', component: ChartTypeFieldsComponent },
] ]
}, },
@@ -308,8 +331,178 @@ const routes: Routes = [
{ path: 'Country', component: CountryComponent },
{ path: 'Adv3', component: Adv3Component },
{ path: 'Ad10', component: Ad10Component },
{ path: 'Childform', component: ChildformComponent },
{ path: 'District', component: DistrictComponent },
{ path: 'State', component: StateComponent },
{ path: 'Country', component: CountryComponent },
{ path: 'Ad9', component: Ad9Component },
{ path: 'Ad8', component: Ad8Component },
{ path: 'Ad7', component: Ad7Component },
{ path: 'Ad6', component: Ad6Component },
{ path: 'Adv5', component: Adv5Component },
{ path: 'Support', component: SupportComponent },
{ path: 'Adv3', component: Adv3Component },
{ path: 'tokenregistery', component: Token_registeryComponent }, { path: 'tokenregistery', component: Token_registeryComponent },
{ path: 'Defatest', component: DefatestComponent },
{ path: 'Country', component: CountryComponent },
{ path: 'Defatest', component: DefatestComponent },
{ path: 'Test2', component: Test2Component },
{ path: 'Country', component: CountryComponent },
{ path: 'Test2', component: Test2Component },
{ path: 'Childform', component: ChildformComponent },
{ path: 'District', component: DistrictComponent },
{ path: 'State', component: StateComponent },
{ path: 'Country', component: CountryComponent },
{ path: 'Ad9', component: Ad9Component },
{ path: 'Ad8', component: Ad8Component },
{ path: 'Ad7', component: Ad7Component },
{ path: 'Ad6', component: Ad6Component },
{ path: 'Adv5', component: Adv5Component },
{ path: 'Adv4', component: Adv4Component },
{ path: 'Support', component: SupportComponent },
{ path: 'Adv3', component: Adv3Component },
{ path: 'Dv2', component: Dv2Component },
{ path: 'Adv1', component: Adv1Component },
{ path: 'Basicp3', component: Basicp3Component },
{ path: 'Basicp2', component: Basicp2Component },
{ path: 'Basicp1', component: Basicp1Component },
{ path: 'cust', component: Customer_informationComponent },
{ path: 'Order_summary', component: Order_summaryComponent },
{ path: 'Types', component: TypesComponent },
{ path: 'Product', component: ProductComponent },
{ path: 'Manufacturer', component: ManufacturerComponent },
{ path: 'Deployment_type', component: Deployment_typeComponent },
{ path: 'Stepper_workflow', component: Stepper_workflowComponent }, { path: 'Stepper_workflow', component: Stepper_workflowComponent },

View File

@@ -1,3 +1,25 @@
import { Ad10Component } from './BuilderComponents/angulardatatype/Ad10/Ad10.component';
import { DefatestComponent } from './BuilderComponents/defu/Defatest/Defatest.component';
import { ChildformComponent } from './BuilderComponents/stpkg/Childform/Childform.component';
import { DistrictComponent } from './BuilderComponents/testdata/District/District.component';
import { StateComponent } from './BuilderComponents/testdata/State/State.component';
import { CountryComponent } from './BuilderComponents/testdata/Country/Country.component';
import { Ad9Component } from './BuilderComponents/angulardatatype/Ad9/Ad9.component';
import { Ad8Component } from './BuilderComponents/angulardatatype/Ad8/Ad8.component';
import { Ad7Component } from './BuilderComponents/angulardatatype/Ad7/Ad7.component';
import { Ad6Component } from './BuilderComponents/angulardatatype/Ad6/Ad6.component';
import { Adv5Component } from './BuilderComponents/angulardatatype/Adv5/Adv5.component';
import { Adv4Component } from './BuilderComponents/angulardatatype/Adv4/Adv4.component';
import { SupportComponent } from './BuilderComponents/angulardatatype/Support/Support.component';
import { Adv3Component } from './BuilderComponents/angulardatatype/Adv3/Adv3.component';
import { Dv2Component } from './BuilderComponents/angulardatatype/Dv2/Dv2.component';
import { Adv1Component } from './BuilderComponents/angulardatatype/Adv1/Adv1.component';
import { Basicp3Component } from './BuilderComponents/angulardatatype/Basicp3/Basicp3.component';
import { Basicp2Component } from './BuilderComponents/angulardatatype/Basicp2/Basicp2.component';
import { Basicp1Component } from './BuilderComponents/angulardatatype/Basicp1/Basicp1.component';
import { CommonModule } from '@angular/common'; import { CommonModule } from '@angular/common';
@@ -53,6 +75,9 @@ import { ReportbuildeditComponent } from './builder/report-build/reportbuildedit
import { ReportbuildqueryComponent } from './builder/report-build/reportbuildquery/reportbuildquery.component'; import { ReportbuildqueryComponent } from './builder/report-build/reportbuildquery/reportbuildquery.component';
import { ReportBuild2Component } from './builder/report-build2/report-build2.component'; import { ReportBuild2Component } from './builder/report-build2/report-build2.component';
import { ReportBuild2editComponent } from './builder/report-build2/report-build2edit/report-build2edit.component'; import { ReportBuild2editComponent } from './builder/report-build2/report-build2edit/report-build2edit.component';
import { ReportRunnerComponent } from './builder/report-runner/report-runner.component';
import { ReportrunnereditComponent } from './builder/report-runner/reportrunneredit/reportrunneredit.component';
import { Reportrunneredit2Component } from './builder/report-runner/reportrunneredit2/reportrunneredit2.component';
import { DashboardnewComponent } from './builder/dashboardnew/dashboardnew.component'; import { DashboardnewComponent } from './builder/dashboardnew/dashboardnew.component';
@@ -113,7 +138,13 @@ import { AllapiregisteryComponent } from './fnd/apiregistery/allapiregistery/all
import { AddapiregisteryComponent } from './fnd/apiregistery/addapiregistery/addapiregistery.component'; import { AddapiregisteryComponent } from './fnd/apiregistery/addapiregistery/addapiregistery.component';
import { EditapiregisteryComponent } from './fnd/apiregistery/editapiregistery/editapiregistery.component'; import { EditapiregisteryComponent } from './fnd/apiregistery/editapiregistery/editapiregistery.component';
import { ApiregisterylineComponent } from './fnd/apiregistery/Apiregisteryline/Apiregisteryline.component'; import { ApiregisterylineComponent } from './fnd/apiregistery/Apiregisteryline/Apiregisteryline.component';
import { Customer_informationComponent } from './BuilderComponents/angulardatatype/Customer_information/Customer_information.component';
import { Deployment_typeComponent } from './BuilderComponents/angulardatatype/Deployment_type/Deployment_type.component';
import { ManufacturerComponent } from './BuilderComponents/angulardatatype/Manufacturer/Manufacturer.component';
import { Order_summaryComponent } from './BuilderComponents/angulardatatype/Order_summary/Order_summary.component';
import { ProductComponent } from './BuilderComponents/angulardatatype/Product/Product.component';
import { TypesComponent } from './BuilderComponents/angulardatatype/Types/Types.component';
import { Test2Component } from './BuilderComponents/testdata/Test2/Test2.component';
import { Token_registeryComponent } from './fnd/Token_registery/Token_registery.component'; import { Token_registeryComponent } from './fnd/Token_registery/Token_registery.component';
import { MyworkspaceComponent } from './admin/myworkspace/myworkspace.component'; import { MyworkspaceComponent } from './admin/myworkspace/myworkspace.component';
import { ThemeCustomizationComponent } from './theme-customization/theme-customization.component'; import { ThemeCustomizationComponent } from './theme-customization/theme-customization.component';
@@ -134,34 +165,11 @@ import { ShieldDashboardModule } from './builder/dashboardnew/gadgets/shield-das
// Import UnifiedChartComponent // Import UnifiedChartComponent
import { UnifiedChartComponent } from './builder/dashboardnew/gadgets/unified-chart/unified-chart.component'; import { UnifiedChartComponent } from './builder/dashboardnew/gadgets/unified-chart/unified-chart.component';
// Import ChartConfigManagerComponent // Import ChartConfigManagerComponent
import { ChartConfigManagerComponent } from './builder/dashboardnew/chart-config/chart-config-manager.component'; import { ChartConfigManagerComponent } from './builder/dashboardnew/chart-config-manager/chart-config-manager.component';
// Import ChartTypeManagerComponent // Import ChartTypeManagerComponent
import { ChartTypeManagerComponent } from './builder/dashboardnew/chart-type-manager/chart-type-manager.component'; import { ChartTypeManagerComponent } from './builder/dashboardnew/chart-type-manager/chart-type-manager.component';
// Import ChartTypePageComponent // Import ChartTypePageComponent
import { ChartTypePageComponent } from './builder/dashboardnew/chart-type-manager/chart-type-page.component'; import { ChartTypePageComponent } from './builder/dashboardnew/chart-type-manager/chart-type-page.component';
// Import AddChartTypeComponent
import { AddChartTypeComponent } from './builder/dashboardnew/chart-type-manager/add-chart-type.component';
// Import EditChartTypeComponent
import { EditChartTypeComponent } from './builder/dashboardnew/chart-type-manager/edit-chart-type.component';
// Import ChartTypeUiComponentsComponent
import { ChartTypeUiComponentsComponent } from './builder/dashboardnew/chart-type-manager/chart-type-ui-components.component';
// Import ChartTypeTemplatesComponent
import { ChartTypeTemplatesComponent } from './builder/dashboardnew/chart-type-manager/chart-type-templates.component';
// Import ChartTypeFieldsComponent
import { ChartTypeFieldsComponent } from './builder/dashboardnew/chart-type-manager/chart-type-fields.component';
// Import new form components
import { ChartTypeFormComponent } from './builder/dashboardnew/chart-config/forms/chart-type-form.component';
import { UiComponentFormComponent } from './builder/dashboardnew/chart-config/forms/ui-component-form.component';
import { ComponentPropertyFormComponent } from './builder/dashboardnew/chart-config/forms/component-property-form.component';
import { ChartTemplateFormComponent } from './builder/dashboardnew/chart-config/forms/chart-template-form.component';
import { DynamicFieldFormComponent } from './builder/dashboardnew/chart-config/forms/dynamic-field-form.component';
// Import ChartConfigModalComponent
import { ChartConfigModalComponent } from './builder/dashboardnew/editnewdash/chart-config-modal.component';
// Import DynamicChartLoaderService
import { DynamicChartLoaderService } from './builder/dashboardnew/chart-config/dynamic-chart-loader.service';
import { ReportRunnerComponent } from './builder/report-runner/report-runner.component';
import { ReportrunnereditComponent } from './builder/report-runner/reportrunneredit/reportrunneredit.component';
import { Reportrunneredit2Component } from './builder/report-runner/reportrunneredit2/reportrunneredit2.component';
@NgModule({ @NgModule({
declarations: [ declarations: [
@@ -181,27 +189,6 @@ import { Reportrunneredit2Component } from './builder/report-runner/reportrunner
ChartTypeManagerComponent, ChartTypeManagerComponent,
// Add ChartTypePageComponent to declarations // Add ChartTypePageComponent to declarations
ChartTypePageComponent, ChartTypePageComponent,
// Add AddChartTypeComponent to declarations
AddChartTypeComponent,
// Add EditChartTypeComponent to declarations
EditChartTypeComponent,
// Add ChartTypeUiComponentsComponent to declarations
ChartTypeUiComponentsComponent,
// Add ChartTypeTemplatesComponent to declarations
ChartTypeTemplatesComponent,
// Add ChartTypeFieldsComponent to declarations
ChartTypeFieldsComponent,
// Add new form components to declarations
ChartTypeFormComponent,
UiComponentFormComponent,
ComponentPropertyFormComponent,
ChartTemplateFormComponent,
DynamicFieldFormComponent,
// Add ChartConfigModalComponent to declarations
ChartConfigModalComponent,
// Add ChartTypeDisplayComponent to declarations
DashrunnerlineComponent, BarRunnerComponent, LineRunnerComponent, DoughnutRunnerComponent, GridRunnerComponent, PieRunnerComponent, PolarRunnerComponent, RadarRunnerComponent, ScatterRunnerComponent, TodoRunnerComponent, BubbleRunnerComponent, DashrunnerlineComponent, BarRunnerComponent, LineRunnerComponent, DoughnutRunnerComponent, GridRunnerComponent, PieRunnerComponent, PolarRunnerComponent, RadarRunnerComponent, ScatterRunnerComponent, TodoRunnerComponent, BubbleRunnerComponent,
// Add CompactFilterRunnerComponent to declarations // Add CompactFilterRunnerComponent to declarations
CompactFilterRunnerComponent, CompactFilterRunnerComponent,
@@ -214,7 +201,7 @@ import { Reportrunneredit2Component } from './builder/report-runner/reportrunner
ApiregisterylineComponent, ApiregisterylineComponent,
DatamanagementComponent, DatamananementworkflowComponent, BulkimportComponent, BulkimportallComponent, BulkimportaddComponent, BulkimporteditComponent, BulkimportlineComponent, BulkimporteditlineComponent, MappingruleComponent, MappingruleallComponent, DatamanagementComponent, DatamananementworkflowComponent, BulkimportComponent, BulkimportallComponent, BulkimportaddComponent, BulkimporteditComponent, BulkimportlineComponent, BulkimporteditlineComponent, MappingruleComponent, MappingruleallComponent,
MappingruleaddComponent, MappingruleaddComponent,
MappingruleeditComponent, Stepper_workflowComponent, MappingruleeditComponent, Stepper_workflowComponent, Customer_informationComponent,
Data_lakeComponent, Data_lakeComponent,
SureconnectComponent, SureconnectComponent,
EditsureconnectComponent, EditsureconnectComponent,
@@ -227,8 +214,32 @@ import { Reportrunneredit2Component } from './builder/report-runner/reportrunner
ThemeCustomizationComponent, ThemeCustomizationComponent,
Ad10Component,
Token_registeryComponent, Token_registeryComponent,
DefatestComponent,
Test2Component,
Order_summaryComponent,
TypesComponent,
ProductComponent,
ManufacturerComponent,
Deployment_typeComponent,
ChildformComponent,
DistrictComponent,
StateComponent,
CountryComponent,
Ad9Component,
Ad8Component,
Ad7Component,
Ad6Component,
Adv5Component,
Adv4Component,
SupportComponent,
Adv3Component,
Dv2Component,
Adv1Component,
Basicp3Component,
Basicp2Component,
Basicp1Component,
], ],
imports: [ imports: [
QRCodeModule, QRCodeModule,
@@ -255,10 +266,8 @@ import { Reportrunneredit2Component } from './builder/report-runner/reportrunner
providers: [ providers: [
CookieService, CookieService,
WireframeService, WireframeService,
DynamicChartLoaderService
],
exports: [
ChartConfigManagerComponent
], ],
schemas: [CUSTOM_ELEMENTS_SCHEMA] schemas: [CUSTOM_ELEMENTS_SCHEMA]
}) })

View File

@@ -1,7 +1,7 @@
import { Injectable } from '@angular/core'; import { Injectable } from '@angular/core';
import { Router } from '@angular/router'; import { Router } from '@angular/router';
import { Observable, BehaviorSubject } from 'rxjs'; import { Observable, BehaviorSubject, Subject } from 'rxjs';
import { UserInfoService, LoginInfoInStorage} from '../user-info.service'; import { UserInfoService, LoginInfoInStorage} from '../user-info.service';
import { ApiRequestService } from './api-request.service'; import { ApiRequestService } from './api-request.service';
import { HttpClient } from '@angular/common/http'; import { HttpClient } from '@angular/common/http';
@@ -43,11 +43,14 @@ export class LoginService {
*/ */
let loginDataSubject:BehaviorSubject<any> = new BehaviorSubject<any>([]); // Will use this BehaviorSubject to emit data that we want after ajax login attempt // let loginDataSubject:BehaviorSubject<any> = new BehaviorSubject<any>([]); // Will use this BehaviorSubject to emit data that we want after ajax login attempt
let loginDataSubject: Subject<any> = new Subject<any>();
let loginInfoReturn:LoginInfoInStorage; // Object that we want to send back to Login Page let loginInfoReturn:LoginInfoInStorage; // Object that we want to send back to Login Page
this.apiRequest.loginAuthentication('token/session', bodyData) this.apiRequest.loginAuthentication('token/session', bodyData)
.subscribe(jsonResp => { .subscribe({
next: (jsonResp) => {
console.log('login response in service : ', jsonResp); console.log('login response in service : ', jsonResp);
if (jsonResp.operationMessage=='Login Failed') { if (jsonResp.operationMessage=='Login Failed') {
this.toastr.warning('Not Login Getting Error check your Username and password'); this.toastr.warning('Not Login Getting Error check your Username and password');
@@ -78,7 +81,7 @@ export class LoginService {
this.userInfoService.storeUserInfo(JSON.stringify(loginInfoReturn.user)); this.userInfoService.storeUserInfo(JSON.stringify(loginInfoReturn.user));
} }
else { else {
//Create a faliure object that we want to send back to login page //Create a failure object that we want to send back to login page
loginInfoReturn = { loginInfoReturn = {
"success":false, "success":false,
"message":jsonResp.operationMessage, "message":jsonResp.operationMessage,
@@ -86,8 +89,9 @@ export class LoginService {
}; };
} }
loginDataSubject.next(loginInfoReturn); loginDataSubject.next(loginInfoReturn);
loginDataSubject.complete(); // Complete the subject
}, },
err => { error: (err) => {
console.log('login error ', err); console.log('login error ', err);
loginInfoReturn = { loginInfoReturn = {
"success": false, "success": false,
@@ -97,6 +101,9 @@ export class LoginService {
if (err) { if (err) {
this.toastr.error('Getting Server Error'); this.toastr.error('Getting Server Error');
} }
loginDataSubject.next(loginInfoReturn); // Send the error response
loginDataSubject.complete(); // Complete the subject
}
}); });
return loginDataSubject; return loginDataSubject;

View File

@@ -1,46 +0,0 @@
import { Injectable } from '@angular/core';
import { Observable } from "rxjs";
import { HttpClient } from "@angular/common/http";
import { ApiRequestService } from "src/app/services/api/api-request.service";
@Injectable({
providedIn: 'root'
})
export class SchedulerService {
private baseURL = "scheduler";
constructor(
private http: HttpClient,
private apiRequest: ApiRequestService,
) { }
// Get job by lake ID
getJobByLakeId(lakeId: number): Observable<any> {
const _http = `${this.baseURL}/lake/${lakeId}`;
return this.apiRequest.get(_http);
}
// Create a new job
createJob(jobData: any): Observable<any> {
const _http = `${this.baseURL}/create`;
return this.apiRequest.post(_http, jobData);
}
// Pause a job
pauseJob(jobId: number): Observable<any> {
const _http = `${this.baseURL}/pause/${jobId}`;
return this.apiRequest.post(_http, {});
}
// Resume a job
resumeJob(jobId: number): Observable<any> {
const _http = `${this.baseURL}/resume/${jobId}`;
return this.apiRequest.post(_http, {});
}
// Stop a job
stopJob(jobId: number): Observable<any> {
const _http = `${this.baseURL}/stop/${jobId}`;
return this.apiRequest.delete(_http);
}
}