import { IPSDEEditForm, IPSDEFormItem } from '@ibizstudio/runtime';
import { ControlServiceBase, Util } from '@ibizstudio/runtime';
import { GlobalService, UtilServiceRegister } from '@ibizstudio/runtime';
import { AppFormModel } from '../ctrl-model';
import { isNilOrEmpty, notNilEmpty } from 'qx-util';

/**
 * Main 部件服务对象
 *
 * @export
 * @class AppFormService
 */
export class AppFormService extends ControlServiceBase {
  /**
   * 表单实例对象
   *
   * @memberof MainModel
   */
  declare controlInstance: IPSDEEditForm;

  /**
   * 数据服务对象
   *
   * @type {any}
   * @memberof AppFormService
   */
  appEntityService!: any;

  /**
   * 远端数据
   *
   * @type {*}
   * @memberof AppFormService
   */
  private remoteCopyData: any = {};

  /**
   * 初始化服务参数
   *
   * @type {boolean}
   * @memberof AppFormService
   */
  async initServiceParam() {
    this.appEntityService = await new GlobalService().getService(this.appDeCodeName, this.context);
    this.model = new AppFormModel(this.controlInstance);
  }

  /**
   * Creates an instance of AppFormService.
   *
   * @param {*} [opts={}]
   * @memberof AppFormService
   */
  constructor(opts: any = {}, context?: any) {
    super(opts, context);
    this.controlInstance = opts;
  }

  /**
   * loaded
   *
   * @memberof AppFormService
   */
  async loaded() {
    await this.initServiceParam();
  }

  /**
   * 处理数据
   *
   * @private
   * @param {Promise<any>} promise
   * @returns {Promise<any>}
   * @memberof AppFormService
   */
  private doItems(promise: Promise<any>, deKeyField: string, deName: string): Promise<any> {
    return new Promise((resolve, reject) => {
      promise
        .then((response: any) => {
          if (response && response.status === 200) {
            const data = response.data;
            data.forEach((item: any, index: number) => {
              item[deName] = item[deKeyField];
              data[index] = item;
            });
            resolve(data);
          } else {
            reject([]);
          }
        })
        .catch((response: any) => {
          reject([]);
        });
    });
  }

  /**
   * 获取跨实体数据集合
   *
   * @param {string} serviceName 服务名称
   * @param {string} interfaceName 接口名称
   * @param {*} data
   * @param {boolean} [isloading]
   * @returns {Promise<any[]>}
   * @memberof  AppFormService
   */
  getItems(serviceName: string, interfaceName: string, context: any = {}, data: any, isloading?: boolean): Promise<any[]> {
    data.page = data.page ? data.page : 0;
    data.size = data.size ? data.size : 1000;
    return new Promise((resolve: any, reject: any) => {
      new GlobalService()
        .getService(serviceName)
        .then((service: any) => {
          const tempContext: any = JSON.parse(JSON.stringify(context));
          if (tempContext && tempContext.srfsessionid) {
            tempContext.srfsessionkey = tempContext.srfsessionid;
            delete tempContext.srfsessionid;
          }
          if (service && service[interfaceName] && Util.isFunction(service[interfaceName])) {
            resolve(this.doItems(service[interfaceName](tempContext, data, isloading), service.APPDEKEY.toLowerCase(), service.APPDENAME.toLowerCase()));
          }
        })
        .catch((erroe: any) => {
          reject([]);
        });
    });
  }

  /**
   * 启动工作流
   *
   * @param {string} action
   * @param {*} [context={}]
   * @param {*} [data={}]
   * @param {boolean} [isloading]
   * @param {*} [localdata]
   * @returns {Promise<any>}
   * @memberof AppFormService
   */
  wfstart(action: string, context: any = {}, data: any = {}, isloading?: boolean, localdata?: any): Promise<any> {
    data = this.handleWFData(data, true);
    context = this.handleRequestData(action, context, data).context;
    return new Promise((resolve: any, reject: any) => {
      let result: Promise<any>;
      const _appEntityService: any = this.appEntityService;
      if (_appEntityService[action] && _appEntityService[action] instanceof Function) {
        result = _appEntityService[action](context, data, localdata);
      } else {
        result = this.appEntityService.WFStart(context, data, localdata);
      }
      result
        .then(response => {
          this.handleResponse(action, response);
          resolve(response);
        })
        .catch(response => {
          reject(response);
        });
    });
  }

