From 62a447d89331aee1feae7724c7616aa1bb2cfe79 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 14:28:37 +0800
Subject: [PATCH] 将CMQ替换为rabbitmq
---
fanli/src/main/java/com/yeshi/fanli/service/impl/order/dividents/TeamDividentsSourceOrderServiceImpl.java | 261 +++++++++++++++++++++++++++-------------------------
1 files changed, 136 insertions(+), 125 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/dividents/TeamDividentsSourceOrderServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/dividents/TeamDividentsSourceOrderServiceImpl.java
index c9cb9ba..7a40156 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/dividents/TeamDividentsSourceOrderServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/dividents/TeamDividentsSourceOrderServiceImpl.java
@@ -1,125 +1,136 @@
-package com.yeshi.fanli.service.impl.order.dividents;
-
-import java.math.BigDecimal;
-import java.util.Date;
-
-import javax.annotation.Resource;
-
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-
-import com.yeshi.fanli.dao.mybatis.order.dividents.TeamDividentsSourceOrderMapper;
-import com.yeshi.fanli.entity.order.dividents.TeamDividentsSourceOrder;
-import com.yeshi.fanli.exception.ParamsException;
-import com.yeshi.fanli.exception.order.dividents.TeamDividentsSourceOrderException;
-import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceOrderService;
-import com.yeshi.fanli.util.StringUtil;
-
-@Service
-public class TeamDividentsSourceOrderServiceImpl implements TeamDividentsSourceOrderService {
-
- @Resource
- private TeamDividentsSourceOrderMapper teamDividentsSourceOrderMapper;
-
- @Override
- public TeamDividentsSourceOrder addTeamDividentsSourceOrder(TeamDividentsSourceOrder order)
- throws TeamDividentsSourceOrderException, ParamsException {
- if (order == null || order.getMoney() == null || StringUtil.isNullOrEmpty(order.getOrderNo())
- || order.getSourceType() == null || order.getState() == null || order.getUid() == null)
- throw new ParamsException(1, "鍙傛暟涓嶅畬鏁�");
-
- TeamDividentsSourceOrder sourceOrder = selectByOrderNoSourceType(order.getOrderNo(), order.getSourceType());
- if (sourceOrder != null)
- throw new TeamDividentsSourceOrderException(TeamDividentsSourceOrderException.CODE_EXIST, "璁㈠崟宸插瓨鍦�");
-
- if (order.getCreateTime() == null)
- order.setCreateTime(new Date());
- teamDividentsSourceOrderMapper.insertSelective(order);
-
- return order;
- }
-
- @Override
- public TeamDividentsSourceOrder selectByPrimaryKeyForUpdate(Long id) {
- return teamDividentsSourceOrderMapper.selectByPrimaryKeyForUpdate(id);
- }
-
- @Override
- public void invalidOrder(String orderNo, int sourceType, String beiZhu) {
- TeamDividentsSourceOrder order = selectByOrderNoSourceType(orderNo, sourceType);
- if (order == null)
- return;
- if (order.getState() != TeamDividentsSourceOrder.STATE_CAN_SEND)
- return;
- TeamDividentsSourceOrder update = new TeamDividentsSourceOrder();
- update.setId(order.getId());
- update.setState(TeamDividentsSourceOrder.STATE_INVALID);
- update.setUpdateTime(new Date());
- update.setBeiZhu(beiZhu);
- teamDividentsSourceOrderMapper.updateByPrimaryKeySelective(update);
- }
-
- @Override
- public void invalidOrderByUid(Long uid, String beiZhu) {
- teamDividentsSourceOrderMapper.setStateByUidAndState(uid, TeamDividentsSourceOrder.STATE_INVALID,
- TeamDividentsSourceOrder.STATE_CAN_SEND, beiZhu);
- }
-
- @Override
- @Transactional
- public void send(Long id) {
- TeamDividentsSourceOrder order = teamDividentsSourceOrderMapper.selectByPrimaryKeyForUpdate(id);
- if (order == null)
- return;
- if (order.getState() != TeamDividentsSourceOrder.STATE_CAN_SEND)
- return;
- TeamDividentsSourceOrder update = new TeamDividentsSourceOrder();
- update.setId(order.getId());
- update.setState(TeamDividentsSourceOrder.STATE_ALREADY_SEND);
- update.setUpdateTime(new Date());
- update.setSendTime(new Date());
- teamDividentsSourceOrderMapper.updateByPrimaryKeySelective(update);
- }
-
- @Override
- public TeamDividentsSourceOrder selectByOrderNoSourceType(String orderNo, int sourceType) {
-
- return teamDividentsSourceOrderMapper.selectByOrderNoAndSourceType(orderNo, sourceType);
-
- }
-
- @Transactional(rollbackFor = Exception.class)
- @Override
- public void orderSettle(String orderNo, int sourceType, Date preSendTime, BigDecimal income) {
- TeamDividentsSourceOrder order = selectByOrderNoSourceType(orderNo, sourceType);
- if (order == null)
- return;
- if (order.getState() == TeamDividentsSourceOrder.STATE_UNKOWN) {
- TeamDividentsSourceOrder update = new TeamDividentsSourceOrder();
- update.setId(order.getId());
- update.setMoney(income);
- update.setState(TeamDividentsSourceOrder.STATE_CAN_SEND);
- update.setPreSendTime(preSendTime);
- update.setUpdateTime(new Date());
- teamDividentsSourceOrderMapper.updateByPrimaryKeySelective(update);
- }
-
- }
-
- @Override
- public void updateMoney(String orderNo, int sourceType, BigDecimal money) {
-
- TeamDividentsSourceOrder order = selectByOrderNoSourceType(orderNo, sourceType);
- if (order == null)
- return;
- if (order.getState() == TeamDividentsSourceOrder.STATE_UNKOWN) {
- TeamDividentsSourceOrder update = new TeamDividentsSourceOrder();
- update.setId(order.getId());
- update.setMoney(money);
- update.setUpdateTime(new Date());
- teamDividentsSourceOrderMapper.updateByPrimaryKeySelective(update);
- }
-
- }
-
-}
+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 org.springframework.transaction.annotation.Transactional;
+
+import com.yeshi.fanli.dao.mybatis.order.dividents.TeamDividentsSourceOrderMapper;
+import com.yeshi.fanli.entity.order.dividents.TeamDividentsSourceOrder;
+import com.yeshi.fanli.exception.ParamsException;
+import com.yeshi.fanli.exception.order.dividents.TeamDividentsSourceOrderException;
+import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceOrderService;
+import com.yeshi.fanli.util.StringUtil;
+
+@Service
+public class TeamDividentsSourceOrderServiceImpl implements TeamDividentsSourceOrderService {
+
+ @Resource
+ private TeamDividentsSourceOrderMapper teamDividentsSourceOrderMapper;
+
+ @Override
+ public TeamDividentsSourceOrder addTeamDividentsSourceOrder(TeamDividentsSourceOrder order)
+ throws TeamDividentsSourceOrderException, ParamsException {
+ if (order == null || order.getMoney() == null || StringUtil.isNullOrEmpty(order.getOrderNo())
+ || order.getSourceType() == null || order.getState() == null || order.getUid() == null)
+ throw new ParamsException(1, "鍙傛暟涓嶅畬鏁�");
+
+ TeamDividentsSourceOrder sourceOrder = selectByOrderNoSourceType(order.getOrderNo(), order.getSourceType());
+ if (sourceOrder != null)
+ throw new TeamDividentsSourceOrderException(TeamDividentsSourceOrderException.CODE_EXIST, "璁㈠崟宸插瓨鍦�");
+
+ if (order.getCreateTime() == null)
+ order.setCreateTime(new Date());
+ teamDividentsSourceOrderMapper.insertSelective(order);
+
+ return order;
+ }
+
+ @Override
+ public TeamDividentsSourceOrder selectByPrimaryKeyForUpdate(Long id) {
+ return teamDividentsSourceOrderMapper.selectByPrimaryKeyForUpdate(id);
+ }
+
+ @Override
+ public void invalidOrder(String orderNo, int sourceType, String beiZhu) {
+ TeamDividentsSourceOrder order = selectByOrderNoSourceType(orderNo, sourceType);
+ if (order == null)
+ return;
+ if (order.getState() != TeamDividentsSourceOrder.STATE_CAN_SEND)
+ return;
+ TeamDividentsSourceOrder update = new TeamDividentsSourceOrder();
+ update.setId(order.getId());
+ update.setState(TeamDividentsSourceOrder.STATE_INVALID);
+ update.setUpdateTime(new Date());
+ update.setBeiZhu(beiZhu);
+ teamDividentsSourceOrderMapper.updateByPrimaryKeySelective(update);
+ }
+
+ @Override
+ public void invalidOrderByUid(Long uid, String beiZhu) {
+ teamDividentsSourceOrderMapper.setStateByUidAndState(uid, TeamDividentsSourceOrder.STATE_INVALID,
+ TeamDividentsSourceOrder.STATE_CAN_SEND, beiZhu);
+ }
+
+ @Override
+ @Transactional
+ public void send(Long id) {
+ TeamDividentsSourceOrder order = teamDividentsSourceOrderMapper.selectByPrimaryKeyForUpdate(id);
+ if (order == null)
+ return;
+ if (order.getState() != TeamDividentsSourceOrder.STATE_CAN_SEND)
+ return;
+ TeamDividentsSourceOrder update = new TeamDividentsSourceOrder();
+ update.setId(order.getId());
+ update.setState(TeamDividentsSourceOrder.STATE_ALREADY_SEND);
+ update.setUpdateTime(new Date());
+ update.setSendTime(new Date());
+ teamDividentsSourceOrderMapper.updateByPrimaryKeySelective(update);
+ }
+
+ @Override
+ public TeamDividentsSourceOrder selectByOrderNoSourceType(String orderNo, int sourceType) {
+
+ return teamDividentsSourceOrderMapper.selectByOrderNoAndSourceType(orderNo, sourceType);
+
+ }
+
+ @Transactional(rollbackFor = Exception.class)
+ @Override
+ public void orderSettle(String orderNo, int sourceType, Date preSendTime, BigDecimal income) {
+ TeamDividentsSourceOrder order = selectByOrderNoSourceType(orderNo, sourceType);
+ if (order == null)
+ return;
+ if (order.getState() == TeamDividentsSourceOrder.STATE_UNKOWN) {
+ TeamDividentsSourceOrder update = new TeamDividentsSourceOrder();
+ update.setId(order.getId());
+ update.setMoney(income);
+ update.setState(TeamDividentsSourceOrder.STATE_CAN_SEND);
+ update.setPreSendTime(preSendTime);
+ update.setUpdateTime(new Date());
+ teamDividentsSourceOrderMapper.updateByPrimaryKeySelective(update);
+ }
+
+ }
+
+ @Override
+ public void updateMoney(String orderNo, int sourceType, BigDecimal money) {
+
+ TeamDividentsSourceOrder order = selectByOrderNoSourceType(orderNo, sourceType);
+ if (order == null)
+ return;
+ if (order.getState() == TeamDividentsSourceOrder.STATE_UNKOWN) {
+ TeamDividentsSourceOrder update = new TeamDividentsSourceOrder();
+ update.setId(order.getId());
+ update.setMoney(money);
+ update.setUpdateTime(new Date());
+ teamDividentsSourceOrderMapper.updateByPrimaryKeySelective(update);
+ }
+
+ }
+
+ @Override
+ public List<TeamDividentsSourceOrder> listByOrderNoOrUid(String orderNo, Long uid) {
+ return null;
+ }
+
+ @Override
+ public List<TeamDividentsSourceOrder> listByOrderNo(String orderNo) {
+ return teamDividentsSourceOrderMapper.listByOrderNo(orderNo);
+ }
+
+}
--
Gitblit v1.8.0