cloudEditionService.js 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564
  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=v.sso_id;
  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=1;gi<v.upgrade_list.length;gi++){
  169. console.log(v.upgrade_list);
  170. for(var ci=0;ci<compilationList.length;ci++){
  171. if( compilationList[ci]._id == v.upgrade_list[gi].compilationID&&v.upgrade_list[gi].isUpgrade) {
  172. curingCloudList[i].upgradeListName+='<span class="badge badge-primary"><%= compilation.name %></span>';
  173. break;
  174. }
  175. }
  176. }
  177. });
  178. var parameter='?compilation='+compilation+'&latestCompilation='+latestCompilation+'&sortField='+sortField+'&sort='+sort;
  179. //分页计算
  180. var pageData = await getPage('','',page,limit,parameter,curingCloudData.pageData.total);
  181. console.log(compilationList);
  182. return {curingList:curingCloudList,pageData:pageData,sortList:[sortField,sort]};
  183. },
  184. /**
  185. * 获得养护编办--接口拉取
  186. */
  187. getCompilationList:async function (){
  188. var url= curingUrl+'/getCompilationList';
  189. var data= await curlRequest(url);
  190. return data;
  191. },
  192. /**
  193. * 获得本地编办列表--废弃
  194. */
  195. getCuringCompilationList:async function (){
  196. var compilationList = await models.cloud_curing.getCuringCompilationList();
  197. return compilationList;
  198. },
  199. //获取本地养护数据
  200. getBindCuringByMobile:async function (mobile){
  201. var curingList = await models.cloud_curing.getCuringByMobile(mobile);
  202. if (curingList!=null){
  203. var cid=[curingList['client_id']];
  204. var attributes= ['cid', 'clientname', 'companyid', 'companyname'];
  205. var clientList = await models.CLD_client.findAllInCid(cid,attributes);
  206. curingList.clientInfo={};
  207. clientList.forEach(function(clientVal,clientI){
  208. if(curingList.client_id==clientVal.cid){
  209. curingList.clientInfo=clientVal;
  210. }
  211. });
  212. curingList.addtime=moment.unix(curingList.addtime).format('YYYY-MM-DD HH:mm');
  213. }
  214. return curingList;
  215. },
  216. //根据手机号码获得养护用户信息
  217. getCuringByMobile: async function(mobile){
  218. var url= curingUrl+'/getUsersAndCompilation?mobile='+ mobile;
  219. var userData= await curlRequest(url);
  220. return userData;
  221. },
  222. /**
  223. * 用户详情页-数据
  224. */
  225. getCuringBySsoid: async function(ssoid,client_id){
  226. var curingSsoid=ssoid;
  227. if(!hash.isNotANumber(ssoid)){
  228. ssoid=hash.hashDecode(ssoid);
  229. if(!hash.isNotANumber(ssoid)){
  230. return [];
  231. }
  232. }
  233. var url= curingUrl+'/getUsersAndCompilation?ssoID='+ ssoid;
  234. var userData= await curlRequest(url);
  235. if(!hash.isExistence(userData)){
  236. return [];
  237. }
  238. //本地养护用户
  239. userData['curingInfo']=await models.cloud_curing.getCuringBySsoid(curingSsoid);
  240. client_id=userData['curingInfo']['client_id'];
  241. /*userData['clientInfo']='';
  242. if(!hash.isNotANumber(client_id)){
  243. client_id=hash.hashDecode(client_id);
  244. if(!hash.isNotANumber(client_id)){
  245. userData['clientInfo']=[];
  246. }
  247. }*/
  248. var detail =[];
  249. if(hash.isExistence(client_id)){
  250. detail = await models.CLD_client.findById(client_id);
  251. }
  252. userData['clientInfo']=detail;
  253. //组合数据升级产品数据
  254. userData['compilationList'].forEach(function(value,key){
  255. userData['userInfo']['upgrade_list'].forEach(function(v,k){
  256. if(v['compilationID']==value['_id']){
  257. userData['compilationList'][key]['isUpgrade']=v['isUpgrade'];
  258. }
  259. });
  260. });
  261. userData['userInfo']['ssoIdKey']=hash.hashEncode(userData['userInfo']['ssoId'].toString());
  262. //获得操作日志
  263. userData['operateLog']=[];
  264. if(hash.isExistence(userData['curingInfo'])){
  265. userData['operateLog']=await models.operate_log.findByCondition(1,hash.hashDecode(userData['curingInfo']['id']));
  266. }
  267. return userData;
  268. },
  269. upCuringDo: async function(data){
  270. var url = curingUrl+'/setUserUpgrade';
  271. var ssoid=hash.hashDecode(data.ssoid);
  272. var postData ={'ssoId':ssoid,'cid':data.compilationId};
  273. var result= await postRequest(url,postData);
  274. result=JSON.parse(result);
  275. if(result.error==0){ //接口更新成
  276. var curingDetail=await models.cloud_curing.getCuringByMobile(data.mobile);
  277. var id='';
  278. if(hash.isExistence(curingDetail)){ //是否需要同步同步到本地库中
  279. var url= curingUrl+'/getUsersAndCompilation?ssoID='+ ssoid;
  280. var userData= await curlRequest(url);
  281. //获得更新数量updateTotal
  282. var updateTotal=0;
  283. userData['userInfo']['upgrade_list'].forEach(function(value,key){
  284. if(value['isUpgrade']){
  285. updateTotal++;
  286. }
  287. });
  288. //更新数量
  289. var values = {
  290. updateTotal: updateTotal
  291. }
  292. var where={
  293. where: {id: curingDetail['id']}
  294. };
  295. await models.cloud_curing.update(values,where);
  296. id=curingDetail['id'];
  297. }else{
  298. sid=hash.hashDecode(STAFF.sid);
  299. //获得登陆用户相关信息
  300. var obj = {
  301. mobile: data.mobile,
  302. sso_id: data.ssoid,
  303. compilation_id: data.compilationId,
  304. curingCompany: data.name,
  305. sid: sid,
  306. cid: STAFF.cid,
  307. status: 1,
  308. addtime: new Date().getTime(),
  309. updateTotal: 1
  310. };
  311. var detail=await models.cloud_curing.create(obj);
  312. id=detail['cloud_curing']['id'];
  313. }
  314. var operation=STAFF.username+'升级'+data.name;
  315. //记录锁日志
  316. await models.operate_log.createOperateLog(1,id,operation);
  317. return true;
  318. }else{
  319. return false;
  320. }
  321. },
  322. //养护用户绑定CLD客户
  323. relevanceClientDo: async function(data){
  324. var cid=hash.hashDecode(data.cidKey);
  325. var id=hash.hashDecode(data.id);
  326. if(!hash.isNotANumber(cid)||!hash.isNotANumber(id)){
  327. return false;
  328. }
  329. var curingDetail=await models.cloud_curing.getCuringById(id);
  330. if(hash.isExistence(curingDetail)) {
  331. var clientDetail=await models.CLD_client.findById(cid);
  332. if(hash.isExistence(clientDetail)){
  333. //更新数量
  334. var values = {
  335. client_id: cid
  336. }
  337. var where={
  338. where: {id: curingDetail['id']}
  339. };
  340. await models.cloud_curing.update(values,where);
  341. //记录操作日志
  342. var operation=STAFF.username+'关联CLD联系人'+clientDetail.clientname;
  343. await models.operate_log.createOperateLog(1,id,operation);
  344. return true;
  345. }else{
  346. return false;
  347. }
  348. }else{
  349. return false;
  350. }
  351. },
  352. //移除关联CLD客户
  353. relieveClientDo: async function(data){
  354. var id=hash.hashDecode(data.id);
  355. if(!hash.isNotANumber(id)){
  356. return false;
  357. }
  358. var curingDetail=await models.cloud_curing.getCuringById(id);
  359. if(hash.isExistence(curingDetail)) {
  360. //更新数量
  361. var values = {
  362. client_id: ''
  363. }
  364. var where={
  365. where: {id: curingDetail['id']}
  366. };
  367. await models.cloud_curing.update(values,where);
  368. var clientDetail=await models.CLD_client.findById(curingDetail['client_id']);
  369. //记录操作日志
  370. var operation=STAFF.username+'移除CLD联系人'+clientDetail.clientname;
  371. await models.operate_log.createOperateLog(1,id,operation);
  372. return true;
  373. }else{
  374. return false;
  375. }
  376. },
  377. }
  378. module.exports = cloudService;
  379. //接口调用
  380. var curlRequest = async function(url){
  381. var got = require('got');
  382. var data=[];
  383. await got(url, { json: true,timeout:300 }).then(response => {
  384. data= response.body.data;
  385. }).catch(error => {
  386. console.log('GET调用接口超时');
  387. });
  388. return data;
  389. }
  390. var postRequest= async function(url,data){
  391. //var fs = require('fs');
  392. var got = require('got');
  393. var qs = require('querystring');
  394. var keysList=Object.keys(data);
  395. var content = qs.stringify(data);
  396. result= await got.post(url, {
  397. body: content,
  398. timeout:300,
  399. headers: {
  400. 'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8'
  401. }
  402. }).catch(error => {
  403. console.log('POST调用接口超时');
  404. });
  405. return result.body;
  406. //var FormData = require('form-data');
  407. //var form = new FormData();
  408. /* keysList.forEach(function(v,i){
  409. console.log(v);
  410. form.append(v, data[v]);
  411. });*/
  412. //form.append('ssoId', data.ssoId);
  413. //form.append('cid', data.cid);
  414. //console.log(form);
  415. //console.log(keysList);
  416. //form.append('my_file', fs.createReadStream('/foo/bar.jpg'));
  417. //?longle=12
  418. //url='http://cld.com/longle/list/add';
  419. //var content = qs.stringify({'longle':125});
  420. //console.log(data);
  421. }
  422. var modelsQuery= async function(sql){
  423. var data=[];
  424. await models.sequelize.query(sql).spread((results, metadata) => {
  425. // 结果将是一个空数组,元数据将包含受影响的行数。
  426. data=results;
  427. });
  428. return data;
  429. }
  430. /**
  431. * 分页相关数据计算
  432. * modelsTable 数据表对象
  433. * parameter 设置传的参数
  434. */
  435. var getPage= async function(modelsTable,where,currentPage,pageSize,parameter,totalCount){
  436. if(!hash.isExistence(totalCount)){
  437. if(hash.isExistence(where)){
  438. totalCount=await modelsTable.count({where});
  439. }else{
  440. totalCount=await modelsTable.count();
  441. }
  442. }
  443. currentPage=parseInt(currentPage);
  444. var total =0;
  445. if(totalCount!=0){
  446. total = Math.trunc ( totalCount / pageSize );
  447. }
  448. var totalPage = (totalCount % pageSize) == 0 ? total : total + 1;
  449. var pageMax=1;
  450. var pageWidth=15;
  451. //开始页数
  452. var startPage=1;
  453. if (currentPage >= pageWidth) {
  454. pageMax = parseInt ( currentPage / pageWidth ) + 1;
  455. startPage = parseInt ( currentPage / pageWidth ) * pageWidth - 1;
  456. }
  457. //结束页数
  458. var endPage=pageWidth * pageMax;
  459. if(endPage>totalPage){
  460. endPage=totalPage;
  461. }
  462. var page={
  463. 'currentPage':currentPage, //当前页
  464. 'previousPage':currentPage!=0?currentPage-1:currentPage, //上一页
  465. 'nextPage': currentPage==totalPage ? totalPage:currentPage+1,
  466. 'totalPage':totalPage,
  467. 'startPage':startPage,
  468. 'endPage':endPage,
  469. 'pageWidth':pageWidth,
  470. 'parameter':encodeURI(parameter)
  471. };
  472. return page;
  473. }