  /**
   * 提交工作流
   *
   * @param {string} action
   * @param {*} [context={}]
   * @param {*} [data={}]
   * @param {boolean} [isloading]
   * @param {*} [localdata]
   * @returns {Promise<any>}
   * @memberof AppFormService
   */
  wfsubmit(action: string, context: any = {}, data: any = {}, isloading?: boolean, localdata?: any): Promise<any> {
    data = this.handleWFData(data, true);
    context = this.handleRequestData(action, context, data, true).context;
    return new Promise((resolve: any, reject: any) => {
      let result: Promise<any>;
      const _appEntityService: any = this.appEntityService;
      if (_appEntityService[action] && _appEntityService[action] instanceof Function) {
        result = _appEntityService[action](context, data, localdata);
      } else {
        result = this.appEntityService.WFSubmit(context, data, localdata);
      }
      result
        .then(response => {
          this.handleResponse(action, response);
          resolve(response);
        })
        .catch(response => {
          reject(response);
        });
    });
  }

  /**
   * 添加数据
   *
   * @param {string} action
   * @param {*} [context={}]
   * @param {*} [data={}]
   * @param {boolean} [isloading]
   * @param {boolean} [isWorkflow] 是否在工作流中添加数据
   * @returns {Promise<any>}
   * @memberof AppFormService
   */
  add(action: string, context: any = {}, data: any = {}, isloading?: boolean, isWorkflow?: boolean): Promise<any> {
    const { data: Data, context: Context } = this.handleRequestData(action, context, data, isWorkflow);
    // 手动修改数据主键的情况
    this.controlInstance.getPSDEFormItems()?.find((item: IPSDEFormItem) => {
      if (!item.hidden && item.getPSAppDEField()?.keyField) {
        Object.assign(Data, {
          [this.appDeKeyFieldName.toLowerCase()]: data[item.id],
          srffrontuf: '1',
        });
        return true;
      }
    });
    return new Promise((resolve: any, reject: any) => {
      let result: Promise<any>;
      const _appEntityService: any = this.appEntityService;
      if (_appEntityService[action] && _appEntityService[action] instanceof Function) {
        result = _appEntityService[action](Context, Data);
      } else {
        result = this.appEntityService.Create(Context, Data);
      }
      result
        .then(response => {
          if (isWorkflow) {
            resolve(response);
          } else {
            this.handleResponse(action, response);
            resolve(response);
          }
        })
        .catch(response => {
          reject(response);
        });
    });
  }

  /**
   * 删除数据
   *
   * @param {string} action
   * @param {*} [context={}]
   * @param {*} [data={}]
   * @param {boolean} [isloading]
   * @returns {Promise<any>}
   * @memberof AppFormService
   */
  delete(action: string, context: any = {}, data: any = {}, isloading?: boolean): Promise<any> {
    const { data: Data, context: Context } = this.handleRequestData(action, context, data);
    return new Promise((resolve: any, reject: any) => {
      let result: Promise<any>;
      const _appEntityService: any = this.appEntityService;
      if (_appEntityService[action] && _appEntityService[action] instanceof Function) {
        result = _appEntityService[action](Context, Data);
      } else {
        result = this.appEntityService.Remove(Context, Data);
      }
      result
        .then(response => {
          resolve(response);
        })
        .catch(response => {
          reject(response);
        });
    });
  }

  /**
   * 修改数据
   *
   * @param {string} action
   * @param {*} [context={}]
   * @param {*} [data={}]
   * @param {boolean} [isloading]
   * @param {boolean} [isWorkflow] 是否在工作流中修改数据
   * @returns {Promise<any>}
   * @memberof AppFormService
   */
  update(action: string, context: any = {}, data: any = {}, isloading?: boolean, isWorkflow?: boolean): Promise<any> {
    const { data: Data, context: Context } = this.handleRequestData(action, context, data, isWorkflow);
    return new Promise((resolve: any, reject: any) => {
      let result: Promise<any>;
      const _appEntityService: any = this.appEntityService;
      if (_appEntityService[action] && _appEntityService[action] instanceof Function) {
        result = _appEntityService[action](Context, Data);
      } else {
        result = this.appEntityService.Update(Context, Data);
      }
      result
        .then(response => {
          if (isWorkflow) {
            resolve(response);
          } else {
            this.handleResponse(action, response);
            resolve(response);
          }
        })
        .catch(response => {
          reject(response);
        });
    });
  }

