主分类 + 子分类 DAO改造

yujian

2019-03-27 cdcbed9af813b2a02cdc01eefa24db8bec6b51a9

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

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



import java.io.Serializable;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock;

@@ -10,14 +10,11 @@


import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.yeshi.utils.NumberUtil;



import com.yeshi.fanli.dao.mybatis.order.LostOrderMapper;

import com.yeshi.fanli.dao.order.LostOrderDao;

import com.yeshi.fanli.entity.bus.user.HongBaoV2;

import com.yeshi.fanli.entity.bus.user.LostOrder;

import com.yeshi.fanli.entity.bus.user.Order;

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

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

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

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

@@ -34,11 +31,9 @@
   private HongBaoOrderService hongBaoOrderService;



   @Resource

   private LostOrderDao lostOrderDao;



   @Resource

   private LostOrderMapper lostOrderMapper;



   @Transactional

   @Override

   public int addLostOrder(LostOrder lostOrder) {

      String orderId = lostOrder.getOrderId();

@@ -75,9 +70,10 @@
      try {

         try {

            lostOrderwriteLock.lock();

            List<LostOrder> list = lostOrderDao.list(

                  "from LostOrder lo where lo.orderId= ? and lo.type = ? and (lo.state = 0 or lo.state = 1)", 0,

                  1, new Serializable[] { orderId, type });

            List<Integer> stateList = new ArrayList<>();

            stateList.add(0);

            stateList.add(1);

            List<LostOrder> list = lostOrderMapper.listByOrderIdAndTypeAndState(orderId, type, stateList);

            if (list.size() > 0) {

               LostOrder find = list.get(0);

               Integer state = find.getState();

@@ -106,7 +102,8 @@
         } else {

            lostOrder.setJudge("不匹配");

         }

         lostOrderDao.save(lostOrder);



         lostOrderMapper.insertSelective(lostOrder);

      } finally {

         lostOrderReadLock.unlock();

      }

@@ -142,74 +139,29 @@
      }

      lostOrder.setHandleTime(System.currentTimeMillis());

      lostOrder.setResultCode(LostOrder.RESULT_CODE_VERFING);

      lostOrderDao.update(lostOrder);

      lostOrderMapper.updateByPrimaryKeySelective(lostOrder);

   }



   public void reject(LostOrder lostOrder) {

      lostOrder.setHandleTime(System.currentTimeMillis());

      lostOrder.setState(2);

      lostOrderDao.update(lostOrder);

   }



   @Override

   public List<LostOrder> findLostOrderList(String key, int page) {

      List<LostOrder> list;

      if (key == null || "".equals(key.trim())) {

         list = lostOrderDao.list("from LostOrder lo order by id desc", (page - 1) * Constant.PAGE_SIZE,

               Constant.PAGE_SIZE, new Serializable[] {});

      } else {

         if (NumberUtil.isNumeric(key) && key.length() >= 18) {

            // long id = Long.parseLong(key);

            list = lostOrderDao.list("from LostOrder lo where lo.orderId like ? order by id desc",

                  (page - 1) * Constant.PAGE_SIZE, Constant.PAGE_SIZE, new Serializable[] { "%" + key + "%" });



         } else {



            list = lostOrderDao.list("from LostOrder lo where lo.userInfo.nickName like ? order by id desc",

                  (page - 1) * Constant.PAGE_SIZE, Constant.PAGE_SIZE, new Serializable[] { "%" + key + "%" });

         }



      }

      return list;

   }



   @Override

   public int getCount(String key) {

      int count = 0;

      if (key == null || "".equals(key.trim())) {

         count = (int) lostOrderDao.getCount("select count(*) from LostOrder");

      } else {



         if (NumberUtil.isNumeric(key) && key.length() >= 18) {

            // long id = Long.parseLong(key);

            count = (int) lostOrderDao.getCount("select count(*) from LostOrder lo where lo.orderId like ?",

                  new Serializable[] { "%" + key + "%" });

         } else {



            count = (int) lostOrderDao.getCount(

                  "select count(*) from LostOrder lo where lo.userInfo.nickName like ?",

                  new Serializable[] { "%" + key + "%" });

         }

      }

      return count;

      lostOrderMapper.updateByPrimaryKeySelective(lostOrder);

   }



   @Override

   public LostOrder getOne(long id) {

      return lostOrderDao.find(LostOrder.class, id);

      return lostOrderMapper.selectByPrimaryKey(id);

   }



   @Override

   public List<LostOrder> getLostOrderListByUid(Long uid, int page, int pageSize) {



      return lostOrderDao.list("from LostOrder lo where lo.userInfo.id=? order by lo.createTime desc",

            (page - 1) * pageSize, pageSize, new Serializable[] { uid });

      return lostOrderMapper.listByUidOrderByCreateTimeDesc(uid, (page - 1) * pageSize, pageSize);

   }



   @Override

   public long getLostOrderCountByUid(Long uid) {

      return lostOrderDao.getCount("select count(*)  from LostOrder lo where lo.userInfo.id=?",

            new Serializable[] { uid });

      return lostOrderMapper.countAllByUid(uid);

   }



   @Transactional

@@ -232,29 +184,31 @@


   @Override

   public void processFail(String orderId) {

      lostOrderDao.update("update LostOrder lo set lo.resultCode=? where lo.orderId=?",

            new Serializable[] { LostOrder.RESULT_CODE_FAIL, orderId });

      List<LostOrder> list = lostOrderMapper.selectByOrderId(orderId);

      if (list != null)

         for (LostOrder order : list) {

            LostOrder update = new LostOrder();

            update.setId(order.getId());

            update.setResultCode(LostOrder.RESULT_CODE_FAIL);

            lostOrderMapper.updateByPrimaryKeySelective(update);

         }

   }



   @Override

   public void processFail() {

      // 订单申诉人工通过后，但是隔了3天还未处理成功就视为该订单申诉失败

      lostOrderDao.update(

            "update LostOrder lo set lo.resultCode=? where lo.state=1 and lo.resultCode=? and lo.handleTime<?",

            new Serializable[] { LostOrder.RESULT_CODE_FAIL, LostOrder.RESULT_CODE_VERFING,

                  System.currentTimeMillis() - 1000 * 60 * 60 * 24 * 3L });

      lostOrderMapper.processFail();

   }



   @Override

   public void deleteLostOrder(long id) {

      LostOrder lostOrder = new LostOrder();

      lostOrder.setId(id);

      lostOrderDao.delete(lostOrder);

      lostOrderMapper.deleteByPrimaryKey(id);

   }



   @Override

   public void deleteLostOrderByUid(long uid) {

      lostOrderDao.update("delete from LostOrder lo where lo.userInfo.id=?", new Serializable[] { uid });



      lostOrderMapper.deleteByUid(uid);

   }



   @Override