zhenghaoyu
1 year ago
3 changed files with 228 additions and 34 deletions
@ -0,0 +1,36 @@
|
||||
package com.logpm.factory.excel; |
||||
|
||||
import com.alibaba.excel.annotation.ExcelProperty; |
||||
import lombok.Data; |
||||
|
||||
@Data |
||||
public class ExcelMode14 { |
||||
|
||||
@ExcelProperty(index = 0) |
||||
private String authCode; |
||||
@ExcelProperty(index = 1) |
||||
private String op_shipNo; |
||||
@ExcelProperty(index = 2) |
||||
private Integer warehouse_id; |
||||
@ExcelProperty(index = 3) |
||||
private String orderSelfNum; |
||||
@ExcelProperty(index = 4) |
||||
private String scan_time; |
||||
@ExcelProperty(index = 5) |
||||
private String scan_user; |
||||
@ExcelProperty(index = 6) |
||||
private String mctsTruck; |
||||
@ExcelProperty(index = 7) |
||||
private String siteName; |
||||
@ExcelProperty(index = 8) |
||||
private String firstPackName; |
||||
@ExcelProperty(index = 9) |
||||
private String secondPackName; |
||||
@ExcelProperty(index = 10) |
||||
private String thirdPackName; |
||||
@ExcelProperty(index = 11) |
||||
private String productname; |
||||
@ExcelProperty(index = 12) |
||||
private String CODE; |
||||
|
||||
} |
||||
@ -0,0 +1,79 @@
|
||||
package com.logpm.factory.listener; |
||||
|
||||
import cn.hutool.http.HttpRequest; |
||||
import cn.hutool.json.JSONUtil; |
||||
import com.alibaba.excel.context.AnalysisContext; |
||||
import com.alibaba.excel.event.AnalysisEventListener; |
||||
import com.alibaba.fastjson.JSON; |
||||
import com.alibaba.fastjson.JSONObject; |
||||
|
||||
import java.util.ArrayList; |
||||
import java.util.HashMap; |
||||
import java.util.List; |
||||
import java.util.Map; |
||||
|
||||
public class ExcelListener extends AnalysisEventListener { |
||||
|
||||
//自定义用于暂时存储data。
|
||||
//定义成静态变量，不过要注意的是我们try-catch导入逻辑的时候记得要在finally手动调用clear()方法，因为我们可能在解析excel的时候抛异常了，这个时候doAfterAllAnalysed()方法是不会执行的，如果没有清空静态变量的数据就会有脏数据（也就是上次解析成功的数据还在）
|
||||
public static List<Object> datas = new ArrayList<>(); |
||||
|
||||
@Override |
||||
public void invoke(Object object, AnalysisContext context) { |
||||
System.out.println("导入数据："+ JSONUtil.toJsonStr(object)); |
||||
// 这边可以进行其他操作，如直接存入数据库
|
||||
String s = JSONUtil.toJsonStr(object); |
||||
JSONObject jsonObject = JSONObject.parseObject(s); |
||||
Map<String,Object> reqMap = new HashMap<>(); |
||||
reqMap.put("authCode", jsonObject.getString("authCode")); |
||||
|
||||
// 收货单
|
||||
reqMap.put("op_shipNo", jsonObject.getString("op_shipNo")); |
||||
//仓库ID
|
||||
reqMap.put("warehouse_id", jsonObject.getInteger("warehouse_id")); |
||||
//订单自编号
|
||||
reqMap.put("orderSelfNum", jsonObject.getString("orderSelfNum")); |
||||
//扫描时间
|
||||
reqMap.put("scan_time", jsonObject.getString("scan_time")); |
||||
//扫描人
|
||||
reqMap.put("scan_user", ""); |
||||
//车次号
|
||||
reqMap.put("mctsTruck", jsonObject.getString("mctsTruck")); |
||||
//发货基地
|
||||
reqMap.put("siteName", jsonObject.getString("siteName")); |
||||
//一级品类
|
||||
reqMap.put("firstPackName", jsonObject.getString("firstPackName")); |
||||
//二级品类
|
||||
reqMap.put("secondPackName", jsonObject.getString("secondPackName")); |
||||
//三级品类
|
||||
reqMap.put("thirdPackName", jsonObject.getString("thirdPackName")); |
||||
//物料名称
|
||||
reqMap.put("productname", jsonObject.getString("productname")); |
||||
//包条码
|
||||
reqMap.put("unitNo", jsonObject.getString("CODE")); |
||||
|
||||
// 构建请求头
|
||||
String authCode = reqMap.get("authCode").toString(); |
||||
|
||||
String url = "http://twms.huitongys.com/openApi/newSystem.OptimsWarehouseScan/index"; |
||||
String body = HttpRequest.post(url).form(reqMap).header("token", authCode).execute().body(); |
||||
if (jodd.util.StringUtil.isNotBlank(body)) { |
||||
|
||||
JSONObject res = JSON.parseObject(body); |
||||
if ("200".equals(res.getString("code"))) { |
||||
System.out.println("处理成功："+jsonObject.getString("CODE")); |
||||
} |
||||
|
||||
} |
||||
} |
||||
|
||||
@Override |
||||
public void doAfterAllAnalysed(AnalysisContext context) { |
||||
datas.clear();//解析结束销毁不用的资源
|
||||
} |
||||
|
||||
public static void clear(){ |
||||
datas.clear(); |
||||
} |
||||
|
||||
} |
||||
Loading…
Reference in new issue