import { DBProvider } from 'ionic-np-dbprovider/src';
import { ProductDiscountEntity } from 'ionic-np-core-entitycomponent/src'
import { ServiceProvider } from 'ionic-np-serviceprovider/src'
import { Injectable } from '@angular/core'

@Injectable()
export class ProductDiscountBC {

    constructor(private serviceprovider: ServiceProvider) {


    }

    public Read(where?: string): Promise<ProductDiscountEntity[]> {

        return new Promise(function (resolve, reject) {
            let dbProvider: DBProvider;
            let productDiscountEntity: ProductDiscountEntity[];

            dbProvider = new DBProvider();

            let retValue: Array<Object>;
            let strSql = ProductDiscountEntity.TABLE_NAME;
            if (where) { strSql = strSql + " " + where };

                dbProvider.Read(strSql).
                then((resultSet) => {

                    if (resultSet.rows.length > 0) {
                        productDiscountEntity = new Array(resultSet.rows.length);

                        for (let i = 0; i < resultSet.rows.length; i++) {
                            productDiscountEntity[i] = new ProductDiscountEntity();
                            productDiscountEntity[i].PRD_CD = resultSet.rows.item(i).PRD_CD;
                            productDiscountEntity[i].DISC_CD = resultSet.rows.item(i).DISC_CD;
                            productDiscountEntity[i].DISC_RATE = resultSet.rows.item(i).DISC_RATE;

                        }
                    }
                    resolve(productDiscountEntity);

                });

        });

    }

    public Create(productDiscountEntity: Array<ProductDiscountEntity>): Promise<any> {
        return new Promise(function (resolve, reject) {

            let dbProvider: DBProvider;
            dbProvider = new DBProvider();

            let strSqls: Array<string>;
            strSqls = new Array();
            for (let i = 0; i < productDiscountEntity.length; i++) {
                strSqls.push("insert into " + ProductDiscountEntity.TABLE_NAME +
                    " (PRD_CD,DISC_CD,DISC_RATE) VALUES ('" +
                    productDiscountEntity[i].PRD_CD + "','" +
                    productDiscountEntity[i].DISC_CD + "','" +
                    productDiscountEntity[i].DISC_RATE + "')"
                );

            }

            dbProvider.ExecuteSql(strSqls)
                .then(() => {
                    resolve();
                })
                .catch((e) => {
                    reject(e);
                });


        });
    }

    public Get(httpUrl): Promise<ProductDiscountEntity[]> {
        return new Promise(resolve => {
            this.serviceprovider.Get(httpUrl).subscribe((result) => {

                let productdiscountentity: Array<ProductDiscountEntity>;
                productdiscountentity = new Array();
                for (let i = 0; i < result.length; i++) {
                    let productdiscount: ProductDiscountEntity;
                    productdiscount = new ProductDiscountEntity();
                    productdiscount.PRD_CD = result[i].PRD_CD;
                    productdiscount.DISC_CD = result[i].DISC_CD;
                    productdiscount.DISC_RATE = result[i].DISC_RATE;
                    productdiscountentity.push(productdiscount);

                }
                resolve(productdiscountentity);
            });
        });

    }
}