2.1需求

yujian

2020-05-09 7e7db2fa55a9a3af46d4fd8ede0dee147f101d64

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

@@ -7,6 +7,7 @@
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;



@@ -14,17 +15,31 @@
public class ESOrderServiceImpl implements ESOrderService {



   @Resource

   private ESOrderDao esOrderDao;

   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);

   }

}