记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit fa0304ea authored by jiangxiulong's avatar jiangxiulong
Browse files
Options

同步数据接口

parent 5de1aa23
Hide whitespace changes
Inline Side-by-side
Showing with 70 additions and 33 deletions
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/controller/syncRedis/UserDataController.java
View file @ fa0304ea
...@@ -67,9 +67,12 @@ public class UserDataController { ...@@ -67,9 +67,12 @@ public class UserDataController {
@GetMapping("users") @GetMapping("users")
@ApiOperation("同步所有关注服务号用户") @ApiOperation("同步所有关注服务号用户")
public void getUsers() { @ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "Integer", name = "type", value = "type 1正在 2摩登", required = true)
})
public void getUsers(@RequestParam() Integer type) {
try { try {
userDataService.userInfo(); userDataService.userInfo(type);
} catch (Exception e) { } catch (Exception e) {
log.error("getUsers", e); log.error("getUsers", e);
} }
......
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/syncRedis/UserDataServiceImpl.java
View file @ fa0304ea
...@@ -31,8 +31,8 @@ public class UserDataServiceImpl { ...@@ -31,8 +31,8 @@ public class UserDataServiceImpl {
@Autowired @Autowired
private QueueUtils queueUtils; private QueueUtils queueUtils;
public void userInfo() throws WxErrorException { public void userInfo(Integer type) throws WxErrorException {
WxMpService wxMpService = wechatMpConfigure.getWxMpService(1); WxMpService wxMpService = wechatMpConfigure.getWxMpService(type);
String nextOpenid = ""; String nextOpenid = "";
do { do {
...@@ -53,36 +53,70 @@ public class UserDataServiceImpl { ...@@ -53,36 +53,70 @@ public class UserDataServiceImpl {
log.info("getSubscribeFalse：openId：[{}]", openId); log.info("getSubscribeFalse：openId：[{}]", openId);
continue; continue;
} }
SweetWechatUser userInfo = redisDataUtils.getSweetWechatUser(wxMpUser.getUnionId()); if (type == 1) {
if (null == userInfo) { SweetWechatUser userInfo = redisDataUtils.getSweetWechatUser(wxMpUser.getUnionId());
SweetWechatUser sweetWechatUser = SweetWechatUser.getNew(); if (null == userInfo) {
sweetWechatUser.setOpenId(wxMpUser.getOpenId()); SweetWechatUser sweetWechatUser = SweetWechatUser.getNew();
sweetWechatUser.setUnionId(wxMpUser.getUnionId()); sweetWechatUser.setOpenId(wxMpUser.getOpenId());
sweetWechatUser.setNickname(wxMpUser.getNickname()); sweetWechatUser.setUnionId(wxMpUser.getUnionId());
sweetWechatUser.setSexDesc(wxMpUser.getSexDesc()); sweetWechatUser.setNickname(wxMpUser.getNickname());
sweetWechatUser.setSex(wxMpUser.getSex()); sweetWechatUser.setSexDesc(wxMpUser.getSexDesc());
sweetWechatUser.setHeadImgUrl(wxMpUser.getHeadImgUrl()); sweetWechatUser.setSex(wxMpUser.getSex());
sweetWechatUser.setLanguage(wxMpUser.getLanguage()); sweetWechatUser.setHeadImgUrl(wxMpUser.getHeadImgUrl());
sweetWechatUser.setCountry(wxMpUser.getCountry()); sweetWechatUser.setLanguage(wxMpUser.getLanguage());
sweetWechatUser.setProvince(wxMpUser.getProvince()); sweetWechatUser.setCountry(wxMpUser.getCountry());
sweetWechatUser.setCity(wxMpUser.getCity()); sweetWechatUser.setProvince(wxMpUser.getProvince());
sweetWechatUser.setSubscribeTime(DateUtil.ofEpochMilli(wxMpUser.getSubscribeTime())); sweetWechatUser.setCity(wxMpUser.getCity());
sweetWechatUser.setSubscribeScene(wxMpUser.getSubscribeScene()); sweetWechatUser.setSubscribeTime(DateUtil.ofEpochMilli(wxMpUser.getSubscribeTime()));
sweetWechatUser.setUserId(IDGenerator.nextSnowId()); sweetWechatUser.setSubscribeScene(wxMpUser.getSubscribeScene());
LinkedList<String> sqls = CollectionUtil.linkedListString(); sweetWechatUser.setUserId(IDGenerator.nextSnowId());
LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr(); LinkedList<String> sqls = CollectionUtil.linkedListString();
sqls.add(SqlMapping.get("sweet_user.insert")); LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
sqlsDataA.add(new Object[]{ sqls.add(SqlMapping.get("sweet_user.insert"));
sweetWechatUser.getUserId(), sweetWechatUser.getOpenId(), sweetWechatUser.getUnionId(), sweetWechatUser.getNickname(), sqlsDataA.add(new Object[]{
sweetWechatUser.getSexDesc(), sweetWechatUser.getSex(), sweetWechatUser.getHeadImgUrl(), sweetWechatUser.getLanguage(), sweetWechatUser.getUserId(), 1, sweetWechatUser.getOpenId(), sweetWechatUser.getUnionId(), sweetWechatUser.getNickname(),
sweetWechatUser.getCountry(), sweetWechatUser.getProvince(), sweetWechatUser.getCity(), sweetWechatUser.getSexDesc(), sweetWechatUser.getSex(), sweetWechatUser.getHeadImgUrl(), sweetWechatUser.getLanguage(),
sweetWechatUser.getSubscribeTime(), sweetWechatUser.getSubscribeScene() sweetWechatUser.getCountry(), sweetWechatUser.getProvince(), sweetWechatUser.getCity(),
}); sweetWechatUser.getSubscribeTime(), sweetWechatUser.getSubscribeScene()
queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(), });
SqlMapping.gets(sqls, sqlsDataA)); queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
// 入缓存 SqlMapping.gets(sqls, sqlsDataA));
redisDataUtils.setSweetWechatUser(sweetWechatUser); // 入缓存
redisDataUtils.setSweetWechatUser(sweetWechatUser);
}
} else if (type == 2) {
SweetWechatUser userInfo = redisDataUtils.getSweetWechatUserModernsky(wxMpUser.getUnionId());
if (null == userInfo) {
SweetWechatUser sweetWechatUser = SweetWechatUser.getNew();
sweetWechatUser.setOpenId(wxMpUser.getOpenId());
sweetWechatUser.setUnionId(wxMpUser.getUnionId());
sweetWechatUser.setNickname(wxMpUser.getNickname());
sweetWechatUser.setSexDesc(wxMpUser.getSexDesc());
sweetWechatUser.setSex(wxMpUser.getSex());
sweetWechatUser.setHeadImgUrl(wxMpUser.getHeadImgUrl());
sweetWechatUser.setLanguage(wxMpUser.getLanguage());
sweetWechatUser.setCountry(wxMpUser.getCountry());
sweetWechatUser.setProvince(wxMpUser.getProvince());
sweetWechatUser.setCity(wxMpUser.getCity());
sweetWechatUser.setSubscribeTime(DateUtil.ofEpochMilli(wxMpUser.getSubscribeTime()));
sweetWechatUser.setSubscribeScene(wxMpUser.getSubscribeScene());
sweetWechatUser.setUserId(IDGenerator.nextSnowId());
LinkedList<String> sqls = CollectionUtil.linkedListString();
LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
sqls.add(SqlMapping.get("sweet_user.insert"));
sqlsDataA.add(new Object[]{
sweetWechatUser.getUserId(), 2, sweetWechatUser.getOpenId(), sweetWechatUser.getUnionId(), sweetWechatUser.getNickname(),
sweetWechatUser.getSexDesc(), sweetWechatUser.getSex(), sweetWechatUser.getHeadImgUrl(), sweetWechatUser.getLanguage(),
sweetWechatUser.getCountry(), sweetWechatUser.getProvince(), sweetWechatUser.getCity(),
sweetWechatUser.getSubscribeTime(), sweetWechatUser.getSubscribeScene()
});
queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_USER_INSERT_DRAW.getKey(),
SqlMapping.gets(sqls, sqlsDataA));
// 入缓存
redisDataUtils.setSweetWechatUserModernsky(sweetWechatUser);
}
} }
} catch (Exception e) { } catch (Exception e) {
log.info("forException：openId：[{}]", openId); log.info("forException：openId：[{}]", openId);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment