thisgun
913d1c66c7
기존에는 쿠폰별로 잠금을 잡아, 같은 회원이 서로 다른 포인트 쿠폰을 동시에 요청하면 각 요청이 요청 시작 시점의 보유 포인트 값으로 검사를 통과하여 잔액보다 많은 쿠폰을 받을 수 있었다. - 잠금 범위를 쿠폰별에서 회원별로 변경 - 보유 포인트를 잠금 획득 후 회원 테이블에서 다시 조회하여 검사 Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com> (cherry picked from commit fd04b432cf34dfba52e281fc74391f8e2d48fe6b)
88 lines
3.3 KiB
PHP
88 lines
3.3 KiB
PHP
<?php
|
|
include_once('./_common.php');
|
|
|
|
if(!$member['mb_id'])
|
|
die(json_encode(array('error' => '회원 로그인 후 이용해 주십시오.')));
|
|
|
|
$cz_id = isset($_GET['cz_id']) ? preg_replace('#[^0-9]#', '', $_GET['cz_id']) : 0;
|
|
|
|
if(!$cz_id)
|
|
die(json_encode(array('error' => '올바른 방법으로 이용해 주십시오.')));
|
|
|
|
$sql = " select * from {$g5['g5_shop_coupon_zone_table']} where cz_id = '$cz_id' ";
|
|
$cp = sql_fetch($sql);
|
|
|
|
if(!$cp['cz_id'])
|
|
die(json_encode(array('error' => '쿠폰정보가 존재하지 않습니다.')));
|
|
|
|
if(!($cp['cz_start'] <= G5_TIME_YMD && $cp['cz_end'] >= G5_TIME_YMD))
|
|
die(json_encode(array('error' => '다운로드할 수 없는 쿠폰입니다.')));
|
|
|
|
// 동시 요청으로 인한 쿠폰 중복 발급 방지
|
|
// 포인트는 회원 단위 자원이므로 쿠폰이 달라도 같은 회원의 요청은 직렬화한다.
|
|
$lock_key = 'g5_coupon_dl_'.addslashes($member['mb_id']);
|
|
$lock_row = sql_fetch(" select get_lock('$lock_key', 5) as lk ");
|
|
if(empty($lock_row['lk']))
|
|
die(json_encode(array('error' => '잠시 후 다시 시도해 주십시오.')));
|
|
|
|
// 발급여부 (락 획득 후 재확인)
|
|
if(is_coupon_downloaded($member['mb_id'], $cp['cz_id'])) {
|
|
sql_query(" do release_lock('$lock_key') ");
|
|
die(json_encode(array('error' => '이미 다운로드하신 쿠폰입니다.')));
|
|
}
|
|
|
|
// 포인트 쿠폰은 회원포인트 체크 (락 획득 후 최신 잔액으로 재확인)
|
|
if($cp['cz_type']) {
|
|
$row_pt = sql_fetch(" select mb_point from {$g5['member_table']} where mb_id = '{$member['mb_id']}' ");
|
|
|
|
if(($row_pt['mb_point'] - $cp['cz_point']) < 0) {
|
|
sql_query(" do release_lock('$lock_key') ");
|
|
die(json_encode(array('error' => '보유하신 포인트가 부족하여 쿠폰을 다운로드할 수 없습니다.')));
|
|
}
|
|
}
|
|
|
|
// 쿠폰발급
|
|
$j = 0;
|
|
do {
|
|
$cp_id = get_coupon_id();
|
|
|
|
$sql3 = " select count(*) as cnt from {$g5['g5_shop_coupon_table']} where cp_id = '$cp_id' ";
|
|
$row3 = sql_fetch($sql3);
|
|
|
|
if(!$row3['cnt'])
|
|
break;
|
|
else {
|
|
if($j > 20) {
|
|
sql_query(" do release_lock('$lock_key') ");
|
|
die(json_encode(array('error' => 'Coupon ID Error')));
|
|
}
|
|
}
|
|
$j++;
|
|
} while(1);
|
|
|
|
$cp = array_map('addslashes', $cp);
|
|
$cp_start = G5_TIME_YMD;
|
|
$period = $cp['cz_period'] - 1;
|
|
if($period < 0)
|
|
$period = 0;
|
|
$cp_end = date('Y-m-d', strtotime("+{$period} days", G5_SERVER_TIME));
|
|
$result = false;
|
|
|
|
$sql = " INSERT INTO {$g5['g5_shop_coupon_table']}
|
|
( cp_id, cp_subject, cp_method, cp_target, mb_id, cz_id, cp_start, cp_end, cp_type, cp_price, cp_trunc, cp_minimum, cp_maximum, cp_datetime )
|
|
VALUES
|
|
( '$cp_id', '{$cp['cz_subject']}', '{$cp['cp_method']}', '{$cp['cp_target']}', '{$member['mb_id']}', '$cz_id', '$cp_start', '$cp_end', '{$cp['cp_type']}', '{$cp['cp_price']}', '{$cp['cp_trunc']}', '{$cp['cp_minimum']}', '{$cp['cp_maximum']}', '".G5_TIME_YMDHIS."' ) ";
|
|
|
|
$result = sql_query($sql);
|
|
|
|
// 포인트 쿠폰이면 포인트 차감
|
|
if($result && $cp['cz_type'])
|
|
insert_point($member['mb_id'], (-1) * $cp['cz_point'], "쿠폰 $cp_id 발급");
|
|
|
|
// 다운로드 증가
|
|
sql_query(" update {$g5['g5_shop_coupon_zone_table']} set cz_download = cz_download + 1 where cz_id = '$cz_id' ");
|
|
|
|
sql_query(" do release_lock('$lock_key') ");
|
|
|
|
die(json_encode(array('error' => '')));
|