淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

 fanli/src/main/java/com/yeshi/fanli/service/impl/order/ESOrderServiceImpl.java

@@ -1,30 +1,45 @@
package com.yeshi.fanli.service.impl.order;



import java.util.List;



import javax.annotation.Resource;



import org.springframework.stereotype.Service;



import com.yeshi.fanli.dao.elastic.ESOrderDao;

import com.yeshi.fanli.entity.order.ESOrder;

import com.yeshi.fanli.service.inter.order.ESOrderService;



@Service

public class ESOrderServiceImpl implements ESOrderService {



   @Resource

   private ESOrderDao esOrderDao;





   @Override

   public void add(ESOrder record) {

      esOrderDao.save(record, record.getPlatform() + "#" + record.getTradeId());

   }



	
   @Override

   public List<ESOrder> query(String key, String uid, List<Integer> listPlatform) {

      return esOrderDao.query(key, uid, listPlatform);

   }

}

package com.yeshi.fanli.service.impl.order;

import java.util.List;

import javax.annotation.Resource;

import org.springframework.stereotype.Service;

import com.yeshi.fanli.dao.elastic.ESOrderDao;
import com.yeshi.fanli.dao.mybatis.order.OrderSearchIndexMapper;
import com.yeshi.fanli.entity.order.ESOrder;
import com.yeshi.fanli.service.inter.order.ESOrderService;

@Service
public class ESOrderServiceImpl implements ESOrderService {

   @Resource
   private OrderSearchIndexMapper orderSearchIndexMapper;

   @Resource
   private ESOrderDao esOrderDao;

   @Override
   public void add(ESOrder record) {
      esOrderDao.save(record, record.getPlatform() + "#" + record.getTradeId());
   }

   @Override
   public List<ESOrder> query(String key, String uid, List<Integer> listPlatform) {
      return esOrderDao.query(key, uid, listPlatform);
   }

   @Override
   public void syncAddOrder(int count) {
      List<Long> hbIdList = orderSearchIndexMapper.listHBId(0, count);
      if (hbIdList == null || hbIdList.size() == 0)
         return;
      List<ESOrder> list = orderSearchIndexMapper.listByHBIds(hbIdList);
      if (list != null)
         for (ESOrder order : list) {
            add(order);
         }
      orderSearchIndexMapper.deleteByHBIds(hbIdList);
   }
}