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

Skip to content

L
liquidnet-bus-v1
Commit bc2034a1 authored by GaoHu's avatar GaoHu
Browse files
Options

exit

parent 0f98589f
Hide whitespace changes
Inline Side-by-side
Showing with 67 additions and 72 deletions
liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/docu/db_0315_jxl_nft.sql
View file @ bc2034a1
...@@ -276,7 +276,6 @@ CREATE TABLE `goblin_goods_anticipate_share` ( ...@@ -276,7 +276,6 @@ CREATE TABLE `goblin_goods_anticipate_share` (
`sid` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '主键ID', `sid` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '主键ID',
`uid` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '用户uid', `uid` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '用户uid',
`sku_id` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT 'sku_Id', `sku_id` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT 'sku_Id',
`url` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT 'url分享地址（备用）',
`created_date` datetime NOT NULL COMMENT '创建时间', `created_date` datetime NOT NULL COMMENT '创建时间',
PRIMARY KEY (`sid`) USING BTREE PRIMARY KEY (`sid`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '预约创建助力表' ROW_FORMAT = Dynamic; ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '预约创建助力表' ROW_FORMAT = Dynamic;
......
liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/manage/GoblinGoodsAnticipateMgServiceImpl.java
View file @ bc2034a1
...@@ -68,90 +68,86 @@ public class GoblinGoodsAnticipateMgServiceImpl implements IGoblinGoodsAnticipat ...@@ -68,90 +68,86 @@ public class GoblinGoodsAnticipateMgServiceImpl implements IGoblinGoodsAnticipat
} }
} }
//生成的antId for (GoblinGoodsAnticipateValueAddParam goodsAnticipateValueAddParam : goodsAnticipateAddParam.getList()) {
String antId = IDGenerator.nextTimeId2(); //生成的antId
GoblinGoodsAnticipateVo goodsAnticipateVo = new GoblinGoodsAnticipateVo(); String antId = IDGenerator.nextTimeId2();
goodsAnticipateVo.copy(goodsAnticipateAddParam); GoblinGoodsAnticipateVo goodsAnticipateVo = new GoblinGoodsAnticipateVo();
goodsAnticipateVo.setAntId(antId); goodsAnticipateVo.copy(goodsAnticipateAddParam);
goodsAnticipateVo.setCreatedDate(LocalDateTime.now()); goodsAnticipateVo.setAntId(antId);
goodsAnticipateVo.setDelTag(0); goodsAnticipateVo.setCreatedDate(LocalDateTime.now());
goodsAnticipateVo.setDelTag(0);
//redis消息预约消息表 //redis消息预约消息表
LinkedList<Object[]> sqlAnt = CollectionUtil.linkedListObjectArr(); LinkedList<Object[]> sqlAnt = CollectionUtil.linkedListObjectArr();
sqlAnt.add(new Object[]{ sqlAnt.add(new Object[]{
goodsAnticipateVo.getName(), goodsAnticipateVo.getName(),
antId, antId,
goodsAnticipateVo.getPeople(), goodsAnticipateVo.getPeople(),
goodsAnticipateVo.getType(), goodsAnticipateVo.getType(),
goodsAnticipateVo.getRule(), goodsAnticipateVo.getRule(),
goodsAnticipateVo.getCreatedDate(), goodsAnticipateVo.getCreatedDate(),
goodsAnticipateVo.getDelTag() goodsAnticipateVo.getDelTag()
}); });
sendRedis("goblin_goods_anticipate", sqlAnt); sendRedis("goblin_goods_anticipate", sqlAnt);
//mongodb新增
goblinMongoUtils.setGoblinGoodsAnticipateVo(goodsAnticipateVo);
addAnticipateValues(antId, goodsAnticipateAddParam.getRule(), goodsAnticipateAddParam.getList(), goodsAnticipateAddParam.getPeople(), goodsAnticipateAddParam.getType()); //mongodb新增
goblinMongoUtils.setGoblinGoodsAnticipateVo(goodsAnticipateVo);
//返回预约id addAnticipateValues(antId, goodsAnticipateAddParam.getRule(), goodsAnticipateValueAddParam, goodsAnticipateAddParam.getPeople(), goodsAnticipateAddParam.getType());
return ResponseDto.success(antId); }
return ResponseDto.success("1");
} }
return ResponseDto.failure("参数有误"); return ResponseDto.failure("参数有误");
} }
public void addAnticipateValues(String antId, String rule, List<GoblinGoodsAnticipateValueAddParam> list, Integer people, Integer type) { public void addAnticipateValues(String antId, String rule, GoblinGoodsAnticipateValueAddParam goodsAnticipateValueAddParam, Integer people, Integer type) {
//获取创建者uid //获取创建者uid
String uid = CurrentUtil.getCurrentUid(); String uid = CurrentUtil.getCurrentUid();
if (list != null && list.size() > 0) { GoblinGoodsAnticipateValueVo goodsAnticipateValueVo = new GoblinGoodsAnticipateValueVo();
list.forEach(item -> { goodsAnticipateValueVo.copy(goodsAnticipateValueAddParam);
GoblinGoodsAnticipateValueVo goodsAnticipateValueVo = new GoblinGoodsAnticipateValueVo(); goodsAnticipateValueVo.setUid(uid);
goodsAnticipateValueVo.copy(item); goodsAnticipateValueVo.setAntId(antId);
goodsAnticipateValueVo.setUid(uid); goodsAnticipateValueVo.setRule(rule);
goodsAnticipateValueVo.setAntId(antId); goodsAnticipateValueVo.setCreatedDate(LocalDateTime.now());
goodsAnticipateValueVo.setRule(rule); goodsAnticipateValueVo.setDelTag(0);
goodsAnticipateValueVo.setCreatedDate(LocalDateTime.now()); goodsAnticipateValueVo.setAboutPeople(BigInteger.valueOf(0));
goodsAnticipateValueVo.setDelTag(0); goodsAnticipateValueVo.setActualPeople(BigInteger.valueOf(0));
goodsAnticipateValueVo.setAboutPeople(BigInteger.valueOf(0)); goodsAnticipateValueVo.setType(type);
goodsAnticipateValueVo.setActualPeople(BigInteger.valueOf(0)); goodsAnticipateValueVo.setPeopleType(people);
goodsAnticipateValueVo.setType(type); //redis消息
goodsAnticipateValueVo.setPeopleType(people); //redis标识存入该sku处于预约列表
//redis消息 goblinRedisUtils.setValue(goodsAnticipateValueVo);
//redis标识存入该sku处于预约列表
goblinRedisUtils.setValue(goodsAnticipateValueVo);
//redis缓存预约条件 //redis缓存预约条件
/*GoblinGoodsAnticipateHelp goodsAnticipateHelp = GoblinGoodsAnticipateHelp.getNew(); /*GoblinGoodsAnticipateHelp goodsAnticipateHelp = GoblinGoodsAnticipateHelp.getNew();
goodsAnticipateHelp.setSkuId(goodsAnticipateValueVo.getSkuId()); goodsAnticipateHelp.setSkuId(goodsAnticipateValueVo.getSkuId());
goodsAnticipateHelp.setType(type); goodsAnticipateHelp.setType(type);
goodsAnticipateHelp.setPeople(people); goodsAnticipateHelp.setPeople(people);
goodsAnticipateHelp.setAboutStartDate(goodsAnticipateValueVo.getAboutStartDate()); goodsAnticipateHelp.setAboutStartDate(goodsAnticipateValueVo.getAboutStartDate());
goodsAnticipateHelp.setAboutEndDate(goodsAnticipateValueVo.getAboutEndDate()); goodsAnticipateHelp.setAboutEndDate(goodsAnticipateValueVo.getAboutEndDate());
goblinRedisUtils.setSharePeopleBySkuId(item.getSkuId(), goodsAnticipateHelp);*/ goblinRedisUtils.setSharePeopleBySkuId(item.getSkuId(), goodsAnticipateHelp);*/
//保存mysql中间表 //保存mysql中间表
LinkedList<Object[]> sqlValue = CollectionUtil.linkedListObjectArr(); LinkedList<Object[]> sqlValue = CollectionUtil.linkedListObjectArr();
sqlValue.add(new Object[]{ sqlValue.add(new Object[]{
goodsAnticipateValueVo.getUid(), goodsAnticipateValueVo.getUid(),
goodsAnticipateValueVo.getAntId(), goodsAnticipateValueVo.getAntId(),
goodsAnticipateValueVo.getSkuName(), goodsAnticipateValueVo.getSkuName(),
goodsAnticipateValueVo.getSkuId(), goodsAnticipateValueVo.getSkuId(),
goodsAnticipateValueVo.getSpuId(), goodsAnticipateValueVo.getSpuId(),
goodsAnticipateValueVo.getAboutPeople(), goodsAnticipateValueVo.getAboutPeople(),
goodsAnticipateValueVo.getActualPeople(), goodsAnticipateValueVo.getActualPeople(),
goodsAnticipateValueVo.getRule(), goodsAnticipateValueVo.getRule(),
goodsAnticipateValueVo.getAboutStartDate(), goodsAnticipateValueVo.getAboutStartDate(),
goodsAnticipateValueVo.getAboutEndDate(), goodsAnticipateValueVo.getAboutEndDate(),
goodsAnticipateValueVo.getCreatedDate(), goodsAnticipateValueVo.getCreatedDate(),
goodsAnticipateValueVo.getDelTag() goodsAnticipateValueVo.getDelTag()
}); });
sendRedis("goblin_goods_anticipate_value", sqlValue); sendRedis("goblin_goods_anticipate_value", sqlValue);
//存入mongodb中 //存入mongodb中
goblinMongoUtils.addAnticipateValues(goodsAnticipateValueVo); goblinMongoUtils.addAnticipateValues(goodsAnticipateValueVo);
});
}
} }
@Override @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