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

Commit 85f0e0e1 authored by 张国柄's avatar 张国柄

fix:处理tag for mysql;

parent 96e02cff
......@@ -72,7 +72,7 @@ create table adam_user_info
mid int unsigned auto_increment primary key,
uid varchar(64) not null,
nickname varchar(32) comment '昵称',
sex varchar(32) comment '性别',
sex varchar(50) comment '性别',
birthday date comment '生日YYYY-MM-DD',
area varchar(100) comment '常住地/区域',
signature varchar(255) comment '个性签名',
......@@ -80,7 +80,7 @@ create table adam_user_info
background varchar(255) comment '背景图',
qr_code varchar(255) comment '身份二维码',
qr_pic varchar(255) comment '身份二维码',
tag_me varchar(500) comment '音乐标签',
tag_me json comment '音乐标签',
comment text
) engine = InnoDB comment '用户信息';
......
......@@ -16,14 +16,11 @@ import org.bson.Document;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.convert.MongoConverter;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;
import java.time.LocalDateTime;
import java.util.Arrays;
import java.util.List;
/**
* <p>
......@@ -35,8 +32,6 @@ import java.util.List;
*/
@Service
public class AdamUserInfoServiceImpl extends ServiceImpl<AdamUserInfoMapper, AdamUserInfo> implements IAdamUserInfoService {
@Autowired
MongoConverter mongoConverter;
@Autowired
MongoTemplate mongoTemplate;
@Autowired
......@@ -52,11 +47,16 @@ public class AdamUserInfoServiceImpl extends ServiceImpl<AdamUserInfoMapper, Ada
new Document("$set", Document.parse(JsonUtils.toJson(userInfoVo))),
new FindOneAndUpdateOptions().returnDocument(ReturnDocument.AFTER)
);
if (null != doc) {
userInfoVo = BsonUtil.toBean(doc, AdamUserInfoVo.class);
List<Object> paramList = Arrays.asList(
adamRdmService.setUserInfoVoByUid(userInfoVo.getUid(), userInfoVo);
rabbitTemplate.convertSendAndReceive(MQConst.EX_LNS_SQL_UCENTER, MQConst.RK_SQL_UCENTER,
SqlMapping.get(
userInfoVo.getIsComplete() == 0 ? "adam_user_info.add" : "adam_user_info.edit",
userInfoVo.getNickname(),
userInfoVo.getSex(),
JsonUtils.toJson(userInfoVo.getSex()),
userInfoVo.getBirthday(),
userInfoVo.getArea(),
userInfoVo.getSignature(),
......@@ -64,13 +64,11 @@ public class AdamUserInfoServiceImpl extends ServiceImpl<AdamUserInfoMapper, Ada
userInfoVo.getBackground(),
userInfoVo.getQrCode(),
null,// qr_pic
userInfoVo.getTagMe(),
JsonUtils.toJson(userInfoVo.getTagMe()),
userInfoVo.getUid()
)
);
rabbitTemplate.convertSendAndReceive(MQConst.EX_LNS_SQL_UCENTER, MQConst.RK_SQL_UCENTER,
SqlMapping.get(userInfoVo.getIsComplete() == 0 ? "adam_user_info.add" : "adam_user_info.edit", paramList.toArray()));
adamRdmService.setUserInfoVoByUid(userInfoVo.getUid(), userInfoVo);
}
}
@Override
......
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