feat: refs #7287 Minor chnage

.eslintrc.yml

@@ -36,7 +36,3 @@ rules:
     jasmine/no-focused-tests: 0
     jasmine/prefer-toHaveBeenCalledWith: 0
     arrow-spacing: ["error", { "before": true, "after": true }]
-    no-restricted-syntax:
-    - "error"
-    - selector: "NewExpression[callee.name='Date']"
-      message: "Use Date.vnNew() instead of new Date()."

CHANGELOG.md

@@ -1,444 +1,3 @@
-# Version 25.00 - 2025-01-14
-
-### Added 🆕
-
-- feat: refs #7235 add serialType parameter to getInvoiceDate and implement corresponding tests  by:jgallego
-- feat: refs #7301 update lastEntriesFilter to include landedDate and enhance test cases  (origin/7301-removeRedundantInventories) by:pablone
-- feat: refs #7880 error code and translations  by:ivanm
-- feat: refs #7924 add isCustomInspectionRequired field to item and update related logic  by:jgallego
-- feat: refs #8167 update canBeInvoiced method to include active status check and improve test cases  by:jgallego
-- feat: refs #8167 update locale and improve invoicing logic with error handling  by:jgallego
-- feat: refs #8246 added relation for the front's new field  by:Jon
-- feat: refs #8266 added itemFk and needed fixtures  by:jtubau
-- feat: refs #8324 country unique  by:Carlos Andrés
-
-### Changed 📦
-
-
-### Fixed 🛠️
-
-- feat: refs #8266 added itemFk and needed fixtures  by:jtubau
-- fix: add isCustomInspectionRequired column to item table for customs inspection indication  by:jgallego
-- fix: canBeInvoiced only in makeInvoice  by:alexm
-- fix: hotFix getMondayWeekYear  by:alexm
-- fix: refs #6598 update ACL property assignment  by:jorgep
-- fix: refs #6861 refs#6861 addPrevOK  by:sergiodt
-- fix: refs #7301 remove debug console log and update test cases in lastEntriesFilter  by:pablone
-- fix: refs #7301 update SQL fixtures and improve lastEntriesFilter logic  by:pablone
-
-# Version 24.52 - 2024-01-07
-
-### Added 🆕
-
-- chore: pullinfo  by:alexm
-- chore: refs #8002 drop comments  by:jorgep
-- chore: refs #8002 drop useless code  by:jorgep
-- feat: added translations and show error in item-type  by:Jon
-- feat: modified data to be equal as the updated back  by:Jon
-- feat: refs #4460 invoiceIn refund  by:Carlos Andrés
-- feat: refs #4466 invoiceIn refund  by:Carlos Andrés
-- feat: refs #6583 add new opt in where builder  by:jorgep
-- feat: refs #6583 add tests  by:jorgep
-- feat: refs #6583 retrieve cloned sale  by:jorgep
-- feat: refs #6583 rollback  by:jorgep
-- feat: refs #7301 add inventory-config and  acl  by:pablone
-- feat: refs #7301 update SQL fixtures and enhance lastEntriesFilter logic  by:pablone
-- feat: refs #7882 Added locationiq service  by:guillermo
-- feat: refs #7882 Added osrm service  by:guillermo
-- feat: refs #7882 Added tests  by:guillermo
-- feat: refs #7882 Fixed problems osrm service  by:guillermo
-- feat: refs #7882 Osrm service  by:guillermo
-- feat: refs #7882 Reequested changes  by:guillermo
-- feat: refs #7882 Requested changes  by:guillermo
-- feat: refs #7936 add back test for updateInvoiceIn  by:jorgep
-- feat: refs #7936 add company filter  by:jorgep
-- feat: refs #7936 add currency check to updateInvoiceIn  by:jorgep
-- feat: refs #7936 add currency handling in invoiceIn trigger  by:jorgep
-- feat: refs #7936 add locale  by:jorgep
-- feat: refs #7936 add minimum due date  by:jorgep
-- feat: refs #7936 add reference rates for currency in fixtures  by:jorgep
-- feat: refs #7936 add save validation  by:jorgep
-- feat: refs #7936 add SiiTypeInvoiceIn model and update invoice correction logic  by:jorgep
-- feat: refs #7936 add tests for invoiceIn  by:jorgep
-- feat: refs #7936 add tests for invoiceIn filter  by:jorgep
-- feat: refs #7936 add validation to InvoiceIn & InvoiceInTax  by:jorgep
-- feat: refs #7936 return country code & is vies fields  by:jorgep
-- feat: refs #8002 adjust to lilium  by:jorgep
-- feat: refs #8002 drop support btn  by:jorgep
-- feat: refs #8174 Changed datatype incompatibility access  by:guillermo
-- feat: refs #8174 Created table sim  by:guillermo
-- feat: refs #8174 create table simsupplier  by:Jbreso
-- feat: refs #8174 fix  by:Jbreso
-- feat: refs#8174 simSupplier  by:Jbreso
-- feat: refs #8190 entry_getCommission  by:robert
-- feat: refs #8190 entry_getCommission change request  by:robert
-- feat: refs #8218 Added time and code in mistakeType  by:guillermo
-- feat: refs #8293 include zone data  by:Jtubau
-- refactor: refs #6583 entry report table style  by:jorgep
-
-### Changed 📦
-
-- refactor: refs #6583 entry report table style  by:jorgep
-- refactor: refs #6583 use warehouseId var  by:jorgep
-- refactor: refs #7301 update entry and item filter tests to validate results against specific criteria  by:pablone
-- refactor: refs #7882 Added ACL's  by:guillermo
-- refactor: refs #7882 Deleted quadminds files  by:guillermo
-- refactor: refs #7936 add transaction & tests  by:jorgep
-- refactor: refs #7936 remove old trigger and add isRaid column to travel table  by:jorgep
-- refactor: refs #7936 remove schema  by:jorgep
-- refactor: refs #8002 use loop wip  by:jorgep
-- refactor: refs #8004 simplify SQL query by removing redundant aliases  by:pablone
-- refactor: refs #8262 Deprecated inventoryFailure  by:guillermo
-- refactor: refs #8266 changed expedition item name  by:Jtubau
-- refactor: refs #8272 delete bi.rotacion  by:ivanm
-
-### Fixed 🛠️
-
-- feat: refs #7301 update SQL fixtures and enhance lastEntriesFilter logic  by:pablone
-- feat: refs #7936 add reference rates for currency in fixtures  by:jorgep
-- feat: refs #8174 fix  by:Jbreso
-- fix: 8174 pasar PIN a CHAR  by:Jbreso
-- fix: monitorPayMethodFilter  by:carlossa
-- fix: refs #6389 back  by:carlossa
-- fix: refs #6389 filter  by:carlossa
-- fix: refs #6389 packing  by:carlossa
-- fix: refs #6389 saleMonitor filter  by:carlossa
-- fix: refs #6389 salesFilter  by:carlossa
-- fix: refs #6583 drop focus  by:jorgep
-- fix: refs #6583 update onlyWithDestination logic to handle null values correctly  by:jorgep
-- fix: refs #7028 fix confirm deny  by:carlossa
-- fix: refs #7028 fix pr  by:carlossa
-- fix: refs #7028 fix tback findById  by:carlossa
-- fix: refs #7028 fix userError  by:carlossa
-- fix: refs #7028 remove ifs  by:carlossa
-- fix: refs #7028 requesterId fix  by:carlossa
-- fix: refs #7028 requesterId fix salesPerson  by:carlossa
-- fix: refs #7031 fix vnPrice  by:carlossa
-- fix: refs #7031 remove check  by:carlossa
-- fix: refs #7301 update ACL insertion to use INSERT IGNORE and refine property value  by:pablone
-- fix: refs #7936 add IF NOT EXISTS to isRaid column in travel table  by:jorgep
-- fix: refs #7936 change type  by:jorgep
-- fix: refs #7936 check if insert in hook & change test description  by:jorgep
-- fix: refs #7936 conflicts  by:jorgep
-- fix: refs #7936 locale  by:jorgep
-- fix: refs #7936 update Spanish locale for SII terms  by:jorgep
-- fix: refs #8174 fix  by:Jbreso
-- fix: refs#8174 fix  by:Jbreso
-- fix: refs8174 pasar a char el PIN  by:Jbreso
-- fix: refs #8174 Version  by:guillermo
-- fix: refs #8251 add eng template  by:carlossa
-- fix: refs #8315 fixture claimDevelopment  by:alexm
-
-# Version 24.48 - 2024-11-25
-
-### Added 🆕
-
-- feat: refs #4948 Added ticket_selfConsumptionPackaging  by:guillermo
-- feat: refs #6818 add config table  by:jorgep
-- feat: refs #6818 add records  by:jorgep
-- feat: refs #6818 saysimple integration  by:jorgep
-- feat: refs #6845 userInterface  by:sergiodt
-- feat: refs #6869 add back  by:jorgep
-- feat: refs #6869 define model  by:jorgep
-- feat: refs #6869 refs#6869 itemShelving_get  (origin/6869-createGetDetails) by:sergiodt
-- feat: refs #7006 itemTypeLog  by:guillermo
-- feat: refs #7006 itemTypeLog created  by:guillermo
-- feat: refs #7006 Requested changes  by:guillermo
-- feat: refs #7193 added scope in parking model  by:Jon
-- feat: refs #7244 Requested changes  by:guillermo
-- feat: refs #7266 Added details and improvements in item label reports  by:guillermo
-- feat: refs #7266 buyFkForPrint  by:sergiodt
-- feat: refs #7266 First commit  by:guillermo
-- feat: refs #7266 Item label barcode  by:guillermo
-- feat: refs #7266 Item label QR  by:guillermo
-- feat: refs #7266 Item label QR finished  by:guillermo
-- feat: refs #7266 Minor change  by:guillermo
-- feat: refs #7266 Print corrections  by:guillermo
-- feat: refs #7266 Requested changes and improvements  by:guillermo
-- feat: refs #7266 Requested changes and query optimization  by:guillermo
-- feat: refs #7266 Version  by:guillermo
-- feat: refs #7289 #7289 apply option 1  by:Javier Segarra
-- feat: refs #7289 #7289 remove bad translation  by:Javier Segarra
-- feat: refs #7524 restrict fields  by:jorgep
-- feat: refs #7641 fine tunning  by:jorgep
-- feat: refs #7641 improve style  by:jorgep
-- feat: refs #7743 add simple spec for sendMail  by:pablone
-- feat: refs #7743 add try catch stmt to the test  by:pablone
-- feat: refs #7874 add default type  by:jorgep
-- feat: refs #7874 use name  by:jorgep
-- feat: refs #7920 Added ItemShelving in shelvingLog  by:guillermo
-- feat: refs #7921 refs#7921 sendLostExpedition  by:sergiodt
-- feat: refs #7922 refs #792 scanOrder  by:sergiodt
-- feat: refs #7943 quitar lectura en metodos comunes  by:jgallego
-- feat: refs #7943 return just the required content  by:jorgep
-- feat: refs #7943 usa back con permisos  by:jgallego
-- feat: refs #8020 machineWorkerDeprecated  by:sergiodt
-- feat: refs #8057 Added data updates  by:guillermo
-- feat: refs #8057 Added data updates  (origin/8057-geoFk) by:guillermo
-- feat: refs #8057 Added geoFk columns  by:guillermo
-- feat: refs #8057 Fix version  by:guillermo
-- feat: refs #8057 More precision in getGeo  by:guillermo
-- feat: refs #8057 Requested changes  by:guillermo
-- feat: refs #8071 quitar esquema  by:robert
-- feat: refs #8071 travel_weeklyClone  by:robert
-- feat: refs #8080 Added column comment  by:guillermo
-- feat: refs #8083 add prop  by:jorgep
-- feat: refs #8087 Traspasar redadas a travels  by:Carlos Andrés
-- feat: refs #8099 refs#8099 addComplmentSalary  by:sergiodt
-- feat: refs #8124 Enrutadores nuevos requerimientos  by:Carlos Andrés
-- feat: refs #8124 Enrutadores nuevos requerimientos  (origin/8124-enrutadoresNuevosRequerimientos) by:Carlos Andrés
-- feat: refs #8127 entry_getCommission  by:robert
-- feat: refs #8127 quitar esquemas  by:robert
-- feat: refs #8135 refs#8135 updateTicketACL  (origin/8135-ticketACL) by:sergiodt
-- feat: refs #8143 deprecate recoverPass and sync from account.user  by:ivanm
-- feat: refs #8150 movExpeditions  by:sergiodt
-- feat: refs #8151 Added test  by:guillermo
-- feat: refs #8151 moveExpeditions  by:guillermo
-- feat: refs #8151 Requested changes  by:guillermo
-- feat(Supplier): refs #6828 add companySize  by:alexm
-- refactor: refs #7641 entry report style  by:jorgep
-
-### Changed 📦
-
-- refactor: refs #6920 add correct role  by:alexm
-- refactor: refs #7242 Deleted select column  by:guillermo
-- refactor: refs #7457 Added from param if not exists  by:guillermo
-- refactor: refs #7641 entry report style  by:jorgep
-- refactor: refs #7715 Deleted hasNewLabelMrwMethod column  by:guillermo
-- refactor: refs #7920 Fix tests  by:guillermo
-- refactor: refs #7920 Fix version  by:guillermo
-- refactor: refs #7920 itemShelvingLog  by:guillermo
-- refactor: refs #7920 Main change  by:guillermo
-- refactor: refs #7920 Major changes  by:guillermo
-- refactor: refs #7920 No changes in itemShelvingLog table  by:guillermo
-- refactor: refs #7920 Requested changes  by:guillermo
-- refactor: refs #7950 Created cmr model  (7950-cmrModelUnify) by:guillermo
-- refactor: refs #7950 Requested changes  by:guillermo
-- refactor: refs #8153 Optimized order_getTax  by:guillermo
-
-### Fixed 🛠️
-
-- fix: clean deletes also zoneEvent range records  by:jgallego
-- fix: more data for fixture.before  by:Pako
-- fix: refs #4948 Tests  by:guillermo
-- fix: refs #6644 email and translations  by:carlossa
-- fix: refs #6818 add config  by:jorgep
-- fix: refs #6818 add defaultChannel  by:jorgep
-- fix: refs #6818 use right col type  by:jorgep
-- fix: refs #6869 use id as primaryKey  by:jorgep
-- fix: refs #7244 Added collection ACL  by:guillermo
-- fix: refs #7283 item filters  by:carlossa
-- fix: refs #7283 remove  by:carlossa
-- fix: refs #7283 remove tests  by:carlossa
-- fix: refs #7283 tback  by:carlossa
-- fix: refs #7323 add remaining fields  (origin/7323-warfix-addRemainingFields) by:jorgep
-- fix: refs #7457 add with on select to reduce  by:pablone
-- fix: refs #7457 empty commit for gitea  by:pablone
-- fix: refs #7457 error on empty from param and add translate  by:pablone
-- fix: refs #7457 remove group by calc time reduce bellow 1s  by:pablone
-- fix: refs #7457 remove translate and use param definition for restriction  by:pablone
-- fix: refs #7641 align columns  by:jorgep
-- fix: refs #7641 drop boilerplate code  by:jorgep
-- fix: refs #7920 refs#7920 itemShelvingLog  by:sergiodt
-- fix: refs #8153 Version  by:guillermo
-- revert cd7ed6987a88e00275b562d3248f368b6333620c  by:Javier Segarra
-
-# Version 24.38 - 2024-09-17
-
-### Added 🆕
-
-- chore: refs #7323 filter data  by:jorgep
-- chore: refs #7323 fix test  by:jorgep
-- chore: refs #7323 worker changes  by:jorgep
-- chore: refs #7323 worker changes wip  by:jorgep
-- chore: refs #7524 add select limit  by:jorgep
-- feat(AccessToken&ACL): refs #7547 upgrade security  by:alexm
-- feat: deleted code and redirect to Lilium  by:Jon
-- feat: refs #4515 New throw buy_checkItem  by:guillermo
-- feat: refs #6650 Added saleGroupLog  by:guillermo
-- feat: refs #6650 new itemShelvingLog  by:guillermo
-- feat: refs #6760 refs #actualiza campo nickname  by:jgallego
-- feat: refs #7277 fdescribe  by:jgallego
-- feat: refs #7277 fit  by:jgallego
-- feat: refs #7277 refundInvoices  by:jgallego
-- feat: refs #7277 test with warehouse  by:jgallego
-- feat: refs #7277 traducciones  by:jgallego
-- feat: refs #7277 transfer addressFk  by:jgallego
-- feat: refs #7532 Requested changes  by:guillermo
-- feat: refs #7564 Added proc  by:guillermo
-- feat: refs #7564 Added ticket_setVolumeItemCost  by:guillermo
-- feat: refs #7564 Added volume column  by:guillermo
-- feat: refs #7564 Fix version  by:guillermo
-- feat: refs #7564 Requested changes  by:guillermo
-- feat: refs #7615 setDeleted  by:robert
-- feat: refs #7650 Added no transfer lines to inventory entry and fixtures  by:guillermo
-- feat: refs #7650 Fix tests  by:guillermo
-- feat: refs #7747 Delete buyUltimate and buyUltimateFromInterval  by:ivanm
-- feat: refs #7759 Changed defined only of vn objects  by:guillermo
-- feat: refs #7759 Changed definer root to vn-admin  by:guillermo
-- feat: refs #7759 Changed name  by:guillermo
-- feat: refs #7759 Deleted version 11163-maroonEucalyptus  by:guillermo
-- feat: refs #7759 Revoke routine grants vn  by:guillermo
-- feat: refs #7811 Added comment  by:guillermo
-- feat: refs #7811 Added new params in datasources.json  by:guillermo
-- feat: refs #7898 Add column "floor" in vn.parking  by:ivanm
-- feat: refs #7898 Modify default  by:ivanm
-- feat: refs #7905 Added new method getBuysCsv  by:guillermo
-- feat: refs #7905 Added param toCsv  by:guillermo
-- feat: refs #7938 remove unnecessary insert in clientLog  by:alexm
-- feat: refs #7953 pullinfo  (7953-devToTest_2438) by:alexm
-- feat(salix): #7671 define isDestiny field in model  by:Javier Segarra
-- feat(salix): refs #7896 update version and changelog  (origin/7896_down_devToTest_2436) by:Javier Segarra
-- feat(salix): refs #7905 #7905 use getBuys toCSV flattened  by:Javier Segarra
-- feat(ssalix): refs #7671 #7671 checkDates  by:Javier Segarra
-- feat(ssalix): refs #7671 #7671 checkDates to present  by:Javier Segarra
-- feat: ticket 215005 Changed acl show transferClient  by:guillermo
-
-### Changed 📦
-
-- perf: refs #7671 improve showBadDates  by:Javier Segarra
-- perf(salix): refs #7671 #7671 imrpove and revert where changes  by:Javier Segarra
-- refactor: deleted e2e & added back descriptor and summary  by:Jon
-
-### Fixed 🛠️
-
-- chore: refs #7323 fix test  by:jorgep
-- feat: refs #7650 Added no transfer lines to inventory entry and fixtures  by:guillermo
-- fix  by:guillermo
-- fixes: refs #7760 collection problems  by:Carlos Andrés
-- fix merge dev  (7407-workerMedical) by:alexm
-- fix: refs #6727 No delete log tables data in clean procedures  by:guillermo
-- fix: refs #6897 back and tests  by:carlossa
-- fix: refs #6897 back  by:carlossa
-- fix: refs #6897 fix filter  by:carlossa
-- fix: refs #6897 fix json  by:carlossa
-- fix: refs #6897 travel filter  by:carlossa
-- fix: refs #6897 error test  by:jgallego
-- fix: refs #7323 fetch from right source  by:jorgep
-- fix: refs #7564 Deleted query  by:guillermo
-- fix: refs #7759 Added user 'vn'@'localhost' & grants  by:guillermo
-- fix: refs #7760 collection problems  by:Carlos Andrés
-- fix: refs #7760 tmp.ticketIPT  by:Carlos Andrés
-- fix: refs #7905 added comments to flatten.js  by:guillermo
-- fix: refs ##7905 Handle error  by:guillermo
-- fix(salix): refs #7905 #7905 use right fn to flatten data  by:Javier Segarra
-- perf(salix): refs #7671 #7671 imrpove and revert where changes  by:Javier Segarra
-- refs #6898 fix supplier remove  by:carlossa
-- refs #7407 fix acls fixtures  by:carlossa
-- test: fix connections e2e  (7547-accessToken-security) by:alexm
-- test: refs #7277 fix test proposal  by:Javier Segarra
-- test(salix): refs #7671 #7671 improve and revert where changes  by:Javier Segarra
-
-# Version 24.36 - 2024-09-03
-
-### Added 🆕
-
-- chore: refs #7524 WIP limit call  by:jorgep
-- chore: refs #7524 modify ormConfig table col  (origin/7524-warmfix-modifyColumn) by:jorgep
-- feat(update-user): refs #7848 add twoFactor  by:alexm
-- feat: #3199 Requested changes  by:guillermo
-- feat: refs #3199 Added more scopes ticket_recalcByScope  by:guillermo
-- feat: refs #3199 Added one more scope ticket_recalcByScope  by:guillermo
-- feat: refs #3199 Created ticket_recalcItemTaxCountryByScope  by:guillermo
-- feat: refs #3199 Requested changes  by:guillermo
-- feat: refs #7346 add multiple feature  by:jgallego
-- feat: refs #7346 backTest checks new implementation  by:jgallego
-- feat: refs #7346 mas intuitivo  by:jgallego
-- feat: refs #7514 Changes to put srt log  (origin/7514-srtLog) by:guillermo
-- feat: refs #7524 add default limit  (origin/7524-limitSelect) by:jorgep
-- feat: refs #7524 add mock limit on find query  by:jorgep
-- feat: refs #7524 wip remote hooks  by:jorgep
-- feat: refs #7562 Requested changes  by:guillermo
-- feat: refs #7567 Changed time to call event  by:guillermo
-- feat: refs #7567 Requested changes  by:guillermo
-- feat: refs #7710 pr revision  by:jgallego
-- feat: refs #7710 test fixed  (origin/7710-cloneWithTicketPackaging, 7710-cloneWithTicketPackaging) by:jgallego
-- feat: refs #7712 Fix  by:guillermo
-- feat: refs #7712 Unify  by:guillermo
-- feat: refs #7712 sizeLimit  (origin/7712-sizeLimit) by:guillermo
-- feat: refs #7758 Add code mandateType and accountDetailType  by:ivanm
-- feat: refs #7758 Modify code lowerCamelCase and UNIQUE  by:ivanm
-- feat: refs #7758 accountDetailType fix deploy error  by:ivanm
-- feat: refs #7784 Changes in entry-order-pdf  by:guillermo
-- feat: refs #7784 Requested changes  by:guillermo
-- feat: refs #7799 Added Fk in vn.item.itemPackingTypeFk  by:guillermo
-- feat: refs #7800 Added company Fk  by:guillermo
-- feat: refs #7842 Added editorFk in vn.host  by:guillermo
-- feat: refs #7860 Update new packagings  (origin/7860-newPackaging) by:guillermo
-- feat: refs #7862 roadmap new fields  by:ivanm
-- feat: refs #7882 Added quadMindsConfig table  by:guillermo
-
-### Changed 📦
-
-- refactor: refs #7567 Fix and improvement  by:guillermo
-- refactor: refs #7567 Minor change  by:guillermo
-- refactor: refs #7756 Fix tests  by:guillermo
-- refactor: refs #7798 Drop bi.Greuges_comercial_detail  by:guillermo
-- refactor: refs #7848 adapt to lilium  by:alexm
-
-### Fixed 🛠️
-
-- feat: refs #7710 test fixed  (origin/7710-cloneWithTicketPackaging, 7710-cloneWithTicketPackaging) by:jgallego
-- feat: refs #7758 accountDetailType fix deploy error  by:ivanm
-- fix(salix): #7283 ItemFixedPrice duplicated  (origin/7283_itemFixedPrice_duplicated) by:Javier Segarra
-- fix: refs #7346 minor error  (origin/7346, 7346) by:jgallego
-- fix: refs #7355 remove and tests accounts  (origin/7355-accountMigration2) by:carlossa
-- fix: refs #7355 remove and tests accounts  by:carlossa
-- fix: refs #7524 default limit select  by:jorgep
-- fix: refs #7756 Foreign keys invoiceOut  (origin/7756-fixRefFk) by:guillermo
-- fix: refs #7756 id 0  by:guillermo
-- fix: refs #7800 tpvMerchantEnable PRIMARY KEY  (origin/7800-tpvMerchantEnable) by:guillermo
-- fix: refs #7800 tpvMerchantEnable PRIMARY KEY  by:guillermo
-- fix: refs #7916 itemShelving_transfer  (origin/test, test) by:guillermo
-- fix: refs #pako Deleted duplicated version  by:guillermo
-
-# Version 24.34 - 2024-08-20
-
-### Added 🆕
-
-- #6900 feat: clear empty  by:jorgep
-- #6900 feat: empty commit  by:jorgep
-- chore: refs #6900 beautify code  by:jorgep
-- chore: refs #6989 add config model  by:jorgep
-- feat workerActivity refs #6078  by:sergiodt
-- feat: #6453 Refactor  (origin/6453-orderConfirm) by:guillermo
-- feat: #6453 Rollback always split by itemPackingType  by:guillermo
-- feat: deleted worker module code & redirect to Lilium  by:Jon
-- feat: refs #6453 Added new ticket search  by:guillermo
-- feat: refs #6453 Fixes  by:guillermo
-- feat: refs #6453 Minor changes  by:guillermo
-- feat: refs #6453 Requested changes  by:guillermo
-- feat: refs #6900 drop section  by:jorgep
-- feat: refs #7283 order by desc date  by:jorgep
-- feat: refs #7323 add locale  by:jorgep
-- feat: refs #7323 redirect to lilium  by:jorgep
-- feat: refs #7646  delete scannableCodeType  by:robert
-- feat: refs #7713 Created ACLLog  by:guillermo
-- feat: refs #7774  (origin/7774-ticket_cloneWeekly) by:robert
-- feat: refs #7774 #7774 Changes ticket_cloneWeekly  by:guillermo
-- feat: refs #7774 ticket_cloneWeekly  by:robert
-
-### Changed 📦
-
-- refactor: refs #6453 Major changes  by:guillermo
-- refactor: refs #6453 Minor changes  by:guillermo
-- refactor: refs #6453 order_confirmWithUser  by:guillermo
-- refactor: refs #7646 #7646 Deleted scannable* variables productionConfig  by:guillermo
-- refactor: refs #7820 Deprecated silexACL  by:guillermo
-
-### Fixed 🛠️
-
-- #6900 fix: #6900 rectificative filter  by:jorgep
-- #6900 fix: empty commit  by:jorgep
-- fix(orders_filter): add sourceApp accepts  by:alexm
-- fix: refs #6130 commit lint  by:pablone
-- fix: refs #6453 order_confirmWithUser  by:guillermo
-- fix: refs #7283 sql  by:jorgep
-- fix: refs #7713 ACL Log  by:guillermo
-- test: fix claim descriptor redirect to lilium  by:alexm
-- test: fix ticket redirect to lilium  by:alexm
-- test: fix ticket sale e2e  by:alexm
-
 # Version 24.32 - 2024-08-06
 
 ### Added 🆕

