Implemented: logic to create search preference and schedule a service (#29bdb9f)

src/components/SaveThresholdModal.vue

@@ -0,0 +1,204 @@
+<template>
+  <ion-header>
+    <ion-toolbar>
+      <ion-buttons slot="start">
+        <ion-button @click="closeModal">
+          <ion-icon slot="icon-only" :icon="closeOutline" />
+        </ion-button>
+      </ion-buttons>
+      <ion-title>{{ $t("Save threshold rule") }}</ion-title>
+    </ion-toolbar>
+  </ion-header>
+
+  <ion-content>
+    <ion-list>
+      <ion-list-header>{{ $t("Info") }}</ion-list-header>
+      <ion-item>
+        <ion-icon :icon="shirtOutline" slot="start" />
+        <ion-label>{{ totalSKUs }} {{ $t('SKUs') }}</ion-label>
+      </ion-item>
+      <ion-item>
+        <ion-icon :icon="optionsOutline" slot="start" />
+        <ion-label>{{ threshold }} {{ $t('threshold') }}</ion-label>
+      </ion-item>
+
+      <ion-item>
+        <ion-label>{{ $t("Rule name") }}</ion-label>
+        <ion-input :placeholder="$t('rule name')" v-model="jobName"/>
+      </ion-item>
+    </ion-list>
+
+    <ion-fab vertical="bottom" horizontal="end" slot="fixed">
+      <ion-fab-button @click="saveThresholdRule()">
+        <ion-icon :icon="cloudUploadOutline" />
+      </ion-fab-button>
+    </ion-fab>
+  </ion-content>
+</template>
+
+<script lang="ts">
+import { defineComponent } from 'vue';
+import {
+  IonButton,
+  IonButtons,
+  IonContent,
+  IonFab,
+  IonFabButton,
+  IonHeader,
+  IonIcon,
+  IonInput,
+  IonItem,
+  IonLabel,
+  IonList,
+  IonListHeader,
+  IonTitle,
+  IonToolbar,
+  modalController
+} from '@ionic/vue';
+import {
+  closeOutline,
+  shirtOutline,
+  optionsOutline,
+  cloudUploadOutline
+} from 'ionicons/icons';
+import { ProductService } from '@/services/ProductService';
+import { hasError, showToast } from '@/utils';
+import { translate } from '@/i18n';
+import { mapGetters, useStore } from 'vuex';
+import { DateTime } from 'luxon';
+import { JobService } from '@/services/JobService';
+
+export default defineComponent({
+  name: 'SaveThresholdModal',
+  components: {
+    IonButton,
+    IonButtons,
+    IonContent,
+    IonFab,
+    IonFabButton,
+    IonHeader,
+    IonIcon,
+    IonInput,
+    IonItem,
+    IonLabel,
+    IonList,
+    IonListHeader,
+    IonTitle,
+    IonToolbar
+  },
+  props: ["threshold", "query", "totalSKUs"],
+  data () {
+    return {
+      jobName: ''
+    }
+  },
+  computed: {
+    ...mapGetters({
+      currentEComStore: 'user/getCurrentEComStore',
+      shopifyConfig: 'util/getShopifyConfig',
+      jobs: 'job/getJobs'
+    })
+  },
+  methods: {
+    closeModal() {
+      modalController.dismiss({ dismissed: true });
+    },
+    async saveThresholdRule() {
+      const solrQuery = this.query
+
+      // removed params object from query as there is no need for grouping or pagination when storing the query
+      delete solrQuery.json.params
+      // made the query to default (*:*) before storing, as the threshold will be set for all the products those
+      // are fullfilling the filters condition
+      solrQuery.json['query'] = "*:*"
+
+      try {
+        const resp = await ProductService.createSearchPreference({
+          searchPrefValue: JSON.stringify(solrQuery)
+        });
+
+        if (resp.status == 200 && resp?.data?.searchPrefId) {
+          const searchPrefId = resp.data.searchPrefId;
+          this.scheduleService(searchPrefId, this.threshold)
+        } else {
+          showToast(translate('Something went wrong'))
+        }
+      } catch (err) {
+        console.error(err)
+        showToast(translate('Something went wrong'))
+      }
+    },
+    async scheduleService(searchPrefId: string, threshold: string) {
+      let job = this.jobs['ping']
+      const productStoreId = this.currentEComStore.productStoreId
+      let shopifyConfigId = this.shopifyConfig[productStoreId]
+      let resp = '' as any;
+
+      if (!job) {
+        await this.store.dispatch('job/fetchJobs', {
+          inputFields: {
+            statusId: "SERVICE_DRAFT",
+            statusId_op: "equals",
+            systemJobEnumId: "ping",
+          },
+          viewSize: 1
+        })
+        job = this.jobs['ping']
+      }
+
+      if(!shopifyConfigId) {
+        const resp = await this.store.dispatch('util/getShopifyConfig', productStoreId)
+        shopifyConfigId = resp[productStoreId]
+      }
+
+      const payload = job ? {
+        'JOB_NAME': this.jobName ? this.jobName : job.jobName,
+        'SERVICE_NAME': job.serviceName,
+        'SERVICE_COUNT': '0',
+        'jobFields': {
+          'productStoreId': productStoreId,
+          'systemJobEnumId': job.systemJobEnumId,
+          'tempExprId': job.tempExprId,
+          'maxRecurrenceCount': '-1',
+          'parentJobId': job.parentJobId,
+          'runAsUser': 'system', // default system, but empty in run now
+          'recurrenceTimeZone': DateTime.now().zoneName
+        },
+        'shopifyConfigId': shopifyConfigId,
+        'statusId': "SERVICE_PENDING",
+        'systemJobEnumId': job.systemJobEnumId,
+        searchPrefId,
+        threshold
+      } as any : {}
+
+      // checking if the runtimeData has productStoreId, and if present then adding it on root level
+      job?.runtimeData?.productStoreId?.length >= 0 && (payload['productStoreId'] = productStoreId)
+      job?.priority && (payload['SERVICE_PRIORITY'] = job.priority.toString())
+
+      try {
+        resp = await JobService.scheduleJob({ ...job.runtimeData, ...payload });
+        if (resp.status == 200 && !hasError(resp)) {
+          showToast(translate('Service has been scheduled'))
+        } else {
+          showToast(translate('Something went wrong'))
+        }
+      } catch (err) {
+        showToast(translate('Something went wrong'))
+        console.error(err)
+      }
+      return resp;
+    }
+  },
+  setup() {
+    const store = useStore();
+
+    return {
+      closeOutline,
+      cloudUploadOutline,
+      shirtOutline,
+      optionsOutline,
+      store
+    };
+  },
+});
+</script>

src/locales/en.json

@@ -14,6 +14,7 @@
   "Don't skip": "Don't skip",
   "Download": "Download",
   "Download data in csv": "Download data in csv",
+  "Enter threshold value": "Enter threshold value",
   "Every 5 minutes": "Every 5 minutes",
   "Every 15 minutes": "Every 15 minutes",
   "Every 30 minutes": "Every 30 minutes",
@@ -35,19 +36,23 @@
   "No previous occurrence": "No previous occurrence",
   "Only show selected products": "Only show selected products",
   "Pending": "Pending",
+  "Please enter a threshold value to set for these products before proceeding.": "Please enter a threshold value to set for these products before proceeding.",
   "Product list": "Product list",
   "Product SKU column": "Product SKU column",
   "Products not found": "Products not found",
   "products selected": "products selected",
+  "Ok": "Ok",
   "OMS": "OMS",
   "Ready to create an app?": "Ready to create an app?",
   "reset": "reset",
   "retry": "retry",
+  "rule name": "rule name",
   "Running": "Running",
   "Run time": "Run time",
   "Save changes": "Save changes",
   "Schedule": "Schedule",
   "Results": "Results",
+  "Rule name": "Rule name",
   "Safety stock": "Safety stock",
   "Save": "Save",
   "Save threshold rule": "Save threshold rule",
@@ -61,9 +66,11 @@
   "Select locations": "Select locations",
   "Select the column index for the following information in the uploaded CSV": "Select the column index for the following information in the uploaded CSV",
   "Select run time": "Select run time",
+  "Service has been scheduled": "Service has been scheduled",
   "Set safety stock": "Set safety stock",
   "Settings": "Settings",
   "Shop": "Shop",
+  "SKUs": "SKUs",
   "Size": "Size",
   "Skip": "Skip",
   "Skip job": "Skip job",
@@ -81,6 +88,7 @@
   "There are no jobs pending right now": "There are no jobs pending right now",
   "There are no jobs running right now": "There are no jobs running right now",
   "Tags": "Tags",
+  "threshold": "threshold",
   "Threshold": "Threshold",
   "Threshold management": "Threshold management",
   "Threshold Management": "Threshold Management",

src/services/ProductService.ts

@@ -26,7 +26,16 @@ const fetchProductFacets = async (payload: any): Promise<any> => {
   })
 }
 
