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

Commit df3d8fee authored by GaoHu's avatar GaoHu

exit

parent a5c02246
...@@ -36,6 +36,12 @@ public class GoblinGoodsAnticipateAddParam { ...@@ -36,6 +36,12 @@ public class GoblinGoodsAnticipateAddParam {
@NotBlank(message = "预约规则") @NotBlank(message = "预约规则")
private String rule; private String rule;
/**
* 预约人数
*/
@ApiModelProperty(value = "预约人数")
private Long aboutPeople;
/** /**
* 预约开始时间 * 预约开始时间
*/ */
...@@ -50,11 +56,4 @@ public class GoblinGoodsAnticipateAddParam { ...@@ -50,11 +56,4 @@ public class GoblinGoodsAnticipateAddParam {
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = DateUtil.DATE_FULL_STR) @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = DateUtil.DATE_FULL_STR)
private LocalDateTime aboutEndDate; private LocalDateTime aboutEndDate;
/**
* 库存
*/
@ApiModelProperty(value = "sku关联")
private List<GoblinGoodsAnticipateValueVo> goodsAnticipateValues;
} }
package com.liquidnet.service.goblin.dto.manage;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.io.Serializable;
import java.util.List;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.liquidnet.commons.lang.util.DateUtil;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import javax.validation.constraints.NotBlank;
/**
* <p>
* 预约关联sku和spu表
* </p>
*
* @author liquidnet
* @since 2022-04-08
*/
@Data
public class GoblinGoodsAnticipateValueParam {
private static final long serialVersionUID = 1L;
/**
* antId
*/
@ApiModelProperty(value = "antId")
@NotBlank(message = "antId不能为空")
private String antId;
/**
* sku名称
*/
@ApiModelProperty(value = "sku名称")
@NotBlank(message = "skuName不能为空")
private String skuName;
/**
* sku_id 对应 goblin_goods_sku.sku_id
*/
@ApiModelProperty(value = "sku_id 对应 goblin_goods_sku.sku_id")
@NotBlank(message = "skuId不能为空")
private String skuId;
/**
* spu_id对应 goblin_goods_spu_id
*/
@ApiModelProperty(value = "spu_id对应 goblin_goods_spu_id")
@NotBlank(message = "spuId不能为空")
private String spuId;
/**
* 预约开始时间
*/
@ApiModelProperty(value = "预约开始时间")
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = DateUtil.DATE_FULL_STR)
@NotBlank(message = "预约开始时间不能为空")
private LocalDateTime aboutStartDate;
/**
* 预约结束时间
*/
@ApiModelProperty(value = "预约结束时间")
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = DateUtil.DATE_FULL_STR)
@NotBlank(message = "预约结束时间不能为空")
private LocalDateTime aboutEndDate;
}
package com.liquidnet.service.goblin.dto.manage.vo; package com.liquidnet.service.goblin.dto.manage.vo;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.io.Serializable;
import java.util.List;
import com.fasterxml.jackson.annotation.JsonFormat; import com.fasterxml.jackson.annotation.JsonFormat;
import com.liquidnet.commons.lang.util.DateUtil; import com.liquidnet.commons.lang.util.DateUtil;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode;
import java.time.LocalDateTime;
/** /**
* <p> * <p>
...@@ -27,6 +20,13 @@ public class GoblinGoodsAnticipateValueVo { ...@@ -27,6 +20,13 @@ public class GoblinGoodsAnticipateValueVo {
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
/**
* antId
*/
@ApiModelProperty(value = "antId")
private String antId;
/** /**
* sku名称 * sku名称
*/ */
...@@ -59,4 +59,24 @@ public class GoblinGoodsAnticipateValueVo { ...@@ -59,4 +59,24 @@ public class GoblinGoodsAnticipateValueVo {
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = DateUtil.DATE_FULL_STR) @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = DateUtil.DATE_FULL_STR)
private LocalDateTime aboutEndDate; private LocalDateTime aboutEndDate;
/**
* 创建时间
*/
@ApiModelProperty(value = "创建时间")
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = DateUtil.DATE_FULL_STR)
private LocalDateTime createdDate;
/**
* 修改时间
*/
@ApiModelProperty(value = "修改时间")
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = DateUtil.DATE_FULL_STR)
private LocalDateTime updateDate;
/**
* 删除(0:未删除1:已删除)
*/
@ApiModelProperty(value = "删除(0:未删除1:已删除)")
private Integer delTag;
} }
...@@ -91,12 +91,4 @@ public class GoblinGoodsAnticipateVo implements Serializable { ...@@ -91,12 +91,4 @@ public class GoblinGoodsAnticipateVo implements Serializable {
@ApiModelProperty(value = "目前三种状态(0:未开始,1:预约中,2:已结束)") @ApiModelProperty(value = "目前三种状态(0:未开始,1:预约中,2:已结束)")
private Integer state; private Integer state;
/**
* 库存
*/
@ApiModelProperty(value = "sku关联")
private List<GoblinGoodsAnticipateValueVo> goodsAnticipateValues;
} }
...@@ -5,6 +5,7 @@ import com.liquidnet.service.base.ResponseDto; ...@@ -5,6 +5,7 @@ import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateAddParam; import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateAddParam;
import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateParam; import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateParam;
import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateUpdateParam; import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateUpdateParam;
import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateValueParam;
import com.liquidnet.service.goblin.dto.vo.GoblinGoodsAnticipateVo; import com.liquidnet.service.goblin.dto.vo.GoblinGoodsAnticipateVo;
import java.util.List; import java.util.List;
...@@ -28,13 +29,17 @@ public interface IGoblinGoodsAnticipateService{ ...@@ -28,13 +29,17 @@ public interface IGoblinGoodsAnticipateService{
ResponseDto<Object> add(GoblinGoodsAnticipateAddParam goodsAnticipateAddParam); ResponseDto<Object> add(GoblinGoodsAnticipateAddParam goodsAnticipateAddParam);
ResponseDto<Object> updatePeople(String antId,Long people);
ResponseDto<Object> update(GoblinGoodsAnticipateUpdateParam goodsAnticipateUpdateParam); ResponseDto<Object> update(GoblinGoodsAnticipateUpdateParam goodsAnticipateUpdateParam);
ResponseDto<Object> updatePeople(String antId,Long people);
ResponseDto<Object> delete(String antId); ResponseDto<Object> delete(String antId);
ResponseDto<Object> getSkus(String spuId); ResponseDto<Object> getSkus(String spuId);
ResponseDto<Object> userAbout(String antId, String skuId,String uid, String phone,Integer state); ResponseDto<Object> userAbout(String antId, String skuId,String uid, String phone,Integer state);
ResponseDto<Object> addAnticipateValues(List<GoblinGoodsAnticipateValueParam> list);
ResponseDto<Object> updateAnticipateValues(List<GoblinGoodsAnticipateValueParam> list);
} }
package com.liquidnet.service.goblin.controller; package com.liquidnet.service.goblin.controller.manage;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
...@@ -6,6 +6,7 @@ import com.liquidnet.service.base.ResponseDto; ...@@ -6,6 +6,7 @@ import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateAddParam; import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateAddParam;
import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateParam; import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateParam;
import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateUpdateParam; import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateUpdateParam;
import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateValueParam;
import com.liquidnet.service.goblin.dto.vo.GoblinGoodsAnticipateVo; import com.liquidnet.service.goblin.dto.vo.GoblinGoodsAnticipateVo;
import com.liquidnet.service.goblin.service.IGoblinGoodsAnticipateService; import com.liquidnet.service.goblin.service.IGoblinGoodsAnticipateService;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
...@@ -33,17 +34,18 @@ public class GoblinGoodsAnticipateController { ...@@ -33,17 +34,18 @@ public class GoblinGoodsAnticipateController {
@Autowired @Autowired
IGoblinGoodsAnticipateService goblinGoodsAnticipateService; IGoblinGoodsAnticipateService goblinGoodsAnticipateService;
@ApiOperation("创建预约信息")
@PostMapping("/add")
public ResponseDto<Object> add(@RequestBody GoblinGoodsAnticipateAddParam goodsAnticipateAddParam) {
return goblinGoodsAnticipateService.add(goodsAnticipateAddParam);
}
@PostMapping("/list") @PostMapping("/list")
@ApiOperation("获取预约列表") @ApiOperation("获取预约列表")
public ResponseDto<PageInfo<GoblinGoodsAnticipateVo>> list(GoblinGoodsAnticipateParam goodsAnticipateParam) { public ResponseDto<PageInfo<GoblinGoodsAnticipateVo>> list(GoblinGoodsAnticipateParam goodsAnticipateParam) {
return goblinGoodsAnticipateService.list(goodsAnticipateParam); return goblinGoodsAnticipateService.list(goodsAnticipateParam);
} }
@ApiOperation("创建预约信息")
@PostMapping("/add")
public ResponseDto<Object> add(@RequestBody GoblinGoodsAnticipateAddParam goodsAnticipateAddParam) {
return goblinGoodsAnticipateService.add(goodsAnticipateAddParam);
}
@ApiOperation("修改预约人数") @ApiOperation("修改预约人数")
@PostMapping("/updatePeople") @PostMapping("/updatePeople")
...@@ -63,6 +65,19 @@ public class GoblinGoodsAnticipateController { ...@@ -63,6 +65,19 @@ public class GoblinGoodsAnticipateController {
return goblinGoodsAnticipateService.delete(antId); return goblinGoodsAnticipateService.delete(antId);
} }
@ApiOperation("创建预约关联sku")
@PostMapping("/addAnticipateValues")
public ResponseDto<Object> addAnticipateValues(List<GoblinGoodsAnticipateValueParam> list) {
return goblinGoodsAnticipateService.addAnticipateValues(list);
}
@ApiOperation("修改预约关联")
@PostMapping("/updateAnticipateValues")
public ResponseDto<Object> updateAnticipateValues(List<GoblinGoodsAnticipateValueParam> list ) {
return goblinGoodsAnticipateService.updateAnticipateValues(list);
}
@ApiOperation("用户预约(state预约标识:0为预约,1为取消预约)") @ApiOperation("用户预约(state预约标识:0为预约,1为取消预约)")
@PostMapping("/userAbout") @PostMapping("/userAbout")
public ResponseDto<Object> userAbout(@RequestParam(name = "antId", required = true) String antId, public ResponseDto<Object> userAbout(@RequestParam(name = "antId", required = true) String antId,
...@@ -73,7 +88,7 @@ public class GoblinGoodsAnticipateController { ...@@ -73,7 +88,7 @@ public class GoblinGoodsAnticipateController {
return goblinGoodsAnticipateService.userAbout(antId, skuId, uid, phone, state); return goblinGoodsAnticipateService.userAbout(antId, skuId, uid, phone, state);
} }
@ApiOperation("根据spuid查询出所有的sku") @ApiOperation("根据spuId查询出所有的sku")
@PostMapping("") @PostMapping("")
public ResponseDto<Object> getSkus(@RequestParam(name = "apuId") String SpuId) { public ResponseDto<Object> getSkus(@RequestParam(name = "apuId") String SpuId) {
return goblinGoodsAnticipateService.getSkus(SpuId); return goblinGoodsAnticipateService.getSkus(SpuId);
......
...@@ -3,13 +3,13 @@ package com.liquidnet.service.goblin.service.impl; ...@@ -3,13 +3,13 @@ package com.liquidnet.service.goblin.service.impl;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.liquidnet.commons.lang.util.CollectionUtil; import com.liquidnet.commons.lang.util.CollectionUtil;
import com.liquidnet.commons.lang.util.IDGenerator; import com.liquidnet.commons.lang.util.IDGenerator;
import com.liquidnet.service.base.PagedResult;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.base.SqlMapping; import com.liquidnet.service.base.SqlMapping;
import com.liquidnet.service.base.constant.MQConst; import com.liquidnet.service.base.constant.MQConst;
import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateAddParam; import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateAddParam;
import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateParam; import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateParam;
import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateUpdateParam; import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateUpdateParam;
import com.liquidnet.service.goblin.dto.manage.GoblinGoodsAnticipateValueParam;
import com.liquidnet.service.goblin.dto.manage.vo.GoblinGoodsAnticipateValueVo; import com.liquidnet.service.goblin.dto.manage.vo.GoblinGoodsAnticipateValueVo;
import com.liquidnet.service.goblin.dto.vo.GoblinGoodAnticipateUserVo; import com.liquidnet.service.goblin.dto.vo.GoblinGoodAnticipateUserVo;
import com.liquidnet.service.goblin.dto.vo.GoblinGoodsAnticipateVo; import com.liquidnet.service.goblin.dto.vo.GoblinGoodsAnticipateVo;
...@@ -17,7 +17,6 @@ import com.liquidnet.service.goblin.service.IGoblinGoodsAnticipateService; ...@@ -17,7 +17,6 @@ import com.liquidnet.service.goblin.service.IGoblinGoodsAnticipateService;
import com.liquidnet.service.goblin.util.GoblinMongoUtils; import com.liquidnet.service.goblin.util.GoblinMongoUtils;
import com.liquidnet.service.goblin.util.GoblinRedisUtils; import com.liquidnet.service.goblin.util.GoblinRedisUtils;
import com.liquidnet.service.goblin.util.QueueUtils; import com.liquidnet.service.goblin.util.QueueUtils;
import io.swagger.models.auth.In;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
...@@ -83,17 +82,14 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS ...@@ -83,17 +82,14 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
if (StringUtils.isNotBlank(goodsAnticipateAddParam.getName()) if (StringUtils.isNotBlank(goodsAnticipateAddParam.getName())
&& StringUtils.isNotBlank(goodsAnticipateAddParam.getRule()) && StringUtils.isNotBlank(goodsAnticipateAddParam.getRule())
&& StringUtils.isNotBlank(goodsAnticipateAddParam.getAboutStartDate().toString()) && StringUtils.isNotBlank(goodsAnticipateAddParam.getAboutStartDate().toString())
&& StringUtils.isNotBlank(goodsAnticipateAddParam.getAboutEndDate().toString()) && StringUtils.isNotBlank(goodsAnticipateAddParam.getAboutEndDate().toString())) {
&& goodsAnticipateAddParam.getGoodsAnticipateValues() != null) {
List<GoblinGoodsAnticipateValueVo> goodsAnticipateValues = goodsAnticipateAddParam.getGoodsAnticipateValues();
//生成的antId //生成的antId
String antId = IDGenerator.nextTimeId2(); String antId = IDGenerator.nextTimeId2();
GoblinGoodsAnticipateVo goodsAnticipateVo = new GoblinGoodsAnticipateVo(); GoblinGoodsAnticipateVo goodsAnticipateVo = new GoblinGoodsAnticipateVo();
BeanUtils.copyProperties(goodsAnticipateAddParam, goodsAnticipateVo); BeanUtils.copyProperties(goodsAnticipateAddParam, goodsAnticipateVo);
goodsAnticipateVo.setAntId(antId); goodsAnticipateVo.setAntId(antId);
goodsAnticipateVo.setDelTag(0);
goodsAnticipateVo.setCreatedDate(LocalDateTime.now()); goodsAnticipateVo.setCreatedDate(LocalDateTime.now());
goodsAnticipateVo.setDelTag(0);
//redis消息预约消息表 //redis消息预约消息表
...@@ -102,32 +98,14 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS ...@@ -102,32 +98,14 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
antId, antId,
goodsAnticipateVo.getName(), goodsAnticipateVo.getName(),
goodsAnticipateVo.getRule(), goodsAnticipateVo.getRule(),
goodsAnticipateVo.getAboutPeople(),
goodsAnticipateVo.getAboutStartDate(), goodsAnticipateVo.getAboutStartDate(),
goodsAnticipateVo.getAboutEndDate() goodsAnticipateVo.getAboutEndDate(),
goodsAnticipateVo.getCreatedDate(),
goodsAnticipateVo.getDelTag()
}); });
sendRedis("goblin_goods_anticipate", sqlAnt); sendRedis("goblin_goods_anticipate", sqlAnt);
//redis消息
goodsAnticipateValues.forEach(goodsAnticipateValueVo -> {
//redis标识存入该sku处于预约列表
goblinRedisUtils.setAnticipate(goodsAnticipateValueVo.getSkuId());
//锁定库存
//TODO:修改mongodb,修改数据库,修改redis
//保存mysql中间表
LinkedList<Object[]> sqlValue = CollectionUtil.linkedListObjectArr();
sqlValue.add(new Object[]{
antId,
goodsAnticipateValueVo.getSkuName(),
goodsAnticipateValueVo.getSkuId(),
goodsAnticipateValueVo.getSpuId(),
goodsAnticipateValueVo.getAboutStartDate(),
goodsAnticipateValueVo.getAboutEndDate(),
});
sendRedis("goblin_goods_anticipate_value", sqlValue);
});
//mongodb新增 //mongodb新增
goblinMongoUtils.setGoblinGoodsAnticipateVo(goodsAnticipateVo); goblinMongoUtils.setGoblinGoodsAnticipateVo(goodsAnticipateVo);
return ResponseDto.success(); return ResponseDto.success();
...@@ -173,9 +151,9 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS ...@@ -173,9 +151,9 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
antId antId
}); });
//预约库删除 //预约库删除
sendRedis("goblin_goods_anticipate_delete",sqlValue); sendRedis("goblin_goods_anticipate_delete", sqlValue);
//预约关联库删除 //预约关联库删除
sendRedis("goblin_goods_anticipate_value_delete",sqlValue); sendRedis("goblin_goods_anticipate_value_delete", sqlValue);
//删除mongodb //删除mongodb
if (goblinMongoUtils.delGoodsAnticipateVo(antId)) { if (goblinMongoUtils.delGoodsAnticipateVo(antId)) {
return ResponseDto.success(); return ResponseDto.success();
...@@ -223,6 +201,66 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS ...@@ -223,6 +201,66 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
return null; return null;
} }
@Override
public ResponseDto<Object> addAnticipateValues(List<GoblinGoodsAnticipateValueParam> list) {
if (list != null && list.size() > 0) {
list.forEach(item -> {
GoblinGoodsAnticipateValueVo goodsAnticipateValueVo = new GoblinGoodsAnticipateValueVo();
BeanUtils.copyProperties(item, goodsAnticipateValueVo);
goodsAnticipateValueVo.setCreatedDate(LocalDateTime.now());
goodsAnticipateValueVo.setCreatedDate(LocalDateTime.now());
goodsAnticipateValueVo.setDelTag(0);
//redis消息
//redis标识存入该sku处于预约列表
goblinRedisUtils.setAnticipate(goodsAnticipateValueVo.getSkuId());
//保存mysql中间表
LinkedList<Object[]> sqlValue = CollectionUtil.linkedListObjectArr();
sqlValue.add(new Object[]{
goodsAnticipateValueVo.getAntId(),
goodsAnticipateValueVo.getSkuName(),
goodsAnticipateValueVo.getSkuId(),
goodsAnticipateValueVo.getSpuId(),
goodsAnticipateValueVo.getAboutStartDate(),
goodsAnticipateValueVo.getAboutEndDate(),
goodsAnticipateValueVo.getCreatedDate(),
goodsAnticipateValueVo.getDelTag()
});
sendRedis("goblin_goods_anticipate_value", sqlValue);
//存入mongodb中
goblinMongoUtils.addAnticipateValues(goodsAnticipateValueVo);
});
}
return ResponseDto.success();
}
@Override
public ResponseDto<Object> updateAnticipateValues(List<GoblinGoodsAnticipateValueParam> list) {
if (list != null && list.size() > 0) {
list.forEach(item -> {
GoblinGoodsAnticipateValueVo goodsAnticipateValueVo = new GoblinGoodsAnticipateValueVo();
BeanUtils.copyProperties(item, goodsAnticipateValueVo);
//redis消息
//redis标识存入该sku处于预约列表
goblinRedisUtils.setAnticipate(goodsAnticipateValueVo.getSkuId());
//保存mysql中间表
LinkedList<Object[]> sqlValue = CollectionUtil.linkedListObjectArr();
sqlValue.add(new Object[]{
goodsAnticipateValueVo.getAboutStartDate(),
goodsAnticipateValueVo.getAboutEndDate(),
goodsAnticipateValueVo.getAntId(),
goodsAnticipateValueVo.getSkuId(),
goodsAnticipateValueVo.getSpuId(),
});
sendRedis("goblin_goods_anticipate_value_update", sqlValue);
});
}
return null;
}
public void sendRedis(String sqlKey, LinkedList<Object[]> sqlData) { public void sendRedis(String sqlKey, LinkedList<Object[]> sqlData) {
LinkedList<String> sql = CollectionUtil.linkedListString(); LinkedList<String> sql = CollectionUtil.linkedListString();
......
...@@ -113,8 +113,7 @@ public class GoblinMongoUtils { ...@@ -113,8 +113,7 @@ public class GoblinMongoUtils {
*/ */
public boolean delGoodsAnticipateVo(String antId) { public boolean delGoodsAnticipateVo(String antId) {
//查询该预约下有多少个开启预约的skuId //查询该预约下有多少个开启预约的skuId
GoblinGoodsAnticipateVo anticipateVo = getAnticipateVo(antId); List<GoblinGoodsAnticipateValueVo> goodsAnticipateValues = getGoodsAnticipateValues(antId);
List<GoblinGoodsAnticipateValueVo> goodsAnticipateValues = anticipateVo.getGoodsAnticipateValues();
if (goodsAnticipateValues!=null && goodsAnticipateValues.size()>0){ if (goodsAnticipateValues!=null && goodsAnticipateValues.size()>0){
goodsAnticipateValues.forEach(goblinGoodsAnticipateValueVo -> { goodsAnticipateValues.forEach(goblinGoodsAnticipateValueVo -> {
redisUtils.delGoodsAnticipateVo(goblinGoodsAnticipateValueVo.getSkuId()); redisUtils.delGoodsAnticipateVo(goblinGoodsAnticipateValueVo.getSkuId());
...@@ -125,6 +124,15 @@ public class GoblinMongoUtils { ...@@ -125,6 +124,15 @@ public class GoblinMongoUtils {
return mongoTemplate.remove(query, GoblinGoodsAnticipateVo.class.getSimpleName()).getDeletedCount() > 0; return mongoTemplate.remove(query, GoblinGoodsAnticipateVo.class.getSimpleName()).getDeletedCount() > 0;
} }
/**
* 根据活动id查询关联
*/
public List<GoblinGoodsAnticipateValueVo> getGoodsAnticipateValues(String autId){
Criteria criteria = Criteria.where("autId").is(autId);
Query query = Query.query(criteria);
return mongoTemplate.find(query, GoblinGoodsAnticipateValueVo.class, GoblinGoodsAnticipateValueVo.class.getSimpleName());
}
/** /**
* 根据用户预约 * 根据用户预约
*/ */
...@@ -141,6 +149,10 @@ public class GoblinMongoUtils { ...@@ -141,6 +149,10 @@ public class GoblinMongoUtils {
GoblinGoodsAnticipateVo.class, GoblinGoodsAnticipateVo.class.getSimpleName()); GoblinGoodsAnticipateVo.class, GoblinGoodsAnticipateVo.class.getSimpleName());
} }
public void addAnticipateValues(GoblinGoodsAnticipateValueVo goodsAnticipateValueVo) {
mongoTemplate.insert(goodsAnticipateValueVo, GoblinGoodsAnticipateValueVo.class.getSimpleName());
}
/* ---------------------------------------- 平台分类数据源 ---------------------------------------- */ /* ---------------------------------------- 平台分类数据源 ---------------------------------------- */
......
...@@ -134,9 +134,10 @@ goblin_user_digital_artwork.update_for_chain=UPDATE goblin_user_digital_artwork ...@@ -134,9 +134,10 @@ goblin_user_digital_artwork.update_for_chain=UPDATE goblin_user_digital_artwork
goblin_user_digital_artwork.update_for_unboxing=UPDATE goblin_user_digital_artwork SET state=1,del_flg='1',opening_at=?,updated_at=?,deleted_at=? WHERE artwork_id=? AND state<>1 goblin_user_digital_artwork.update_for_unboxing=UPDATE goblin_user_digital_artwork SET state=1,del_flg='1',opening_at=?,updated_at=?,deleted_at=? WHERE artwork_id=? AND state<>1
#---- #----
#---- \u9884\u7EA6 #---- \u9884\u7EA6
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(?,?,?,0,?,?,NOW(),0) 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_delete=UPDATE goblin_goods_anticipate SET `del_tag` = 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_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(?,?,?,?,?,?,NOW(),0) 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_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 = ?
goblin_goods_anticipate_update=UPDATE goblin_goods_anticipate SET `name` = ?,`rule`= ? WHERE ant_id = ? goblin_goods_anticipate_update=UPDATE goblin_goods_anticipate SET `name` = ?,`rule`= ? WHERE ant_id = ?
goblin_goods_anticipate_update_proper=UPDATE goblin_goods_anticipate SET about_people = ? WHERE ant_id = ? goblin_goods_anticipate_update_proper=UPDATE goblin_goods_anticipate SET about_people = ? 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