订单优化 + 后台提现曲线图

yujian

2019-01-14 92c681fabac989d1a9f16fa13202d7f5ccac52d9

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

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



import java.io.Serializable;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Date;

import java.util.HashMap;

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.DateUtil;

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 +26,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 +39,9 @@
   @Resource

   private PidOrderDao pidOrderDao;



   @Resource

   private LostOrderMapper lostOrderMapper;



   @Override

   public int addLostOrder(LostOrder lostOrder) {

      String orderId = lostOrder.getOrderId();

@@ -38,6 +49,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 +144,7 @@
         lostOrder.setState(2);

      }

      lostOrder.setHandleTime(System.currentTimeMillis());

      lostOrder.setResultCode(LostOrder.RESULT_CODE_VERFING);

      lostOrderDao.update(lostOrder);

   }



@@ -177,4 +202,236 @@
      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);

   }

	
	
   @Override

   public List<Map<String, Object>> countLostNum( Integer dateType, Integer resultCode, 
         String year, String startTime, String endTime) throws Exception {

		
      List<Map<String, Object>> list = lostOrderMapper.countLostNum(dateType, resultCode, year, startTime, endTime);

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

         return null;

      } 
		
      switch (dateType){

         case 1: // 按天处理

            return dayFactory(startTime, endTime, list);

         case 2: // 按月处理

            return monthFactory(list);

         case 3: 
            return yearFactory(list);

         default: 
            return null;

      }

   }

	
	
   @Override

   public List<Map<String, Object>> countAppealMoney( Integer dateType, String year, String startTime, 
         String endTime) throws Exception {

		
      List<Map<String, Object>> list = lostOrderMapper.countAppealMoney(dateType, year, startTime, endTime);

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

         return null;

      } 
		
      switch (dateType){

         case 1: // 按天处理

            return dayFactory(startTime, endTime, list);

         case 2: // 按月处理

            return monthFactory(list);

         case 3: 
            return yearFactory(list);

         default: 
            return null;

      }

   }

	
   public List<Map<String, Object>> dayFactory(String startTime, String endTime, List<Map<String, Object>> list) throws Exception {



      List<Map<String, Object>> listObject = new ArrayList<Map<String, Object>>();



      if (startTime.equals(endTime)) {



         Map<String, Object> map = list.get(0);

         Object total = map.get("showValue");

         if (total == null) {

            map.put("showValue", 0);

         }

         listObject.add(map);

         return listObject;

      }



      String plusDay = "";

      for (int i = 0; i < 1000; i++) {

         if (i == 0) {

            plusDay = startTime;

         } else {

            plusDay = DateUtil.plusDay(i, startTime);

         }



         Map<String, Object> mapObject = new HashMap<String, Object>();

         Object total = null;



         for (int j = 0; j < list.size(); j++) {

            Map<String, Object> map = list.get(j);

            Object createDate = map.get("showDate");

            String month = createDate.toString();

            if (plusDay.equalsIgnoreCase(month)) {

               total = map.get("showValue");

               break;

            }

         }



         if (total == null) {

            total = 0;

         }

         mapObject.put("showValue", total);



         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");

         SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy/MM/dd");

         Date parseDate = sdf.parse(plusDay.toString());



         mapObject.put("showDate", sdf2.format(parseDate));



         listObject.add(mapObject);



         if (plusDay.equals(endTime)) {

            break; // 时间结束

         }

      }



      return listObject;

   }



   public List<Map<String, Object>> monthFactory(List<Map<String, Object>> list) {



      List<Map<String, Object>> listObject = new ArrayList<Map<String, Object>>();

      // 12 个月处理

      for (int i = 1; i <= 12; i++) {

         Map<String, Object> mapObject = new HashMap<String, Object>();

         Object total = null;



         for (int j = 0; j < list.size(); j++) {

            Map<String, Object> map = list.get(j);

            Object createDate = map.get("showDate");

            String month = createDate.toString();

            if ((i + "").equalsIgnoreCase(month) || i == Integer.parseInt(month)) {

               total = map.get("total");

               break;

            }

         }



         if (total == null) {

            total = 0;

         }

         mapObject.put("total", total);



         mapObject.put("showDate", i + "月");



         listObject.add(mapObject);

      }

      return listObject;

   }



   public List<Map<String, Object>> yearFactory(List<Map<String, Object>> list) {



      List<Map<String, Object>> listObject = new ArrayList<Map<String, Object>>();



      for (int i = 0; i < list.size(); i++) {

         Map<String, Object> map = list.get(i);

         Object total = map.get("total");



         if (total == null) {

            total = 0;

         }

         map.put("total", total);



         listObject.add(map);

      }



      return listObject;

   }

}