PAA전략 프로그램(2)

https://www.moayo.net/p-moayo-20609 (짧은주소)

PAA전략 12개의 ETF 크롤링 하는방법 설명

PAA전략에 필요한 데이터가 있습니다

12개의 ETF입니다

해당 ETF의 과거시세가 없다면 내용을 표현할수가 없습니다

그래서 해당 시세를 입력하는 프로그램 소스를 설명합니다

1)12개의 ETF 과거 시세를 기록

2)12개의 ETF 시세를 하루에 한번 업데이트

3)하루에 한번 업데이트 자동화처리

실제 작동되는 프로그램 주소 입니다

http://vm.ssbang.net/program.php?p_code=vmlist&p=read_paa

;

paa_all_insert.py (파이썬파일)

import time
from datetime import datetime,timedelta
import datetime
import requests
import yfinance as yf

s_now = "2022-08-16 23:59:59" #시작날짜
e_now = "2022-08-11" #종료날짜
now = datetime.datetime.strptime(s_now,"%Y-%m-%d %H:%M:%S")


for i in range(1,10000) :
    wdate_s=(now+timedelta(days=-i-1)).strftime('%Y-%m-%d') #-1일 을 하면서 하루씩 입력함
    
    etf1=yf.download("SPY QQQ IWM VGK EWJ EEM VNQ GLD DBC HYG LQD TLT",start=wdate_s,end=wdate_s)
    print(etf1)
    obj={"data_paa1":str(etf1['Close'])}
    res=requests.post("http://vm.ssbang.net/plugins/paa_all_insert.php",data=obj)

    #종료하기위한 부분
    if str(wdate_s)==e_now :
        break

paa_insert.py (파이썬파일)

import time
import requests
import yfinance as yf

wdate=time.strftime('%Y-%m-%d', time.localtime(time.time()))
datetime=time.strftime('%H:%I', time.localtime(time.time())) #00:00

#ETF 코드 배열로 넣기
ETF_CODE=("SPY","QQQ","IWM","VGK","EWJ","EEM","VNQ","GLD","DBC","HYG","LQD","TLT")


for etf_code in ETF_CODE:
	etf1=yf.download(etf_code,start=wdate,end=wdate)
	obj={"data_paa1":str(etf1['Close']),"etf_name":str(etf_code)}
	print(etf1["Close"])
	res=requests.post("http://vm.ssbang.net/plugins/paa_insert.php",data=obj) #저장할 내용 전송

paa_all_insert.php (PHP파일)

<?include"{$_SERVER[DOCUMENT_ROOT]}default/header.php"?>
<?
//여러개의 여백을하나로 변경하는함수
function ssb_space_replace($content,$bar="<>"){
  $content=preg_replace("!\s+!",$bar, $content);//여러여백을 하나로 변경
  return $content;
}

//한꺼번에 데이타 입력하기
$DATA_DAY=explode("\n",$data_paa1);//한줄씩 배열로 저장

//ETF 이름호출 1부터 시작함
$DATA_DAY_ARR=ssb_space_replace($DATA_DAY[0],"<>");
$ETF_NAME=explode("<>",$DATA_DAY_ARR);


for($i=2;$i<=count($DATA_DAY);$i++){
  $DATA_DAY_BAR=ssb_space_replace($DATA_DAY[$i],"<>");
  $ETF_VALUE=explode("<>",$DATA_DAY_BAR);//날짜와 ETF값을 호출함
  for($j=1;$j<count($ETF_VALUE);$j++){//날짜별 각각의 ETF저장
    if($ETF_VALUE[0]&&$ETF_NAME[$j]&&$ETF_VALUE[$j]){//날짜,종목,종가가 있는경우 실행
      //입력하기전에 해당 내용이 있는지 점검
      $csql="  select * from {$table[vmlist]} where 1";
      $csql.=" and p_title='$ETF_NAME[$j]'";
      $csql.=" and ext1='PAA'";
      $csql.=" and wdate='".date("Y-m-d 23:59:59",strtotime($ETF_VALUE[0]))."'";//날짜
      $cresult=mysql_query($csql,$dbcon);
      $crow=mysql_fetch_array($cresult);

      if($crow[idx_code]){//내용이 있는경우 수정
        $usql="  update {$table[vmlist]} set ";
        $usql.="  udate=now()";//날짜
        $usql.=" ,p_int1='$ETF_VALUE[$j]'";//종가(현재가)
        $usql.=" where 1 ";
        $usql.=" and p_title='$ETF_NAME[$j]'";
        $usql.=" and ext1='PAA'";
        $usql.=" and wdate='".date("Y-m-d 23:59:59",strtotime($ETF_VALUE[0]))."'";//날짜
        mysql_query($usql,$dbcon);
      }else{//없는경우 입력
        $isql="  insert {$table[vmlist]} set ";
        $isql.="  p_content='$ETF_NAME[$j]'";
        $isql.=" ,p_title='$ETF_NAME[$j]'";
        $isql.=" ,wdate='".date("Y-m-d 23:59:59",strtotime($ETF_VALUE[0]))."'";//날짜
        $isql.=" ,udate=now()";//날짜
        $isql.=" ,ext1='PAA'";//PAA ETF 12종목
        $isql.=" ,ext2='".$ETF_NAME[$j].$ETF_VALUE[0]."'";//날짜
        $isql.=" ,ext3='y'";//구분을 위해 입력하는값
        $isql.=" ,ext4='$data_paa1'";//넘어온내역 그대로 기록
        $isql.=" ,p_int1='$ETF_VALUE[$j]'";//종가(현재가)
        mysql_query($isql,$dbcon);
      }

    }
  }
}


