xiang_api/application/api/common.php

<?php
// 接口公共方法
use think\Db;
use think\cache\driver\Redis;
//function get_order_sn(){
//    $order_id_main = date('YmdHis') . rand(10000000,99999999);
//    $order_id_len = strlen($order_id_main);
//    $order_id_sum = 0;
//    for($i=0; $i<$order_id_len; $i++){
//        $order_id_sum += (int)(substr($order_id_main,$i,1));
//    }
//    $osn = $order_id_main . str_pad((100 - $order_id_sum % 100) % 100,2,'0',STR_PAD_LEFT);
//    return $osn;
//}



// 生成消息记录
function  send_user_message($user_id,$type_id,$content){
    $msg_data =[
        'user_id' => $user_id,
        'type_id' => $type_id,
        'content' => $content,
        'create_at' => date('Y-m-d H:i:s'),
    ];
    Db::table('user_message')->insert($msg_data);
    return Db::getLastInsID();
}

function  goods_sell_info($goods_info,$user_id,$from_id = 0)
{
    $sell_info =[
        'goods_id'=>$goods_info['id'],
        'goods_type'=>$goods_info['type'],
        'user_id'=>$user_id,
        'year'=> date('Y'),
        'month'=> date('m'),
        'day'=> date('d'),
        'from_id'=> $from_id,
        'goods_info'=>json_encode($goods_info)
    ];
    Db::table('goods_sell_info')->insert($sell_info);
}

/**
 * 获取商品hash值
 * @param $user_id 用户id
 * @param $name 商品id
 * @param $count   收藏数量
 * @return string
 */
function get_goods_hash($user_id,$name='',$count = 0){
    $host = "http://101.200.81.225:9090/contract/call";
    //$host = "http://jc.nfrcn.vip:9090/contract/call";
    $method = "POST";
    $headers = array();
    array_push($headers, "Content-Type".":"."application/json; charset=UTF-8");
    $bodys = [
        'key' => 'JDchinahgsc20220035',
        'userkey' =>$user_id,
        'product' => json_encode(['name'=>$name,'count'=>$count])
    ];
    $curl = curl_init();
    curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $method);
    curl_setopt($curl, CURLOPT_URL, $host);
    curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
    curl_setopt($curl, CURLOPT_FAILONERROR, false);
    curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($curl, CURLOPT_HEADER, false);
    if (1 == strpos("$".$host, "https://"))
    {
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
    }
    curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($bodys));
    $res = curl_exec($curl);
    if(!$res) return ['hash_str'=>''];
    $hash_res = json_decode($res,true);
    return [
        'hash_str'=> isset($hash_res['code']) &&  $hash_res['code'] == 200 ? $hash_res['data']['contentHash']:'',// 哈希
    ];
}


/**
 * 获取系统配置
 * @param $array
 * @return array
 * @throws \think\db\exception\DataNotFoundException
 * @throws \think\db\exception\ModelNotFoundException
 * @throws \think\exception\DbException
 */
function getConfig($array){
    $set = Db::table('system_config')->where('name','in',$array)->select();
    $ret = [];
    foreach ($set as $value) {
        $ret[$value['name']]=$value['value'];
    }
    return $ret;
}




/**
 * @title 取消订单定时任务
 * @desc  十五分钟内未支付的自动取消
 */
function cancel_goods_order($user_id = 0)
{
    $set_time = intval(sysconf('cancel_time')) ? : 5;// 没设置默认5分钟未支付的自动取消
    $sel_time = time() - $set_time * 60 ;
    $where = [];
    $where[] = ['create_at','< time',date('Y-m-d H:i:s',$sel_time)];
    $where[] = ['status','=',0];
    $where[] = ['cancel_state','=',0];
    if($user_id)  $where[] = ['uid','=',$user_id];
    $order_data = Db::table('goods_order')
        ->where($where)
        ->select();
    foreach ($order_data as $order_info) {
        Db::startTrans();
        try {
            Db::table('goods_order')->where(['id'=>$order_info['id']])
                ->update(['status'=>9,'cancel_state'=>1,'cancel_at'=>date('Y-m-d H:i:s'),'cancel_desc'=>'支付超时！自动取消']);
            Db::table('store_goods')->where('id', $order_info['goods_id'])
                ->setInc('stock', $order_info['goods_num']);
            Db::commit();
        }catch (\Exception $e){
            Db::rollback();
        }
    }
}

// 商品抽签
function goods_draw($goods_id){
    $redis = new Redis();
    $goods_info = Db::name('store_collect')->find($goods_id);
    $stock = $redis->get('collection_count_'.$goods_id);
    if(!$stock) return ['code'=>201,'msg'=>'商品库存不足'];
    $apply_list = Db::name('store_collection_draw')->where(['coll_id'=>$goods_id,'is_ballot'=>0])->column('id,user_id,code');
    shuffle($apply_list);// 打乱申请记录顺序
    $ballot = array_slice($apply_list,0,$stock);//截取数据
    $ballot_ids = array_column($ballot,'id');
    $ballot_user = array_column($ballot,'user_id');
    Db::name('store_collection_draw')->where(['coll_id'=>$goods_id,'is_ballot'=>0])->whereIn('id',implode($ballot_ids))->update(['is_ballot'=>1]);
    Db::name('store_collection_draw')->where(['coll_id'=>$goods_id,'is_ballot'=>0])->whereNotIn('id',implode($ballot_ids))->update(['is_ballot'=>2]);
    Db::name('store_collect')->where('id',$goods_id)->update(['is_task'=>1]);
    $redis->hMSet('lucky_draw',['goods_id_'.$goods_id=>json_encode($ballot_user)]);
    return ['code'=>200,'msg'=>'ok'];
}