fanli-server.git

			@@ -1,15 +1,6 @@
			package com.yeshi.fanli.service.impl.money;

			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.aliyun.openservices.ons.api.Message;
			import com.aliyun.openservices.ons.api.Producer;
			import com.yeshi.fanli.dao.mybatis.UserInfoMapper;
			import com.yeshi.fanli.dao.mybatis.money.UserMoneyDetailMapper;
			import com.yeshi.fanli.dao.mybatis.share.ShareMapper;
			@@ -25,6 +16,12 @@
			import com.yeshi.fanli.util.mq.cmq.UserMoneyChangeCMQManager;
			import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
			import com.yeshi.fanli.util.rocketmq.MQTopicName;
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.annotation.Transactional;

			import javax.annotation.Resource;
			import java.math.BigDecimal;
			import java.util.Date;

			@Service
			public class UserMoneyServiceImpl implements UserMoneyService {
			@@ -40,6 +37,9 @@

			@Resource
			private RocketMQManager rocketMQManager;

			@Resource
			private UserMoneyChangeCMQManager userMoneyChangeCMQManager;

			@Override
			public BigDecimal getMoneyToday(Long uid) {
			@@ -67,7 +67,7 @@
			userInfoMapper.subHongBaoByUid(uid, money);
			try {
			if (!Constant.IS_TEST)
			UserMoneyChangeCMQManager.getInstance()
			userMoneyChangeCMQManager
			.addUserMoneyChangeMsg(new UserMoneyChangeDTO(uid, new BigDecimal(0).subtract(money)));
			} catch (Exception e) {
			try {
			@@ -85,7 +85,7 @@
			userInfoMapper.addHongBaoByUid(uid, money);
			try {
			if (!Constant.IS_TEST)
			UserMoneyChangeCMQManager.getInstance().addUserMoneyChangeMsg(new UserMoneyChangeDTO(uid, money));
			userMoneyChangeCMQManager.addUserMoneyChangeMsg(new UserMoneyChangeDTO(uid, money));
			} catch (Exception e) {
			try {
			LogHelper.errorDetailInfo(e);