+const createSearchPreference = async (payload: any): Promise<any> => {
+  return api({
+    url: "service/createSearchPreference",
+    method: "post",
+    data: payload
+  });
+}
+
 export const ProductService = {
+  createSearchPreference,
   fetchProducts,
   fetchProductFacets,
   getProducts

src/services/UtilService.ts

@@ -9,6 +9,15 @@ const getServiceStatusDesc = async (payload: any): Promise<any> => {
   });
 }
 
+const getShopifyConfig = async (payload: any): Promise <any>  => {
+  return api({
+    url: "performFind",
+    method: "post",
+    data: payload
+  });
+}
+
 export const UtilService = {
-  getServiceStatusDesc
+  getServiceStatusDesc,
+  getShopifyConfig
 }

src/store/modules/job/actions.ts

@@ -229,7 +229,7 @@ const actions: ActionTree<JobState, RootState> = {
       },
       "entityName": "JobSandbox",
       "noConditionFind": "Y",
-      "viewSize": (payload.inputFields?.systemJobEnumId?.length * 2)
+      "viewSize": payload.viewSize ? payload.viewSize : (payload.inputFields?.systemJobEnumId?.length * 2)
     })
     if (resp.status === 200 && !hasError(resp) && resp.data.docs) {
       const cached = JSON.parse(JSON.stringify(state.cached)); 

src/store/modules/job/getters.ts

@@ -38,6 +38,9 @@ const getters: GetterTree <JobState, RootState> = {
     getJobHistory (state){
       return state.history.list;
     },
+    getJobs: (state) => {
+      return state.cached;
+    }
   }
 
   export default getters;

src/store/modules/util/UtilState.ts

@@ -1,3 +1,4 @@
 export default interface UtilState {
   statusDesc: any;
+  shopifyConfig: any;
 }

src/store/modules/util/actions.ts

@@ -28,6 +28,25 @@ const actions: ActionTree<UtilState, RootState> = {
       console.error(err)
     }
   },
