Forráskód Böngészése

feat:查询扩展

开发 1 hónapja
szülő
commit
46469807ce
1 módosított fájl, 34 hozzáadás és 11 törlés
  1. 34 11
      Source/server/jiance-echartServer/util/sqlUtil.js

+ 34 - 11
Source/server/jiance-echartServer/util/sqlUtil.js

@@ -280,26 +280,49 @@ function getBoXing(req) {
 function getDataManage(req){
   let startTime = req.body.startTime;
   let endTime = req.body.endTime;
-
-  //let sql = `select dc.czbh,dc.zxsd,dc.cxsd,dc.guixing,dc.zyk,dc.juming,dc.jbh,dc.id,dc.dcth,dc.quanchang,dc.czm,dc.dcbh,dc.zch,dc.xgbz,dc.fuzhu,dc.xbh,ab.* from( select lgl.jcrq,lgl.lgcxl,lgl.lghxl,lgl.tgxs,lgl.yswjm,lgl.lzlfz,lgl.lzjzl,lgl.zzcfz,lgl.yzhfz,lgl.yzcfz,lgl.ytgxs,lgl.ztgxs,lgl.id as lgl_id,lgl.zzhfz,lgl.sudu_lgl, jhfx.xlm,jhfx.yswjm_jhfx,jhfx.gxfz,jhfx.xingbie,jhfx.gjhy,jhfx.gjhyffz,jhfx.gdfz,jhfx.cbgdfz,jhfx.cbgxfz,jhfx.id as jhfx_id,jhfx.jgjlc,jhfx.cthjfz,jhfx.cthjffz,jhfx.ctcjfz,jhfx.ctcjffz,jhfx.spfz,jhfx.zcx,jhfx.riqi,jhfx.zfx,jhfx.dcqtqi,jhfx.jcc,jhfx.remark,jhfx.zgdfz,jhfx.zgxfz,jhfx.ygxfz,jhfx.cbzgdfz,jhfx.cbygdfz,jhfx.cbzgxfz,jhfx.cbygxfz,jhfx.zgjffz_jhfx,jhfx.ygdfz,jhfx.ygjffz,jhfx.xuhao,jhfx.sjkfz,jhfx.ygjfz,jhfx.sudu_jhfx,jhfx.wx_xgjlc,jhfx.wx_bhl_gd,jhfx.wx_bhl_gx,jhfx.wx_bhl_sp,jhfx.wx_bhl_sjk,jhfx.wx_bhl_gj,jhfx.wx_check,jhfx.wx_isload  from t_lunguili_account lgl, t_jihefenxi_account jhfx where lgl.xlm = jhfx.xlm and  lgl.xingbie = jhfx.xingbie and   lgl.jgjlc = jhfx.jgjlc) as ab,t_daocha_account dc where ab.xlm = dc.xlm and   ab.xingbie = dc.xingbie and  ab.jgjlc = dc.jgjlc`
-  let sql = `select dc.czbh,dc.zxsd,dc.cxsd,dc.guixing,dc.zyk,dc.juming,dc.jbh,dc.id,dc.dcth,dc.quanchang,dc.czm,dc.dcbh,dc.zch,dc.xgbz,dc.fuzhu,dc.xbh,ab.* from( select lgl.jcrq,lgl.lgcxl,lgl.lghxl,lgl.tgxs,lgl.yswjm,lgl.lzlfz,lgl.lzjzl,lgl.zzcfz,lgl.yzhfz,lgl.yzcfz,lgl.ytgxs,lgl.ztgxs,lgl.id as lgl_id,lgl.zzhfz,lgl.sudu_lgl, jhfx.xlm,jhfx.yswjm_jhfx,jhfx.gxfz,jhfx.xingbie,jhfx.gjhy,jhfx.gjhyffz,jhfx.gdfz,jhfx.cbgdfz,jhfx.cbgxfz,jhfx.id as jhfx_id,jhfx.jgjlc,jhfx.cthjfz,jhfx.cthjffz,jhfx.ctcjfz,jhfx.ctcjffz,jhfx.spfz,jhfx.zcx,jhfx.riqi,jhfx.zfx,jhfx.dcqtqi,jhfx.jcc,jhfx.remark,jhfx.zgdfz,jhfx.zgxfz,jhfx.ygxfz,jhfx.cbzgdfz,jhfx.cbygdfz,jhfx.cbzgxfz,jhfx.cbygxfz,jhfx.zgjffz_jhfx,jhfx.ygdfz,jhfx.ygjffz,jhfx.xuhao,jhfx.sjkfz,jhfx.ygjfz,jhfx.sudu_jhfx,jhfx.wx_xgjlc,jhfx.wx_bhl_gd,jhfx.wx_bhl_gx,jhfx.wx_bhl_sp,jhfx.wx_bhl_sjk,jhfx.wx_bhl_gj,jhfx.wx_check,jhfx.wx_isload  from t_lunguili_account lgl, t_jihefenxi_account jhfx) as ab,t_daocha_account dc where ab.xlm = dc.xlm and   ab.xingbie = dc.xingbie and  ab.jgjlc = dc.jgjlc and ab.riqi >='${startTime}' and ab.riqi <='${endTime}'`
-  let sql1 = `select dc.czbh,dc.zxsd,dc.cxsd,dc.guixing,dc.zyk,dc.juming,dc.jbh,dc.id,dc.dcth,dc.quanchang,dc.czm,dc.dcbh,dc.zch,dc.xgbz,dc.fuzhu,dc.xbh,ab.* from( select lgl.jcrq,lgl.lgcxl,lgl.lghxl,lgl.tgxs,lgl.yswjm,lgl.lzlfz,lgl.lzjzl,lgl.zzcfz,lgl.yzhfz,lgl.yzcfz,lgl.ytgxs,lgl.ztgxs,lgl.id as lgl_id,lgl.zzhfz,lgl.sudu_lgl, jhfx.xlm,jhfx.yswjm_jhfx,jhfx.gxfz,jhfx.xingbie,jhfx.gjhy,jhfx.gjhyffz,jhfx.gdfz,jhfx.cbgdfz,jhfx.cbgxfz,jhfx.id as jhfx_id,jhfx.jgjlc,jhfx.cthjfz,jhfx.cthjffz,jhfx.ctcjfz,jhfx.ctcjffz,jhfx.spfz,jhfx.zcx,jhfx.riqi,jhfx.zfx,jhfx.dcqtqi,jhfx.jcc,jhfx.remark,jhfx.zgdfz,jhfx.zgxfz,jhfx.ygxfz,jhfx.cbzgdfz,jhfx.cbygdfz,jhfx.cbzgxfz,jhfx.cbygxfz,jhfx.zgjffz_jhfx,jhfx.ygdfz,jhfx.ygjffz,jhfx.xuhao,jhfx.sjkfz,jhfx.ygjfz,jhfx.sudu_jhfx,jhfx.wx_xgjlc,jhfx.wx_bhl_gd,jhfx.wx_bhl_gx,jhfx.wx_bhl_sp,jhfx.wx_bhl_sjk,jhfx.wx_bhl_gj,jhfx.wx_check,jhfx.wx_isload  from t_lunguili_account lgl, t_jihefenxi_account jhfx) as ab,t_daocha_account dc where ab.xlm = dc.xlm and   ab.xingbie = dc.xingbie and  ab.jgjlc = dc.jgjlc`
-  if(startTime ==='' && endTime ===''){
-    return sql1
-  }else{
-    return sql
-  }
+  let xlm = req.body.xlm;
+  let chezhan = req.body.chezhan;
+  let dcbh = req.body.dcbh;
+  let startCondition = startTime ==='' ? '' : `and ab.riqi >='${startTime}'`;
+  let endCondition = endTime ===''? '' : `and ab.riqi <='${endTime}' `;
+  let xlmCondition = xlm ===''? '' : `and ab.xlm = '${xlm}'`;
+  let czmCondition = chezhan ===''? '' : `and dc.czm = '${chezhan}'`;
+  let dcbhCondition = dcbh ===''? '' : `and dc.dcbh = '${dcbh}'`;
+  let sql = `select dc.czbh,dc.zxsd,dc.cxsd,dc.guixing,dc.zyk,dc.juming,dc.jbh,dc.id,dc.dcth,dc.quanchang,dc.czm,dc.dcbh,dc.zch,dc.xgbz,dc.fuzhu,dc.xbh,ab.* from( select lgl.jcrq,lgl.lgcxl,lgl.lghxl,lgl.tgxs,lgl.yswjm,lgl.lzlfz,lgl.lzjzl,lgl.zzcfz,lgl.yzhfz,lgl.yzcfz,lgl.ytgxs,lgl.ztgxs,lgl.id as lgl_id,lgl.zzhfz,lgl.sudu_lgl, jhfx.xlm,jhfx.yswjm_jhfx,jhfx.gxfz,jhfx.xingbie,jhfx.gjhy,jhfx.gjhyffz,jhfx.gdfz,jhfx.cbgdfz,jhfx.cbgxfz,jhfx.id as jhfx_id,jhfx.jgjlc,jhfx.cthjfz,jhfx.cthjffz,jhfx.ctcjfz,jhfx.ctcjffz,jhfx.spfz,jhfx.zcx,jhfx.riqi,jhfx.zfx,jhfx.dcqtqi,jhfx.jcc,jhfx.remark,jhfx.zgdfz,jhfx.zgxfz,jhfx.ygxfz,jhfx.cbzgdfz,jhfx.cbygdfz,jhfx.cbzgxfz,jhfx.cbygxfz,jhfx.zgjffz_jhfx,jhfx.ygdfz,jhfx.ygjffz,jhfx.xuhao,jhfx.sjkfz,jhfx.ygjfz,jhfx.sudu_jhfx,jhfx.wx_xgjlc,jhfx.wx_bhl_gd,jhfx.wx_bhl_gx,jhfx.wx_bhl_sp,jhfx.wx_bhl_sjk,jhfx.wx_bhl_gj,jhfx.wx_check,jhfx.wx_isload  from t_lunguili_account lgl, t_jihefenxi_account jhfx) as ab,t_daocha_account dc where ab.xlm = dc.xlm and   ab.xingbie = dc.xingbie and  ab.jgjlc = dc.jgjlc ${startCondition}  ${endCondition} ${xlmCondition} ${czmCondition} ${dcbhCondition}`
+  return sql
 }
 
 //通过sql获取电务功率数据列表
 function getDwDataManage(req){
-  let sql = `select a.xianlu,a.chezhan,a.dcbh,b.time,b.directionalmarker,b.curvetype,b.totalwork,b.changerate,b.offsetvalue,b.powervariance from t_gonglv_account as a ,t_glanalysis_account as b where a.qxxh = b.curvenumber`
+  let startTime = req.body.startTime;
+  let endTime = req.body.endTime;
+  let xlm = req.body.xlm;
+  let chezhan = req.body.chezhan;
+  let dcbh = req.body.dcbh;
+  let startCondition = startTime ==='' ? '' : `and ab.riqi >='${startTime}'`;
+  let endCondition = endTime ===''? '' : `and ab.riqi <='${endTime}' `;
+  let xlmCondition = xlm ===''? '' : `and ab.xlm = '${xlm}'`;
+  let czmCondition = chezhan ===''? '' : `and dc.czm = '${chezhan}'`;
+  let dcbhCondition = dcbh ===''? '' : `and dc.dcbh = '${dcbh}'`;
+ 
+  let sql = `select a.xianlu,a.chezhan,a.dcbh,b.time,b.directionalmarker,b.curvetype,b.totalwork,b.changerate,b.offsetvalue,b.powervariance from t_gonglv_account as a ,t_glanalysis_account as b where a.qxxh = b.curvenumber ${startCondition}  ${endCondition} ${xlmCondition} ${czmCondition} ${dcbhCondition}`
   return sql;
 }
 
 //通过sql获取电务缺口数据列表
 function getQkDataManage(req){
-  let sql = `select a.xianlu,a.chezhan,a.dcbh,a.zzj, b.time,b.movechange,b.change,b.passchange from t_quekou_account as a ,t_qkanalysis_account as b where a.qxxh = b.gapnumber`
+  let startTime = req.body.startTime;
+  let endTime = req.body.endTime;
+  let xlm = req.body.xlm;
+  let chezhan = req.body.chezhan;
+  let dcbh = req.body.dcbh;
+  let startCondition = startTime ==='' ? '' : `and ab.riqi >='${startTime}'`;
+  let endCondition = endTime ===''? '' : `and ab.riqi <='${endTime}' `;
+  let xlmCondition = xlm ===''? '' : `and ab.xlm = '${xlm}'`;
+  let czmCondition = chezhan ===''? '' : `and dc.czm = '${chezhan}'`;
+  let dcbhCondition = dcbh ===''? '' : `and dc.dcbh = '${dcbh}'`;
+ 
+  let sql = `select a.xianlu,a.chezhan,a.dcbh,a.zzj, b.time,b.movechange,b.change,b.passchange from t_quekou_account as a ,t_qkanalysis_account as b where a.qxxh = b.gapnumber ${startCondition}  ${endCondition} ${xlmCondition} ${czmCondition} ${dcbhCondition}`
   return sql;
 }