UserSignJingdouRepository.php 2.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. <?php
  2. namespace app\common\repositories\user;
  3. use app\common\dao\user\UserSignJingdouDao;
  4. use app\common\enum\user\UserSignJingdouEnum;
  5. use app\common\repositories\BaseRepository;
  6. use app\common\repositories\store\order\StoreOrderRepository;
  7. use app\entity\data\user\UserSignJingdouEntity;
  8. use think\exception\ValidateException;
  9. class UserSignJingdouRepository extends BaseRepository
  10. {
  11. public function __construct(UserSignJingdouDao $dao)
  12. {
  13. $this->dao = $dao;
  14. }
  15. public function create($data)
  16. {
  17. return $this->dao->create($data);
  18. }
  19. /**
  20. * 写入京豆记录
  21. * @param UserSignJingdouEntity $userSignJingdouEntity
  22. * @return UserSignJingdouEntity
  23. */
  24. public function createByEntity(UserSignJingdouEntity $userSignJingdouEntity): UserSignJingdouEntity
  25. {
  26. $result = $this->dao->create($userSignJingdouEntity->toUnderlineArray())->toArray();
  27. /** @var UserSignJingdouEntity $entity */
  28. $entity = UserSignJingdouEntity::newInstance($result);
  29. return $entity;
  30. }
  31. /**
  32. * 添加京豆记录
  33. * @param int $uid
  34. * @param int $type
  35. * @param float $number
  36. * @param string $mark
  37. * @param string $orderType
  38. * @param string $orderId
  39. * @return UserSignJingdouEntity
  40. */
  41. public function addUserSingJingdou(int $uid, int $type, float $number, int $merId, string $mark = '', string $orderType = '', string $orderId = ''): UserSignJingdouEntity
  42. {
  43. if (!empty($orderType)) {
  44. if (!empty($orderId)) {
  45. if ($orderType == UserSignJingdouEnum::ORDER_TYPE['Platform']['code']) {
  46. /** @var StoreOrderRepository $storeOrderRepository */
  47. $storeOrderRepository = app()->make(StoreOrderRepository::class);
  48. $storeOrderEntity = $storeOrderRepository->getStoreOrderEntityByOrderId((int)$orderId);
  49. if (empty($storeOrderEntity->getOrderId())) {
  50. throw new ValidateException('未查询到订单信息');
  51. }
  52. }
  53. }
  54. }
  55. /** @var UserSignJingdouEntity $userSignJingdouEntity */
  56. $userSignJingdouEntity = UserSignJingdouEntity::newInstance();
  57. $userSignJingdouEntity->setUid($uid)
  58. ->setType($type)
  59. ->setNumber($number)
  60. ->setMerId($merId)
  61. ->setMark($mark)
  62. ->setOrderType($orderType)
  63. ->setOrderId($orderId)
  64. ->setAddtime(time())
  65. ->setStatus(UserSignJingdouEnum::STATUS['PendingConfirmation']['code']);
  66. return $this->createByEntity($userSignJingdouEntity);
  67. }
  68. }