+
+  async getShopifyConfig({ commit }, payload) {
+    // TODO: for now passing view size as 1 by considering that one product store id is associated with only
+    // one shopify config
+    const resp = await UtilService.getShopifyConfig({
+      "inputFields": {
+        "productStoreId": payload
+      },
+      "entityName": "ShopifyConfig",
+      "noConditionFind": "Y",
+      "fieldList": ["shopifyConfigId", "productStoreId"],
+      "viewSize": 1
+    })
+
+    if (resp.status === 200 && !hasError(resp)) {
+      commit(types.UTIL_SHOPIFY_CONFIG_UPDATED, resp.data.docs?.length > 0 ? resp.data.docs[0] : {});
+      return resp.data.docs[0];
+    }
+  },
 }
 
 export default actions;

src/store/modules/util/getters.ts

@@ -5,6 +5,9 @@ import RootState from '@/store/RootState'
 const getters: GetterTree <UtilState, RootState> = {
   getStatusDesc: (state) => (statusId: any) => {
     return state.statusDesc[statusId] ? state.statusDesc[statusId] : "-";
-  }
+  },
+  getShopifyConfig(state) {
+    return state.shopifyConfig
+}
 }
 export default getters;

src/store/modules/util/index.ts

@@ -8,7 +8,8 @@ import RootState from '@/store/RootState'
 const utilModule: Module<UtilState, RootState> = {
   namespaced: true,
   state: {
-    statusDesc: {}
+    statusDesc: {},
+    shopifyConfig: {}
   },
   getters,
   actions,

src/store/modules/util/mutation-types.ts

@@ -1,2 +1,3 @@
 export const SN_UTIL = 'util'
-export const UTIL_SERVICE_STATUS_DESC_UPDATED = SN_UTIL + '/SERVICE_STATUS_DESC_UPDATED'
+export const UTIL_SERVICE_STATUS_DESC_UPDATED = SN_UTIL + '/SERVICE_STATUS_DESC_UPDATED'
+export const UTIL_SHOPIFY_CONFIG_UPDATED = SN_UTIL + '/SHOPIFY_CONFIG_UPDATED'

src/store/modules/util/mutations.ts

@@ -7,6 +7,9 @@ const mutations: MutationTree <UtilState> = {
     payload.map((status: any) => {
       state.statusDesc[status.statusId] = status.description;
     })
+  },
+  [types.UTIL_SHOPIFY_CONFIG_UPDATED] (state, payload) {
+    state.shopifyConfig[payload.productStoreId] = payload.shopifyConfigId;
   }
 }
 export default mutations;