新后台订单上传

喻健

2018-11-12 3bb8dc295880450581e8ca84b2b3b14d73944f46

 fanli/src/main/java/com/yeshi/fanli/controller/admin/UploadController.java

@@ -1,8 +1,13 @@
package com.yeshi.fanli.controller.admin;



import java.io.BufferedWriter;

import java.io.File;

import java.io.FileWriter;

import java.io.IOException;

import java.io.InputStream;

import java.io.PrintWriter;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import java.util.UUID;



@@ -12,6 +17,7 @@


import net.sf.json.JSONObject;



import org.springframework.core.task.TaskExecutor;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

@@ -20,14 +26,21 @@
import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.tencentcloud.COSManager;



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

import com.yeshi.fanli.entity.common.AdminUser;

import com.yeshi.fanli.entity.taobao.ScanHistory;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.entity.taobao.TaoBaoOrder;

import com.yeshi.fanli.service.AdminUserService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoService;

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

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

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.ThreadUtil;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.annotation.RequestNoLogin;

import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;



@Controller

@RequestMapping("admin/new/api/v1/upload")

@@ -44,6 +57,10 @@
   

   @Resource

   private AdminUserService adminUserService;

	
   @Resource(name = "taskExecutor")

   private TaskExecutor executor;

	
   



   // private static final String PAYSUCCESS = "支付成功";

@@ -146,6 +163,7 @@
    * @param response

    * @param out

    */

   @RequestNoLogin()

   @RequestMapping(value = "uploadOrderFile")

   public void uploadOrderFile(@RequestParam("file") CommonsMultipartFile file, Long uid,

          HttpServletRequest request, HttpServletResponse response, PrintWriter out) {

@@ -164,17 +182,31 @@
         return;

      }

      

      List<TaoBaoOrder> orderList = null ;

      try {

         List<TaoBaoOrder> orderList = TaoBaoOrderUtil.parseOrder(file.getInputStream());

			
         orderProcessService.processOrder(TaoBaoOrderUtil.classifyTaoBaoOrderByOrderId(orderList));

			
         out.print(JsonUtil.loadTrueResult("上传成功"));

		
         orderList = TaoBaoOrderUtil.parseOrder(file.getInputStream());

         out.print(JsonUtil.loadTrueResult("上传文件成功"));

      } catch (IOException e) {

         out.print(JsonUtil.loadFalseResult("上传文件失败"));

         e.printStackTrace();

         out.print(JsonUtil.loadFalseResult("上传异常"));

      }

		
      final List<TaoBaoOrder> list = orderList;

		
      executor.execute(new Runnable() {

         @Override

         public void run() {

            try {

					
               orderProcessService.processOrder(TaoBaoOrderUtil.classifyTaoBaoOrderByOrderId(list));

					
            } catch (Exception e) {

               e.printStackTrace();

            }



         }

      });

			
   }

   

}