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

see external call

Browse Source
This commit is contained in:
CHIEFSOFT\ameye
2024-08-25 11:04:24 -04:00
parent b4ed056b84
commit c5c67a841e
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/assign_action.js
+4 -6
View File
@@ -1,18 +1,16 @@
const db = require('../app/db') const db = require('../app/db')
const logger = require('../app/logger'); const logger = require('../app/logger');
const redeem = require("../service/redeem");
var assign_action ={ var assign_action ={
processLinedJobs(req) { processLinedJobs(value) {
console.log("Receive NEW_OFFER_110022 message processLinedJobs ************************ : ", req); console.log("Receive NEW_OFFER_110022 message processLinedJobs ************************ : ", revalueq);
// if (obj.depend_uid !== undefined && obj.depend_uid.length > 10){ // if (obj.depend_uid !== undefined && obj.depend_uid.length > 10){
// console.log("We need contact people that did this job: ", obj.depend_uid); // console.log("We need contact people that did this job: ", obj.depend_uid);
// //
// } // }
}, },
}; };
server.js
+4 -2
View File
@@ -47,10 +47,12 @@ kafka.consume("NEW_OFFER_110011", (value) => {
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);
const obj = JSON.parse(value); const obj = JSON.parse(value);
console.log( obj); console.log( "**Receive NEW_OFFER_110022 message : ", obj);
console.log("START -----------------------------------------");
assign_action.processLinedJobs(ojb); assign_action.processLinedJobs(ojb);
console.log("END -----------------------------------------");
} catch (exceptionVar) { } catch (exceptionVar) {
console.log(" Error ", exceptionVar.message); console.log(" Error ", exceptionVar.message);
} }