RyTask.java 5.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189
  1. package com.dgtly.quartz.task;
  2. import com.dgtly.common.utils.StringUtils;
  3. import com.dgtly.sync.service.AnalysisDiyCustomerComponent;
  4. import com.dgtly.sync.service.HanaOrderComponent;
  5. import com.dgtly.sync.service.RelationCustomerOnlineComponent;
  6. import com.dgtly.system.service.ISysUserOrderAuthorService;
  7. import com.dgtly.system.service.HanaSalesOrderService;
  8. import com.dgtly.wxportal.service.IWxSendMessageService;
  9. import lombok.extern.slf4j.Slf4j;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.stereotype.Component;
  12. /**
  13. * 定时任务调度测试
  14. *
  15. * @author dgtly
  16. */
  17. @Component("ryTask")
  18. @Slf4j
  19. public class RyTask
  20. {
  21. @Autowired
  22. private AnalysisDiyCustomerComponent analysisDiyCustomerComponent;
  23. @Autowired
  24. private HanaOrderComponent hanaOrderComponent;
  25. @Autowired
  26. private RelationCustomerOnlineComponent relationCustomerOnlineComponent;
  27. @Autowired
  28. private ISysUserOrderAuthorService sysUserOrderAuthorService;
  29. @Autowired
  30. private IWxSendMessageService wxSendMessageService;
  31. @Autowired
  32. private HanaSalesOrderService HanaSalesOrderService;
  33. // private static RyTask ryTask;
  34. // @PostConstruct
  35. // public void init() {
  36. // ryTask = this;
  37. // ryTask.analysisDiyCustomerComponent = this.analysisDiyCustomerComponent;
  38. // }
  39. public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i)
  40. {
  41. log.info(StringUtils.format("执行多参方法: 字符串类型{},布尔类型{},长整型{},浮点型{},整形{}", s, b, l, d, i));
  42. }
  43. public void ryParams(String params)
  44. {
  45. log.info("执行有参方法:" + params);
  46. }
  47. public void ryNoParams()
  48. {
  49. log.info("执行无参方法");
  50. }
  51. /*立邦DIY人员定时同步*/
  52. public void analyDiyCustomer(){
  53. analysisDiyCustomerComponent.analyDiyCustomer();
  54. }
  55. /*立邦DIY人员定时同步*/
  56. /* public void analyCwCustomer(){
  57. analysisDiyCustomerComponent.analyCwCustomer();
  58. }*/
  59. /*HANA订单数据定时同步*/
  60. public void hanaSalesOrderSync() throws Exception {
  61. hanaOrderComponent.hanaSalesOrderSync();
  62. }
  63. /*HANA交货单数据定时同步*/
  64. public void hanaDeliverOrderSync() throws Exception {
  65. hanaOrderComponent.hanaDeliverOrderSync();
  66. }
  67. /**HANA已复核线下月底手动过账的交货单仍需自提同步*/
  68. public void hanaSelfReviewedDeliverOrderSync()throws Exception{
  69. hanaOrderComponent.hanaSelfReviewedDeliverOrderSync();
  70. }
  71. /**HANA已冻结经销商**/
  72. public void hanaFreezeCustomer()throws Exception{
  73. hanaOrderComponent.hanaFreezeCustomer();
  74. }
  75. /*关联经销商上线定时任务*/
  76. public void relationCustomerOnlineSync() throws Exception {
  77. relationCustomerOnlineComponent.relationCustomerOnlineSync();
  78. }
  79. /*初始化用户权限*/
  80. public void initUserAuthor() throws Exception {
  81. sysUserOrderAuthorService.initUserAuthor();
  82. }
  83. /**
  84. *
  85. * 离职用户标识
  86. * **/
  87. public void quitUser()throws Exception {
  88. sysUserOrderAuthorService.quitUser();
  89. }
  90. /**
  91. *
  92. * 维护经销商表
  93. * **/
  94. public void updateCustomers()throws Exception {
  95. sysUserOrderAuthorService.updateCustomers();
  96. }
  97. /**
  98. * 用户账号重复通知邮件
  99. * **/
  100. public void sendmailUnionUser()throws Exception{
  101. sysUserOrderAuthorService.sendmailUnionUser();
  102. }
  103. /**
  104. * 有道接口经销商用户账号重复进行业务处理
  105. * **/
  106. public void unionCustomerUser(){
  107. sysUserOrderAuthorService.unionCustomerUser();
  108. }
  109. /**
  110. * @description: 无tms工厂的交货单更新状态和订单
  111. * @param: []
  112. * @return: void
  113. * @author: njs
  114. * @date: 2023/2/23 13:16
  115. */
  116. public void tmsPlantByOrder(){
  117. sysUserOrderAuthorService.tmsPlantByOrder();
  118. }
  119. /**
  120. * @description: 经销商自动上线
  121. * @param:
  122. * @return:
  123. * @author: njs
  124. * @date: 2023/2/23 13:16
  125. */
  126. public void customersStart(){
  127. sysUserOrderAuthorService.customersStart();
  128. }
  129. /**
  130. * @description: 自提未提货企微消息通知提醒
  131. * @param:
  132. * @return:
  133. * @author: njs
  134. * @date: 2023/5/15 11:29
  135. */
  136. public void sendWxTmsMessage(){
  137. wxSendMessageService.sendWxTmsMessage();
  138. }
  139. /**
  140. * @description: 未过信的经销商订单的要货记录id(做逻辑删除,重新要货)
  141. * @param: []
  142. * @return: void
  143. * @author: njs
  144. * @date: 2023/6/16 10:26
  145. */
  146. /* public void salesOrderBaseByCreditStatus(){
  147. HanaSalesOrderService.updateSalesOrderBaseNoCrditStatus();
  148. }*/
  149. }
  150. /**
  151. * @description: 业绩进度指标预警邮件/企微消息通知
  152. * @param:
  153. * @return:
  154. * @author: njs
  155. * @date: 2024/2/4 9:21
  156. */
  157. public void sendMailAndWxEarlyTucMessage(){
  158. wxSendMessageService.sendMailAndWxEarlyTucMessage();
  159. }
  160. }