cloudEditionService.js 18 KB

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