API tools faq
paste
Guest User

Untitled

a guest
Jul 17th, 2019
111
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 126.01 KB
raw download clone embed print report
  1. // @flow
  2. import db from '../../db'
  3. import _ from 'lodash/fp'
  4. // $FlowFixMe
  5. import VError from 'verror'
  6. import { Log } from '../../util/Logger'
  7. import Debug from 'debug'
  8. import ES from '../../util/ES'
  9. import { getters } from './fields'
  10. import RE from 'require-environment-variables'
  11. import neighborsStates from './neighbors_states'
  12. import OrdSrv from '../ord/Order'
  13. import redis from '../../redis/index'
  14. import crypto from 'crypto'
  15. import __ from 'lodash'
  16. import { generateHashKeyPrefix, setRadisGeneratedKey, getValuesOfKeysRedisToCompare } from '../../util/Utils'
  17. import { FREE_FILL_SETTINGS_COND } from '../../util/Consts'
  18. import SingletonCache from '../../util/SingletonCache'
  19. // eslint-disable-next-line no-unused-vars
  20. const debug = Debug('sm:srv_prd_product')
  21.  
  22. // $FlowFixMe
  23. let keyPrefix = `sm_dbl_${process.env.NODE_ENV}`
  24.  
  25. function srvError(err, msg = 'Constructor') {
  26. const methodErr = new VError(err, msg)
  27. return new VError(methodErr, 'Product Service')
  28. }
  29.  
  30. function log(req_id, level, method, params, result, err) {
  31. Log[level]({
  32. req_id, // TODO fix it in log
  33. srv: {
  34. domain: 'prd',
  35. name: 'product',
  36. method,
  37. params,
  38. result,
  39. err,
  40. },
  41. })
  42. }
  43.  
  44. RE(['ES_URL'])
  45. const env = process.env.NODE_ENV !== undefined ? process.env.NODE_ENV : 'development'
  46. // $FlowFixMe
  47. export const es_product_index = `sm_dblsearch_${env}`
  48.  
  49. export function limitQuery(q: any, page: number, limit: number) {
  50. if (page) {
  51. limit = limit ? limit : 10
  52. q.offset(page * limit)
  53. }
  54.  
  55. if (limit) {
  56. q.limit(limit)
  57. }
  58. }
  59.  
  60. export const product_columns = [
  61. 'prd_tag_lst.prd_tag_id',
  62. 'prd_tag_lst.prd_tag',
  63. 'prd_versions.prd_ver_id',
  64. 'prd_versions.product_id',
  65. 'prd_versions.org_warehouse_id',
  66. 'prd_versions.product_status',
  67. 'prd_versions.product_published',
  68. 'prd_versions.is_frozen',
  69. 'prd_versions.is_perishable',
  70. 'prd_versions.is_refrigirated',
  71. 'prd_versions.rotate_vertical',
  72. 'prd_versions.product_title',
  73. 'prd_versions.product_descr',
  74. 'prd_versions.shelf_life',
  75. 'prd_versions.case_cube',
  76. 'prd_versions.srp',
  77. 'prd_versions.unit_type',
  78. 'prd_versions.unit_size',
  79. 'prd_versions.units_per_case',
  80. 'prd_versions.product_width',
  81. 'prd_versions.product_height',
  82. 'prd_versions.product_length',
  83. 'prd_versions.product_weight',
  84. // 'prd_sogm.min_sogm',
  85. 'prd_cat_products.*',
  86. 'prd_categories.prd_cat_id',
  87. 'prd_categories.category_title',
  88. 'prd_categories.dscr',
  89. 'prd_product_target.*',
  90. 'prd_target_lst.prd_target_id',
  91. 'prd_target_lst.target_title',
  92. 'prd_sold_at.*',
  93. 'prd_sold_at_lst.prd_sold_at_id',
  94. 'prd_sold_at_lst.sold_at_title',
  95. 'prd_images.prd_image_id',
  96. 'prd_images.prd_ver_id',
  97. 'prd_images.size',
  98. 'prd_images.type',
  99. 'prd_images.image_position',
  100. 'prd_images.name',
  101. 'prd_images.ext',
  102. 'prd_images.file_path',
  103. 'prd_images.full_name',
  104. 'prd_images.legacy_image_id',
  105. 'prd_images.primary',
  106. 'prd_inventory.prd_ver_id',
  107. 'prd_inventory.inventory',
  108. 'prd_upcs.prd_upc_id',
  109. 'prd_upcs.prd_ver_id',
  110. 'prd_upcs.upc',
  111. 'prd_upcs.type as upc_type',
  112. 'shp_packs.shp_pack_id',
  113. 'shp_packs.prd_ver_id',
  114. 'shp_packs.pack_width',
  115. 'shp_packs.pack_height',
  116. 'shp_packs.pack_length',
  117. 'shp_packs.pack_weight',
  118. 'shp_packs.pack_qua',
  119. 'shp_packs.is_cons',
  120. 'shp_packs.free_fill',
  121. 'shp_packs.free_fill_quota',
  122. 'shp_packs.legacy_pack_id',
  123. 'shp_pack_prices.shp_pack_price_id',
  124. 'shp_pack_prices.shp_pack_id',
  125. 'shp_pack_prices.price',
  126. 'org_warehouses.org_warehouse_id',
  127. 'org_warehouses.org_id',
  128. 'org_warehouses.warehouse_name',
  129. 'org_warehouses.profile_pic',
  130. 'org_warehouses.avatar_pic',
  131. 'org_warehouses.status',
  132. 'org_warehouses.ord_min_val',
  133. 'org_warehouses.will_ship_within',
  134. 'org_warehouses.shp_method_id',
  135. 'org_warehouses.legacy_owner_id',
  136. 'orgs.org_id',
  137. 'orgs.title',
  138. 'orgs.type',
  139. 'orgs.org_address_id',
  140. 'orgs.org_phone_id',
  141. 'orgs.org_lead_id',
  142. 'orgs.org_reg_scripts',
  143. 'org_phones.org_phone_id',
  144. 'org_phones.phone',
  145. 'org_phones.push_token',
  146. 'org_phones.is_sms',
  147. 'org_phones.is_push',
  148. 'org_addresses.org_address_id',
  149. 'org_addresses.address_1',
  150. 'org_addresses.address_2',
  151. 'org_addresses.address_3',
  152. 'org_addresses.city',
  153. 'org_addresses.state',
  154. 'org_addresses.zip',
  155. 'org_addresses.org_phone_id',
  156. // db.raw('ROUND(EXTRACT(epoch from shelf_life) / ( 3600 * 24 * 30 * 12)) as shelf_life'),
  157. db.raw('EXTRACT(day from will_ship_within) as will_ship_within_days'),
  158. 'shp_packs.shp_pack_id as shp_pack_id',
  159. 'shp_packs.title as pack_title',
  160. 'prd_upcs.type as upc_type',
  161. 'shp_packs.prd_ver_id as prd_ver_id',
  162. 'shp_packs_upcs.shp_pack_upc_id',
  163. 'shp_packs_upcs.pack_type',
  164. 'shp_packs_upcs.pack_upc',
  165. ]
  166.  
  167. export const product_preview_columns = [
  168. 'prd_versions.prd_ver_id',
  169. 'prd_versions.product_id',
  170. 'prd_versions.org_warehouse_id',
  171. 'prd_versions.product_status',
  172. 'prd_versions.product_published',
  173. 'prd_versions.is_frozen',
  174. 'prd_versions.is_perishable',
  175. 'prd_versions.is_refrigirated',
  176. 'prd_versions.rotate_vertical',
  177. 'prd_versions.product_title',
  178. 'prd_versions.product_descr',
  179. 'prd_versions.shelf_life',
  180. 'prd_versions.case_cube',
  181. 'prd_versions.srp',
  182. 'prd_versions.unit_type',
  183. 'prd_versions.unit_size',
  184. 'prd_versions.units_per_case',
  185. 'prd_versions.product_width',
  186. 'prd_versions.product_height',
  187. 'prd_versions.product_length',
  188. 'prd_versions.product_weight',
  189. // 'prd_sogm.min_sogm',
  190. 'prd_images.prd_image_id',
  191. 'prd_images.prd_ver_id',
  192. 'prd_images.size',
  193. 'prd_images.type',
  194. 'prd_images.image_position',
  195. 'prd_images.name',
  196. 'prd_images.ext',
  197. 'prd_images.file_path',
  198. 'prd_images.full_name',
  199. 'prd_images.legacy_image_id',
  200. 'prd_images.primary',
  201. 'prd_inventory.prd_ver_id',
  202. 'prd_inventory.inventory',
  203. 'shp_packs.shp_pack_id',
  204. 'shp_packs.prd_ver_id',
  205. 'shp_packs.pack_width',
  206. 'shp_packs.pack_height',
  207. 'shp_packs.pack_length',
  208. 'shp_packs.pack_weight',
  209. 'shp_packs.pack_qua',
  210. 'shp_packs.is_cons',
  211. 'shp_packs.free_fill',
  212. 'shp_packs.free_fill_quota',
  213. 'shp_packs.legacy_pack_id',
  214. 'shp_pack_prices.shp_pack_price_id',
  215. 'shp_pack_prices.shp_pack_id',
  216. 'shp_pack_prices.price',
  217. 'org_warehouses.org_warehouse_id',
  218. 'org_warehouses.org_id',
  219. 'org_warehouses.warehouse_name',
  220. 'org_warehouses.profile_pic',
  221. 'org_warehouses.avatar_pic',
  222. 'org_warehouses.status',
  223. 'org_warehouses.ord_min_val',
  224. 'org_warehouses.will_ship_within',
  225. 'org_warehouses.shp_method_id',
  226. 'org_warehouses.legacy_owner_id',
  227. 'org_warehouse_settings.settings',
  228. 'orgs.org_id',
  229. 'orgs.title',
  230. 'orgs.type',
  231. 'orgs.org_address_id',
  232. 'orgs.org_phone_id',
  233. 'orgs.org_lead_id',
  234. 'orgs.org_reg_scripts',
  235. 'org_phones.org_phone_id',
  236. 'org_phones.phone',
  237. 'org_phones.push_token',
  238. 'org_phones.is_sms',
  239. 'org_phones.is_push',
  240. 'org_addresses.org_address_id',
  241. 'org_addresses.address_1',
  242. 'org_addresses.address_2',
  243. 'org_addresses.address_3',
  244. 'org_addresses.city',
  245. 'org_addresses.state',
  246. 'org_addresses.zip',
  247. 'org_addresses.org_phone_id',
  248. // db.raw('ROUND(EXTRACT(epoch from shelf_life) / ( 3600 * 24 * 30 * 12)) as shelf_life'),
  249. db.raw('EXTRACT(day from will_ship_within) as will_ship_within_days'),
  250. 'shp_packs.shp_pack_id as shp_pack_id',
  251. 'shp_packs.title as pack_title',
  252. 'prd_upcs.type as upc_type',
  253. 'shp_packs.prd_ver_id as prd_ver_id',
  254. 'prd_upcs.upc',
  255. 'prd_upcs.prd_upc_id',
  256. // 'prd_upcs.prd_ver_id as prd_ver_id2',
  257. // undo because slow request
  258. // 'shp_packs_upcs.shp_pack_upc_id',
  259. // 'shp_packs_upcs.pack_type',
  260. // 'shp_packs_upcs.pack_upc',
  261. ]
  262.  
  263. export function prodOrderQuery(prd_ver_id: Number, orderId: Number) {
  264. let q = db
  265. .with(
  266. 'ordr',
  267. db('orders')
  268. .select('created_at', db.raw('?? as prd_ver_id', prd_ver_id))
  269. .where({
  270. order_id: orderId,
  271. })
  272. )
  273. .from('prd_versions')
  274. // Product
  275.  
  276. .joinRaw('JOIN ordr USING (prd_ver_id)')
  277. .joinRaw('LEFT JOIN prd_cat_products USING (prd_ver_id)')
  278. .joinRaw('LEFT JOIN prd_categories USING (prd_cat_id)')
  279.  
  280. // .joinRaw('LEFT JOIN prd_product_target USING (prd_ver_id)')
  281. // .joinRaw('LEFT JOIN prd_target_lst USING (prd_target_id)')
  282.  
  283. // .joinRaw('LEFT JOIN prd_sold_at USING (prd_ver_id)')
  284. // .joinRaw('LEFT JOIN prd_sold_at_lst USING (prd_sold_at_id)')
  285.  
  286. // .joinRaw('LEFT JOIN prd_tag_con USING (prd_ver_id)')
  287. // .joinRaw('LEFT JOIN prd_tag_lst USING (prd_tag_id)')
  288.  
  289. .joinRaw('LEFT JOIN prd_images USING (prd_ver_id)')
  290. // .joinRaw('LEFT JOIN prd_inventory USING (prd_ver_id)')
  291. .joinRaw('LEFT JOIN prd_upcs USING (prd_ver_id)')
  292.  
  293. .joinRaw('JOIN shp_packs USING (prd_ver_id)')
  294. .joinRaw('JOIN shp_pack_prices USING (shp_pack_id)')
  295.  
  296. // Warehouse
  297.  
  298. .joinRaw('JOIN org_warehouses USING (org_warehouse_id)')
  299. .joinRaw('left JOIN org_warehouse_settings USING (org_warehouse_id)')
  300. .joinRaw('JOIN orgs USING (org_id)')
  301. .joinRaw('JOIN org_phones USING (org_phone_id)')
  302. .joinRaw('JOIN org_addresses USING (org_address_id)')
  303.  
  304. .where(function() {
  305. this.whereRaw('ordr.created_at BETWEEN shp_pack_prices.dt_from AND shp_pack_prices.dt_to').orWhereRaw('ordr.created_at >= shp_pack_prices.dt_from AND shp_pack_prices.dt_to IS NULL')
  306. })
  307.  
  308. .where({
  309. prd_ver_id,
  310. })
  311.  
  312. .columns(['*', 'prd_upcs.type as upc_type', db.raw('ROUND(EXTRACT(epoch from shelf_life) / ( 3600 * 24 * 30 * 12)) as shelf_life'), db.raw('EXTRACT(day from will_ship_within) as will_ship_within_days')])
  313.  
  314. // debug('ProductOrder', q.toString())
  315.  
  316. return q
  317. }
  318.  
  319. export function prodQuery(published: boolean, admin: boolean) {
  320. return (
  321. db
  322.  
  323. .from('prd_versions')
  324. // Product
  325.  
  326. .joinRaw('LEFT JOIN prd_cat_products USING (prd_ver_id)')
  327. .joinRaw('LEFT JOIN prd_categories USING (prd_cat_id)')
  328.  
  329. .joinRaw('LEFT JOIN prd_product_target USING (prd_ver_id)')
  330. .joinRaw('LEFT JOIN prd_target_lst USING (prd_target_id)')
  331.  
  332. .joinRaw('LEFT JOIN prd_sold_at USING (prd_ver_id)')
  333. .joinRaw('LEFT JOIN prd_sold_at_lst USING (prd_sold_at_id)')
  334.  
  335. .joinRaw('LEFT JOIN prd_tag_con USING (prd_ver_id)')
  336. .joinRaw('LEFT JOIN prd_tag_lst USING (prd_tag_id)')
  337.  
  338. .joinRaw('LEFT JOIN prd_images USING (prd_ver_id)')
  339. .joinRaw('LEFT JOIN prd_inventory USING (prd_ver_id)')
  340. .joinRaw('LEFT JOIN prd_upcs USING (prd_ver_id)')
  341.  
  342. .joinRaw('JOIN shp_packs USING (prd_ver_id)')
  343. .joinRaw('JOIN shp_pack_prices USING (shp_pack_id)')
  344. .joinRaw('LEFT JOIN shp_pack_images on shp_pack_images.spi_shp_pack_id = shp_packs.shp_pack_id')
  345. .joinRaw('LEFT JOIN shp_packs_upcs on shp_packs.shp_pack_id = shp_packs_upcs.shp_pack_id')
  346.  
  347. // Warehouse
  348.  
  349. .joinRaw('JOIN org_warehouses USING (org_warehouse_id)')
  350. .joinRaw('left JOIN org_warehouse_settings USING (org_warehouse_id)')
  351. .joinRaw('JOIN orgs USING (org_id)')
  352. .joinRaw('JOIN org_phones USING (org_phone_id)')
  353. .joinRaw('JOIN org_addresses USING (org_address_id)')
  354. // .joinRaw('LEFT JOIN prd_sogm on sogm_product_id = prd_versions.product_id')
  355. // Default where
  356.  
  357. .where(function() {
  358. if (published) {
  359. this.where('prd_versions.product_published', true)
  360. }
  361. })
  362.  
  363. .whereNull('prd_versions.end_at')
  364. .whereNull('shp_pack_prices.dt_to')
  365. .whereNull('prd_inventory.dt_to')
  366. .where(function() {
  367. if (!admin) {
  368. this.where('prd_versions.product_not_available', false)
  369. }
  370. })
  371. )
  372. }
  373.  
  374. export function prodCartQuery(published: boolean, admin: boolean) {
  375. return (
  376. db
  377. // .with(
  378. // 'prd_sogm',
  379. // db('vm_orders_by_products')
  380. // .select([db.raw("min(replace(actual__gm,'%', '')) as min_sogm"), 'product_id as sogm_product_id'])
  381. // .where('is_product_consolidated', true)
  382. // .whereRaw("replace(actual__gm,'%', '') > replace(non_cons_gm,'%', '')")
  383. // .groupBy('sogm_product_id')
  384. // )
  385.  
  386. .from('prd_versions')
  387. // Product
  388.  
  389. .joinRaw('LEFT JOIN prd_images USING (prd_ver_id)')
  390. .joinRaw('LEFT JOIN prd_inventory USING (prd_ver_id)')
  391. .joinRaw('LEFT JOIN prd_upcs USING (prd_ver_id)')
  392.  
  393. .joinRaw('JOIN shp_packs USING (prd_ver_id)')
  394. .joinRaw('JOIN shp_pack_prices USING (shp_pack_id)')
  395.  
  396. // Warehouse
  397.  
  398. .joinRaw('JOIN org_warehouses USING (org_warehouse_id)')
  399. .joinRaw('left JOIN org_warehouse_settings USING (org_warehouse_id)')
  400. .joinRaw('JOIN orgs USING (org_id)')
  401. .joinRaw('JOIN org_phones USING (org_phone_id)')
  402. .joinRaw('JOIN org_addresses USING (org_address_id)')
  403. // .joinRaw('LEFT JOIN prd_sogm on sogm_product_id = prd_versions.product_id')
  404. // Default where
  405.  
  406. .where(function() {
  407. if (published) {
  408. this.where('prd_versions.product_published', true)
  409. }
  410. })
  411.  
  412. .whereNull('prd_versions.end_at')
  413. .whereNull('shp_pack_prices.dt_to')
  414. .whereNull('prd_inventory.dt_to')
  415. .where(function() {
  416. if (!admin) {
  417. this.where('prd_versions.product_not_available', false)
  418. }
  419. })
  420. )
  421. }
  422.  
  423. export function prodPreviewQuery(published: boolean, admin: boolean) {
  424. return (
  425. db
  426. // .with(
  427. // 'prd_sogm',
  428. // db('vm_orders_by_products')
  429. // .select([db.raw("min(replace(actual__gm,'%', '')) as min_sogm"), 'product_id as sogm_product_id'])
  430. // .where('is_product_consolidated', true)
  431. // .whereRaw("replace(actual__gm,'%', '') > replace(non_cons_gm,'%', '')")
  432. // .groupBy('sogm_product_id')
  433. // )
  434.  
  435. .from('prd_versions')
  436. // Product
  437.  
  438. .joinRaw('LEFT JOIN prd_images USING (prd_ver_id)')
  439. .joinRaw('LEFT JOIN prd_inventory USING (prd_ver_id)')
  440. .joinRaw('LEFT JOIN prd_upcs USING (prd_ver_id)')
  441. .joinRaw('JOIN shp_packs USING (prd_ver_id)')
  442. .joinRaw('JOIN shp_pack_prices USING (shp_pack_id)')
  443. // .joinRaw('LEFT JOIN shp_pack_images on shp_pack_images.spi_shp_pack_id = shp_packs.shp_pack_id')
  444. // .joinRaw('LEFT JOIN shp_packs_upcs on shp_packs.shp_pack_id = shp_packs_upcs.shp_pack_id')
  445.  
  446. // Warehouse
  447.  
  448. .joinRaw('JOIN org_warehouses USING (org_warehouse_id)')
  449. .joinRaw('left JOIN org_warehouse_settings USING (org_warehouse_id)')
  450. .joinRaw('JOIN orgs USING (org_id)')
  451. .joinRaw('JOIN org_phones USING (org_phone_id)')
  452. .joinRaw('JOIN org_addresses USING (org_address_id)')
  453.  
  454. // .joinRaw('LEFT JOIN prd_sogm on sogm_product_id = prd_versions.product_id')
  455.  
  456. // Default where
  457.  
  458. .where(function() {
  459. if (published) {
  460. this.where('prd_versions.product_published', true)
  461. }
  462. })
  463.  
  464. .whereNull('prd_versions.end_at')
  465. .whereNull('shp_pack_prices.dt_to')
  466. .whereNull('prd_inventory.dt_to')
  467. .where(function() {
  468. if (!admin) {
  469. this.where('prd_versions.product_not_available', false)
  470. }
  471. })
  472. )
  473. // .columns([
  474. // // 'prd_versions.prd_ver_id',
  475. // // 'prd_versions.product_id',
  476. // // 'prd_versions.org_warehouse_id',
  477. // // 'prd_versions.product_status',
  478. // // 'prd_versions.product_published',
  479. // // 'prd_versions.is_frozen',
  480. // // 'prd_versions.is_perishable',
  481. // // 'prd_versions.is_refrigirated',
  482. // // 'prd_versions.rotate_vertical',
  483. // // 'prd_versions.product_title',
  484. // // 'prd_versions.product_descr',
  485. // // 'prd_versions.shelf_life',
  486. // // 'prd_versions.case_cube',
  487. // // 'prd_versions.srp',
  488. // // 'prd_versions.unit_type',
  489. // // 'prd_versions.unit_size',
  490. // // 'prd_versions.units_per_case',
  491. // // 'prd_versions.product_width',
  492. // // 'prd_versions.product_height',
  493. // // 'prd_versions.product_length',
  494. // // 'prd_versions.product_weight',
  495. // // 'prd_cat_products.*',
  496. // // 'prd_categories.*',
  497. // // 'prd_product_target.*',
  498. // // 'prd_target_lst.*',
  499. // // 'prd_sold_at.*',
  500. // // 'prd_sold_at_lst.*',
  501. // // 'prd_images.*',
  502. // // 'prd_inventory.*',
  503. // // 'prd_upcs.*',
  504. // // 'shp_packs.*',
  505. // // 'shp_pack_prices.*',
  506. // // 'org_warehouses.*',
  507. // // 'orgs.*',
  508. // // 'org_phones.*',
  509. // // 'org_addresses.*',
  510. // '*',
  511. // db.raw('ROUND(EXTRACT(epoch from shelf_life) / ( 3600 * 24 * 30 * 12)) as shelf_life'),
  512. // db.raw('EXTRACT(day from will_ship_within) as will_ship_within_days'),
  513. // ])
  514. }
  515.  
  516. export default class Product {
  517. static async saveDraft(data: any, org_warehouse_id: number, req_id: string = 'not_set') {
  518. return db('prd_drafts')
  519. .insert({
  520. data,
  521. org_warehouse_id,
  522. })
  523. .then(() => {
  524. log(req_id, 'info', 'saveDraft', {
  525. data,
  526. org_warehouse_id,
  527. })
  528. })
  529. .catch(err => {
  530. let nerr
  531.  
  532. if (+err.code === 23503) {
  533. nerr = srvError(new VError('No such org_warehouse_id = %d', org_warehouse_id), 'saveDraft')
  534. } else {
  535. nerr = srvError(err, 'saveDraft')
  536. }
  537.  
  538. log(
  539. req_id,
  540. 'error',
  541. 'saveDraft',
  542. {
  543. data,
  544. org_warehouse_id,
  545. },
  546. null,
  547. nerr
  548. )
  549.  
  550. throw nerr
  551. })
  552. }
  553.  
  554. static async getDrafts(org_warehouse_id: number, req_id: string = 'not set') {
  555. return db('prd_drafts')
  556. .column(['created_at', 'data'])
  557. .where('org_warehouse_id', org_warehouse_id)
  558. .tap(() => {
  559. log(req_id, 'info', 'getDrafts', {
  560. org_warehouse_id,
  561. })
  562. })
  563. .catch(err => {
  564. let nerr = srvError(err, 'getDrafts')
  565. log(
  566. req_id,
  567. 'error',
  568. 'getDrafts',
  569. {
  570. org_warehouse_id,
  571. },
  572. null,
  573. nerr
  574. )
  575.  
  576. throw nerr
  577. })
  578. }
  579.  
  580. _req_id: string
  581.  
  582. setReqId(req_id: string) {
  583. this._req_id = req_id
  584. }
  585.  
  586. static getProductsByWarehouse(org_warehouse_id: number, page: number, limit: number, published: any, filters: ?any, product_title: ?string, preview: ?any, store_id: ?number, warehouse_id: number) {
  587. debug({
  588. preview,
  589. })
  590. // preview = true
  591. let columns = preview ? product_preview_columns : product_columns
  592. let q = (preview ? prodPreviewQuery : prodQuery)(published || false)
  593. .whereIn(
  594. 'prd_versions.prd_ver_id',
  595. db('prd_versions')
  596. .pluck('prd_ver_id')
  597. .distinct()
  598. .modify(limitQuery, page, limit)
  599. .joinRaw('join prd_inventory using(prd_ver_id)')
  600. .where('prd_versions.org_warehouse_id', org_warehouse_id)
  601. .andWhere('prd_versions.product_not_available', false)
  602.  
  603. .where(function() {
  604. if (published) {
  605. this.where('prd_versions.product_published', true)
  606. }
  607. })
  608. .where(function() {
  609. if (product_title) {
  610. this.where('prd_versions.product_title', 'ILIKE', `%${product_title}%`)
  611. }
  612. })
  613. .where(function() {
  614. if (filters && filters.length) {
  615. filters.map(filter => {
  616. if (filter == 1) return this.where('prd_versions.product_published', true)
  617. if (filter == 2) return this.where('prd_versions.product_published', false)
  618. if (filter == 3) return this.where('prd_inventory.inventory', '<', 20)
  619. })
  620. }
  621. })
  622. .whereNull('prd_versions.end_at')
  623. )
  624. .joinRaw('JOIN products USING (product_id)')
  625. .orderBy('products.created_at', 'desc')
  626. if (warehouse_id != null) {
  627. q.joinRaw('LEFT JOIN prd_tag_con USING (prd_ver_id)')
  628. .joinRaw('LEFT JOIN prd_tag_lst USING (prd_tag_id)')
  629. .columns([...columns, 'products.created_at as created_at', 'prd_tag_lst.prd_tag_id', 'prd_tag_lst.prd_tag'])
  630. } else {
  631. q.columns([...columns, 'products.created_at as created_at'])
  632. }
  633. // debug('query to-->', q.toString())
  634. return q
  635. .then(s => {
  636. return s
  637. })
  638. .then(getters.product)
  639. .then(async pr => {
  640. const { total } = await db('prd_versions')
  641. .joinRaw('join prd_inventory using(prd_ver_id)')
  642. .count('prd_ver_id as total')
  643. .distinct()
  644. .where('prd_versions.org_warehouse_id', org_warehouse_id)
  645. .where('prd_versions.product_not_available', false)
  646. .whereNull('prd_inventory.dt_to')
  647. .where(function() {
  648. if (published) {
  649. this.where('prd_versions.product_published', true)
  650. }
  651. })
  652. .where(function() {
  653. if (product_title) {
  654. this.where('prd_versions.product_title', 'ILIKE', `%${product_title}%`)
  655. }
  656. })
  657. .where(function() {
  658. if (filters && filters.length) {
  659. filters.map(filter => {
  660. if (filter == 1) return this.where('prd_versions.product_published', true)
  661. if (filter == 2) return this.where('prd_versions.product_published', false)
  662. if (filter == 3) return this.where('prd_inventory.inventory', '<', 20)
  663. })
  664. }
  665. })
  666. .whereNull('prd_versions.end_at')
  667. .first()
  668. if (store_id) {
  669. pr = await this.updateFreeFillOnProducts(pr, store_id)
  670. }
  671.  
  672. return {
  673. products: pr,
  674. total,
  675. }
  676. })
  677. }
  678.  
  679. static async productsByInterval(days: number, term: ?string, page: number, limit: number, store_id: ?number) {
  680. const sub = db.select('prd_ver_id').from(function() {
  681. this.from('prd_versions')
  682. .select('prd_versions.prd_ver_id', 'products.created_at')
  683. .distinct()
  684. // .modify(limitQuery, page, limit)
  685. .limit(limit)
  686. .offset(page * limit)
  687. .whereNull('prd_versions.end_at')
  688. .where('prd_versions.product_published', true)
  689. .where('prd_versions.product_not_available', false)
  690. .where(function() {
  691. if (term) {
  692. this.where('warehouse_name', 'ILIKE', `%${term}%`).orWhere('product_title', 'ILIKE', `%${term}%`)
  693. }
  694. })
  695. .joinRaw('JOIN products USING (product_id)')
  696. .whereRaw(`products.created_at >= current_date - interval '${days} days'`)
  697. .orderBy('products.created_at', 'desc')
  698. .as('a')
  699. })
  700. // debug('sub query', sub.toString())
  701. const q = prodPreviewQuery(true)
  702. .whereIn('prd_versions.prd_ver_id', sub)
  703. .joinRaw('JOIN products USING (product_id)')
  704. .columns([...product_preview_columns, 'products.created_at as created_at'])
  705. .orderBy('products.created_at', 'desc')
  706.  
  707. // debug('query to string', q.toString())
  708.  
  709. return q.then(getters.product).then(async pr => {
  710. const { total } = await db('prd_versions')
  711. .whereNull('prd_versions.end_at')
  712. .where('prd_versions.product_published', true)
  713. .where('prd_versions.product_not_available', false)
  714. .joinRaw('JOIN products USING (product_id)')
  715. .joinRaw('JOIN org_warehouses USING (org_warehouse_id)')
  716. .whereRaw(`products.created_at >= current_date - interval '${days} days'`)
  717. .where(function() {
  718. if (term) {
  719. this.where('warehouse_name', 'ILIKE', `%${term}%`).orWhere('product_title', 'ILIKE', `%${term}%`)
  720. }
  721. })
  722. .count('prd_versions.prd_ver_id as total')
  723. .first()
  724.  
  725. if (store_id) pr = await this.updateFreeFillOnProducts(pr, store_id)
  726.  
  727. return {
  728. products: pr,
  729. total,
  730. }
  731. })
  732. }
  733.  
  734. static async localProducts(org_store_id: number, page: number, limit: number) {
  735. debug('local products')
  736. console.time('timestate')
  737. let { state } = await db('org_addresses')
  738. .whereIn(
  739. 'org_address_id',
  740. db('orgs')
  741. .joinRaw('JOIN org_stores using(org_id)')
  742. .where({
  743. org_store_id,
  744. })
  745. .select('org_address_id')
  746. .limit(1)
  747. )
  748. .select('state')
  749. .first()
  750. console.timeEnd('timestate')
  751.  
  752. let neighbors_states = neighborsStates.filter(s => s.StateCode == state).map(s => s.NeighborStateCode)
  753. neighbors_states.push(state)
  754.  
  755. console.time('sub')
  756.  
  757. const sub = db.select('prd_ver_id').from(function() {
  758. this.from('org_warehouses')
  759. .joinRaw('join orgs using(org_id)')
  760. .joinRaw('join org_addresses using(org_address_id)')
  761. .joinRaw('join prd_versions using(org_warehouse_id)')
  762. .joinRaw('JOIN products USING (product_id)')
  763. .whereIn('org_addresses.state', neighbors_states)
  764. .whereNull('prd_versions.end_at')
  765. .where('prd_versions.product_published', true)
  766. .where('prd_versions.product_not_available', false)
  767. .orderBy('products.created_at', 'desc')
  768. .limit(limit)
  769. .offset(page * limit)
  770. .distinct()
  771. .columns(['*', 'products.created_at'])
  772. .as('a')
  773. })
  774. console.timeEnd('sub')
  775.  
  776. console.time('qe')
  777. const q = prodPreviewQuery(true)
  778. .whereIn('prd_versions.prd_ver_id', sub)
  779. .joinRaw('JOIN products USING (product_id)')
  780. .columns([...product_preview_columns, 'products.created_at as created_at'])
  781. .orderBy('products.created_at', 'desc')
  782. // debug('q', q.toString())
  783. console.timeEnd('qe')
  784.  
  785. return q.then(getters.product).then(async pr => {
  786. const { total } = await db('org_warehouses')
  787. .joinRaw('join orgs using(org_id)')
  788. .joinRaw('join org_addresses using(org_address_id)')
  789. .joinRaw('join prd_versions using(org_warehouse_id)')
  790. .whereIn('org_addresses.state', neighbors_states)
  791. .whereIn('prd_versions.prd_ver_id', db('shp_packs').select('prd_ver_id'))
  792. .whereNull('prd_versions.end_at')
  793. .where('prd_versions.product_published', true)
  794. .where('prd_versions.product_not_available', false)
  795. .distinct()
  796. .count('prd_versions.prd_ver_id as total')
  797. .first()
  798.  
  799. if (org_store_id) {
  800. pr = await this.updateFreeFillOnProducts(pr, org_store_id)
  801. }
  802. return {
  803. products: pr,
  804. total,
  805. }
  806. })
  807. }
  808.  
  809. static async byCategory(prd_cat_id: number, page: number, limit: number, store_id: ?number) {
  810. return (
  811. prodPreviewQuery(true)
  812. .whereIn(
  813. 'prd_versions.prd_ver_id',
  814. db('prd_cat_rel')
  815. .innerJoin('prd_cat_products', 'prd_cat_products.prd_cat_id', 'prd_cat_rel.sub_prd_cat_id')
  816. .joinRaw('join prd_versions using(prd_ver_id)')
  817. .distinct()
  818. .pluck('prd_ver_id')
  819. .modify(limitQuery, page, limit)
  820. .where('prd_cat_rel.prd_cat_id', prd_cat_id)
  821. .where('prd_versions.product_published', true)
  822. .whereNull('prd_versions.end_at')
  823. )
  824. .joinRaw('JOIN products USING (product_id)')
  825. .orderBy('products.created_at', 'desc')
  826. // .debug()
  827. .columns([...product_preview_columns, 'products.created_at as created_at', 'shp_packs.shp_pack_id as shp_pack_id', 'prd_upcs.type as upc_type', 'products.created_at as created_at', 'shp_packs.title as pack_title', 'shp_packs.prd_ver_id as prd_ver_id'])
  828. .then(getters.product)
  829. .then(async pr => {
  830. const { total } = await db
  831. .count('* as total')
  832. .from(function() {
  833. this.from('prd_cat_rel')
  834. .select('prd_ver_id')
  835. .innerJoin('prd_cat_products', 'prd_cat_products.prd_cat_id', 'prd_cat_rel.sub_prd_cat_id')
  836. .joinRaw('join prd_versions using(prd_ver_id)')
  837. .distinct('prd_ver_id')
  838. .where('prd_cat_rel.prd_cat_id', prd_cat_id)
  839. .where('prd_versions.product_published', true)
  840. .whereNull('prd_versions.end_at')
  841. .as('a')
  842. })
  843. .first()
  844. if (store_id) pr = await this.updateFreeFillOnProducts(pr, store_id)
  845.  
  846. return {
  847. products: pr,
  848. total,
  849. }
  850. })
  851. )
  852. }
  853.  
  854. static async byTag(prd_tag_id: number, page: number, limit: number, store_id: ?number) {
  855. return (
  856. prodPreviewQuery(true)
  857. .whereIn(
  858. 'prd_versions.prd_ver_id',
  859. db('prd_tag_con')
  860. .innerJoin('prd_tag_lst', 'prd_tag_lst.prd_tag_id', 'prd_tag_con.prd_tag_id')
  861. .joinRaw('join prd_versions using(prd_ver_id)')
  862. .distinct()
  863. .pluck('prd_versions.prd_ver_id')
  864. .modify(limitQuery, page, limit)
  865. .where('prd_tag_con.prd_tag_id', prd_tag_id)
  866. .where('prd_versions.product_published', true)
  867. .whereNull('prd_versions.end_at')
  868. )
  869. .joinRaw('JOIN products USING (product_id)')
  870. .orderBy('products.created_at', 'desc')
  871. // .debug()
  872. .columns([...product_preview_columns, 'products.created_at as created_at'])
  873. .then(getters.product)
  874. .then(async pr => {
  875. const { total } = await db
  876. .count('* as total')
  877. .from(function() {
  878. this.from('prd_tag_con')
  879. .select('prd_ver_id')
  880. .innerJoin('prd_tag_lst', 'prd_tag_lst.prd_tag_id', 'prd_tag_con.prd_tag_id')
  881. .joinRaw('join prd_versions using(prd_ver_id)')
  882. .distinct('prd_ver_id')
  883. .where('prd_tag_con.prd_tag_id', prd_tag_id)
  884. .where('prd_versions.product_published', true)
  885. .whereNull('prd_versions.end_at')
  886. .as('a')
  887. })
  888. .first()
  889.  
  890. if (store_id) pr = await this.updateFreeFillOnProducts(pr, store_id)
  891.  
  892. return {
  893. products: pr,
  894. total,
  895. }
  896. })
  897. )
  898. }
  899.  
  900. static simpleSearch(term: string) {
  901. return db('prd_versions')
  902. .joinRaw('join org_warehouses using(org_warehouse_id)')
  903. .whereNull('end_at')
  904. .where('product_not_available', false)
  905. .where(function() {
  906. if (term) {
  907. this.where('product_title', 'ILIKE', `%${term}%`).orWhere('warehouse_name', 'ILIKE', `%${term}%`)
  908. }
  909. })
  910. .distinct()
  911. }
  912.  
  913. static async basedOnPreferences(org_store_id: number) {
  914. let cats = await db('org_store_cat_preferences_con')
  915. .where({
  916. org_store_id,
  917. })
  918. .pluck('prd_cat_id')
  919. let tags = await db('org_store_tag_preferences_con')
  920. .where({
  921. org_store_id,
  922. })
  923. .pluck('prd_tag_id')
  924.  
  925. let p = await db('prd_versions')
  926. .joinRaw('join prd_tag_con using(prd_ver_id)')
  927. .joinRaw('join prd_cat_products USING (prd_ver_id)')
  928. .whereNull('end_at')
  929. .where(function() {
  930. this.whereIn('prd_tag_id', tags).orWhereIn('prd_cat_id', cats)
  931. })
  932. .select('product_id', 'prd_cat_id', 'prd_tag_id')
  933.  
  934. let sort = _.flow(
  935. _.groupBy('product_id'),
  936. _.map(p => ({
  937. product_id: p[0].product_id,
  938. tags: _.uniq(p.map(t => t.prd_tag_id)),
  939. cats: _.uniq(p.map(t => t.prd_cat_id)),
  940. })),
  941. _.map(p => {
  942. let tagsCalc = _.intersectionWith((a, b) => Number(a) == Number(b))(p.tags, tags)
  943. let catsCalc = _.intersectionWith((a, b) => Number(a) == Number(b))(p.cats, cats)
  944. return {
  945. ...p,
  946. match: (catsCalc.length + tagsCalc.length) / (tags.length + cats.length),
  947. orgtag: tags,
  948. orgcat: cats,
  949. tagsCalc,
  950. catsCalc,
  951. }
  952. }),
  953. _.orderBy(p => p.match, ['desc'])
  954. )(p)
  955.  
  956. let buildCat = arr => {
  957. let a = []
  958. arr.forEach(el => {
  959. el.catsCalc.forEach(s => {
  960. a.push({
  961. ...el,
  962. cat: s,
  963. })
  964. })
  965. })
  966. return a
  967. }
  968.  
  969. let buildTag = arr => {
  970. let a = []
  971. arr.forEach(el => {
  972. el.tagsCalc.forEach(s => {
  973. a.push({
  974. ...el,
  975. tag: s,
  976. })
  977. })
  978. })
  979. return a
  980. }
  981.  
  982. let catsBuild = _.flow(
  983. _.filter(c => c.catsCalc.length > 0),
  984. buildCat,
  985. _.groupBy('cat'),
  986. _.map(s =>
  987. _.flow(
  988. _.orderBy(p => p.match, ['desc']),
  989. _.slice(0, 3),
  990. o => ({
  991. cat_id: o[0].cat,
  992. products: o.map(p => p.product_id),
  993. })
  994. )(s)
  995. )
  996. )(sort)
  997.  
  998. let tagsBuild = _.flow(
  999. _.filter(c => c.tagsCalc.length > 0),
  1000. buildTag,
  1001. _.groupBy('tag'),
  1002. _.map(s =>
  1003. _.flow(
  1004. _.orderBy(p => p.match, ['desc']),
  1005. _.slice(0, 3),
  1006. o => ({
  1007. tag_id: o[0].tag,
  1008. products: o.map(p => p.product_id),
  1009. })
  1010. )(s)
  1011. )
  1012. )(sort)
  1013.  
  1014. let productsByCats = await Promise.all(
  1015. catsBuild.map(async p => {
  1016. let cat = await db('prd_categories')
  1017. .where('prd_cat_id', p.cat_id)
  1018. .first()
  1019. let products = await prodPreviewQuery(true)
  1020. .whereIn('prd_versions.product_id', p.products)
  1021. .joinRaw('JOIN products USING (product_id)')
  1022. .whereNull('prd_versions.end_at')
  1023. .where('prd_versions.product_published', true)
  1024. .columns(['*', 'products.created_at as created_at'])
  1025. .then(getters.product)
  1026. return {
  1027. category_title: cat.category_title,
  1028. prd_cat_id: cat.prd_cat_id,
  1029. products,
  1030. }
  1031. })
  1032. )
  1033.  
  1034. let productsByTags = await Promise.all(
  1035. tagsBuild.map(async p => {
  1036. let tag = await db('prd_tag_lst')
  1037. .where('prd_tag_id', p.tag_id)
  1038. .first()
  1039. let products = await prodPreviewQuery(true)
  1040. .whereIn('prd_versions.product_id', p.products)
  1041. .joinRaw('JOIN products USING (product_id)')
  1042. .whereNull('prd_versions.end_at')
  1043. .where('prd_versions.product_published', true)
  1044. .columns(['*', 'products.created_at as created_at'])
  1045. .then(getters.product)
  1046. return {
  1047. prd_tag: tag.prd_tag,
  1048. prd_tag_id: tag.prd_tag_id,
  1049. products,
  1050. }
  1051. })
  1052. )
  1053.  
  1054. return {
  1055. productsByCats,
  1056. productsByTags,
  1057. }
  1058. }
  1059.  
  1060. static getRelavantCategoryListForRealProducts() {
  1061. return db('prd_cat_products')
  1062. .joinRaw('join prd_versions USING (prd_ver_id)')
  1063. .whereNull('prd_versions.end_at')
  1064. .where('prd_versions.product_published', true)
  1065. .distinct()
  1066. .select('prd_cat_id')
  1067. }
  1068.  
  1069. static async byId(prd_ver_id: ?number, product_id: ?number, warehouse_id: ?number, admin: ?boolean, store_id: number) {
  1070. let res = await prodQuery(warehouse_id !== null ? false : true, admin)
  1071. .where(function() {
  1072. if (prd_ver_id) {
  1073. this.where('prd_versions.prd_ver_id', prd_ver_id)
  1074. }
  1075. if (product_id) {
  1076. this.where('prd_versions.product_id', product_id)
  1077. }
  1078. })
  1079. .joinRaw('JOIN products USING (product_id)')
  1080. .columns(['*', 'prd_upcs.type as upc_type', 'prd_upcs.upc', 'prd_upcs.prd_upc_id', 'prd_upcs.prd_ver_id', 'shp_packs.shp_pack_id as shp_pack_id', 'products.created_at as created_at', 'shp_packs.title as pack_title', 'shp_packs.prd_ver_id as prd_ver_id'])
  1081. .then(getters.product)
  1082. .then(r => r[0])
  1083.  
  1084. if (res && store_id) {
  1085. res = await this.updateFreeFillOnProducts([res], store_id)
  1086. res = res[0]
  1087. }
  1088.  
  1089. return res
  1090. }
  1091.  
  1092. static async byIds(prd_ver_id: ?number, product_ids: ?any, warehouse_id: ?number, admin: ?boolean, preview: boolean, store_id: number) {
  1093. debug('by ids func:', { preview, product_ids })
  1094. let res = await (preview ? prodPreviewQuery : prodQuery)(warehouse_id !== null ? false : true, admin)
  1095. .where(function() {
  1096. if (prd_ver_id) {
  1097. this.where('prd_versions.prd_ver_id', prd_ver_id)
  1098. }
  1099. if (product_ids && product_ids.length) {
  1100. this.whereIn('prd_versions.product_id', product_ids)
  1101. }
  1102. })
  1103. .joinRaw('JOIN products USING (product_id)')
  1104. .columns(['*', 'prd_upcs.type as upc_type', 'prd_upcs.upc', 'prd_upcs.prd_upc_id', 'prd_upcs.prd_ver_id', 'prd_upcs.upc', 'shp_packs.shp_pack_id as shp_pack_id', 'products.created_at as created_at', 'shp_packs.title as pack_title', 'shp_packs.prd_ver_id as prd_ver_id'])
  1105.  
  1106. .then(r => getters.product(r))
  1107. if (res && store_id) {
  1108. res = await this.updateFreeFillOnProducts(res, store_id)
  1109. }
  1110. return res
  1111. }
  1112.  
  1113. static async create(obj: any, req_id: string = 'not set', tr: any) {
  1114. let createFunc = async (trx: any) => {
  1115. let product_id
  1116.  
  1117. if (!obj.product_id) {
  1118. ;[product_id] = await trx('products')
  1119. .insert({})
  1120. .returning('product_id')
  1121. } else {
  1122. product_id = obj.product_id
  1123. }
  1124.  
  1125. // prd_versions
  1126.  
  1127. let [prd_ver_id] = await trx('prd_versions')
  1128. .insert({
  1129. product_id,
  1130. org_warehouse_id: obj.org_warehouse_id,
  1131.  
  1132. product_status: obj.info.status,
  1133. product_title: obj.info.name,
  1134. product_descr: obj.info.description,
  1135. shelf_life: `${obj.info.shelf_life} ${obj.info.shelf_life_type}`,
  1136. //dim
  1137.  
  1138. product_width: obj.dim.width,
  1139. product_height: obj.dim.height,
  1140. product_length: obj.dim.length,
  1141. product_weight: obj.dim.weight,
  1142. case_cube: obj.dim.case_cube,
  1143. srp: obj.info.srp,
  1144. deposit: obj.info.deposit,
  1145. unit_type: obj.info.unit_type,
  1146. unit_size: obj.info.unit_size,
  1147. units_per_case: obj.info.units_per_case,
  1148. product_published: obj.info.product_published,
  1149. })
  1150. .returning('prd_ver_id')
  1151.  
  1152. // inventory
  1153.  
  1154. await trx('prd_inventory').insert({
  1155. prd_ver_id,
  1156. inventory: obj.info.inventory,
  1157. })
  1158.  
  1159. // categories
  1160.  
  1161. await trx.batchInsert(
  1162. 'prd_cat_products',
  1163. obj.categories.map(prd_cat_id => {
  1164. return {
  1165. prd_ver_id,
  1166. prd_cat_id,
  1167. }
  1168. })
  1169. )
  1170.  
  1171. // target
  1172.  
  1173. await trx.batchInsert(
  1174. 'prd_product_target',
  1175. obj.market.target_customer.map(prd_target_id => {
  1176. return {
  1177. prd_ver_id,
  1178. prd_target_id,
  1179. }
  1180. })
  1181. )
  1182.  
  1183. // sold at
  1184.  
  1185. await trx.batchInsert(
  1186. 'prd_sold_at',
  1187. obj.market.sold_at.map(prd_sold_at_id => {
  1188. return {
  1189. prd_ver_id,
  1190. prd_sold_at_id,
  1191. }
  1192. })
  1193. )
  1194.  
  1195. // packs
  1196.  
  1197. await Promise.all(
  1198. obj.pack_options.map(async pack => {
  1199. let [shp_container_id] = await trx('shp_containers')
  1200. .insert({
  1201. type: 'pack',
  1202. })
  1203. .returning('shp_container_id')
  1204.  
  1205. let [shp_pack_id] = await trx('shp_packs')
  1206. .insert({
  1207. shp_pack_id: shp_container_id,
  1208. legacy_pack_id: pack.legacy_pack_id || null,
  1209. prd_ver_id,
  1210. free_fill: pack.free_fill || false,
  1211. free_fill_quota: pack.free_fill_quota || 0,
  1212. pack_width: pack.width,
  1213. pack_height: pack.height,
  1214. pack_length: pack['length'],
  1215. pack_weight: pack.weight,
  1216. pack_qua: pack.quantity,
  1217. is_cons: pack.is_consolidate,
  1218. title: pack.title || null,
  1219. })
  1220. .returning('shp_pack_id')
  1221.  
  1222. let shp_pack_upc_id = null
  1223.  
  1224. if (pack.upcs) {
  1225. await Promise.all(
  1226. pack.upcs
  1227. .filter(u => u.pack_upc != null)
  1228. .map(async upc => {
  1229. await trx('shp_packs_upcs').insert({
  1230. shp_pack_id,
  1231. pack_upc: upc.pack_upc,
  1232. pack_type: upc.pack_type,
  1233. })
  1234. })
  1235. )
  1236. }
  1237. await trx('shp_pack_prices').insert({
  1238. shp_pack_id,
  1239. price: pack.price,
  1240. })
  1241.  
  1242. if (pack.images) {
  1243. await Promise.all(
  1244. pack.images.map(async img => {
  1245. await trx('shp_pack_images').insert({
  1246. spi_shp_pack_id: shp_pack_id,
  1247. spi_size: img.size,
  1248. spi_type: img.type,
  1249. spi_name: img.name,
  1250. spi_ext: img.ext,
  1251. spi_file_path: img.file_path,
  1252. spi_image_position: img.position,
  1253. spi_full_name: img.full_name,
  1254. })
  1255. })
  1256. )
  1257. }
  1258. })
  1259. )
  1260.  
  1261. // tags
  1262.  
  1263. if (obj.tags && obj.tags.length) {
  1264. await Promise.all(
  1265. obj.tags.map(async tag => {
  1266. if (+tag) {
  1267. return await trx('prd_tag_con').insert({
  1268. prd_tag_id: +tag,
  1269. prd_ver_id,
  1270. })
  1271. }
  1272.  
  1273. if (typeof tag === 'string') {
  1274. let dbTag = await trx('prd_tag_lst')
  1275. .where({
  1276. prd_tag: tag,
  1277. })
  1278. .first()
  1279.  
  1280. if (dbTag) {
  1281. return await trx('prd_tag_con').insert({
  1282. prd_tag_id: dbTag.prd_tag_id,
  1283. prd_ver_id,
  1284. })
  1285. } else {
  1286. let [prd_tag_id] = await trx('prd_tag_lst')
  1287. .insert({
  1288. prd_tag: tag,
  1289. })
  1290. .returning('prd_tag_id')
  1291.  
  1292. return await trx('prd_tag_con').insert({
  1293. prd_tag_id,
  1294. prd_ver_id,
  1295. })
  1296. }
  1297. }
  1298. })
  1299. )
  1300. }
  1301.  
  1302. // upc
  1303. await Promise.all(
  1304. obj.upc
  1305. .filter(u => u.upc != null)
  1306. .map(async upc => {
  1307. await trx('prd_upcs').insert({
  1308. prd_ver_id,
  1309. upc: upc.upc,
  1310. type: upc.type,
  1311. })
  1312. })
  1313. )
  1314.  
  1315. // images
  1316. if (obj.images) {
  1317. await Promise.all(
  1318. obj.images.map(async img => {
  1319. await trx('prd_images').insert(
  1320. _.assign(
  1321. {
  1322. prd_ver_id,
  1323. },
  1324. _.pick(['size', 'type', 'name', 'ext', 'file_path', 'image_position', 'full_name', 'legacy_image_id', 'primary'], img)
  1325. )
  1326. )
  1327. })
  1328. )
  1329. }
  1330.  
  1331. return {
  1332. product_id,
  1333. prd_ver_id,
  1334. product_published: obj.info.product_published,
  1335. pack_options_size: obj.pack_options.length,
  1336. }
  1337. }
  1338.  
  1339. const action = obj.product_id ? 'update' : 'create'
  1340.  
  1341. try {
  1342. let r
  1343.  
  1344. if (tr) {
  1345. r = await createFunc(tr)
  1346. } else {
  1347. r = await db.transaction(createFunc)
  1348. // TODO refactor all functions like this using TRX
  1349. }
  1350.  
  1351. if (env !== 'test') {
  1352. let findProduct = await ES().search({
  1353. q: `product_id: ${r.product_id}`,
  1354. size: 1000,
  1355. index: es_product_index,
  1356. type: 'product',
  1357. })
  1358.  
  1359. if (findProduct) {
  1360. let es_ids = findProduct.hits.hits.map(doc => doc._id)
  1361. let del = await Promise.all(
  1362. es_ids.map(id =>
  1363. ES().delete({
  1364. index: es_product_index,
  1365. type: 'product',
  1366. id,
  1367. })
  1368. )
  1369. )
  1370. }
  1371.  
  1372. let product = await Product.byId(null, r.product_id, null)
  1373. if (!r.product_published || !r.pack_options_size || !product) {
  1374. debug('product unpulished or no pack items = not indexing')
  1375. log(
  1376. req_id,
  1377. 'info',
  1378. action,
  1379. {
  1380. obj,
  1381. },
  1382. r
  1383. )
  1384. return r
  1385. }
  1386.  
  1387. // debug(product)
  1388. let index = await ES().index({
  1389. index: es_product_index,
  1390. type: 'product',
  1391. body: {
  1392. product_id: r.product_id,
  1393. prd_ver_id: r.prd_ver_id,
  1394. product_title: obj.info.name.toLowerCase(),
  1395. warehouse_name: await db('org_warehouses')
  1396. .where({
  1397. org_warehouse_id: obj.org_warehouse_id,
  1398. })
  1399. .pluck('warehouse_name')
  1400. .map(warehouse_name => warehouse_name.toLowerCase()),
  1401. upc: obj.upc.map(u => u.upc), //('' + obj.upc).toLowerCase(),
  1402. tags: product.tags.filter(t => t.prd_tag_id).map(t => t.prd_tag),
  1403. category_title: await db('prd_categories')
  1404. .whereIn('prd_cat_id', obj.categories)
  1405. .pluck('category_title')
  1406. .map(cat => cat.toLowerCase()),
  1407. },
  1408. })
  1409. }
  1410.  
  1411. log(
  1412. req_id,
  1413. 'info',
  1414. action,
  1415. {
  1416. obj,
  1417. },
  1418. r
  1419. )
  1420. return r
  1421. } catch (err) {
  1422. let nerr = srvError(err, action)
  1423. log(
  1424. req_id,
  1425. 'error',
  1426. action,
  1427. {
  1428. obj,
  1429. },
  1430. null,
  1431. nerr
  1432. )
  1433. throw nerr
  1434. }
  1435. }
  1436.  
  1437. static async update(obj: any, product_id: number, req_id: string = 'not set', trx: any) {
  1438. if (!product_id) {
  1439. throw new Error('missing product id')
  1440. }
  1441. let f = t => {
  1442. return t('prd_versions')
  1443. .update({
  1444. end_at: db.fn.now(),
  1445. })
  1446. .where({
  1447. product_id,
  1448. })
  1449. .whereNull('end_at')
  1450. .then(() => {
  1451. return this.create(
  1452. {
  1453. ...obj,
  1454. product_id,
  1455. },
  1456. req_id,
  1457. t
  1458. )
  1459. })
  1460. }
  1461.  
  1462. if (trx) {
  1463. return f(trx)
  1464. } else {
  1465. return db.transaction(f)
  1466. }
  1467. }
  1468.  
  1469. static async publish(published: boolean, product_id: number, req_id: string = 'not set', trx: any) {
  1470. let f = async t => {
  1471. try {
  1472. let { prd_ver_id } = await t('prd_versions')
  1473. .first()
  1474. .where({
  1475. product_id,
  1476. })
  1477. .whereNull('prd_versions.end_at')
  1478.  
  1479. await t('prd_versions')
  1480. .update({
  1481. product_published: published,
  1482. })
  1483. .where({
  1484. prd_ver_id,
  1485. })
  1486.  
  1487. log(req_id, 'info', 'publish', null, {
  1488. product_id,
  1489. published,
  1490. })
  1491. return
  1492. } catch (err) {
  1493. log(
  1494. req_id,
  1495. 'error',
  1496. 'publish',
  1497. null,
  1498. {
  1499. product_id,
  1500. published,
  1501. },
  1502. err
  1503. )
  1504. srvError(err, 'publish')
  1505. }
  1506. }
  1507.  
  1508. if (trx) {
  1509. await f(trx)
  1510. } else {
  1511. await db.transaction(f)
  1512. }
  1513. return Product.reindexProduct(product_id)
  1514. }
  1515.  
  1516. static async publishAll(published: boolean, org_warehouse_id: number, req_id: string = 'not set', trx: any) {
  1517. let f = async t => {
  1518. try {
  1519. let products = await t('prd_versions')
  1520. .joinRaw('join products using(product_id)')
  1521. .whereNull('prd_versions.end_at')
  1522. .where({
  1523. org_warehouse_id,
  1524. })
  1525.  
  1526. await Promise.all(
  1527. products.map(async product => {
  1528. return t('prd_versions')
  1529. .update({
  1530. product_published: published,
  1531. })
  1532. .where('prd_ver_id', product.prd_ver_id)
  1533. })
  1534. )
  1535.  
  1536. log(req_id, 'info', 'publish', null, {
  1537. org_warehouse_id,
  1538. published,
  1539. })
  1540. return
  1541. } catch (err) {
  1542. debug(err)
  1543. log(
  1544. req_id,
  1545. 'error',
  1546. 'publish',
  1547. null,
  1548. {
  1549. org_warehouse_id,
  1550. published,
  1551. },
  1552. err
  1553. )
  1554. srvError(err, 'publish')
  1555. }
  1556. }
  1557.  
  1558. if (trx) {
  1559. await f(trx)
  1560. } else {
  1561. await db.transaction(f)
  1562. }
  1563.  
  1564. let products = await db('prd_versions')
  1565. .joinRaw('join products using(product_id)')
  1566. .whereNull('prd_versions.end_at')
  1567. .where({
  1568. org_warehouse_id,
  1569. })
  1570. return await Promise.all(products.map(product => Product.reindexProduct(product.product_id)))
  1571. }
  1572.  
  1573. static async notAvailable(product_not_available: boolean, product_id: number, req_id: string = 'not set', trx: any) {
  1574. debug(product_not_available)
  1575. let f = async t => {
  1576. try {
  1577. let { prd_ver_id } = await t('prd_versions')
  1578. .first()
  1579. .where({
  1580. product_id,
  1581. })
  1582. .whereNull('prd_versions.end_at')
  1583.  
  1584. await t('prd_versions')
  1585. .update({
  1586. product_not_available: product_not_available,
  1587. })
  1588. .where({
  1589. prd_ver_id,
  1590. })
  1591.  
  1592. log(req_id, 'info', 'not_available', null, {
  1593. product_id,
  1594. product_not_available,
  1595. })
  1596. return
  1597. } catch (err) {
  1598. log(
  1599. req_id,
  1600. 'error',
  1601. 'not_available',
  1602. null,
  1603. {
  1604. product_id,
  1605. product_not_available,
  1606. },
  1607. err
  1608. )
  1609. srvError(err, 'not_available')
  1610. }
  1611. }
  1612.  
  1613. if (trx) {
  1614. await f(trx)
  1615. } else {
  1616. await db.transaction(f)
  1617. }
  1618. return Product.reindexProduct(product_id)
  1619. }
  1620.  
  1621. static async reindexProduct(product_id: number) {
  1622. if (env !== 'test') {
  1623. let findProduct = await ES().search({
  1624. q: `product_id: ${product_id}`,
  1625. size: 1000,
  1626. index: es_product_index,
  1627. type: 'product',
  1628. })
  1629.  
  1630. if (findProduct) {
  1631. let es_ids = findProduct.hits.hits.map(doc => doc._id)
  1632. let del = await Promise.all(
  1633. es_ids.map(id =>
  1634. ES().delete({
  1635. index: es_product_index,
  1636. type: 'product',
  1637. id,
  1638. })
  1639. )
  1640. )
  1641. }
  1642.  
  1643. let product = await Product.byId(null, product_id, null)
  1644. if (!product || !product.product_published) {
  1645. debug('product unpulished or no pack items = not indexing')
  1646. return
  1647. }
  1648. let index = await ES().index({
  1649. index: es_product_index,
  1650. type: 'product',
  1651. body: {
  1652. product_id: product.product_id,
  1653. prd_ver_id: product.prd_ver_id,
  1654. product_title: product.name.toLowerCase(),
  1655. warehouse_name: product.warehouse.warehouse_name.toLowerCase(),
  1656. upc: product.upc.map(u => u.upc),
  1657. tags: product.tags.filter(t => t.prd_tag_id).map(t => t.prd_tag),
  1658. category_title: product.categories.filter(cat => cat.prd_cat_id).map(cat => cat.category_title.toLowerCase()),
  1659. },
  1660. })
  1661. return true
  1662. }
  1663. return true
  1664. }
  1665.  
  1666. static async categories() {
  1667. let res = await db('prd_cat_rel as r')
  1668. .innerJoin('prd_categories as c', 'c.prd_cat_id', 'r.sub_prd_cat_id')
  1669. .innerJoin('prd_categories as p', 'p.prd_cat_id', 'r.prd_cat_id')
  1670. .columns(['p.prd_cat_id as parent_prd_cat_id', 'p.category_title as parent_category_title', 'c.prd_cat_id as prd_cat_id', 'c.category_title as category_title', 'c.category_image as category_image', 'c.mobile_title as mobile_title'])
  1671.  
  1672. let byParent = _.groupBy('prd_cat_id', res)
  1673.  
  1674. let find = level =>
  1675. _.flow(
  1676. _.filter(k => _.size(k) === level),
  1677. _.map(cat => {
  1678. return {
  1679. prd_cat_id: cat[0].prd_cat_id,
  1680. category_title: cat[0].category_title,
  1681. mobile_title: cat[0].mobile_title ? cat[0].mobile_title : cat[0].category_title,
  1682. category_image: cat[0].category_image,
  1683. sub: findSub(level + 1, cat[0].prd_cat_id),
  1684. }
  1685. })
  1686. )
  1687.  
  1688. let findSub = (level, parent_prd_cat_id) => {
  1689. return _.flow(
  1690. _.filter(k => _.size(k) === level),
  1691. _.filter(
  1692. _.some({
  1693. parent_prd_cat_id,
  1694. })
  1695. ),
  1696. _.map(v =>
  1697. _.reject(
  1698. {
  1699. parent_prd_cat_id,
  1700. },
  1701. v
  1702. )
  1703. ),
  1704. _.map(one => {
  1705. return {
  1706. prd_cat_id: one[0].prd_cat_id,
  1707. category_title: one[0].category_title,
  1708. mobile_title: one[0].mobile_title ? one[0].mobile_title : one[0].category_title,
  1709. category_image: one[0].category_image,
  1710. sub: findSub(level + 1, one[0].prd_cat_id),
  1711. }
  1712. })
  1713. )(byParent)
  1714. }
  1715.  
  1716. return find(1)(byParent)
  1717. }
  1718.  
  1719. static async updateCategories(data) {
  1720. debug('update categories', data.categories)
  1721. let update = async tx => {
  1722. await Promise.all(
  1723. data.categories.map(c => {
  1724. return tx('prd_categories')
  1725. .update({
  1726. category_title: c.category_title,
  1727. category_image: c.category_image,
  1728. mobile_title: c.mobile_title,
  1729. })
  1730. .where('prd_cat_id', c.prd_cat_id)
  1731. })
  1732. )
  1733. }
  1734. return db.transaction(update)
  1735. }
  1736.  
  1737. static async productPerCat(limit: number = 5) {
  1738. return (
  1739. prodQuery(true)
  1740. .with(
  1741. 'a',
  1742. db('prd_cat_products as pc')
  1743. .innerJoin('prd_versions as pv', 'pc.prd_ver_id', 'pv.prd_ver_id')
  1744. .select(['pc.prd_cat_id as sel_prd_cat_id', 'pv.prd_ver_id as sel_prd_ver_id', db.raw('row_number() OVER ( PARTITION BY pc.prd_cat_id ORDER BY pc.prd_cat_id, pc.prd_ver_id DESC ) as n')])
  1745. .where('pv.product_published', true)
  1746. .whereNull('pv.end_at')
  1747. )
  1748. .with('b', db('a').where('n', '<=', limit))
  1749. .innerJoin('b', 'b.sel_prd_ver_id', 'prd_versions.prd_ver_id')
  1750. // .debug()
  1751. .then(
  1752. _.flow(
  1753. _.groupBy('sel_prd_cat_id'),
  1754. _.mapValues(getters.product)
  1755. )
  1756. )
  1757. )
  1758. // .then(debug)
  1759. }
  1760.  
  1761. static async search(query: string, limit: number = 10, page: number = 0, store_id: number) {
  1762. // let rewritten = query.split(' ').map(word => `*${word.toLowerCase()}*`).join(' AND ')
  1763. // debug(query, query.length)
  1764. let esQuery
  1765. if (query.length < 8 || !isNaN(query)) {
  1766. esQuery = {
  1767. multi_match: {
  1768. fields: ['product_title', 'warehouse_name', 'upc', 'tags', 'category_title'],
  1769. type: 'phrase',
  1770. query: query, //rewritten,
  1771. },
  1772. }
  1773. } else {
  1774. let windowSize = query.length - 8
  1775. let rewritten = []
  1776. for (let index = 0; index <= windowSize; index++) {
  1777. rewritten.push(query.substring(index, 8 + index))
  1778. }
  1779. esQuery = {
  1780. bool: {
  1781. should: _.flow(
  1782. _.map(map => ({
  1783. multi_match: {
  1784. fields: ['product_title', 'warehouse_name', 'upc', 'tags', 'category_title'],
  1785. type: 'phrase',
  1786. query: map,
  1787. },
  1788. }))
  1789. )(rewritten),
  1790. minimum_should_match: windowSize,
  1791. },
  1792. }
  1793. // debug('rewritten', rewritten, query, windowSize)
  1794. }
  1795.  
  1796. return (
  1797. ES()
  1798. .search({
  1799. index: es_product_index,
  1800. type: 'product',
  1801. body: {
  1802. from: page * limit,
  1803. size: limit,
  1804. // query: {
  1805. // // query_string: {
  1806. // // fields: [
  1807. // // 'product_title',
  1808. // // 'warehouse_name',
  1809. // // 'upc',
  1810. // // 'category_title',
  1811. // // ],
  1812. // // query: rewritten,
  1813. // // },
  1814. // multi_match: {
  1815. // fields: [
  1816. // 'product_title',
  1817. // 'warehouse_name',
  1818. // 'upc',
  1819. // 'category_title',
  1820. // ],
  1821. // type:'phrase',
  1822. // query: query, //rewritten,
  1823. // },
  1824. // },
  1825. query: esQuery,
  1826. },
  1827. })
  1828. // .then(r => {
  1829. // debug({ all: JSON.stringify(r), hits: JSON.stringify(r.hits.hits.map(a => a._source.product_id)), size: r.hits.hits.length })
  1830. // return r
  1831. // })
  1832. .then(r => ({
  1833. total: r.hits.total,
  1834. hits: r.hits.hits.map(pr => ({
  1835. score: pr._score,
  1836. id: pr._source.prd_ver_id,
  1837. })),
  1838. }))
  1839. .then(async pr => {
  1840. // debug('pr-->', pr)
  1841. return {
  1842. products: await prodPreviewQuery(true)
  1843. .whereIn('prd_ver_id', pr.hits.map(p => p.id))
  1844. .joinRaw('JOIN products USING (product_id)')
  1845. .columns([...product_preview_columns, 'products.created_at as created_at']),
  1846. es: pr,
  1847. }
  1848. })
  1849. .then(async pr => {
  1850. let products = getters.product(pr.products).map(pro => {
  1851. const score = _.find(es => es.id == pro.prd_ver_id, pr.es.hits)
  1852. return {
  1853. ...pro,
  1854. score: score.score,
  1855. }
  1856. })
  1857. if (store_id) {
  1858. products = await this.updateFreeFillOnProducts(products, store_id)
  1859. }
  1860. return {
  1861. products: _.sortBy('score', products).reverse(),
  1862. total: pr.es.total,
  1863. }
  1864. })
  1865. )
  1866. }
  1867.  
  1868. static async searchSuggestions(query: string) {
  1869. let productsObj = {}
  1870. let getProductCategories = async prd_ver_id => {
  1871. if (productsObj[prd_ver_id]) return productsObj[prd_ver_id]
  1872. let pr = await db('prd_cat_products')
  1873. .joinRaw('JOIN prd_categories using(prd_cat_id)')
  1874. .where('prd_ver_id', prd_ver_id)
  1875. .andWhere('category_title', 'ILIKE', `%${query}%`)
  1876. productsObj[prd_ver_id] = pr
  1877.  
  1878. return pr
  1879. }
  1880. let term = field => {
  1881. if (query.length < 8 || !isNaN(query)) {
  1882. return {
  1883. index: es_product_index,
  1884. size: 100,
  1885. type: 'product',
  1886. body: {
  1887. query: {
  1888. match_phrase: {
  1889. [field]: query,
  1890. },
  1891. },
  1892. },
  1893. }
  1894. } else {
  1895. let windowSize = query.length - 8
  1896. let rewritten = []
  1897. for (let index = 0; index <= windowSize; index++) {
  1898. rewritten.push(query.substring(index, 8 + index))
  1899. }
  1900. let a = {
  1901. index: es_product_index,
  1902. size: 100,
  1903. type: 'product',
  1904. body: {
  1905. query: {
  1906. bool: {
  1907. should: _.flow(
  1908. _.map(map => ({
  1909. match_phrase: {
  1910. [field]: map,
  1911. },
  1912. }))
  1913. )(rewritten),
  1914. minimum_should_match: windowSize,
  1915. },
  1916. },
  1917. },
  1918. }
  1919. return a
  1920. }
  1921. }
  1922. let [products, warehouses, upcs, tags, categories] = await Promise.all([
  1923. ES().search(term('product_title')),
  1924. ES().search(term('warehouse_name')),
  1925. // db('org_warehouses').where('warehouse_name', 'ILIKE', `%${query}%`).columns(['org_warehouse_id', 'warehouse_name']).limit(100),
  1926. ES().search(term('upc')),
  1927. ES().search(term('tags')),
  1928. ES().search(term('category_title')),
  1929. // db('prd_categories').where('category_title', 'ILIKE', `%${query}%`).columns(['prd_cat_id', 'category_title']).limit(100),
  1930. ])
  1931. warehouses = await Promise.all(
  1932. _.uniqBy(hit => hit.warehouse_name)(warehouses.hits.hits.map(hit => hit._source)).map(async product => {
  1933. let { org_warehouse_id } = await db('prd_versions')
  1934. .where('prd_ver_id', product.prd_ver_id)
  1935. .pluck('org_warehouse_id')
  1936. .first()
  1937. return {
  1938. warehouse_name: product.warehouse_name,
  1939. org_warehouse_id,
  1940. }
  1941. })
  1942. )
  1943. products = _.uniqBy(hit => hit.product_title)(products.hits.hits.map(hit => hit._source)).map(product => {
  1944. return {
  1945. product_title: product.product_title,
  1946. product_id: product.product_id,
  1947. }
  1948. })
  1949. let categoriesLst = []
  1950. categories = await Promise.all(
  1951. categories.hits.hits.map(async product => {
  1952. let cats = await getProductCategories(product._source.prd_ver_id)
  1953. cats.forEach(catF => {
  1954. if (!_.find(cat => cat.prd_cat_id == catF.prd_cat_id)(categoriesLst)) {
  1955. categoriesLst.push({
  1956. category_title: catF.category_title,
  1957. prd_cat_id: catF.prd_cat_id,
  1958. })
  1959. }
  1960. })
  1961. })
  1962. )
  1963.  
  1964. return {
  1965. products: _.uniqBy(p => p.product_id)(products),
  1966. warehouses: _.uniqBy(w => w.org_warehouse_id)(warehouses),
  1967. upcs: upcs.hits.hits.map(hit => hit._source),
  1968. tags: tags.hits.hits.map(hit => hit._source),
  1969. categories: _.uniqBy(c => c.prd_cat_id)(categoriesLst),
  1970. }
  1971. }
  1972.  
  1973. static listOfProducts(categories: any, published: any, product_name: string, warehouses: any, limit: any, page: any) {
  1974. let q = db('prd_versions')
  1975. .joinRaw('JOIN org_warehouses USING (org_warehouse_id)')
  1976. .joinRaw('JOIN products USING (product_id)')
  1977. .joinRaw('JOIN shp_packs USING (prd_ver_id)')
  1978.  
  1979. .with(
  1980. 'categories',
  1981. db('prd_cat_products')
  1982. .joinRaw('JOIN prd_categories USING (prd_cat_id)')
  1983. .whereIn('prd_cat_products.prd_cat_id', categories)
  1984. )
  1985.  
  1986. .with(
  1987. 'brands',
  1988. db('users')
  1989. .joinRaw('JOIN usr_user_roles USING (user_id)')
  1990. .joinRaw('JOIN org_rel USING (org_id)')
  1991. .joinRaw('JOIN orgs ON org_rel.child_org_id = orgs.org_id')
  1992. .joinRaw('LEFT JOIN org_warehouses ON org_warehouses.org_id = org_rel.child_org_id')
  1993. .where('orgs.type', 'warehouse')
  1994. )
  1995. .joinRaw('JOIN brands USING (org_warehouse_id)')
  1996. // .joinRaw('JOIN prd_cat_products USING (prd_ver_id)')
  1997. // .joinRaw('JOIN prd_categories USING (prd_cat_id)')
  1998.  
  1999. if (categories.length) {
  2000. // q.whereIn('prd_cat_products.prd_cat_id', [categories])
  2001. q.joinRaw('JOIN categories using(prd_ver_id)')
  2002. }
  2003. if (published != null && published != 'not_available') {
  2004. q.where('prd_versions.product_published', published).where('prd_versions.product_not_available', false)
  2005. }
  2006. if (published === 'not_available') {
  2007. q.where('prd_versions.product_not_available', true)
  2008. }
  2009.  
  2010. if (product_name) {
  2011. q.where('prd_versions.product_title', 'ILIKE', `%${product_name}%`)
  2012. }
  2013.  
  2014. if (warehouses && warehouses.length) {
  2015. q.whereIn('org_warehouses.org_warehouse_id', warehouses)
  2016. }
  2017.  
  2018. q.whereNull('prd_versions.end_at')
  2019. .limit(limit)
  2020. .offset(page * limit)
  2021. .orderBy('products.created_at', 'desc')
  2022. .columns(['prd_versions.product_published', 'prd_versions.product_not_available', 'prd_versions.product_title', 'products.product_id', 'brands.warehouse_name', 'brands.email', 'products.created_at as created_at'])
  2023. return q
  2024. }
  2025.  
  2026. // static async getProductOrderHistory(product_id, org_store_id) {
  2027. // let q = db
  2028. // .with(
  2029. // 'deliverd_at',
  2030. // db
  2031. // .from(
  2032. // db('ord_snapshots')
  2033. // .joinRaw('join ord_item_history using(ord_snapshot_id)')
  2034. // .columns(['order_id as deliverd_at_order_id', 'ord_item_history.created_at as status_created_at', db.raw('max(ord_item_status_id) over (PARTITION BY order_id) as ord_item_status_id'), db.raw('row_number() over(PARTITION BY order_id)')])
  2035. // .as('t')
  2036. // )
  2037. // .where('t.row_number', 1)
  2038. // )
  2039. // .from('ord_snapshots')
  2040. // .joinRaw('join orders USING (order_id)')
  2041. // .joinRaw('join ord_items USING (ord_snapshot_id)')
  2042. // .joinRaw('join ord_stores USING (ord_snapshot_id)')
  2043. // .joinRaw('join shp_packs USING (shp_pack_id)')
  2044. // .joinRaw('join shp_pack_prices using(shp_pack_id)')
  2045. // .joinRaw('join shp_containers on shp_packs.shp_pack_id = shp_containers.shp_container_id')
  2046. // .joinRaw('join shp_packages on shp_containers.shp_container_id = shp_packages.shp_container_id and shp_packages.ord_snapshot_id = ord_items.ord_snapshot_id')
  2047.  
  2048. // .joinRaw('join prd_versions USING (prd_ver_id)')
  2049. // .joinRaw('join ord_warehouse_metadata using(order_id)')
  2050. // .joinRaw('LEFT JOIN deliverd_at on deliverd_at.deliverd_at_order_id = ord_snapshots.order_id')
  2051. // .columns(['orders.order_id', 'orders.created_at', 'ord_items.cart_pack_qua', 'shp_packs.shp_pack_id', 'shp_packs.pack_qua', 'deliverd_at.ord_item_status_id as ord_item_status_id', 'shp_pack_prices.price', 'shp_packages.shp_cons_rate', 'shp_packages.package_quantity', 'deliverd_at.status_created_at', 'shp_packages.shp_package_id'])
  2052. // .where('prd_versions.product_id', product_id)
  2053. // .where(function() {
  2054. // if (org_store_id) {
  2055. // this.where('ord_stores.org_store_id', org_store_id)
  2056. // }
  2057. // })
  2058. // .where(function() {
  2059. // this.whereRaw('orders.created_at BETWEEN shp_pack_prices.dt_from and shp_pack_prices.dt_to')
  2060. // .orWhereRaw('orders.created_at >= shp_pack_prices.dt_from and shp_pack_prices.dt_to IS NULL')
  2061. // .orWhereNull('shp_pack_prices.shp_pack_id')
  2062. // })
  2063. // .distinct(['orders.order_id', 'orders.created_at'])
  2064.  
  2065. // debug(q.toString())
  2066. // let res = await q
  2067.  
  2068. // //TODO: fix group by shp_packs look at TASK build_ord_lines
  2069.  
  2070. // return _.flow(
  2071. // _.groupBy('order_id'),
  2072. // _.map(o => {
  2073. // let cart_pack_qua = Object.keys(_.flow(_.groupBy('shp_package_id'))(o)).length
  2074. // cart_pack_qua = cart_pack_qua == 1 ? o[0].package_quantity : cart_pack_qua
  2075. // return {
  2076. // order_id: o[0].order_id,
  2077. // created_at: o[0].created_at,
  2078. // cart_pack_qua: cart_pack_qua,
  2079. // shp_pack_id: o[0].shp_pack_id,
  2080. // pack_qua: o[0].pack_qua,
  2081. // ord_item_status_id: o[0].ord_item_status_id,
  2082. // status_created_at: o[0].status_created_at,
  2083. // total: (+o[0].price + +o[0].shp_cons_rate) * +cart_pack_qua,
  2084. // }
  2085. // })
  2086. // )(res)
  2087. // }
  2088.  
  2089. static async getProductOrderHistory(product_id, org_store_id) {
  2090. let q = await db('ord_items_metadata')
  2091. .count()
  2092. .joinRaw('join orders USING (order_id)')
  2093. .where('org_store_id', org_store_id)
  2094. .andWhere('product_id', product_id)
  2095. .first()
  2096.  
  2097. return q
  2098. }
  2099.  
  2100. static async getProductOrderHistoryDetails(product_id: number, org_store_id: number) {
  2101. let q = await db
  2102. .with(
  2103. 'deliverd_at',
  2104. db
  2105. .from(
  2106. db('ord_snapshots')
  2107. .joinRaw('join ord_item_history using(ord_snapshot_id)')
  2108. .columns(['order_id as deliverd_at_order_id', 'ord_item_history.created_at as status_created_at', db.raw('max(ord_item_status_id) over (PARTITION BY order_id) as ord_item_status_id'), db.raw('row_number() over(PARTITION BY order_id)')])
  2109. .as('t')
  2110. )
  2111. .where('t.row_number', 1)
  2112. )
  2113. .from('ord_items_metadata')
  2114. .joinRaw('join ord_store_metadata USING (order_id)')
  2115. .joinRaw('join shp_packs USING (shp_pack_id)')
  2116. .joinRaw('LEFT JOIN deliverd_at on deliverd_at.deliverd_at_order_id = ord_items_metadata.order_id')
  2117. .joinRaw('join ord_warehouse_metadata on ord_warehouse_metadata.order_id = ord_items_metadata.order_id and ord_warehouse_metadata.org_warehouse_id = ord_items_metadata.org_warehouse_id')
  2118. .where(function() {
  2119. if (org_store_id) {
  2120. this.where('org_store_id', org_store_id)
  2121. }
  2122. })
  2123. .where('product_id', product_id)
  2124.  
  2125. return _.flow(
  2126. _.groupBy('order_id'),
  2127. _.map(o => o[0])
  2128. )(q)
  2129. }
  2130.  
  2131. static async reindex() {
  2132. let products = await db('prd_versions')
  2133. .joinRaw('LEFT JOIN prd_cat_products USING (prd_ver_id)')
  2134. .joinRaw('LEFT JOIN prd_cat_rel ON prd_cat_rel.sub_prd_cat_id = prd_cat_products.prd_cat_id')
  2135. .joinRaw('LEFT JOIN prd_categories ON prd_categories.prd_cat_id = prd_cat_rel.prd_cat_id')
  2136.  
  2137. // UPC
  2138.  
  2139. .joinRaw('LEFT JOIN prd_upcs USING (prd_ver_id)')
  2140. .joinRaw('LEFT JOIN prd_tag_con USING (prd_ver_id)')
  2141. .joinRaw('LEFT JOIN prd_tag_lst USING (prd_tag_id)')
  2142.  
  2143. .joinRaw('JOIN shp_packs USING (prd_ver_id)')
  2144. .joinRaw('JOIN shp_pack_prices USING (shp_pack_id)')
  2145.  
  2146. // Warehouse
  2147.  
  2148. .joinRaw('JOIN org_warehouses USING (org_warehouse_id)')
  2149.  
  2150. .where('prd_versions.product_published', true)
  2151. .whereNull('prd_versions.end_at')
  2152.  
  2153. .columns(['product_id', 'prd_ver_id', db.raw('lower(product_title) as product_title'), db.raw('lower(warehouse_name) as warehouse_name'), db.raw('array_agg(DISTINCT lower(upc)) as upc'), db.raw('array_agg(DISTINCT lower(prd_tag)) as tags'), db.raw('array_agg(DISTINCT lower(category_title)) as category_title')])
  2154. .groupByRaw('prd_ver_id, prd_ver_id, product_title, warehouse_name')
  2155.  
  2156. let reindex = _.flow(
  2157. _.map(r => {
  2158. return [
  2159. {
  2160. index: {
  2161. _index: es_product_index,
  2162. _type: 'product',
  2163. },
  2164. },
  2165. r,
  2166. ]
  2167. }),
  2168. _.flattenDeep
  2169. )(products)
  2170.  
  2171. return ES()
  2172. .indices.delete({
  2173. index: es_product_index,
  2174. ignore: [404],
  2175. })
  2176. .then(() => {
  2177. return ES().bulk({
  2178. body: [...reindex],
  2179. })
  2180. })
  2181. }
  2182.  
  2183. static async getProductsdetails(product_ids: any) {
  2184. let q = await db('prd_versions')
  2185. .joinRaw('join prd_images using(prd_ver_id)')
  2186. .joinRaw('join prd_upcs using(prd_ver_id)')
  2187. .joinRaw('join prd_cat_products USING (prd_ver_id)')
  2188. .joinRaw('join prd_categories USING (prd_cat_id)')
  2189. .whereIn('product_id', product_ids)
  2190. .whereNull('end_at')
  2191. .where('product_not_available', false)
  2192. .distinct()
  2193.  
  2194. return _.flow(
  2195. _.groupBy('product_id'),
  2196. _.map(p => ({
  2197. images: _.uniqBy(img => img.full_name)(p).map(img => ({
  2198. full_name: img.full_name,
  2199. primary: img.primary,
  2200. })),
  2201. categories: _.uniqBy(cat => cat.category_title)(p).map(cat => ({
  2202. category_title: cat.category_title,
  2203. })),
  2204. product_id: p[0].product_id,
  2205. deposit: p[0].deposit,
  2206. upcs: _.uniqBy(upc => upc.upc)(p).map(upc => ({
  2207. upc: upc.upc,
  2208. })),
  2209. }))
  2210. )(q)
  2211. }
  2212.  
  2213. static async updateStorePreferences(obj) {
  2214. let update = async tx => {
  2215. await tx('org_store_cat_preferences_con')
  2216. .where('org_store_id', obj.org_store_id)
  2217. .del()
  2218. await tx('org_store_tag_preferences_con')
  2219. .where('org_store_id', obj.org_store_id)
  2220. .del()
  2221. let tags = await Promise.all(
  2222. obj.tags.map(tag => {
  2223. return tx('org_store_tag_preferences_con')
  2224. .insert({
  2225. org_store_id: obj.org_store_id,
  2226. prd_tag_id: tag.prd_tag_id,
  2227. })
  2228. .returning('org_store_tag_preference_id')
  2229. })
  2230. )
  2231.  
  2232. let cats = await Promise.all(
  2233. obj.cats.map(cat => {
  2234. return tx('org_store_cat_preferences_con')
  2235. .insert({
  2236. org_store_id: obj.org_store_id,
  2237. prd_cat_id: cat.prd_cat_id,
  2238. })
  2239. .returning('org_store_cat_preference_id')
  2240. })
  2241. )
  2242. return {
  2243. tags,
  2244. cats,
  2245. }
  2246. }
  2247.  
  2248. return db.transaction(update)
  2249. }
  2250. static async updateFreeFillOnProducts(pr: any, store_id: number) {
  2251. // return pr
  2252. this.keys_redis = []
  2253. let global_org_store_settings = await db('org_store_settings')
  2254. .select('settings')
  2255. .where('org_store_id', store_id)
  2256. .union(db('utl_settings').select('settings'))
  2257. .first()
  2258.  
  2259. var reason = {
  2260. free_fill_reason: '',
  2261. bogo_reason: '',
  2262. free_fill_status: 0,
  2263. bogo_status: 0,
  2264. }
  2265.  
  2266. var global_reason = {
  2267. free_fill_reason: '',
  2268. bogo_reason: '',
  2269. free_fill_status: 0,
  2270. bogo_status: 0,
  2271. }
  2272. let products = _.cloneDeep(pr)
  2273. let pass_pre_check = await this.preCheckFFCond(store_id, reason, global_reason)
  2274.  
  2275. let products_upc_boughts_by_retailers = await this.getProductsUpcsBoughtByRetailer(store_id)
  2276. products_upc_boughts_by_retailers = products_upc_boughts_by_retailers.map(o => o.upc)
  2277.  
  2278. let pass_warehouse_cond, pass_store_check, pass_warehouse_check
  2279. for (var i = 0; i < products.length; i++) {
  2280. products[i].product_reason = {
  2281. free_fill_reason: '',
  2282. free_fill_status: 0,
  2283. }
  2284.  
  2285. let org_warehouse_id = products[i].org_warehouse_id,
  2286. product_id = products[i].product_id
  2287.  
  2288. // if (pass_pre_check) {
  2289.  
  2290. pass_store_check = await this.productNotOrderedByStoreAlready(product_id, store_id, reason, products[i], products_upc_boughts_by_retailers)
  2291.  
  2292. if (pass_pre_check && pass_store_check) {
  2293. let warehouse_keys = _.values(FREE_FILL_SETTINGS_COND.warehouse).map(k => `${k}_${org_warehouse_id}`)
  2294.  
  2295. pass_warehouse_check = SingletonCache.getValuesOfKeysToCompare(warehouse_keys, 'free_fill', false)
  2296. debug('pass_warehouse_check', pass_warehouse_check)
  2297.  
  2298. if (pass_warehouse_check.exist === '') {
  2299. pass_warehouse_cond = await this.warehouseCheckFFCond(org_warehouse_id, reason, products[i])
  2300.  
  2301. let free_fill_obj = {
  2302. free_fill: pass_warehouse_cond.free_fill,
  2303. reason,
  2304. product_reason: products[i].product_reason,
  2305. }
  2306. let key = SingletonCache.setKey(pass_warehouse_cond.reason, free_fill_obj)
  2307. // let key = await setRadisGeneratedKey(pass_warehouse_cond.reason, free_fill_obj)
  2308.  
  2309. // this.keys_redis.push(key)
  2310. pass_warehouse_cond = pass_warehouse_cond.free_fill
  2311. } else {
  2312. pass_warehouse_cond = !pass_warehouse_check.exist
  2313. if (pass_warehouse_check.exist) {
  2314. products[i].product_reason = pass_warehouse_check.value[0].value.product_reason
  2315. }
  2316. }
  2317. }
  2318.  
  2319. if (pass_pre_check) {
  2320. reason.free_fill_reason = ''
  2321. reason.free_fill_status = 0
  2322. reason.bogo_reason = ''
  2323. reason.bogo_status = 0
  2324. }
  2325.  
  2326. let pack_options = products[i].pack_options
  2327.  
  2328. for (let j = 0; j < pack_options.length; j++) {
  2329. let pack_option = pack_options[j]
  2330. pack_options[j].promo_reason = {
  2331. free_fill_reason: '',
  2332. bogo_reason: '',
  2333. free_fill_status: 0,
  2334. bogo_status: 0,
  2335. }
  2336. pack_option.left_free_fill_quota = await this.getLeftFreeFillQuotaByShpPack(pack_option.shp_pack_id, pack_option)
  2337. if (pass_pre_check && pass_store_check && pass_warehouse_cond) {
  2338. var bogo = false
  2339. if (global_org_store_settings && global_org_store_settings.settings) {
  2340. bogo = await this.isShpPackTakePartBogoPromo(pack_option, store_id, global_org_store_settings.settings, reason)
  2341. pack_options[j].promo_reason.bogo_reason = reason.bogo_reason
  2342. pack_options[j].promo_reason.bogo_status = reason.bogo_status
  2343. }
  2344. pack_option.bogo = bogo
  2345.  
  2346. if (!pack_option.free_fill || (pack_option.free_fill && pack_option.left_free_fill_quota <= 0)) {
  2347. pack_options[j].promo_reason.free_fill_reason = `B- The specific product pack option ${pack_option.shp_pack_id} is not defined by the brand to take part in promo`
  2348. pack_options[j].promo_reason.free_fill_status = 10
  2349. }
  2350.  
  2351. // removed check of pack_qua>1
  2352. let pack_keys_arr = _.values(FREE_FILL_SETTINGS_COND.pack).map(k => `${k}_${pack_option.shp_pack_id}`)
  2353.  
  2354. let pass_pack_check = SingletonCache.getValuesOfKeysToCompare(pack_keys_arr, 'free_fill', false)
  2355. if (pass_pack_check.exist === '' || pass_pack_check.exist) {
  2356. let pass_pack_cond = await this.packCheckFFCond(pack_options[j], reason)
  2357.  
  2358. pack_options[j].free_fill_by_brand = pack_options[j].left_free_fill_quota > 0
  2359. pack_options[j].free_fill = pack_options[j].free_fill && pass_pack_cond.free_fill
  2360.  
  2361. if (!pack_options[j].free_fill_by_brand) {
  2362. pack_options[j].promo_reason.free_fill_reason = `B- The specific product pack option ${pack_option.shp_pack_id} case pack is not defined by the brand to take part in promo`
  2363. pack_options[j].promo_reason.free_fill_status = 10
  2364. }
  2365.  
  2366. if (!pass_pack_cond.free_fill) {
  2367. SingletonCache.setKey(pass_pack_cond.reason, {
  2368. free_fill: false,
  2369. })
  2370. // this.keys_redis.push(key)
  2371. }
  2372. } else {
  2373. pack_options[j].free_fill_by_brand = pack_options[j].left_free_fill_quota > 0 && pack_options[j].free_fill
  2374. pack_options[j].free_fill = false
  2375. }
  2376. } else {
  2377. debug
  2378. pack_options[j].free_fill_by_brand = pack_option.left_free_fill_quota > 0 && pack_option.free_fill
  2379.  
  2380. pack_options[j].free_fill = false
  2381. pack_options[j].promo_reason.free_fill_reason = products[i].product_reason.free_fill_reason != '' ? products[i].product_reason.free_fill_reason : pack_options[j].promo_reason.free_fill_reason == '' ? global_reason.free_fill_reason : pack_options[j].promo_reason.free_fill_reason
  2382. pack_options[j].promo_reason.free_fill_status = products[i].product_reason.free_fill_status != '' ? products[i].product_reason.free_fill_status : pack_options[j].promo_reason.free_fill_status == '' ? global_reason.free_fill_status : pack_options[j].promo_reason.free_fill_status
  2383.  
  2384. pack_options[j].promo_reason.bogo_reason = global_reason.bogo_reason
  2385. pack_options[j].promo_reason.bogo_status = global_reason.bogo_status
  2386. }
  2387. }
  2388.  
  2389. products[i].pack_options = _.cloneDeep(pack_options)
  2390. }
  2391.  
  2392. SingletonCache.clear()
  2393.  
  2394. return products
  2395. }
  2396.  
  2397. static async preCheckFFCond(store_id: number, reason: any, global_reason: any) {
  2398. // section general
  2399.  
  2400. const data = await db('utl_settings')
  2401. .orderBy('created_at', 'DESC')
  2402. .first()
  2403.  
  2404. if (!data || !data.settings || (data.settings && !data.settings.free_fill)) {
  2405. global_reason.free_fill_reason = 'global data settings not exist or free fill false'
  2406. global_reason.free_fill_status = 1
  2407. return false
  2408. }
  2409.  
  2410. // section f
  2411. let free_fill_promotion_id = 1
  2412. let retailer_participate_in_ff_discount = await db('org_store_ord_promotion_con')
  2413. .joinRaw('join org_store_settings using(org_store_id)')
  2414. .where('ord_promotion_id', free_fill_promotion_id)
  2415. .where('org_store_ord_promotion_con.org_store_id', store_id)
  2416. .first()
  2417.  
  2418. if (!retailer_participate_in_ff_discount || (retailer_participate_in_ff_discount && !retailer_participate_in_ff_discount.settings.free_fill)) {
  2419. global_reason.free_fill_reason = 'F - The retailer not selected in the "Retailers that participate in the FF discount'
  2420. global_reason.free_fill_status = 30
  2421.  
  2422. return false
  2423. }
  2424.  
  2425. let store_settings = retailer_participate_in_ff_discount.settings
  2426. let total_orders_from_brands_taken_ff = await OrdSrv.getOrdersOfStoreFromBrandsTakenThemFF(store_id)
  2427. let at_least_one_order_paid = __.some(total_orders_from_brands_taken_ff, o => Number(o.amount) > 0)
  2428. if (!at_least_one_order_paid) {
  2429. let total_ff_taken = await OrdSrv.getTotalOrdersOfStoreByPeriod(store_id)
  2430. if (Number(total_ff_taken.count) >= Number(store_settings.maximum_amount_ff_can_claim_without_order)) {
  2431. global_reason.free_fill_reason = 'J - Maximum Free Free Fills'
  2432. global_reason.free_fill_status = 55
  2433. return false
  2434. }
  2435. }
  2436.  
  2437. // // section g
  2438. let total_orders_by_period = await OrdSrv.getTotalOrdersOfStoreByPeriod(store_id, store_settings.period_length)
  2439.  
  2440. if (total_orders_by_period && Number(total_orders_by_period.count) >= Number(store_settings.number_free_fill_offering_per_period)) {
  2441. global_reason.free_fill_reason = 'G - The retailer exceed the total amount of FF per day/per period'
  2442. global_reason.free_fill_status = 35
  2443.  
  2444. return false
  2445. }
  2446.  
  2447. let total_orders_per_day = await OrdSrv.getTotalOrdersOfStoreOfToday(store_id, true)
  2448. if (total_orders_per_day && Number(total_orders_per_day.count) >= Number(store_settings.number_free_fill_per_day)) {
  2449. global_reason.free_fill_reason = 'G - The retailer exceed the total amount of FF per day/per period'
  2450. global_reason.free_fill_status = 35
  2451. return false
  2452. }
  2453.  
  2454. // v3 - 636
  2455.  
  2456. // let total_orders_from_brands_taken_ff = await OrdSrv.getOrdersOfStoreFromBrandsTakenThemFF(store_id)
  2457.  
  2458. this.store_settings = store_settings
  2459.  
  2460. return true
  2461. }
  2462.  
  2463. static async warehouseCheckFFCond(warehouse_id, reason, product) {
  2464. let is_warehouse_participated = await db('org_warehouse_ord_promotion_con')
  2465. .joinRaw('join org_warehouse_settings using(org_warehouse_id)')
  2466. .where('org_warehouse_id', warehouse_id)
  2467. .first()
  2468.  
  2469. if (!is_warehouse_participated) {
  2470. reason.free_fill_reason = `E - The brand ${warehouse_id} not selected in the "Brands that participate in the FF discount`
  2471. reason.free_fill_status = 25
  2472.  
  2473. product.product_reason.free_fill_reason = `E - The brand ${warehouse_id} not selected in the Brands that participate in the FF discount`
  2474. product.product_reason.free_fill_status = 25
  2475.  
  2476. return {
  2477. free_fill: false,
  2478. reason: `${FREE_FILL_SETTINGS_COND.warehouse.WAREHOUSE_PARTICIPATE_IN_FF_DISCOUNT_VALID}_${warehouse_id}`,
  2479. }
  2480. }
  2481.  
  2482. let warehouse_settings = is_warehouse_participated.settings
  2483.  
  2484. //section a
  2485. // let sum_orders = await OrdSrv.getSumOrdersOfWarehouseByPeriod(warehouse_id, '30')
  2486.  
  2487. // changed by new task v3-347
  2488. let sum_activation_costs = await OrdSrv.getSumActivationCostOfWarehouseByPeriod(warehouse_id, '30')
  2489. debug('warehouse_id:', warehouse_id, ' sum_activation_costs', sum_activation_costs)
  2490. debug('warehouse_id:', warehouse_id, ' warehouse_settings.activation_spent_limit_per_month', warehouse_settings.activation_spent_limit_per_month)
  2491. if ((sum_activation_costs.sum && Number(sum_activation_costs.sum) >= Number(warehouse_settings.activation_spent_limit_per_month)) || warehouse_settings.activation_spent_limit_per_month == 0) {
  2492. debug('baba')
  2493. reason.free_fill_reason = 'A - The Brand store activation per month is zero or more than what is defined'
  2494. reason.free_fill_status = 5
  2495.  
  2496. product.product_reason.free_fill_reason = 'A - The Brand store activation per month is more than what is defined'
  2497. product.product_reason.free_fill_status = 5
  2498.  
  2499. return {
  2500. free_fill: false,
  2501. reason: `${FREE_FILL_SETTINGS_COND.warehouse.WAREHOUSE_MONTHLY_VOLUME_VALID}_${warehouse_id}`,
  2502. }
  2503. }
  2504.  
  2505. // section c
  2506. let total_items_ordered_from_warehouse = await OrdSrv.getTotalFFItemsFromWarehouse(warehouse_id, '30')
  2507.  
  2508. if (total_items_ordered_from_warehouse && Number(total_items_ordered_from_warehouse.count) >= Number(warehouse_settings.max_items_count_per_month)) {
  2509. reason.free_fill_reason = 'C - the total items ordered from the brand this month is more than what is defined'
  2510. reason.free_fill_status = 15
  2511. product.product_reason.free_fill_reason = 'C - the total items ordered from the brand this month is more than what is defined'
  2512. product.product_reason.free_fill_status = 15
  2513.  
  2514. return {
  2515. free_fill: false,
  2516. reason: `${FREE_FILL_SETTINGS_COND.warehouse.WAREHOUSE_MONTHLY_TOTAL_ITEMS_VALID}_${warehouse_id}`,
  2517. }
  2518. }
  2519.  
  2520. // section d
  2521. let total_shipping_value = await OrdSrv.getTotalShippingValueOfOrdersByWarehouse(warehouse_id, '30')
  2522. let differ_warehouse_shipping = Number(warehouse_settings.max_shipping_limit_value) + Number(warehouse_settings.max_shipping_limit_value) * 0.1
  2523.  
  2524.  
  2525. if (total_shipping_value && Number(total_shipping_value.sum) >= differ_warehouse_shipping) {
  2526. reason.free_fill_reason = 'D - the total FF shipping value is more than 10% of what is defined.'
  2527. reason.free_fill_status = 20
  2528.  
  2529. product.product_reason.free_fill_reason = 'D - the total FF shipping value is more than 10% of what is defined.'
  2530. product.product_reason.free_fill_status = 20
  2531.  
  2532. return {
  2533. free_fill: false,
  2534. reason: `${FREE_FILL_SETTINGS_COND.warehouse.TOTAL_SHIPPING_VALUE_VALID}_${warehouse_id}`,
  2535. }
  2536. }
  2537.  
  2538. return {
  2539. free_fill: true,
  2540. reason: `${FREE_FILL_SETTINGS_COND.warehouse.WAREHOUSE_PASS_CONDITIONS}_${warehouse_id}`,
  2541. }
  2542. }
  2543.  
  2544. static async packCheckFFCond(pack_option, reason) {
  2545. // let count_orders_by_shp_pack_id = await db('shp_packs')
  2546. // .joinRaw('JOIN ord_items_metadata USING (shp_pack_id)')
  2547. // .count()
  2548. // .where('shp_packs.shp_pack_id', pack_option.shp_pack_id)
  2549. // // .andWhereRaw(`created_at >= now() - interval '30 days '`)
  2550. // .first()
  2551.  
  2552. // section i
  2553. let count_orders_by_shp_pack_id = await OrdSrv.getCountFreeFillUsedByShpPack(pack_option.shp_pack_id, 30)
  2554.  
  2555. if (count_orders_by_shp_pack_id && Number(count_orders_by_shp_pack_id.count) >= Number(pack_option.free_fill_quota)) {
  2556. pack_option.promo_reason.free_fill_reason = 'I - the quota of case packs for the given product for was reached'
  2557. pack_option.promo_reason.free_fill_status = 45
  2558.  
  2559. reason.free_fill_reason = 'I - the quota of case packs for the given product for was reached'
  2560. reason.free_fill_status = 45
  2561. return {
  2562. free_fill: false,
  2563. reason: `${FREE_FILL_SETTINGS_COND.pack.MONTHLY_QUOTA_CASE_PACK}_${pack_option.shp_pack_id}`,
  2564. }
  2565. }
  2566. return {
  2567. free_fill: true,
  2568. reason: '',
  2569. }
  2570. }
  2571. static async productNotOrderedByStoreAlready(product_id: number, store_id: number, reason, product, products_retailer_upcs) {
  2572. // section h
  2573. let item_already_ordered_by_store = false
  2574. // let item_already_ordered_by_store = await this.getProductOrderHistory(product_id, store_id)
  2575.  
  2576. // if (item_already_ordered_by_store && item_already_ordered_by_store.count > 0) {
  2577. // product.product_reason.free_fill_reason = `H - item was ordered ${product_id} by the retailer already`
  2578. // product.product_reason.free_fill_status = 40
  2579. // reason.free_fill_reason = `H - item was ordered ${product_id} by the retailer already`
  2580. // reason.free_fill_status = 40
  2581.  
  2582. // return false
  2583. // }
  2584.  
  2585. // changed by task 584
  2586. let product_upcs = product.upc.map(u => u.upc)
  2587.  
  2588. item_already_ordered_by_store = products_retailer_upcs.some(v => product_upcs.indexOf(v) !== -1)
  2589. if (item_already_ordered_by_store) {
  2590. product.product_reason.free_fill_reason = `H1 - upc was ordered by the retailer already`
  2591. product.product_reason.free_fill_status = 40
  2592. reason.free_fill_reason = `H1 - upc was order by the retailer already`
  2593. reason.free_fill_status = 40
  2594.  
  2595. return false
  2596. }
  2597.  
  2598. return true
  2599. }
  2600.  
  2601. static async isShpPackTakePartBogoPromo(pack_option: any, store_id: number, settings: any, reason: any) {
  2602. let days = settings.max_number_days_claim_bogo ? settings.max_number_days_claim_bogo : '30'
  2603.  
  2604. let bogo = await db('ord_store_metadata as osm')
  2605. .joinRaw('JOIN orders USING (order_id)')
  2606. .joinRaw('JOIN ord_items_metadata as oim ON orders.order_id = oim.order_id')
  2607. .where('oim.shp_pack_id', pack_option.shp_pack_id)
  2608. .andWhere('orders.org_store_id', store_id)
  2609. .andWhere('osm.ord_status_id', 6) // status 6 - delivered
  2610. .andWhere('oim.free_fill_used', true)
  2611. .andWhereRaw(`osm.created_at >= now() - interval '${days} days '`)
  2612. .select('oim.free_fill_used')
  2613. .first()
  2614.  
  2615. if (bogo && bogo.free_fill_used) {
  2616. return true
  2617. }
  2618.  
  2619. reason.bogo_reason = `pack is not free fill used or status not delivered yet or order with free fill ordered than ${days}`
  2620. reason.bogo_status = 50
  2621. return false
  2622. }
  2623.  
  2624. static async getFreeFillProducts(store_id: number, limit: number, page: number) {
  2625. debug('getFreeFIllProducts-->', store_id)
  2626. let products = [],
  2627. count = 0,
  2628. reason = {}
  2629. if (store_id) {
  2630. let pass_pre_check = await this.preCheckFFCond(store_id, {}, reason)
  2631. if (Object.keys(reason).length > 0 && reason.free_fill_status == 55) {
  2632. reason.key = 'v3_retailer_ff_block_reason'
  2633. }
  2634. if (pass_pre_check) {
  2635. const data = await db('utl_settings')
  2636. .orderBy('created_at', 'DESC')
  2637. .first()
  2638.  
  2639. if (data && data.settings && data.settings.free_fill) {
  2640. let free_fill_funnel_according_type = data.settings.free_fill_funnel_according_type || 'date_added'
  2641. let total_free_fill_items_per_brand_funnel = data.settings.total_free_fill_items_per_brand_funnel || 5
  2642.  
  2643. debug('total_free_fill_items_per_brand_funnel', total_free_fill_items_per_brand_funnel)
  2644. debug('free_fill_funnel_according_type', free_fill_funnel_according_type)
  2645. let warehouses_query = db
  2646. .with(
  2647. 'activation_spent_warehouses',
  2648. db('ord_items_metadata as om')
  2649. .columns(['org_warehouse_id', db.raw('count(ord_item_metadata_id) as count_ord'), db.raw('sum(org_shp_cons_rate) as sum_shp_cons_rate')])
  2650. .where('om.free_fill_used', true)
  2651.  
  2652. .whereRaw(`om.created_at >= now() - interval '30 days'`)
  2653. .groupBy('om.org_warehouse_id')
  2654. )
  2655. .with(
  2656. 'activation_cost_spent_warehouses',
  2657. db({ om: 'ord_items_metadata', oac: 'org_warehouse_activation_cost' })
  2658. .columns(['org_warehouse_id', db.raw('sum(oac.activation_cost) as sum_activation_cost')])
  2659. .where('om.free_fill_used', true)
  2660. .whereRaw('om.bill_weight BETWEEN oac.from_billable_weight and oac.to_billable_weight')
  2661. .whereRaw(`om.created_at >= now() - interval '30 days'`)
  2662. .groupBy('om.org_warehouse_id')
  2663. )
  2664. .from('org_warehouse_settings')
  2665. .joinRaw('left join activation_spent_warehouses on activation_spent_warehouses.org_warehouse_id = org_warehouse_settings.org_warehouse_id')
  2666. .joinRaw('left join activation_cost_spent_warehouses on activation_cost_spent_warehouses.org_warehouse_id = org_warehouse_settings.org_warehouse_id')
  2667. .whereIn(
  2668. 'org_warehouse_settings.org_warehouse_id',
  2669. db('org_warehouse_ord_promotion_con')
  2670. .select('org_warehouse_id')
  2671. .whereIn(
  2672. 'ord_promotion_id',
  2673. db('ord_promotions')
  2674. .select('ord_promotion_id')
  2675. .where('code', 'free_fill')
  2676. )
  2677. )
  2678. .columns([
  2679. 'org_warehouse_settings.org_warehouse_id',
  2680. db.raw(`json_extract_path_text(org_warehouse_settings.settings::json,
  2681. 'activation_spent_limit_per_month')::numeric - COALESCE(activation_cost_spent_warehouses.sum_activation_cost,0) as differ_smc`),
  2682. db.raw(`json_extract_path_text(org_warehouse_settings.settings::json,
  2683. 'max_items_count_per_month')::numeric - COALESCE(activation_spent_warehouses.count_ord,0) as differ_cr`),
  2684. db.raw(`(json_extract_path_text(org_warehouse_settings.settings::json,
  2685. 'max_shipping_limit_value')::numeric + (json_extract_path_text(org_warehouse_settings.settings::json,
  2686. 'max_shipping_limit_value')::numeric * 0.1)) -
  2687. COALESCE(activation_spent_warehouses.sum_shp_cons_rate,0) as differ_sr`),
  2688. ])
  2689.  
  2690. let products_ids_query = db
  2691. .with(
  2692. 'count_shp_packs',
  2693. db('ord_items_metadata')
  2694. .select('shp_pack_id', db.raw('count(*) as count'))
  2695. .where('free_fill_used', true)
  2696. .whereRaw(`created_at >= now() - interval '30 days'`)
  2697. .groupBy('shp_pack_id')
  2698. )
  2699. .from('prd_versions')
  2700. .joinRaw('JOIN shp_packs USING (prd_ver_id)')
  2701. .joinRaw('left JOIN count_shp_packs on count_shp_packs.shp_pack_id = shp_packs.shp_pack_id')
  2702. .joinRaw('left JOIN prd_upcs on prd_upcs.prd_ver_id = prd_versions.prd_ver_id')
  2703. .whereIn(
  2704. 'org_warehouse_id',
  2705. db
  2706. .select('ms.org_warehouse_id')
  2707. .from(warehouses_query.as('ms'))
  2708. .whereRaw('differ_smc>0 AND differ_cr>0 AND differ_sr>0')
  2709. )
  2710. .whereNull('end_at')
  2711. .where('product_not_available', false)
  2712. .where('product_published', true)
  2713. .where('shp_packs.free_fill', true)
  2714. .whereRaw('((free_fill_quota - count_shp_packs.count > 0) OR (free_fill_quota>0 AND count_shp_packs.count is null))')
  2715. .whereNotIn(
  2716. 'upc',
  2717. db('ord_items_metadata')
  2718. .joinRaw('JOIN orders USING (order_id)')
  2719. .joinRaw('JOIN products USING (product_id)')
  2720. .joinRaw('JOIN prd_versions on prd_versions.product_id = products.product_id ')
  2721. .joinRaw('JOIN prd_upcs on prd_upcs.prd_ver_id = prd_versions.prd_ver_id ')
  2722. .where('org_store_id', store_id)
  2723. .whereNull('end_at')
  2724. .select('upc')
  2725. )
  2726. .distinct()
  2727.  
  2728. switch (free_fill_funnel_according_type) {
  2729. case 'date_added': {
  2730. products_ids_query
  2731. .joinRaw('JOIN products USING (product_id)')
  2732. .columns(['product_id', 'products.created_at', 'org_warehouse_id'])
  2733. .orderBy('products.created_at', 'desc')
  2734. break
  2735. }
  2736. case 'item_added_other_retailers': {
  2737. debug('item_added_other_retailers')
  2738. products_ids_query
  2739. .columns(['product_id', db.raw('count(*) over (PARTITION BY product_id) as count'), 'org_warehouse_id', 'products.created_at'])
  2740. .joinRaw('JOIN products USING (product_id)')
  2741. .orderBy('count', 'desc')
  2742. break
  2743. }
  2744. }
  2745. let getColumns = type => {
  2746. if (type == 'date_added') {
  2747. return ['product_id', 'created_at', 'org_warehouse_id', db.raw('ROW_NUMBER() over (partition by org_warehouse_id order by created_at DESC ) as rownum')]
  2748. }
  2749. if (type == 'item_added_other_retailers') {
  2750. return ['product_id', 'created_at', 'org_warehouse_id', db.raw('row_number() over (partition by org_warehouse_id order by count DESC ) as rownum'), 'count']
  2751. }
  2752. }
  2753.  
  2754. count = await db
  2755. .from(function() {
  2756. this.from(db.raw('? as G', products_ids_query))
  2757. .columns(getColumns(free_fill_funnel_according_type))
  2758. .as('M')
  2759. })
  2760. .where('rownum', '<=', total_free_fill_items_per_brand_funnel)
  2761. .count()
  2762.  
  2763. count = count[0].count
  2764.  
  2765. let q = db
  2766. .select('*')
  2767. .from(function() {
  2768. this.from(db.raw('? as G', products_ids_query))
  2769. .columns(getColumns(free_fill_funnel_according_type))
  2770. .as('M')
  2771. })
  2772. .where('rownum', '<=', total_free_fill_items_per_brand_funnel)
  2773. .limit(limit)
  2774. .offset(page * limit)
  2775.  
  2776. debug('q to-->', q.toString())
  2777.  
  2778. let products_ids = await q
  2779. products_ids = products_ids && products_ids.map(p => p.product_id)
  2780. if (products_ids && products_ids.length > 0) {
  2781. products = await this.byIds(null, products_ids, false, false, true)
  2782. }
  2783. }
  2784. }
  2785. }
  2786.  
  2787. return {
  2788. products,
  2789. total: count,
  2790. reason,
  2791. }
  2792. }
  2793. static async getCountFreeFillLeftByStoreId(store_id: number) {
  2794. let left_ff = 0
  2795. if (store_id) {
  2796. const data = await db('utl_settings')
  2797. .orderBy('created_at', 'DESC')
  2798. .first()
  2799.  
  2800. debug('store_id', store_id)
  2801. if (data && data.settings && data.settings.free_fill) {
  2802. let free_fill_promotion_id = 1
  2803. let store_participated = await db('org_store_ord_promotion_con')
  2804. .joinRaw('join org_store_settings using(org_store_id)')
  2805. .where('ord_promotion_id', free_fill_promotion_id)
  2806. .where('org_store_ord_promotion_con.org_store_id', store_id)
  2807. .first()
  2808. debug('store_participated', store_participated)
  2809.  
  2810. if (store_participated) {
  2811. // // section g
  2812. let total_orders_by_period = await OrdSrv.getTotalOrdersOfStoreByPeriod(store_id, store_participated.settings.period_length)
  2813. debug('total_orders_by_period', total_orders_by_period)
  2814.  
  2815. if (total_orders_by_period && Number(total_orders_by_period.count) >= Number(store_participated.settings.number_free_fill_offering_per_period)) {
  2816. left_ff = 0
  2817. } else {
  2818. let total_ff_used = await OrdSrv.getTotalOrdersOfStoreOfToday(store_id, true)
  2819. debug('total_ff_used', total_ff_used)
  2820. left_ff = store_participated.settings.number_free_fill_per_day - total_ff_used.count
  2821. }
  2822. }
  2823. }
  2824. }
  2825. return left_ff > 0 ? left_ff : 0
  2826. }
  2827.  
  2828. static async getTotalFreeFillProducts() {
  2829. let count = 0
  2830. const data = await db('utl_settings')
  2831. .orderBy('created_at', 'DESC')
  2832. .first()
  2833.  
  2834. if (data && data.settings && data.settings && data.settings.free_fill) {
  2835. let warehouses_query = db
  2836. .with(
  2837. 'activation_spent_warehouses',
  2838. db({ om: 'ord_items_metadata', oac: 'org_warehouse_activation_cost' })
  2839. .columns(['org_warehouse_id', db.raw('sum(oac.activation_cost) as sum_activation_cost'), db.raw('count(ord_item_metadata_id) as count_ord'), db.raw('sum(org_shp_cons_rate) as sum_shp_cons_rate')])
  2840. .where('om.free_fill_used', true)
  2841. .whereRaw('om.bill_weight BETWEEN oac.from_billable_weight and oac.to_billable_weight')
  2842. .whereRaw(`om.created_at >= now() - interval '30 days'`)
  2843. .groupBy('om.org_warehouse_id')
  2844. )
  2845. .from('org_warehouse_settings')
  2846. .joinRaw('left join activation_spent_warehouses on activation_spent_warehouses.org_warehouse_id = org_warehouse_settings.org_warehouse_id')
  2847. .whereIn(
  2848. 'org_warehouse_settings.org_warehouse_id',
  2849. db('org_warehouse_ord_promotion_con')
  2850. .select('org_warehouse_id')
  2851. .whereIn(
  2852. 'ord_promotion_id',
  2853. db('ord_promotions')
  2854. .select('ord_promotion_id')
  2855. .where('code', 'free_fill')
  2856. )
  2857. )
  2858. .columns([
  2859. 'org_warehouse_settings.org_warehouse_id',
  2860. db.raw(`json_extract_path_text(org_warehouse_settings.settings::json,
  2861. 'activation_spent_limit_per_month')::numeric - COALESCE(activation_spent_warehouses.sum_activation_cost,0) as differ_smc`),
  2862. db.raw(`json_extract_path_text(org_warehouse_settings.settings::json,
  2863. 'max_items_count_per_month')::numeric - COALESCE(activation_spent_warehouses.count_ord,0) as differ_cr`),
  2864. db.raw(`(json_extract_path_text(org_warehouse_settings.settings::json,
  2865. 'max_shipping_limit_value')::numeric + (json_extract_path_text(org_warehouse_settings.settings::json,
  2866. 'max_shipping_limit_value')::numeric * 0.1)) -
  2867. COALESCE(activation_spent_warehouses.sum_shp_cons_rate,0) as differ_sr`),
  2868. ])
  2869.  
  2870. let total_ff_products = await db
  2871. .with(
  2872. 'count_shp_packs',
  2873. db('ord_items_metadata')
  2874. .select('shp_pack_id', db.raw('count(*) as count'))
  2875. .where('free_fill_used', true)
  2876. .whereRaw(`created_at >= now() - interval '30 days'`)
  2877. .groupBy('shp_pack_id')
  2878. )
  2879. .from('prd_versions')
  2880. .joinRaw('JOIN shp_packs USING (prd_ver_id)')
  2881. .joinRaw('left JOIN count_shp_packs on count_shp_packs.shp_pack_id = shp_packs.shp_pack_id')
  2882. .joinRaw('left JOIN prd_upcs on prd_upcs.prd_ver_id = prd_versions.prd_ver_id')
  2883. .joinRaw('join org_warehouses ow on ow.org_warehouse_id = prd_versions.org_warehouse_id')
  2884.  
  2885. .whereIn(
  2886. 'prd_versions.org_warehouse_id',
  2887. db
  2888. .select('ms.org_warehouse_id')
  2889. .from(warehouses_query.as('ms'))
  2890. .whereRaw('differ_smc>0 AND differ_cr>0 AND differ_sr>0')
  2891. )
  2892. .whereNull('end_at')
  2893. .where('product_not_available', false)
  2894. .where('product_published', true)
  2895. .where('shp_packs.free_fill', true)
  2896. .whereRaw('((free_fill_quota - count_shp_packs.count > 0) OR (free_fill_quota>0 AND count_shp_packs.count is null))')
  2897. .count()
  2898. count = total_ff_products[0].count
  2899. }
  2900. return {
  2901. count,
  2902. }
  2903. }
  2904.  
  2905. static async getLeftFreeFillQuotaByShpPack(shp_pack_id: number, pack: any) {
  2906. let ff_used_per_shp_pack = await OrdSrv.getCountFreeFillUsedByShpPack(shp_pack_id, 30)
  2907. return pack.free_fill_quota - ff_used_per_shp_pack.count
  2908. }
  2909.  
  2910. static async getHottestProducts(store_id: number, limit: number, days: number) {
  2911. let count = await prodPreviewQuery(true)
  2912. .whereIn(
  2913. 'prd_versions.product_id',
  2914. db.select('product_id').from(function() {
  2915. this.from('ord_items_metadata')
  2916. .select(['product_id', db.raw('count(product_id) OVER (PARTITION BY product_id)')])
  2917. .whereIn(
  2918. 'product_id',
  2919. db('prd_versions')
  2920. .whereNull('prd_versions.end_at')
  2921. .where('prd_versions.product_published', true)
  2922. .where('prd_versions.product_not_available', false)
  2923. .select('product_id')
  2924. )
  2925. .whereRaw(`created_at >= now() - interval '${days} days'`)
  2926. .distinct()
  2927. .as('m')
  2928. })
  2929. )
  2930. .count()
  2931.  
  2932. count = count[0].count
  2933.  
  2934. let products = await prodPreviewQuery(true)
  2935. .whereIn(
  2936. 'prd_versions.product_id',
  2937. db.select('product_id').from(function() {
  2938. this.from('ord_items_metadata')
  2939. .select(['product_id', db.raw('count(product_id) OVER (PARTITION BY product_id)')])
  2940. .whereIn(
  2941. 'product_id',
  2942. db('prd_versions')
  2943. .whereNull('prd_versions.end_at')
  2944. .where('prd_versions.product_published', true)
  2945. .where('prd_versions.product_not_available', false)
  2946. .select('product_id')
  2947. )
  2948. .whereRaw(`created_at >= now() - interval '${days} days'`)
  2949.  
  2950. .orderBy('count', 'DESC')
  2951. .distinct()
  2952. .limit(limit)
  2953. .as('m')
  2954. })
  2955. )
  2956. .joinRaw('join products USING (product_id)')
  2957. .columns([...product_preview_columns, 'products.created_at'])
  2958. .then(getters.product)
  2959.  
  2960. if (store_id) {
  2961. products = await this.updateFreeFillOnProducts(products, store_id)
  2962. }
  2963.  
  2964. return {
  2965. products,
  2966. total: count,
  2967. }
  2968. }
  2969.  
  2970. static async getActivationCostByBillableWeight(billable_weight: number) {
  2971. let activation_cost = await db('org_warehouse_activation_cost')
  2972. .select('activation_cost')
  2973. .where('from_billable_weight', '<=', billable_weight)
  2974. .where('to_billable_weight', '>=', billable_weight)
  2975. .first()
  2976. if (!activation_cost) {
  2977. activation_cost = await db('org_warehouse_activation_cost')
  2978. .select(db.raw('max(activation_cost) as activation_cost'))
  2979. .first()
  2980. }
  2981.  
  2982. return activation_cost
  2983. }
  2984.  
  2985. static async addRecentSearchProductByUserId(data: any) {
  2986. return db('usr_search_term').insert({
  2987. org_store_id: data.org_store_id,
  2988. user_id: data.user_id,
  2989. search_term: data.search_term,
  2990. })
  2991. }
  2992.  
  2993. static async getRecentSearchProductByUserId(user_id: number) {
  2994. let searches = db('usr_search_term')
  2995. .select('search_term')
  2996. .where({ user_id })
  2997.  
  2998. searches = searches && searches.map(s => s.search_term)
  2999. return searches
  3000. }
  3001.  
  3002. static async getPublicFreeFillProducts(limit: number, page: number) {
  3003. let products = [],
  3004. count = 0
  3005. const data = await db('utl_settings')
  3006. .orderBy('created_at', 'DESC')
  3007. .first()
  3008.  
  3009. if (data && data.settings && data.settings.free_fill) {
  3010. let free_fill_funnel_according_type = data.settings.free_fill_funnel_according_type || 'date_added'
  3011. let total_free_fill_items_per_brand_funnel = data.settings.total_free_fill_items_per_brand_funnel || 5
  3012.  
  3013. let warehouses_query = db
  3014. .with(
  3015. 'activation_spent_warehouses',
  3016. db({ om: 'ord_items_metadata', oac: 'org_warehouse_activation_cost' })
  3017. .columns(['org_warehouse_id', db.raw('sum(oac.activation_cost) as sum_activation_cost'), db.raw('count(ord_item_metadata_id) as count_ord'), db.raw('sum(org_shp_cons_rate) as sum_shp_cons_rate')])
  3018. .where('om.free_fill_used', true)
  3019. .whereRaw('om.bill_weight BETWEEN oac.from_billable_weight and oac.to_billable_weight')
  3020. .whereRaw(`om.created_at >= now() - interval '30 days'`)
  3021. .groupBy('om.org_warehouse_id')
  3022. )
  3023. .from('org_warehouse_settings')
  3024. .joinRaw('left join activation_spent_warehouses on activation_spent_warehouses.org_warehouse_id = org_warehouse_settings.org_warehouse_id')
  3025. .whereIn(
  3026. 'org_warehouse_settings.org_warehouse_id',
  3027. db('org_warehouse_ord_promotion_con')
  3028. .select('org_warehouse_id')
  3029. .whereIn(
  3030. 'ord_promotion_id',
  3031. db('ord_promotions')
  3032. .select('ord_promotion_id')
  3033. .where('code', 'free_fill')
  3034. )
  3035. )
  3036. .columns([
  3037. 'org_warehouse_settings.org_warehouse_id',
  3038. db.raw(`json_extract_path_text(org_warehouse_settings.settings::json,
  3039. 'activation_spent_limit_per_month')::numeric - COALESCE(activation_spent_warehouses.sum_activation_cost,0) as differ_smc`),
  3040. db.raw(`json_extract_path_text(org_warehouse_settings.settings::json,
  3041. 'max_items_count_per_month')::numeric - COALESCE(activation_spent_warehouses.count_ord,0) as differ_cr`),
  3042. db.raw(`(json_extract_path_text(org_warehouse_settings.settings::json,
  3043. 'max_shipping_limit_value')::numeric + (json_extract_path_text(org_warehouse_settings.settings::json,
  3044. 'max_shipping_limit_value')::numeric * 0.1)) -
  3045. COALESCE(activation_spent_warehouses.sum_shp_cons_rate,0) as differ_sr`),
  3046. ])
  3047.  
  3048. let products_ids_query = db
  3049. .with(
  3050. 'count_shp_packs',
  3051. db('ord_items_metadata')
  3052. .select('shp_pack_id', db.raw('count(*) as count'))
  3053. .where('free_fill_used', true)
  3054. .whereRaw(`created_at >= now() - interval '30 days'`)
  3055. .groupBy('shp_pack_id')
  3056. )
  3057. .from('prd_versions')
  3058. .joinRaw('JOIN shp_packs USING (prd_ver_id)')
  3059. .joinRaw('left JOIN count_shp_packs on count_shp_packs.shp_pack_id = shp_packs.shp_pack_id')
  3060. .whereIn(
  3061. 'org_warehouse_id',
  3062. db
  3063. .select('ms.org_warehouse_id')
  3064. .from(warehouses_query.as('ms'))
  3065. .whereRaw('differ_smc>0 AND differ_cr>0 AND differ_sr>0')
  3066. )
  3067. .whereNull('end_at')
  3068. .where('product_not_available', false)
  3069. .where('product_published', true)
  3070. .where('shp_packs.free_fill', true)
  3071. .whereRaw('((free_fill_quota - count_shp_packs.count > 0) OR (free_fill_quota>0 AND count_shp_packs.count is null))')
  3072. .distinct()
  3073.  
  3074. switch (free_fill_funnel_according_type) {
  3075. case 'date_added': {
  3076. products_ids_query
  3077. .joinRaw('JOIN products USING (product_id)')
  3078. .columns(['product_id', 'products.created_at', 'org_warehouse_id'])
  3079. .orderBy('products.created_at', 'desc')
  3080. break
  3081. }
  3082. case 'item_added_other_retailers': {
  3083. debug('item_added_other_retailers')
  3084. products_ids_query
  3085. .columns(['product_id', db.raw('count(*) over (PARTITION BY product_id) as count'), 'org_warehouse_id', 'products.created_at'])
  3086. .joinRaw('JOIN products USING (product_id)')
  3087. .orderBy('count', 'desc')
  3088. break
  3089. }
  3090. }
  3091. let getColumns = type => {
  3092. if (type == 'date_added') {
  3093. return ['product_id', 'created_at', 'org_warehouse_id', db.raw('ROW_NUMBER() over (partition by org_warehouse_id order by created_at DESC ) as rownum')]
  3094. }
  3095. if (type == 'item_added_other_retailers') {
  3096. return ['product_id', 'created_at', 'org_warehouse_id', db.raw('row_number() over (partition by org_warehouse_id order by count DESC ) as rownum'), 'count']
  3097. }
  3098. }
  3099. count = await db
  3100. .from(function() {
  3101. this.from(db.raw('? as G', products_ids_query))
  3102. .columns(getColumns(free_fill_funnel_according_type))
  3103. .as('M')
  3104. })
  3105. .where('rownum', '<=', total_free_fill_items_per_brand_funnel)
  3106. .count()
  3107.  
  3108. count = count[0].count
  3109.  
  3110. let q = db
  3111. .select('*')
  3112. .from(function() {
  3113. this.from(db.raw('? as G', products_ids_query))
  3114. .columns(getColumns(free_fill_funnel_according_type))
  3115. .as('M')
  3116. })
  3117. .where('rownum', '<=', total_free_fill_items_per_brand_funnel)
  3118. .limit(limit)
  3119. .offset(page * limit)
  3120.  
  3121. let products_ids = await q
  3122. products_ids = products_ids && products_ids.map(p => p.product_id)
  3123. if (products_ids && products_ids.length > 0) {
  3124. products = await this.byIds(null, products_ids, false, false, true)
  3125. }
  3126. }
  3127.  
  3128. return {
  3129. products,
  3130. total: count,
  3131. }
  3132. }
  3133.  
  3134. static async addOrgStorePromotionByOrdPromotionId(data: any) {
  3135. let org_store_promotion = await db('org_store_ord_promotion_con')
  3136. .where('org_store_id', data.org_store_id)
  3137. .where('ord_promotion_id', data.ord_promotion_id)
  3138. .first()
  3139.  
  3140. if (!org_store_promotion) {
  3141. return db('org_store_ord_promotion_con').insert({
  3142. org_store_id: data.org_store_id,
  3143. ord_promotion_id: data.ord_promotion_id,
  3144. })
  3145. }
  3146. return org_store_promotion
  3147. }
  3148.  
  3149. static async addUserProductNotificationByUserId(data: any) {
  3150. let usr_notification = await db('usr_product_notifications')
  3151. .select('*')
  3152. .where('org_store_id', data.org_store_id)
  3153. .where('user_id', data.user_id)
  3154. .where('product_id', data.product_id)
  3155. .first()
  3156.  
  3157. if (!usr_notification) {
  3158. return db('usr_product_notifications').insert({
  3159. org_store_id: data.org_store_id,
  3160. user_id: data.user_id,
  3161. product_id: data.product_id,
  3162. notification_type: data.notification_type,
  3163. })
  3164. }
  3165. return
  3166. }
  3167.  
  3168. static async addPrdNotOnShelfmintByUserId(data: any) {
  3169. return db('prd_not_on_shelfmint').insert({
  3170. org_store_id: data.org_store_id,
  3171. user_id: data.user_id,
  3172. comment: data.comment,
  3173. images: data.images,
  3174. upc: data.upc,
  3175. })
  3176. }
  3177.  
  3178. static async getProductsNotOnShelfmint() {
  3179. return db('prd_not_on_shelfmint')
  3180. .joinRaw('JOIN org_stores USING (org_store_id)')
  3181. .joinRaw('JOIN users USING (user_id)')
  3182. .joinRaw('JOIN org_phones USING (org_phone_id)')
  3183. .select('prd_not_on_shelfmint_id', 'org_store_id', 'images', 'comment', 'upc', 'prd_not_on_shelfmint.created_at', 'store_name', 'email', 'first_name', 'last_name', 'phone')
  3184. }
  3185.  
  3186. static async getProductsUpcsBoughtByRetailer(store_id) {
  3187. return db('ord_items_metadata')
  3188. .joinRaw('JOIN orders USING (order_id)')
  3189. .joinRaw('JOIN products USING (product_id)')
  3190. .joinRaw('JOIN prd_versions on prd_versions.product_id = products.product_id ')
  3191. .joinRaw('JOIN prd_upcs on prd_upcs.prd_ver_id = prd_versions.prd_ver_id ')
  3192. .where('org_store_id', store_id)
  3193. .whereNull('end_at')
  3194. .select('upc')
  3195. }
  3196.  
  3197. static async getFreeFillStatistics(warehouse_ids: any, warehouse_take_part_ff: boolean, store_ids: any, store_take_part_ff: boolean, shp_pack_take_part_ff: boolean, warehouse_ids_products: any, shp_pack_id: number, product_name: string) {
  3198. let warehouse_statistics = await this.getFreeFillWarehousesStatistics(warehouse_ids, warehouse_take_part_ff)
  3199. let store_statistics = await this.getFreeFillStoresStatistics(store_ids, store_take_part_ff)
  3200.  
  3201. let shp_packs_statistics = await this.getFreeFillShpPacksStatistics(shp_pack_take_part_ff, warehouse_ids_products, shp_pack_id, product_name)
  3202. return {
  3203. warehouse_statistics,
  3204. store_statistics,
  3205. shp_packs_statistics,
  3206. }
  3207. }
  3208.  
  3209. static async getFreeFillStoresStatistics(store_ids: any, store_take_part_ff: boolean) {
  3210. let store_participate_ff = db('org_store_ord_promotion_con')
  3211. .select('org_store_ord_promotion_con.org_store_id')
  3212. .where(
  3213. 'ord_promotion_id',
  3214. db('ord_promotions')
  3215. .select('ord_promotion_id')
  3216. .where('code', 'free_fill')
  3217. )
  3218. if (store_ids && store_ids.length > 0) {
  3219. store_participate_ff.whereIn('org_store_id', store_ids)
  3220. }
  3221. let store_query = db
  3222. .with(
  3223. 'count_free_fill_period',
  3224. db('ord_items_metadata')
  3225. .joinRaw('join orders o on ord_items_metadata.order_id = o.order_id')
  3226. .where('free_fill_used', true)
  3227. .whereRaw(`ord_items_metadata.created_at >= now() - interval '30 days'`)
  3228. .columns(['org_store_id', db.raw('count(ord_item_metadata_id) as count_period')])
  3229. .groupBy('org_store_id')
  3230. )
  3231. .with(
  3232. 'count_free_fill_today',
  3233. db('ord_items_metadata')
  3234. .joinRaw('join orders o on ord_items_metadata.order_id = o.order_id')
  3235. .where('free_fill_used', true)
  3236. .whereRaw(`ord_items_metadata.created_at BETWEEN date_trunc('day', current_timestamp) and date_trunc('day', current_timestamp) + interval '1 day'`)
  3237. .columns(['org_store_id', db.raw('count(ord_item_metadata_id) as count_today')])
  3238. .groupBy('org_store_id')
  3239. )
  3240. .with(
  3241. 'count_general_free_fill',
  3242. db('ord_items_metadata')
  3243. .joinRaw('join orders o on ord_items_metadata.order_id = o.order_id')
  3244. .where('free_fill_used', true)
  3245. .columns(['org_store_id', db.raw('count(ord_item_metadata_id) as count_general')])
  3246. .groupBy('org_store_id')
  3247. )
  3248. .with(
  3249. 'sum_orders_store_from_brand_taken_ff',
  3250. db('ord_store_metadata')
  3251. .joinRaw('join ord_warehouse_metadata using(order_id)')
  3252. .whereIn(
  3253. 'org_warehouse_id',
  3254. db('ord_items_metadata')
  3255. .joinRaw('join orders on ord_items_metadata.order_id = orders.order_id AND orders.org_store_id = ord_store_metadata.org_store_id ')
  3256. .where('free_fill_used', true)
  3257. .select('org_warehouse_id')
  3258. .distinct()
  3259. )
  3260. .columns(['org_store_id', db.raw('sum(amount) as sum_amount_orders')])
  3261. .groupBy('org_store_id')
  3262. )
  3263. .from('org_store_settings')
  3264. .joinRaw('left join count_free_fill_period on org_store_settings.org_store_id = count_free_fill_period.org_store_id')
  3265. .joinRaw('left join count_free_fill_today on org_store_settings.org_store_id = count_free_fill_today.org_store_id')
  3266. .joinRaw('left join count_general_free_fill on org_store_settings.org_store_id = count_general_free_fill.org_store_id')
  3267. .joinRaw('left join sum_orders_store_from_brand_taken_ff on org_store_settings.org_store_id = sum_orders_store_from_brand_taken_ff.org_store_id')
  3268. .joinRaw('join org_stores on org_stores.org_store_id = org_store_settings.org_store_id ')
  3269. .whereIn('org_store_settings.org_store_id', store_participate_ff)
  3270. .columns([
  3271. 'org_store_settings.org_store_id',
  3272. 'store_name',
  3273. db.raw('COALESCE(sum_amount_orders,0) as sum_amount_orders'),
  3274. db.raw(`json_extract_path_text(org_store_settings.settings::json,
  3275. 'number_free_fill_per_day')::numeric as number_free_fill_per_day`),
  3276. db.raw(`json_extract_path_text(org_store_settings.settings::json,
  3277. 'number_free_fill_offering_per_period')::numeric as number_free_fill_offering_per_period`),
  3278. db.raw(`json_extract_path_text(org_store_settings.settings::json,
  3279. 'number_free_fill_offering_per_period')::numeric as number_free_fill_offering_per_period`),
  3280. db.raw(`json_extract_path_text(org_store_settings.settings::json,
  3281. 'period_length')::numeric as period_length`),
  3282. db.raw(`json_extract_path_text(org_store_settings.settings::json,
  3283. 'number_free_fill_per_day')::numeric - COALESCE(count_free_fill_today.count_today,0) as differ_count_day`),
  3284. db.raw(`json_extract_path_text(org_store_settings.settings::json,
  3285. 'number_free_fill_offering_per_period')::numeric - COALESCE(count_free_fill_period.count_period,0) as differ_count_period`),
  3286. db.raw(`json_extract_path_text(org_store_settings.settings::json,
  3287. 'maximum_amount_ff_can_claim_without_order')::numeric - COALESCE(count_general_free_fill.count_general,0) as differ_count_general`),
  3288. ])
  3289.  
  3290. let store_statistics_query = db.columns(['*', db.raw('CASE WHEN (differ_count_day<=0 OR differ_count_period<=0 OR (differ_count_general<=0 AND sum_amount_orders = 0)) THEN false ELSE true END AS take_part_ff'), db.raw('CASE WHEN (differ_count_general<=0 AND sum_amount_orders = 0) THEN true ELSE false END AS suspended_from_ff')]).from(store_query.as('M'))
  3291.  
  3292. let store_statistics = await store_statistics_query
  3293.  
  3294. // store_statistics =
  3295. // store_statistics &&
  3296. // store_statistics.map(o => ({
  3297. // ...o,
  3298. // take_part_ff: Number(o.differ_count_day) <= 0 || Number(o.differ_count_period) <= 0 || (Number(o.differ_count_general) <= 0 && Number(o.sum_amount_orders) == 0) ? false : true,
  3299. // // suspended_from_ff: Number(o.differ_count_general) <= 0 && Number(o.sum_amount_orders) == 0 ? true : false,
  3300. // }))
  3301. if (store_take_part_ff != undefined) {
  3302. store_take_part_ff = store_take_part_ff === 'true' ? true : false
  3303.  
  3304. store_statistics = store_statistics && store_statistics.filter(o => o.take_part_ff === store_take_part_ff)
  3305. }
  3306. return store_statistics
  3307. }
  3308.  
  3309. static async getFreeFillWarehousesStatistics(warehouse_ids: any, warehouse_take_part_ff: boolean) {
  3310. let warehouses_participate_ff = db('org_warehouse_ord_promotion_con')
  3311. .select('org_warehouse_id')
  3312. .whereIn(
  3313. 'ord_promotion_id',
  3314. db('ord_promotions')
  3315. .select('ord_promotion_id')
  3316. .where('code', 'free_fill')
  3317. )
  3318. if (warehouse_ids && warehouse_ids.length) {
  3319. warehouses_participate_ff.whereIn('org_warehouse_id', warehouse_ids)
  3320. }
  3321. let warehouse_query = db
  3322. .with(
  3323. 'activation_spent_warehouses',
  3324. db({ om: 'ord_items_metadata', oac: 'org_warehouse_activation_cost' })
  3325. .columns(['org_warehouse_id', db.raw('sum(oac.activation_cost) as sum_activation_cost'), db.raw('count(ord_item_metadata_id) as count_ord'), db.raw('sum(org_shp_cons_rate) as sum_shp_cons_rate')])
  3326. .where('om.free_fill_used', true)
  3327. .whereRaw('om.bill_weight BETWEEN oac.from_billable_weight and oac.to_billable_weight')
  3328. .whereRaw(`om.created_at >= now() - interval '30 days'`)
  3329. .groupBy('om.org_warehouse_id')
  3330. )
  3331. .from('org_warehouse_settings')
  3332. .joinRaw('left join activation_spent_warehouses on activation_spent_warehouses.org_warehouse_id = org_warehouse_settings.org_warehouse_id')
  3333. .joinRaw('join org_warehouses ow on ow.org_warehouse_id = org_warehouse_settings.org_warehouse_id')
  3334. .whereIn('org_warehouse_settings.org_warehouse_id', warehouses_participate_ff)
  3335. .columns([
  3336. 'org_warehouse_settings.org_warehouse_id',
  3337. db.raw(`json_extract_path_text(org_warehouse_settings.settings::json,
  3338. 'activation_spent_limit_per_month')::numeric as activation_spent_limit_per_month`),
  3339. db.raw(`json_extract_path_text(org_warehouse_settings.settings::json,
  3340. 'max_items_count_per_month')::numeric as max_items_count_per_month`),
  3341. db.raw(`json_extract_path_text(org_warehouse_settings.settings::json,
  3342. 'max_shipping_limit_value')::numeric as max_shipping_limit_value`),
  3343. db.raw(`json_extract_path_text(org_warehouse_settings.settings::json,
  3344. 'activation_spent_limit_per_month')::numeric - COALESCE(activation_spent_warehouses.sum_activation_cost,0) as differ_smc`),
  3345. db.raw(`json_extract_path_text(org_warehouse_settings.settings::json,
  3346. 'max_items_count_per_month')::numeric - COALESCE(activation_spent_warehouses.count_ord,0) as differ_cr`),
  3347. db.raw(`(json_extract_path_text(org_warehouse_settings.settings::json,
  3348. 'max_shipping_limit_value')::numeric + (json_extract_path_text(org_warehouse_settings.settings::json,
  3349. 'max_shipping_limit_value')::numeric * 0.1)) -
  3350. COALESCE(activation_spent_warehouses.sum_shp_cons_rate,0) as differ_sr`),
  3351. 'warehouse_name',
  3352. ])
  3353.  
  3354. let warehouses_statistics = await warehouse_query
  3355. warehouses_statistics =
  3356. warehouses_statistics &&
  3357. warehouses_statistics.map(o => ({
  3358. ...o,
  3359. take_part_ff: Number(o.differ_smc) <= 0 || Number(o.differ_cr) <= 0 || Number(o.differ_sr) <= 0 ? false : true,
  3360. }))
  3361. if (warehouse_take_part_ff != undefined) {
  3362. warehouse_take_part_ff = warehouse_take_part_ff === 'true' ? true : false
  3363.  
  3364. warehouses_statistics = warehouses_statistics && warehouses_statistics.filter(o => o.take_part_ff === warehouse_take_part_ff)
  3365. // debug('after warehouses_statistics',warehouses_statistics)
  3366. }
  3367.  
  3368. return warehouses_statistics
  3369. }
  3370.  
  3371. static async getFreeFillShpPacksStatistics(shp_pack_take_part_ff: boolean, warehouse_ids_products: any, shp_pack_id: number, product_name: string) {
  3372. let warehouses_participate_ff = db('org_warehouse_ord_promotion_con')
  3373. .select('org_warehouse_id')
  3374. .whereIn(
  3375. 'ord_promotion_id',
  3376. db('ord_promotions')
  3377. .select('ord_promotion_id')
  3378. .where('code', 'free_fill')
  3379. )
  3380. if (warehouse_ids_products && warehouse_ids_products.length) {
  3381. warehouses_participate_ff.whereIn('org_warehouse_id', warehouse_ids_products)
  3382. }
  3383.  
  3384. let warehouses_query = db
  3385. .with(
  3386. 'activation_spent_warehouses',
  3387. db({ om: 'ord_items_metadata', oac: 'org_warehouse_activation_cost' })
  3388. .columns(['org_warehouse_id', db.raw('sum(oac.activation_cost) as sum_activation_cost'), db.raw('count(ord_item_metadata_id) as count_ord'), db.raw('sum(org_shp_cons_rate) as sum_shp_cons_rate')])
  3389. .where('om.free_fill_used', true)
  3390. .whereRaw('om.bill_weight BETWEEN oac.from_billable_weight and oac.to_billable_weight')
  3391. .whereRaw(`om.created_at >= now() - interval '30 days'`)
  3392. .groupBy('om.org_warehouse_id')
  3393. )
  3394. .from('org_warehouse_settings')
  3395. .joinRaw('left join activation_spent_warehouses on activation_spent_warehouses.org_warehouse_id = org_warehouse_settings.org_warehouse_id')
  3396. .whereIn('org_warehouse_settings.org_warehouse_id', warehouses_participate_ff)
  3397. .columns([
  3398. 'org_warehouse_settings.org_warehouse_id',
  3399. db.raw(`json_extract_path_text(org_warehouse_settings.settings::json,
  3400. 'activation_spent_limit_per_month')::numeric - COALESCE(activation_spent_warehouses.sum_activation_cost,0) as differ_smc`),
  3401. db.raw(`json_extract_path_text(org_warehouse_settings.settings::json,
  3402. 'max_items_count_per_month')::numeric - COALESCE(activation_spent_warehouses.count_ord,0) as differ_cr`),
  3403. db.raw(`(json_extract_path_text(org_warehouse_settings.settings::json,
  3404. 'max_shipping_limit_value')::numeric + (json_extract_path_text(org_warehouse_settings.settings::json,
  3405. 'max_shipping_limit_value')::numeric * 0.1)) -
  3406. COALESCE(activation_spent_warehouses.sum_shp_cons_rate,0) as differ_sr`),
  3407. ])
  3408.  
  3409. let products_ids_query = db
  3410. .with(
  3411. 'count_shp_packs',
  3412. db('ord_items_metadata')
  3413. .select('shp_pack_id', db.raw('count(*) as count'))
  3414. .where('free_fill_used', true)
  3415. .whereRaw(`created_at >= now() - interval '30 days'`)
  3416. .groupBy('shp_pack_id')
  3417. )
  3418. .from('prd_versions')
  3419. .joinRaw('JOIN shp_packs USING (prd_ver_id)')
  3420. .joinRaw('left JOIN count_shp_packs on count_shp_packs.shp_pack_id = shp_packs.shp_pack_id')
  3421. .joinRaw('left JOIN prd_upcs on prd_upcs.prd_ver_id = prd_versions.prd_ver_id')
  3422. .joinRaw('join org_warehouses ow on ow.org_warehouse_id = prd_versions.org_warehouse_id')
  3423.  
  3424. .whereIn(
  3425. 'prd_versions.org_warehouse_id',
  3426. db
  3427. .select('ms.org_warehouse_id')
  3428. .from(warehouses_query.as('ms'))
  3429. .whereRaw('differ_smc>0 AND differ_cr>0 AND differ_sr>0')
  3430. )
  3431. .whereNull('end_at')
  3432. .where('product_not_available', false)
  3433. .where('product_published', true)
  3434. .where('shp_packs.free_fill', true)
  3435. .whereRaw('((free_fill_quota - count_shp_packs.count > 0) OR (free_fill_quota>0 AND count_shp_packs.count is null))')
  3436. .columns(['product_id', 'prd_versions.org_warehouse_id', 'free_fill_quota', 'count', db.raw('COALESCE((free_fill_quota - count), free_fill_quota) as left_shp_pack_count'), 'warehouse_name', 'product_title', 'shp_packs.shp_pack_id', 'ow.org_warehouse_id'])
  3437. .distinct()
  3438.  
  3439. if (shp_pack_id) {
  3440. products_ids_query.where('shp_packs.shp_pack_id', shp_pack_id)
  3441. }
  3442.  
  3443. if (product_name) {
  3444. products_ids_query.where('product_title', 'ILIKE', `%${product_name}%`)
  3445. }
  3446. let shp_packs_statistics = await products_ids_query
  3447. shp_packs_statistics =
  3448. shp_packs_statistics &&
  3449. shp_packs_statistics.map(o => ({
  3450. ...o,
  3451. take_part_ff: Number(o.left_shp_pack_count) <= 0 ? false : true,
  3452. }))
  3453. if (shp_pack_take_part_ff != undefined) {
  3454. shp_pack_take_part_ff = shp_pack_take_part_ff === 'true' ? true : false
  3455.  
  3456. shp_packs_statistics = shp_packs_statistics && shp_packs_statistics.filter(o => o.take_part_ff === shp_pack_take_part_ff)
  3457. // debug('after warehouses_statistics',warehouses_statistics)
  3458. }
  3459.  
  3460. return shp_packs_statistics
  3461. }
  3462. }
RAW Paste Data
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!