diff --git a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/DouDianOrderCatchServiceImpl.java b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/DouDianOrderCatchServiceImpl.java index fdf98ac085..395e5d645c 100644 --- a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/DouDianOrderCatchServiceImpl.java +++ b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/DouDianOrderCatchServiceImpl.java @@ -1,24 +1,16 @@ package cn.iocoder.yudao.module.haoka.service.orderCatch; import cn.hutool.core.collection.CollectionUtil; -import cn.iocoder.yudao.framework.common.pojo.PageResult; -import cn.iocoder.yudao.framework.common.util.object.BeanUtils; import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX; import cn.iocoder.yudao.module.haoka.controller.admin.onsaleproduct.vo.OnSaleProductPreOrderRespVO; import cn.iocoder.yudao.module.haoka.controller.admin.orderCatch.po.Message; -import cn.iocoder.yudao.module.haoka.controller.admin.orderCatch.vo.OrderCatchRepVO; -import cn.iocoder.yudao.module.haoka.controller.admin.ordersynclog.vo.OrderSyncLogPageReqVO; -import cn.iocoder.yudao.module.haoka.controller.admin.ordersynclog.vo.OrderSyncLogSaveReqVO; import cn.iocoder.yudao.module.haoka.dal.dataobject.onsaleproduct.OnSaleProductDO; import cn.iocoder.yudao.module.haoka.dal.dataobject.orders.OrdersDO; -import cn.iocoder.yudao.module.haoka.dal.dataobject.ordersynclog.OrderSyncLogDO; import cn.iocoder.yudao.module.haoka.dal.mysql.onsaleproduct.OnSaleProductMapper; import cn.iocoder.yudao.module.haoka.dal.mysql.orders.OrdersMapper; import cn.iocoder.yudao.module.haoka.service.onsaleproduct.OnSaleProductService; import cn.iocoder.yudao.module.haoka.service.ordersynclog.OrderSyncLogService; -import cn.iocoder.yudao.module.haoka.service.ordersynclog.OrderSyncLogServiceImpl; import cn.iocoder.yudao.module.haoka.utils.GroupListUtil; -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.doudian.open.api.order_batchDecrypt.OrderBatchDecryptRequest; import com.doudian.open.api.order_batchDecrypt.OrderBatchDecryptResponse; import com.doudian.open.api.order_batchDecrypt.data.DecryptInfosItem; @@ -143,7 +135,7 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { * 2.1 需更新的数据: 订单状态 退款状态 */ // 所有在售商品 - List onSaleProductDOS = onSaleProductMapper.selectList(new QueryWrapper().eq("deleted", 0).eq("onSale", true)); + List onSaleProductDOS = onSaleProductMapper.selectList(new LambdaQueryWrapperX().eq(OnSaleProductDO::getDeleted, 0).eq(OnSaleProductDO::getOnSale, true)); // 所有在售商品sku List skuList = onSaleProductDOS.stream().map(OnSaleProductDO::getSku).toList(); // 买家备注 @@ -248,7 +240,7 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { } } // 查询订单是否存在 不存在则新增,存在则更新 - List ordersDOS = ordersMapper.selectList(new QueryWrapper().eq("real_source_id", orderId).eq("deleted", 0)); + List ordersDOS = ordersMapper.selectList(new LambdaQueryWrapperX().eq(OrdersDO::getRealSourceId, orderId).eq(OrdersDO::getDeleted, 0)); if(CollectionUtil.isNotEmpty(ordersDOS)){ // 更新订单 OrdersDO ordersDO1 = ordersDOS.get(0); @@ -326,7 +318,7 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { * 2.1 需更新的数据: 订单状态 退款状态 */ // 所有在售商品 - List onSaleProductDOS = onSaleProductMapper.selectList(new QueryWrapper().eq("deleted", 0).eq("onSale", true)); + List onSaleProductDOS = onSaleProductMapper.selectList(new LambdaQueryWrapperX().eq(OnSaleProductDO::getDeleted, 0).eq(OnSaleProductDO::getOnSale, true)); // 所有在售商品sku List skuList = onSaleProductDOS.stream().map(OnSaleProductDO::getSku).toList(); // 买家备注 @@ -431,7 +423,7 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { } } // 查询订单是否存在 不存在则新增,存在则更新 - List ordersDOS = ordersMapper.selectList(new QueryWrapper().eq("real_source_id", orderId).eq("deleted", 0)); + List ordersDOS = ordersMapper.selectList(new LambdaQueryWrapperX().eq(OrdersDO::getRealSourceId, orderId).eq(OrdersDO::getDeleted, 0)); if(CollectionUtil.isNotEmpty(ordersDOS)){ // 更新订单 OrdersDO ordersDO1 = ordersDOS.get(0); @@ -623,7 +615,7 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { } } // 查询订单是否存在 不存在则新增,存在则更新 - List ordersDOS = ordersMapper.selectList(new QueryWrapper().eq("real_source_id", orderId).eq("deleted", 0)); + List ordersDOS = ordersMapper.selectList(new LambdaQueryWrapperX().eq(OrdersDO::getRealSourceId, orderId).eq(OrdersDO::getDeleted, 0)); if(CollectionUtil.isNotEmpty(ordersDOS)){ // 更新订单 OrdersDO ordersDO1 = ordersDOS.get(0);