영카트4에서 영카트5로 업그레이드시 포인트 소멸처리

// 소멸포인트 삭제function delete_expire_point($mb_id, $point){    global $g5, $config;    $point1 = abs($point);    $sql = " select po_id, po_use_point, po_expired, po_expire_date                from {$g5['point_table']}                where mb_id = '$mb_id'                  and po_expired = '1'                  and po_point >= 0                  and po_use_point > 0                order by po_expire_date desc, po_id desc ";    $result = sql_query($sql);    for($i=0; $row=sql_fetch_array($result); $i++) {        $point2 = $row['po_use_point'];        $po_expired = '0';        $po_expire_date = '9999-12-31';        if($config['cf_point_term'] > 0)            $po_expire_date = date('Y-m-d', strtotime('+'.($config['cf_point_term'] - 1).' days', G5_SERVER_TIME));        if($point2 > $point1) {            $sql = " update {$g5['point_table']}                        set po_use_point = po_use_point - '$point1',                            po_expired = '$po_expired',                            po_expire_date = '$po_expire_date'                        where po_id = '{$row['po_id']}' ";            sql_query($sql);            break;        } else {            $sql = " update {$g5['point_table']}                        set po_use_point = '0',                            po_expired = '$po_expired',                            po_expire_date = '$po_expire_date'                        where po_id = '{$row['po_id']}' ";            sql_query($sql);            $point1 -= $point2;        }    }}// 포인트 내역 합계function get_point_sum($mb_id){    global $g5, $config;    if($config['cf_point_term'] > 0) {        // 소멸포인트가 있으면 내역 추가        $expire_point = get_expire_point($mb_id);        if($expire_point > 0) {            $mb = get_member($mb_id, 'mb_point');            $content = '포인트 소멸';            $rel_table = '@expire';            $rel_id = $mb_id;            $rel_action = 'expire'.'-'.uniqid('');            $point = $expire_point * (-1);            $po_mb_point = $mb['mb_point'] + $point;            $po_expire_date = G5_TIME_YMD;            $po_expired = 1;            $sql = " insert into {$g5['point_table']}                        set mb_id = '$mb_id',                            po_datetime = '".G5_TIME_YMDHIS."',                            po_content = '".addslashes($content)."',                            po_point = '$point',                            po_use_point = '0',                            po_mb_point = '$po_mb_point',                            po_expired = '$po_expired',                            po_expire_date = '$po_expire_date',                            po_rel_table = '$rel_table',                            po_rel_id = '$rel_id',                            po_rel_action = '$rel_action' ";            sql_query($sql);            // 포인트를 사용한 경우 포인트 내역에 사용금액 기록            if($point < 0) {                insert_use_point($mb_id, $point);            }        }        // 유효기간이 있을 때 기간이 지난 포인트 expired 체크        $sql = " update {$g5['point_table']}                    set po_expired = '1'                    where mb_id = '$mb_id'                      and po_expired <> '1'                      and po_expire_date <> '9999-12-31'                      and po_expire_date < '".G5_TIME_YMD."' ";        sql_query($sql);    }    // 포인트합    $sql = " select sum(po_point) as sum_po_point                from {$g5['point_table']}                where mb_id = '$mb_id' ";    $row = sql_fetch($sql);    return $row['sum_po_point'];}// 소멸 포인트function get_expire_point($mb_id){    global $g5, $config;    if($config['cf_point_term'] == 0)        return 0;    $sql = " select sum(po_point - po_use_point) as sum_point                from {$g5['point_table']}                where mb_id = '$mb_id'                  and po_expired = '0'                  and po_expire_date <> '9999-12-31'                  and po_expire_date < '".G5_TIME_YMD."' ";    $row = sql_fetch($sql);    return $row['sum_point'];}// 포인트 삭제function delete_point($mb_id, $rel_table, $rel_id, $rel_action){    global $g5;    $result = false;    if ($rel_table || $rel_id || $rel_action)    {        // 포인트 내역정보        $sql = " select * from {$g5['point_table']}                    where mb_id = '$mb_id'                      and po_rel_table = '$rel_table'                      and po_rel_id = '$rel_id'                      and po_rel_action = '$rel_action' ";        $row = sql_fetch($sql);        if($row['po_point'] < 0) {            $mb_id = $row['mb_id'];            $po_point = abs($row['po_point']);            delete_use_point($mb_id, $po_point);        } else {            if($row['po_use_point'] > 0) {                insert_use_point($row['mb_id'], $row['po_use_point'], $row['po_id']);            }        }        $result = sql_query(" delete from {$g5['point_table']}                     where mb_id = '$mb_id'                       and po_rel_table = '$rel_table'                       and po_rel_id = '$rel_id'                       and po_rel_action = '$rel_action' ", false);        // po_mb_point에 반영        $sql = " update {$g5['point_table']}                    set po_mb_point = po_mb_point - '{$row['po_point']}'                    where mb_id = '$mb_id'                      and po_id > '{$row['po_id']}' ";        sql_query($sql);        // 포인트 내역의 합을 구하고        $sum_point = get_point_sum($mb_id);        // 포인트 UPDATE        $sql = " update {$g5['member_table']} set mb_point = '$sum_point' where mb_id = '$mb_id' ";        $result = sql_query($sql);    }    return $result;}​