  /**
   * 查询数据
   *
   * @param {string} action
   * @param {*} [context={}]
   * @param {*} [data={}]
   * @param {boolean} [isloading]
   * @returns {Promise<any>}
   * @memberof AppFormService
   */
  get(action: string, context: any = {}, data: any = {}, isloading?: boolean): Promise<any> {
    const { data: Data, context: Context } = this.handleRequestData(action, context, data, true);
    return new Promise((resolve: any, reject: any) => {
      let result: Promise<any>;
      const _appEntityService: any = this.appEntityService;
      if (_appEntityService[action] && _appEntityService[action] instanceof Function) {
        result = _appEntityService[action](Context, Data);
      } else {
        result = this.appEntityService.Get(Context, Data);
      }
      result
        .then(response => {
          this.setRemoteCopyData(response);
          this.handleResponse(action, response);
          resolve(response);
        })
        .catch(response => {
          reject(response);
        });
    });
  }

  /**
   * 加载草稿
   *
   * @param {string} action
   * @param {*} [context={}]
   * @param {*} [data={}]
   * @param {boolean} [isloading]
   * @returns {Promise<any>}
   * @memberof AppFormService
   */
  loadDraft(action: string, context: any = {}, data: any = {}, isloading?: boolean): Promise<any> {
    if (this.controlInstance?.controlType == 'SEARCHFORM') {
      return new Promise((resolve: any, reject: any) => {
        let response: any = { status: 200, data: {} };
        this.handleResponse(action, response, true);
        resolve(response);
      });
    }
    const { data: Data, context: Context } = this.handleRequestData(action, context, data, true);
    // 仿真主键数据
    const PrimaryKey = Util.createUUID();
    if (this.controlInstance.controlType != 'SEARCHFORM') {
      Data[this.appDeKeyFieldName.toLowerCase()] = PrimaryKey;
      Data[this.appDeCodeName.toLowerCase()] = PrimaryKey;
    }
    return new Promise((resolve: any, reject: any) => {
      let result: Promise<any>;
      const _appEntityService: any = this.appEntityService;
      if (_appEntityService[action] && _appEntityService[action] instanceof Function) {
        result = _appEntityService[action](Context, Data);
      } else {
        result = this.appEntityService.GetDraft(Context, Data);
      }
      result
        .then(response => {
          this.setRemoteCopyData(response);
          if (response.data && this.controlInstance.controlType != 'SEARCHFORM') {
            response.data[this.appDeKeyFieldName.toLowerCase()] = PrimaryKey;
          }
          this.handleResponse(action, response, notNilEmpty(data.srfkey) ? false : true);
          resolve(response);
        })
        .catch(response => {
          reject(response);
        });
    });
  }

  /**
   * 前台逻辑
   * @param {string} action
   * @param {*} [context={}]
   * @param {*} [data={}]
   * @param {boolean} [isloading]
   * @returns {Promise<any>}
   * @memberof AppFormService
   */
  frontLogic(action: string, context: any = {}, data: any = {}, isloading?: boolean): Promise<any> {
    const { data: Data, context: Context } = this.handleRequestData(action, context, data);
    return new Promise((resolve: any, reject: any) => {
      let result: Promise<any>;
      const _appEntityService: any = this.appEntityService;
      if (_appEntityService[action] && _appEntityService[action] instanceof Function) {
        result = _appEntityService[action](Context, Data);
      } else {
        return reject({ status: 500, data: { title: '失败', message: `实体服务缺少${action}方法` } });
      }
      result
        .then(response => {
          this.handleResponse(action, response, true);
          resolve(response);
        })
        .catch(response => {
          reject(response);
        });
    });
  }

  /**
   * 处理请求数据
   *
   * @param action 行为
   * @param data 数据
   * @memberof AppFormService
   */
  handleRequestData(action: string, context: any, data: any = {}, isMerge: boolean = false) {
    let mode: any = this.getMode();
    if (!mode && mode.getDataItems instanceof Function) {
      return data;
    }
    let formItemItems: any[] = mode.getDataItems();
    let requestData: any = {};
    if (isMerge && data && data.viewparams) {
      Object.assign(requestData, data.viewparams);
    }
    formItemItems.forEach((item: any) => {
      if (item.prop === 'srfupdatedate') {
        requestData.srfupdatedate = data.updatedate;
      } else if (item && item.dataType && Object.is(item.dataType, 'FRONTKEY')) {
          if (item && item.prop) {
              requestData[item.prop] = context[item.name] || data[item.prop];
          }
      } else {
          if (item && item.prop && item.name && (data[item.name] || data[item.name] === 0 || data[item.name] === null)) {
              requestData[item.prop] = data[item.name];
          } else {
              if (item.dataType && Object.is(item.dataType, "FORMPART")) {
                  Object.assign(requestData, data[item.name]);
              }
          }
      }
  });
    let tempContext: any = JSON.parse(JSON.stringify(context));
    if (tempContext && tempContext.srfsessionid) {
      tempContext.srfsessionkey = tempContext.srfsessionid;
      delete tempContext.srfsessionid;
    }
    if (context.srfcallbacktype && context.srfcallbackid) {
      Object.assign(requestData, {
        srfcallbacktype: context.srfcallbacktype,
        srfcallbackid: context.srfcallbackid,
      });
    }
    return { context: tempContext, data: requestData };
  }

