objDUserCoupon = new DUserCoupon(); $this->objDCoupon = new DCoupon(); $this->objDUserCoupon->setSearchIndex('user_coupon_search')->setType('user_coupon');; } /** * @param $params * @return bool * @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=' AND mustCondition<=' . $params['payAmount']; $coupon = self::selectCoupon($this->objDCoupon,['grantType'=>StatusCode::$grantType['onlinePay']],$extends); $checkCoupon = self::checkCoupon($this->objDUserCoupon,$coupon,$params); self::add($this->objDUserCoupon,$checkCoupon,$params); self::receiveNumIncr($this->objDCoupon,$checkCoupon,$params); } }