<?php

require_once "/home/users/daiyuanpei/db.php";
//$centerdb = conn('CENTERDB_SCRIPT');
//$miscdb = conn('MISCDB_SCRIPT');
//$coredb = conn('COREDB_SCRIPT');
$fndb = conn('FNDB_SCRIPT');
$file = file("dajinrong.csv");
$data = array();
foreach($file as &$line){
    $line = trim($line);
    $lineArr = explode("\t", $line);
    if(empty($lineArr[5])){
        $fndbSql = "select F_sp_id from bfb_db_finance.t_scenario_sp_map where F_sp_user_id=$lineArr[0]";
        $fnData = queryInfo($fndbSql, $fndb);
        $lineArr[5] = $fnData[0]['F_sp_id'];
    }
    $fndbSql = "select sp_type from bfb_db_finance.t_sp_tag where sp_id=$lineArr[5]";
    $fnData = queryInfo($fndbSql, $fndb);
    $lineArr[6] = empty($fnData[0]['sp_type']) ? 7 : $fnData[0]['sp_type'];
    $data[] = $lineArr;
}
$dataMap = array();
foreach($data as $value){
    $key = $value[2].'_'.$value[1].'_'.$value[6];
    if(isset($dataMap[$key])){
        $dataMap[$key][3] += $value[3];
        $dataMap[$key][4] += $value[4];
    }else{
        $dataMap[$key] = $value;
    }
}
$fileName='data.csv';
foreach ($dataMap as $k=>$v){
    $str = $k."\t".$v[0]."\t".$v[2]."\t".$v[1]."\t".$v[6]."\t".$v[3]."\t".$v[4];
    file_put_contents($fileName, $str."\n", FILE_APPEND);
}

?>