积分赠送脚本优化

feat/task1-c-wallet
gongfuxiang 2022-03-27 23:32:17 +08:00
parent 2178463458
commit a22de0f4f5
2 changed files with 22 additions and 13 deletions

View File

@ -70,7 +70,11 @@ class Crontab extends Common
public function GoodsGiveIntegral() public function GoodsGiveIntegral()
{ {
$ret = CrontabService::GoodsGiveIntegral(); $ret = CrontabService::GoodsGiveIntegral();
if($ret['code'] == 0)
{
return 'sucs:'.$ret['data']['sucs'].', fail:'.$ret['data']['fail']; return 'sucs:'.$ret['data']['sucs'].', fail:'.$ret['data']['fail'];
} }
return $ret['msg'];
}
} }
?> ?>

View File

@ -211,6 +211,10 @@ class CrontabService
// 开启事务 // 开启事务
Db::startTrans(); Db::startTrans();
if(Db::name('GoodsGiveIntegralLog')->where(['id'=>$v['id'], 'status'=>0])->update($upd_data)) if(Db::name('GoodsGiveIntegralLog')->where(['id'=>$v['id'], 'status'=>0])->update($upd_data))
{
// 用户是否存在
$count = (int) Db::name('User')->where(['id'=>$v['user_id']])->count();
if($count > 0)
{ {
// 扣减用户锁定积分 // 扣减用户锁定积分
if(!Db::name('User')->where(['id'=>$v['user_id']])->dec('locking_integral', $v['integral'])->update()) if(!Db::name('User')->where(['id'=>$v['user_id']])->dec('locking_integral', $v['integral'])->update())
@ -227,6 +231,7 @@ class CrontabService
// 积分日志 // 积分日志
IntegralService::UserIntegralLogAdd($v['user_id'], $user_integral, $v['integral'], '订单商品赠送', 1); IntegralService::UserIntegralLogAdd($v['user_id'], $user_integral, $v['integral'], '订单商品赠送', 1);
}
// 提交事务 // 提交事务
Db::commit(); Db::commit();