TestTask.java 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758
  1. package com.kmall.admin.task;
  2. import com.kmall.admin.entity.PickUpCodeEntity;
  3. import com.kmall.admin.fromcomm.entity.SysUserEntity;
  4. import com.kmall.admin.fromcomm.service.SysUserService;
  5. import com.kmall.admin.service.PickUpCodeService;
  6. import com.kmall.admin.websocket.WebSocketServer;
  7. import org.apache.commons.lang.builder.ToStringBuilder;
  8. import org.slf4j.Logger;
  9. import org.slf4j.LoggerFactory;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.scheduling.annotation.EnableScheduling;
  12. import org.springframework.scheduling.annotation.Scheduled;
  13. import org.springframework.stereotype.Component;
  14. import java.text.SimpleDateFormat;
  15. import java.util.Date;
  16. import java.util.HashMap;
  17. import java.util.List;
  18. import java.util.Map;
  19. /**
  20. * 测试定时任务(演示Demo,可删除)
  21. * <p>
  22. * testTask为spring bean的名称
  23. *
  24. * @author Scott
  25. * @email
  26. * @date 2016年11月30日 下午1:34:24
  27. */
  28. @Component("testTask")
  29. @EnableScheduling
  30. public class TestTask {
  31. private Logger logger = LoggerFactory.getLogger(getClass());
  32. @Autowired
  33. private SysUserService sysUserService;
  34. @Autowired
  35. private static PickUpCodeService pickUpCodeService;
  36. @Scheduled(cron = "0/5 * * * * ?")
  37. public void flushPickUpCode() {
  38. logger.info("flushPickUpCode-----------------" );
  39. WebSocketServer.broadcastInfo("broadcast");
  40. // SysUserEntity user = sysUserService.queryObject(1L);
  41. // System.out.println(ToStringBuilder.reflectionToString(user));
  42. }
  43. public void test2() {
  44. logger.info("我是不带参数的test2方法,正在被执行");
  45. }
  46. }