xxl-job

jobinfo.index.1.js 21KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601
  1. $(function() {
  2. // init date tables
  3. var jobTable = $("#job_list").dataTable({
  4. "deferRender": true,
  5. "processing" : true,
  6. "serverSide": true,
  7. "ajax": {
  8. url: base_url + "/jobinfo/pageList",
  9. type:"post",
  10. data : function ( d ) {
  11. var obj = {};
  12. obj.jobGroup = $('#jobGroup').val();
  13. obj.triggerStatus = $('#triggerStatus').val();
  14. obj.jobDesc = $('#jobDesc').val();
  15. obj.executorHandler = $('#executorHandler').val();
  16. obj.author = $('#author').val();
  17. obj.start = d.start;
  18. obj.length = d.length;
  19. return obj;
  20. }
  21. },
  22. "searching": false,
  23. "ordering": false,
  24. //"scrollX": true, // scroll x,close self-adaption
  25. "columns": [
  26. {
  27. "data": 'id',
  28. "bSortable": false,
  29. "visible" : true,
  30. "width":'7%'
  31. },
  32. {
  33. "data": 'jobGroup',
  34. "visible" : false,
  35. "render": function ( data, type, row ) {
  36. var groupMenu = $("#jobGroup").find("option");
  37. for ( var index in $("#jobGroup").find("option")) {
  38. if ($(groupMenu[index]).attr('value') == data) {
  39. return $(groupMenu[index]).html();
  40. }
  41. }
  42. return data;
  43. }
  44. },
  45. {
  46. "data": 'jobDesc',
  47. "visible" : true,
  48. "width":'25%'
  49. },
  50. {
  51. "data": 'glueType',
  52. "width":'25%',
  53. "visible" : true,
  54. "render": function ( data, type, row ) {
  55. var glueTypeTitle = findGlueTypeTitle(row.glueType);
  56. if (row.executorHandler) {
  57. return glueTypeTitle +":" + row.executorHandler;
  58. } else {
  59. return glueTypeTitle;
  60. }
  61. }
  62. },
  63. { "data": 'executorParam', "visible" : false},
  64. {
  65. "data": 'jobCron',
  66. "visible" : true,
  67. "width":'13%'
  68. },
  69. {
  70. "data": 'addTime',
  71. "visible" : false,
  72. "render": function ( data, type, row ) {
  73. return data?moment(new Date(data)).format("YYYY-MM-DD HH:mm:ss"):"";
  74. }
  75. },
  76. {
  77. "data": 'updateTime',
  78. "visible" : false,
  79. "render": function ( data, type, row ) {
  80. return data?moment(new Date(data)).format("YYYY-MM-DD HH:mm:ss"):"";
  81. }
  82. },
  83. { "data": 'author', "visible" : true, "width":'10%'},
  84. { "data": 'alarmEmail', "visible" : false},
  85. {
  86. "data": 'triggerStatus',
  87. "width":'10%',
  88. "visible" : true,
  89. "render": function ( data, type, row ) {
  90. // status
  91. if (1 == data) {
  92. return '<small class="label label-success" >RUNNING</small>';
  93. } else {
  94. return '<small class="label label-default" >STOP</small>';
  95. }
  96. return data;
  97. }
  98. },
  99. {
  100. "data": I18n.system_opt ,
  101. "width":'10%',
  102. "render": function ( data, type, row ) {
  103. return function(){
  104. // status
  105. var start_stop_div = "";
  106. if (1 == row.triggerStatus ) {
  107. start_stop_div = '<li><a href="javascript:void(0);" class="job_operate" _type="job_pause" >'+ I18n.jobinfo_opt_stop +'</a></li>\n';
  108. } else {
  109. start_stop_div = '<li><a href="javascript:void(0);" class="job_operate" _type="job_resume" >'+ I18n.jobinfo_opt_start +'</a></li>\n';
  110. }
  111. // log url
  112. var logHref = base_url +'/joblog?jobId='+ row.id;
  113. // log url
  114. var codeBtn = "";
  115. if ('BEAN' != row.glueType) {
  116. var codeUrl = base_url +'/jobcode?jobId='+ row.id;
  117. codeBtn = '<li><a href="'+ codeUrl +'" target="_blank" >GLUE IDE</a></li>\n';
  118. }
  119. // data
  120. tableData['key'+row.id] = row;
  121. // opt
  122. var html = '<div class="btn-group">\n' +
  123. ' <button type="button" class="btn btn-primary btn-sm">'+ I18n.system_opt +'</button>\n' +
  124. ' <button type="button" class="btn btn-primary btn-sm dropdown-toggle" data-toggle="dropdown">\n' +
  125. ' <span class="caret"></span>\n' +
  126. ' <span class="sr-only">Toggle Dropdown</span>\n' +
  127. ' </button>\n' +
  128. ' <ul class="dropdown-menu" role="menu" _id="'+ row.id +'" >\n' +
  129. ' <li><a href="javascript:void(0);" class="job_trigger" >'+ I18n.jobinfo_opt_run +'</a></li>\n' +
  130. ' <li><a href="'+ logHref +'">'+ I18n.jobinfo_opt_log +'</a></li>\n' +
  131. ' <li><a href="javascript:void(0);" class="job_registryinfo" >' + I18n.jobinfo_opt_registryinfo + '</a></li>\n' +
  132. ' <li class="divider"></li>\n' +
  133. start_stop_div +
  134. codeBtn +
  135. ' <li><a href="javascript:void(0);" class="update" >'+ I18n.system_opt_edit +'</a></li>\n' +
  136. ' <li><a href="javascript:void(0);" class="job_operate" _type="job_del" >'+ I18n.system_opt_del +'</a></li>\n' +
  137. ' </ul>\n' +
  138. ' </div>';
  139. return html;
  140. };
  141. }
  142. }
  143. ],
  144. "language" : {
  145. "sProcessing" : I18n.dataTable_sProcessing ,
  146. "sLengthMenu" : I18n.dataTable_sLengthMenu ,
  147. "sZeroRecords" : I18n.dataTable_sZeroRecords ,
  148. "sInfo" : I18n.dataTable_sInfo ,
  149. "sInfoEmpty" : I18n.dataTable_sInfoEmpty ,
  150. "sInfoFiltered" : I18n.dataTable_sInfoFiltered ,
  151. "sInfoPostFix" : "",
  152. "sSearch" : I18n.dataTable_sSearch ,
  153. "sUrl" : "",
  154. "sEmptyTable" : I18n.dataTable_sEmptyTable ,
  155. "sLoadingRecords" : I18n.dataTable_sLoadingRecords ,
  156. "sInfoThousands" : ",",
  157. "oPaginate" : {
  158. "sFirst" : I18n.dataTable_sFirst ,
  159. "sPrevious" : I18n.dataTable_sPrevious ,
  160. "sNext" : I18n.dataTable_sNext ,
  161. "sLast" : I18n.dataTable_sLast
  162. },
  163. "oAria" : {
  164. "sSortAscending" : I18n.dataTable_sSortAscending ,
  165. "sSortDescending" : I18n.dataTable_sSortDescending
  166. }
  167. }
  168. });
  169. // table data
  170. var tableData = {};
  171. // search btn
  172. $('#searchBtn').on('click', function(){
  173. jobTable.fnDraw();
  174. });
  175. // jobGroup change
  176. $('#jobGroup').on('change', function(){
  177. //reload
  178. var jobGroup = $('#jobGroup').val();
  179. window.location.href = base_url + "/jobinfo?jobGroup=" + jobGroup;
  180. });
  181. // job operate
  182. $("#job_list").on('click', '.job_operate',function() {
  183. var typeName;
  184. var url;
  185. var needFresh = false;
  186. var type = $(this).attr("_type");
  187. if ("job_pause" == type) {
  188. typeName = I18n.jobinfo_opt_stop ;
  189. url = base_url + "/jobinfo/stop";
  190. needFresh = true;
  191. } else if ("job_resume" == type) {
  192. typeName = I18n.jobinfo_opt_start ;
  193. url = base_url + "/jobinfo/start";
  194. needFresh = true;
  195. } else if ("job_del" == type) {
  196. typeName = I18n.system_opt_del ;
  197. url = base_url + "/jobinfo/remove";
  198. needFresh = true;
  199. } else {
  200. return;
  201. }
  202. var id = $(this).parents('ul').attr("_id");
  203. layer.confirm( I18n.system_ok + typeName + '?', {
  204. icon: 3,
  205. title: I18n.system_tips ,
  206. btn: [ I18n.system_ok, I18n.system_cancel ]
  207. }, function(index){
  208. layer.close(index);
  209. $.ajax({
  210. type : 'POST',
  211. url : url,
  212. data : {
  213. "id" : id
  214. },
  215. dataType : "json",
  216. success : function(data){
  217. if (data.code == 200) {
  218. layer.msg( typeName + I18n.system_success );
  219. if (needFresh) {
  220. //window.location.reload();
  221. jobTable.fnDraw(false);
  222. }
  223. } else {
  224. layer.msg( data.msg || typeName + I18n.system_fail );
  225. }
  226. }
  227. });
  228. });
  229. });
  230. // job trigger
  231. $("#job_list").on('click', '.job_trigger',function() {
  232. var id = $(this).parents('ul').attr("_id");
  233. var row = tableData['key'+id];
  234. $("#jobTriggerModal .form input[name='id']").val( row.id );
  235. $("#jobTriggerModal .form textarea[name='executorParam']").val( row.executorParam );
  236. $('#jobTriggerModal').modal({backdrop: false, keyboard: false}).modal('show');
  237. });
  238. $("#jobTriggerModal .ok").on('click',function() {
  239. $.ajax({
  240. type : 'POST',
  241. url : base_url + "/jobinfo/trigger",
  242. data : {
  243. "id" : $("#jobTriggerModal .form input[name='id']").val(),
  244. "executorParam" : $("#jobTriggerModal .textarea[name='executorParam']").val()
  245. },
  246. dataType : "json",
  247. success : function(data){
  248. if (data.code == 200) {
  249. $('#jobTriggerModal').modal('hide');
  250. layer.msg( I18n.jobinfo_opt_run + I18n.system_success );
  251. } else {
  252. layer.msg( data.msg || I18n.jobinfo_opt_run + I18n.system_fail );
  253. }
  254. }
  255. });
  256. });
  257. $("#jobTriggerModal").on('hide.bs.modal', function () {
  258. $("#jobTriggerModal .form")[0].reset();
  259. });
  260. // job registryinfo
  261. $("#job_list").on('click', '.job_registryinfo',function() {
  262. var id = $(this).parents('ul').attr("_id");
  263. var row = tableData['key'+id];
  264. var jobGroup = row.jobGroup;
  265. $.ajax({
  266. type : 'POST',
  267. url : base_url + "/jobgroup/loadById",
  268. data : {
  269. "id" : jobGroup
  270. },
  271. dataType : "json",
  272. success : function(data){
  273. var html = '<center>';
  274. if (data.code == 200 && data.content.registryList) {
  275. for (var index in data.content.registryList) {
  276. html += '<span class="badge bg-green" >' + data.content.registryList[index] + '</span><br>';
  277. }
  278. }
  279. html += '</center>';
  280. layer.open({
  281. title: I18n.jobinfo_opt_registryinfo ,
  282. btn: [ I18n.system_ok ],
  283. content: html
  284. });
  285. }
  286. });
  287. });
  288. // add
  289. $(".add").click(function(){
  290. // init
  291. $("#addModal .form input[name='jobCron']").cronGen({});
  292. $('#addModal').modal({backdrop: false, keyboard: false}).modal('show');
  293. });
  294. var addModalValidate = $("#addModal .form").validate({
  295. errorElement : 'span',
  296. errorClass : 'help-block',
  297. focusInvalid : true,
  298. rules : {
  299. jobDesc : {
  300. required : true,
  301. maxlength: 50
  302. },
  303. jobCron : {
  304. required : true
  305. },
  306. author : {
  307. required : true
  308. },
  309. executorTimeout : {
  310. digits:true
  311. },
  312. executorFailRetryCount : {
  313. digits:true
  314. }
  315. },
  316. messages : {
  317. jobDesc : {
  318. required : I18n.system_please_input + I18n.jobinfo_field_jobdesc
  319. },
  320. jobCron : {
  321. required : I18n.system_please_input + "Cron"
  322. },
  323. author : {
  324. required : I18n.system_please_input + I18n.jobinfo_field_author
  325. },
  326. executorTimeout : {
  327. digits: I18n.system_please_input + I18n.system_digits
  328. },
  329. executorFailRetryCount : {
  330. digits: I18n.system_please_input + I18n.system_digits
  331. }
  332. },
  333. highlight : function(element) {
  334. $(element).closest('.form-group').addClass('has-error');
  335. },
  336. success : function(label) {
  337. label.closest('.form-group').removeClass('has-error');
  338. label.remove();
  339. },
  340. errorPlacement : function(error, element) {
  341. element.parent('div').append(error);
  342. },
  343. submitHandler : function(form) {
  344. // process
  345. var executorTimeout = $("#addModal .form input[name='executorTimeout']").val();
  346. if(!/^\d+$/.test(executorTimeout)) {
  347. executorTimeout = 0;
  348. }
  349. $("#addModal .form input[name='executorTimeout']").val(executorTimeout);
  350. var executorFailRetryCount = $("#addModal .form input[name='executorFailRetryCount']").val();
  351. if(!/^\d+$/.test(executorFailRetryCount)) {
  352. executorFailRetryCount = 0;
  353. }
  354. $("#addModal .form input[name='executorFailRetryCount']").val(executorFailRetryCount);
  355. $.post(base_url + "/jobinfo/add", $("#addModal .form").serialize(), function(data, status) {
  356. if (data.code == "200") {
  357. $('#addModal').modal('hide');
  358. layer.open({
  359. title: I18n.system_tips ,
  360. btn: [ I18n.system_ok ],
  361. content: I18n.system_add_suc ,
  362. icon: '1',
  363. end: function(layero, index){
  364. jobTable.fnDraw();
  365. //window.location.reload();
  366. }
  367. });
  368. } else {
  369. layer.open({
  370. title: I18n.system_tips ,
  371. btn: [ I18n.system_ok ],
  372. content: (data.msg || I18n.system_add_fail),
  373. icon: '2'
  374. });
  375. }
  376. });
  377. }
  378. });
  379. $("#addModal").on('hide.bs.modal', function () {
  380. $("#addModal .form")[0].reset();
  381. addModalValidate.resetForm();
  382. // 清理 cronGen
  383. $("input[name=jobCron]").show().siblings().remove();
  384. $("#addModal .form .form-group").removeClass("has-error");
  385. $(".remote_panel").show(); // remote
  386. $("#addModal .form input[name='executorHandler']").removeAttr("readonly");
  387. });
  388. // glueType change
  389. $(".glueType").change(function(){
  390. // executorHandler
  391. var $executorHandler = $(this).parents("form").find("input[name='executorHandler']");
  392. var glueType = $(this).val();
  393. if ('BEAN' != glueType) {
  394. $executorHandler.val("");
  395. $executorHandler.attr("readonly","readonly");
  396. } else {
  397. $executorHandler.removeAttr("readonly");
  398. }
  399. });
  400. $("#addModal .glueType").change(function(){
  401. // glueSource
  402. var glueType = $(this).val();
  403. if ('GLUE_GROOVY'==glueType){
  404. $("#addModal .form textarea[name='glueSource']").val( $("#addModal .form .glueSource_java").val() );
  405. } else if ('GLUE_SHELL'==glueType){
  406. $("#addModal .form textarea[name='glueSource']").val( $("#addModal .form .glueSource_shell").val() );
  407. } else if ('GLUE_PYTHON'==glueType){
  408. $("#addModal .form textarea[name='glueSource']").val( $("#addModal .form .glueSource_python").val() );
  409. } else if ('GLUE_PHP'==glueType){
  410. $("#addModal .form textarea[name='glueSource']").val( $("#addModal .form .glueSource_php").val() );
  411. } else if ('GLUE_NODEJS'==glueType){
  412. $("#addModal .form textarea[name='glueSource']").val( $("#addModal .form .glueSource_nodejs").val() );
  413. } else if ('GLUE_POWERSHELL'==glueType){
  414. $("#addModal .form textarea[name='glueSource']").val( $("#addModal .form .glueSource_powershell").val() );
  415. } else {
  416. $("#addModal .form textarea[name='glueSource']").val("");
  417. }
  418. });
  419. // update
  420. $("#job_list").on('click', '.update',function() {
  421. var id = $(this).parents('ul').attr("_id");
  422. var row = tableData['key'+id];
  423. // base data
  424. $("#updateModal .form input[name='id']").val( row.id );
  425. $('#updateModal .form select[name=jobGroup] option[value='+ row.jobGroup +']').prop('selected', true);
  426. $("#updateModal .form input[name='jobDesc']").val( row.jobDesc );
  427. $("#updateModal .form input[name='jobCron']").val( row.jobCron );
  428. $("#updateModal .form input[name='author']").val( row.author );
  429. $("#updateModal .form input[name='alarmEmail']").val( row.alarmEmail );
  430. $("#updateModal .form input[name='executorTimeout']").val( row.executorTimeout );
  431. $("#updateModal .form input[name='executorFailRetryCount']").val( row.executorFailRetryCount );
  432. $('#updateModal .form select[name=executorRouteStrategy] option[value='+ row.executorRouteStrategy +']').prop('selected', true);
  433. $("#updateModal .form input[name='executorHandler']").val( row.executorHandler );
  434. $("#updateModal .form textarea[name='executorParam']").val( row.executorParam );
  435. $("#updateModal .form input[name='childJobId']").val( row.childJobId );
  436. $('#updateModal .form select[name=executorBlockStrategy] option[value='+ row.executorBlockStrategy +']').prop('selected', true);
  437. $('#updateModal .form select[name=glueType] option[value='+ row.glueType +']').prop('selected', true);
  438. $("#updateModal .form select[name=glueType]").change();
  439. // init
  440. $("#updateModal .form input[name='jobCron']").cronGen({});
  441. // show
  442. $('#updateModal').modal({backdrop: false, keyboard: false}).modal('show');
  443. });
  444. var updateModalValidate = $("#updateModal .form").validate({
  445. errorElement : 'span',
  446. errorClass : 'help-block',
  447. focusInvalid : true,
  448. rules : {
  449. jobDesc : {
  450. required : true,
  451. maxlength: 50
  452. },
  453. jobCron : {
  454. required : true
  455. },
  456. author : {
  457. required : true
  458. },
  459. executorTimeout : {
  460. digits:true
  461. },
  462. executorFailRetryCount : {
  463. digits:true
  464. }
  465. },
  466. messages : {
  467. jobDesc : {
  468. required : I18n.system_please_input + I18n.jobinfo_field_jobdesc
  469. },
  470. jobCron : {
  471. required : I18n.system_please_input + "Cron"
  472. },
  473. author : {
  474. required : I18n.system_please_input + I18n.jobinfo_field_author
  475. },
  476. executorTimeout : {
  477. digits: I18n.system_please_input + I18n.system_digits
  478. },
  479. executorFailRetryCount : {
  480. digits: I18n.system_please_input + I18n.system_digits
  481. }
  482. },
  483. highlight : function(element) {
  484. $(element).closest('.form-group').addClass('has-error');
  485. },
  486. success : function(label) {
  487. label.closest('.form-group').removeClass('has-error');
  488. label.remove();
  489. },
  490. errorPlacement : function(error, element) {
  491. element.parent('div').append(error);
  492. },
  493. submitHandler : function(form) {
  494. // process
  495. var executorTimeout = $("#updateModal .form input[name='executorTimeout']").val();
  496. if(!/^\d+$/.test(executorTimeout)) {
  497. executorTimeout = 0;
  498. }
  499. $("#updateModal .form input[name='executorTimeout']").val(executorTimeout);
  500. var executorFailRetryCount = $("#updateModal .form input[name='executorFailRetryCount']").val();
  501. if(!/^\d+$/.test(executorFailRetryCount)) {
  502. executorFailRetryCount = 0;
  503. }
  504. $("#updateModal .form input[name='executorFailRetryCount']").val(executorFailRetryCount);
  505. // post
  506. $.post(base_url + "/jobinfo/update", $("#updateModal .form").serialize(), function(data, status) {
  507. if (data.code == "200") {
  508. $('#updateModal').modal('hide');
  509. layer.open({
  510. title: I18n.system_tips ,
  511. btn: [ I18n.system_ok ],
  512. content: I18n.system_update_suc ,
  513. icon: '1',
  514. end: function(layero, index){
  515. //window.location.reload();
  516. jobTable.fnDraw();
  517. }
  518. });
  519. } else {
  520. layer.open({
  521. title: I18n.system_tips ,
  522. btn: [ I18n.system_ok ],
  523. content: (data.msg || I18n.system_update_fail ),
  524. icon: '2'
  525. });
  526. }
  527. });
  528. }
  529. });
  530. $("#updateModal").on('hide.bs.modal', function () {
  531. $("#updateModal .form")[0].reset();
  532. // 清理 cronGen
  533. $("input[name=jobCron]").show().siblings().remove();
  534. });
  535. /**
  536. * find title by name, GlueType
  537. */
  538. function findGlueTypeTitle(glueType) {
  539. var glueTypeTitle;
  540. $("#addModal .form select[name=glueType] option").each(function () {
  541. var name = $(this).val();
  542. var title = $(this).text();
  543. if (glueType == name) {
  544. glueTypeTitle = title;
  545. return false
  546. }
  547. });
  548. return glueTypeTitle;
  549. }
  550. });