dao = $dao; } public function create($data) { return $this->dao->create($data); } /** * 写入 复购金 记录 * @param UserSignFugouEntity $userSignFugouEntity * @return UserSignFugouEntity */ public function createByEntity(UserSignFugouEntity $userSignFugouEntity): UserSignFugouEntity { $result = $this->dao->create($userSignFugouEntity->toUnderlineArray())->toArray(); /** @var UserSignFugouEntity $entity */ $entity = UserSignFugouEntity::newInstance($result); return $entity; } /** * 添加 复购金记录 * @param int $uid * @param int $type * @param float $number * @param string $mark * @param string $orderType * @param string $orderId * @return UserSignFugouEntity */ public function addUserSingFugou(int $uid, int $type, float $number, string $mark = '', string $orderType = '', string $orderId = ''): UserSignFugouEntity { if (!empty($orderType)) { if (!empty($orderId)) { if ($orderType == UserSignFugouEnum::ORDER_TYPE['Platform']['code']) { /** @var StoreOrderRepository $storeOrderRepository */ $storeOrderRepository = app()->make(StoreOrderRepository::class); $storeOrderEntity = $storeOrderRepository->getStoreOrderEntityByOrderId((int)$orderId); if (empty($storeOrderEntity->getOrderId())) { throw new ValidateException('未查询到订单信息'); } } } } /** @var UserSignFugouEntity $userSignFugouEntity */ $userSignFugouEntity = UserSignFugouEntity::newInstance(); $userSignFugouEntity->setUid($uid) ->setType($type) ->setNumber($number) ->setMark($mark) ->setOrderType($orderType) ->setOrderId($orderId) ->setAddtime(time()) ->setStatus(UserSignFugouEnum::STATUS['Pending']['code']); return $this->createByEntity($userSignFugouEntity); } }