From 7912a94e5de72b628bde39b16e6c7b21172910eb Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期一, 08 六月 2020 17:15:39 +0800
Subject: [PATCH] 2.1.2bug

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudManageServiceImpl.java |   17 ++++++++++++++++-
 1 files changed, 16 insertions(+), 1 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudManageServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudManageServiceImpl.java
index c47f434..cc5b06e 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudManageServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudManageServiceImpl.java
@@ -4,10 +4,12 @@
 
 import javax.annotation.Resource;
 
+import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
 
 import com.yeshi.fanli.dao.mybatis.user.cloud.UserCloudManageMapper;
 import com.yeshi.fanli.entity.bus.user.cloud.UserCloudManage;
+import com.yeshi.fanli.service.inter.user.cloud.UserCloudGoodsService;
 import com.yeshi.fanli.service.inter.user.cloud.UserCloudManageService;
 
 
@@ -17,18 +19,25 @@
 	@Resource
 	private UserCloudManageMapper userCloudManageMapper;
 	
+	@Lazy
+	@Resource
+	private UserCloudGoodsService userCloudGoodsService;
+	
 	@Override
 	public void save(Long uid, Boolean official, Boolean custom) {
 		if (uid == null) 
 			return;
 		
+		boolean send = false;
 		UserCloudManage cloudManage = userCloudManageMapper.selectByPrimaryKey(uid);
 		if (cloudManage != null) {
 			UserCloudManage update = new UserCloudManage();
 			if (official != null)
 				update.setOfficial(official);
-			if (custom != null)
+			if (custom != null) {
 				update.setCustom(custom);	
+				send = custom;
+			}
 			update.setId(uid);
 			update.setUpdateTime(new Date());
 			userCloudManageMapper.updateByPrimaryKeySelective(update);
@@ -43,6 +52,12 @@
 			manage.setOfficial(official);
 			manage.setCreateTime(new Date());
 			userCloudManageMapper.insertSelective(manage);
+			
+			send = manage.getCustom();
+		}
+		
+		if (send) {
+			userCloudGoodsService.sendGoodsMQMsg(uid);
 		}
 	}
 	

--
Gitblit v1.8.0