1, 'employee_id'=> 1, 'type'=> 1, 'team_id'=> 1] * $type 1加微,2到店,3量房,4签单,5转单,6后台添加团队积分,7到场 */ public static function addIntegral($data, $root_id){ // 判断本企业是否有微爆活动 $where[] = ['start_date', '<', date('Y-m-d H:i:s')]; $where[] = ['end_date', '>', date('Y-m-d H:i:s')]; $where[] = ['root_id', '=', $root_id]; $list = WechatActivity::where($where)->select()->toArray(); if (!empty($list)) { // 同一时间段会不会有多个 活动? foreach ($list as $k => $v) { // 查询团队设置 $org_ids = WechatActivityTeam::where([['activity_id', '=', $v['id']], ['root_id', '=', $root_id]])->column('org_id'); if (!in_array($data['org_id'], $org_ids)) { continue; } // 加微先判断 if ($data['type'] == 1 && ($data['add_wechat_time'] < $v['start_date'] || $data['add_wechat_time'] > $v['end_date'])){ continue; } switch($data['type']) { case 1: $i_data['integral'] = $v['one_jv_integral']; break; case 2: $i_data['integral'] = $v['one_dd_integral']; break; case 3: $i_data['integral'] = $v['one_lf_integral']; break; case 4: $i_data['integral'] = $v['one_qd_integral']; break; case 5: $i_data['integral'] = $v['one_zd_integral']; break; case 7: $i_data['integral'] = $v['one_dc_integral']; break; default: break; } $f_where = []; $f_where[] = ['activity_id', '=', $v['id']]; $f_where[] = ['employee_id', '=', $data['employee_id']]; $f_where[] = ['customer_id', '=', $data['customer_id']]; $f_where[] = ['type', '=', $data['type']]; $f_where[] = ['root_id', '=', $root_id]; $i_data['activity_id'] = $v['id']; $i_data['employee_id'] = $data['employee_id']; $i_data['customer_id'] = $data['customer_id']; $i_data['type'] = $data['type']; $i_data['root_id'] = $root_id; $i_data['org_id'] = $data['org_id']; $find = self::where($f_where)->find(); if (empty($find)) { $result = self::create($i_data); } } } } } ?>