Merge branch 'devops-staging' into 'master'

Devops staging

See merge request empatnusabangsa/ppob/ppob-backend!215

src/product/product.service.ts

@@ -63,6 +63,7 @@ export class ProductService {
     await mapSeries(data, async (it) => {
       let dataHistoryPrice;
       let partnerData;
+      let productStatusPartner;
 
       const subCategories =
           await this.productSubCategoriesService.findOneForCSVParser(it[2]);
@@ -76,15 +77,34 @@ export class ProductService {
         supplier: supplierData,
       });
 
+      const productStatus = await this.productHistoryStatus.findOne({
+        product: productData,
+        partner: null,
+      });
+
       if (productData) {
         //TODO : Handle Update Product
         productData.name = it[1];
         productData.status = it[5] == 'active' ? 'ACTIVE' : 'NOT ACTIVE';
+
         await this.productRepository.save(productData);
 
         //TODO : Handle History Price
         if (it[6] != '-' && it[6] != '') {
           partnerData = await this.partnerService.findOne(it[6]);
+          productStatusPartner = await this.productHistoryStatus.findOne({
+            product: productData,
+            partner: partnerData.id,
+          });
+
+          if (productStatusPartner === undefined) {
+            await this.productHistoryStatus.insert({
+              product: productData,
+              partner: it[6] != '-' ? partnerData : null,
+              status: it[5] == 'active' ? 'ACTIVE' : 'NOT ACTIVE',
+            });
+          }
+
           dataHistoryPrice = await this.productHistoryPrice.findOne({
             where: {
               product: productData.id,
@@ -93,6 +113,16 @@ export class ProductService {
             },
           });
         } else {
+          if (productStatus != undefined) {
+            productStatus.status = it[5] == 'active' ? 'ACTIVE' : 'NOT ACTIVE';
+            await this.productHistoryStatus.save(productStatus);
+          } else {
+            await this.productHistoryStatus.insert({
+              product: productData,
+              partner: it[6] != '-' ? partnerData : null,
+              status: it[5] == 'active' ? 'ACTIVE' : 'NOT ACTIVE',
+            });
+          }
           dataHistoryPrice = await this.productHistoryPrice.findOne({
             product: productData,
             partner: IsNull(),
@@ -106,12 +136,11 @@ export class ProductService {
           });
         }
 
-        await this.productHistoryStatus.insert({
+        if (productStatusPartner) {
-          product: productData,
+          await this.productHistoryStatus.update(productStatusPartner.id, {
-          partner: it[6] != '-' ? partnerData : null,
+            status: it[5] == 'active' ? 'ACTIVE' : 'NOT ACTIVE',
-          status: it[5] == 'active' ? 'ACTIVE' : 'NOT ACTIVE',
+          });
-
+        }
-        });
 
         await this.productHistoryPrice.insert({
           product: productData,