Magento2自己动手写scheduled import export 定时任务

追影

（1/）etc/crontab.xml
注：时间的五个※ 分别是 分　 时　 日　 月　 周　

1. <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:module:Magento_Cron:etc/crontab.xsd">
   
2.     <group id="index">
   
3.         <job name="silks_scheduled_importexport" instance="Silk\Catalog\Model\ScheduledImportExport" method="execute">
   
4.             <schedule>*/5 * * * *</schedule>
   
5.         </job>
   
6.     </group>
   
7. </config>
   

复制代码

（2/app/code/Silk/Catalog/Model/ScheduledImportExport.php

1. <?php
   
2. /**
   
3. * Created by PhpStorm.
   
4. * User: toby
   
5. * Date: 18-7-11
   
6. * Time: 上午11:50
   
7. */
   
8. namespace Silk\Catalog\Model;
   
9. 
   
10. use Magento\Framework\DataObject;
    
11. 
    
12. class ScheduledImportExport {
    
13. 
    
14.     protected $_objectManager;
    
15.     protected $_dateTime;
    
16.     protected $_import_export_collection;
    
17.     protected $_localtime;
    
18. 
    
19.     public function __construct(
    
20.         \Magento\Framework\Stdlib\DateTime $dateTime,
    
21.         \Magento\ScheduledImportExport\Model\ResourceModel\Scheduled\Operation\Collection $collection,
    
22.         \Magento\Framework\Stdlib\DateTime\TimezoneInterface $timezone,
    
23.         \Magento\Store\Model\StoreManagerInterface $storeManager,
    
24.         array $data = []
    
25.     )
    
26.     {
    
27.         $this->_objectManager = \Magento\Framework\App\ObjectManager::getInstance();
    
28.         $this->_import_export_collection = $collection;
    
29.         $this->_dateTime = $dateTime;
    
30.         $this->_localtime = $timezone;
    
31. 
    
32.     }
    
33. 
    
34.     public function execute(){
    
35.         try{
    
36.             $list = $this->_import_export_collection->getItems();
    
37.             foreach($list as $item){
    
38.                 $operationId = (int)$item->getId();
    
39.                 $freq = $item->getFreq();
    
40.                 $cur_time = $this->_localtime->date()->format('Y-m-d').' '.$item->getStartTime();
    
41.                 $now_time = $this->_localtime->date()->format('Y-m-d H:i:s');
    
42.                 $compare_result = $this->compare_time($now_time,$cur_time);
    
43.                 $last_time = (string)$item->getLastRunDate();
    
44.                 $last_unix = (int)strtotime($last_time);
    
45.                 //$this->log($now_time.' '.$cur_time . $compare_result);
    
46.                 switch($freq){
    
47.                     case 'D':
    
48.                         if(( !$last_unix && $compare_result) || ($last_unix && time() - $last_unix >= 24*3600)){
    
49.                            // $this->log('执行D:'. $operationId." $now_time $cur_time");
    
50.                             $this->scheduled_operation($operationId);
    
51.                         }
    
52.                         break;
    
53.                     case 'M':
    
54.                         if((!$last_unix && $compare_result) || ($last_unix && time() - $last_unix >= 7*24*3600)){
    
55.                            // $this->log('执行M:'. $operationId." $now_time $cur_time");
    
56.                             $this->scheduled_operation($operationId);
    
57.                         }
    
58.                         break;
    
59.                     case 'Y':
    
60.                         if((!$last_unix && $compare_result) || ($last_unix && time() - $last_unix >= 365*24*3600)){
    
61.                            // $this->log('执行Y:'. $operationId." $now_time $cur_time");
    
62.                             $this->scheduled_operation($operationId);
    
63.                         }
    
64.                         break;
    
65.                 }
    
66. 
    
67.             }
    
68.             return true;
    
69.         }catch(\Exception $e){
    
70.             return false;
    
71.         }
    
72. 
    
73.     }
    
74. 
    
75.     private function scheduled_operation($operationId){
    
76.         $schedule = new DataObject();
    
77.         $schedule->setJobCode(
    
78.             \Magento\ScheduledImportExport\Model\Scheduled\Operation::CRON_JOB_NAME_PREFIX . $operationId
    
79.         );
    
80.         /** @var \Magento\ScheduledImportExport\Model\Observer $result */
    
81.         $result = $this->_objectManager->get(\Magento\ScheduledImportExport\Model\Observer::class)
    
82.             ->processScheduledOperation($schedule, true);
    
83.         return $result;
    
84.     }
    
85. 
    
86.     function compare_time($a,$b){
    
87.         if(date('H',strtotime($a)) == date('H',strtotime($b)) && date('i',strtotime($a)) >= date('i',strtotime($b))){
    
88.             return true;
    
89.         }
    
90.         return false;
    
91.     }
    
92. 
    
93.     protected function log($msg) {
    
94.         if (is_array($msg) || is_object($msg)) {
    
95.             $msg = print_r($msg, true);
    
96.         }
    
97.         $_objectManager = \Magento\Framework\App\ObjectManager::getInstance();
    
98.         $msg = '['.date('Y-m-d H:i:s').']: '.$msg."\n";
    
99.         $directory = $_objectManager->get('\Magento\Framework\Filesystem\DirectoryList');
    
100.         file_put_contents($directory->getPath('log').'/silk_import.log', $msg, FILE_APPEND);
     
101.     }
     
102. 
     
103. }

复制代码