McAliworkController.java 7.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208
  1. package com.malk.controller;
  2. import com.malk.server.aliwork.YDConf;
  3. import com.malk.server.aliwork.YDParam;
  4. import com.malk.server.common.McR;
  5. import com.malk.service.aliwork.YDClient;
  6. import com.malk.service.aliwork.YDService;
  7. import io.swagger.annotations.Api;
  8. import io.swagger.annotations.ApiOperation;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.validation.annotation.Validated;
  11. import org.springframework.web.bind.annotation.PostMapping;
  12. import org.springframework.web.bind.annotation.RequestBody;
  13. import org.springframework.web.bind.annotation.RequestMapping;
  14. import org.springframework.web.bind.annotation.RestController;
  15. /**
  16. * 错误抛出与拦截详见CatchException
  17. */
  18. @Api(tags = "宜搭", value = "YD", description = "宜搭相关接口")
  19. @RestController
  20. @RequestMapping("/aliwork")
  21. public class McAliworkController {
  22. @Autowired
  23. private YDService service;
  24. @Autowired
  25. private YDClient client;
  26. ////////////////////////////////////////
  27. // 原子接口
  28. ////////////////////////////////////////
  29. @ApiOperation(tags = {"mc"}, value = "表单数据查询", notes = "匹配条件, 查询表单, 返回formData列表")
  30. @PostMapping("form/queryDataList")
  31. McR queryFormDataMatchCondition(@RequestBody @Validated(YDParam.Retrieve_Condition.class) YDParam param) {
  32. return McR.success(client.queryData(YDConf.API_FORM_QUERY_DATA, param));
  33. }
  34. /**
  35. * 2.匹配条件, 查询流程, 返回data列表
  36. */
  37. @ApiOperation(value = "登1录", notes = "用户登录", httpMethod = "POST")
  38. @PostMapping("process/queryDataList")
  39. McR queryProcessDataMatchCondition(@RequestBody @Validated(YDParam.Retrieve_Condition.class) YDParam param) {
  40. return McR.success(client.queryData(YDConf.API_PROCESS_QUERY_DATA, param));
  41. }
  42. /**
  43. * 3.匹配条件, 查询表单, 返回formInstId列表
  44. */
  45. @PostMapping("form/queryIdList")
  46. McR queryFormInstIdMatchCondition(@RequestBody @Validated(YDParam.Retrieve_Condition.class) YDParam param) {
  47. return McR.success(client.queryData(YDConf.API_FORM_QUERY_ID, param));
  48. }
  49. /**
  50. * 4.匹配条件, 查询流程, 返回processInstanceId列表
  51. */
  52. @PostMapping("process/queryIdList")
  53. McR queryProcessInstanceIdMatchCondition(@RequestBody @Validated(YDParam.Retrieve_Condition.class) YDParam param) {
  54. return McR.success(client.queryData(YDConf.API_FORM_QUERY_ID, param));
  55. }
  56. /**
  57. * 5.匹配formInstId, 返回表单实例详情
  58. */
  59. @PostMapping("form/queryDetail")
  60. McR queryFormDetail(@RequestBody @Validated(YDParam.Retrieve_FormInstId.class) YDParam param) {
  61. return McR.success(client.operateData(YDConf.API_FORM_DETAIL, param));
  62. }
  63. /**
  64. * 6.匹配processInstanceId, 返回流程实例详情
  65. */
  66. @PostMapping("process/queryDetail")
  67. McR queryProcessDetail(@RequestBody @Validated(YDParam.Retrieve_ProcessInstanceId.class) YDParam param) {
  68. return McR.success(client.operateData(YDConf.API_PROCESS_DETAIL, param));
  69. }
  70. /**
  71. * 7.匹配processInstanceIds, 批量返回流程实例详情列表
  72. */
  73. @PostMapping("process/queryBatchDetail")
  74. McR queryProcessBatchDetail(@RequestBody @Validated(YDParam.Retrieve_ProcessInstanceIds.class) YDParam param) {
  75. return McR.success(client.queryData(YDConf.API_PROCESS_BATCH_DETAIL, param));
  76. }
  77. /**
  78. * 8.新增表单数据, result返回实例Id
  79. */
  80. @PostMapping("form/create")
  81. McR createFormData(@RequestBody @Validated(YDParam.Create.class) YDParam param) {
  82. return McR.success(client.operateData(YDConf.API_FORM_CREATE, param));
  83. }
  84. /**
  85. * 9.新增流程数据, result返回实例Id
  86. */
  87. @PostMapping("proces/create")
  88. McR createProcessData(@RequestBody @Validated(YDParam.Create_Process.class) YDParam param) {
  89. return McR.success(client.operateData(YDConf.API_PROCESS_CREATE, param));
  90. }
  91. /**
  92. * 10.删除表单, 返回result为空, 若失败抛出异常于过滤器处理
  93. */
  94. @PostMapping("form/delete")
  95. McR deleteFormData(@RequestBody @Validated(YDParam.Delete.class) YDParam param) {
  96. return McR.success(client.operateData(YDConf.API_FORM_DELETE, param));
  97. }
  98. /**
  99. * 11.删除流程, 返回result为空, 若失败抛出异常于过滤器处理
  100. */
  101. @PostMapping("process/delete")
  102. McR deleteProcessData(@RequestBody @Validated(YDParam.Delete_ProcessInstanceId.class) YDParam param) {
  103. return McR.success(client.operateData(YDConf.API_PROCESS_DELETE, param));
  104. }
  105. /**
  106. * 12.更新表单, 返回result为空, 若失败抛出异常于过滤器处理
  107. */
  108. @PostMapping("form/upate")
  109. McR updateFormData(@RequestBody @Validated(YDParam.Update.class) YDParam param) {
  110. return McR.success(client.operateData(YDConf.API_FORM_UPDATE, param));
  111. }
  112. /**
  113. * 13.更新表单, 返回result为空, 若失败抛出异常于过滤器处理
  114. */
  115. @PostMapping("process/upate")
  116. McR updateProcessData(@RequestBody @Validated(YDParam.Update_ProcessInstanceId.class) YDParam param) {
  117. return McR.success(client.operateData(YDConf.API_FORM_UPDATE, param));
  118. }
  119. ////////////////////////////////////////
  120. // 服务接口
  121. ////////////////////////////////////////
  122. /**
  123. * a. 并发查询全量数据
  124. */
  125. @PostMapping("server/queryAllByConcurrence")
  126. McR queryAllDataByConcurrence(@RequestBody @Validated(YDParam.Retrieve_Condition.class) YDParam param) {
  127. return McR.success(service.queryAllDataByConcurrence(param));
  128. }
  129. /**
  130. * b. 同步查询全量数据
  131. */
  132. @PostMapping("server/queryAll")
  133. McR queryAllData(@RequestBody @Validated(YDParam.Retrieve_Condition.class) YDParam param) {
  134. return McR.success(service.queryAllData(param));
  135. }
  136. /**
  137. * c. 查询条件实现: 批量删除, 一个分页
  138. */
  139. @PostMapping("server/batchDelete")
  140. McR batchDelete(@RequestBody @Validated(YDParam.Retrieve_Condition.class) YDParam param) {
  141. return McR.success(service.operatePageData(param));
  142. }
  143. /**
  144. * d. 查询条件实现: 批量更新, 一个分页
  145. */
  146. @PostMapping("server/batchUpdate")
  147. McR batchUpdate(@RequestBody @Validated({YDParam.Retrieve_Condition_Update.class}) YDParam param) {
  148. return McR.success(service.operatePageData(param));
  149. }
  150. /**
  151. * e. 查询条件实现: 批量删除, 一个切片
  152. */
  153. @PostMapping("server/limitDelete")
  154. McR limitDelete(@RequestBody @Validated({YDParam.Retrieve_Condition.class}) YDParam param) {
  155. return McR.success(service.operateLimitData(param));
  156. }
  157. /**
  158. * f. 查询条件实现: 批量更新, 一个切片
  159. */
  160. @PostMapping("server/limitUpdate")
  161. McR limitUpdate(@RequestBody @Validated(YDParam.Retrieve_Condition_Update.class) YDParam param) {
  162. return McR.success(service.operateLimitData(param));
  163. }
  164. /**
  165. * g. 查询条件实现: 全量删除
  166. */
  167. @PostMapping("server/deleteAll")
  168. McR deleteAll(@RequestBody @Validated({YDParam.Retrieve_Condition.class}) YDParam param) {
  169. return McR.success(service.operateAllData(param));
  170. }
  171. /**
  172. * h. 查询条件实现: 全量更新
  173. */
  174. @PostMapping("server/updateALl")
  175. McR updateAll(@RequestBody @Validated(YDParam.Retrieve_Condition_Update.class) YDParam param) {
  176. return McR.success(service.operateAllData(param));
  177. }
  178. }