objDUserCoupon = new DUserCoupon(); $this->objDCoupon = new DCoupon(); $this->objDUserCoupon->setSearchIndex('user_coupon_search')->setType('user_coupon');; } /** * @param $params * @throws \Exception */ public function push($params) { $this->onlineEnterpriseId = $params['enterpriseId']; // 计算分表 $this->objDUserCoupon->setTable($this->objDUserCoupon->get_Table() . '_' . $params['enterpriseId']); $this->objDCoupon->setTable($this->objDCoupon->get_Table() . '_' . $params['enterpriseId']); $extends = ''; if (!empty($params['customerId'])) { $extends = ' AND FIND_IN_SET(' . $params['customerId'] . ',customerIds)'; } $coupon = self::selectCoupon($this->objDCoupon, ['grantType' => StatusCode::$grantType['grant']], $extends); $checkCoupon = self::checkCoupon($this->objDUserCoupon, $coupon, $params); self::add($this->objDUserCoupon, $checkCoupon, $params); self::receiveNumIncr($this->objDCoupon, $checkCoupon, $params); } }