12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182 |
- <?php
- declare (strict_types = 1);
- namespace app\command;
- use app\admin\model\CgdCaixiao;use app\admin\model\Platform;use app\admin\model\SaleCaixiao;use think\console\Command;use think\console\Input;use think\console\Output;use think\facade\Cache;use think\facade\Db;
- class caixiao extends Command
- {
- protected $table = null;
- protected $contect = null;
- protected $hour = null;
- protected function cgd(){
- $cgd=new CgdCaixiao();
- $where=[['updatetime','>=',$this->hour]];
- $list = $cgd->where($where)->cursor();
- $cgdArr=[];
- foreach ($list as $item){
- $unique = md5($item->cgdNo.$item->updatetime);
- $temp=['order_type'=>2,'uniqkey'=>$unique,'status'=>1,'addtime'=>date('Y-m:d H:i:s')];
- if($this->isInCfp($unique)){
- $item['cat_name'] = json_decode($item->cat_name);
- $temp['data']= json_encode($item,JSON_UNESCAPED_UNICODE);
- $cgdArr[]=$temp;
- }
- }
- if(empty($cgdArr)==false) $this->table->insertAll($cgdArr);
- }
- protected function configure()
- {
- // 指令配置
- $this->setName('caixiao')
- ->setDescription('the caixiao command');
- }
-
- protected function execute(Input $input, Output $output)
- {
- // 指令输出
- $key="caixiao_copy";
- $rs = Cache::store('redis')->inc($key);
- if ($rs!=1){
- Cache::store('redis')->dec($key);
- return true;
- }
- $this->hour=date('Y-m-d H:i:s',strtotime('-1 hours'));
- $this->contect= Db::connect('mysql_cxinv');
- $this->table =$this->contect->name("caixiao_data");
- $this->sale();
- $this->cgd();
- Cache::store('redis')->dec($key);
- $output->writeln('caixiao');
- }
-
- protected function getPay($plat_id=0){
- $plat =new Platform();
- return $plat->where("id",$plat_id)->value("platform_name","");
- }
-
- protected function sale(){
- $sale=new SaleCaixiao();
- $where=[["updatetime",">=",$this->hour]];
- $list = $sale->where($where)->cursor();
- $qrd=[];
- foreach ($list as $item){
- $unique = md5($item->orderCode.$item->updatetime);
- $temp=["order_type"=>1,"uniqkey"=>$unique,"status"=>1,"addtime"=>date('Y-m:d H:i:s')];
- if($this->isInCfp($unique)){
- $item['cat_name'] = json_decode($item->cat_name);
- $temp["data"]= json_encode($item,JSON_UNESCAPED_UNICODE);
- $qrd[]=$temp;
- }
- }
- if(empty($qrd)==false) $this->table->insertAll($qrd);
- }
-
- protected function isInCfp($unique){
- $ist = $this->contect->name("caixiao_data")->where("uniqkey",$unique)->findOrEmpty();
- return empty($ist);
- }
- }
|