| package doumeemes.task; | 
|   | 
|   | 
| import doumeemes.biz.system.SystemDictDataBiz; | 
| import doumeemes.core.utils.DateUtil; | 
| import doumeemes.service.business.PlansService; | 
| import doumeemes.service.ext.*; | 
| import doumeemes.service.system.SystemDictService; | 
| import doumeemes.service.system.impl.SystemDictServiceImpl; | 
| import org.springframework.amqp.rabbit.core.RabbitTemplate; | 
| import org.springframework.beans.factory.annotation.Autowired; | 
| import org.springframework.scheduling.annotation.Scheduled; | 
| import org.springframework.stereotype.Component; | 
|   | 
| /** | 
|  * 定时任务 | 
|  * @author jiangping | 
|  * @date 2021-10-10 14:40:35 | 
|  * https://www.bejson.com/othertools/cron/  cron 表达式生成地址 | 
|  */ | 
| @Component | 
| public class ScheduleTool { | 
|     @Autowired | 
|     public RabbitTemplate rabbitTemplate; | 
|     @Autowired | 
|     DepartmentExtService departmentExtService; | 
|     @Autowired | 
|     BarcodeParamExtService barcodeParamExtService; | 
|     @Autowired | 
|     CategoryExtService categoryExtService; | 
|     @Autowired | 
|     ProceduresExtService proceduresExtService; | 
|     @Autowired | 
|     PlansExtService plansExtService; | 
|     @Autowired | 
|     SystemDictDataBiz systemDictDataBiz; | 
|     @Autowired | 
|     WorkorderExtService workorderExtService; | 
|   | 
|     /** | 
|      * 初始化全部企业部门数据 | 
|      * @throws Exception | 
|      */ | 
|     @Scheduled(fixedDelay = 1000 * 60 * 60 * 24) | 
|     public void syncDepartment() throws Exception { | 
|         System.out.println("定时加载企业部门缓存信息--------Begin------"); | 
|         departmentExtService.loadAllDepart(); | 
|         System.out.println("定时加载企业部门缓存信息--------end------"); | 
|     } | 
|   | 
|     /** | 
|      * 初始化全部企业二维码数据 | 
|      * @throws Exception | 
|      */ | 
|     @Scheduled(fixedDelay = 1000 * 60 * 60 * 24) | 
|     public void syncBarcode() throws Exception { | 
|         System.out.println("定时加载企业二维码缓存信息--------Begin------"); | 
|         barcodeParamExtService.loadAll(); | 
|         System.out.println("定时加载企业二维码缓存信息--------end------"); | 
|     } | 
|     /** | 
|      * 初始化全部企业全部分类 | 
|      * @throws Exception | 
|      */ | 
|     @Scheduled(fixedDelay = 1000 * 60 * 60 * 24) | 
|     public void syncCategory() throws Exception { | 
|         System.out.println("定时加载企业分类信息缓存信息--------Begin------"); | 
|         categoryExtService.loadAll(); | 
|         System.out.println("定时加载企业分类信息缓存信息--------end------"); | 
|     } | 
|     /** | 
|      * 初始化全部企业工序数据 | 
|      * @throws Exception | 
|      */ | 
|     @Scheduled(fixedDelay = 1000 * 60 * 60 * 24) | 
|     public void syncProcedures() throws Exception { | 
|         System.out.println("定时加载企业工序缓存信息--------Begin------"); | 
|         proceduresExtService.loadAll(); | 
|         System.out.println("定时加载企业工序缓存信息--------end------"); | 
|     } | 
|     @Scheduled(fixedDelay = 1000 * 60 * 60 * 1) | 
|     public void updatEdgpAccessToken() throws Exception { | 
|         System.out.println("定时更新edgp平台访问授权码--------Begin------"); | 
|         systemDictDataBiz.updatEdgpAccessToken(); | 
|         System.out.println("定时更新edgp平台访问授权码--------end------"); | 
|     } | 
|   | 
|     /** | 
|      * 每天凌晨重置所有企业的出入库、计划、工单code初始值 | 
|      * @throws Exception | 
|      */ | 
|     @Scheduled(cron="0 0 0 * * ?") | 
|     public void initCompnayCodes() throws Exception { | 
|         System.out.println("定时加载数据code缓存信息--------Begin------"); | 
|         departmentExtService.initCompnayCodes(); | 
|         System.out.println("定时加载数据code缓存信息--------end------"); | 
|     } | 
|   | 
|     /** | 
|      * 每天凌晨定点关闭不能关闭的计划 | 
|      * @throws Exception | 
|      */ | 
|     @Scheduled(cron="0 0 1 * * ?") | 
|     public void closePlans() throws Exception { | 
|         System.out.println("定点关闭不能关闭的计划--------Begin------"); | 
|         plansExtService.autoClose(); | 
|         System.out.println("定点关闭不能关闭的计划--------end------"); | 
|     } | 
|   | 
| } |