lisang
/
jeepay
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

异步更新；

This commit is contained in:
terrfly 2021-11-19 10:38:03 +08:00
parent e9635a860c
commit 818489271c
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
jeepay-manager/src/main/java/com/jeequan/jeepay/mgr/ctrl/config/SysConfigController.java
View File

@ -23,11 +23,13 @@ import com.jeequan.jeepay.core.aop.MethodLog;
import com.jeequan.jeepay.core.constants.ApiCodeEnum;
import com.jeequan.jeepay.core.entity.SysConfig;
import com.jeequan.jeepay.core.model.ApiRes;
import com.jeequan.jeepay.core.utils.SpringBeansUtil;
import com.jeequan.jeepay.mgr.ctrl.CommonCtrl;
import com.jeequan.jeepay.service.impl.SysConfigService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
@ -87,9 +89,16 @@ public class SysConfigController extends CommonCtrl {
return ApiRes.fail(ApiCodeEnum.SYSTEM_ERROR, "更新失败");
}
mqSender.send(ResetAppConfigMQ.build(groupKey));
// 异步更新到MQ
SpringBeansUtil.getBean(SysConfigController.class).updateSysConfigMQ(groupKey);
return ApiRes.ok();
}
@Async
public void updateSysConfigMQ(String groupKey){
mqSender.send(ResetAppConfigMQ.build(groupKey));
}
}