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

Commit 9a005ee3 authored by jiangxiulong's avatar jiangxiulong

Merge remote-tracking branch 'origin/jxl_422_nft_ya' into jxl_422_mongo_list

# Conflicts:
#	liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/GoblinNftOrderServiceImpl.java
parents 4d954947 5ec41c60
...@@ -83,7 +83,7 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService { ...@@ -83,7 +83,7 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
return ResponseDto.failure("该商品当前状态不可购买~"); return ResponseDto.failure("该商品当前状态不可购买~");
} }
// 单独设置的售罄 // 单独设置的售罄
if (null != skuVo.getSoldoutStatus() && skuVo.getSoldoutStatus().equals(1)) { if (StringUtils.equals("1", skuVo.getSoldoutStatus())) {
return ResponseDto.failure("该商品已售罄~"); return ResponseDto.failure("该商品已售罄~");
} }
// 判断开售、停售时间 // 判断开售、停售时间
...@@ -726,7 +726,11 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService { ...@@ -726,7 +726,11 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
//mongo //mongo
goblinOrderUtils.setMongoList(GoblinNftOrderVo.class.getSimpleName(), "orderId", orderId, GoblinRedisConst.REDIS_GOBLIN_NFT_ORDER_INFO, 2); goblinOrderUtils.setMongoList(GoblinNftOrderVo.class.getSimpleName(), "orderId", orderId, GoblinRedisConst.REDIS_GOBLIN_NFT_ORDER_INFO, 2);
// goblinMongoUtils.updateGoblinNftOrderVo(nftOrder); // goblinMongoUtils.updateGoblinNftOrderVo(nftOrder);
goblinMongoUtils.updateGoblinNftOrderRefundVo(nftOrderRefundVo); HashMap<String, Object> updateRefundMdbMap = CollectionUtil.mapStringObject();
updateMdbMap.put("status", nftOrderRefundVo.getStatus());
updateMdbMap.put("refundAt", nftOrderRefundVo.getRefundAt());
updateMdbMap.put("updatedAt", nftOrderRefundVo.getUpdatedAt());
goblinMongoUtils.updateGoblinNftOrderRefundVo(nftOrderRefundVo.getOrderRefundId(), updateRefundMdbMap);
//mysql //mysql
LinkedList<String> sqls = CollectionUtil.linkedListString(); LinkedList<String> sqls = CollectionUtil.linkedListString();
LinkedList<Object[]> sqlsOrder = CollectionUtil.linkedListObjectArr(); LinkedList<Object[]> sqlsOrder = CollectionUtil.linkedListObjectArr();
......
...@@ -10,6 +10,7 @@ import org.springframework.data.mongodb.core.query.Criteria; ...@@ -10,6 +10,7 @@ import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query; import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.List; import java.util.List;
@Component @Component
...@@ -113,11 +114,12 @@ public class GoblinMongoUtils { ...@@ -113,11 +114,12 @@ public class GoblinMongoUtils {
public void setGoblinNftOrderVo(GoblinNftOrderVo vo) { public void setGoblinNftOrderVo(GoblinNftOrderVo vo) {
mongoTemplate.insert(vo, GoblinNftOrderVo.class.getSimpleName()); mongoTemplate.insert(vo, GoblinNftOrderVo.class.getSimpleName());
} }
public UpdateResult updateGoblinNftOrderVo(GoblinNftOrderVo data) {
BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(data)); public UpdateResult updateGoblinNftOrderVo(String orderId, HashMap<String, Object> data) {
return mongoTemplate.getCollection(GoblinNftOrderVo.class.getSimpleName()).updateOne( return mongoTemplate.getCollection(GoblinNftOrderVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("orderId").is(data.getOrderId())).getQueryObject(), Query.query(Criteria.where("orderId").is(orderId)).getQueryObject(),
object); ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(data))
);
} }
//添加 订单退款数据 //添加 订单退款数据
...@@ -129,11 +131,11 @@ public class GoblinMongoUtils { ...@@ -129,11 +131,11 @@ public class GoblinMongoUtils {
return mongoTemplate.findOne(Query.query(Criteria.where("refundCode").is(refundCode)), GoblinNftOrderRefundVo.class, GoblinNftOrderRefundVo.class.getSimpleName()); return mongoTemplate.findOne(Query.query(Criteria.where("refundCode").is(refundCode)), GoblinNftOrderRefundVo.class, GoblinNftOrderRefundVo.class.getSimpleName());
} }
//修改 订单退款数据 //修改 订单退款数据
public UpdateResult updateGoblinNftOrderRefundVo(GoblinNftOrderRefundVo data) { public UpdateResult updateGoblinNftOrderRefundVo(String orderRefundId, HashMap<String, Object> data) {
BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(data));
return mongoTemplate.getCollection(GoblinNftOrderRefundVo.class.getSimpleName()).updateOne( return mongoTemplate.getCollection(GoblinNftOrderRefundVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("orderRefundId").is(data.getOrderRefundId())).getQueryObject(), Query.query(Criteria.where("orderRefundId").is(orderRefundId)).getQueryObject(),
object); ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(data))
);
} }
/** /**
......
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