From 3bb8dc295880450581e8ca84b2b3b14d73944f46 Mon Sep 17 00:00:00 2001 From: 喻健 <喻健@Admin> Date: 星期一, 12 十一月 2018 11:52:06 +0800 Subject: [PATCH] 新后台订单上传 --- fanli/src/main/java/com/yeshi/fanli/controller/admin/UploadController.java | 96 ++++++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 88 insertions(+), 8 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/admin/UploadController.java b/fanli/src/main/java/com/yeshi/fanli/controller/admin/UploadController.java index be0c54a..dad3056 100644 --- a/fanli/src/main/java/com/yeshi/fanli/controller/admin/UploadController.java +++ b/fanli/src/main/java/com/yeshi/fanli/controller/admin/UploadController.java @@ -1,29 +1,46 @@ 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; import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +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; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.multipart.commons.CommonsMultipartFile; - -import com.yeshi.fanli.entity.taobao.TaoBaoOrder; -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.TimeUtil; -import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil; import org.yeshi.utils.JsonUtil; import org.yeshi.utils.tencentcloud.COSManager; -import net.sf.json.JSONObject; +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") @@ -37,6 +54,14 @@ @Resource private OrderProcessService orderProcessService; + + @Resource + private AdminUserService adminUserService; + + @Resource(name = "taskExecutor") + private TaskExecutor executor; + + // private static final String PAYSUCCESS = "鏀粯鎴愬姛"; // private static final String ORDERCLOSE="璁㈠崟鍏抽棴"; @@ -129,4 +154,59 @@ } + + /** + * 鏂板悗鍙扮 涓婁紶璁㈠崟鏂囦欢 + * @param file excel鏂囦欢 + * @param uid 褰撳墠鐢ㄦ埛id + * @param request + * @param response + * @param out + */ + @RequestNoLogin() + @RequestMapping(value = "uploadOrderFile") + public void uploadOrderFile(@RequestParam("file") CommonsMultipartFile file, Long uid, + HttpServletRequest request, HttpServletResponse response, PrintWriter out) { + + response.setHeader("Access-Control-Allow-Origin", "*"); + response.setHeader("Access-Control-Allow-Methods", "*"); + + AdminUser admin = adminUserService.selectByPrimaryKey(uid); + if (admin == null) { + out.print(JsonUtil.loadFalseResult("鐢ㄦ埛楠岃瘉鏈�氳繃")); + return; + } + + if (file == null) { + out.print(JsonUtil.loadFalseResult("涓婁紶鏂囦欢涓嶈兘涓虹┖")); + return; + } + + List<TaoBaoOrder> orderList = null ; + try { + orderList = TaoBaoOrderUtil.parseOrder(file.getInputStream()); + out.print(JsonUtil.loadTrueResult("涓婁紶鏂囦欢鎴愬姛")); + } catch (IOException e) { + out.print(JsonUtil.loadFalseResult("涓婁紶鏂囦欢澶辫触")); + e.printStackTrace(); + } + + final List<TaoBaoOrder> list = orderList; + + executor.execute(new Runnable() { + @Override + public void run() { + try { + + orderProcessService.processOrder(TaoBaoOrderUtil.classifyTaoBaoOrderByOrderId(list)); + + } catch (Exception e) { + e.printStackTrace(); + } + + } + }); + + } + } -- Gitblit v1.8.0