Browse Source

1.修正欧派的数据推送到系统

training
pref_mail@163.com 2 years ago
parent
commit
cebfd67f43
  1. 225
      blade-service/logpm-factory/src/test/java/com/logpm/factory/TestService.java
  2. 31
      blade-service/logpm-factory/src/test/java/com/logpm/factory/excel/JpDataMode.java

225
blade-service/logpm-factory/src/test/java/com/logpm/factory/TestService.java

@ -1,96 +1,129 @@
package com.logpm.factory;
import cn.hutool.http.HttpResponse;
import cn.hutool.http.HttpUtil;
import com.alibaba.excel.EasyExcel;
import com.alibaba.excel.EasyExcelFactory;
import com.alibaba.excel.annotation.ExcelProperty;
import com.alibaba.excel.metadata.BaseRowModel;
import com.alibaba.excel.metadata.Sheet;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.baomidou.mybatisplus.extension.conditions.update.UpdateChainWrapper;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.logpm.factory.comfac.controller.FactoryCommonController;
import com.logpm.factory.comfac.dto.UnloadCarDTO;
import com.logpm.factory.excel.ExcelMode;
import com.logpm.factory.mt.entity.MtFactoryOrderMain;
import com.logpm.factory.mt.entity.MtPushData;
import com.logpm.factory.mt.service.IMtFactoryDataService;
import com.logpm.factory.mt.service.IMtFactoryOrderMainService;
import com.logpm.factory.mt.service.IMtPushDataService;
import com.logpm.factory.mt.service.impl.MtFactoryDataServiceImpl;
import com.logpm.factory.oupai.service.IOuPaiFactoryService;
import com.logpm.factory.snm.vo.MTOrderPackageRelationVO;
import com.logpm.oldproject.entity.AdvanceDetailEntity;
import com.logpm.oldproject.feign.IAdvanceDetailClient;
import com.rabbitmq.client.Channel;
import lombok.Data;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springblade.core.test.BladeBootTest;
import org.springblade.core.test.BladeSpringExtension;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.api.ResultCode;
import org.springblade.core.tool.utils.StringUtil;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.beans.factory.annotation.Autowired;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.security.NoSuchAlgorithmException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;
@ExtendWith(BladeSpringExtension.class)
@BladeBootTest(appName = "logpm-factory-pref", enableLoader = true)
public class TestService {
// @Autowired
// private IOuPaiFactoryService ouPaiFactoryService;
//
//
//
public void test2() {
// ouPaiFactoryService.findOuPaiFactoryOrderDTOByCarCarNumber("LCD230505047");
// 获取Excle
Sheet sheet = new Sheet(1, 1, ExcelMode.class);
try {
List<Object> readList = EasyExcelFactory.read(new FileInputStream("f://order_status_log.xlsx"), sheet);
List<ExcelMode> list = new ArrayList<ExcelMode>();
for (Object obj : readList) {
ExcelMode t = (ExcelMode) obj;
JSONObject json = JSONObject.parseObject(t.getArgs());
System.out.println(json.getString("unitNo"));
//HttpResponse execute = HttpUtil.createPost("http://h5u.huitongys.com/api/logpm-factory/factory/common/sendOrderStatus").body(t.getArgs()).execute();
//System.out.println(execute.body());
}
} catch (FileNotFoundException e) {
e.printStackTrace();
}
}
}
//package com.logpm.factory;
//
//import cn.hutool.http.HttpResponse;
//import cn.hutool.http.HttpUtil;
//import com.alibaba.excel.EasyExcel;
//import com.alibaba.excel.EasyExcelFactory;
//import com.alibaba.excel.annotation.ExcelProperty;
//import com.alibaba.excel.metadata.BaseRowModel;
//import com.alibaba.excel.metadata.Sheet;
//import com.alibaba.fastjson.JSON;
//import com.alibaba.fastjson.JSONArray;
//import com.alibaba.fastjson.JSONObject;
//import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
//import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
//import com.baomidou.mybatisplus.extension.conditions.update.UpdateChainWrapper;
//import com.fasterxml.jackson.core.JsonProcessingException;
//import com.logpm.factory.comfac.controller.FactoryCommonController;
//import com.logpm.factory.comfac.dto.UnloadCarDTO;
//import com.logpm.factory.excel.ExcelMode;
//import com.logpm.factory.excel.JpDataMode;
//import com.logpm.factory.mt.entity.MtFactoryOrderMain;
//import com.logpm.factory.mt.entity.MtPushData;
//import com.logpm.factory.mt.service.IMtFactoryDataService;
//import com.logpm.factory.mt.service.IMtFactoryOrderMainService;
//import com.logpm.factory.mt.service.IMtPushDataService;
//import com.logpm.factory.mt.service.impl.MtFactoryDataServiceImpl;
//import com.logpm.factory.oupai.service.IOuPaiFactoryService;
//import com.logpm.factory.snm.vo.MTOrderPackageRelationVO;
//import com.logpm.oldproject.entity.AdvanceDetailEntity;
//import com.logpm.oldproject.feign.IAdvanceDetailClient;
//import com.rabbitmq.client.Channel;
//import lombok.Data;
//import org.junit.jupiter.api.Test;
//import org.junit.jupiter.api.extension.ExtendWith;
//import org.springblade.core.test.BladeBootTest;
//import org.springblade.core.test.BladeSpringExtension;
//import org.springblade.core.tool.api.R;
//import org.springblade.core.tool.api.ResultCode;
//import org.springblade.core.tool.utils.StringUtil;
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.rabbit.annotation.RabbitHandler;
//import org.springframework.beans.factory.annotation.Autowired;
//
//import java.io.*;
//import java.security.NoSuchAlgorithmException;
//import java.text.ParseException;
//import java.text.SimpleDateFormat;
//import java.util.*;
//import java.util.stream.Collectors;
//
//@ExtendWith(BladeSpringExtension.class)
//@BladeBootTest(appName = "logpm-factory-pref", enableLoader = true)
//public class TestService {
//
//
//// @Autowired
//// private IOuPaiFactoryService ouPaiFactoryService;
////
////
////
//
//
// @Test
// public void test2() {
//// ouPaiFactoryService.findOuPaiFactoryOrderDTOByCarCarNumber("LCD230505047");
//
// // 获取Excle
//
// try {
//
// File file = new File("F://response.json");
//
// BufferedReader reader = new BufferedReader(new FileReader(file));
//
// StringBuffer sb = new StringBuffer();
//
// while (true) {
// String ms = reader.readLine();
// if (StringUtil.isBlank(ms)) {
// break;
// }
// sb.append(ms);
// }
// JSONObject object = JSONObject.parseObject(sb.toString());
//
// JSONArray jsonArray = object.getJSONArray("rows");
//
// List<JpDataMode> ls = new ArrayList<>();
// for (int i = 0; i < jsonArray.size(); i++) {
// JpDataMode jpDataMode = new JpDataMode();
// JSONObject t = jsonArray.getJSONObject(i);
// String yjOrderNo =t.getString("yjOrderNo");
// String omsExtYsId =t.getString("omsExtYsId");
// String sendTime =t.getString("sendTime");
// String goodsNumber =t.getString("goodsNumber");
// String scanedNum =t.getString("scanedNum");
// String handedNum =t.getString("handedNum");
//
//
// jpDataMode.setOmsExtYsId(omsExtYsId);
// jpDataMode.setOrderId(yjOrderNo);
// jpDataMode.setGoodsNumber(goodsNumber);
// jpDataMode.setSendTime(sendTime);
// jpDataMode.setScanedNum(scanedNum);
// jpDataMode.setHandedNum(handedNum);
//
//
// ls.add(jpDataMode);
// }
//
//
//
//
// EasyExcel.write("F:\\11.xlsx").sheet("sheet1").doWrite(ls);
//
//
//
// } catch (FileNotFoundException e) {
// e.printStackTrace();
// } catch (IOException e) {
// e.printStackTrace();
// }
//
//
// }
//
//
//}
//

31
blade-service/logpm-factory/src/test/java/com/logpm/factory/excel/JpDataMode.java

@ -0,0 +1,31 @@
package com.logpm.factory.excel;
import com.alibaba.excel.annotation.ExcelProperty;
import com.alibaba.excel.metadata.BaseRowModel;
import lombok.Data;
@Data
public class JpDataMode extends BaseRowModel {
@ExcelProperty("DD单号")
private String orderId;
@ExcelProperty("YS单号")
private String omsExtYsId;
@ExcelProperty("发车时间")
private String sendTime;
@ExcelProperty("总件数")
private String goodsNumber;
@ExcelProperty("扫码入库数")
private String scanedNum;
@ExcelProperty("手动入库件数")
private String handedNum;
}
Loading…
Cancel
Save