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

Commit ec80de80 authored by GaoHu's avatar GaoHu

exit

parent 52aeb023
...@@ -18,7 +18,7 @@ public class GoblinGoodsAnticipateUpdateParam { ...@@ -18,7 +18,7 @@ public class GoblinGoodsAnticipateUpdateParam {
@ApiModelProperty(value ="预约id") @ApiModelProperty(value ="预约id")
@NotBlank(message = "预约id") @NotBlank(message = "预约id")
private String autId; private String antId;
/** /**
* 预约名称 * 预约名称
......
...@@ -54,6 +54,12 @@ public class GoblinGoodsAnticipateVo implements Serializable { ...@@ -54,6 +54,12 @@ public class GoblinGoodsAnticipateVo implements Serializable {
@ApiModelProperty(value = "预约人数") @ApiModelProperty(value = "预约人数")
private Long aboutPeople; private Long aboutPeople;
/**
* 预约人数
*/
@ApiModelProperty(value = "实际预约人数")
private Long actualPeople;
/** /**
* 预约开始时间 * 预约开始时间
*/ */
......
...@@ -137,7 +137,7 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS ...@@ -137,7 +137,7 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
sqlValue.add(new Object[]{ sqlValue.add(new Object[]{
goodsAnticipateUpdateParam.getName(), goodsAnticipateUpdateParam.getName(),
goodsAnticipateUpdateParam.getRule(), goodsAnticipateUpdateParam.getRule(),
goodsAnticipateUpdateParam.getAutId() goodsAnticipateUpdateParam.getAntId()
}); });
sendRedis("goblin_goods_anticipate_update", sqlValue); sendRedis("goblin_goods_anticipate_update", sqlValue);
return ResponseDto.success(); return ResponseDto.success();
...@@ -158,8 +158,7 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS ...@@ -158,8 +158,7 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
if (goblinMongoUtils.delGoodsAnticipateVo(antId)) { if (goblinMongoUtils.delGoodsAnticipateVo(antId)) {
return ResponseDto.success(); return ResponseDto.success();
} }
log.error("delete() antId:{}", antId); return ResponseDto.success();
return ResponseDto.failure("请重试");
} }
@Override @Override
......
...@@ -103,7 +103,7 @@ public class GoblinMongoUtils { ...@@ -103,7 +103,7 @@ public class GoblinMongoUtils {
* 根据antId修改 预约人数 * 根据antId修改 预约人数
*/ */
public void updateGoblinGoodsAnticipateVo(GoblinGoodsAnticipateUpdateParam goodsAnticipateUpdateParam) { public void updateGoblinGoodsAnticipateVo(GoblinGoodsAnticipateUpdateParam goodsAnticipateUpdateParam) {
Query query = Query.query(Criteria.where("antId").is(goodsAnticipateUpdateParam.getAutId())); Query query = Query.query(Criteria.where("antId").is(goodsAnticipateUpdateParam.getAntId()));
Update update = new Update().set("name", goodsAnticipateUpdateParam.getName()).set("rule", goodsAnticipateUpdateParam.getRule()).set("updateDate",LocalDateTime.now()); Update update = new Update().set("name", goodsAnticipateUpdateParam.getName()).set("rule", goodsAnticipateUpdateParam.getRule()).set("updateDate",LocalDateTime.now());
mongoTemplate.updateFirst(query, update, GoblinGoodsAnticipateVo.class.getSimpleName()); mongoTemplate.updateFirst(query, update, GoblinGoodsAnticipateVo.class.getSimpleName());
} }
...@@ -113,12 +113,7 @@ public class GoblinMongoUtils { ...@@ -113,12 +113,7 @@ public class GoblinMongoUtils {
*/ */
public boolean delGoodsAnticipateVo(String antId) { public boolean delGoodsAnticipateVo(String antId) {
//查询该预约下有多少个开启预约的skuId //查询该预约下有多少个开启预约的skuId
List<GoblinGoodsAnticipateValueVo> goodsAnticipateValues = getGoodsAnticipateValues(antId); delAnticipateValues(antId);
if (goodsAnticipateValues!=null && goodsAnticipateValues.size()>0){
goodsAnticipateValues.forEach(goblinGoodsAnticipateValueVo -> {
redisUtils.delGoodsAnticipateVo(goblinGoodsAnticipateValueVo.getSkuId());
});
}
redisUtils.delGoodsAnticipateVo(antId); redisUtils.delGoodsAnticipateVo(antId);
Query query = Query.query(Criteria.where("antId").is(antId)); Query query = Query.query(Criteria.where("antId").is(antId));
return mongoTemplate.remove(query, GoblinGoodsAnticipateVo.class.getSimpleName()).getDeletedCount() > 0; return mongoTemplate.remove(query, GoblinGoodsAnticipateVo.class.getSimpleName()).getDeletedCount() > 0;
...@@ -127,8 +122,8 @@ public class GoblinMongoUtils { ...@@ -127,8 +122,8 @@ public class GoblinMongoUtils {
/** /**
* 根据活动id查询关联 * 根据活动id查询关联
*/ */
public List<GoblinGoodsAnticipateValueVo> getGoodsAnticipateValues(String autId){ public List<GoblinGoodsAnticipateValueVo> getGoodsAnticipateValues(String antId){
Criteria criteria = Criteria.where("autId").is(autId); Criteria criteria = Criteria.where("antId").is(antId);
Query query = Query.query(criteria); Query query = Query.query(criteria);
return mongoTemplate.find(query, GoblinGoodsAnticipateValueVo.class, GoblinGoodsAnticipateValueVo.class.getSimpleName()); return mongoTemplate.find(query, GoblinGoodsAnticipateValueVo.class, GoblinGoodsAnticipateValueVo.class.getSimpleName());
} }
...@@ -144,16 +139,22 @@ public class GoblinMongoUtils { ...@@ -144,16 +139,22 @@ public class GoblinMongoUtils {
/** /**
* 根据预约ID获取预约详情 * 根据预约ID获取预约详情
*/ */
public GoblinGoodsAnticipateVo getAnticipateVo(String autId) { public GoblinGoodsAnticipateVo getAnticipateVo(String antId) {
return mongoTemplate.findOne(Query.query(Criteria.where("autId").is(autId)), return mongoTemplate.findOne(Query.query(Criteria.where("autId").is(antId)),
GoblinGoodsAnticipateVo.class, GoblinGoodsAnticipateVo.class.getSimpleName()); GoblinGoodsAnticipateVo.class, GoblinGoodsAnticipateVo.class.getSimpleName());
} }
/**
* 添加预约中间表信息
*/
public void addAnticipateValues(GoblinGoodsAnticipateValueVo goodsAnticipateValueVo) { public void addAnticipateValues(GoblinGoodsAnticipateValueVo goodsAnticipateValueVo) {
mongoTemplate.insert(goodsAnticipateValueVo, GoblinGoodsAnticipateValueVo.class.getSimpleName()); mongoTemplate.insert(goodsAnticipateValueVo, GoblinGoodsAnticipateValueVo.class.getSimpleName());
} }
public void delAnticipateValues(String antId){
Query query = Query.query(Criteria.where("antId").is(antId));
mongoTemplate.remove(query, GoblinGoodsAnticipateValueVo.class.getSimpleName()).getDeletedCount();
}
/* ---------------------------------------- 平台分类数据源 ---------------------------------------- */ /* ---------------------------------------- 平台分类数据源 ---------------------------------------- */
......
...@@ -137,7 +137,7 @@ goblin_user_digital_artwork.update_for_unboxing=UPDATE goblin_user_digital_artwo ...@@ -137,7 +137,7 @@ goblin_user_digital_artwork.update_for_unboxing=UPDATE goblin_user_digital_artwo
goblin_goods_anticipate=INSERT INTO goblin_goods_anticipate(ant_id,`name`,`rule`,actual_people,about_start_date,about_end_date,created_date,del_tag) VALUES(?,?,?,?,?,?,?,?) goblin_goods_anticipate=INSERT INTO goblin_goods_anticipate(ant_id,`name`,`rule`,actual_people,about_start_date,about_end_date,created_date,del_tag) VALUES(?,?,?,?,?,?,?,?)
goblin_goods_anticipate_update_actual_add_people=UPDATE goblin_goods_anticipate SET actual_people = actual_people+1 WHERE ant_id = ? goblin_goods_anticipate_update_actual_add_people=UPDATE goblin_goods_anticipate SET actual_people = actual_people+1 WHERE ant_id = ?
goblin_goods_anticipate_update_actual_reduce_people=UPDATE goblin_goods_anticipate SET actual_people = actual_people-1 WHERE ant_id = ? goblin_goods_anticipate_update_actual_reduce_people=UPDATE goblin_goods_anticipate SET actual_people = actual_people-1 WHERE ant_id = ?
goblin_goods_anticipate_delete=UPDATE goblin_goods_anticipate SET `del_tag` = 1,update_date = NOW() WHERE ant_id = ? goblin_goods_anticipate_delete=UPDATE goblin_goods_anticipate SET `del_tag` = 1 WHERE ant_id = ?
goblin_goods_anticipate_value=INSERT INTO goblin_goods_anticipate_value (ant_id,sku_name,sku_id,spu_id,about_start_date,about_end_date,created_date,del_tag) VALUES(?,?,?,?,?,?,?,?) goblin_goods_anticipate_value=INSERT INTO goblin_goods_anticipate_value (ant_id,sku_name,sku_id,spu_id,about_start_date,about_end_date,created_date,del_tag) VALUES(?,?,?,?,?,?,?,?)
goblin_goods_anticipate_value_update=UPDATE goblin_goods_anticipate_value SET `about_start_date` = ?,`about_end_date`= ?,update_date = NOW() WHERE ant_id = ? AND sku_id = ? AND spu_id = ? goblin_goods_anticipate_value_update=UPDATE goblin_goods_anticipate_value SET `about_start_date` = ?,`about_end_date`= ?,update_date = NOW() WHERE ant_id = ? AND sku_id = ? AND spu_id = ?
goblin_goods_anticipate_value_delete=UPDATE goblin_goods_anticipate_value SET `del_tag` = 1 WHERE ant_id = ? goblin_goods_anticipate_value_delete=UPDATE goblin_goods_anticipate_value SET `del_tag` = 1 WHERE ant_id = ?
......
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