From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 25 二月 2025 16:41:22 +0800
Subject: [PATCH] 淘宝转链接口更新
---
fanli/src/main/java/com/yeshi/fanli/service/impl/order/dividents/TeamDividentsSourceUserServiceImpl.java | 137 +++++++++++++++++++++++++--------------------
1 files changed, 75 insertions(+), 62 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/dividents/TeamDividentsSourceUserServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/dividents/TeamDividentsSourceUserServiceImpl.java
index ac9eb5d..3798be0 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/dividents/TeamDividentsSourceUserServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/dividents/TeamDividentsSourceUserServiceImpl.java
@@ -1,62 +1,75 @@
-package com.yeshi.fanli.service.impl.order.dividents;
-
-import java.math.BigDecimal;
-import java.util.Date;
-import java.util.List;
-
-import javax.annotation.Resource;
-
-import org.springframework.stereotype.Service;
-
-import com.yeshi.fanli.dao.mybatis.order.dividents.TeamDividentsSourceUserMapper;
-import com.yeshi.fanli.entity.order.dividents.TeamDividentsSourceUser;
-import com.yeshi.fanli.exception.ParamsException;
-import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceUserService;
-import com.yeshi.fanli.util.StringUtil;
-
-@Service
-public class TeamDividentsSourceUserServiceImpl implements TeamDividentsSourceUserService {
-
- @Resource
- private TeamDividentsSourceUserMapper teamDividentsSourceUserMapper;
-
- @Override
- public void addTeamDividentsSourceUser(TeamDividentsSourceUser teamDividentsSourceUser) throws ParamsException {
- if (teamDividentsSourceUser == null || StringUtil.isNullOrEmpty(teamDividentsSourceUser.getDay())
- || teamDividentsSourceUser.getMoney() == null || teamDividentsSourceUser.getSourceUid() == null
- || teamDividentsSourceUser.getTargetUid() == null)
- throw new ParamsException(1, "鍙傛暟涓嶅畬鏁�");
- if (teamDividentsSourceUser.getCreateTime() == null)
- teamDividentsSourceUser.setCreateTime(new Date());
- teamDividentsSourceUserMapper.insertSelective(teamDividentsSourceUser);
- }
-
- @Override
- public BigDecimal sumMoneyByUidAndDay(Long uid, String day,Integer type) {
- BigDecimal money = teamDividentsSourceUserMapper.sumMoneyByTargetUidAndDayAndType(uid, day,type);
- if (money == null)
- return new BigDecimal(0);
- return money;
- }
-
- @Override
- public List<Long> listTargetUid(String day, int page, int pageSize) {
- return teamDividentsSourceUserMapper.listTargetUidByDay(day, (page - 1) * pageSize, pageSize);
- }
-
- @Override
- public List<TeamDividentsSourceUser> listBySourceUidAndDay(Long sourceUid, String day) {
- return teamDividentsSourceUserMapper.listBySourceUidAndDay(sourceUid, day);
- }
-
- @Override
- public long countTargetUid(String day) {
- return teamDividentsSourceUserMapper.countTargetUidByDay(day);
- }
-
- @Override
- public TeamDividentsSourceUser selectBySourceUidAndDayAndUid(Long sourceUid, Long targetUid, String day) {
- return teamDividentsSourceUserMapper.selectBySourceUidAndDayAndUid(sourceUid, targetUid, day);
- }
-
-}
+package com.yeshi.fanli.service.impl.order.dividents;
+
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.List;
+
+import javax.annotation.Resource;
+
+import org.springframework.stereotype.Service;
+
+import com.yeshi.fanli.dao.mybatis.order.dividents.TeamDividentsSourceUserMapper;
+import com.yeshi.fanli.entity.order.dividents.TeamDividentsSourceUser;
+import com.yeshi.fanli.exception.ParamsException;
+import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceUserService;
+import com.yeshi.fanli.util.StringUtil;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+public class TeamDividentsSourceUserServiceImpl implements TeamDividentsSourceUserService {
+
+ @Resource
+ private TeamDividentsSourceUserMapper teamDividentsSourceUserMapper;
+
+ @Transactional(rollbackFor = Exception.class)
+ @Override
+ public void addTeamDividentsSourceUser(TeamDividentsSourceUser teamDividentsSourceUser) throws ParamsException {
+ if (teamDividentsSourceUser == null || StringUtil.isNullOrEmpty(teamDividentsSourceUser.getDay())
+ || teamDividentsSourceUser.getMoney() == null || teamDividentsSourceUser.getSourceUid() == null
+ || teamDividentsSourceUser.getTargetUid() == null)
+ throw new ParamsException(1, "鍙傛暟涓嶅畬鏁�");
+ if (teamDividentsSourceUser.getCreateTime() == null)
+ teamDividentsSourceUser.setCreateTime(new Date());
+ //鏌ヨ鏄惁瀛樺湪
+ TeamDividentsSourceUser sourceUser = teamDividentsSourceUserMapper.selectBySourceUidAndDayAndUidAndTypeForUpdate(teamDividentsSourceUser.getSourceUid(), teamDividentsSourceUser.getTargetUid(), teamDividentsSourceUser.getDay(), teamDividentsSourceUser.getType());
+
+ if (sourceUser != null) {
+ TeamDividentsSourceUser record = new TeamDividentsSourceUser();
+ record.setId(sourceUser.getId());
+ record.setMoney(sourceUser.getMoney().add(teamDividentsSourceUser.getMoney()));
+ record.setUpdateTime(new Date());
+ teamDividentsSourceUserMapper.updateByPrimaryKeySelective(record);
+ } else {
+ teamDividentsSourceUserMapper.insertSelective(teamDividentsSourceUser);
+ }
+ }
+
+ @Override
+ public BigDecimal sumMoneyByUidAndDay(Long uid, String day, Integer type) {
+ BigDecimal money = teamDividentsSourceUserMapper.sumMoneyByTargetUidAndDayAndType(uid, day, type);
+ if (money == null)
+ return new BigDecimal(0);
+ return money;
+ }
+
+ @Override
+ public List<Long> listTargetUid(String day, int page, int pageSize) {
+ return teamDividentsSourceUserMapper.listTargetUidByDay(day, (page - 1) * pageSize, pageSize);
+ }
+
+ @Override
+ public List<TeamDividentsSourceUser> listBySourceUidAndDay(Long sourceUid, String day) {
+ return teamDividentsSourceUserMapper.listBySourceUidAndDay(sourceUid, day);
+ }
+
+ @Override
+ public long countTargetUid(String day) {
+ return teamDividentsSourceUserMapper.countTargetUidByDay(day);
+ }
+
+ @Override
+ public TeamDividentsSourceUser selectBySourceUidAndDayAndUid(Long sourceUid, Long targetUid, String day) {
+ return teamDividentsSourceUserMapper.selectBySourceUidAndDayAndUid(sourceUid, targetUid, day);
+ }
+
+}
--
Gitblit v1.8.0