  /**
   * 通过属性名称获取表单项名称
   *
   * @param name 实体属性名称
   * @memberof AppFormService
   */
  getItemNameByDeName(name: string): string {
    let itemName = name;
    let mode: any = this.getMode();
    if (!mode && mode.getDataItems instanceof Function) {
      return name;
    }
    let formItemItems: any[] = mode.getDataItems();
    formItemItems.forEach((item: any) => {
      if (item.prop === name) {
        itemName = item.name;
      }
    });
    return itemName.trim();
  }

  /**
   * 重写处理返回数据
   *
   * @param {string} action
   * @param {*} response
   * @memberof AppFormService
   */
  handleResponseData(action: string, data: any = {}, isCreate?: boolean, codelistArray?: any) {
    if (data.srfopprivs) {
      this.getStore().commit('authresource/setSrfappdeData', { key: `${this.deName}-${data[this.appDeKeyFieldName.toLowerCase()]}`, value: data.srfopprivs });
    }
    const model: any = this.getMode();
    if (!model && model.getDataItems instanceof Function) {
      return data;
    }
    const item: any = {};
    const dataItems: any[] = model.getDataItems();
    dataItems.forEach(dataitem => {
      if (dataitem.prop === 'srfupdatedate') {
        item.srfupdatedate = data.updatedate;
        return;
      }
      let val = data[dataitem.prop];
      if (isNilOrEmpty(val)) {
        val = data[dataitem.name];
      }
      if (isNilOrEmpty(isCreate) && Object.is(dataitem.dataType, 'GUID') && Object.is(dataitem.name, 'srfkey') && notNilEmpty(val)) {
        isCreate = true;
      }
      item[dataitem.name] = val;
      // 转化代码表
      if (codelistArray && dataitem.codelist) {
        if (codelistArray.get(dataitem.codelist.tag) && codelistArray.get(dataitem.codelist.tag).get(val)) {
          item[dataitem.name] = codelistArray.get(dataitem.codelist.tag).get(val);
        }
      }
    });
    item.srfuf = data.srfuf ? data.srfuf : isCreate ? '0' : '1';
    return item;
  }

  /**
   * 设置远端数据
   *
   * @param result 远端请求结果
   * @memberof AppFormService
   */
  setRemoteCopyData(result: any) {
    if (result && result.status === 200) {
      this.remoteCopyData = Util.deepCopy(result.data);
    }
  }

  /**
   * 获取远端数据
   *
   * @memberof AppFormService
   */
  getRemoteCopyData() {
    return this.remoteCopyData;
  }

  /**
   * 加载数据模型
   *
   * @param {string} serviceName
   * @param {*} context
   * @param {*} viewparams
   * @memberof AppFormService
   */
  loadModel(serviceName: string, context: any, viewparams: any) {
    return new Promise((resolve: any, reject: any) => {
      UtilServiceRegister.getService(context, serviceName)
        .then((service: any) => {
          if (service) {
            service
              .loadModelData(JSON.stringify(context), viewparams)
              .then((response: any) => {
                resolve(response);
              })
              .catch((response: any) => {
                reject(response);
              });
          }
        })
        .catch((response: any) => {
          reject(response);
        });
    });
  }

  /**
   * 保存模型
   *
   * @param {string} serviceName
   * @param {*} context
   * @param {*} viewparams
   * @returns
   * @memberof AppFormService
   */
  saveModel(serviceName: string, context: any, viewparams: any) {
    return new Promise((resolve: any, reject: any) => {
      UtilServiceRegister.getService(context, serviceName)
        .then((service: any) => {
          if (service) {
            service
              .saveModelData(JSON.stringify(context), '', viewparams)
              .then((response: any) => {
                resolve(response);
              })
              .catch((response: any) => {
                reject(response);
              });
          }
        })
        .catch((response: any) => {
          reject(response);
        });
    });
  }
}