替换原来老的资金详情

admin

2018-12-25 4cb15e222cd7d099d533ccbeb7f9a8cd99bf180c

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

@@ -2,13 +2,17 @@


import java.io.Serializable;

import java.util.List;

import java.util.Map;

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

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



import javax.annotation.Resource;



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.dao.order.PidOrderDao;

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

@@ -17,7 +21,6 @@
import com.yeshi.fanli.service.inter.order.OrderService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.Utils;

import org.yeshi.utils.NumberUtil;



@Service

public class LostOrderServiceImpl implements LostOrderService {

@@ -31,6 +34,9 @@
   @Resource

   private PidOrderDao pidOrderDao;



   @Resource

   private LostOrderMapper lostOrderMapper;



   @Override

   public int addLostOrder(LostOrder lostOrder) {

      String orderId = lostOrder.getOrderId();

@@ -38,6 +44,19 @@
      if (type == null) { // 默认为淘宝订单

         lostOrder.setType(1);

         type = 1;

      }



      // 查询是否提交

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

      if (orderList != null && orderList.size() > 0) {

         if (orderList.get(0).getState() == 0 || orderList.get(0).getResultCode() == LostOrder.RESULT_CODE_VERFING) {

            return -2;

         } else if (orderList.get(0).getState() == 1

               && orderList.get(0).getResultCode() == LostOrder.RESULT_CODE_SUCCESS) {

            return -1;

         } else {

            return -6;

         }

      }



      Order order = orderService.findOrderByOrderIdAndType(orderId, type);

@@ -120,6 +139,7 @@
         lostOrder.setState(2);

      }

      lostOrder.setHandleTime(System.currentTimeMillis());

      lostOrder.setResultCode(LostOrder.RESULT_CODE_VERFING);

      lostOrderDao.update(lostOrder);

   }



@@ -177,4 +197,84 @@
      return lostOrderDao.find(LostOrder.class, 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 });

   }



   @Override

   public long getLostOrderCountByUid(Long uid) {

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

            new Serializable[] { uid });

   }



   @Transactional

   @Override

   public void processSuceess(String orderId) {

      // 查询订单号是否在申诉列表中

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

      if (list == null || list.size() == 0)

         return;

      for (LostOrder lo : list) {

         if (lo.getState() == 1 && lo.getResultCode() != null

               && lo.getResultCode() == LostOrder.RESULT_CODE_VERFING) {

            LostOrder update = new LostOrder();

            update.setId(lo.getId());

            update.setResultCode(LostOrder.RESULT_CODE_SUCCESS);

            lostOrderMapper.updateByPrimaryKeySelective(update);

         }

      }

   }



   @Override

   public void processFail(String orderId) {

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

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

   }



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

   }



   @Override

   public void deleteLostOrder(long id) {

      LostOrder lostOrder = new LostOrder();

      lostOrder.setId(id);

      lostOrderDao.delete(lostOrder);

   }



   @Override

   public void deleteLostOrderByUid(long uid) {

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

   }



   @Override

   public Map<String, Object> countByUid(long uid) {

      return lostOrderMapper.countByUid(uid);

   }



   /**

    * 后端列表查询

    * 
    * @param start

    * @param count

    * @param key

    * @return

    */

   @Override

   public List<LostOrder> listQuery(long start, int count, String key, Integer state, Integer handleType) {

      return lostOrderMapper.listQuery(start, count, key, state, handleType);

   }



   @Override

   public long countQuery(String key, Integer state, Integer handleType) {

      return lostOrderMapper.countQuery(key, state, handleType);

   }

}