?>

paa_insert.php (PHP파일)

<?include"{$_SERVER[DOCUMENT_ROOT]}default/header.php"?>
<?
//여러개의 여백을하나로 변경하는함수
function ssb_space_replace($content,$bar="<>"){
  $content=preg_replace("!\s+!",$bar, $content);//여러여백을 하나로 변경
  return $content;
}

//평균 200일 평균
function ssb_avg_cal($code,$datetime,$count=200){
  global $table,$dbcon;
  $tablename=$table[vmlist];

  $SEARCH.=" and wdate<='$datetime 23:59:00'";//기준일 이전 내역들을 가져오기 위함
  $SEARCH.=" and ext3='y'";//종가

  //평균을 구하는 부분
  $sql="  select p_int1 from $tablename where 1 ";
  $sql.=" and p_title='$code'";
  $sql.=" $SEARCH";
  $sql.=" order by wdate desc";
  $sql.=" limit 0,$count";
  $result=mysql_query($sql,$dbcon);
  $num=0;
  while($row=mysql_fetch_array($result)){
    $total_p_int1+=$row[p_int1];
    $num++;
  }
  $return=@($total_p_int1/$num);
  return $return;
}

//한꺼번에 데이타 입력하기
$DATA_DAY=explode("\n",$data_paa1);//한줄씩 배열로 저장

//ETF 이름호출 1부터 시작함
$DATA_DAY_ARR=space_replace($DATA_DAY[0],"<>");
$ETF_NAME=explode("<>",$DATA_DAY_ARR);


$DATA_DAY_BAR=ssb_space_replace($DATA_DAY[1],"<>");
$ETF_VALUE=explode("<>",$DATA_DAY_BAR);//날짜와 ETF값을 호출함


  
  
if($ETF_VALUE[0]&&$etf_name&&$ETF_VALUE[1]){//날짜,종목,종가가 있는경우 실행
  //입력하기전에 해당 내용이 있는지 점검
  $csql="  select * from {$table[vmlist]} where 1";
  $csql.=" and p_title='$etf_name'";
  $csql.=" and ext1='PAA'";
  $csql.=" and wdate='".date("Y-m-d 23:59:59",strtotime($ETF_VALUE[0]))."'";//날짜
  $cresult=mysql_query($csql,$dbcon);
  $crow=mysql_fetch_array($cresult);

  if($crow[idx_code]){//내용이 있는경우 수정
    $usql="  update {$table[vmlist]} set ";
    $usql.="  udate=now()";//날짜
    $usql.=" ,p_int1='$ETF_VALUE[1]'";//종가(현재가)
    $usql.=" where 1 ";
    $usql.=" and p_title='$etf_name'";
    $usql.=" and ext1='PAA'";
    $usql.=" and wdate='".date("Y-m-d 23:59:59",strtotime($ETF_VALUE[0]))."'";//날짜      
    mysql_query($usql,$dbcon);
  }else{//없는경우 입력
    $isql="  insert {$table[vmlist]} set ";
    $isql.="  p_content='$etf_name'";
    $isql.=" ,p_title='$etf_name'";
    $isql.=" ,wdate='".date("Y-m-d 23:59:59",strtotime($ETF_VALUE[0]))."'";//날짜
    $isql.=" ,udate=now()";//날짜
    $isql.=" ,ext1='PAA'";//PAA ETF 12종목
    $isql.=" ,ext2='".$etf_name.$ETF_VALUE[0]."'";//날짜
    $isql.=" ,ext3='y'";//구분을 위해 입력하는값
    $isql.=" ,ext4='$data_paa1'";//넘어온내역 그대로 기록
    $isql.=" ,p_int1='$ETF_VALUE[1]'";//종가(현재가)
    mysql_query($isql,$dbcon);
  }

  ///////////// 240일 평균값을 넣기위한 부분 시작 ///////////
  //입력한 내용 다시 호출하기
  $sql="  select * from {$table[vmlist]} where 1";
  $sql.=" and p_title='$etf_name'";
  $sql.=" and ext1='PAA'";
  $sql.=" and wdate='".date("Y-m-d 23:59:59",strtotime($ETF_VALUE[0]))."'";//날짜
  $result=mysql_query($sql,$dbcon);
  $row=mysql_fetch_array($result);
  //240일 평균값 입력하기
  $avg=ssb_avg_cal($row[p_title],date("Y-m-d",strtotime($row[wdate])),240);//종가 240일 평균값
  $usql="update $table[vmlist] set p_int6='$avg' where 1 and idx_code='$row[idx_code]'";
  mysql_query($usql,$dbcon);
  ///////////// 240일 평균값을 넣기위한 부분 종료 ///////////
}

?>

유사한정보