DataProcessController.java 1.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. package com.yihu.wlyy.statistics.controller;
  2. import com.fasterxml.jackson.databind.deser.Deserializers;
  3. import com.yihu.wlyy.statistics.task.PatientDiseaseToLabel;
  4. import com.yihu.wlyy.statistics.task.PatientGroupToLabelRunnable;
  5. import com.yihu.wlyy.statistics.task.SignTeamAndGroupRunnable;
  6. import org.springframework.web.bind.annotation.RequestMapping;
  7. import org.springframework.web.bind.annotation.RestController;
  8. /**
  9. * Created by lyr-pc on 2016/10/12.
  10. */
  11. @RestController
  12. @RequestMapping(value = "/data_process")
  13. public class DataProcessController extends BaseController {
  14. /**
  15. * 签约同步数据设置团队和分组
  16. *
  17. * @return
  18. */
  19. @RequestMapping(value = "/sign_team_group_thread")
  20. public String setTeamGroupPage(long start,long end){
  21. try {
  22. new Thread(new SignTeamAndGroupRunnable(start,end)).start();
  23. return write(200,"启动成功");
  24. } catch (Exception e) {
  25. e.printStackTrace();
  26. return error(-1, "启动失败");
  27. }
  28. }
  29. /**
  30. * 签约同步数据设置团队和分组
  31. *
  32. * @return
  33. */
  34. @RequestMapping(value = "/disease_to_label_thread")
  35. public String diseaseToLabel(long start){
  36. try {
  37. new Thread(new PatientDiseaseToLabel(start)).start();
  38. return write(200,"启动成功");
  39. } catch (Exception e) {
  40. e.printStackTrace();
  41. return error(-1, "启动失败");
  42. }
  43. }
  44. /**
  45. * 签约同步数据设置团队和分组
  46. *
  47. * @return
  48. */
  49. @RequestMapping(value = "/group_to_label_thread")
  50. public String diseaseToLabel(long start,long end){
  51. try {
  52. new Thread(new PatientGroupToLabelRunnable(start,end)).start();
  53. return write(200,"启动成功");
  54. } catch (Exception e) {
  55. e.printStackTrace();
  56. return error(-1, "启动失败");
  57. }
  58. }
  59. }