Tcel-Eprocurement/backend-Eprocurement
3
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

upd

Browse Source
This commit is contained in:
Rizki
2026-03-12 10:11:48 +07:00
parent b59a9b830a
commit 4a75f278f7
1 changed files with 707 additions and 590 deletions
Download Patch File Download Diff File Expand all files Collapse all files

499
adapter/pradapter.js
View File

@ -1,9 +1,8 @@
const db=require('../config/dbproc.js');
const Adapter=require('./dbadapter.js');
const QRCode = require('qrcode');
const db = require("../config/dbproc.js");
const Adapter = require("./dbadapter.js");
const QRCode = require("qrcode");
const fs = require("fs");
class PrAdapter extends Adapter {
constructor() {
super();
@ -12,37 +11,34 @@ class PrAdapter extends Adapter{
async queryPrJustificationList(req, callback) {
var apires = this.getApiResultDefined();
try {
// console.log(req);
let nik = req.query.nik;
let qry = "select * from vw_justification where iscreatepr=0 and status=2 and iby='"+nik+"' order by id asc";
let qry =
"select * from vw_justification where iscreatepr=0 and status=2 and iby='" +
nik +
"' order by id asc";
// console.log(qry);
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
if (result.length > 0) {
apires.success = true;
apires.data = JSON.parse(JSON.stringify(result));
}
else{
} else {
apires.meta.code = 200;
apires.meta.message = "Record Not Found";
}
callback(null, apires);
}
});
}
catch(err) {
} catch (err) {
apires.meta.code = 500;
apires.meta.message = err.toString();
callback('error',apires);
callback("error", apires);
}
}
@ -50,34 +46,34 @@ class PrAdapter extends Adapter{
var apires = this.getApiResultDefined();
try {
let nik = req.query.nik;
let qry = "select count(_idx) totalrows,date_format(now(),'%Y%m%d') dates from tbl_pr where iby='"+nik+"' and year(idt)=year(now())";
let qry =
"select count(_idx) totalrows,date_format(now(),'%Y%m%d') dates from tbl_pr where iby='" +
nik +
"' and year(idt)=year(now())";
// console.log(qry);
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
var resp = JSON.parse(JSON.stringify(result));
// console.log(resp[0]['dates']);
var ymd = resp[0]['dates'];
var ymd = resp[0]["dates"];
ymd = ymd.toString().trim().replace("-", "");
var counter = resp[0]['totalrows']+1;
var counterstr = ("0000000000"+counter);
var counter = resp[0]["totalrows"] + 1;
var counterstr = "0000000000" + counter;
counterstr = counterstr.substring(counterstr.length - 4, counterstr.length);
var trxid = "TCEL-PR/" + ymd + "/" + nik + "/" + counterstr;
apires.success = true;
apires.data = trxid
apires.data = trxid;
callback(null, apires);
}
});
} catch (error) {
apires.meta.code = 500;
apires.meta.message = err.toString();
callback('error',apires);
callback("error", apires);
}
}
@ -105,33 +101,72 @@ class PrAdapter extends Adapter{
let statusdescription = "draft";
let qry = "insert into tbl_pr ";
qry = qry +"set trxidpr='"+trxidpr+"',prnumber='"+prnumber+"',idxjustification='"+idxjustification+"',justificationnumber='"+justificationnumber+"',costcenter='"+costcenter+"',";
qry = qry +"profitcenter='"+profitcenter+"',description='"+description+"',qty='"+qty+"',unit='"+unit+"',netprice='"+netprice+"',totalvalue='"+totalvalue+"',";
qry = qry +"curr='"+curr+"',prdate='"+prdate+"',status='"+status+"',statusdescription='"+statusdescription+"',";
qry = qry +"idxapproval='"+idxapproval+"',nikapproval='"+nikapproval+"',iby='"+nik+"',idt=now()";
qry =
qry +
"set trxidpr='" +
trxidpr +
"',prnumber='" +
prnumber +
"',idxjustification='" +
idxjustification +
"',justificationnumber='" +
justificationnumber +
"',costcenter='" +
costcenter +
"',";
qry =
qry +
"profitcenter='" +
profitcenter +
"',description='" +
description +
"',qty='" +
qty +
"',unit='" +
unit +
"',netprice='" +
netprice +
"',totalvalue='" +
totalvalue +
"',";
qry =
qry +
"curr='" +
curr +
"',prdate='" +
prdate +
"',status='" +
status +
"',statusdescription='" +
statusdescription +
"',";
qry =
qry +
"idxapproval='" +
idxapproval +
"',nikapproval='" +
nikapproval +
"',iby='" +
nik +
"',idt=now()";
console.log(qry);
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
var res = JSON.parse(JSON.stringify(result));
apires.success = true;
apires.meta.message = "Saved Success";
apires.data = res;
callback(null, apires);
}
});
} catch (err) {
apires.meta.code = 500;
apires.meta.message = err.toString();
callback('error',apires);
callback("error", apires);
}
}
@ -160,33 +195,70 @@ class PrAdapter extends Adapter{
let statusdescription = "draft";
let qry = "update tbl_pr ";
qry = qry +"set trxidpr='"+trxidpr+"',prnumber='"+prnumber+"',idxjustification='"+idxjustification+"',justificationnumber='"+justificationnumber+"',costcenter='"+costcenter+"',";
qry = qry +"profitcenter='"+profitcenter+"',description='"+description+"',qty='"+qty+"',unit='"+unit+"',netprice='"+netprice+"',totalvalue='"+totalvalue+"',";
qry = qry +"idxapproval='"+idxapproval+"',nikapproval='"+nikapproval+"',curr='"+curr+"',prdate='"+prdate+"',status='"+status+"',statusdescription='"+statusdescription+"',uby='"+nik+"',udt=now() ";
qry =
qry +
"set trxidpr='" +
trxidpr +
"',prnumber='" +
prnumber +
"',idxjustification='" +
idxjustification +
"',justificationnumber='" +
justificationnumber +
"',costcenter='" +
costcenter +
"',";
qry =
qry +
"profitcenter='" +
profitcenter +
"',description='" +
description +
"',qty='" +
qty +
"',unit='" +
unit +
"',netprice='" +
netprice +
"',totalvalue='" +
totalvalue +
"',";
qry =
qry +
"idxapproval='" +
idxapproval +
"',nikapproval='" +
nikapproval +
"',curr='" +
curr +
"',prdate='" +
prdate +
"',status='" +
status +
"',statusdescription='" +
statusdescription +
"',uby='" +
nik +
"',udt=now() ";
qry = qry + "where _idx='" + idxpr + "'";
// console.log(qry);
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
var res = JSON.parse(JSON.stringify(result));
apires.success = true;
apires.meta.message = "Updated Success";
apires.data = res;
callback(null, apires);
}
});
} catch (err) {
apires.meta.code = 500;
apires.meta.message = err.toString();
callback('error',apires);
callback("error", apires);
}
}
@ -206,7 +278,9 @@ class PrAdapter extends Adapter{
}
var setprnumber = "prnumber='" + prsapnumber + "',";
if(!prsapnumber){setprnumber="";}
if (!prsapnumber) {
setprnumber = "";
}
var setdescription = "";
if (description) {
@ -217,17 +291,25 @@ class PrAdapter extends Adapter{
}
// console.log(setdescription);
var qry = "update tbl_pr set "+setprnumber+setdescription+"sapmessage='"+sapmessage+"',"+swherestatus+"uby='"+nik+"',udt=now() ";
var qry =
"update tbl_pr set " +
setprnumber +
setdescription +
"sapmessage='" +
sapmessage +
"'," +
swherestatus +
"uby='" +
nik +
"',udt=now() ";
qry = qry + "where _idx='" + idxpr + "'";
console.log(qry);
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
apires.success = true;
apires.data = JSON.parse(JSON.stringify(result));
callback(null, apires);
@ -236,7 +318,7 @@ class PrAdapter extends Adapter{
} catch (err) {
apires.meta.code = 500;
apires.meta.message = err.toString();
callback('error',apires);
callback("error", apires);
}
}
@ -248,17 +330,16 @@ class PrAdapter extends Adapter{
let nik = req.body.nik;
let qry = "update tbl_pr ";
qry = qry +"set isdeleted=1,remarkdeleted='"+remarkdeleted+"',dby='"+nik+"',ddt=now()";
qry =
qry + "set isdeleted=1,remarkdeleted='" + remarkdeleted + "',dby='" + nik + "',ddt=now()";
qry = qry + " where _idx='" + id + "'";
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
apires.success = true;
apires.meta.message = "Deleted Success";
callback(null, apires);
@ -267,14 +348,13 @@ class PrAdapter extends Adapter{
} catch (err) {
apires.meta.code = 500;
apires.meta.message = err.toString();
callback('error',apires);
callback("error", apires);
}
}
async queryPrDetail(req, callback) {
var apires = this.getApiResultDefined();
try {
let _idx = req.query.id;
let qry = "select * from vw_pr where id='" + _idx + "'";
@ -282,18 +362,15 @@ class PrAdapter extends Adapter{
// console.log(qry);
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
let dataRows = result.length;
if (dataRows <= 0) {
apires.meta.message = "Record not found";
callback('',apires);
}
else{
callback("", apires);
} else {
let resultJson = JSON.stringify(result);
resultJson = JSON.parse(resultJson);
apires.success = true;
@ -302,19 +379,18 @@ class PrAdapter extends Adapter{
}
}
});
} catch (err) {
apires.meta.code = 500;
apires.meta.message = err.toString();
callback('error',apires);
callback("error", apires);
}
}
async queryPrList(req, callback) {
var apires = this.getApiResultDefined();
try {
const proc_nik = process.env.PROC_USER_NIK ?? ""
const proc_users = proc_nik.split(",")
const proc_nik = process.env.PROC_USER_NIK ?? "";
const proc_users = proc_nik.split(",");
let limit = req.body.limit;
let offset = req.body.offset;
@ -322,75 +398,84 @@ class PrAdapter extends Adapter{
let nik = req.body.nik;
let status = req.body.status;
// let qry = "select * from vw_pr ";
// qry = qry +"where (trim(trxidpr) like '%"+ keyword +"%' or trim(prnumber) like '%"+ keyword +"%') ";
// qry = qry +"and iby='"+nik+"' and status in("+status+") order by id asc limit " + offset + ", " + limit;
let swherenik = "";
if (nik) {
if (!proc_users.includes(nik)) {
swherenik = '(iby="'+nik+' or nikapproval="'+nik+'") and ';
swherenik = '(iby="' + nik + '" or nikapproval="' + nik + '") and ';
}
}
let qry = "select * from vw_pr ";
qry = qry +"where (trim(trxidpr) like '%"+ keyword +"%' or trim(prnumber) like '%"+ keyword +"%') ";
qry = qry +"and "+swherenik+" status in("+status+") order by id asc limit " + offset + ", " + limit;
qry +=
"where (trim(trxidpr) like '%" +
keyword +
"%' or trim(prnumber) like '%" +
keyword +
"%') ";
qry += "and " + swherenik + "status in(" + status + ") ";
qry += "order by id asc limit " + offset + ", " + limit;
// console.log(qry);
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
if (result.length > 0) {
let pagination = result.length / limit;
if (!Number.isInteger(pagination)) {
pagination=(Math.floor(result.length / limit))+1;
pagination = Math.floor(result.length / limit) + 1;
}
// let pagination = Adapter.getPagination(result.length, limit);
apires.success = true;
apires.data.push({
"totalpage": pagination,
"totalrows": result.length
"totalrows": result.length,
});
qry = "select * from vw_pr ";
qry = qry +"where (trim(trxidpr) like '%"+ keyword +"%' or trim(prnumber) like '%"+ keyword +"%') ";
qry = qry +"and "+swherenik+" status in("+status+") order by id asc limit " + offset + ", " + limit;
qry =
qry +
"where (trim(trxidpr) like '%" +
keyword +
"%' or trim(prnumber) like '%" +
keyword +
"%') ";
qry =
qry +
"and " +
swherenik +
" status in(" +
status +
") order by id asc limit " +
offset +
", " +
limit;
// console.log(qry);
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
apires.data.push({
"results": JSON.parse(JSON.stringify(result))
"results": JSON.parse(JSON.stringify(result)),
});
callback(null, apires);
}
});
}
else{
} else {
apires.meta.code = 200;
apires.meta.message = "Record Not Found";
callback(null, apires);
}
}
});
} catch (err) {
apires.meta.code = 500;
apires.meta.message = err.toString();
callback('error',apires);
callback("error", apires);
}
}
@ -423,67 +508,103 @@ class PrAdapter extends Adapter{
token = token + "," + nikapproval;
let qry = "update tbl_pr ";
qry = qry +"set trxidpr='"+trxidpr+"',prnumber='"+prnumber+"',idxjustification='"+idxjustification+"',justificationnumber='"+justificationnumber+"',costcenter='"+costcenter+"',";
qry = qry +"profitcenter='"+profitcenter+"',description='"+description+"',qty='"+qty+"',unit='"+unit+"',netprice='"+netprice+"',totalvalue='"+totalvalue+"',";
qry = qry +"idxapproval='"+idxapproval+"',nikapproval='"+nikapproval+"',approveddate='"+approveddate+"',curr='"+curr+"',prdate='"+prdate+"',status='"+status+"',statusdescription='"+statusdescription+"',";
qry = qry +"token=md5('"+token+"'),filepng='"+filepng+"',uby='"+nik+"',udt=now() ";
qry =
qry +
"set trxidpr='" +
trxidpr +
"',prnumber='" +
prnumber +
"',idxjustification='" +
idxjustification +
"',justificationnumber='" +
justificationnumber +
"',costcenter='" +
costcenter +
"',";
qry =
qry +
"profitcenter='" +
profitcenter +
"',description='" +
description +
"',qty='" +
qty +
"',unit='" +
unit +
"',netprice='" +
netprice +
"',totalvalue='" +
totalvalue +
"',";
qry =
qry +
"idxapproval='" +
idxapproval +
"',nikapproval='" +
nikapproval +
"',approveddate='" +
approveddate +
"',curr='" +
curr +
"',prdate='" +
prdate +
"',status='" +
status +
"',statusdescription='" +
statusdescription +
"',";
qry =
qry + "token=md5('" + token + "'),filepng='" + filepng + "',uby='" + nik + "',udt=now() ";
qry = qry + "where _idx='" + idxpr + "'";
// console.log(qry);
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
QRCode.toDataURL(token, function (err, code) {
// console.log(code);
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
var imageBuffer = Adapter.decodeBase64Image(code);
fs.writeFile('./assets/png/'+filepng, imageBuffer.data, function(err) {
fs.writeFile("./assets/png/" + filepng, imageBuffer.data, function (err) {
// console.log(err);
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback(err.toString(), apires);
}
else{
} else {
apires.success = true;
apires.data = {
"isapproved": 1,
"token": token,
"urltoken": process.env.BASEURL+"/main/getimageinfo?route=png&name="+filepng
"urltoken":
process.env.BASEURL + "/main/getimageinfo?route=png&name=" + filepng,
};
callback(null, apires);
}
});
}
});
}
});
} catch (err) {
apires.meta.code = 500;
apires.meta.message = err.toString();
callback('error',apires);
callback("error", apires);
}
}
async queryPrManagementList(req, callback) {
var apires = this.getApiResultDefined();
try {
const proc_nik = process.env.PROC_USER_NIK ?? ""
const proc_users = proc_nik.split(",")
const proc_nik = process.env.PROC_USER_NIK ?? "";
const proc_users = proc_nik.split(",");
let limit = req.query.limit;
let offset = req.query.offset;
@ -499,66 +620,71 @@ class PrAdapter extends Adapter{
// qry = qry +"where (trim(trxidpr) like '%"+ keyword +"%' or trim(prnumber) like '%"+ keyword +"%') ";
// qry = qry +swherenik+" order by id asc limit " + offset + ", " + limit;
let qry = "select * from vw_prmanagement ";
qry = qry +"where (trim(trxidpr) like '%"+ keyword +"%' or trim(prnumber) like '%"+ keyword +"%') ";
qry =
qry +
"where (trim(trxidpr) like '%" +
keyword +
"%' or trim(prnumber) like '%" +
keyword +
"%') ";
// qry = qry +swherenik+" order by id asc limit " + offset + ", " + limit;
// console.log(qry);
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
if (result.length > 0) {
let pagination = result.length / limit;
if (!Number.isInteger(pagination)) {
pagination=(Math.floor(result.length / limit))+1;
pagination = Math.floor(result.length / limit) + 1;
}
// let pagination = Adapter.getPagination(result.length, limit);
apires.success = true;
apires.data.push({
"totalpage": pagination,
"totalrows": result.length
"totalrows": result.length,
});
qry = "select * from vw_prmanagement ";
qry = qry +"where status >= 2 and (trim(trxidpr) like '%"+ keyword +"%' or trim(prnumber) like '%"+ keyword +"%') ";
qry =
qry +
"where status >= 2 and (trim(trxidpr) like '%" +
keyword +
"%' or trim(prnumber) like '%" +
keyword +
"%') ";
qry = qry + swherenik + " order by id asc limit " + offset + ", " + limit;
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
apires.data.push({
"results": JSON.parse(JSON.stringify(result))
"results": JSON.parse(JSON.stringify(result)),
});
callback(null, apires);
}
});
}
else{
} else {
apires.meta.code = 200;
apires.meta.message = "Record Not Found";
callback(null, apires);
}
}
});
} catch (err) {
apires.meta.code = 500;
apires.meta.message = err.toString();
callback('error',apires);
callback("error", apires);
}
}
async queryPrManagementListDetail(req, callback) {
var apires = this.getApiResultDefined();
try {
let idxpr = req.query.idxpr;
let qry = "select * from vw_prmanagement ";
qry = qry + "where id='" + idxpr + "'";
@ -566,29 +692,24 @@ class PrAdapter extends Adapter{
// console.log(qry);
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
apires.meta.code = 200;
if (result.length > 0) {
apires.success = true;
apires.data = JSON.parse(JSON.stringify(result));
}
else{
} else {
apires.meta.message = "Record Not Found";
}
callback(null, apires);
}
});
} catch (err) {
apires.meta.code = 500;
apires.meta.message = err.toString();
callback('error',apires);
callback("error", apires);
}
}
@ -602,16 +723,14 @@ class PrAdapter extends Adapter{
var qry = "update tbl_pr set sapmessage='" + sapmessage + "', uby='" + nik + "',udt=now() ";
qry = qry + "where _idx='" + idxpr + "'";
console.log('qry', qry)
console.log("qry", qry);
db.query(qry, [], function (err, result, fields) {
if (err) {
apires.meta['message'] = err.toString();
apires.meta['code'] = 500;
callback('err',apires);
}
else
{
apires.meta["message"] = err.toString();
apires.meta["code"] = 500;
callback("err", apires);
} else {
apires.success = true;
apires.data = JSON.parse(JSON.stringify(result));
callback(null, apires);
@ -620,11 +739,9 @@ class PrAdapter extends Adapter{
} catch (err) {
apires.meta.code = 500;
apires.meta.message = err.toString();
callback('error',apires);
callback("error", apires);
}
}
}
module.exports = PrAdapter;