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

Commit 19f07844 authored by zhanggb's avatar zhanggb

+api:商品管理:藏品AR删除;

parent 97bcc914
......@@ -72,7 +72,7 @@ public class GoblinStoreMgtGoodsSkuExtraController {
// GoblinGoodsSkuInfoVo mgtGoodsSkuInfoVo = goblinRedisUtils.getGoodsSkuInfoVo(skuId);
// if (null == mgtGoodsSkuInfoVo || !mgtGoodsSkuInfoVo.getDelFlg().equals("0")) {
// log.warn("商品管理:藏品AR:管理:藏品不存在或已删除[UID={},skuId={}]", currentUid, skuId);
// return ResponseDto.failure(ErrorCode.HTTP_PARAM_ERROR.getCode(), "藏品不存在或已删除");
// return ResponseDto.failure(ErrorCode.HTTP_PARAM_ERROR.getCode(), "藏品AR不存在或已删除");
// }
// if (mgtGoodsSkuInfoVo.getSkuType() != 1) {
// log.warn("商品管理:藏品AR:管理:非数字藏品不支持此操作[UID={},skuId={}]", currentUid, skuId);
......
......@@ -64,6 +64,26 @@ public class GoblinStoreMgtGoodsSkuExtraServiceImpl implements IGoblinStoreMgtGo
@Override
public boolean skuArDel(String uid, List<String> skuIdList) {
LocalDateTime now = LocalDateTime.now();
if (goblinMongoUtils.updateGoodsSkuInfoVoDelArUrl(uid, now, skuIdList)) {
log.info("商品管理:藏品AR:删除[UID={},PARAMS={}]", uid, JsonUtils.toJson(skuIdList));
LinkedList<Object[]> delGoodsSkuExtraObjs = CollectionUtil.linkedListObjectArr();
skuIdList.forEach(skuId -> {
goblinRedisUtils.delGoodsSkuInfoVo(skuId);
goblinRedisUtils.delGoodsSkuInfoVoByUnShelves(skuId);
delGoodsSkuExtraObjs.add(new Object[]{uid, now, skuId});
});
LinkedList<String> toMqSqls = CollectionUtil.linkedListString();
toMqSqls.add(SqlMapping.get("goblin_goods_sku_extra.del_ar"));
// LinkedList<Object[]> delGoodsSkuExtraObjs = CollectionUtil.linkedListObjectArr();
queueUtils.sendMsgByRedis(MQConst.GoblinQueue.SQL_GOODS.getKey(), SqlMapping.gets(toMqSqls, delGoodsSkuExtraObjs));
return true;
}
return false;
}
}
......@@ -873,6 +873,12 @@ public class GoblinMongoUtils {
GoblinGoodsSkuInfoVo.class.getSimpleName()).getModifiedCount() > 0;
}
public boolean updateGoodsSkuInfoVoDelArUrl(String uid, LocalDateTime now, List<String> skuIds) {
return mongoTemplate.updateMulti(Query.query(Criteria.where("skuId").in(skuIds).and("delFlg").is("0").and("arUrlIos").exists(true)),
Update.update("updatedBy", uid).set("updatedAt", now).unset("arUrlIos").unset("arUrlAndroid"),
GoblinGoodsSkuInfoVo.class.getSimpleName()).getModifiedCount() > 0;
}
/* ---------------------------------------- ---------------------------------------- */
/**
......
......@@ -62,6 +62,7 @@ goblin_goods_sku.update_by_del=UPDATE goblin_goods_sku SET del_flg='1',updated_b
goblin_goods_sku_extra.add_ar=INSERT INTO goblin_goods_sku_extra (sku_id,ar_url_ios,ar_url_android,del_flg,created_by,created_at) VALUES (?,?,?,'0',?,?)
goblin_goods_sku_extra.edit_ar=UPDATE goblin_goods_sku_extra SET ar_url_ios=?,ar_url_android=?,updated_by=?,updated_at=? WHERE sku_id=? AND del_flg='0'
goblin_goods_sku_extra.del_ar=UPDATE goblin_goods_sku_extra SET del_flg='1',updated_by=?,updated_at=? WHERE sku_id=? AND del_flg='0'
#goblin_goods_sku_nft.insert_for_digital=INSERT INTO goblin_goods_sku_nft (sku_id,route_type,material_type,material_url,upchain,display_url,nft_url,series_id,series_hash,nft_hash,declare_at,created_at)VALUES(?,?,?,?,?,?,?,?,?,?,?,?)
goblin_goods_sku_nft.insert_for_digital=INSERT INTO goblin_goods_sku_nft (sku_id,route_type,material_type,material_url,upchain,display_url,nft_url,created_at)VALUES(?,?,?,?,?,?,?,?)
......
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