WrenchBoard/WrenchEventConsumer
2
0
Fork 0
Code Issues Pull Requests Releases Activity

removed php array convert

Browse Source
This commit is contained in:
CHIEFSOFT\ameye
2024-08-25 06:13:30 -04:00
parent 4033e32fba
commit 37bc7a5118
1 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server.js
+9 -8
View File
@@ -35,12 +35,13 @@ routes(app);
kafka.consume("NEW_OFFER_110022", (value) => { kafka.consume("NEW_OFFER_110022", (value) => {
try { try {
console.log("Receive NEW_OFFER_110022 message xxxx: ", value); console.log("Receive NEW_OFFER_110022 message xxxx: ", value);
var obj = phpUnserialize(value); //var obj = phpUnserialize(value);
console.log(obj); // var obj = JSON.stringify(value);
if (obj.depend_uid !== undefined && obj.depend_uid.length > 10){ // console.log( obj);
console.log("We need contact people that did this job: ", obj.depend_uid); // 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) { } catch (exceptionVar) {
console.log(" Error ", exceptionVar.message); console.log(" Error ", exceptionVar.message);
} }
@@ -49,8 +50,8 @@ kafka.consume("NEW_OFFER_110022", (value) => {
kafka.consume("INTEREST_MSG", (value) => { kafka.consume("INTEREST_MSG", (value) => {
try { try {
console.log("Receive INTEREST_MSG message xxxx: ", value); console.log("Receive INTEREST_MSG message xxxx: ", value);
var obj = phpUnserialize(value); // var obj = phpUnserialize(value);
console.log(obj); // console.log(obj);
} catch (exceptionVar) { } catch (exceptionVar) {
console.log(" Error ", exceptionVar.message); console.log(" Error ", exceptionVar.message);