cloudEditionService.js 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569
  1. /**
  2. * Created by MyPC on 2019/11/5.
  3. */
  4. var models=require('../models');
  5. var moment = require('moment');
  6. const hash=require('../class/hash');
  7. const urlObj=require("url");
  8. //http://qa.smartcost.com.cn:2060/cld
  9. //"https://yhuat.smartcost.com.cn/cld";
  10. //var curingUrl ="https://yhuat.smartcost.com.cn/cld"; //'https://yhyun.smartcost.com.cn/cld';
  11. var curingUrl ="http://qa.smartcost.com.cn:2060/cld";
  12. var buildUrl = 'https://yun.smartcost.com.cn/cld';
  13. var cloudService={
  14. /**
  15. * 获得养护列表
  16. * paramsCompilation 传参包含
  17. * -compilation 已升级编办
  18. * -latestCompilation 最近使用编办
  19. */
  20. getCuringList: async function(req, res){
  21. //获得远程养护用户
  22. //分页数据
  23. var page=1;
  24. var compilation='';
  25. var latestCompilation='';
  26. var sortField='create_time';
  27. var sort='-1';
  28. var wd=''; //检索内容
  29. //编办参数-排序参数-当前页
  30. if(hash.isExistence(req.url)){
  31. var params = urlObj.parse(req.url, true).query;
  32. if(hash.isExistence(params.compilation)){
  33. compilation=params.compilation;
  34. }
  35. if(hash.isExistence(params.latestCompilation)){
  36. latestCompilation=params.latestCompilation;
  37. }
  38. //排序
  39. var mAge=1000*60*60*24*28;
  40. if(hash.isExistence(params.sortField)){
  41. res.cookie('sortField','create_time', {maxAge: mAge});
  42. sortField='create_time';
  43. if(params.sortField=='latest_login'){
  44. sortField='latest_login';
  45. res.cookie('sortField','latest_login', {maxAge: mAge});
  46. }
  47. }else if(hash.isExistence(req.cookies.sortField)){
  48. sortField=req.cookies.sortField;
  49. }
  50. if(hash.isExistence(params.sort)){
  51. res.cookie('sort','-1', {maxAge: mAge});
  52. sort=-1;
  53. if(params.sort=='1'){
  54. sort=1;
  55. res.cookie('sort','1', {maxAge: mAge});
  56. }
  57. }else if(hash.isExistence(req.cookies.sort)){
  58. sort=req.cookies.sort;
  59. }
  60. //当前页数
  61. var page=req.params.currentPage;
  62. if(!hash.isNotANumber(page)){
  63. page=1;
  64. }
  65. //检索 内容
  66. if(hash.isExistence(params.wd)){
  67. wd=params.wd;
  68. }
  69. }
  70. //分页参数
  71. var limit=12;
  72. var offset=0;
  73. if(page!=1){
  74. var pg=page-1;
  75. offset=pg*limit;
  76. }
  77. //排序参数
  78. //var sortField=curingInterfaceConfig.sort[0];
  79. //var sort=curingInterfaceConfig.sort[1];
  80. var url= curingUrl+'/getUserList'+
  81. '?page='+page+'&pageSize='+limit+'&latestUsed='+latestCompilation+'&upGrade='+compilation+'&sortField='+sortField+'&sortType='+sort+
  82. '&keyword='+wd;
  83. /* 接口请求获得的信息
  84. * userInfo
  85. * pageData
  86. * compilationlist
  87. */
  88. var curingCloudData=await curlRequest(url);
  89. var curingCloudList=curingCloudData.userInfo;
  90. //组合数据以获得本地扩展数据
  91. var mobile=[];
  92. curingCloudList.forEach(function(v,i){
  93. mobile.push(v.mobile);
  94. });
  95. if(!hash.isExistence(mobile)){
  96. return {curingList:[],pageData:[]};
  97. }
  98. //获得指定数据
  99. var curingList = await models.cloud_curing.getCuringInMobile(mobile);
  100. //组合同步云版数据
  101. var falg=false;
  102. curingCloudList.forEach(async function(cclValue,cclKey){
  103. curingCloudList[cclKey].client_id=0
  104. falg=true;
  105. for(var i=0;i<curingList.length;i++){
  106. if(cclValue.mobile==curingList[i].mobile){
  107. curingCloudList[cclKey].client_id=curingList[i].client_id;
  108. falg=false;
  109. break;
  110. }
  111. }
  112. if(falg){//新增本地扩展信息
  113. sid=hash.hashDecode(STAFF.sid);
  114. var obj = {
  115. mobile: cclValue.mobile,
  116. sso_id: cclValue.ssoId,
  117. sid: sid,
  118. cid: STAFF.cid,
  119. status: 2,
  120. };
  121. var detail = await models.cloud_curing.create(obj);
  122. }
  123. });
  124. //获得编办数据
  125. var compilationList=await this.getCompilationList(); //编办信息
  126. //console.log(compilationList);
  127. //数据组合--cld客户数据
  128. var cid=[];
  129. curingCloudList.forEach(function(v,i){
  130. if(v.client_id!=0){
  131. cid.push(v.client_id);
  132. }
  133. });
  134. var clientList =[];
  135. if(hash.isExistence(cid)){
  136. var attributes= ['cid', 'clientname', 'companyid', 'companyname'];
  137. clientList = await models.CLD_client.findAllInCid(cid,attributes);
  138. }
  139. //组合页面需要展示的数据
  140. curingCloudList.forEach(function(v,i){
  141. curingCloudList[i].clientInfo={};
  142. clientList.forEach(function(clientVal,clientI){
  143. if(v.client_id==clientVal.cid){
  144. curingCloudList[i].clientInfo=clientVal;
  145. }
  146. });
  147. curingCloudList[i].addtime=moment(v.create_time).format('YYYY-MM-DD HH:mm');
  148. curingCloudList[i].latest_login=moment(v.latest_login).format('YYYY-MM-DD HH:mm');
  149. curingCloudList[i].client_id=hash.hashEncode(v.client_id.toString());
  150. curingCloudList[i].sso_id=hash.hashEncode(v.sso_id.toString());
  151. //最后使用
  152. curingCloudList[i].latest_usedName='';
  153. for(var ci=0;ci<compilationList.length;ci++){
  154. if(compilationList[ci]._id==v.latest_used){
  155. curingCloudList[i].latest_usedName=compilationList[ci].name;
  156. break;
  157. }
  158. }
  159. //登录时长
  160. if(hash.isExistence(v.online_list)){
  161. var onlineTimeLength=v.online_list.length-1;
  162. curingCloudList[i].online_newest=v.online_list[onlineTimeLength].online_times+'('+v.online_list[onlineTimeLength].dateString+')';
  163. }else{
  164. curingCloudList[i].online_newest='';
  165. }
  166. //已升级专业版
  167. curingCloudList[i].upgradeListName='';
  168. for(var gi=0;gi<v.upgrade_list.length;gi++){
  169. for(var ci=0;ci<compilationList.length;ci++){
  170. if( compilationList[ci]._id == v.upgrade_list[gi].compilationID&&v.upgrade_list[gi].isUpgrade) {
  171. curingCloudList[i].upgradeListName+='<span class="badge badge-primary">'+compilationList[ci].name+'</span>';
  172. break;
  173. }
  174. }
  175. }
  176. });
  177. var parameter='?compilation='+compilation+'&latestCompilation='+latestCompilation+'&sortField='+sortField+'&sort='+sort;
  178. //分页计算
  179. var pageData = await getPage('','',page,limit,parameter,curingCloudData.pageData.total);
  180. return {curingList:curingCloudList,pageData:pageData,sortList:[sortField,sort]};
  181. },
  182. /**
  183. * 获得养护编办--接口拉取
  184. */
  185. getCompilationList:async function (){
  186. var url= curingUrl+'/getCompilationList';
  187. var data= await curlRequest(url);
  188. return data;
  189. },
  190. /**
  191. * 用户详情页-数据
  192. */
  193. getCuringBySsoid: async function(ssoid,client_id){
  194. if(!hash.isNotANumber(ssoid)){
  195. ssoid=hash.hashDecode(ssoid);
  196. if(!hash.isNotANumber(ssoid)){
  197. return [];
  198. }
  199. }
  200. var url= curingUrl+'/getUsersAndCompilation?ssoID='+ ssoid;
  201. var userData= await curlRequest(url);
  202. if(!hash.isExistence(userData)){
  203. return [];
  204. }
  205. console.log(userData);
  206. //本地养护用户
  207. userData['curingInfo']=await models.cloud_curing.getCuringBySsoid(ssoid);
  208. client_id=userData['curingInfo']['client_id'];
  209. /*userData['clientInfo']='';
  210. if(!hash.isNotANumber(client_id)){
  211. client_id=hash.hashDecode(client_id);
  212. if(!hash.isNotANumber(client_id)){
  213. userData['clientInfo']=[];
  214. }
  215. }*/
  216. var detail =[];
  217. if(hash.isExistence(client_id)){
  218. detail = await models.CLD_client.findById(client_id);
  219. }
  220. userData['clientInfo']=detail;
  221. //组合数据升级产品数据
  222. userData['compilationList'].forEach(function(value,key){
  223. userData['userInfo']['upgrade_list'].forEach(function(v,k){
  224. if(v['compilationID']==value['_id']){
  225. userData['compilationList'][key]['isUpgrade']=v['isUpgrade'];
  226. }
  227. });
  228. });
  229. userData['userInfo']['ssoIdKey']=hash.hashEncode(userData['userInfo']['ssoId'].toString());
  230. //获得操作日志
  231. userData['operateLog']=[];
  232. if(hash.isExistence(userData['curingInfo'])){
  233. userData['operateLog']=await models.operate_log.findByCondition(1,hash.hashDecode(userData['curingInfo']['id']));
  234. }
  235. return userData;
  236. },
  237. /**
  238. * 获得本地编办列表--废弃
  239. */
  240. getCuringCompilationList:async function (){
  241. var compilationList = await models.cloud_curing.getCuringCompilationList();
  242. return compilationList;
  243. },
  244. //获取本地养护数据--可能废弃
  245. getBindCuringByMobile:async function (mobile){
  246. var curingList = await models.cloud_curing.getCuringByMobile(mobile);
  247. if (curingList!=null){
  248. var cid=[curingList['client_id']];
  249. var attributes= ['cid', 'clientname', 'companyid', 'companyname'];
  250. var clientList = await models.CLD_client.findAllInCid(cid,attributes);
  251. curingList.clientInfo={};
  252. clientList.forEach(function(clientVal,clientI){
  253. if(curingList.client_id==clientVal.cid){
  254. curingList.clientInfo=clientVal;
  255. }
  256. });
  257. curingList.addtime=moment.unix(curingList.addtime).format('YYYY-MM-DD HH:mm');
  258. }
  259. return curingList;
  260. },
  261. //根据手机号码获得养护用户信息--可能废弃
  262. getCuringByMobile: async function(mobile){
  263. var url= curingUrl+'/getUsersAndCompilation?mobile='+ mobile;
  264. var userData= await curlRequest(url);
  265. return userData;
  266. },
  267. upCuringDo: async function(data){
  268. var url = curingUrl+'/setUserUpgrade';
  269. var ssoid=hash.hashDecode(data.ssoid);
  270. var postData ={'ssoId':ssoid,'cid':data.compilationId};
  271. var result= await postRequest(url,postData);
  272. result=JSON.parse(result);
  273. if(result.error==0){ //接口更新成
  274. var curingDetail=await models.cloud_curing.getCuringByMobile(data.mobile);
  275. var id='';
  276. if(hash.isExistence(curingDetail)){ //是否需要同步同步到本地库中
  277. var url= curingUrl+'/getUsersAndCompilation?ssoID='+ ssoid;
  278. var userData= await curlRequest(url);
  279. //获得更新数量updateTotal
  280. var updateTotal=0;
  281. userData['userInfo']['upgrade_list'].forEach(function(value,key){
  282. if(value['isUpgrade']){
  283. updateTotal++;
  284. }
  285. });
  286. //更新数量
  287. var values = {
  288. updateTotal: updateTotal
  289. }
  290. var where={
  291. where: {id: curingDetail['id']}
  292. };
  293. await models.cloud_curing.update(values,where);
  294. id=curingDetail['id'];
  295. }else{
  296. sid=hash.hashDecode(STAFF.sid);
  297. //获得登陆用户相关信息
  298. var obj = {
  299. mobile: data.mobile,
  300. sso_id: data.ssoid,
  301. compilation_id: data.compilationId,
  302. curingCompany: data.name,
  303. sid: sid,
  304. cid: STAFF.cid,
  305. status: 1,
  306. addtime: new Date().getTime(),
  307. updateTotal: 1
  308. };
  309. var detail=await models.cloud_curing.create(obj);
  310. id=detail['cloud_curing']['id'];
  311. }
  312. var operation=STAFF.username+'升级'+data.name;
  313. //记录锁日志
  314. await models.operate_log.createOperateLog(1,id,operation);
  315. return true;
  316. }else{
  317. return false;
  318. }
  319. },
  320. //养护用户绑定CLD客户
  321. relevanceClientDo: async function(data){
  322. var cid=hash.hashDecode(data.cidKey);
  323. var id=hash.hashDecode(data.id);
  324. if(!hash.isNotANumber(cid)||!hash.isNotANumber(id)){
  325. return false;
  326. }
  327. var curingDetail=await models.cloud_curing.getCuringById(id);
  328. if(hash.isExistence(curingDetail)) {
  329. var clientDetail=await models.CLD_client.findById(cid);
  330. if(hash.isExistence(clientDetail)){
  331. //更新数量
  332. var values = {
  333. client_id: cid
  334. }
  335. var where={
  336. where: {id: curingDetail['id']}
  337. };
  338. await models.cloud_curing.update(values,where);
  339. //记录操作日志
  340. var operation=STAFF.username+'关联CLD联系人'+clientDetail.clientname;
  341. await models.operate_log.createOperateLog(1,id,operation);
  342. return true;
  343. }else{
  344. return false;
  345. }
  346. }else{
  347. return false;
  348. }
  349. },
  350. //移除关联CLD客户
  351. relieveClientDo: async function(data){
  352. var id=hash.hashDecode(data.id);
  353. if(!hash.isNotANumber(id)){
  354. return false;
  355. }
  356. var curingDetail=await models.cloud_curing.getCuringById(id);
  357. if(hash.isExistence(curingDetail)) {
  358. //更新数量
  359. var values = {
  360. client_id: ''
  361. }
  362. var where={
  363. where: {id: curingDetail['id']}
  364. };
  365. await models.cloud_curing.update(values,where);
  366. var clientDetail=await models.CLD_client.findById(curingDetail['client_id']);
  367. //记录操作日志
  368. var operation=STAFF.username+'移除CLD联系人'+clientDetail.clientname;
  369. await models.operate_log.createOperateLog(1,id,operation);
  370. return true;
  371. }else{
  372. return false;
  373. }
  374. },
  375. }
  376. module.exports = cloudService;
  377. //接口调用
  378. var curlRequest = async function(url){
  379. var got = require('got');
  380. var data=[];
  381. await got(url, { json: true,timeout:300 }).then(response => {
  382. data= response.body.data;
  383. }).catch(error => {
  384. console.log('GET调用接口超时');
  385. });
  386. return data;
  387. }
  388. var postRequest= async function(url,data){
  389. //var fs = require('fs');
  390. var got = require('got');
  391. var qs = require('querystring');
  392. var keysList=Object.keys(data);
  393. var content = qs.stringify(data);
  394. result= await got.post(url, {
  395. body: content,
  396. timeout:300,
  397. headers: {
  398. 'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8'
  399. }
  400. }).catch(error => {
  401. console.log('POST调用接口超时');
  402. });
  403. return result.body;
  404. //var FormData = require('form-data');
  405. //var form = new FormData();
  406. /* keysList.forEach(function(v,i){
  407. console.log(v);
  408. form.append(v, data[v]);
  409. });*/
  410. //form.append('ssoId', data.ssoId);
  411. //form.append('cid', data.cid);
  412. //console.log(form);
  413. //console.log(keysList);
  414. //form.append('my_file', fs.createReadStream('/foo/bar.jpg'));
  415. //?longle=12
  416. //url='http://cld.com/longle/list/add';
  417. //var content = qs.stringify({'longle':125});
  418. //console.log(data);
  419. }
  420. var modelsQuery= async function(sql){
  421. var data=[];
  422. await models.sequelize.query(sql).spread((results, metadata) => {
  423. // 结果将是一个空数组,元数据将包含受影响的行数。
  424. data=results;
  425. });
  426. return data;
  427. }
  428. /**
  429. * 分页相关数据计算
  430. * modelsTable 数据表对象
  431. * parameter 设置传的参数
  432. */
  433. var getPage= async function(modelsTable,where,currentPage,pageSize,parameter,totalCount){
  434. if(!hash.isExistence(totalCount)){
  435. if(hash.isExistence(where)){
  436. totalCount=await modelsTable.count({where});
  437. }else{
  438. totalCount=await modelsTable.count();
  439. }
  440. }
  441. currentPage=parseInt(currentPage);
  442. var total =0;
  443. if(totalCount!=0){
  444. total = Math.trunc ( totalCount / pageSize );
  445. }
  446. var totalPage = (totalCount % pageSize) == 0 ? total : total + 1;
  447. var pageMax=1;
  448. var pageWidth=15;
  449. //开始页数
  450. var startPage=1;
  451. if (currentPage >= pageWidth) {
  452. pageMax = parseInt ( currentPage / pageWidth ) + 1;
  453. startPage = parseInt ( currentPage / pageWidth ) * pageWidth - 1;
  454. }
  455. //结束页数
  456. var endPage=pageWidth * pageMax;
  457. if(endPage>totalPage){
  458. endPage=totalPage;
  459. }
  460. var page={
  461. 'currentPage':currentPage, //当前页
  462. 'previousPage':currentPage!=0?currentPage-1:currentPage, //上一页
  463. 'nextPage': currentPage==totalPage ? totalPage:currentPage+1,
  464. 'totalPage':totalPage,
  465. 'startPage':startPage,
  466. 'endPage':endPage,
  467. 'pageWidth':pageWidth,
  468. 'parameter':encodeURI(parameter)
  469. };
  470. return page;
  471. }