cloudEditionService.js 16 KB

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