Jenkinsfile

@@ -7,8 +7,7 @@ def RUN_BUILD
 
 def BRANCH_ENV = [
     test: 'test',
-    master: 'production',
+    master: 'production'
-    beta: 'production'
 ]
 
 node {
@@ -19,8 +18,7 @@ node {
         PROTECTED_BRANCH = [
             'dev',
             'test',
-            'master',
+            'master'
-            'beta'
         ].contains(env.BRANCH_NAME)
 
         FROM_GIT = env.JOB_NAME.startsWith('gitea/')
@@ -64,18 +62,6 @@ pipeline {
         PROJECT_NAME = 'salix'
     }
     stages {
-        stage('Version') {
-            when {
-                expression { RUN_BUILD }
-            }
-            steps {
-                script {
-                    def packageJson = readJSON file: 'package.json'
-                    def version = "${packageJson.version}-build${env.BUILD_ID}"
-                    writeFile(file: 'VERSION.txt', text: version)
-                }
-            }
-        }
         stage('Install') {
             environment {
                 NODE_ENV = ''
@@ -132,10 +118,11 @@ pipeline {
                             when {
                                 expression { RUN_BUILD }
                             }
-                            environment {
-                                VERSION = readFile 'VERSION.txt'
-                            }
                             steps {
+                                script {
+                                    def packageJson = readJSON file: 'package.json'
+                                    env.VERSION = "${packageJson.version}-build${env.BUILD_ID}"
+                                }
                                 sh 'docker-compose build back'
                             }
                         }
@@ -169,10 +156,11 @@ pipeline {
                             when {
                                 expression { RUN_BUILD }
                             }
-                            environment {
-                                VERSION = readFile 'VERSION.txt'
-                            }
                             steps {
+                                script {
+                                    def packageJson = readJSON file: 'package.json'
+                                    env.VERSION = "${packageJson.version}-build${env.BUILD_ID}"
+                                }
                                 sh 'gulp build'
                                 sh 'docker-compose build front'
                             }
@@ -187,9 +175,12 @@ pipeline {
             }
             environment {
                 CREDENTIALS = credentials('docker-registry')
-                VERSION = readFile 'VERSION.txt'
             }
             steps {
+                script {
+                    def packageJson = readJSON file: 'package.json'
+                    env.VERSION = "${packageJson.version}-build${env.BUILD_ID}"
+                }
                 sh 'docker login --username $CREDENTIALS_USR --password $CREDENTIALS_PSW $REGISTRY'
                 sh 'docker-compose push'
             }
@@ -216,10 +207,11 @@ pipeline {
                     when {
                         expression { FROM_GIT }
                     }
-                    environment {
-                        VERSION = readFile 'VERSION.txt'
-                    }
                     steps {
+                        script {
+                            def packageJson = readJSON file: 'package.json'
+                            env.VERSION = "${packageJson.version}-build${env.BUILD_ID}"
+                        }
                         withKubeConfig([
                             serverUrl: "$KUBERNETES_API",
                             credentialsId: 'kubernetes',

back/Dockerfile

@@ -32,7 +32,8 @@ RUN apt-get update \
 RUN apt-get update \
     && apt-get install -y --no-install-recommends \
         samba-common-bin samba-dsdb-modules\
-    && rm -rf /var/lib/apt/lists/*
+    && rm -rf /var/lib/apt/lists/* \
+    && npm -g install pm2
 
 # Salix
 
@@ -54,4 +55,7 @@ COPY \
     README.md \
     ./
 
-CMD ["node", "--tls-min-v1.0", "--openssl-legacy-provider", "./loopback/server/server.js"]
+CMD ["pm2-runtime", "./back/process.yml"]
+
+HEALTHCHECK --interval=15s --timeout=10s \
+    CMD curl -f http://localhost:3000/api/Applications/status || exit 1

back/methods/chat/sendCheckingPresence.js

@@ -27,46 +27,38 @@ module.exports = Self => {
     });
 
     Self.sendCheckingPresence = async(ctx, recipientId, message) => {
+        if (!recipientId) return false;
+        const models = Self.app.models;
+
         const userId = ctx.req.accessToken.userId;
+        const sender = await models.VnUser.findById(userId, {fields: ['id']});
+        const recipient = await models.VnUser.findById(recipientId, null);
+
+        // Prevent sending messages to yourself
+        if (recipientId == userId) return false;
+        if (!recipient)
+            throw new Error(`Could not send message "${message}" to worker id ${recipientId} from user ${userId}`);
+
+        if (!isProduction())
+            message = `[Test:Environment to user ${userId}] ` + message;
+
+        const chat = await models.Chat.create({
+            senderFk: sender.id,
+            recipient: `@${recipient.name}`,
+            dated: Date.vnNew(),
+            checkUserStatus: 1,
+            message: message,
+            status: 'sending',
+            attempts: 0
+        });
+
         try {
-            const models = Self.app.models;
+            await Self.sendCheckingUserStatus(chat);
-            const sender = await models.VnUser.findById(userId, {fields: ['id']});
+            await Self.updateChat(chat, 'sent');
-            const error = `Could not send message from user ${userId}`;
+        } catch (error) {
-
+            await Self.updateChat(chat, 'error', error);
-            if (!recipientId) throw new Error(error);
-            const recipient = await models.VnUser.findById(recipientId, null);
-            if (!recipient)
-                throw new Error(error);
-
-            // Prevent sending messages to yourself
-            if (recipientId == userId) return false;
-
-            if (!isProduction())
-                message = `[Test:Environment to user ${userId}] ` + message;
-
-            const chat = await models.Chat.create({
-                senderFk: sender.id,
-                recipient: `@${recipient.name}`,
-                dated: Date.vnNew(),
-                checkUserStatus: 1,
-                message: message,
-                status: 'sending',
-                attempts: 0
-            });
-
-            try {
-                await Self.sendCheckingUserStatus(chat);
-                await Self.updateChat(chat, 'sent');
-            } catch (error) {
-                await Self.updateChat(chat, 'error', error);
-            }
-
-            return true;
-        } catch (e) {
-            await Self.rawSql(`
-                INSERT INTO util.debug (variable, value)
-                    VALUES ('sendCheckingPresence_error', ?)
-            `, [`User: ${userId}, recipient: ${recipientId}, message: ${message}, error: ${e}`]);
         }
+
+        return true;
     };
 };

back/methods/collection/assignCollection.js

@@ -19,15 +19,8 @@ module.exports = Self => {
 
         if (typeof options == 'object')
             Object.assign(myOptions, options);
-
+        const [info, info2, [{'@vCollectionFk': collectionFk}]] = await Self.rawSql(
-        const randStr = Math.random().toString(36).substring(3);
+            'CALL vn.collection_getAssigned(?, @vCollectionFk);SELECT @vCollectionFk', [userId], myOptions);
-        const result = await Self.rawSql(`
-            CALL vn.collection_getAssigned(?, @vCollectionFk);
-            SELECT @vCollectionFk ?
-            `, [userId, randStr], myOptions);
-
-        const collectionFk = result.find(item => item[0]?.[randStr] !== undefined)?.[0]?.[randStr];
-
         if (!collectionFk) throw new UserError('There are not picking tickets');
         await Self.rawSql('CALL vn.collection_printSticker(?, NULL)', [collectionFk], myOptions);
 

back/methods/collection/getSales.js

@@ -29,8 +29,10 @@ module.exports = Self => {
     });
 
     Self.getSales = async(ctx, collectionOrTicketFk, print, source, options) => {
+        const models = Self.app.models;
         const userId = ctx.req.accessToken.userId;
         const myOptions = {userId};
+        const $t = ctx.req.__;
 
         if (typeof options == 'object')
             Object.assign(myOptions, options);
@@ -57,6 +59,22 @@ module.exports = Self => {
 
         if (print) await Self.rawSql('CALL vn.collection_printSticker(?,NULL)', [id], myOptions);
 
+        for (let ticket of tickets) {
+            if (ticket.observaciones) {
+                let observations = ticket.observaciones.split(' ');
+
+                for (let observation of observations) {
+                    const salesPerson = ticket.salesPersonFk;
+                    if (observation.startsWith('#') || observation.startsWith('@')) {
+                        await models.Chat.send(ctx,
+                            observation,
+                            $t('ticketCommercial', {ticket: ticket.ticketFk, salesPerson})
+                        );
+                    }
+                }
+            }
+        }
+
         return getCollection(id, tickets, sales, placements, myOptions);
     };
 

back/methods/collection/getTickets.js

@@ -40,7 +40,6 @@ module.exports = Self => {
 
         const sales = await Self.rawSql(`
             SELECT s.ticketFk,
-                    NULL ticketOrder,
                     sgd.saleGroupFk,
                     s.id saleFk,
                     s.itemFk,
@@ -58,14 +57,12 @@ module.exports = Self => {
                     ROW_NUMBER () OVER (PARTITION BY s.id ORDER BY pickingOrder) currentItemShelving,
                     COUNT(*) OVER (PARTITION BY s.id ORDER BY s.id) totalItemShelving,
                     sh.code,
-                    p2.code parkingCodePrevia,
+                    p2.code parkingCode,
-                    p2.pickingOrder pickingOrderPrevia,
+                    p2.pickingOrder pickingOrder,
-                    p.code parkingCode,
+                    p.code parkingCodePrevia,
-                    p.pickingOrder pickingOrder,
+                    p.pickingOrder pickingOrderPrevia,
                     iss.id itemShelvingSaleFk,
-                    iss.isPicked,
+                    iss.isPicked
-                    iss.itemShelvingFk,
-                    st.code stateCode
                 FROM ticketCollection tc
                     LEFT JOIN collection c ON c.id = tc.collectionFk
                     JOIN sale s ON s.ticketFk = tc.ticketFk
@@ -75,16 +72,14 @@ module.exports = Self => {
                     JOIN item i ON i.id = s.itemFk
                     JOIN itemShelvingSale iss ON iss.saleFk = s.id
                     LEFT JOIN itemShelving ish ON ish.id = iss.itemShelvingFk
-                    LEFT JOIN shelving sh ON sh.id = ish.shelvingFk
+                    LEFT JOIN shelving sh ON sh.code = ish.shelvingFk
                     LEFT JOIN parking p ON p.id = sh.parkingFk
                     LEFT JOIN itemColor ic ON ic.itemFk = s.itemFk
                     LEFT JOIN origin o ON o.id = i.originFk
-                    LEFT JOIN state st ON st.id = sg.stateFk
                 WHERE tc.collectionFk = ?
                 GROUP BY s.id, ish.id, p.code, p2.code
             UNION ALL
             SELECT s.ticketFk,
-                DENSE_RANK() OVER (ORDER BY ss.id),
                 sgd.saleGroupFk,
                 s.id saleFk,
                 s.itemFk,
@@ -107,9 +102,7 @@ module.exports = Self => {
                 p.code,
                 p.pickingOrder,
                 iss.id itemShelvingSaleFk,
-                iss.isPicked,
+                iss.isPicked
-                iss.itemShelvingFk,
-                st.code stateCode
             FROM sectorCollection sc
                 JOIN sectorCollectionSaleGroup ss ON ss.sectorCollectionFk  = sc.id 
                 JOIN saleGroup sg ON sg.id = ss.saleGroupFk
@@ -119,11 +112,10 @@ module.exports = Self => {
                 JOIN item i ON i.id = s.itemFk
                 JOIN itemShelvingSale iss ON iss.saleFk = s.id
                 LEFT JOIN itemShelving ish ON ish.id = iss.itemShelvingFk
-                LEFT JOIN shelving sh ON sh.id = ish.shelvingFk
+                LEFT JOIN shelving sh ON sh.code = ish.shelvingFk
                 LEFT JOIN parking p ON p.id = sh.parkingFk
                 LEFT JOIN itemColor ic ON ic.itemFk = s.itemFk
                 LEFT JOIN origin o ON o.id = i.originFk
-                LEFT JOIN state st ON st.id = sg.stateFk
             WHERE sc.id = ? 
                 AND sgd.saleGroupFk
             GROUP BY s.id, ish.id, p.code, p2.code`, [id, id], myOptions);

back/methods/collection/spec/assign.spec.js

@@ -28,10 +28,9 @@ describe('ticket assign()', () => {
         await tx.rollback();
     });
 
-    it('should throw an error when there are no picking tickets', async() => {
+    it('should throw an error when  there is not picking tickets', async() => {
         try {
             await models.Collection.assign(ctx, options);
-            fail('Expected an error to be thrown, but none was thrown.');
         } catch (e) {
             expect(e.message).toEqual('There are not picking tickets');
         }

back/methods/collection/spec/assignCollection.spec.js

@@ -15,7 +15,9 @@ describe('ticket assignCollection()', () => {
             args: {}
         };
 
-        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({active: ctx.req});
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: ctx.req
+        });
 
         options = {transaction: tx};
         tx = await models.Sale.beginTransaction({});
@@ -23,7 +25,7 @@ describe('ticket assignCollection()', () => {
     });
 
     afterEach(async() => {
-        if (tx) await tx.rollback();
+        await tx.rollback();
     });
 
     it('should throw an error when  there is not picking tickets', async() => {

back/methods/dms/updateFile.js

@@ -38,7 +38,7 @@ module.exports = Self => {
         {
             arg: 'hasFile',
             type: 'Boolean',
-            description: 'True if has the original in paper'
+            description: 'True if has an attached file'
         },
         {
             arg: 'hasFileAttached',

back/methods/docuware/core.js

@@ -4,45 +4,21 @@ module.exports = Self => {
     /**
      * Returns basic headers
      *
+     * @param {string} cookie - The docuware cookie
      * @return {object} - The headers
      */
     Self.getOptions = async() => {
         const docuwareConfig = await Self.app.models.DocuwareConfig.findOne();
-        const now = Date.vnNow();
-        let {url, username, password, token, expired} = docuwareConfig;
-
-        if (process.env.NODE_ENV && (!expired || expired < now + 60)) {
-            const {data: {IdentityServiceUrl}} = await axios.get(`${url}/Home/IdentityServiceInfo`);
-            const {data: {token_endpoint}} = await axios.get(`${IdentityServiceUrl}/.well-known/openid-configuration`);
-            const {data} = await axios.post(token_endpoint, {
-                grant_type: 'password',
-                scope: 'docuware.platform',
-                client_id: 'docuware.platform.net.client',
-                username,
-                password
-            }, {headers: {
-                'Accept': 'application/json',
-                'Content-Type': 'application/x-www-form-urlencoded'
-            }});
-
-            const newToken = data.access_token;
-            token = data.token_type + ' ' + newToken;
-            await docuwareConfig.updateAttributes({
-                token,
-                expired: now + data.expires_in
-            });
-        }
-
         const headers = {
             headers: {
                 'Accept': 'application/json',
                 'Content-Type': 'application/json',
-                'Authorization': token
+                'Cookie': docuwareConfig.cookie
             }
         };
 
         return {
-            url,
+            url: docuwareConfig.url,
             headers
         };
     };

back/methods/docuware/specs/core.spec.js

@@ -2,54 +2,87 @@ const axios = require('axios');
 const models = require('vn-loopback/server/server').models;
 
 describe('Docuware core', () => {
-    const fileCabinetCode = 'deliveryNote';
+    beforeAll(() => {
-    beforeAll(async() => {
         process.env.NODE_ENV = 'testing';
+    });
 
-        const docuwareInfo = await models.Docuware.findOne({
+    afterAll(() => {
-            where: {
+        delete process.env.NODE_ENV;
-                code: fileCabinetCode
+    });
-            }
+
+    describe('getOptions()', () => {
+        it('should return url and headers', async() => {
+            const result = await models.Docuware.getOptions();
+
+            expect(result.url).toBeDefined();
+            expect(result.headers).toBeDefined();
         });
+    });
 
-        spyOn(axios, 'get').and.callFake(url => {
+    describe('getDialog()', () => {
-            if (url.includes('IdentityServiceInfo')) return {data: {IdentityServiceUrl: 'IdentityServiceUrl'}};
+        it('should return dialogId', async() => {
-            if (url.includes('IdentityServiceUrl')) return {data: {token_endpoint: 'token_endpoint'}};
+            const dialogs = {
-            if (url.includes('dialogs')) {
+                data: {
-                return {
+                    Dialog: [
-                    data: {
+                        {
-                        Dialog: [
+                            DisplayName: 'find',
-                            {
+                            Id: 'getDialogTest'
-                                DisplayName: 'find',
+                        }
-                                Id: 'getDialogTest'
+                    ]
-                            }
+                }
-                        ]
+            };
-                    }
+            spyOn(axios, 'get').and.returnValue(new Promise(resolve => resolve(dialogs)));
-                };
+            const result = await models.Docuware.getDialog('deliveryNote', 'find', 'randomFileCabinetId');
-            }
 
-            if (url.includes('FileCabinets')) {
+            expect(result).toEqual('getDialogTest');
-                return {data: {
+        });
+    });
+
+    describe('getFileCabinet()', () => {
+        it('should return fileCabinetId', async() => {
+            const code = 'deliveryNote';
+            const docuwareInfo = await models.Docuware.findOne({
+                where: {
+                    code
+                }
+            });
+            const dialogs = {
+                data: {
                     FileCabinet: [
                         {
                             Name: docuwareInfo.fileCabinetName,
                             Id: 'getFileCabinetTest'
                         }
                     ]
-                }};
+                }
-            }
+            };
+            spyOn(axios, 'get').and.returnValue(new Promise(resolve => resolve(dialogs)));
+            const result = await models.Docuware.getFileCabinet(code);
+
+            expect(result).toEqual('getFileCabinetTest');
+        });
+    });
+
+    describe('get()', () => {
+        it('should return data without parse', async() => {
+            spyOn(models.Docuware, 'getFileCabinet').and.returnValue((new Promise(resolve => resolve(Math.random()))));
+            spyOn(models.Docuware, 'getDialog').and.returnValue((new Promise(resolve => resolve(Math.random()))));
+            const data = {
+                data: {
+                    id: 1
+                }
+            };
+            spyOn(axios, 'post').and.returnValue(new Promise(resolve => resolve(data)));
+            const result = await models.Docuware.get('deliveryNote');
+
+            expect(result.id).toEqual(1);
         });
 
-        spyOn(axios, 'post').and.callFake(url => {
+        it('should return data with parse', async() => {
-            if (url.includes('token_endpoint')) {
+            spyOn(models.Docuware, 'getFileCabinet').and.returnValue((new Promise(resolve => resolve(Math.random()))));
-                return {data: {
+            spyOn(models.Docuware, 'getDialog').and.returnValue((new Promise(resolve => resolve(Math.random()))));
-                    access_token: 'access_token',
+            const data = {
-                    token_type: 'bearer',
+                data: {
-                    expires_in: 10000
-                }};
-            }
-            if (url.includes('DialogExpression')) {
-                return {data: {
                     Items: [{
                         Fields: [
                             {
@@ -70,52 +103,12 @@ describe('Docuware core', () => {
                         ]
                     }]
                 }
-                };
+            };
-            }
-        });
-    });
-
-    afterAll(() => {
-        delete process.env.NODE_ENV;
-    });
-
-    describe('getOptions()', () => {
-        it('should return url and headers', async() => {
-            const result = await models.Docuware.getOptions();
-
-            expect(result.url).toBeDefined();
-            expect(result.headers).toBeDefined();
-        });
-    });
-
-    describe('Dialog()', () => {
-        it('should return dialogId', async() => {
-            const result = await models.Docuware.getDialog('deliveryNote', 'find', 'randomFileCabinetId');
-
-            expect(result).toEqual('getDialogTest');
-        });
-    });
-
-    describe('getFileCabinet()', () => {
-        it('should return fileCabinetId', async() => {
-            const result = await models.Docuware.getFileCabinet(fileCabinetCode);
-
-            expect(result).toEqual('getFileCabinetTest');
-        });
-    });
-
-    describe('get()', () => {
-        it('should return data without parse', async() => {
-            const [result] = await models.Docuware.get('deliveryNote');
-
-            expect(result.firstRequiredField).toEqual(1);
-        });
-
-        it('should return data with parse', async() => {
             const parse = {
                 'firstRequiredField': 'id',
                 'secondRequiredField': 'name',
             };
+            spyOn(axios, 'post').and.returnValue(new Promise(resolve => resolve(data)));
             const [result] = await models.Docuware.get('deliveryNote', null, parse);
 
             expect(result.id).toEqual(1);
@@ -126,14 +119,17 @@ describe('Docuware core', () => {
 
     describe('getById()', () => {
         it('should return data', async() => {
-            spyOn(models.Docuware, 'get');
+            spyOn(models.Docuware, 'getFileCabinet').and.returnValue((new Promise(resolve => resolve(Math.random()))));
-            await models.Docuware.getById('deliveryNote', 1);
+            spyOn(models.Docuware, 'getDialog').and.returnValue((new Promise(resolve => resolve(Math.random()))));
+            const data = {
+                data: {
+                    id: 1
+                }
+            };
+            spyOn(axios, 'post').and.returnValue(new Promise(resolve => resolve(data)));
+            const result = await models.Docuware.getById('deliveryNote', 1);
 
-            expect(models.Docuware.get).toHaveBeenCalledWith(
+            expect(result.id).toEqual(1);
-                'deliveryNote',
-                {condition: [Object({DBName: 'N__ALBAR_N', Value: [1]})]},
-                undefined
-            );
         });
     });
 });

back/methods/docuware/upload.js

@@ -143,7 +143,7 @@ module.exports = Self => {
                 headers: {
                     'Content-Type': 'multipart/form-data',
                     'X-File-ModifiedDate': Date.vnNew(),
-                    'Authorization': docuwareOptions.headers.headers.Authorization,
+                    'Cookie': docuwareOptions.headers.headers.Cookie,
                     ...data.getHeaders()
                 },
             };

back/methods/machine-worker/specs/updateInTime.spec.js

@@ -0,0 +1,132 @@
+const {models} = require('vn-loopback/server/server');
+
+describe('machineWorker updateInTime()', () => {
+    const itBoss = 104;
+    const davidCharles = 1106;
+
+    beforeAll(async() => {
+        ctx = {
+            req: {
+                accessToken: {},
+                headers: {origin: 'http://localhost'},
+                __: value => value
+            }
+        };
+    });
+
+    it('should throw an error if the plate does not exist', async() => {
+        const tx = await models.MachineWorker.beginTransaction({});
+        const options = {transaction: tx};
+        const plate = 'RE-123';
+        ctx.req.accessToken.userId = 1106;
+        try {
+            await models.MachineWorker.updateInTime(ctx, plate, options);
+            await tx.rollback();
+        } catch (e) {
+            const error = e;
+
+            expect(error.message).toContain('the plate does not exist');
+            await tx.rollback();
+        }
+    });
+
+    it('should grab a machine where is not in use', async() => {
+        const tx = await models.MachineWorker.beginTransaction({});
+        const options = {transaction: tx};
+        const plate = 'RE-003';
+        ctx.req.accessToken.userId = 1107;
+        try {
+            const totalBefore = await models.MachineWorker.find(null, options);
+            await models.MachineWorker.updateInTime(ctx, plate, options);
+            const totalAfter = await models.MachineWorker.find(null, options);
+
+            expect(totalAfter.length).toEqual(totalBefore.length + 1);
+            await tx.rollback();
+        } catch (e) {
+            await tx.rollback();
+        }
+    });
+
+    describe('less than 12h', () => {
+        const plate = 'RE-001';
+        it('should trow an error if it is not himself', async() => {
+            const tx = await models.MachineWorker.beginTransaction({});
+            const options = {transaction: tx};
+            ctx.req.accessToken.userId = davidCharles;
+
+            try {
+                await models.MachineWorker.updateInTime(ctx, plate, options);
+                await tx.rollback();
+            } catch (e) {
+                const error = e;
+
+                expect(error.message).toContain('This machine is already in use');
+                await tx.rollback();
+            }
+        });
+
+        it('should throw an error if it is himself with a different machine', async() => {
+            const tx = await models.MachineWorker.beginTransaction({});
+            const options = {transaction: tx};
+            ctx.req.accessToken.userId = itBoss;
+            const plate = 'RE-003';
+            try {
+                await models.MachineWorker.updateInTime(ctx, plate, options);
+                await tx.rollback();
+            } catch (e) {
+                const error = e;
+
+                expect(error.message).toEqual('You are already using a machine');
+                await tx.rollback();
+            }
+        });
+
+        it('should set the out time if it is himself', async() => {
+            const tx = await models.MachineWorker.beginTransaction({});
+            const options = {transaction: tx};
+            ctx.req.accessToken.userId = itBoss;
+
+            try {
+                const isNotParked = await models.MachineWorker.findOne({
+                    where: {workerFk: itBoss}
+                }, options);
+                await models.MachineWorker.updateInTime(ctx, plate, options);
+                const isParked = await models.MachineWorker.findOne({
+                    where: {workerFk: itBoss}
+                }, options);
+
+                expect(isNotParked.outTime).toBeNull();
+                expect(isParked.outTime).toBeDefined();
+                await tx.rollback();
+            } catch (e) {
+                await tx.rollback();
+            }
+        });
+    });
+
+    describe('equal or more than 12h', () => {
+        const plate = 'RE-002';
+        it('should set the out time and grab the machine', async() => {
+            const tx = await models.MachineWorker.beginTransaction({});
+            const options = {transaction: tx};
+            ctx.req.accessToken.userId = davidCharles;
+            const filter = {
+                where: {workerFk: davidCharles, machineFk: 2}
+            };
+            try {
+                const isNotParked = await models.MachineWorker.findOne(filter, options);
+                const totalBefore = await models.MachineWorker.find(null, options);
+                await models.MachineWorker.updateInTime(ctx, plate, options);
+                const isParked = await models.MachineWorker.findOne(filter, options);
+                const totalAfter = await models.MachineWorker.find(null, options);
+
+                expect(isNotParked.outTime).toBeNull();
+                expect(isParked.outTime).toBeDefined();
+                expect(totalAfter.length).toEqual(totalBefore.length + 1);
+                await tx.rollback();
+            } catch (e) {
+                await tx.rollback();
+            }
+        });
+    });
+});

back/methods/machine-worker/updateInTime.js

@@ -0,0 +1,77 @@
+const UserError = require('vn-loopback/util/user-error');
+module.exports = Self => {
+    Self.remoteMethodCtx('updateInTime', {
+        description: 'Updates the corresponding registry if the worker has been registered in the last few hours',
+        accessType: 'WRITE',
+        accepts: [
+            {
+                arg: 'plate',
+                type: 'string',
+            }
+        ],
+        http: {
+            path: `/updateInTime`,
+            verb: 'POST'
+        }
+    });
+
+    Self.updateInTime = async(ctx, plate, options) => {
+        const models = Self.app.models;
+        const userId = ctx.req.accessToken.userId;
+        const $t = ctx.req.__;
+
+        let tx;
+        const myOptions = {};
+
+        if (typeof options == 'object')
+            Object.assign(myOptions, options);
+
+        if (!myOptions.transaction) {
+            tx = await Self.beginTransaction({});
+            myOptions.transaction = tx;
+        }
+
+        try {
+            const machine = await models.Machine.findOne({
+                fields: ['id', 'plate'],
+                where: {plate}
+            }, myOptions);
+
+            if (!machine)
+                throw new UserError($t('the plate does not exist', {plate}));
+
+            const machineWorker = await Self.findOne({
+                where: {
+                    or: [{machineFk: machine.id}, {workerFk: userId}],
+                    outTime: null,
+                }
+            }, myOptions);
+
+            const {maxHours} = await models.MachineWorkerConfig.findOne({fields: ['maxHours']}, myOptions);
+            const hoursDifference = (Date.vnNow() - machineWorker?.inTime?.getTime() ?? 0) / (60 * 60 * 1000);
+
+            if (machineWorker) {
+                const isHimself = userId == machineWorker.workerFk;
+                const isSameMachine = machine.id == machineWorker.machineFk;
+
+                if (hoursDifference < maxHours && !isHimself)
+                    throw new UserError($t('This machine is already in use.'));
+
+                if (hoursDifference < maxHours && isHimself && !isSameMachine)
+                    throw new UserError($t('You are already using a machine'));
+
+                await machineWorker.updateAttributes({
+                    outTime: Date.vnNew()
+                }, myOptions);
+            }
+
+            if (!machineWorker || hoursDifference >= maxHours)
+                await models.MachineWorker.create({machineFk: machine.id, workerFk: userId}, myOptions);
+
+            if (tx) await tx.commit();
+        } catch (e) {
+            if (tx) await tx.rollback();
+            throw e;
+        }
+    };
+};

back/methods/mrw-config/cancelShipment.js

@@ -24,13 +24,12 @@ module.exports = Self => {
 
     Self.cancelShipment = async expeditionFk => {
         const models = Self.app.models;
+
         const mrw = await models.MrwConfig.findOne();
         const {externalId} = await models.Expedition.findById(expeditionFk);
         const clientType = await models.MrwConfig.getClientType(expeditionFk);
         const template = fs.readFileSync(__dirname + '/cancelShipment.ejs', 'utf-8');
         const renderedXml = ejs.render(template, {mrw, externalId, clientType});
-
-        await Self.rawSql('CALL util.debugAdd(?,?);', ['cancelShipment', renderedXml]);
         const response = await axios.post(mrw.url, renderedXml, {
             headers: {
                 'Content-Type': 'application/soap+xml; charset=utf-8'
@@ -38,11 +37,9 @@ module.exports = Self => {
         });
 
         const xmlString = response.data;
-        await Self.rawSql('CALL util.debugAdd(?,?);', ['cancelShipmentResponse', xmlString]);
         const parser = new DOMParser();
         const xmlDoc = parser.parseFromString(xmlString, 'text/xml');
-
         const result = xmlDoc.getElementsByTagName('Mensaje')[0].textContent;
-        return ['no se ha encontrado', 'se ha cancelado correctamente'].some(res => result.toLowerCase().includes(res));
+        return result.toLowerCase().includes('se ha cancelado correctamente');
     };
 };

back/methods/mrw-config/specs/createShipment.spec.js

@@ -12,8 +12,9 @@ const ticket1 = {
     'addressFk': 1,
     'agencyModeFk': 999
 };
-let expedition;
+
 const expedition1 = {
+    'id': 17,
     'agencyModeFk': 999,
     'ticketFk': 44,
     'freightItemFk': 71,
@@ -46,7 +47,7 @@ describe('MRWConfig createShipment()', () => {
         await createMrwConfig();
 
         await models.Ticket.create(ticket1);
-        expedition = await models.Expedition.create(expedition1);
+        await models.Expedition.create(expedition1);
     });
 
     afterAll(async() => {
@@ -92,7 +93,7 @@ describe('MRWConfig createShipment()', () => {
     }
 
     it('should create a shipment and return a base64Binary label', async() => {
-        const {file} = await models.MrwConfig.createShipment(expedition.id);
+        const {file} = await models.MrwConfig.createShipment(expedition1.id);
 
         expect(file).toEqual(mockBase64Binary);
     });
@@ -100,7 +101,7 @@ describe('MRWConfig createShipment()', () => {
     it('should fail if mrwConfig has no data', async() => {
         let error;
         await models.MrwConfig.destroyAll();
-        await models.MrwConfig.createShipment(expedition.id).catch(e => {
+        await models.MrwConfig.createShipment(expedition1.id).catch(e => {
             error = e;
         }).finally(async() => {
             expect(error.message).toEqual(`MRW service is not configured`);
@@ -125,7 +126,7 @@ describe('MRWConfig createShipment()', () => {
         yesterday.setDate(yesterday.getDate() - 1);
 
         await models.Ticket.updateAll({id: ticket1.id}, {shipped: yesterday});
-        await models.MrwConfig.createShipment(expedition.id).catch(e => {
+        await models.MrwConfig.createShipment(expedition1.id).catch(e => {
             error = e;
         }).finally(async() => {
             expect(error.message).toEqual(`This ticket has a shipped date earlier than today`);
@@ -135,7 +136,7 @@ describe('MRWConfig createShipment()', () => {
 
     it('should send mail if you are past the dead line and is not notified today', async() => {
         await models.MrwConfig.updateAll({id: 1}, {expeditionDeadLine: '10:00:00', notified: null});
-        await models.MrwConfig.createShipment(expedition.id);
+        await models.MrwConfig.createShipment(expedition1.id);
         const notification = await getLastNotification();
 
         expect(notification.notificationFk).toEqual(filter.notificationFk);
@@ -143,7 +144,7 @@ describe('MRWConfig createShipment()', () => {
 
     it('should send mail if you are past the dead line and it is notified from another day', async() => {
         await models.MrwConfig.updateAll({id: 1}, {expeditionDeadLine: '10:00:00', notified: new Date()});
-        await models.MrwConfig.createShipment(expedition.id);
+        await models.MrwConfig.createShipment(expedition1.id);
         const notification = await getLastNotification();
 
         expect(notification.notificationFk).toEqual(filter.notificationFk);
@@ -151,7 +152,7 @@ describe('MRWConfig createShipment()', () => {
 
     it('should not send mail if you are past the dead line and it is notified', async() => {
         await models.MrwConfig.updateAll({id: 1}, {expeditionDeadLine: '10:00:00', notified: Date.vnNew()});
-        await models.MrwConfig.createShipment(expedition.id);
+        await models.MrwConfig.createShipment(expedition1.id);
         const notification = await getLastNotification();
 
         expect(notification).toEqual(null);

back/methods/osrm-config/optimize.js

@@ -1,112 +0,0 @@
-const UserError = require('vn-loopback/util/user-error');
-const axios = require('axios');
-
-module.exports = Self => {
-    Self.remoteMethod('optimize', {
-        description: 'Return optimized coords',
-        accessType: 'READ',
-        accepts: [{
-            arg: 'addressIds',
-            type: 'array',
-            required: true
-        }, {
-            arg: 'firstAddressId',
-            type: 'number',
-            required: false
-        }, {
-            arg: 'lastAddressId',
-            type: 'number',
-            required: false
-        }],
-        returns: {
-            type: 'object',
-            root: true
-        },
-        http: {
-            path: `/optimize`,
-            verb: 'GET'
-        }
-    });
-
-    Self.optimize = async(addressIds, firstAddressId, lastAddressId) => {
-        const models = Self.app.models;
-        try {
-            const osrmConfig = await models.OsrmConfig.findOne();
-            if (!osrmConfig) throw new UserError(`OSRM service is not configured`);
-
-            let coords = [];
-            if (firstAddressId) {
-                const address = await models.Address.findById(firstAddressId);
-                if (address.latitude && address.longitude) {
-                    coords.push({
-                        addressId: address.id,
-                        latitude: address.latitude.toFixed(6),
-                        longitude: address.longitude.toFixed(6)
-                    });
-                }
-            }
-
-            for (const addressId of addressIds) {
-                const address = await models.Address.findById(addressId);
-                if (address.latitude && address.longitude) {
-                    coords.push({
-                        addressId,
-                        latitude: address.latitude.toFixed(6),
-                        longitude: address.longitude.toFixed(6)
-                    });
-                }
-            }
-
-            if (lastAddressId) {
-                const firstAddress = await models.Address.findById(lastAddressId);
-                if (firstAddress.latitude && firstAddress.longitude) {
-                    coords.push({
-                        addressId: firstAddress.id,
-                        latitude: firstAddress.latitude.toFixed(6),
-                        longitude: firstAddress.longitude.toFixed(6)
-                    });
-                }
-            }
-
-            if (!coords.length) throw new UserError('No address has coordinates');
-
-            const concatCoords = coords
-                .map(coord => `${coord.longitude},${coord.latitude}`)
-                .join(';');
-            const response = await axios.post(`
-                ${osrmConfig.url}/trip/v1/driving/${concatCoords}?source=first&destination=last&roundtrip=true
-            `);
-            const tolerance = osrmConfig.tolerance;
-            for (const waypoint of response.data.waypoints) {
-                const longitude = waypoint.location[0];
-                const latitude = waypoint.location[1];
-
-                const matchedAddress = coords.find(coord =>
-                    coord.position === undefined &&
-                    Math.abs(coord.latitude - latitude) <= tolerance &&
-                    Math.abs(coord.longitude - longitude) <= tolerance
-                );
-                if (matchedAddress)
-                    matchedAddress.position = waypoint.waypoint_index;
-            }
-            coords.sort((a, b) => {
-                const posA = a.position !== undefined ? a.position : Infinity;
-                const posB = b.position !== undefined ? b.position : Infinity;
-                return posA - posB;
-            });
-
-            return coords;
-        } catch (err) {
-            switch (err.response?.data?.code) {
-            case 'NoTrips':
-                throw new UserError('No trips found because input coordinates are not connected');
-            case 'NotImplemented':
-                throw new UserError('This request is not supported');
-            case 'InvalidOptions':
-                throw new UserError('Invalid options or too many coordinates');
-            default:
-                throw err;
-            }
-        }
-    };
-};

back/methods/osrm-config/specs/optimize.spec.js

@@ -1,33 +0,0 @@
-const models = require('vn-loopback/server/server').models;
-
-describe('osrmConfig optimize()', function() {
-    it('should send coords, receive OSRM response, and return a correctly ordered result', async function() {
-        const result = await models.OsrmConfig.optimize([4, 3], 1, 2);
-
-        // Verifications
-        expect(Array.isArray(result)).toBe(true);
-        expect(result.length).toBe(4);
-
-        // Check the order
-        expect(result[0].addressId).toBe(1);
-        expect(result[1].addressId).toBe(4);
-        expect(result[2].addressId).toBe(3);
-        expect(result[3].addressId).toBe(2);
-
-        // Check the coordinates format
-        expect(result[0].latitude).toBe('10.111111');
-        expect(result[0].longitude).toBe('-74.111111');
-    });
-
-    it('should throw an error if no addresses are provided', async function() {
-        let error;
-        try {
-            await models.OsrmConfig.optimize([], null);
-        } catch (e) {
-            error = e;
-        }
-
-        expect(error).toBeDefined();
-        expect(error.message).toBe('No address has coordinates');
-    });
-});

back/methods/osticket/sendToSupport.js

@@ -29,34 +29,35 @@ module.exports = Self => {
     });
 
     Self.sendToSupport = async(ctx, reason, additionalData) => {
-        const userId = ctx.req.accessToken.userId;
         const emailUser =
-            await Self.app.models.EmailUser.findById(userId, {fields: ['email']});
+            await Self.app.models.EmailUser.findById(ctx.req.accessToken.userId, {fields: ['email']});
 
-        let html = `<h2>Motivo: ${reason}</h2>`;
+        let html = `<strong>Motivo</strong>:<br/>${reason}<br/>`;
-        html += `<h3>Usuario: ${userId} ${emailUser.email}</h3>`;
+        html += `<strong>Usuario</strong>:<br/>${ctx.req.accessToken.userId} ${emailUser.email}<br/>`;
-        html += `<h3>Additional Data:</h3>`;
-        html += '<ul>';
-        for (const [key, val] of Object.entries(additionalData)) {
-            if (key !== 'config') html += `<li>${key}: ${parse(val)}</li>`;
-            else {
-                html += `<li>${key}:</li><ul style="list-style-type: square;">`;
-                for (const [confKey, confVal] of Object.entries(val))
-                    html += `<li>${confKey}: ${parse(confVal)}</li>`;
-                html += '</ul>';
-            }
-        }
-        html += '</ul>';
 
-        const {message, path, name} = additionalData;
+        delete additionalData.backError.config.headers.Authorization;
+        const httpRequest = JSON.parse(additionalData?.httpRequest);
+
+        if (httpRequest)
+            delete httpRequest.config.headers.Authorization;
+        additionalData.httpRequest = httpRequest;
+
+        for (const data in additionalData)
+            html += `<strong>${data}</strong>:<br/>${tryParse(additionalData[data])}<br/>`;
+
+        const subjectReason = httpRequest?.data?.error;
         await smtp.send({
             to: `${config.app.reportEmail}, ${emailUser.email}`,
-            subject: `[Support-Salix] ${path} ${name}: ${message}`,
+            subject:
+                '[Support-Salix] ' +
+                additionalData?.frontPath + ' ' +
+                subjectReason?.name + ':' +
+                subjectReason?.message,
             html
         });
     };
 
-    function parse(value) {
+    function tryParse(value) {
         try {
             try {
                 value = JSON.parse(value);

back/methods/postcode/specs/filter.spec.js

@@ -29,7 +29,7 @@ describe('Postcode filter()', () => {
                 }
             }, options);
 
-            expect(results.length).toEqual(5);
+            expect(results.length).toEqual(4);
             await tx.rollback();
         } catch (e) {
             await tx.rollback();
@@ -63,7 +63,7 @@ describe('Postcode filter()', () => {
                 search: 'one',
             }}, options);
 
-            expect(results.length).toEqual(5);
+            expect(results.length).toEqual(4);
             await tx.rollback();
         } catch (e) {
             await tx.rollback();

back/methods/url/getUrl.js

@@ -22,7 +22,7 @@ module.exports = Self => {
         const url = await Self.app.models.Url.findOne({
             where: {
                 appName,
-                environment: process.env.NODE_ENV || 'development'
+                environment: process.env.NODE_ENV || 'dev'
             }
         });
         return url?.url;

back/methods/vn-token/killSession.js

@@ -1,29 +0,0 @@
-module.exports = Self => {
-    Self.remoteMethodCtx('killSession', {
-        description: 'Kill session',
-        accepts: [{
-            arg: 'userId',
-            type: 'integer',
-            description: 'The user id',
-            required: true,
-        }, {
-            arg: 'created',
-            type: 'date',
-            description: 'The created time',
-            required: true,
-        }],
-        accessType: 'WRITE',
-        http: {
-            path: `/killSession`,
-            verb: 'POST'
-        }
-    });
-
-    Self.killSession = async function(ctx, userId, created) {
-        await Self.app.models.VnUser.userSecurity(ctx, ctx.req.accessToken.userId);
-        const tokens = await Self.app.models.AccessToken.find({where: {userId, created}});
-        if (!tokens?.length) return;
-        for (const token of tokens)
-            await Self.app.models.AccessToken.deleteById(token.id);
-    };
-};

back/methods/vn-user/acls.js

@@ -19,7 +19,7 @@ module.exports = Self => {
                 if (acl.principalType == 'ROLE' && acl.permission == 'ALLOW') {
                     const staticAcl = {
                         model: model.name,
-                        property: acl.property,
+                        property: '*',
                         accessType: acl.accessType,
                         permission: acl.permission,
                         principalType: acl.principalType,

back/methods/vn-user/renew-token.js

@@ -30,11 +30,8 @@ module.exports = Self => {
 
             // Schedule to remove current token
             setTimeout(async() => {
-                try {
+                if (await models.AccessToken.findById(token.id))
                     await Self.logout(token.id);
-                } catch (error) {
-                    // FIXME: Crash if do throw new Error(error)
-                }
             }, courtesyTime * 1000);
 
             // Get scopes

back/methods/vn-user/specs/renew-token.spec.js

@@ -72,9 +72,9 @@ describe('Renew Token', () => {
         }
 
         expect(error).toBeDefined();
+        const query = 'SELECT * FROM util.debug';
 
-        const query = 'SELECT * FROM util.debug WHERE variable = "renewToken"';
+        const debugLog = await models.Application.rawSql(query, null);
-        const debugLog = await models.Application.rawSql(query);
 
         expect(debugLog.length).toEqual(1);
     });

back/methods/vn-user/update-user.js

@@ -22,11 +22,11 @@ module.exports = Self => {
                 description: 'The user email'
             }, {
                 arg: 'lang',
-                type: 'any',
+                type: 'string',
                 description: 'The user lang'
             }, {
                 arg: 'twoFactor',
-                type: 'any',
+                type: 'string',
                 description: 'The user twoFactor'
             }
         ],

back/methods/workerActivity/add.js

@@ -31,7 +31,7 @@ module.exports = Self => {
         return await Self.rawSql(`
             INSERT INTO workerActivity (workerFk, workerActivityTypeFk, model)
                 SELECT ?, ?, ?
-                    FROM workerTimeControlConfig wtcc
+                    FROM workerTimeControlParams wtcp
                         LEFT JOIN (
                             SELECT wa.workerFk,
                                 wa.created,
@@ -44,7 +44,7 @@ module.exports = Self => {
                         ) sub ON TRUE
                     WHERE sub.workerFk IS NULL
                         OR sub.code <> ? 
-                        OR TIMESTAMPDIFF(SECOND, sub.created, util.VN_NOW()) > wtcc.dayBreak;`
+                        OR TIMESTAMPDIFF(SECOND, sub.created, util.VN_NOW()) > wtcp.dayBreak;`
         , [userId, code, model, userId, code], myOptions);
     };
 };

back/methods/workerActivity/specs/add.spec.js

@@ -10,10 +10,10 @@ describe('workerActivity insert()', () => {
 
         try {
             await models.WorkerActivityType.create(
-                {'code': 'TEST', 'description': 'TEST'}, options
+                {'code': 'STOP', 'description': 'STOP'}, options
             );
 
-            await models.WorkerActivity.add(ctx, 'TEST', 'APP', options);
+            await models.WorkerActivity.add(ctx, 'STOP', 'APP', options);
 
             count = await models.WorkerActivity.count(
                 {'workerFK': 1106}, options

back/model-config.json

@@ -79,19 +79,19 @@
     "ImageCollectionSize": {
         "dataSource": "vn"
     },
-    "ImageConfig": {
-        "dataSource": "vn"
-    },
     "ImageContainer": {
         "dataSource": "imageStorage"
     },
     "Language": {
         "dataSource": "vn"
     },
-    "OsrmConfig": {
+    "Machine": {
         "dataSource": "vn"
     },
-    "Machine": {
+    "MachineWorker": {
+        "dataSource": "vn"
+    },
+    "MachineWorkerConfig": {
         "dataSource": "vn"
     },
     "MobileAppVersionControl": {
@@ -130,15 +130,9 @@
     "Payment": {
         "dataSource": "vn"
     },
-    "PbxConfig": {
-        "dataSource": "vn"
-    },
     "Postcode": {
         "dataSource": "vn"
     },
-    "Prefix": {
-        "dataSource": "vn"
-    },
     "ReferenceRate": {
         "dataSource": "vn"
     },
@@ -148,12 +142,6 @@
     "StarredModule": {
         "dataSource": "vn"
     },
-    "SaySimpleCountry": {
-        "dataSource": "vn"
-    },
-    "SaySimpleConfig": {
-        "dataSource": "vn"
-    },
     "TempContainer": {
         "dataSource": "tempStorage"
     },
@@ -184,15 +172,9 @@
     "PrintConfig": {
         "dataSource": "vn"
     },
-    "QueueMember": {
-        "dataSource": "vn"
-    },
     "ViaexpressConfig": {
         "dataSource": "vn"
     },
-    "VnToken": {
-        "dataSource": "vn"
-    },
     "VnUser": {
         "dataSource": "vn"
     },

back/models/autonomy.json

@@ -16,10 +16,6 @@
         "name": {
             "type": "string",
             "required": true
-        },
-        "hasDailyInvoice": {
-            "type": "boolean",
-            "description": "Indicates if the autonomy has daily invoice enabled"
         }
     },
     "relations": {

back/models/country.json

@@ -28,10 +28,6 @@
         },
         "continentFk": {
             "type": "number"
-        },
-        "hasDailyInvoice": {
-            "type": "boolean",
-            "description": "Indicates if the autonomy has daily invoice enabled"
         }
     },
     "relations": {
@@ -44,11 +40,6 @@
             "type": "belongsTo",
             "model": "Continent",
             "foreignKey": "continentFk"
-        },
-        "saySimpleCountry": {
-            "type": "hasOne",
-            "model": "SaySimpleCountry",
-            "foreignKey": "countryFk"
         }
     },
     "acls": [

back/models/docuware-config.json

@@ -16,17 +16,17 @@
         "url": {
             "type": "string"
         },
-        "token": {
+        "cookie": {
             "type": "string"
-        },
-        "username": {
-            "type": "string"
-        },
-        "password": {
-            "type": "string"
-        },
-        "expired":{
-            "type": "number"
         }
-    }
+    },
+    "acls": [
+        {
+            "property": "*",
+            "accessType": "*",
+            "principalType": "ROLE",
+            "principalId": "$everyone",
+            "permission": "ALLOW"
+	    }
+    ]
 }

back/models/expedition_PrintOut.json

@@ -14,6 +14,9 @@
         },
         "itemFk": {
             "type": "number"
+        },
+        "isChecked": {
+            "type": "boolean"
         }
     }
 }

back/models/image-config.json

@@ -1,22 +0,0 @@
-{
-    "name": "ImageConfig",
-    "base": "VnModel",
-    "options": {
-        "mysql": {
-            "table": "hedera.imageConfig"
-        }
-    },
-    "properties": {
-        "url": {
-            "type": "string"
-        }
-    },
-    "acls": [
-        {
-            "accessType": "READ",
-            "principalType": "ROLE",
-            "principalId": "$authenticated",
-            "permission": "ALLOW"
-        }
-    ]
-}

back/models/machine-worker-config.json

@@ -0,0 +1,18 @@
+{
+	"name": "MachineWorkerConfig",
+	"base": "VnModel",
+	"options": {
+		"mysql": {
+			"table": "vn.machineWorkerConfig"
+		}
+	},
+	"properties": {
+        "id": {
+            "type": "number",
+            "id": true
+        },
+        "maxHours": {
+            "type": "number"
+        }
+	}
+}

back/models/machine-worker.js

@@ -0,0 +1,3 @@
+module.exports = Self => {
+    require('../methods/machine-worker/updateInTime')(Self);
+};

back/models/machine-worker.json

@@ -0,0 +1,33 @@
+{
+	"name": "MachineWorker",
+	"base": "VnModel",
+	"options": {
+		"mysql": {
+			"table": "vn.machineWorker"
+		}
+	},
+	"properties": {
+		"id": {
+			"type": "number",
+			"id": true
+		},
+		"workerFk": {
+			"type": "number"
+		},
+		"machineFk": {
+			"type": "number"
+		},
+		"inTime": {
+			"type": "date",
+			"mysql": {
+				"columnName": "inTimed"
+			}
+		},
+		"outTime": {
+			"type": "date",
+			"mysql": {
+				"columnName": "outTimed"
+			}
+		}
+	}
+}

back/models/osrm-config.js

@@ -1,4 +0,0 @@
-module.exports = Self => {
-    require('../methods/osrm-config/optimize')(Self);
-};
-

back/models/osrm-config.json

@@ -1,24 +0,0 @@
-{
-	"name": "OsrmConfig",
-	"base": "VnModel",
-	"options": {
-		"mysql": {
-			"table": "osrmConfig"
-		}
-	},
-	"properties": {
-		"id": {
-			"type": "number",
-			"id": true,
-			"required": true
-		},
-		"url": {
-			"type": "string",
-			"required": true
-		},
-		"tolerance": {
-			"type": "number",
-			"required": false
-		}
-	}
-}

back/models/pbx-config.json

@@ -1,27 +0,0 @@
-{
-    "name": "PbxConfig",
-    "base": "VnModel",
-    "options": {
-        "mysql": {
-            "table": "pbx.config"
-        }
-    },
-    "properties": {
-        "id": {
-            "type": "number",
-            "id": true
-        },
-        "defaultPrefix": {
-            "type": "string"
-        }
-    },
-    "acls": [
-        {
-            "property": "*",
-            "accessType": "READ",
-            "principalType": "ROLE",
-            "principalId": "employee",
-            "permission": "ALLOW"
-        }
-    ]
-}

back/models/prefix.json

@@ -1,27 +0,0 @@
-{
-    "name": "Prefix",
-    "base": "VnModel",
-    "options": {
-        "mysql": {
-            "table": "pbx.prefix"
-        }
-    },
-    "properties": {
-        "country": {
-            "type": "string",
-            "id": true
-        },
-        "prefix": {
-            "type": "string"
-        }
-    },
-    "acls": [
-        {
-            "property": "*",
-            "accessType": "READ",
-            "principalType": "ROLE",
-            "principalId": "employee",
-            "permission": "ALLOW"
-        }
-    ]
-}

back/models/production-config.json

@@ -20,9 +20,6 @@
 		},
 		"backupPrinterNotificationDelay": {
 			"type": "string"
-		},
-		"itemOrderReviewHours": {
-			"type": "number"
 		}
 	}
 }

back/models/province.json

@@ -16,9 +16,6 @@
         "name": {
             "type": "string",
             "required": true
-        },
-        "autonomyFk": {
-            "type": "number"
         }
     },
     "relations": {

back/models/queue-member.json

@@ -1,38 +0,0 @@
-{
-    "name": "QueueMember",
-    "base": "VnModel",
-    "options": {
-        "mysql": {
-            "table": "pbx.queueMember"
-        }
-    },
-    "properties": {
-        "id": {
-            "type": "number",
-            "id": true
-        },
-        "queue": {
-            "type": "string"
-        },
-        "extension": {
-            "type": "string"
-        }
-    },
-    "relations": {
-        "queueRelation": {
-            "type": "belongsTo",
-            "model": "Queue",
-            "foreignKey": "queue",
-            "primaryKey": "name"
-        }
-    },
-    "acls": [
-        {
-            "property": "*",
-            "accessType": "READ",
-            "principalType": "ROLE",
-            "principalId": "employee",
-            "permission": "ALLOW"
-        }
-    ]
-}

back/models/say-simple-config.json

@@ -1,29 +0,0 @@
-{
-    "name": "SaySimpleConfig",
-    "base": "VnModel",
-    "options": {
-        "mysql": {
-            "table": "saySimpleConfig"
-        }
-    },
-    "properties": {
-        "id": {
-            "type": "number",
-            "id": true
-        },
-        "url": {
-            "type": "string"
-        },
-        "defaultChannel": {
-            "type": "number"
-        }
-    },
-    "acls": [
-        {
-            "accessType": "READ",
-            "principalType": "ROLE",
-            "principalId": "$authenticated",
-            "permission": "ALLOW"
-        }
-    ]
-}

back/models/say-simple-country.json

@@ -1,26 +0,0 @@
-{
-    "name": "SaySimpleCountry",
-    "base": "VnModel",
-    "options": {
-        "mysql": {
-            "table": "saySimpleCountry"
-        }
-    },
-    "properties": {
-        "countryFk": {
-            "type": "number",
-            "id": true
-        },
-        "channel": {
-            "type": "number"
-        }
-    },
-    "acls": [
-        {
-            "accessType": "READ",
-            "principalType": "ROLE",
-            "principalId": "$authenticated",
-            "permission": "ALLOW"
-        }
-    ]
-}

back/models/vn-token.js

@@ -1,5 +0,0 @@
-const vnModel = require('vn-loopback/common/models/vn-model');
-module.exports = function(Self) {
-    vnModel(Self);
-    require('../methods/vn-token/killSession')(Self);
-};

back/models/vn-token.json

@@ -1,22 +0,0 @@
-{
-    "name": "VnToken",
-    "base": "AccessToken",
-    "options": {
-        "mysql": {
-            "table": "salix.AccessToken"
-        }
-    },
-    "properties": {
-        "created": {
-            "type": "date"
-        }
-    },
-    "relations": {
-        "user": {
-            "type": "belongsTo",
-            "model": "VnUser",
-            "foreignKey": "userId"
-        }
-    },
-    "hidden": ["id"]
-}

back/models/vn-user.json

@@ -165,8 +165,7 @@
                 "hasGrant",
                 "realm",
                 "email",
-                "emailVerified",
+                "emailVerified"
-                "twoFactor"
             ]
         }
     }

back/models/warehouse.json

@@ -25,9 +25,6 @@
     "isManaged": {
       "type": "boolean"
     },
-    "isDestiny": {
-      "type": "boolean"
-    },
     "countryFk": {
       "type": "number"
     }

back/process.yml

@@ -0,0 +1,7 @@
+apps:
+  - script: ./loopback/server/server.js
+    name: salix-back
+    instances: 1
+    max_restarts: 0
+    autorestart: false
+    node_args: --tls-min-v1.0 --openssl-legacy-provider

db/.pullinfo.json

@@ -9,7 +9,7 @@
     },
     "vn": {
       "view": {
-        "expeditionPallet_Print": "04fc5f2967ce53bfbb85f7f48b9a3dca4a4f7111ac41e1775f4cc7d6538774b2"
+        "expeditionPallet_Print": "ced2b84a114fcb99fce05f0c34f4fc03f3fa387bef92621be1bc306608a84345"
       }
     }
   }

db/dump/dump.before.sql

@@ -1,14 +1 @@
 -- Executed before dump
-
-CREATE USER 'vn'@'localhost';
-
-GRANT SELECT,
-        INSERT,
-        UPDATE,
-        DELETE,
-        DROP,
-        CREATE TEMPORARY TABLES,
-        EXECUTE,
-        EVENT,
-        TRIGGER
-    ON *.* TO 'vn'@'localhost';

db/routines/account/views/myUser.sql

@@ -7,7 +7,8 @@ AS SELECT `u`.`id` AS `id`,
 	`u`.`email` AS `email`,
 	`u`.`nickname` AS `nickname`,
 	`u`.`lang` AS `lang`,
-	`u`.`role` AS `role`
+	`u`.`role` AS `role`,
+	`u`.`recoverPass` AS `recoverPass`
 FROM `account`.`user` `u`
 WHERE `u`.`name` = `myUser_getName`()
 WITH CASCADED CHECK OPTION

db/routines/bi/procedures/rutasAnalyze.sql

@@ -19,14 +19,14 @@ BEGIN
 			bultos)
 		SELECT r.id,
 				r.agencyModeFk,
-				r.dated,
+				r.created,
 				SUM(sv.volume / ebv.m3)
 			FROM vn.route r
 				JOIN vn.ticket t ON t.routeFk = r.id
 				LEFT JOIN vn.`zone` z ON z.id = t.zoneFk
 				JOIN vn.saleVolume sv ON sv.ticketFk = t.id
 				JOIN vn.expeditionBoxVol ebv ON ebv.code = 'transportBox'
-			WHERE r.dated BETWEEN vDatedFrom AND vDatedTo
+			WHERE r.created BETWEEN vDatedFrom AND vDatedTo
 				AND z.isVolumetric
 			GROUP BY r.id;
 		
@@ -38,12 +38,12 @@ BEGIN
 			Bultos)
 		SELECT r.id,
 				r.agencyModeFk,
-				r.dated,
+				r.created,
 				SUM(t.packages)
 			FROM vn.route r
 				JOIN vn.ticket t ON t.routeFk = r.id
 				LEFT JOIN vn.`zone` z ON z.id = t.zoneFk
-			WHERE r.dated BETWEEN vDatedFrom AND vDatedTo
+			WHERE r.created BETWEEN vDatedFrom AND vDatedTo
 				AND NOT z.isVolumetric
 			GROUP BY r.id
 		ON DUPLICATE KEY UPDATE Bultos = Bultos + VALUES(Bultos);
@@ -60,7 +60,7 @@ BEGIN
 						JOIN vn.component c ON c.id = sc.componentFk
 						JOIN vn.componentType ct ON ct.id = c.typeFk
 					WHERE ct.code = 'freight'
-						AND r.dated BETWEEN vDatedFrom AND vDatedTo
+						AND r.created BETWEEN vDatedFrom AND vDatedTo
 					GROUP BY r.id
 			 ) sub ON sub.routeFk = r.Id_Ruta
 		SET r.practico = IFNULL(sub.totalPractice / r.Bultos, 0);
@@ -77,7 +77,7 @@ BEGIN
 					JOIN vn.address ad ON ad.id = t.addressFk
 					JOIN vn.client c ON c.id = ad.clientFk
 					LEFT JOIN vn.`zone` z ON z.id = t.zoneFk
-				WHERE r.dated BETWEEN vDatedFrom AND vDatedTo
+				WHERE r.created BETWEEN vDatedFrom AND vDatedTo
 					AND NOT z.isVolumetric
 				GROUP BY t.routeFk
 			) sub ON r.Id_Ruta = sub.routeFk
@@ -93,7 +93,7 @@ BEGIN
 					JOIN vn.saleVolume sf ON sf.ticketFk = t.id
 					JOIN vn.client c ON c.id = t.clientFk
 					JOIN vn.`zone` z ON z.id = t.zoneFk
-				WHERE r.dated BETWEEN vDatedFrom AND vDatedTo
+				WHERE r.created BETWEEN vDatedFrom AND vDatedTo
 					AND z.isVolumetric
 				GROUP BY t.routeFk
 			) sub ON r.Id_Ruta = sub.routeFk
@@ -108,7 +108,7 @@ BEGIN
 					JOIN vn.route r ON r.id = t.routeFk
 					JOIN vn.greuge g ON g.ticketFk = t.id
 					JOIN vn.greugeType gt ON gt.id = g.greugeTypeFk
-				WHERE r.dated BETWEEN vDatedFrom AND vDatedTo
+				WHERE r.created BETWEEN vDatedFrom AND vDatedTo
 					AND gt.code = 'freightDifference'
 				GROUP BY t.routeFk
 			) sub ON r.Id_Ruta = sub.routeFk

db/routines/bi/views/rotacion.sql

@@ -0,0 +1,15 @@
+CREATE OR REPLACE DEFINER=`root`@`localhost`
+	SQL SECURITY DEFINER
+	VIEW `bi`.`rotacion`
+AS SELECT `ic`.`itemFk` AS `Id_Article`,
+	`ic`.`warehouseFk` AS `warehouse_id`,
+	`ic`.`quantity` AS `total`,
+	`ic`.`rotation` AS `rotacion`,
+	`ic`.`cm3` AS `cm3`,
+	`ic`.`storage` AS `almacenaje`,
+	`ic`.`handling` AS `manipulacion`,
+	`ic`.`extraCharge` AS `auxiliar`,
+	`ic`.`wasted` AS `mermas`,
+	`ic`.`cm3delivery` AS `cm3reparto`,
+	`ic`.`grams` AS `grams`
+FROM `vn`.`itemCost` `ic`

db/routines/bs/procedures/clientNewBorn_recalc.sql

@@ -6,27 +6,25 @@ BLOCK1: BEGIN
 	DECLARE vShipped DATE; 
 	DECLARE vPreviousShipped DATE;
 	DECLARE vDone boolean;  
+	DECLARE cur cursor for         
 	 
-	DECLARE cur CURSOR FOR  
+	SELECT clientFk, firstShipped  
-		SELECT clientFk, firstShipped  
+		FROM bs.clientNewBorn;  
-			FROM bs.clientNewBorn;    
         
 	DECLARE continue HANDLER FOR NOT FOUND SET vDone = TRUE;      
 	SET vDone := FALSE;  
 
 	DELETE FROM	bs.clientNewBorn WHERE isModified = FALSE;
 
-	INSERT INTO clientNewBorn(clientFk, firstShipped, lastShipped)
+        INSERT INTO clientNewBorn(clientFk, firstShipped, lastShipped)
-		SELECT  c.id, DATE(MAX(t.shipped)), DATE(MAX(t.shipped))
+			SELECT  c.id, MAX(t.shipped), MAX(t.shipped)
-			FROM vn.client c
+				FROM vn.client c
-				JOIN vn.ticket t ON t.clientFk =  c.id
+					JOIN vn.ticket t on t.clientFk =  c.id
-				LEFT JOIN clientNewBorn cb ON cb.clientFk = c.id
+                    LEFT JOIN clientNewBorn cb on cb.clientFk = c.id
-			WHERE t.shipped BETWEEN util.VN_CURDATE() - INTERVAL 1 YEAR 
+				WHERE t.shipped BETWEEN TIMESTAMPADD(YEAR, -1, util.VN_CURDATE()) AND util.VN_CURDATE() AND cb.isModified is null
-					AND util.VN_CURDATE() 
+				GROUP BY c.id;
-				AND cb.isModified IS NULL
-			GROUP BY c.id;
-
 	OPEN cur;
+     
 	LOOP1: LOOP
 		SET vDone := FALSE;
 		FETCH cur INTO vClientFk, vShipped;

db/routines/bs/procedures/inventoryDiscrepancyDetail_replace.sql

@@ -32,7 +32,7 @@ BEGIN
 		CREATE OR REPLACE TEMPORARY TABLE tVisible
 			SELECT itemFk, SUM(visible) totalVisible
 				FROM vn.itemShelving ish
-					JOIN vn.shelving sh ON sh.id = ish.shelvingFk
+					JOIN vn.shelving sh ON sh.code = ish.shelvingFk
 					JOIN vn.parking p ON p.id = sh.parkingFk
 					JOIN vn.sector sc ON sc.id = p.sectorFk
 					WHERE sc.warehouseFk = vWarehouseFk

db/routines/bs/procedures/waste_addSales.sql

@@ -1,70 +1,32 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `bs`.`waste_addSales`(
+CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `bs`.`waste_addSales`()
-	vDateFrom DATE, 
-	vDateTo DATE
-)
 BEGIN
-/**
+ 	DECLARE vDateFrom DATE DEFAULT util.VN_CURDATE() - INTERVAL WEEKDAY(util.VN_CURDATE()) DAY;
- * Recalcula las mermas de un periodo.
+	DECLARE vDateTo DATE DEFAULT vDateFrom + INTERVAL 6 DAY;
- * 
- * @param vDateFrom Fecha desde
- * @param vDateTo Fecha hasta
- */
-	DECLARE vDaysInYear INT;
-	SET vDaysInYear = DATEDIFF(util.lastDayOfYear(CURDATE()), util.firstDayOfYear(CURDATE()));
-
-	SET vDateFrom = COALESCE(vDateFrom, util.VN_CURDATE());
-	SET vDateTo = COALESCE(vDateTo, util.VN_CURDATE());
-
-	IF DATEDIFF(vDateTo, vDateFrom) > vDaysInYear THEN
-		CALL util.throw('The period cannot be longer than one year');
-	END IF;
-
-	-- Obtiene el primer día de la semana de esa fecha
-	SET vDateFrom = DATE_SUB(vDateFrom, INTERVAL ((WEEKDAY(vDateFrom) + 1) % 7) DAY);
-
-	-- Obtiene el último día de la semana de esa fecha
-	SET vDateTo = DATE_ADD(vDateTo, INTERVAL (6 - ((WEEKDAY(vDateTo) + 1) % 7)) DAY);
 
 	CALL cache.last_buy_refresh(FALSE);
 
 	REPLACE bs.waste
-		SELECT YEARWEEK(t.shipped, 6) DIV 100,
+		SELECT YEAR(t.shipped),
-				WEEK(t.shipped, 6),
+				WEEK(t.shipped, 4),
 				it.workerFk,
 				it.id,
 				s.itemFk,
 				SUM((b.buyingValue + b.freightValue + b.comissionValue + b.packageValue) * s.quantity),
 				SUM(IF(aw.`type`, s.quantity, 0)),
-				SUM(IF(
+				SUM(
+					IF(
+						aw.`type` = 'internal',
+						(b.buyingValue + b.freightValue + b.comissionValue + b.packageValue) * s.quantity,
+						0
+					)
+				),		
+				SUM(
+					IF(
 						aw.`type` = 'external',
 						(b.buyingValue + b.freightValue + b.comissionValue + b.packageValue) * s.quantity,
 						0
 					)
-				),
-				SUM(IF(
-						aw.`type` = 'fault',
-						(b.buyingValue + b.freightValue + b.comissionValue + b.packageValue) * s.quantity,
-						0
-					)
-				),
-				SUM(IF(
-						aw.`type` = 'container',
-						(b.buyingValue + b.freightValue + b.comissionValue + b.packageValue) * s.quantity,
-						0
-					)
-				),
-				SUM(IF(
-						aw.`type` = 'break',
-						(b.buyingValue + b.freightValue + b.comissionValue + b.packageValue) * s.quantity,
-						0
-					)
-				),
-				SUM(IF(
-						aw.`type` = 'other',
-						(b.buyingValue + b.freightValue + b.comissionValue + b.packageValue) * s.quantity,
-						0
-					)
 				)
 			FROM vn.sale s
 				JOIN vn.item i ON i.id = s.itemFk
@@ -76,8 +38,8 @@ BEGIN
 				JOIN cache.last_buy lb ON lb.item_id = i.id
 					AND lb.warehouse_id = w.id
 				JOIN vn.buy b ON b.id = lb.buy_id
-			WHERE t.shipped BETWEEN vDateFrom AND util.dayEnd(vDateTo)
+			WHERE t.shipped BETWEEN vDateFrom AND vDateTo
 				AND w.isManaged
-			GROUP BY YEARWEEK(t.shipped, 6) DIV 100, WEEK(t.shipped, 6), i.id;
+			GROUP BY i.id;
 END$$
 DELIMITER ;

db/routines/bs/procedures/waste_addSalesLauncher.sql

@@ -1,6 +0,0 @@
-DELIMITER $$
-CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `bs`.`waste_addSalesLauncher`()
-BEGIN
-	CALL waste_addSales(NULL, NULL);
-END$$
-DELIMITER ;

db/routines/cache/procedures/availableNoRaids_refresh.sql

@@ -53,7 +53,7 @@ proc: BEGIN
 					WHERE t.landed BETWEEN vInventoryDate AND vStartDate
 						AND t.warehouseInFk = vWarehouse
 						AND s.name != 'INVENTARIO'
-						AND NOT t.isRaid
+						AND NOT e.isRaid
 					GROUP BY b.itemFk
 			) c
 				JOIN vn.item i ON i.id = c.itemFk

db/routines/cache/procedures/available_refresh.sql

@@ -1,10 +1,5 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `cache`.`available_refresh`(
+CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `cache`.`available_refresh`(OUT `vCalc` INT, IN `vRefresh` INT, IN `vWarehouse` INT, IN `vDated` DATE)
-	OUT `vCalc` INT,
-	`vRefresh` INT,
-	`vWarehouse` INT,
-	`vDated` DATE
-)
 proc: BEGIN
 	DECLARE vStartDate DATE;
 	DECLARE vReserveDate DATETIME;

db/routines/cache/procedures/available_updateItem.sql

@@ -1,31 +0,0 @@
-DELIMITER $$
-CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `cache`.`available_updateItem`(
-	`vItem` INT,
-	`vWarehouse` INT,
-	`vDated` DATE,
-	`vQuantity` INT
-)
-BEGIN
-/**
- * Immediately deduct/add an amount from the available cache (if exists).
- *
- * @param vItem The item id
- * @param vWarehouse The warehouse id
- * @param vDated Available cache date
- * @param vQuantity The amount to be deducted from the cache
- */
-	DECLARE vCalc INT;
-
-	SELECT id INTO vCalc
-		FROM cache_calc
-		WHERE cacheName = 'available'
-			AND params = CONCAT_WS('/', vWarehouse, vDated);
-
-	IF vCalc IS NOT NULL THEN
-		UPDATE available
-			SET available = available - vQuantity
-			WHERE calc_id = vCalc
-				AND item_id = vItem;
-	END IF;
-END$$
-DELIMITER ;

db/routines/cache/procedures/last_buy_refresh.sql

@@ -4,7 +4,7 @@ proc: BEGIN
 /**
  * Crea o actualiza la cache con la última compra y fecha de cada
  * artículo hasta ayer. Para obtener la última compra hasta una fecha
- * determinada utilizar el procedimiento vn.buy_getUltimate().
+ * determinada utilizar el procedimiento vn.buyUltimate().
  *
  * @param vRefresh %TRUE para forzar el recálculo de la cache
  */

db/routines/edi/events/floramondo.sql

@@ -0,0 +1,8 @@
+DELIMITER $$
+CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `edi`.`floramondo`
+	ON SCHEDULE EVERY 6 MINUTE
+		STARTS '2022-01-28 09:52:45.000'
+	ON COMPLETION NOT PRESERVE
+	DISABLE
+DO CALL edi.floramondo_offerRefresh()$$
+DELIMITER ;

db/routines/edi/procedures/floramondo_offerRefresh.sql

@@ -0,0 +1,522 @@
+DELIMITER $$
+CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `edi`.`floramondo_offerRefresh`()
+proc: BEGIN
+	DECLARE vLanded DATETIME;
+	DECLARE vDone INT DEFAULT FALSE;
+	DECLARE vFreeId INT;
+	DECLARE vSupplyResponseFk INT;
+	DECLARE vLastInserted DATETIME;
+	DECLARE vIsAuctionDay BOOLEAN;
+	DECLARE vMaxNewItems INT DEFAULT 10000;
+	DECLARE vStartingTime DATETIME;
+	DECLARE vAalsmeerMarketPlaceID VARCHAR(13) DEFAULT '8713783439043';
+	DECLARE vDayRange INT;
+
+	DECLARE cur1 CURSOR FOR
+		SELECT id
+			FROM edi.item_free;
+
+	DECLARE cur2 CURSOR FOR
+		SELECT srId
+			FROM itemToInsert;
+
+	DECLARE CONTINUE HANDLER FOR NOT FOUND SET vDone = TRUE;
+	DECLARE EXIT HANDLER FOR SQLSTATE '45000'
+	BEGIN
+		ROLLBACK;
+		RESIGNAL;
+	END;
+
+	DECLARE CONTINUE HANDLER FOR SQLEXCEPTION
+	BEGIN
+		DO RELEASE_LOCK('edi.floramondo_offerRefresh');
+		SET @isTriggerDisabled = FALSE;
+		RESIGNAL;
+	END;
+
+	IF 'test' = (SELECT environment FROM util.config) THEN
+		LEAVE proc;
+	END IF;
+
+	IF !GET_LOCK('edi.floramondo_offerRefresh', 0) THEN
+		LEAVE proc;
+	END IF;
+
+	SELECT dayRange INTO vDayRange 
+		FROM offerRefreshConfig;
+
+	IF vDayRange IS NULL THEN
+		CALL util.throw("Variable vDayRange not declared");
+	END IF;
+
+	SET vStartingTime = util.VN_NOW();
+
+	TRUNCATE edi.offerList;
+
+	INSERT INTO edi.offerList(supplier, total)
+		SELECT v.name, COUNT(DISTINCT sr.ID) total
+			FROM edi.supplyResponse sr
+					JOIN edi.VMPSettings v ON v.VMPID = sr.vmpID
+				WHERE sr.NumberOfUnits > 0
+					AND sr.EmbalageCode != 999
+				GROUP BY sr.vmpID;
+
+	UPDATE edi.offerList o
+		JOIN (SELECT v.name, COUNT(*) total
+			FROM edi.supplyOffer sr
+				JOIN edi.VMPSettings v ON v.VMPID = sr.vmpID
+				GROUP BY sr.vmpID) sub ON o.supplier = sub.name
+		SET o.`filter` = sub.total;
+
+	-- Elimina de la lista de items libres aquellos que ya existen
+	DELETE itf.*
+		FROM edi.item_free itf
+			JOIN vn.item i ON i.id = itf.id;
+
+	CREATE OR REPLACE TEMPORARY TABLE tmp
+	(INDEX (`Item_ArticleCode`))
+	ENGINE = MEMORY
+		SELECT 	t.*
+			FROM (
+				SELECT *
+					FROM edi.supplyOffer
+					ORDER BY (MarketPlaceID = vAalsmeerMarketPlaceID) DESC,
+						NumberOfUnits DESC LIMIT 10000000000000000000) t
+		GROUP BY t.srId;
+
+	CREATE OR REPLACE TEMPORARY TABLE edi.offer (INDEX (`srID`), INDEX (`EmbalageCode`),
+		INDEX (`ef1`), INDEX (`ef2`), INDEX (`ef3`), INDEX (`ef4`),INDEX (`ef5`), INDEX (`ef6`),
+		INDEX (`s1Value`), INDEX (`s2Value`), INDEX (`s3Value`), INDEX (`s4Value`),INDEX (`s5Value`), INDEX (`s6Value`))
+	ENGINE = MEMORY
+		SELECT so.*,
+				ev1.type_description s1Value,
+				ev2.type_description s2Value,
+				ev3.type_description s3Value,
+				ev4.type_description s4Value,
+				ev5.type_description s5Value,
+				ev6.type_description s6Value,
+				eif1.feature ef1,
+				eif2.feature ef2,
+				eif3.feature ef3,
+				eif4.feature ef4,
+				eif5.feature ef5,
+				eif6.feature ef6
+			FROM tmp so
+				LEFT JOIN edi.item_feature eif1 ON eif1.item_id = so.Item_ArticleCode
+					AND eif1.presentation_order = 1
+					AND eif1.expiry_date IS NULL
+				LEFT JOIN edi.item_feature eif2 ON eif2.item_id = so.Item_ArticleCode
+					AND eif2.presentation_order = 2
+					AND eif2.expiry_date IS NULL
+				LEFT JOIN edi.item_feature eif3 ON eif3.item_id = so.Item_ArticleCode
+					AND eif3.presentation_order = 3
+					AND eif3.expiry_date IS NULL
+				LEFT JOIN edi.item_feature eif4 ON eif4.item_id = so.Item_ArticleCode
+					AND eif4.presentation_order = 4
+					AND eif4.expiry_date IS NULL
+				LEFT JOIN edi.item_feature eif5 ON eif5.item_id = so.Item_ArticleCode
+					AND eif5.presentation_order = 5
+					AND eif5.expiry_date IS NULL
+				LEFT JOIN edi.item_feature eif6 ON eif6.item_id = so.Item_ArticleCode
+					AND eif6.presentation_order = 6
+					AND eif6.expiry_date IS NULL
+				LEFT JOIN edi.`value` ev1 ON ev1.type_id = eif1.feature
+					AND so.s1 = ev1.type_value
+				LEFT JOIN edi.`value` ev2 ON ev2.type_id = eif2.feature
+					AND so.s2 = ev2.type_value
+				LEFT JOIN edi.`value` ev3 ON ev3.type_id = eif3.feature
+					AND so.s3 = ev3.type_value
+				LEFT JOIN edi.`value` ev4 ON ev4.type_id = eif4.feature
+					AND so.s4 = ev4.type_value
+				LEFT JOIN edi.`value` ev5 ON ev5.type_id = eif5.feature
+					AND so.s5 = ev5.type_value
+				LEFT JOIN edi.`value` ev6 ON ev6.type_id = eif6.feature
+					AND so.s6 = ev6.type_value
+			ORDER BY Price;
+
+	DROP TEMPORARY TABLE tmp;
+
+	DELETE o
+		FROM edi.offer o
+			LEFT JOIN vn.tag t1 ON t1.ediTypeFk = o.ef1 AND t1.overwrite = 'size'
+			LEFT JOIN vn.tag t2 ON t2.ediTypeFk = o.ef2 AND t2.overwrite = 'size'
+			LEFT JOIN vn.tag t3 ON t3.ediTypeFk = o.ef3 AND t3.overwrite = 'size'
+			LEFT JOIN vn.tag t4 ON t4.ediTypeFk = o.ef4 AND t4.overwrite = 'size'
+			LEFT JOIN vn.tag t5 ON t5.ediTypeFk = o.ef5 AND t5.overwrite = 'size'
+			LEFT JOIN vn.tag t6 ON t6.ediTypeFk = o.ef6 AND t6.overwrite = 'size'
+			JOIN vn.floramondoConfig fc ON TRUE
+		WHERE (t1.id IS NOT NULL AND CONVERT(s1Value, UNSIGNED) > fc.itemMaxSize)
+			OR (t2.id IS NOT NULL AND CONVERT(s2Value, UNSIGNED) > fc.itemMaxSize)
+			OR (t3.id IS NOT NULL AND CONVERT(s3Value, UNSIGNED) > fc.itemMaxSize)
+			OR (t4.id IS NOT NULL AND CONVERT(s4Value, UNSIGNED) > fc.itemMaxSize)
+			OR (t5.id IS NOT NULL AND CONVERT(s5Value, UNSIGNED) > fc.itemMaxSize)
+			OR (t6.id IS NOT NULL AND CONVERT(s6Value, UNSIGNED) > fc.itemMaxSize);
+
+	START TRANSACTION;
+
+	-- Actualizamos el campo supplyResponseFk para aquellos articulos que ya estan creados y reutilizamos
+	UPDATE IGNORE edi.offer o
+			JOIN vn.item i
+				ON i.name = o.product_name
+				AND i.subname <=> o.company_name
+				AND i.value5 <=> o.s1Value
+				AND i.value6 <=> o.s2Value
+				AND i.value7 <=> o.s3Value
+				AND i.value8 <=> o.s4Value
+				AND i.value9 <=> o.s5Value
+				AND i.value10 <=> o.s6Value
+				AND i.NumberOfItemsPerCask <=> o.NumberOfItemsPerCask
+				AND i.EmbalageCode <=> o.EmbalageCode
+				AND i.quality <=> o.Quality
+			JOIN vn.itemType it ON it.id = i.typeFk
+			LEFT JOIN vn.sale s ON s.itemFk = i.id
+			LEFT JOIN vn.ticket t ON t.id = s.ticketFk
+				AND t.shipped > (util.VN_CURDATE() - INTERVAL 1 WEEK)
+			LEFT JOIN edi.supplyResponse sr ON sr.ID = i.supplyResponseFk
+			LEFT JOIN edi.deliveryInformation di ON di.supplyResponseID = sr.ID
+			LEFT JOIN edi.putOrder po ON po.supplyResponseID = i.supplyResponseFk
+				AND po.OrderTradeLineDateTime > (util.VN_CURDATE() - INTERVAL 1 WEEK)
+		SET i.supplyResponseFk = o.srID
+		WHERE (sr.ID IS NULL
+				OR sr.NumberOfUnits = 0
+				OR di.LatestOrderDateTime < util.VN_NOW()
+				OR di.ID IS NULL)
+			AND it.isInventory
+			AND t.id IS NULL
+			AND po.id IS NULL;
+
+	CREATE OR REPLACE TEMPORARY TABLE itemToInsert
+	ENGINE = MEMORY
+		SELECT o.*, CAST(NULL AS DECIMAL(6,0)) itemFk
+			FROM edi.offer o
+				LEFT JOIN vn.item i ON i.supplyResponseFk = o.srId
+		WHERE i.id IS NULL
+	LIMIT vMaxNewItems;
+
+	-- Reciclado de nº de item
+	OPEN cur1;
+	OPEN cur2;
+
+	read_loop: LOOP
+
+		FETCH cur2 INTO vSupplyResponseFk;
+		FETCH cur1 INTO vFreeId;
+
+		IF vDone THEN
+			LEAVE read_loop;
+		END IF;
+
+		UPDATE itemToInsert
+			SET itemFk = vFreeId
+			WHERE srId = vSupplyResponseFk;
+
+	END LOOP;
+
+	CLOSE cur1;
+	CLOSE cur2;
+
+	-- Insertamos todos los items en Articles de la oferta
+	INSERT INTO vn.item(id,
+					`name`,
+					longName,
+					subName,
+					expenseFk,
+					typeFk,
+					intrastatFk,
+					originFk,
+					supplyResponseFk,
+					numberOfItemsPerCask,
+					embalageCode,
+					quality,
+					isFloramondo)
+		SELECT iti.itemFk,
+				iti.product_name,
+				iti.product_name,
+				iti.company_name,
+				iti.expenseFk,
+				iti.itemTypeFk,
+				iti.intrastatFk,
+				iti.originFk,
+				iti.`srId`,
+				iti.NumberOfItemsPerCask,
+				iti.EmbalageCode,
+				iti.Quality,
+				TRUE
+		FROM itemToInsert iti;
+
+	-- Inserta la foto de los articulos nuevos (prioridad alta)
+	INSERT IGNORE INTO vn.itemImageQueue(itemFk, url)
+		SELECT i.id, PictureReference
+			FROM itemToInsert ii
+				JOIN vn.item i ON i.supplyResponseFk = ii.srId
+			WHERE PictureReference IS NOT NULL
+				AND i.image IS NULL;
+
+	INSERT INTO edi.`log`(tableName, fieldName,fieldValue)
+		SELECT 'itemImageQueue','NumImagenesPtes', COUNT(*)
+			FROM vn.itemImageQueue
+			WHERE attempts = 0;
+
+	-- Inserta si se añadiesen tags nuevos
+	INSERT IGNORE INTO vn.tag (name, ediTypeFk)
+		SELECT description, type_id FROM edi.type;
+
+	-- Desabilita el trigger para recalcular los tags al final
+	SET @isTriggerDisabled = TRUE;
+
+	-- Inserta los tags sólo en los articulos nuevos
+	INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
+		SELECT i.id, t.id , ii.product_name, 1
+			FROM itemToInsert ii
+				JOIN vn.tag t ON t.`name` = 'Producto'
+				JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
+			WHERE NOT ii.product_name IS NULL;
+			
+	INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
+		SELECT i.id, t.id , ii.Quality, 3
+			FROM itemToInsert ii
+				JOIN vn.tag t ON t.`name` = 'Calidad'
+				JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
+			WHERE NOT ii.Quality IS NULL;
+			
+	INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
+		SELECT i.id, t.id , ii.company_name, 4
+			FROM itemToInsert ii
+				JOIN vn.tag t ON t.`name` = 'Productor'
+				JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
+			WHERE NOT ii.company_name IS NULL;
+
+	INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
+		SELECT i.id, t.id , s1Value, 5
+			FROM itemToInsert ii
+				JOIN vn.tag t ON t.ediTypeFk = ii.ef1
+				JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
+			WHERE NOT s1Value IS NULL;
+
+	INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
+		SELECT i.id, t.id , s2Value, 6
+			FROM itemToInsert ii
+				JOIN vn.tag t ON t.ediTypeFk = ii.ef2
+				JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
+			WHERE NOT s2Value IS NULL;
+
+	INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
+		SELECT i.id, t.id , s3Value, 7
+			FROM itemToInsert ii
+				JOIN vn.tag t ON t.ediTypeFk = ii.ef3
+				JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
+			WHERE NOT s3Value IS NULL;
+
+	INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
+		SELECT i.id, t.id , s4Value, 8
+			FROM itemToInsert ii
+				JOIN vn.tag t ON t.ediTypeFk = ii.ef4
+				JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
+			WHERE NOT s4Value IS NULL;
+
+	INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
+		SELECT i.id, t.id , s5Value, 9
+			FROM itemToInsert ii
+				JOIN vn.tag t ON t.ediTypeFk = ii.ef5
+				JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
+			WHERE NOT s5Value IS NULL;
+
+	INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
+		SELECT i.id, t.id , s6Value, 10
+			FROM itemToInsert ii
+				JOIN vn.tag t ON t.ediTypeFk = ii.ef6
+				JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
+			WHERE NOT s6Value IS NULL;
+
+	INSERT IGNORE INTO vn.itemTag(itemFk, tagFk, value, priority)
+		SELECT i.id, t.id, IFNULL(ink.name, ik.color), 11
+			FROM itemToInsert ii
+				JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
+				JOIN vn.tag t ON t.`name` = 'Color'
+				LEFT JOIN edi.feature f ON f.item_id = ii.Item_ArticleCode
+				LEFT JOIN edi.`type` tp ON tp.type_id = f.feature_type_id
+					AND tp.`description` = 'Hoofdkleur 1'
+				LEFT JOIN vn.ink ON ink.dutchCode = f.feature_value
+				LEFT JOIN vn.itemInk ik ON ik.longName = i.longName
+			WHERE ink.name IS NOT NULL
+				OR ik.color IS NOT NULL;
+
+	CREATE OR REPLACE TABLE tmp.item
+		(PRIMARY KEY (id))
+		SELECT i.id FROM vn.item i
+			JOIN itemToInsert ii ON i.supplyResponseFk = ii.`srId`;
+
+	CALL vn.item_refreshTags();
+
+	DROP TABLE tmp.item;
+
+	SELECT MIN(LatestDeliveryDateTime) INTO vLanded
+		FROM edi.supplyResponse sr
+			JOIN edi.deliveryInformation di ON di.supplyResponseID = sr.ID
+			JOIN edi.marketPlace mp ON mp.id = sr.MarketPlaceID
+			JOIN vn.floramondoConfig fc
+		WHERE mp.isLatestOrderDateTimeRelevant
+			AND di.LatestOrderDateTime > IF(
+				fc.MaxLatestOrderHour > HOUR(util.VN_NOW()),
+				util.VN_CURDATE(),
+				util.VN_CURDATE() + INTERVAL 1 DAY);
+
+	UPDATE vn.floramondoConfig
+		SET nextLanded = vLanded
+		WHERE vLanded IS NOT NULL;
+
+	-- Elimina la oferta obsoleta
+	UPDATE vn.buy b
+			JOIN vn.entry e ON e.id = b.entryFk
+			JOIN vn.travel tr ON tr.id = e.travelFk
+			JOIN vn.agencyMode am ON am.id = tr.agencyModeFk
+			JOIN vn.item i ON i.id = b.itemFk
+			LEFT JOIN edi.supplyResponse sr ON i.supplyResponseFk = sr.ID
+			LEFT JOIN edi.deliveryInformation di ON di.ID = b.deliveryFk
+		SET b.quantity = 0
+		WHERE (IFNULL(di.LatestOrderDateTime,util.VN_NOW()) <= util.VN_NOW()
+			OR i.supplyResponseFk IS NULL
+			OR sr.NumberOfUnits = 0)
+			AND am.name = 'LOGIFLORA'
+			AND e.isRaid;
+
+	-- Localiza las entradas de cada almacen
+	UPDATE edi.warehouseFloramondo
+		SET entryFk = vn.entry_getForLogiflora(vLanded + INTERVAL travellingDays DAY, warehouseFk);
+
+	IF vLanded IS NOT NULL THEN
+		-- Actualiza la oferta existente
+		UPDATE vn.buy b
+				JOIN edi.warehouseFloramondo wf ON wf.entryFk = b.entryFk
+				JOIN vn.item i ON i.id = b.itemFk
+				JOIN edi.offer o ON i.supplyResponseFk = o.`srId`
+			SET b.quantity = o.NumberOfUnits * o.NumberOfItemsPerCask,
+				b.buyingValue = o.price
+			WHERE (b.quantity <> o.NumberOfUnits * o.NumberOfItemsPerCask
+				OR b.buyingValue <> o.price);
+
+		-- Inserta el resto
+		SET vLastInserted := util.VN_NOW();
+
+		-- Inserta la oferta
+		INSERT INTO vn.buy (
+				entryFk,
+				itemFk,
+				quantity,
+				buyingValue,
+				stickers,
+				packing,
+				`grouping`,
+				groupingMode,
+				packagingFk,
+				deliveryFk)
+			SELECT wf.entryFk,
+					i.id,
+					o.NumberOfUnits * o.NumberOfItemsPerCask quantity,
+					o.Price,
+					o.NumberOfUnits etiquetas,
+					o.NumberOfItemsPerCask packing,
+					GREATEST(1, IFNULL(o.MinimumQuantity,0)) * o.NumberOfItemsPerCask `grouping`,
+					'packing',
+					o.embalageCode,
+					o.diId
+				FROM edi.offer o
+					JOIN vn.item i ON i.supplyResponseFk = o.srId
+					JOIN edi.warehouseFloramondo wf
+					JOIN vn.packaging p ON p.id
+						LIKE o.embalageCode
+					LEFT JOIN vn.buy b ON b.itemFk = i.id
+						AND b.entryFk = wf.entryFk
+				WHERE b.id IS NULL; -- Quitar esta linea y mirar de crear los packages a tiempo REAL
+
+			INSERT INTO vn.itemCost(
+					itemFk,
+					warehouseFk,
+					cm3,
+					cm3delivery)
+				SELECT b.itemFk,
+						wf.warehouseFk,
+						@cm3 := vn.buy_getUnitVolume(b.id),
+						IFNULL((vc.standardFlowerBox * 1000) / i.packingOut, @cm3)
+					FROM warehouseFloramondo wf
+						JOIN vn.volumeConfig vc
+						JOIN vn.buy b ON b.entryFk = wf.entryFk
+						JOIN vn.item i ON i.id = b.itemFk
+						LEFT JOIN vn.itemCost ic ON ic.itemFk = b.itemFk
+							AND ic.warehouseFk = wf.warehouseFk
+					WHERE (ic.cm3 IS NULL OR ic.cm3 = 0)
+						ON DUPLICATE KEY UPDATE cm3 = @cm3, cm3delivery = IFNULL((vc.standardFlowerBox * 1000) / i.packingOut, @cm3);
+
+			CREATE OR REPLACE TEMPORARY TABLE tmp.buyRecalc
+			SELECT b.id
+				FROM vn.buy b
+					JOIN warehouseFloramondo wf ON wf.entryFk = b.entryFk
+				WHERE b.created >= vLastInserted;
+		
+			CALL vn.buy_recalcPrices();
+
+			UPDATE edi.offerList o
+				JOIN (SELECT v.name, COUNT(DISTINCT b.itemFk) total
+						FROM vn.buy b
+							JOIN vn.item i ON i.id = b.itemFk
+							JOIN edi.supplyResponse sr ON sr.ID = i.supplyResponseFk
+							JOIN edi.VMPSettings v ON v.VMPID = sr.vmpID
+							JOIN edi.warehouseFloramondo wf ON wf.entryFk = b.entryFk
+							JOIN vn.warehouse w ON w.id = wf.warehouseFk
+							WHERE w.name = 'VNH'
+								AND b.quantity > 0
+						GROUP BY sr.vmpID) sub ON o.supplier = sub.name
+				SET o.vnh = sub.total;
+		
+			UPDATE edi.offerList o
+				JOIN (SELECT v.name, COUNT(DISTINCT b.itemFk) total
+						FROM vn.buy b
+							JOIN vn.item i ON i.id = b.itemFk
+							JOIN edi.supplyResponse sr ON sr.ID = i.supplyResponseFk
+							JOIN edi.VMPSettings v ON v.VMPID = sr.vmpID
+							JOIN edi.warehouseFloramondo wf ON wf.entryFk = b.entryFk
+							JOIN vn.warehouse w ON w.id = wf.warehouseFk
+							WHERE w.name = 'ALGEMESI'
+								AND b.quantity > 0
+						GROUP BY sr.vmpID) sub ON o.supplier = sub.name
+				SET o.algemesi = sub.total;
+	END IF;
+
+	DROP TEMPORARY TABLE
+		edi.offer,
+		itemToInsert;
+
+	SET @isTriggerDisabled = FALSE;
+
+	COMMIT;
+
+	-- Esto habria que pasarlo a procesos programados o trabajar con tags y dejar las familias
+	UPDATE vn.item i
+		SET typeFk = 121
+		WHERE i.longName LIKE 'Rosa Garden %'
+			AND typeFk = 17;
+
+	UPDATE vn.item i
+		SET typeFk = 156
+		WHERE i.longName LIKE 'Rosa ec %'
+			AND typeFk = 17;
+		
+	-- Refresca las fotos de los items existentes que mostramos (prioridad baja)
+	INSERT IGNORE INTO vn.itemImageQueue(itemFk, url, priority)
+		SELECT i.id, sr.PictureReference, 100
+			FROM edi.supplyResponse sr
+				JOIN vn.item i ON i.supplyResponseFk = sr.ID
+				JOIN edi.supplyOffer so ON so.srId = sr.ID
+				JOIN hedera.image i2 ON i2.name = i.image 
+					AND i2.collectionFk = 'catalog'
+			WHERE i2.updated <= (UNIX_TIMESTAMP(util.VN_NOW()) - vDayRange)
+				AND sr.NumberOfUnits;
+
+	INSERT INTO edi.`log`
+		SET tableName = 'floramondo_offerRefresh',
+			fieldName = 'Tiempo de proceso',
+			fieldValue = TIMEDIFF(util.VN_NOW(), vStartingTime);
+
+	DO RELEASE_LOCK('edi.floramondo_offerRefresh');
+END$$
+DELIMITER ;

db/routines/edi/triggers/supplyResponse_afterUpdate.sql

@@ -14,7 +14,7 @@ BEGIN
 			b.stickers = NEW.NumberOfUnits
 		WHERE i.supplyResponseFk = NEW.ID
 			AND am.name = 'LOGIFLORA'
-			AND tr.isRaid
+			AND e.isRaid
 			AND tr.landed >= util.VN_CURDATE();
 	
 END$$

db/routines/hedera/procedures/item_getVisible.sql

@@ -59,7 +59,7 @@ BEGIN
 						JOIN vn.travel t ON t.id = e.travelFk
 					WHERE t.landed BETWEEN vDateInv AND vDate
 						AND t.warehouseInFk = vWarehouse
-						AND NOT t.isRaid
+						AND NOT e.isRaid
 				UNION ALL
 				SELECT b.itemFk, -b.quantity
 					FROM vn.buy b
@@ -67,7 +67,7 @@ BEGIN
 						JOIN vn.travel t ON t.id = e.travelFk
 					WHERE t.shipped BETWEEN vDateInv AND util.VN_CURDATE()
 						AND t.warehouseOutFk = vWarehouse
-						AND NOT t.isRaid
+						AND NOT e.isRaid
 						AND t.isDelivered
 				UNION ALL
 				SELECT m.itemFk, -m.quantity

db/routines/hedera/procedures/orderRow_updateOverstocking.sql

@@ -1,52 +0,0 @@
-DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost`
-PROCEDURE `hedera`.`orderRow_updateOverstocking`(vOrderFk INT)
-BEGIN
-/**
-* Set amount = 0 to avoid overbooking sales
-*
-* @param vOrderFk hedera.order.id
-*/
-	DECLARE vCalcFk INT;
-	DECLARE vDone BOOL;
-	DECLARE vWarehouseFk INT;
-
-	DECLARE cWarehouses CURSOR FOR
-		SELECT DISTINCT warehouseFk
-		FROM orderRow
-		WHERE orderFk = vOrderFk
-			AND shipment = util.VN_CURDATE();
-
-	DECLARE CONTINUE HANDLER FOR NOT FOUND SET vDone = TRUE;
-
-	DECLARE EXIT HANDLER FOR SQLEXCEPTION
-	BEGIN
-		ROLLBACK;
-		RESIGNAL;
-	END;
-
-	OPEN cWarehouses;
-	checking: LOOP
-		SET vDone = FALSE;
-
-		FETCH cWarehouses INTO vWarehouseFk;
-
-		IF vDone THEN
-			LEAVE checking;
-		END IF;
-
-		CALL cache.available_refresh(vCalcFk, FALSE, vWarehouseFk, util.VN_CURDATE());
-
-		UPDATE orderRow r
-				JOIN `order` o ON o.id = r.orderFk
-				JOIN orderConfig oc
-				JOIN cache.available a ON a.calc_id = vCalcFk AND a.item_id = r.itemFk
-			SET r.amount = 0
-			WHERE ADDTIME(o.rowUpdated, oc.reserveTime) < util.VN_NOW()
-				AND a.available <= 0
-				AND r.warehouseFk = vWarehouseFk
-				AND r.orderFk = vOrderFk;
-	END LOOP;
-	CLOSE cWarehouses;
-END$$
-DELIMITER ;

db/routines/hedera/procedures/order_addItem.sql

@@ -1,8 +1,8 @@
 DELIMITER $$
 CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `hedera`.`order_addItem`(
 	vSelf INT,
-	vWarehouse INT,
+    vWarehouse INT,
-	vItem INT,
+    vItem INT,
 	vAmount INT)
 BEGIN
 /**
@@ -47,15 +47,11 @@ BEGIN
 		FROM tmp.zoneGetShipped
 		WHERE warehouseFk = vWarehouse;
 
-	SELECT available INTO vAvailable
+	SELECT IFNULL(available, 0) INTO vAvailable
 		FROM tmp.ticketLot
 		WHERE warehouseFk = vWarehouse
 			AND itemFk = vItem;
 
-	IF vAvailable IS NULL THEN
-		SET vAvailable = 0;
-	END IF;
-
 	IF vAmount > vAvailable THEN
 		CALL util.throw ('ORDER_ROW_UNAVAILABLE');
 	END IF;
@@ -106,8 +102,6 @@ BEGIN
 			amount = vAdd,
 			price = vPrice;
 
-		CALL cache.available_updateItem(vItem, vWarehouse, vShipment, vAdd);
-
 		SET vRow = LAST_INSERT_ID();
 
 		INSERT INTO orderRowComponent (rowFk, componentFk, price)
@@ -127,6 +121,6 @@ BEGIN
 	END IF;
 
 	COMMIT;
-	CALL vn.ticketCalculatePurge;
+    CALL vn.ticketCalculatePurge;
 END$$
 DELIMITER ;

db/routines/hedera/procedures/order_confirmWithUser.sql

@@ -12,7 +12,6 @@ BEGIN
  * @param vUser The user identifier
  */
 	DECLARE vHasRows BOOL;
-	DECLARE vHas0Amount BOOL;
 	DECLARE vDone BOOL;
 	DECLARE vWarehouseFk INT;
 	DECLARE vShipment DATE;
@@ -22,6 +21,7 @@ BEGIN
 	DECLARE vItemFk INT;
 	DECLARE vConcept VARCHAR(30);
 	DECLARE vAmount INT;
+	DECLARE vAvailable INT;
 	DECLARE vPrice DECIMAL(10,2);
 	DECLARE vSaleFk INT;
 	DECLARE vRowFk INT;
@@ -31,6 +31,7 @@ BEGIN
 	DECLARE vClientFk INT;
 	DECLARE vCompanyFk INT;
 	DECLARE vAgencyModeFk INT;
+	DECLARE vCalcFk INT;
 	DECLARE vIsTaxDataChecked BOOL;
 
 	DECLARE vDates CURSOR FOR
@@ -96,20 +97,6 @@ BEGIN
 		SELECT employeeFk INTO vUserFk FROM orderConfig;
 	END IF;
 
-	CALL orderRow_updateOverstocking(vSelf);
-
-	-- Check if any product has a quantity of 0
-	SELECT EXISTS (
-		SELECT id
-			FROM orderRow
-			WHERE orderFk = vSelf
-				AND amount = 0
-	) INTO vHas0Amount;
-
-	IF vHas0Amount THEN
-		CALL util.throw('orderLinesWithZero');
-	END IF;
-
 	START TRANSACTION;
 
 	CALL order_checkEditable(vSelf);

db/routines/hedera/procedures/order_getTax.sql

@@ -9,54 +9,45 @@ BEGIN
  * @param vOrder El identificador del pedido
  * @return tmp.orderTax Bases imponibles, IVA y recargo de equivalencia
  */
- 	-- No poner create or replace, ya que da problemas
 	DROP TEMPORARY TABLE IF EXISTS tmp.addressCompany;
 	CREATE TEMPORARY TABLE tmp.addressCompany
 		(INDEX (addressFk, companyFk))
 		ENGINE = MEMORY 
 		SELECT DISTINCT o.address_id addressFk, o.company_id companyFk
 			FROM tmp.`order` tmpOrder
-				JOIN `order` o ON o.id = tmpOrder.orderFk;
+				JOIN hedera.`order` o ON o.id = tmpOrder.orderFk;
 
-	CALL vn.addressTaxArea();
+	CALL vn.addressTaxArea;
 
 	-- Calcula el IVA y el recargo desglosado.
-	CREATE OR REPLACE TEMPORARY TABLE tmp.orderTax
-		(PRIMARY KEY (orderFk, code, rate))
-		ENGINE = MEMORY
-		WITH orders AS (
-			SELECT tor.orderFk,
-					oro.amount * oro.price total,
-					s.countryFk,
-					ata.areaFk,
-					itc.taxClassFk
-				FROM hedera.orderRow oro
-					JOIN tmp.order tor ON tor.orderFk = oro.orderFk
-					JOIN hedera.`order` o ON o.id = tor.orderFk
-					JOIN vn.item i ON i.id = oro.itemFk
-					JOIN vn.`client` c ON c.id = o.customer_id
-					JOIN vn.supplier s ON s.id = o.company_id
-					JOIN tmp.addressTaxArea ata ON ata.addressFk = o.address_id
-						AND ata.companyFk = o.company_id
-					JOIN vn.itemTaxCountry itc ON itc.itemFk = i.id
-						AND itc.countryFk = s.countryFk
-				HAVING total
-		)
-		SELECT o.orderFk,
-				tc.code,
-				SUM(o.total) taxableBase,
-				pgc.rate
-			FROM orders o
-				JOIN vn.bookingPlanner bp ON bp.countryFk = o.countryFk
-					AND bp.taxAreaFk = o.areaFk
-					AND bp.taxClassFk = o.taxClassFk
-				JOIN vn.pgc ON pgc.code = bp.pgcFk
-				JOIN vn.taxClass tc ON tc.id = bp.taxClassFk
-			GROUP BY o.orderFk, pgc.code, pgc.rate
-			HAVING taxableBase
-			ORDER BY bp.priority;
 
-	-- No poner create or replace, ya que da problemas
+	DROP TEMPORARY TABLE IF EXISTS tmp.orderTax;
+	CREATE TEMPORARY TABLE tmp.orderTax
+		(INDEX (orderFk))
+		ENGINE = MEMORY
+		SELECT o.id orderFk,
+				tc.code,
+				SUM(m.amount * m.price) taxableBase,
+				pgc.rate
+			FROM tmp.`order` tmpOrder
+				JOIN `order` o ON o.id = tmpOrder.orderFk
+				JOIN orderRow m ON m.orderFk = o.id
+				JOIN vn.item i ON i.id = m.itemFk
+				JOIN vn.`client` c ON c.id = o.customer_id
+				JOIN vn.supplier s ON s.id = o.company_id
+				JOIN tmp.addressTaxArea ata
+					ON ata.addressFk = o.address_id AND ata.companyFk = o.company_id
+				JOIN vn.itemTaxCountry itc
+					ON itc.itemFk = i.id AND itc.countryFk = s.countryFk
+				JOIN vn.bookingPlanner bp
+					ON bp.countryFk = s.countryFk
+						AND bp.taxAreaFk = ata.areaFk
+						AND bp.taxClassFk = itc.taxClassFk
+				JOIN vn.pgc ON pgc.`code` = bp.pgcFk
+				JOIN vn.taxClass tc ON tc.id = bp.taxClassFk
+			GROUP BY tmpOrder.orderFk, pgc.`code`, pgc.rate
+			HAVING taxableBase != 0;
+					
 	DROP TEMPORARY TABLE IF EXISTS tmp.orderAmount;
 	CREATE TEMPORARY TABLE tmp.orderAmount
 		(INDEX (orderFk))

db/routines/hedera/triggers/orderRow_afterInsert.sql

@@ -1,10 +0,0 @@
-DELIMITER $$
-CREATE OR REPLACE DEFINER=`root`@`localhost` TRIGGER `hedera`.`orderRow_afterInsert`
-	AFTER INSERT ON `orderRow`
-	FOR EACH ROW
-BEGIN
-	UPDATE `order`
-		SET rowUpdated = util.VN_NOW()
-	WHERE id = NEW.orderFk;
-END$$
-DELIMITER ;

db/routines/sage/procedures/invoiceIn_add.sql

@@ -4,10 +4,10 @@ BEGIN
 /**
  * Traslada la info de contabilidad relacionada con las facturas recibidas
  *
- * @param vInvoiceInFk Factura recibida
+ * @vInvoiceInFk Factura recibida
- * @param vXDiarioFk Id tabla XDiario
+ * @vXDiarioFk Id tabla XDiario
  */
-	DECLARE vInvoiceInOriginalFk INT;
+    DECLARE vInvoiceInOriginalFk INT;
 	DECLARE vDone BOOL DEFAULT FALSE;
 	DECLARE vBase DOUBLE;
 	DECLARE vVat DOUBLE;
@@ -25,8 +25,8 @@ BEGIN
 	DECLARE vIsInformativeExportation BOOL DEFAULT FALSE;
 
 	DECLARE vCursor CURSOR FOR
-		SELECT SUM(it.taxableBase),
+		SELECT it.taxableBase,
-				CAST(SUM((( it.taxableBase / 100) * t.PorcentajeIva)) AS DECIMAL (10,2)),
+				CAST((( it.taxableBase / 100) * t.PorcentajeIva) AS DECIMAL (10,2)),
 				t.PorcentajeIva,
 				it.transactionTypeSageFk,
 				it.taxTypeSageFk,
@@ -39,8 +39,7 @@ BEGIN
 				JOIN TiposTransacciones tt ON tt.CodigoTransaccion = it.transactionTypeSageFk
 				LEFT JOIN vn.dua d ON d.id = vInvoiceInFk
 			WHERE i.id = vInvoiceInFk
-				AND d.id IS NULL
+				AND d.id IS NULL;
-			GROUP BY it.taxTypeSageFk;
 
 	DECLARE CONTINUE HANDLER FOR NOT FOUND SET vDone = TRUE;
 
@@ -205,9 +204,9 @@ BEGIN
 		WHERE correctingFk = vInvoiceInFk;
 
 	IF vInvoiceInOriginalFk THEN 
+
 		UPDATE movContaIVA mci
-				JOIN vn.invoiceInCorrection iic ON iic.correctingFk = vInvoiceInFk
+				JOIN vn.invoiceInRefund iir ON iir.invoiceInRefundFk = vInvoiceInFk
-				JOIN vn.siiTypeInvoiceIn st ON st.id = iic.siiTypeInvoiceInFk
 				JOIN (SELECT issued,
 							SUM(sub.taxableBase) taxableBase, 
 							SUM(ROUND((sub.taxableBase * sub.PorcentajeIva) / 100 , 2)) vat
@@ -216,7 +215,7 @@ BEGIN
 									ti.PorcentajeIva
 								FROM vn.invoiceIn i 
 									JOIN vn.invoiceInTax iit ON iit.invoiceInFk = i.id
-									JOIN TiposIva ti ON ti.CodigoIva = iit.taxTypeSageFk
+									JOIN sage.TiposIva ti ON ti.CodigoIva = iit.taxTypeSageFk
 								WHERE i.id = vInvoiceInOriginalFk
 								GROUP BY ti.CodigoIva)sub
 					)invoiceInOriginal
@@ -229,6 +228,7 @@ BEGIN
 				mci.CuotaIvaOriginal = invoiceInOriginal.vat,
 				mci.ClaveOperacionFactura = co.ClaveOperacionFactura_
 			WHERE mci.id = vXDiarioFk;
+
 	END IF;
 END$$
 DELIMITER ;

db/routines/sage/procedures/invoiceOut_add.sql

@@ -169,7 +169,6 @@ BEGIN
 		UPDATE movContaIVA mci
 				JOIN vn.invoiceOut i ON i.id = vInvoiceOutCorrectedFk
 				JOIN vn.invoiceCorrection ic ON ic.correctedFk = vInvoiceOutCorrectedFk
-				JOIN vn.siiTypeInvoiceOut st ON st.id = ic.siiTypeInvoiceOutFk
 				JOIN (SELECT SUM(IF(IFNULL(e.vatFk, TRUE), iot.taxableBase, 0)) taxableBase, 
 							 SUM(IF(IFNULL(e.vatFk, TRUE), iot.vat, 0)) vat,
 							 SUM(IF(IFNULL(e.vatFk, TRUE), 0, iot.vat)) equ
@@ -178,8 +177,8 @@ BEGIN
 						WHERE iot.invoiceOutFk = vInvoiceOutCorrectedFk
 					) tax
 				JOIN ClavesOperacion co ON co.Descripcion = 'Factura rectificativa'
-			SET mci.TipoRectificativa = ic.cplusRectificationTypeFk,
+			SET mci.TipoRectificativa = 2,
-				mci.ClaseAbonoRectificativas = REGEXP_REPLACE(st.`code`, '[^0-9]', ''), 
+				mci.ClaseAbonoRectificativas = 1, 
 				mci.FechaFacturaOriginal = i.issued,
 				mci.FechaOperacion = i.issued,
 				mci.BaseImponibleOriginal = tax.taxableBase,

db/routines/salix/triggers/ACL_beforeInsert.sql

@@ -4,8 +4,5 @@ CREATE OR REPLACE DEFINER=`root`@`localhost` TRIGGER `salix`.`ACL_beforeInsert`
 	FOR EACH ROW
 BEGIN
 	SET NEW.editorFk = account.myUser_getId();
-	IF NEW.`property` = '*' THEN
-		CALL util.throw('The property field cannot be *');
-	END IF;
 END$$
 DELIMITER ;

db/routines/stock/procedures/log_refreshBuy.sql

@@ -6,11 +6,12 @@ BEGIN
 	DROP TEMPORARY TABLE IF EXISTS tValues;
 	CREATE TEMPORARY TABLE tValues
 		ENGINE = MEMORY
-		SELECT b.id buyFk,
+		SELECT
+				b.id buyFk,
 				e.id entryFk,
 				t.id travelFk,
 				b.itemFk,
-				t.isRaid,
+				e.isRaid,
 				ADDTIME(t.shipped,
 					IFNULL(t.shipmentHour, '00:00:00')) shipped,
 				t.warehouseOutFk,
@@ -49,7 +50,7 @@ BEGIN
 				itemFk,
 				TIMESTAMPADD(DAY, life, @dated),
 				quantity,
-				IF(isIn, isReceived, isDelivered) AND NOT isRaid
+				IF(isIn, isReceived, isDelivered) AND !isRaid
 			FROM tValues
 			WHERE isIn OR !lessThanInventory;
 
@@ -64,7 +65,7 @@ BEGIN
 				itemFk,
 				created,
 				quantity,
-				IF(isIn, isDelivered, isReceived) AND NOT isRaid
+				IF(isIn, isDelivered, isReceived) AND !isRaid
 			FROM tValues
 			WHERE !isIn OR !lessThanInventory;
 

db/routines/util/events/log_clean.sql

@@ -1,8 +0,0 @@
-DELIMITER $$
-CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `util`.`log_clean`
-	ON SCHEDULE EVERY 1 DAY
-		STARTS '2024-07-09 00:30:00.000'
-	ON COMPLETION PRESERVE
-	ENABLE
-DO CALL util.log_clean$$
-DELIMITER ;

db/routines/util/procedures/log_clean.sql

@@ -1,54 +0,0 @@
-DELIMITER $$
-CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `util`.`log_clean`()
-BEGIN
-/**
- * Hace limpieza de los datos de las tablas log,
- * dejando únicamente los días de retención configurados.
- */
-	DECLARE vSchemaName VARCHAR(65);
-	DECLARE vSchemaNameQuoted VARCHAR(65);
-	DECLARE vTableName VARCHAR(65);
-	DECLARE vTableNameQuoted VARCHAR(65);
-	DECLARE vRetentionDays INT;
-	DECLARE vStarted DATETIME;
-	DECLARE vDated DATE;
-	DECLARE vDone BOOL;
-
-	DECLARE vQueue CURSOR FOR
-		SELECT schemaName, tableName, retentionDays
-			FROM logCleanMultiConfig
-			ORDER BY `order`;
-
-	DECLARE CONTINUE HANDLER FOR NOT FOUND SET vDone = TRUE;
-
-	OPEN vQueue;
-	l: LOOP
-		SET vDone = FALSE;
-		FETCH vQueue INTO vSchemaName, vTableName, vRetentionDays;
-
-		IF vDone THEN
-			LEAVE l;
-		END IF;
-
-		IF vRetentionDays THEN
-			SET vStarted = VN_NOW();
-			SET vSchemaNameQuoted = quoteIdentifier(vSchemaName);
-			SET vTableNameQuoted = quoteIdentifier(vTableName);
-			SET vDated = VN_CURDATE() - INTERVAL vRetentionDays DAY;
-
-			EXECUTE IMMEDIATE CONCAT(
-				'DELETE FROM ', vSchemaNameQuoted,
-						'.', vTableNameQuoted,
-					" WHERE creationDate < '", vDated, "'"
-			);
-
-			UPDATE logCleanMultiConfig
-				SET `started` = vStarted,
-					`finished` = VN_NOW()
-				WHERE schemaName = vSchemaName
-					AND tableName = vTableName;
-		END IF;
-	END LOOP;
-	CLOSE vQueue;
-END$$
-DELIMITER ;

db/routines/vn/events/claim_changeState.sql

@@ -1,5 +1,5 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost` EVENT `vn`.`claim_changeState`
+CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `vn`.`claim_changeState`
 	ON SCHEDULE EVERY 1 DAY
 		STARTS '2024-06-06 07:52:46.000'
 	ON COMPLETION PRESERVE

db/routines/vn/events/client_setPackagesDiscountFactor.sql

@@ -1,8 +0,0 @@
-DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost` EVENT `vn`.`client_setPackagesDiscountFactor`
-	ON SCHEDULE EVERY 1 DAY
-		STARTS '2024-10-18 03:00:00.000'
-	ON COMPLETION PRESERVE
-	ENABLE
-DO CALL client_setPackagesDiscountFactor()$$
-DELIMITER ;

db/routines/vn/events/client_unassignSalesPerson.sql

@@ -1,5 +1,5 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost` EVENT `vn`.`client_unassignSalesPerson`
+CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `vn`.`client_unassignSalesPerson`
 	ON SCHEDULE EVERY 1 DAY
 		STARTS '2023-06-01 03:30:00.000'
 	ON COMPLETION PRESERVE

db/routines/vn/events/client_userDisable.sql

@@ -1,5 +1,5 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost` EVENT `vn`.`client_userDisable`
+CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `vn`.`client_userDisable`
 	ON SCHEDULE EVERY 1 MONTH
 		STARTS '2023-06-01 00:00:00.000'
 	ON COMPLETION PRESERVE

db/routines/vn/events/collection_make.sql

@@ -1,5 +1,5 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost` EVENT `vn`.`collection_make`
+CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `vn`.`collection_make`
 	ON SCHEDULE EVERY 5 MINUTE
 		STARTS '2022-09-15 00:00:00.000'
 	ON COMPLETION PRESERVE

db/routines/vn/events/department_doCalc.sql

@@ -1,5 +1,5 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost` EVENT `vn`.`department_doCalc`
+CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `vn`.`department_doCalc`
 	ON SCHEDULE EVERY 15 SECOND
 		STARTS '2019-11-15 00:00:00.000'
 	ON COMPLETION PRESERVE

db/routines/vn/events/envialiaThreHoldChecker.sql

@@ -1,5 +1,5 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost` EVENT `vn`.`envialiaThreHoldChecker`
+CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `vn`.`envialiaThreHoldChecker`
 	ON SCHEDULE EVERY 1 DAY
 		STARTS '2022-01-28 09:52:46.000'
 	ON COMPLETION NOT PRESERVE

db/routines/vn/events/greuge_notify.sql

@@ -1,5 +1,5 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost` EVENT `vn`.`greuge_notify`
+CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `vn`.`greuge_notify`
 	ON SCHEDULE EVERY 1 DAY
 		STARTS '2023-01-01 00:07:00.000'
 	ON COMPLETION NOT PRESERVE

db/routines/vn/events/itemCampaign_add.sql

@@ -1,8 +0,0 @@
-DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost` EVENT `vn`.`itemCampaig_add`
-	ON SCHEDULE EVERY 1 DAY
-		STARTS '2024-10-18 03:00:00.000'
-	ON COMPLETION PRESERVE
-	ENABLE
-DO CALL itemCampaign_add()$$
-DELIMITER ;

db/routines/vn/events/itemImageQueue_check.sql

@@ -1,5 +1,5 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost` EVENT `vn`.`itemImageQueue_check`
+CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `vn`.`itemImageQueue_check`
 	ON SCHEDULE EVERY 1 HOUR
 		STARTS '2023-07-28 00:00:00.000'
 	ON COMPLETION PRESERVE

db/routines/vn/events/itemShelvingSale_doReserve.sql

@@ -1,5 +1,5 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost` EVENT `vn`.`itemShelvingSale_doReserve`
+CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `vn`.`itemShelvingSale_doReserve`
 	ON SCHEDULE EVERY 15 SECOND
 		STARTS '2023-10-16 00:00:00'
 	ON COMPLETION PRESERVE

db/routines/vn/events/mysqlConnectionsSorter_kill.sql

@@ -1,5 +1,5 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost` EVENT `vn`.`mysqlConnectionsSorter_kill`
+CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `vn`.`mysqlConnectionsSorter_kill`
 	ON SCHEDULE EVERY 1 MINUTE
 		STARTS '2021-10-28 09:56:27.000'
 	ON COMPLETION NOT PRESERVE

db/routines/vn/events/printQueue_check.sql

@@ -1,5 +1,5 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`vn`@`localhost` EVENT `vn`.`printQueue_check`
+CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `vn`.`printQueue_check`
 	ON SCHEDULE EVERY 10 MINUTE
 		STARTS '2022-01-28 09:52:46.000'
 	ON COMPLETION PRESERVE

db/routines/vn/events/raidUpdate.sql

@@ -0,0 +1,8 @@
+DELIMITER $$
+CREATE OR REPLACE DEFINER=`root`@`localhost` EVENT `vn`.`raidUpdate`
+	ON SCHEDULE EVERY 1 DAY
+		STARTS '2017-12-29 00:05:00.000'
+	ON COMPLETION PRESERVE
+	ENABLE
+DO CALL raidUpdate$$
+DELIMITER ;