Browse Source

1.欧派工厂对接数据拉取及处理到数据库

training
zhenghaoyu 2 years ago
parent
commit
46fc1860ad
  1. 29
      blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/entity/FactoryOrderEntity.java
  2. 17
      blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/entity/FactoryPackageEntity.java
  3. 4
      blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/ReceivingOrderMapper.java
  4. 3
      blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/IFactoryOrderService.java
  5. 6
      blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/IOuPaiFactoryService.java
  6. 17
      blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/FactoryOrderServiceImpl.java
  7. 2
      blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/OuPaiFactoryDataServiceImpl.java
  8. 304
      blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/OuPaiFactoryServiceImpl.java

29
blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/entity/FactoryOrderEntity.java

@ -22,7 +22,6 @@ import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.springblade.core.mp.base.BaseEntity;
import org.springblade.core.tenant.mp.TenantEntity;
import java.util.Date;
@ -72,32 +71,32 @@ public class FactoryOrderEntity extends BaseEntity {
* 订单状态 待送货:0 已签收:2 已取消:3 部分签收:6
*/
@ApiModelProperty(name = "订单状态 待送货:0 已签收:2 已取消:3 部分签收:6", notes = "")
private String factoryStatus;
private Integer factoryStatus;
/**
* 工厂发货状态 工厂未发货:0 工厂部分发货:1 工厂齐套发货:2
*/
@ApiModelProperty(name = "工厂发货状态 工厂未发货:0 工厂部分发货:1 工厂齐套发货:2", notes = "")
private String factoryShipStatus;
private Integer factoryShipStatus;
/**
* 工厂发货件数
*/
@ApiModelProperty(name = "工厂发货件数", notes = "")
private String factorySendQty;
private Integer factorySendQty;
/**
* 仓库收货状态 仓库未收货:0 仓库部分收货:1 仓库全部收货:2
*/
@ApiModelProperty(name = "仓库收货状态 仓库未收货:0 仓库部分收货:1 仓库全部收货:2", notes = "")
private String warehouseReceiveStatus;
private Integer warehouseReceiveStatus;
/**
* 仓库收货件数
*/
@ApiModelProperty(name = "仓库收货件数", notes = "")
private String warehouseReceiveQty;
private Integer warehouseReceiveQty;
/**
* 可预约状态 不可预约:0 可预约:1
*/
@ApiModelProperty(name = "可预约状态 不可预约:0 可预约:1", notes = "")
private String reservationStatus;
private Integer reservationStatus;
/**
* 所属门店
*/
@ -112,7 +111,7 @@ public class FactoryOrderEntity extends BaseEntity {
* 是否齐套
*/
@ApiModelProperty(name = "是否齐套", notes = "")
private String isMating;
private Integer isMating;
/**
* 品类编码
*/
@ -122,7 +121,7 @@ public class FactoryOrderEntity extends BaseEntity {
* 是否遗留
*/
@ApiModelProperty(name = "是否遗留", notes = "")
private String leave;
private Integer leave;
/**
* 客户名称
*/
@ -167,32 +166,32 @@ public class FactoryOrderEntity extends BaseEntity {
* 首次发货时间
*/
@ApiModelProperty(name = "首次发货时间", notes = "")
private String firstShipTime;
private Date firstShipTime;
/**
* 齐套发货时间
*/
@ApiModelProperty(name = "齐套发货时间", notes = "")
private String matingShipTime;
private Date matingShipTime;
/**
* 首次收货时间
*/
@ApiModelProperty(name = "首次收货时间", notes = "")
private String firstReceiveTime;
private Date firstReceiveTime;
/**
* 齐套收货时间
*/
@ApiModelProperty(name = "齐套收货时间", notes = "")
private String matingReceiveTime;
private Date matingReceiveTime;
/**
* 冻结
*/
@ApiModelProperty(name = "冻结", notes = "")
private String freeze;
private Integer freeze;
/**
* 发运时间
*/
@ApiModelProperty(name = "发运时间", notes = "")
private String outGoingTime;
private Date outGoingTime;
/**
* 状态
*/

17
blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/entity/FactoryPackageEntity.java

@ -22,7 +22,8 @@ import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.springblade.core.mp.base.BaseEntity;
import org.springblade.core.tenant.mp.TenantEntity;
import java.math.BigDecimal;
/**
* 欧派工厂包件 实体类
@ -63,7 +64,7 @@ public class FactoryPackageEntity extends BaseEntity {
private String thirdClassName ;
/** 补进 */
@ApiModelProperty(name = "补进",notes = "")
private String buyin ;
private Integer buyin ;
/** 合包码 */
@ApiModelProperty(name = "合包码",notes = "")
private String cosourcingCode ;
@ -75,22 +76,22 @@ public class FactoryPackageEntity extends BaseEntity {
private Integer packageStatus ;
/** 长(米) */
@ApiModelProperty(name = "长(米)",notes = "")
private String length ;
private BigDecimal length ;
/** 宽(米) */
@ApiModelProperty(name = "宽(米)",notes = "")
private String width ;
private BigDecimal width ;
/** 宽(米) */
@ApiModelProperty(name = "宽(米)",notes = "")
private String height ;
private BigDecimal height ;
/** 宽(米) */
@ApiModelProperty(name = "宽(米)",notes = "")
private String weight ;
private BigDecimal weight ;
/** 是否库存品包 */
@ApiModelProperty(name = "是否库存品包",notes = "")
private String isInventory ;
private Integer isInventory ;
/** 是否冻结 */
@ApiModelProperty(name = "是否冻结",notes = "")
private String freeze ;
private Integer freeze ;
/** 入库单状态 0正常 1作废 */
@ApiModelProperty(name = "入库单状态 0正常 1作废",notes = "")
private Integer receiptStatus ;

4
blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/ReceivingOrderMapper.java

@ -16,12 +16,11 @@
*/
package com.logpm.factory.oupai.mapper;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.logpm.factory.oupai.entity.ReceivingOrderEntity;
import com.logpm.factory.oupai.vo.ReceivingOrderVO;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
@ -31,6 +30,7 @@ import java.util.List;
* @author pref
* @since 2023-08-23
*/
@Mapper
public interface ReceivingOrderMapper extends BaseMapper<ReceivingOrderEntity> {
/**

3
blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/IFactoryOrderService.java

@ -39,6 +39,5 @@ public interface IFactoryOrderService extends BaseService<FactoryOrderEntity> {
IPage<FactoryOrderVO> selectFactoryOrderPage(IPage<FactoryOrderVO> page, FactoryOrderVO factoryOrder);
FactoryOrderEntity selectEntityBySelfCode(String selfCode);
}

6
blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/IOuPaiFactoryService.java

@ -1,9 +1,5 @@
package com.logpm.factory.oupai.service;
import com.logpm.factory.oupai.dto.OuPaiFactoryOrderDTO;
import java.util.List;
public interface IOuPaiFactoryService {
@ -12,7 +8,7 @@ public interface IOuPaiFactoryService {
* @param CarNumber
* @return
*/
List<OuPaiFactoryOrderDTO> findOuPaiFactoryOrderDTOByCarCarNumber(String CarNumber);
void findOuPaiFactoryOrderDTOByCarCarNumber(String CarNumber);
}

17
blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/FactoryOrderServiceImpl.java

@ -16,18 +16,15 @@
*/
package com.logpm.factory.oupai.service.impl;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.logpm.factory.oupai.entity.FactoryOrderEntity;
import com.logpm.factory.oupai.excel.FactoryOrderExcel;
import com.logpm.factory.oupai.mapper.FactoryOrderMapper;
import com.logpm.factory.oupai.service.IFactoryOrderService;
import com.logpm.factory.oupai.vo.FactoryOrderVO;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* 欧派工厂订单 服务实现类
*
@ -42,14 +39,12 @@ public class FactoryOrderServiceImpl extends BaseServiceImpl<FactoryOrderMapper,
return page.setRecords(baseMapper.selectFactoryOrderPage(page, factoryOrder));
}
@Override
public List<FactoryOrderExcel> exportFactoryOrder(Wrapper<FactoryOrderEntity> queryWrapper) {
List<FactoryOrderExcel> factoryOrderList = baseMapper.exportFactoryOrder(queryWrapper);
//factoryOrderList.forEach(factoryOrder -> {
// factoryOrder.setTypeName(DictCache.getValue(DictEnum.YES_NO, FactoryOrder.getType()));
//});
return factoryOrderList;
public FactoryOrderEntity selectEntityBySelfCode(String selfCode) {
QueryWrapper<FactoryOrderEntity> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("self_code",selfCode);
return baseMapper.selectOne(queryWrapper);
}
}

2
blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/OuPaiFactoryDataServiceImpl.java

@ -21,7 +21,7 @@ public class OuPaiFactoryDataServiceImpl implements IOuPaiFactoryDataService {
@Override
public Long saveData(OuPaiDataPushVO ouPaiDataPushVO) {
// 获取需要处理的数据
// 获取需要处理的数据并存入数据库
ouPaiFactoryService.findOuPaiFactoryOrderDTOByCarCarNumber(ouPaiDataPushVO.getCarNum());

304
blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/OuPaiFactoryServiceImpl.java

@ -2,21 +2,25 @@ package com.logpm.factory.oupai.service.impl;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import cn.hutool.json.JSON;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSONPObject;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.logpm.factory.oupai.dto.OuPaiFactoryOrderDTO;
import com.logpm.factory.oupai.dto.OuPaiFactoryOrderPackageDTO;
import com.logpm.factory.oupai.entity.FactoryOrderEntity;
import com.logpm.factory.oupai.entity.FactoryPackageEntity;
import com.logpm.factory.oupai.entity.ReceivingOrderEntity;
import com.logpm.factory.oupai.mapper.ReceivingOrderMapper;
import com.logpm.factory.oupai.service.IFactoryOrderService;
import com.logpm.factory.oupai.service.IFactoryPackageService;
import com.logpm.factory.oupai.service.IOuPaiFactoryService;
import com.logpm.factory.props.OuPaiProperties;
import lombok.extern.slf4j.Slf4j;
import org.springblade.common.exception.CustomerException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Date;
import java.util.Objects;
@Slf4j
@Service
@ -25,8 +29,17 @@ public class OuPaiFactoryServiceImpl implements IOuPaiFactoryService {
@Autowired
private OuPaiProperties ouPaiProperties;
@Autowired
private ReceivingOrderMapper receivingOrderMapper;
@Autowired
private IFactoryOrderService factoryOrderService;
@Autowired
private IFactoryPackageService factoryPackageService;
@Override
public List<OuPaiFactoryOrderDTO> findOuPaiFactoryOrderDTOByCarCarNumber(String carNumber) {
public void findOuPaiFactoryOrderDTOByCarCarNumber(String carNumber) {
// 查询工厂数据
@ -35,9 +48,6 @@ public class OuPaiFactoryServiceImpl implements IOuPaiFactoryService {
// 对返回i的数据进行处理 按照 发车单-->订单-->包件 完成保存
handleData(ourPaiDataByCarNumber);
return null;
}
/**
@ -45,8 +55,263 @@ public class OuPaiFactoryServiceImpl implements IOuPaiFactoryService {
* @param ourPaiDataByCarNumber
*/
private void handleData(JSONArray ourPaiDataByCarNumber) {
// ourPaiDataByCarNumber/
log.info("############handleData: 数据处理开始");
Date start = new Date();
//循环出来jsonArray
for (int i=0;i<ourPaiDataByCarNumber.size();i++){
JSONObject valueObject = ourPaiDataByCarNumber.getJSONObject(i);
if(Objects.isNull(valueObject)){
log.warn("############handleData: value中没有数据");
throw new CustomerException(403,"value中没有数据");
}
JSONObject fromWarehouse = valueObject.getJSONObject("FromWarehouse");
JSONObject currentWarehouse = valueObject.getJSONObject("CurrentWarehouse");
JSONObject endWarehouse = valueObject.getJSONObject("EndWarehouse");
String code = valueObject.getString("Code");
//新发车单数据
ReceivingOrderEntity receivingOrderEntity = new ReceivingOrderEntity();
receivingOrderEntity.setCode(code);
String type = valueObject.getString("Type");
if("中转".equals(type)){
receivingOrderEntity.setType(1);
}else if("配送".equals(type)){
receivingOrderEntity.setType(2);
}else{
receivingOrderEntity.setType(0);
}
if(!Objects.isNull(currentWarehouse)){
receivingOrderEntity.setCurrentWarehouseCode(currentWarehouse.getString("Code"));
receivingOrderEntity.setCurrentWarehouseName(currentWarehouse.getString("Name"));
}
if(!Objects.isNull(fromWarehouse)){
receivingOrderEntity.setFromWarehouseCode(fromWarehouse.getString("Code"));
receivingOrderEntity.setCurrentWarehouseName(fromWarehouse.getString("Name"));
}
if(!Objects.isNull(endWarehouse)){
receivingOrderEntity.setEndWarehouseCode(endWarehouse.getString("Code"));
receivingOrderEntity.setEndWarehouseName(endWarehouse.getString("Name"));
}
receivingOrderEntity.setPackagesCount(valueObject.getInteger("PackagesCount"));
receivingOrderEntity.setReceivePackageCount(valueObject.getInteger("ReceivePackageCount"));
String status = valueObject.getString("Status");
if("待收货".equals(status)){
receivingOrderEntity.setFactoryStatus("0");
}else if("已收货".equals(status)){
receivingOrderEntity.setFactoryStatus("1");
}else if("收货中".equals(status)){
receivingOrderEntity.setFactoryStatus("2");
}else if("已跳过".equals(status)){
receivingOrderEntity.setFactoryStatus("3");
}
receivingOrderEntity.setPlate(valueObject.getString("Plate"));
receivingOrderEntity.setPlateNum(valueObject.getString("PlateNum"));
receivingOrderEntity.setCarNumber(valueObject.getString("CarNumber"));
receivingOrderEntity.setCarrierCode(valueObject.getString("CarrierCode"));
receivingOrderEntity.setSendTime(valueObject.getDate("SendTime"));
receivingOrderEntity.setArrivalTime(valueObject.getDate("ArrivalTime"));
receivingOrderEntity.setReceiveTime(valueObject.getDate("ReceiveTime"));
receivingOrderEntity.setReturnNumber(valueObject.getString("ReturnNumber"));
receivingOrderEntity.setStatus(0);
receivingOrderEntity.setReceiptStatus(0);
receivingOrderEntity.setPushStatus(0);
receivingOrderEntity.setTurnStatus(0);
int row = receivingOrderMapper.insert(receivingOrderEntity);
if(row == 1){
log.info("############handleData: 保存发货单数据 成功成功成功成功 code={}",code);
Long receivingId = receivingOrderEntity.getId();//发货单id
JSONArray packages = valueObject.getJSONArray("Packages");
for (int j = 0; j < packages.size(); j++) {
JSONObject packageEntity = packages.getJSONObject(j);//包件信息
JSONObject orderEntity = packageEntity.getJSONObject("Order");//订单信息
String selfCode = orderEntity.getString("SelfCode");//订单自编码
//先查询是否存在订单自编码
FactoryOrderEntity factoryOrderEntity = factoryOrderService.selectEntityBySelfCode(selfCode);
if(Objects.isNull(factoryOrderEntity)){
factoryOrderEntity = new FactoryOrderEntity();
factoryOrderEntity.setCode(orderEntity.getString("Code"));
factoryOrderEntity.setSelfCode(selfCode);
factoryOrderEntity.setContractNumber(orderEntity.getString("ContractNumber"));
factoryOrderEntity.setServiceNumber(orderEntity.getString("ServiceNumber"));
factoryOrderEntity.setOrderClass(orderEntity.getString("OrderClass"));
factoryOrderEntity.setOrderType(orderEntity.getString("OrderType"));
String factoryStatus = orderEntity.getString("Status");
if("待送货".equals(factoryStatus)){
factoryOrderEntity.setFactoryStatus(0);
}else if("已签收".equals(factoryStatus)){
factoryOrderEntity.setFactoryStatus(2);
}else if("已取消".equals(factoryStatus)){
factoryOrderEntity.setFactoryStatus(3);
}else if("部分签收".equals(factoryStatus)){
factoryOrderEntity.setFactoryStatus(6);
}
String factoryShipStatus = orderEntity.getString("FactoryShipStatus");
if("工厂未发货".equals(factoryShipStatus)){
factoryOrderEntity.setFactoryShipStatus(0);
}else if("工厂部分发货".equals(factoryShipStatus)){
factoryOrderEntity.setFactoryShipStatus(1);
}else if("工厂齐套发货".equals(factoryShipStatus)){
factoryOrderEntity.setFactoryShipStatus(2);
}
factoryOrderEntity.setFactorySendQty(orderEntity.getInteger("FactorySendQty"));
String warehouseReceiveStatus = orderEntity.getString("WarehouseReceiveStatus");
if("仓库未收货".equals(warehouseReceiveStatus)){
factoryOrderEntity.setWarehouseReceiveStatus(0);
}else if("仓库部分收货".equals(warehouseReceiveStatus)){
factoryOrderEntity.setWarehouseReceiveStatus(1);
}else if("仓库全部收货".equals(warehouseReceiveStatus)){
factoryOrderEntity.setWarehouseReceiveStatus(2);
}
factoryOrderEntity.setWarehouseReceiveQty(orderEntity.getInteger("WarehouseReceiveQty"));
String reservationStatus = orderEntity.getString("ReservationStatus");
if("不可预约".equals(reservationStatus)){
factoryOrderEntity.setReservationStatus(0);
}else if("可预约".equals(reservationStatus)){
factoryOrderEntity.setReservationStatus(1);
}
factoryOrderEntity.setStore("");//TODO 没有找到门店字段
factoryOrderEntity.setMatingCode(orderEntity.getString("MatingCode"));
Boolean isMating = orderEntity.getBoolean("IsMating");
if(isMating){
factoryOrderEntity.setIsMating(1);
}else{
factoryOrderEntity.setIsMating(0);
}
factoryOrderEntity.setFirstClassCode(orderEntity.getString("FirstClassCode"));
Boolean leave = orderEntity.getBoolean("Leave");
if(leave){
factoryOrderEntity.setLeave(1);
}else{
factoryOrderEntity.setLeave(0);
}
factoryOrderEntity.setCustomer(orderEntity.getString("Customer"));
factoryOrderEntity.setProvince(orderEntity.getString("Province"));
factoryOrderEntity.setCity(orderEntity.getString("City"));
factoryOrderEntity.setCustomerAddress(orderEntity.getString("CustomerAddress"));
factoryOrderEntity.setCustomerPhone(orderEntity.getString("CustomerPhone"));
factoryOrderEntity.setShopReceiver(orderEntity.getString("ShopReceiver"));
factoryOrderEntity.setBrandCode(orderEntity.getString("BrandCode"));
factoryOrderEntity.setBrandName(orderEntity.getString("BrandName"));
factoryOrderEntity.setFirstShipTime(orderEntity.getDate("FirstShipTime"));
factoryOrderEntity.setMatingShipTime(orderEntity.getDate("MatingShipTime"));
factoryOrderEntity.setFirstReceiveTime(orderEntity.getDate("FirstReceiveTime"));
factoryOrderEntity.setMatingReceiveTime(orderEntity.getDate("MatingReceiveTime"));
Boolean freeze = orderEntity.getBoolean("Freeze");
if(freeze){
factoryOrderEntity.setFreeze(1);
}else{
factoryOrderEntity.setFreeze(0);
}
factoryOrderEntity.setOutGoingTime(orderEntity.getDate("OutGoingTime"));
factoryOrderEntity.setStatus(0);
factoryOrderEntity.setReceivingId(receivingId);
factoryOrderEntity.setReceiptStatus(0);
factoryOrderEntity.setPushStatus(0);
factoryOrderEntity.setTurnStatus(0);
boolean save = factoryOrderService.save(factoryOrderEntity);
if(save){
//保存订单成功,继续保存包件
Long orderId = factoryOrderEntity.getId();
String packageCode = packageEntity.getString("Code");
QueryWrapper<FactoryPackageEntity> packageEntityQueryWrapper = new QueryWrapper<>();
packageEntityQueryWrapper.eq("code",packageCode);
FactoryPackageEntity factoryPackageEntity = factoryPackageService.getOne(packageEntityQueryWrapper);
if(Objects.isNull(factoryPackageEntity)){
factoryPackageEntity = new FactoryPackageEntity();
factoryPackageEntity.setOrderId(orderId);
factoryPackageEntity.setCode(packageCode);
factoryPackageEntity.setFirstClassCode(packageEntity.getString("FirstClassCode"));
factoryPackageEntity.setFirstClassCode(packageEntity.getString("FirstClassName"));
factoryPackageEntity.setSecondClassCode(packageEntity.getString("SecondClassCode"));
factoryPackageEntity.setSecondClassName(packageEntity.getString("secondClassName"));
factoryPackageEntity.setThirdClassCode(packageEntity.getString("ThirdClassCode"));
factoryPackageEntity.setThirdClassName(packageEntity.getString("ThirdClassName"));
Boolean buyIn = packageEntity.getBoolean("BuyIn");
if(buyIn){
factoryPackageEntity.setBuyin(1);
}else{
factoryPackageEntity.setBuyin(0);
}
factoryPackageEntity.setCosourcingCode(packageEntity.getString("CosourcingCode"));
factoryPackageEntity.setCosourcingUnit(packageEntity.getString("CosourcingUnit"));
String packageStatus = packageEntity.getString("PackageStatus");
//未知:0 已调度:1 已装车:2 待收货:3 已收货:4 已在库:5 待理货:6 待上架:7 已上架:8 已下架:9 已发运:10 已签收:11 待返货:12 已提件:13 已拒收:14 异常:-1
if("已调度".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(1);
}else if("已装车".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(2);
}else if("待收货".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(3);
}else if("已收货".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(4);
}else if("已在库".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(5);
}else if("待理货".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(6);
}else if("待上架".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(7);
}else if("已上架".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(8);
}else if("已下架".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(9);
}else if("已发运".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(10);
}else if("已签收".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(11);
}else if("待返货".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(12);
}else if("已提件".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(13);
}else if("已拒收".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(14);
}else if("异常".equals(packageStatus)){
factoryPackageEntity.setPackageStatus(-1);
}else{
factoryPackageEntity.setPackageStatus(0);
}
factoryPackageEntity.setLength(packageEntity.getBigDecimal("Length"));
factoryPackageEntity.setWidth(packageEntity.getBigDecimal("Width"));
factoryPackageEntity.setHeight(packageEntity.getBigDecimal("Height"));
factoryPackageEntity.setWeight(packageEntity.getBigDecimal("Weight"));
Boolean isInventory = packageEntity.getBoolean("IsInventory");
if(isInventory){
factoryPackageEntity.setIsInventory(1);
}else{
factoryPackageEntity.setIsInventory(0);
}
Boolean packageFreeze = packageEntity.getBoolean("Freeze");
if(packageFreeze){
factoryPackageEntity.setFreeze(1);
}else{
factoryPackageEntity.setFreeze(0);
}
//保存包件信息
factoryPackageService.save(factoryPackageEntity);
}else{
log.warn("############handleData: 包件码已存在 packageCode={}",packageCode);
throw new CustomerException(403,"包件码已存在");
}
}else{
log.warn("############handleData: 保存订单失败 selfCode={}",selfCode);
throw new CustomerException(403,"保存订单失败");
}
}
}
}else{
log.warn("############handleData: 保存发货单数据失败 code={}",code);
throw new CustomerException(403,"保存发货单数据失败");
}
Date end = new Date();
long startLong = start.getTime();
long endLong = end.getTime();
long l = endLong - startLong;
log.info("############handleData: 数据处理完成 耗时 {} 毫秒",l);
}
}
@ -59,7 +324,7 @@ public class OuPaiFactoryServiceImpl implements IOuPaiFactoryService {
*/
private JSONArray findOurPaiDataByCarNumber(String carNumber) {
String url = ouPaiProperties.getUri() + "tims_odata_api/api/odata/ReceivingOrder?$filter=CarNumber eq '"+carNumber+"'&select=Code,Type,Status,Plate,PlateNum,CarNumber,CarrierCode,SendTime,ArrivalTime,ReceiveTime,CreateTime,ReturnNumber\n" +
String url = ouPaiProperties.getUri() + "tims_odata_api/api/odata/ReceivingOrder?$filter=CarNumber eq '"+carNumber+"'&select=Code,Type,Status,Plate,PlateNum,CarNumber,CarrierCode,PackagesCount,ReceivePackageCount,SendTime,ArrivalTime,ReceiveTime,CreateTime,ReturnNumber\n" +
"&$expand=Packages($select=Code,PdaNumber,FirstClassCode,FirstClassName,SecondClassCode,SecondClassName,ThirdClassCode,ThirdClassName,BuyIn,CosourcingCode,CosourcingUnit,SortingCenter,DistributionCenter,Length,Width,Height,Weight,PackageDetails,OrderDetail,Order,PathIndex,PathDetail,DeliveryOrders,ReceivingOrders,LPN,LpnSerialNum,IsEntruck,ReservationOrder,OutGoingOrderDetail,SignBill,IsInventory,Inventories,InventoryInDetails,Freeze,OutGoingOrderDetailInventoryDetail,From,Creator,CreateTime,ShipTime,CarNumber,DeliveryMethod,DeliveryReceiver,DeliveryReceiverPhone,ReturnNumber,GroupType,CarrierCode,CarrierName,PackageDetailNames,ReceivingTime,SendTime,ExceptionSignRemark,Descript,SignTime,OutOrder,IsReceiveByHand,PackageStatus;\n" +
"$expand=Order($select=" +
"Code,SelfCode,ContractNumber,ServiceNumber,OrderClass,OrderType,Status,FactoryShipStatus,FactorySendQty,WarehouseReceiveStatus,WarehouseReceiveQty,ReservationStatus,Store,MatingCode,IsMating,FirstClassCode,Leave,Customer,Province,City,CustomerAddress,CustomerPhone,ShopReceiver,BrandCode,BrandName,From,OutGoingTime,CreateTime,Freeze,FirstShipTime,MatingShipTime,FirstReceiveTime,MatingReceiveTime\n" +
@ -75,11 +340,8 @@ public class OuPaiFactoryServiceImpl implements IOuPaiFactoryService {
String result = httpResponse.body();
log.info(">>> findOurPaiDataByCarNumber result {}", result);
// 获取返回内容
JSONObject jsonObject = new JSONObject(result);
JSONObject jsonObject = JSONObject.parseObject(result);
JSONArray resultArray = jsonObject.getJSONArray("value");
return resultArray;
}
@ -96,8 +358,8 @@ public class OuPaiFactoryServiceImpl implements IOuPaiFactoryService {
JSONObject json = new JSONObject();
json.set("userName", ouPaiProperties.getUserName());
json.set("password", ouPaiProperties.getPassword());
json.put("userName", ouPaiProperties.getUserName());
json.put("password", ouPaiProperties.getPassword());
String data = json.toString();
HttpResponse httpResponse = HttpRequest.post(url).body(data).execute();

Loading…
Cancel
Save