From 37bc7a51189701d30b50719f5fc83fac0fae5b09 Mon Sep 17 00:00:00 2001 From: "CHIEFSOFT\\ameye" Date: Sun, 25 Aug 2024 06:13:30 -0400 Subject: [PATCH] removed php array convert --- server.js | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/server.js b/server.js index eab3b35..3783358 100644 --- a/server.js +++ b/server.js @@ -35,12 +35,13 @@ routes(app); kafka.consume("NEW_OFFER_110022", (value) => { try { console.log("Receive NEW_OFFER_110022 message xxxx: ", value); - var obj = phpUnserialize(value); - console.log(obj); - if (obj.depend_uid !== undefined && obj.depend_uid.length > 10){ - console.log("We need contact people that did this job: ", obj.depend_uid); - - } + //var obj = phpUnserialize(value); + // var obj = JSON.stringify(value); + // console.log( obj); + // if (obj.depend_uid !== undefined && obj.depend_uid.length > 10){ + // console.log("We need contact people that did this job: ", obj.depend_uid); + // + // } } catch (exceptionVar) { console.log(" Error ", exceptionVar.message); } @@ -49,8 +50,8 @@ kafka.consume("NEW_OFFER_110022", (value) => { kafka.consume("INTEREST_MSG", (value) => { try { console.log("Receive INTEREST_MSG message xxxx: ", value); - var obj = phpUnserialize(value); - console.log(obj); + // var obj = phpUnserialize(value); + // console.log(obj); } catch (exceptionVar) { console.log(" Error ", exceptionVar.message);