addCard(['card_no' => $car_no,'card_key' => $card_key,'card_type' => $card_type,'amount' => $amount]); } public function testReadCSVFile() { $items = [ ['file' => 'phone-100.csv','card_type' => mtopcard\PhoneCardPaper, 'value' => 100], ['file' => 'oil-100.csv','card_type' => mtopcard\OilCardPaper, 'value' => 100], ['file' => 'oil-200.csv','card_type' => mtopcard\OilCardPaper, 'value' => 200], ['file' => 'oil-500.csv','card_type' => mtopcard\OilCardPaper, 'value' => 500], ['file' => 'oil-1000.csv','card_type' => mtopcard\OilCardPaper, 'value' => 1000], ]; $mod_card = Model('card_key'); foreach ($items as $item) { $file = BASE_DATA_PATH . '/cards/' . $item['file']; $amount = $item['value']; $card_type = $item['card_type']; $fn = fopen($file,"r"); if(empty($fn)) { Log::record("Open File {$item['file']} error.",Log::ERR); break; } else { Log::record("{$item['file']} start woring",Log::DEBUG); } while(! feof($fn)) { $line = trim(fgets($fn)); $results = explode(',',$line); if(empty($results)) { continue; } elseif(count($results) == 2) { $card_no = trim($results[0]); $card_key = trim($results[1]); } elseif(count($results) == 3) { $card_no = trim($results[1]); $card_key = trim($results[2]); } else { Log::record("分析数据失败:{$line}",Log::ERR); continue; } $this->addCard($mod_card,$card_no,$card_key,$card_type,$amount); } fclose($fn); } Log::record("All cards has been add to database.",Log::DEBUG); } private function addFile($file) { $filename = BASE_DATA_PATH . "/cards/{$file}"; if(!file_exists($filename)) { Log::record("{$file} not exists.",Log::ERR); return false; } $mod_card = Model('card_key'); $fileType = PHPExcel_IOFactory::identify($filename); $objReader = PHPExcel_IOFactory::createReader($fileType); $objPHPExcel = $objReader->load($filename); Log::record("{$file} begin....",Log::DEBUG); foreach ($objPHPExcel->getWorkSheetIterator() as $sheet) { $title = strtolower($sheet->getTitle()); Log::record("{$file} - {$title} start....",Log::DEBUG); [$type,$amount,$id] = explode('-',$title); Log::record("type = {$type} amount = {$amount}",Log::DEBUG); if($type == 'p') { $card_type = mtopcard\PhoneCardPaper; } elseif($type == 'o') { $card_type = mtopcard\OilCardPaper; } else { Log::record("{$filename} sheet {$title} name type error.",Log::ERR); return false; } if($amount <= 0) { Log::record("{$filename} sheet {$title} name amount error.",Log::ERR); return false; } foreach ($sheet->getRowIterator() as $row) { $index = $row->getRowIndex(); if ($index < 2) continue; $datas = []; foreach ($row->getCellIterator() as $cell) { $data = $cell->getValue(); $datas[] = $data; } if(empty($datas[1]) || empty($datas[2])) { continue; } $card_no = trim($datas[1]); $card_key = trim($datas[2]); if($this->check_cardno($card_no) && $this->check_cardkey($card_key)) { $this->addCard($mod_card,$card_no,$card_key,$card_type,$amount); } else { Log::record("{$card_no} {$card_key}",Log::ERR); } } } Log::record("{$file} end....",Log::DEBUG); return true; } private function check_cardno($card_no) { $count = self::CardNoLength; return preg_match("/^\d{{$count}}$/i",$card_no) > 0; } private function check_cardkey($card_no) { $count = self::CardKeyLength; return preg_match("/^[a-z0-9]{{$count}}$/",$card_no) > 0; } public function testAddCradFromExecl() { $files = ['lm-1.xlsx','by-1.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function testCancelOrder() { //2020-08-20 处理了一些订单。 $card_nos = ['1900000000668434', '1900000000668403', '1900000000668402', '1900000000668400', '1900000000668398', '1900000000668399', '1900000000668397', '1900000000668396', '1900000000668395', '1900000000668394', '1900000000668392', '1900000000668390', '1900000000668393', '1900000000668387', '1900000000668384', '1900000000668327', '1900000000040001', '1900000000569005', '1900000000264501', '1900000000569004']; $this->cancel_order($card_nos); } private function cancel_order($card_nos) { $mod_card = Model('card_key'); foreach ($card_nos as $card_no) { $items = $mod_card->field('*')->where(['card_no' => $card_no])->select(); $length = count($items); if($length > 1) { Log::record("有{$length}张卡号为{$card_no}的卡",Log::ERR); } elseif(empty($items)) { Log::record("未找到{$card_no}的卡号",Log::ERR); } else { $order_id = intval($items[0]['order_id']); $order_info = Model('vr_order')->getOrderInfo(['order_id' => $order_id]); $vr_logic = Logic('vr_order'); $result = $vr_logic->changeOrderStateCancel($order_info,'','管理员申请退款.'); Log::record("{$card_no} : {$result['state']}",Log::DEBUG); } } } public function test20200821_addCard() { $files = ['fen-p-200.xlsx','fen-p-500.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200902_addCard() { $files = ['fen-p-100-1.xlsx','fen-p-100-2.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200902_1_addCard() { $files = ['100-494-643.xlsx','200-779144-193.xlsx','200-779294-343.xlsx','500-794-843.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200903_addCard() { $files = ['100-895-943.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200904_addCard() { $files = ['100-644-743.xlsx','100-844-893.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200904_1_addCard() { $files = ['200-344-353.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200904_2_addCard() { $files = ['200-344-393.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200904_3_addCard() { $files = ['200-344-393.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200904_4_addCard() { $files = ['100-344-443.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200905_addCard() { $files = ['200-8344-8443.xlsx' , '100-144-243.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200905_1_addCard() { $files = ['100-294-343.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200905_2_addCard() { $files = ['200-244-343.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200905_3_addCard() { $files = ['100-669944-669993-670044-670093.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200906_addCard() { $files = ['200-807944-808043.xlsx']; foreach ($files as $file) { $this->addFile($file); } } public function test20200906_1_addCard() { $files = ['100-1900000000669994-1900000000670043.xlsx' , '100-670844-893.xlsx' , '200-1900000000808194-1900000000808243.xlsx' , 'p100-670-644-693.xlsx' , 'p100-670894-943.xlsx']; foreach ($files as $file) { $this->addFile($file); } } } //docker-compose -f ./docker-compose-dev.yml run phpcli php /var/www/html/phpunit-9.2.5.phar --filter "/(TestAddData::testCancelOrder)( .*)?$/" --test-suffix TestAddData.php /var/www/html/test //docker-compose -f ./docker-compose-dev.yml run phpcli php /var/www/html/phpunit-9.2.5.phar --filter "/(TestAddData::test20200821_addCard)( .*)?$/" --test-suffix TestAddData.php /var/www/html/test //docker-compose run phpcli php /var/www/html/phpunit-9.2.5.phar --filter "/(TestAddData::test20200906_1_addCard)( .*)?$/" --test-suffix TestAddData.php /var/www/html/test