From 5f13dcc8eaac7cd26c0ec41bd1b3efbb70a08180 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 16 六月 2020 17:45:09 +0800
Subject: [PATCH] 云发单金额修改，增加获取电话号码接口
---
fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudManageServiceImpl.java | 20 +++++++++++++++++++-
1 files changed, 19 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..2e18480 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,13 @@
import javax.annotation.Resource;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.scheduling.annotation.Async;
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 +20,27 @@
@Resource
private UserCloudManageMapper userCloudManageMapper;
+ @Lazy
+ @Resource
+ private UserCloudGoodsService userCloudGoodsService;
+
+
+ @Async
@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 +55,12 @@
manage.setOfficial(official);
manage.setCreateTime(new Date());
userCloudManageMapper.insertSelective(manage);
+
+ send = manage.getCustom();
+ }
+
+ if (send) {
+ userCloudGoodsService.sendGoodsMQMsg(uid);
}
}
--
Gitblit v1.8.0