Compare commits
3 Commits
2a2df58b7d
...
wisdom
| Author | SHA1 | Date | |
|---|---|---|---|
| 436ea1cf89 | |||
| 8e0dc4bb88 | |||
| b680a249d5 |
@@ -292,11 +292,11 @@ const mqttOptions = {
|
|||||||
clientId: 'express_mqtt_client_' + Math.random().toString(16).substr(2, 8),
|
clientId: 'express_mqtt_client_' + Math.random().toString(16).substr(2, 8),
|
||||||
clean: true,
|
clean: true,
|
||||||
connectTimeout: 4000,
|
connectTimeout: 4000,
|
||||||
username: '', // jika ada
|
username: 'morekmorekmorek', // jika ada
|
||||||
password: '', // jika ada
|
password: 'morek888', // jika ada
|
||||||
};
|
};
|
||||||
|
|
||||||
const mqttUrl = 'ws://localhost:1884'; // Ganti dengan broker kamu
|
const mqttUrl = 'ws://117.102.231.130:7001'; // Ganti dengan broker kamu
|
||||||
const topic = process.env.TOPIC_COD ?? 'morek';
|
const topic = process.env.TOPIC_COD ?? 'morek';
|
||||||
|
|
||||||
const mqttClient = mqtt.connect(mqttUrl, mqttOptions);
|
const mqttClient = mqtt.connect(mqttUrl, mqttOptions);
|
||||||
|
|||||||
@@ -104,6 +104,8 @@ class AuthController {
|
|||||||
const bytes = CryptoJS.AES.decrypt(tokenRedirect, process.env.VITE_KEY_SESSION);
|
const bytes = CryptoJS.AES.decrypt(tokenRedirect, process.env.VITE_KEY_SESSION);
|
||||||
const decrypted = JSON.parse(bytes.toString(CryptoJS.enc.Utf8));
|
const decrypted = JSON.parse(bytes.toString(CryptoJS.enc.Utf8));
|
||||||
|
|
||||||
|
console.log("decrypted: ", decrypted);
|
||||||
|
|
||||||
const userPhone = decrypted?.user_phone
|
const userPhone = decrypted?.user_phone
|
||||||
const userName = decrypted?.user_name
|
const userName = decrypted?.user_name
|
||||||
const idData = decrypted?.id
|
const idData = decrypted?.id
|
||||||
|
|||||||
@@ -95,7 +95,8 @@ const getAllNotificationDb = async (searchParams = {}) => {
|
|||||||
],
|
],
|
||||||
queryParams
|
queryParams
|
||||||
);
|
);
|
||||||
if (whereParamAnd) queryParams = whereParamAnd;
|
|
||||||
|
queryParams = whereParamAnd ? whereParamAnd : queryParams;
|
||||||
|
|
||||||
const queryText = `
|
const queryText = `
|
||||||
SELECT
|
SELECT
|
||||||
@@ -108,12 +109,12 @@ const getAllNotificationDb = async (searchParams = {}) => {
|
|||||||
a.is_delivered,
|
a.is_delivered,
|
||||||
a.is_read,
|
a.is_read,
|
||||||
a.is_active,
|
a.is_active,
|
||||||
|
a.created_at,
|
||||||
|
|
||||||
b.error_code,
|
b.error_code,
|
||||||
b.error_code_name,
|
b.error_code_name,
|
||||||
b.error_code_color,
|
b.error_code_color,
|
||||||
b.path_icon,
|
b.path_icon,
|
||||||
b.created_at,
|
|
||||||
|
|
||||||
c.solution_name,
|
c.solution_name,
|
||||||
c.type_solution,
|
c.type_solution,
|
||||||
|
|||||||
@@ -67,8 +67,8 @@ class NotifikasiWaService {
|
|||||||
for (const dataUser of dataUsers) {
|
for (const dataUser of dataUsers) {
|
||||||
if (dataUser.is_active) {
|
if (dataUser.is_active) {
|
||||||
const tokenRedirect = await generateTokenRedirect(
|
const tokenRedirect = await generateTokenRedirect(
|
||||||
dataUser.userPhone,
|
dataUser.contact_phone,
|
||||||
dataUser.userName,
|
dataUser.contact_name,
|
||||||
resultNotificationError.notification_error_id
|
resultNotificationError.notification_error_id
|
||||||
);
|
);
|
||||||
|
|
||||||
@@ -105,6 +105,8 @@ class NotifikasiWaService {
|
|||||||
param.bodyMessage
|
param.bodyMessage
|
||||||
);
|
);
|
||||||
|
|
||||||
|
console.log("resultSend: ", resultSend);
|
||||||
|
|
||||||
await updateNotificationErrorUserDb(
|
await updateNotificationErrorUserDb(
|
||||||
resultNotificationErrorUser[0].notification_error_user_id,
|
resultNotificationErrorUser[0].notification_error_user_id,
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user