All files / crons/jobs generateResupply.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
/* eslint-disable no-restricted-syntax */
require('babel-register');
require('babel-polyfill');
const { parentPort } = require('worker_threads');
const databaseConnect = require('../../../config/database');
const { default: ResupplyCtrl } = require('../../controllers/resupply');
const {
  default: ResupplyInformation,
} = require('../../source/resupply/information');
 
// Funcao de envio de mensagem utilizada para logging
function sendMessage(message = '') {
  if (parentPort) parentPort.postMessage(message);
}
 
// ####################################################################
// JOB EXECUTADO PARA REGRA DE RESSUPRIMENTO                         //
// ####################################################################
 
const jobExec = async () => {
  sendMessage('Iniciando Job...');
  const models = await databaseConnect.default();
 
  sendMessage('Procurando as regras de ressuprimento...');
  const rules = await models.ResupplyRules.findAll({});
 
  for (const rule of rules) {
    sendMessage(
      `Buscando endereços/produtos da regra ${rule.dataValues.rulesCode}...`
    );
 
    const arrayCurves = rule.dataValues.curves.split(',');
    const {
      branchCode,
      depositCode,
      materialFamily = [],
      productCodeFrom,
      productCodeTo,
      resupplyCriteria,
      storageAddressCodeFrom,
      storageAddressCodeTo,
      sectorFrom,
      sectorTo,
      storageRangeCodeFrom,
      storageRangeCodeTo,
      streetFrom,
      streetTo,
      columnFrom,
      columnTo,
      columnSide,
      levelFrom,
      levelTo,
      drawerFrom,
      drawerTo,
      resupplyBy,
    } = rule.dataValues;
 
    const filter = {
      branchCode,
      depositCode,
      materialFamily,
      curve: arrayCurves,
      productCodeFrom,
      productCodeTo,
      resupplyCriteria,
      storageAddressCodeFrom,
      storageAddressCodeTo,
      sectorFrom,
      sectorTo,
      storageRangeCodeFrom,
      storageRangeCodeTo,
      streetFrom,
      streetTo,
      columnFrom,
      columnTo,
      levelFrom,
      levelTo,
      drawerFrom,
      drawerTo,
      resupplyBy,
      size: [],
    };
 
    // Query para buscar os endereços Picking para ressuprimento.
    const addressToResupply =
      await ResupplyInformation.getPickingAddressToResupply({}, filter, {});
 
    if (addressToResupply.length > 0) {
      addressToResupply.forEach(function (address, index) {
        if (address.dataValues.column !== '') {
          const value = address.dataValues.column.replace(
            address.dataValues.column.substr(0, 1),
            ''
          );
 
          if (rule.dataValues.columnSide === 'even') {
            if (value % 2 !== 0) {
              addressToResupply.splice(index, 1);
            }
          } else if (rule.dataValues.columnSide === 'odd') {
            if (value % 2 === 0) {
              addressToResupply.splice(index, 1);
            }
          }
        }
      });
 
      sendMessage(
        `Foi encontrado endereços Picking para a regra ${rule.dataValues.rulesCode}...`
      );
      await ResupplyCtrl.createResupply(filter, addressToResupply, false);
    } else {
      sendMessage(
        `Nenhum endereço de picking encontrado para a regra ${rule.dataValues.rulesCode}...`
      );
    }
  }
};
 
(async () => {
  // funcao que executa o job
  await jobExec();
 
  // processo necessario para informar a conclusao do job
  if (parentPort) sendMessage('done');
  else process.exit(0);
})();