add AI agent for TIS

Author: baisui1981

src/base/datax.add.step4.component.ts

@@ -193,7 +193,7 @@ export class SelectedTabsComponent extends BasicFormComponent {
       throw new Error("descriptor can not be null");
     }
     // ,targetItemDesc_batch_source_process_extend
-      console.log([meta, this.dataXReaderTargetName,this.descriptor]);
+     // console.log([meta, this.dataXReaderTargetName,this.descriptor]);
     let detailId = meta.id;
     let pluginMeta: PluginType[]
       = [dataXReaderSubFormPluginMeta(
@@ -405,7 +405,6 @@ export class SelectedTabsComponent extends BasicFormComponent {
 // 设置所选table的表以及 表的列
 // 文档：https://angular.io/docs/ts/latest/guide/forms.html
 @Component({
-  // templateUrl: '/runtime/addapp.htm'
   selector: "datax-reader-table-select",
   template: `
     <tis-steps *ngIf="createModel && this.dto.headerStepShow" [type]="stepType" [step]="0"></tis-steps>
@@ -452,10 +451,7 @@ export class SelectedTabsComponent extends BasicFormComponent {
       </ng-template>
     </nz-spin>
   `
-  , styles: [
-    `
-    `
-  ]
+  , styles: [``]
 })
 export class DataxAddStep4Component extends BasicDataXAddComponent implements OnInit, AfterViewInit {
   errorItem: Item = Item.create([]);
@@ -484,13 +480,6 @@ export class DataxAddStep4Component extends BasicDataXAddComponent implements On
   writerDesc: Array<Descriptor> = [];
   tabFormErrors: Map<string, Array<IFieldError>>;
 
-  // savePlugin = new EventEmitter<any>();
-
-
-
-
-
-
   /**
    *
    * @param baseCpt
@@ -510,32 +499,25 @@ export class DataxAddStep4Component extends BasicDataXAddComponent implements On
         }
         let subFieldForms: Map<string /*tableName*/, Array<Item>> = new Map();
         let subFormHetero: HeteroList = hList[0];
-        // console.log(subFormHetero);
         let item: Item = null;
         let subForm: Array<Item> = null;
-        //  let desc: Descriptor = subFormHetero.descriptors.get(this.dto.readerDescriptor.impl);
-
         if (!readerDescriptorImpl) {
           item = subFormHetero.items[0];
           if (!item) {
             throw new Error("readerDescriptorImpl is undefined and first item also is undefined");
           }
           readerDescriptorImpl = item.impl;
         }
-
         if (!readerDescriptorImpl) {
           throw new Error("readerDescriptorImpl can not be undefined");
         }
-        //console.log([subFormHetero.descriptors,readerDescriptorImpl]);
         let desc: Descriptor = subFormHetero.descriptors.get(readerDescriptorImpl);
         if (!desc) {
-          // console.log(subFormHetero.descriptors.keys());
           throw new Error("readerDescriptorImpl:" + readerDescriptorImpl);
         }
 
         for (let itemIdx = 0; itemIdx < subFormHetero.items.length; itemIdx++) {
           item = subFormHetero.items[itemIdx];
-         // console.log([subFormHetero.items, itemIdx ,item]);
           for (let tabKey in item.vals) {
             /**==========================
              *START: 删除历史脏数据保护措施
@@ -553,9 +535,7 @@ export class DataxAddStep4Component extends BasicDataXAddComponent implements On
             //  item.wrapItemVals();
             // @ts-ignore
             subForm = item.vals[tabKey];
-            // console.log([tabKey, subForm]);
-            // Item.wrapItemPropVal(v, at);
-             console.log([tabKey,subForm]);
+            // console.log([tabKey,subForm]);
             subFieldForms.set(tabKey, subForm);
           }
           break;
@@ -565,13 +545,13 @@ export class DataxAddStep4Component extends BasicDataXAddComponent implements On
           throw new Error("readerDescriptorImpl:" + readerDescriptorImpl + ",desc:" + desc.impl + " must has subForm");
         }
 
-        // console.log(subFieldForms);
         subFieldFormsCallback(subFieldForms, subFormHetero, desc);
       }
     );
   }
 
-  constructor(tisService: TISService, modalService: NzModalService, private drawerService: NzDrawerService, r: Router, route: ActivatedRoute, notification: NzNotificationService) {
+  constructor(tisService: TISService, modalService: NzModalService
+              , private drawerService: NzDrawerService, r: Router, route: ActivatedRoute, notification: NzNotificationService) {
     super(tisService, modalService, r, route, notification);
   }
 

src/base/datax.worker.add.step0.component.ts

@@ -116,9 +116,7 @@ export class DataxWorkerAddStep0Component extends BasicFormComponent implements
           require: true,
           appendParams: appendParams
         };
-        // console.log([pluginDesc,pluginCategory]);
 
-        // console.log(dto);
         let containTplRewriterPlugin = dto.typedPluginCount[PowerjobCptType.JobTplAppOverwrite];
         let modelRef = PluginsComponent.openPluginDialog({
             opt: opt,

src/common/ds.quick.manager.component.ts

@@ -156,18 +156,6 @@ export class DatasourceQuickManagerComponent extends BasicFormComponent implemen
         this.hasSaved = true;
         let newDb: DataBaseMeta = {id: db.dbId, name: db.name, iconEndtype: pluginDesc.endtype};
         this.dsList = [newDb, ...this.dsList];
-        // let origin = {'key': `${db.dbId}`, 'title': db.name, 'children': []};
-        // origin[KEY_DB_ID] = `${db.dbId}`;
-        // // KEY_DB_ID
-        // let newNode: NzTreeNodeOptions[] = [origin];
-        // this.nodes = newNode.concat(this.nodes);
-        //
-        // let e = {'type': NodeType.DB, 'dbId': `${db.dbId}`};
-        // // console.log([db, e, newNode]);
-        // this.treeNodeClicked = true;
-        // this.onEvent(e);
-        // this.addDBNode(db);
-        //  this.notify.success("成功", `数据库${db.name}添加成功`, {nzDuration: 6000});
       });
   }
 

src/common/plugin/item-prop-val.component.ts

@@ -114,14 +114,17 @@ import {createDrawer} from "../ds.quick.manager.component";
                   </ng-container>
                   <ng-container *ngSwitchCase="6">
                     <!--select-->
+
                       <nz-select [attr.data-testid]="_pp.key" [disabled]="disabled" [(ngModel)]="_pp.primary"
-                                 [name]="_pp.key"
+                                 [name]="_pp.key" [nzCustomTemplate]="selOptsTpl"
                                  (ngModelChange)="inputValChange(_pp,$event)" nzAllowClear>
                            <nz-option nzCustomContent *ngFor="let e of _pp.options" [nzLabel]="e.name"
-                                      [nzValue]="e.name">
-                             <span *ngIf="e.endType" nzTheme="fill" nz-icon nz [nzType]="e.endType"></span> {{e.name}}
+                                      [nzValue]="e.name" [nzDisabled]="false" [nzTitle]="e.endType" >
+                             {{e.name}}
                            </nz-option>
                        </nz-select>
+
+                       <ng-template #selOptsTpl let-opt> <span nz-icon style="font-size: 18px" [nzType]="opt.nzTitle" nzTheme="fill" ></span> {{ opt.nzLabel}}</ng-template>
                   </ng-container>
                   <ng-container *ngSwitchCase="7">
                       <!--PASSWORD-->
@@ -413,6 +416,11 @@ export class ItemPropValComponent extends BasicFormComponent implements AfterCon
         return (this._pp && this._pp.pk && this._pp.updateModel) || this._disabled || this._pp.readonly;
     }
 
+    getOptionEndType(opt: any, pp: ItemPropVal): string {
+        // 通过 nzValue 找到对应的 option 对象
+        console.log(opt);
+        return 'folder'; // 如果找不到，返回默认图标
+    }
 
     @Input() set pp(item: ItemPropVal) {
         // console.log(item);
@@ -670,6 +678,9 @@ export class ItemPropValComponent extends BasicFormComponent implements AfterCon
     }
 
     reloadSelectableItems() {
+        if (!this._pluginImpl) {
+            throw new Error("prop _pluginImpl can not be null");
+        }
         let url = "/coredefine/corenodemanage.ajax";
         this.httpPost(url, `action=plugin_action&emethod=get_fresh_enum_field&impl=${this._pluginImpl}&field=${this._pp.key}`)
             .then((r) => {