优化TOC日志推送功能

This commit is contained in:
liuy 2024-09-05 12:06:51 +08:00
parent 962e40ff3b
commit 45bcbbf2e9
20 changed files with 3308 additions and 2125 deletions

View File

@ -0,0 +1,21 @@
package com.hzya.frame.plugin.lets.ofs.dao;
import com.hzya.frame.plugin.lets.ofs.entity.TocofsSaleoutEntity;
import com.hzya.frame.basedao.dao.IBaseDao;
import java.util.List;
/**
* root(tocofs_saleout: table)表数据库访问层
*
* @author makejava
* @since 2024-08-01 17:01:32
*/
public interface ITocofsSaleoutDao extends IBaseDao<TocofsSaleoutEntity, String> {
/**
* 批量插入主表信息
*
* @author liuyang
*/
void entityInsertBatchV2(List<TocofsSaleoutEntity> tocofsSaleoutEntityList) throws Exception;
}

View File

@ -6,16 +6,18 @@ import com.hzya.frame.basedao.dao.IBaseDao;
import java.util.List; import java.util.List;
/** /**
* root(tocofs_saleout: table)表数据库访问层 * O出库单表头(TOCTOB业务底表)(tocofs_saleout: table)表数据库访问层
* *
* @author makejava * @author makejava
* @since 2024-08-01 17:01:32 * @since 2024-09-04 17:48:16
*/ */
public interface ITocofsSaleoutDao extends IBaseDao<TocofsSaleoutEntity, String> { public interface ITocofsSaleoutDao extends IBaseDao<TocofsSaleoutEntity, String> {
/** /**
* 批量插入主表信息 * 批量查询或者更新
* *
* @author liuyang * @author liuyang
*/ */
void entityInsertBatchV2(List<TocofsSaleoutEntity> tocofsSaleoutEntityList) throws Exception; void entityInsertOrUpdateBatch(List<TocofsSaleoutEntity> tocofsSaleoutEntityList) throws Exception;
} }

View File

@ -6,18 +6,18 @@ import com.hzya.frame.basedao.dao.IBaseDao;
import java.util.List; import java.util.List;
/** /**
* tocofs_saleout_detailed(tocofs_saleout_detailed: table)表数据库访问层 * O出库单明细表(TOCTOB业务底表)(tocofs_saleout_detailed: table)表数据库访问层
* *
* @author makejava * @author makejava
* @since 2024-08-01 17:01:53 * @since 2024-09-04 17:48:28
*/ */
public interface ITocofsSaleoutDetailedDao extends IBaseDao<TocofsSaleoutDetailedEntity, String> { public interface ITocofsSaleoutDetailedDao extends IBaseDao<TocofsSaleoutDetailedEntity, String> {
/** /**
* 批量查询明细信息 * 批量插入或者更新
* *
* @author liuyang * @author liuyang
*/ */
void entityInsertBatchV2(List<TocofsSaleoutDetailedEntity> tocofsSaleoutDetailedEntity) throws Exception; void entityInsertOrUpdateBatch(List<TocofsSaleoutDetailedEntity> tocofsSaleoutDetailedEntities) throws Exception;
} }

View File

@ -8,14 +8,15 @@ import com.hzya.frame.basedao.dao.MybatisGenericDao;
import java.util.List; import java.util.List;
/** /**
* root(TocofsSaleout)表数据库访问层 * O出库单表头(TOCTOB业务底表)(TocofsSaleout)表数据库访问层
* *
* @author makejava * @author makejava
* @since 2024-08-01 17:01:32 * @since 2024-09-04 17:48:16
*/ */
public class TocofsSaleoutDaoImpl extends MybatisGenericDao<TocofsSaleoutEntity, String> implements ITocofsSaleoutDao { public class TocofsSaleoutDaoImpl extends MybatisGenericDao<TocofsSaleoutEntity, String> implements ITocofsSaleoutDao {
@Override @Override
public void entityInsertBatchV2(List<TocofsSaleoutEntity> tocofsSaleoutEntityList) throws Exception { public void entityInsertOrUpdateBatch(List<TocofsSaleoutEntity> tocofsSaleoutEntityList) throws Exception {
this.insert("com.hzya.frame.plugin.lets.ofs.dao.impl.TocofsSaleoutDaoImpl.entityInsertBatchV2", tocofsSaleoutEntityList); insert("com.hzya.frame.plugin.lets.ofs.dao.impl.TocofsSaleoutDaoImpl.entityInsertOrUpdateBatch", tocofsSaleoutEntityList);
} }
} }

View File

@ -0,0 +1,21 @@
package com.hzya.frame.plugin.lets.ofs.dao.impl;
import com.hzya.frame.plugin.lets.ofs.entity.TocofsSaleoutEntity;
import com.hzya.frame.plugin.lets.ofs.dao.ITocofsSaleoutDao;
import org.springframework.stereotype.Repository;
import com.hzya.frame.basedao.dao.MybatisGenericDao;
import java.util.List;
/**
* root(TocofsSaleout)表数据库访问层
*
* @author makejava
* @since 2024-08-01 17:01:32
*/
public class TocofsSaleoutDaoImpl extends MybatisGenericDao<TocofsSaleoutEntity, String> implements ITocofsSaleoutDao {
@Override
public void entityInsertBatchV2(List<TocofsSaleoutEntity> tocofsSaleoutEntityList) throws Exception {
this.insert("com.hzya.frame.plugin.lets.ofs.dao.impl.TocofsSaleoutDaoImpl.entityInsertBatchV2", tocofsSaleoutEntityList);
}
}

View File

@ -8,14 +8,14 @@ import com.hzya.frame.basedao.dao.MybatisGenericDao;
import java.util.List; import java.util.List;
/** /**
* tocofs_saleout_detailed(TocofsSaleoutDetailed)表数据库访问层 * O出库单明细表(TOCTOB业务底表)(TocofsSaleoutDetailed)表数据库访问层
* *
* @author makejava * @author makejava
* @since 2024-08-01 17:01:53 * @since 2024-09-04 17:48:28
*/ */
public class TocofsSaleoutDetailedDaoImpl extends MybatisGenericDao<TocofsSaleoutDetailedEntity, String> implements ITocofsSaleoutDetailedDao { public class TocofsSaleoutDetailedDaoImpl extends MybatisGenericDao<TocofsSaleoutDetailedEntity, String> implements ITocofsSaleoutDetailedDao {
@Override @Override
public void entityInsertBatchV2(List<TocofsSaleoutDetailedEntity> tocofsSaleoutDetailedEntity) throws Exception { public void entityInsertOrUpdateBatch(List<TocofsSaleoutDetailedEntity> tocofsSaleoutDetailedEntities) throws Exception {
this.insert("com.hzya.frame.plugin.lets.ofs.dao.impl.TocofsSaleoutDetailedDaoImpl.entityInsertBatchV2", tocofsSaleoutDetailedEntity); insert("com.hzya.frame.plugin.lets.ofs.dao.impl.TocofsSaleoutDetailedDaoImpl.entityInsertOrUpdateBatch", tocofsSaleoutDetailedEntities);
} }
} }

View File

@ -1,18 +1,19 @@
package com.hzya.frame.plugin.lets.ofs.entity; package com.hzya.frame.plugin.lets.ofs.entity;
import com.hzya.frame.web.entity.BaseEntity; import com.hzya.frame.web.entity.BaseEntity;
import lombok.Data;
/** /**
* tocofs_saleout_detailed(TocofsSaleoutDetailed)实体类 * O出库单明细表(TOCTOB业务底表)(TocofsSaleoutDetailed)实体类
* *
* @author makejava * @author makejava
* @since 2024-08-01 17:01:53 * @since 2024-09-04 17:48:28
*/ */
//@Data
//2024年9月5日 11:00:32 抛出异常There is no getter for property named 'primaryKey' in 'class com.hzya.frame.plugin.lets.ofs.entity.TocofsSaleoutDetailedEntity'
//2024年9月5日 11:05:13 没用不是@data这里的问题
@Data
public class TocofsSaleoutDetailedEntity extends BaseEntity { public class TocofsSaleoutDetailedEntity extends BaseEntity {
/**
* rootId
*/
// private Long rootid;
/** /**
* LETS * LETS
*/ */
@ -30,7 +31,7 @@ public class TocofsSaleoutDetailedEntity extends BaseEntity {
*/ */
private String shipmentcode; private String shipmentcode;
/** /**
* 22814582 * 22814582 主键
*/ */
private Long reforderid; private Long reforderid;
/** /**
@ -57,6 +58,7 @@ public class TocofsSaleoutDetailedEntity extends BaseEntity {
* LETS-SO2024031900000002 * LETS-SO2024031900000002
*/ */
private String sourceordercode; private String sourceordercode;
private String sourcelinenum;
/** /**
* AVAILABLE * AVAILABLE
*/ */
@ -73,6 +75,7 @@ public class TocofsSaleoutDetailedEntity extends BaseEntity {
* 0 * 0
*/ */
private Long shipqty; private Long shipqty;
private String shipat;
/** /**
* EA * EA
*/ */
@ -125,327 +128,236 @@ public class TocofsSaleoutDetailedEntity extends BaseEntity {
* LETS-ADMIN * LETS-ADMIN
*/ */
private String lastupdatedby; private String lastupdatedby;
// public Long getRootid() {
// return rootid;
// }
//
// public void setRootid(Long rootid) {
// this.rootid = rootid;
// }
private String newTransmitInfo;
private String newPushDate;
private String newState;
private String newSystemNumber;
private String newSystemPrimary;
/** /**
* 主表主键 * 主表主键
*/ */
private String primaryKey; private String maintableid;
/** /**
* 业务类型 * (销售)推送时间
*/ */
private String businessType; private String newpushdate;
/** /**
* 业务日期 * (销售)报错详情
*/ */
private String businessDate; private String newtransmitinfo;
/**
public String getBusinessDate() { * (销售)出库同步是否成功
return businessDate; */
} private String newstate;
/**
public void setBusinessDate(String businessDate) { * (销售)交易成功()是否成功
this.businessDate = businessDate; */
} private String newstate2;
/**
public String getBusinessType() { * (销售)交易成功()是否成功
return businessType; */
} private String newstate3;
/**
public void setBusinessType(String businessType) { * (销售)交易成功(TOB发票)是否成功
this.businessType = businessType; */
} private String newstate4;
/**
public String getNewTransmitInfo() { * (销售)下游系统编码(库存)
return newTransmitInfo; */
} private String newsystemnumber;
/**
public void setNewTransmitInfo(String newTransmitInfo) { * (销售)下游系统主键(库存)
this.newTransmitInfo = newTransmitInfo; */
} private String newsystemprimary;
/**
public String getNewPushDate() { * (销售)下游系统编码(交易成功红)
return newPushDate; */
} private String newsystemnumber2;
/**
public void setNewPushDate(String newPushDate) { * (销售)下游系统主键(交易成功红)
this.newPushDate = newPushDate; */
} private String newsystemprimary2;
/**
public String getNewState() { * (销售)下游系统编码(交易成功蓝)
return newState; */
} private String newsystemnumber3;
/**
public void setNewState(String newState) { * (销售)下游系统主键(交易成功蓝)
this.newState = newState; */
} private String newsystemprimary3;
/**
public String getNewSystemNumber() { * (销售)下游系统编码(交易成功TOB发票)
return newSystemNumber; */
} private String newsystemnumber4;
/**
public void setNewSystemNumber(String newSystemNumber) { * (销售)下游系统主键(交易成功TOB发票)
this.newSystemNumber = newSystemNumber; */
} private String newsystemprimary4;
/**
public String getNewSystemPrimary() { * (销售)业务日期-出库日期
return newSystemPrimary; */
} private String businessdate;
/**
public void setNewSystemPrimary(String newSystemPrimary) { * (销售)业务日期-交易日期
this.newSystemPrimary = newSystemPrimary; */
} private String successfultradedate;
/**
public String getPrimaryKey() { * (销售)业务发生类型
return primaryKey; */
} private String businesstype;
/**
public void setPrimaryKey(String primaryKey) { * 自定义项
this.primaryKey = primaryKey; */
} private String def1;
/**
public String getClientcode() { * 自定义项
return clientcode; */
} private String def2;
/**
public void setClientcode(String clientcode) { * 自定义项
this.clientcode = clientcode; */
} private String def3;
/**
public String getCompanycode() { * 自定义项
return companycode; */
} private String def4;
/**
public void setCompanycode(String companycode) { * 自定义项
this.companycode = companycode; */
} private String def5;
/**
public String getFacilitycode() { * 自定义项
return facilitycode; */
} private String def6;
/**
public void setFacilitycode(String facilitycode) { * 自定义项
this.facilitycode = facilitycode; */
} private String def7;
/**
public String getShipmentcode() { * 自定义项
return shipmentcode; */
} private String def8;
/**
public void setShipmentcode(String shipmentcode) { * 自定义项
this.shipmentcode = shipmentcode; */
} private String def9;
/**
public Long getReforderid() { * 自定义项
return reforderid; */
} private String def10;
/**
public void setReforderid(Long reforderid) { * 自定义项
this.reforderid = reforderid; */
} private String def11;
/**
public Long getReforderdetailid() { * 自定义项
return reforderdetailid; */
} private String def12;
/**
public void setReforderdetailid(Long reforderdetailid) { * 自定义项
this.reforderdetailid = reforderdetailid; */
} private String def13;
/**
public String getRefordercode() { * 自定义项
return refordercode; */
} private String def14;
/**
public void setRefordercode(String refordercode) { * 自定义项
this.refordercode = refordercode; */
} private String def15;
/**
public Long getAllocinvid() { * 自定义项
return allocinvid; */
} private String def16;
/**
public void setAllocinvid(Long allocinvid) { * 自定义项
this.allocinvid = allocinvid; */
} private String def17;
/**
public String getSkucode() { * 自定义项
return skucode; */
} private String def18;
/**
public void setSkucode(String skucode) { * 自定义项
this.skucode = skucode; */
} private String def19;
/**
public String getSkuname() { * 自定义项
return skuname; */
} private String def20;
/**
public void setSkuname(String skuname) { * 自定义项
this.skuname = skuname; */
} private String def21;
/**
public String getSourceordercode() { * 自定义项
return sourceordercode; */
} private String def22;
/**
public void setSourceordercode(String sourceordercode) { * 自定义项
this.sourceordercode = sourceordercode; */
} private String def23;
/**
public String getInventorysts() { * 自定义项
return inventorysts; */
} private String def24;
/**
public void setInventorysts(String inventorysts) { * 自定义项
this.inventorysts = inventorysts; */
} private String def25;
/**
public Long getIsgift() { * 自定义项
return isgift; */
} private String def26;
/**
public void setIsgift(Long isgift) { * 自定义项
this.isgift = isgift; */
} private String def27;
/**
public Long getRequestqty() { * 自定义项
return requestqty; */
} private String def28;
/**
public void setRequestqty(Long requestqty) { * 自定义项
this.requestqty = requestqty; */
} private String def29;
/**
public Long getShipqty() { * 自定义项
return shipqty; */
} private String def30;
/**
public void setShipqty(Long shipqty) { * 自定义项
this.shipqty = shipqty; */
} private String def31;
/**
public String getQuantityum() { * 自定义项
return quantityum; */
} private String def32;
/**
public void setQuantityum(String quantityum) { * 自定义项
this.quantityum = quantityum; */
} private String def33;
/**
public Long getListprice() { * 自定义项
return listprice; */
} private String def34;
/**
public void setListprice(Long listprice) { * 自定义项
this.listprice = listprice; */
} private String def35;
/**
public Long getItemtotalamount() { * 自定义项
return itemtotalamount; */
} private String def36;
/**
public void setItemtotalamount(Long itemtotalamount) { * 自定义项
this.itemtotalamount = itemtotalamount; */
} private String def37;
/**
public Long getTotalpayamount() { * 自定义项
return totalpayamount; */
} private String def38;
/**
public void setTotalpayamount(Long totalpayamount) { * 自定义项
this.totalpayamount = totalpayamount; */
} private String def39;
/**
public Long getTotalweight() { * 自定义项
return totalweight; */
} private String def40;
}
public void setTotalweight(Long totalweight) {
this.totalweight = totalweight;
}
public Long getTotalvolume() {
return totalvolume;
}
public void setTotalvolume(Long totalvolume) {
this.totalvolume = totalvolume;
}
public Long getTotalvolumeweight() {
return totalvolumeweight;
}
public void setTotalvolumeweight(Long totalvolumeweight) {
this.totalvolumeweight = totalvolumeweight;
}
public String getWeightum() {
return weightum;
}
public void setWeightum(String weightum) {
this.weightum = weightum;
}
public String getVolumeum() {
return volumeum;
}
public void setVolumeum(String volumeum) {
this.volumeum = volumeum;
}
public String getCreated() {
return created;
}
public void setCreated(String created) {
this.created = created;
}
public String getCreatedby() {
return createdby;
}
public void setCreatedby(String createdby) {
this.createdby = createdby;
}
public String getLastupdated() {
return lastupdated;
}
public void setLastupdated(String lastupdated) {
this.lastupdated = lastupdated;
}
public String getLastupdatedby() {
return lastupdatedby;
}
public void setLastupdatedby(String lastupdatedby) {
this.lastupdatedby = lastupdatedby;
}
}

View File

@ -1,14 +1,17 @@
package com.hzya.frame.plugin.lets.ofs.entity; package com.hzya.frame.plugin.lets.ofs.entity;
import com.hzya.frame.web.entity.BaseEntity; import com.hzya.frame.web.entity.BaseEntity;
import lombok.Data;
/** /**
* root(TocofsSaleout)实体类 * O出库单表头(TOCTOB业务底表)(TocofsSaleout)实体类
* *
* @author makejava * @author makejava
* @since 2024-08-01 17:01:32 * @since 2024-09-04 17:48:16
*/ */
@Data
public class TocofsSaleoutEntity extends BaseEntity { public class TocofsSaleoutEntity extends BaseEntity {
/** /**
* LETS * LETS
*/ */
@ -73,14 +76,14 @@ public class TocofsSaleoutEntity extends BaseEntity {
* LETS-SO2024031900000002 * LETS-SO2024031900000002
*/ */
private String sourceordercode; private String sourceordercode;
/**
* TB
*/
private String sourceuseraccount;
/** /**
* *
*/ */
private String shiptoattentionto; private String shiptoattentionto;
/**
* TB
*/
private String sourceuseraccount;
/** /**
* AAA * AAA
*/ */
@ -157,10 +160,19 @@ public class TocofsSaleoutEntity extends BaseEntity {
* 640 * 640
*/ */
private Long itemtotalamount; private Long itemtotalamount;
private String totalfulfillqty;
private String totalfulfillweight;
private String totalfulfillvolume;
private String totalfulfillvolumeweight;
/**
* 发货日期
*/
private String shipat;
/** /**
* ZTO * ZTO
*/ */
private String carriercode; private String carriercode;
private String primarywaybillcode;
/** /**
* 1 * 1
*/ */
@ -212,6 +224,14 @@ public class TocofsSaleoutEntity extends BaseEntity {
* 1 * 1
*/ */
private Long taxpaid; private Long taxpaid;
/**
* 交易成功时间
*/
private String tradesuccessat;
/**
* 交易成功状态
*/
private String sourceorderstatus;
/** /**
* 上海市 * 上海市
*/ */
@ -224,491 +244,168 @@ public class TocofsSaleoutEntity extends BaseEntity {
* 杨浦区 * 杨浦区
*/ */
private String shiptodistrictname; private String shiptodistrictname;
/** /**
* 发货时间 * 出库类型
*/ */
private String shipAt; private String shipmenttype;
/**
public String getShipAt() { * 自定义项
return shipAt; */
} private String def1;
/**
public void setShipAt(String shipAt) { * 自定义项
this.shipAt = shipAt; */
} private String def2;
/**
public String getClientcode() { * 自定义项
return clientcode; */
} private String def3;
/**
public void setClientcode(String clientcode) { * 自定义项
this.clientcode = clientcode; */
} private String def4;
/**
public String getCompanycode() { * 自定义项
return companycode; */
} private String def5;
/**
public void setCompanycode(String companycode) { * 自定义项
this.companycode = companycode; */
} private String def6;
/**
public String getStorecode() { * 自定义项
return storecode; */
} private String def7;
/**
public void setStorecode(String storecode) { * 自定义项
this.storecode = storecode; */
} private String def8;
/**
public String getFacilitycode() { * 自定义项
return facilitycode; */
} private String def9;
/**
public void setFacilitycode(String facilitycode) { * 自定义项
this.facilitycode = facilitycode; */
} private String def10;
/**
public String getCode() { * 自定义项
return code; */
} private String def11;
/**
public void setCode(String code) { * 自定义项
this.code = code; */
} private String def12;
/**
public Long getReforderid() { * 自定义项
return reforderid; */
} private String def13;
/**
public void setReforderid(Long reforderid) { * 自定义项
this.reforderid = reforderid; */
} private String def14;
/**
public String getRefordercode() { * 自定义项
return refordercode; */
} private String def15;
/**
public void setRefordercode(String refordercode) { * 自定义项
this.refordercode = refordercode; */
} private String def16;
/**
public String getRefordertype() { * 自定义项
return refordertype; */
} private String def17;
/**
public void setRefordertype(String refordertype) { * 自定义项
this.refordertype = refordertype; */
} private String def18;
/**
public Long getStatus() { * 自定义项
return status; */
} private String def19;
/**
public void setStatus(Long status) { * 自定义项
this.status = status; */
} private String def20;
/**
public Long getConsolidated() { * 自定义项
return consolidated; */
} private String def21;
/**
public void setConsolidated(Long consolidated) { * 自定义项
this.consolidated = consolidated; */
} private String def22;
/**
public String getInternalinstructiontype() { * 自定义项
return internalinstructiontype; */
} private String def23;
/**
public void setInternalinstructiontype(String internalinstructiontype) { * 自定义项
this.internalinstructiontype = internalinstructiontype; */
} private String def24;
/**
public String getBizchannel() { * 自定义项
return bizchannel; */
} private String def25;
/**
public void setBizchannel(String bizchannel) { * 自定义项
this.bizchannel = bizchannel; */
} private String def26;
/**
public String getSourceplatformcode() { * 自定义项
return sourceplatformcode; */
} private String def27;
/**
public void setSourceplatformcode(String sourceplatformcode) { * 自定义项
this.sourceplatformcode = sourceplatformcode; */
} private String def28;
/**
public String getProcesstype() { * 自定义项
return processtype; */
} private String def29;
/**
public void setProcesstype(String processtype) { * 自定义项
this.processtype = processtype; */
} private String def30;
/**
public Long getSourceorderid() { * 自定义项
return sourceorderid; */
} private String def31;
/**
public void setSourceorderid(Long sourceorderid) { * 自定义项
this.sourceorderid = sourceorderid; */
} private String def32;
/**
public String getSourceordercode() { * 自定义项
return sourceordercode; */
} private String def33;
/**
public void setSourceordercode(String sourceordercode) { * 自定义项
this.sourceordercode = sourceordercode; */
} private String def34;
/**
public String getSourceuseraccount() { * 自定义项
return sourceuseraccount; */
} private String def35;
/**
public void setSourceuseraccount(String sourceuseraccount) { * 自定义项
this.sourceuseraccount = sourceuseraccount; */
} private String def36;
/**
public String getShiptoattentionto() { * 自定义项
return shiptoattentionto; */
} private String def37;
/**
public void setShiptoattentionto(String shiptoattentionto) { * 自定义项
this.shiptoattentionto = shiptoattentionto; */
} private String def38;
/**
public String getShiptoaddress() { * 自定义项
return shiptoaddress; */
} private String def39;
/**
public void setShiptoaddress(String shiptoaddress) { * 自定义项
this.shiptoaddress = shiptoaddress; */
} private String def40;
}
public String getShiptocountry() {
return shiptocountry;
}
public void setShiptocountry(String shiptocountry) {
this.shiptocountry = shiptocountry;
}
public String getShiptostate() {
return shiptostate;
}
public void setShiptostate(String shiptostate) {
this.shiptostate = shiptostate;
}
public String getShiptocity() {
return shiptocity;
}
public void setShiptocity(String shiptocity) {
this.shiptocity = shiptocity;
}
public String getShiptodistrict() {
return shiptodistrict;
}
public void setShiptodistrict(String shiptodistrict) {
this.shiptodistrict = shiptodistrict;
}
public String getShiptomobile() {
return shiptomobile;
}
public void setShiptomobile(String shiptomobile) {
this.shiptomobile = shiptomobile;
}
public Long getTotallines() {
return totallines;
}
public void setTotallines(Long totallines) {
this.totallines = totallines;
}
public Long getTotalqty() {
return totalqty;
}
public void setTotalqty(Long totalqty) {
this.totalqty = totalqty;
}
public Long getTotalcontainers() {
return totalcontainers;
}
public void setTotalcontainers(Long totalcontainers) {
this.totalcontainers = totalcontainers;
}
public Long getTotalcases() {
return totalcases;
}
public void setTotalcases(Long totalcases) {
this.totalcases = totalcases;
}
public Long getTotalweight() {
return totalweight;
}
public void setTotalweight(Long totalweight) {
this.totalweight = totalweight;
}
public Long getTotalvolume() {
return totalvolume;
}
public void setTotalvolume(Long totalvolume) {
this.totalvolume = totalvolume;
}
public Long getTotalvolumeweight() {
return totalvolumeweight;
}
public void setTotalvolumeweight(Long totalvolumeweight) {
this.totalvolumeweight = totalvolumeweight;
}
public String getWeightum() {
return weightum;
}
public void setWeightum(String weightum) {
this.weightum = weightum;
}
public String getVolumeum() {
return volumeum;
}
public void setVolumeum(String volumeum) {
this.volumeum = volumeum;
}
public Long getTotalamount() {
return totalamount;
}
public void setTotalamount(Long totalamount) {
this.totalamount = totalamount;
}
public Long getTotalpayamount() {
return totalpayamount;
}
public void setTotalpayamount(Long totalpayamount) {
this.totalpayamount = totalpayamount;
}
public Long getPostageamount() {
return postageamount;
}
public void setPostageamount(Long postageamount) {
this.postageamount = postageamount;
}
public Long getItemtotalamount() {
return itemtotalamount;
}
public void setItemtotalamount(Long itemtotalamount) {
this.itemtotalamount = itemtotalamount;
}
public String getCarriercode() {
return carriercode;
}
public void setCarriercode(String carriercode) {
this.carriercode = carriercode;
}
public Long getPaymentstatus() {
return paymentstatus;
}
public void setPaymentstatus(Long paymentstatus) {
this.paymentstatus = paymentstatus;
}
public String getCodrequired() {
return codrequired;
}
public void setCodrequired(String codrequired) {
this.codrequired = codrequired;
}
public String getInvoicerequired() {
return invoicerequired;
}
public void setInvoicerequired(String invoicerequired) {
this.invoicerequired = invoicerequired;
}
public String getPaidat() {
return paidat;
}
public void setPaidat(String paidat) {
this.paidat = paidat;
}
public String getShipfromattentionto() {
return shipfromattentionto;
}
public void setShipfromattentionto(String shipfromattentionto) {
this.shipfromattentionto = shipfromattentionto;
}
public String getShipfromaddress() {
return shipfromaddress;
}
public void setShipfromaddress(String shipfromaddress) {
this.shipfromaddress = shipfromaddress;
}
public String getShipfromdistrict() {
return shipfromdistrict;
}
public void setShipfromdistrict(String shipfromdistrict) {
this.shipfromdistrict = shipfromdistrict;
}
public String getShipfromcity() {
return shipfromcity;
}
public void setShipfromcity(String shipfromcity) {
this.shipfromcity = shipfromcity;
}
public String getShipfromstate() {
return shipfromstate;
}
public void setShipfromstate(String shipfromstate) {
this.shipfromstate = shipfromstate;
}
public String getShipfromcountry() {
return shipfromcountry;
}
public void setShipfromcountry(String shipfromcountry) {
this.shipfromcountry = shipfromcountry;
}
public String getShipfrompostalcode() {
return shipfrompostalcode;
}
public void setShipfrompostalcode(String shipfrompostalcode) {
this.shipfrompostalcode = shipfrompostalcode;
}
public String getShipfromphone() {
return shipfromphone;
}
public void setShipfromphone(String shipfromphone) {
this.shipfromphone = shipfromphone;
}
public String getShipfrommobile() {
return shipfrommobile;
}
public void setShipfrommobile(String shipfrommobile) {
this.shipfrommobile = shipfrommobile;
}
public String getShipfromfax() {
return shipfromfax;
}
public void setShipfromfax(String shipfromfax) {
this.shipfromfax = shipfromfax;
}
public String getShipfromemail() {
return shipfromemail;
}
public void setShipfromemail(String shipfromemail) {
this.shipfromemail = shipfromemail;
}
public Long getCodamount() {
return codamount;
}
public void setCodamount(Long codamount) {
this.codamount = codamount;
}
public Long getTax() {
return tax;
}
public void setTax(Long tax) {
this.tax = tax;
}
public Long getTaxpaid() {
return taxpaid;
}
public void setTaxpaid(Long taxpaid) {
this.taxpaid = taxpaid;
}
public String getShiptostatename() {
return shiptostatename;
}
public void setShiptostatename(String shiptostatename) {
this.shiptostatename = shiptostatename;
}
public String getShiptocityname() {
return shiptocityname;
}
public void setShiptocityname(String shiptocityname) {
this.shiptocityname = shiptocityname;
}
public String getShiptodistrictname() {
return shiptodistrictname;
}
public void setShiptodistrictname(String shiptodistrictname) {
this.shiptodistrictname = shiptodistrictname;
}
}

View File

@ -840,12 +840,12 @@ public class ConsignmachiningInReturn extends PluginBaseEntity {
* *
* @author liuyang * @author liuyang
*/ */
private BdTaxitemsEntity queryBdTaxitems(String invcode) { // private BdTaxitemsEntity queryBdTaxitems(String invcode) {
Assert.notNull(invcode, "存货编码不能为空"); // Assert.notNull(invcode, "存货编码不能为空");
BdTaxitemsEntity bdTaxitemsEntity = TocOrderBasicArchivesCacheUtil.stringBdTaxitemsEntityHashMap.get(invcode); // BdTaxitemsEntity bdTaxitemsEntity = TocOrderBasicArchivesCacheUtil.stringBdTaxitemsEntityHashMap.get(invcode);
Assert.notNull(bdTaxitemsEntity, "根据存货编码({}),无法匹配到税率!", invcode); // Assert.notNull(bdTaxitemsEntity, "根据存货编码({}),无法匹配到税率!", invcode);
return bdTaxitemsEntity; // return bdTaxitemsEntity;
} // }
/** /**
* 2024年8月20日 16:42:14 * 2024年8月20日 16:42:14

View File

@ -395,8 +395,8 @@ public class ProxyPurchaseWarehous extends PluginBaseEntity {
OfsPoOrderDetails ofsPoOrderDetail = findOfsPoOrderDetail(ofsPoOrderDataDetails, stockinB); OfsPoOrderDetails ofsPoOrderDetail = findOfsPoOrderDetail(ofsPoOrderDataDetails, stockinB);
//TODO 测试 //TODO 测试
stockinB.setReceivedQty("1"); // stockinB.setReceivedQty("1");
ofsPoOrderDetail.setFulfillAmount("10"); // ofsPoOrderDetail.setFulfillAmount("10");
//2024年8月20日 16:02:21 已经和妮姐万万确认采购公司和收货公司目前是一致的暂时不用区分取数逻辑 //2024年8月20日 16:02:21 已经和妮姐万万确认采购公司和收货公司目前是一致的暂时不用区分取数逻辑
BdInvmandocEntity bdInvmandocEntity = queryInventoryMan(stockinB, bdCorpEntity.getPkCorp()); BdInvmandocEntity bdInvmandocEntity = queryInventoryMan(stockinB, bdCorpEntity.getPkCorp());

View File

@ -382,7 +382,7 @@ public class SoSaleOutPluginInitializerToB extends PluginBaseEntity {
List<TocofsSaleoutEntity> tocofsSaleoutEntityList = copyHeaderDto(headerDtoList); List<TocofsSaleoutEntity> tocofsSaleoutEntityList = copyHeaderDto(headerDtoList);
if (tocofsSaleoutEntityList.size() > 0) { if (tocofsSaleoutEntityList.size() > 0) {
logger.info("TOBofsSaleoutDetailedEntities插入底表{}个对象(表头)", tocofsSaleoutEntityList.size()); logger.info("TOBofsSaleoutDetailedEntities插入底表{}个对象(表头)", tocofsSaleoutEntityList.size());
iTocofsSaleoutDao.entityInsertBatchV2(tocofsSaleoutEntityList); iTocofsSaleoutDao.entityInsertOrUpdateBatch(tocofsSaleoutEntityList);
} else { } else {
logger.info("TOBofsSaleoutEntityList没有对象被插入表头底表"); logger.info("TOBofsSaleoutEntityList没有对象被插入表头底表");
} }
@ -395,7 +395,7 @@ public class SoSaleOutPluginInitializerToB extends PluginBaseEntity {
List<TocofsSaleoutDetailedEntity> tocofsSaleoutDetailedEntities = copyDetailsDto(detailsDtos); List<TocofsSaleoutDetailedEntity> tocofsSaleoutDetailedEntities = copyDetailsDto(detailsDtos);
if (tocofsSaleoutDetailedEntities.size() > 0) { if (tocofsSaleoutDetailedEntities.size() > 0) {
logger.info("TOBofsSaleoutDetailedEntities插入底表{}个对象(表体)", tocofsSaleoutDetailedEntities.size()); logger.info("TOBofsSaleoutDetailedEntities插入底表{}个对象(表体)", tocofsSaleoutDetailedEntities.size());
iTocofsSaleoutDetailedDao.entityInsertBatchV2(tocofsSaleoutDetailedEntities); iTocofsSaleoutDetailedDao.entityInsertOrUpdateBatch(tocofsSaleoutDetailedEntities);
} else { } else {
logger.info("TOBofsSaleoutDetailedEntities没有对象被插入表头底表"); logger.info("TOBofsSaleoutDetailedEntities没有对象被插入表头底表");
} }
@ -1091,9 +1091,16 @@ public class SoSaleOutPluginInitializerToB extends PluginBaseEntity {
if (tocofsSaleoutDetailedEntity != null && detailsDto != null && detailsDto.getHeaderDto() != null) { if (tocofsSaleoutDetailedEntity != null && detailsDto != null && detailsDto.getHeaderDto() != null) {
HeaderDto headerDto = detailsDto.getHeaderDto(); HeaderDto headerDto = detailsDto.getHeaderDto();
tocofsSaleoutDetailedEntity.setPrimaryKey(headerDto.getId());//主表主键 if (headerDto.getId() != null) {
tocofsSaleoutDetailedEntity.setBusinessDate(headerDto.getShipAt());//业务日期 tocofsSaleoutDetailedEntity.setMaintableid(headerDto.getId());//主表主键
tocofsSaleoutDetailedEntity.setBusinessType("TOB_ORDER");//业务类型 }
if (headerDto.getShipAt() != null) {
tocofsSaleoutDetailedEntity.setBusinessdate(headerDto.getShipAt());//业务日期-出库日期
}
if (headerDto.getTradeSuccessAt() != null) {
tocofsSaleoutDetailedEntity.setSuccessfultradedate(headerDto.getTradeSuccessAt());//业务日期-交易时间
}
tocofsSaleoutDetailedEntity.setBusinesstype("TOB_ORDER");//业务类型
} else { } else {
logger.info("createPrimaryKeyAndBusinessDateAndBusinessType方法存在false"); logger.info("createPrimaryKeyAndBusinessDateAndBusinessType方法存在false");
} }
@ -1471,7 +1478,7 @@ public class SoSaleOutPluginInitializerToB extends PluginBaseEntity {
isblargessflag = true; isblargessflag = true;
} }
//TODO 测试 //TODO 测试
detailsDto.setShipQty("1"); // detailsDto.setShipQty("1");
SalesInvoiceBodyDto salesInvoiceBodyDto = new SalesInvoiceBodyDto(); SalesInvoiceBodyDto salesInvoiceBodyDto = new SalesInvoiceBodyDto();
salesInvoiceBodyDto.setCinventoryid(bdInvmandocEntity.getPkInvmandoc()); salesInvoiceBodyDto.setCinventoryid(bdInvmandocEntity.getPkInvmandoc());
salesInvoiceBodyDto.setCupreceipttype("4C");//来源单据类型 salesInvoiceBodyDto.setCupreceipttype("4C");//来源单据类型

View File

@ -0,0 +1,31 @@
package com.hzya.frame.plugin.lets.resultvo;
import com.hzya.frame.plugin.lets.entity.*;
import lombok.Data;
import java.util.Map;
/**
* @Authorliuyang
* @Packagecom.hzya.frame.plugin.lets.resultvo
* @ProjectkangarooDataCenterV3
* @nameCacheMapVo
* @Date2024/9/4 13:35
* @FilenameCacheMapVo
*/
@Data
public class CacheTocMapVo {
private Map<String, BdCorpEntity> stringBdCorpEntityMap;
private Map<String, BdStordocEntity> stringBdStordocEntityMap;
private Map<String, BdCalbodyEntity> stringBdCalbodyEntityMap;
private Map<String, BdSalestruEntity> stringBdSalestruEntityMap;
private Map<String, BdDeptdocEntity> stringBdDeptdocEntityMap;
private Map<String, BdCumandocEntity> stringBdCumandocEntityMap;
private Map<String, BdInvmandocEntity> stringBdInvmandocEntityMap;
private Map<String, BdInvbasdocEntity> stringBdInvbasdocEntityMap;
private Map<String, BdTaxitemsEntity> stringBdTaxitemsEntityMap;
private Map<String, BdCubasdocEntity> stringBdCubasdocEntityMap;
private Map<String, BdDefdocEntity> stringBdDefdocPlatformEntityMap;
private Map<String, BdDefdocEntity> stringBdDefdocShopEntityMap;
private Map<String, BdRdclEntity> stringBdRdclEntityMap;
}

View File

@ -3,6 +3,7 @@ package com.hzya.frame.plugin.lets.u8cdto;
import com.hzya.frame.ttxofs.dto.ofssaleorderoutsearch.DetailsDto; import com.hzya.frame.ttxofs.dto.ofssaleorderoutsearch.DetailsDto;
import com.hzya.frame.ttxofs.dto.ofssaleorderoutsearch.HeaderDto; import com.hzya.frame.ttxofs.dto.ofssaleorderoutsearch.HeaderDto;
import com.hzya.frame.plugin.lets.entity.*; import com.hzya.frame.plugin.lets.entity.*;
import lombok.Data;
import java.math.BigDecimal; import java.math.BigDecimal;
@ -14,213 +15,62 @@ import java.math.BigDecimal;
* @Date2024/8/5 16:07 * @Date2024/8/5 16:07
* @FilenameSonDetailsDto * @FilenameSonDetailsDto
*/ */
@Data
public class SonDetailsDto extends DetailsDto { public class SonDetailsDto extends DetailsDto {
//表头对象
/**
* 表头对象
*/
private HeaderDto header; private HeaderDto header;
/** //表头公司销售公司
* 表头公司销售公司
*/
private BdCorpEntity bdCorpEntity; private BdCorpEntity bdCorpEntity;
/** //发货库存组织
* 发货库存组织
*/
private BdCalbodyEntity bdCalbodyEntity; private BdCalbodyEntity bdCalbodyEntity;
/** //发货仓库
* 发货仓库
*/
private BdStordocEntity bdStordocEntity; private BdStordocEntity bdStordocEntity;
/** //收货库存组织
* 收货库存组织
*/
private BdCalbodyEntity bdCalbodyEntity1; private BdCalbodyEntity bdCalbodyEntity1;
/** //收货仓库
* 收货仓库
*/
private BdStordocEntity bdStordocEntity1; private BdStordocEntity bdStordocEntity1;
/** //销售组织
* 销售组织
*/
private BdSalestruEntity bdSalestruEntity; private BdSalestruEntity bdSalestruEntity;
/** //业务部门
* 业务部门
*/
private BdDeptdocEntity bdDeptdocEntity; private BdDeptdocEntity bdDeptdocEntity;
/** //客商管理档案
* 客商管理档案
*/
private BdCumandocEntity bdCumandocEntity; private BdCumandocEntity bdCumandocEntity;
/** //客商基本档案
* 客商基本档案
*/
private BdCubasdocEntity bdCubasdocEntity; private BdCubasdocEntity bdCubasdocEntity;
/** //生成汇总维度字符串
* 生成汇总维度字符串
*/
private String summaryDimensionStr; private String summaryDimensionStr;
/** //汇总总金额
* 汇总总金额
*/
private BigDecimal groupTotalPayAmount; private BigDecimal groupTotalPayAmount;
/** //汇总实发数量
* 汇总实发数量
*/
private BigDecimal groupShipQty; private BigDecimal groupShipQty;
/** //发货公司
* 发货公司
*/
private BdCorpEntity deliverGoodsCorp; private BdCorpEntity deliverGoodsCorp;
/** //U8C平台档案
* U8C平台档案
*/
private BdDefdocEntity platformArchives; private BdDefdocEntity platformArchives;
/** //U8C店铺档案
* U8C店铺档案
*/
private BdDefdocEntity shopArchives; private BdDefdocEntity shopArchives;
public BdDefdocEntity getShopArchives() { //存货管理档案是发货公司的存货档案
return shopArchives; private BdInvmandocEntity bdInvmandocEntity;
}
public void setShopArchives(BdDefdocEntity shopArchives) { //存货基本档案
this.shopArchives = shopArchives; private BdInvbasdocEntity bdInvbasdocEntity;
}
public BdDefdocEntity getPlatformArchives() { //存货税率
return platformArchives; private BdTaxitemsEntity bdTaxitemsEntity;
}
public void setPlatformArchives(BdDefdocEntity platformArchives) {
this.platformArchives = platformArchives;
}
public BdCorpEntity getDeliverGoodsCorp() {
return deliverGoodsCorp;
}
public void setDeliverGoodsCorp(BdCorpEntity deliverGoodsCorp) {
this.deliverGoodsCorp = deliverGoodsCorp;
}
public BigDecimal getGroupShipQty() {
return groupShipQty;
}
public void setGroupShipQty(BigDecimal groupShipQty) {
this.groupShipQty = groupShipQty;
}
public BigDecimal getGroupTotalPayAmount() {
return groupTotalPayAmount;
}
public void setGroupTotalPayAmount(BigDecimal groupTotalPayAmount) {
this.groupTotalPayAmount = groupTotalPayAmount;
}
public String getSummaryDimensionStr() {
return summaryDimensionStr;
}
public void setSummaryDimensionStr(String summaryDimensionStr) {
this.summaryDimensionStr = summaryDimensionStr;
}
public BdCorpEntity getBdCorpEntity() {
return bdCorpEntity;
}
public void setBdCorpEntity(BdCorpEntity bdCorpEntity) {
this.bdCorpEntity = bdCorpEntity;
}
public BdCalbodyEntity getBdCalbodyEntity() {
return bdCalbodyEntity;
}
public void setBdCalbodyEntity(BdCalbodyEntity bdCalbodyEntity) {
this.bdCalbodyEntity = bdCalbodyEntity;
}
public BdStordocEntity getBdStordocEntity() {
return bdStordocEntity;
}
public void setBdStordocEntity(BdStordocEntity bdStordocEntity) {
this.bdStordocEntity = bdStordocEntity;
}
public BdCalbodyEntity getBdCalbodyEntity1() {
return bdCalbodyEntity1;
}
public void setBdCalbodyEntity1(BdCalbodyEntity bdCalbodyEntity1) {
this.bdCalbodyEntity1 = bdCalbodyEntity1;
}
public BdStordocEntity getBdStordocEntity1() {
return bdStordocEntity1;
}
public void setBdStordocEntity1(BdStordocEntity bdStordocEntity1) {
this.bdStordocEntity1 = bdStordocEntity1;
}
public BdSalestruEntity getBdSalestruEntity() {
return bdSalestruEntity;
}
public void setBdSalestruEntity(BdSalestruEntity bdSalestruEntity) {
this.bdSalestruEntity = bdSalestruEntity;
}
public BdDeptdocEntity getBdDeptdocEntity() {
return bdDeptdocEntity;
}
public void setBdDeptdocEntity(BdDeptdocEntity bdDeptdocEntity) {
this.bdDeptdocEntity = bdDeptdocEntity;
}
public BdCumandocEntity getBdCumandocEntity() {
return bdCumandocEntity;
}
public void setBdCumandocEntity(BdCumandocEntity bdCumandocEntity) {
this.bdCumandocEntity = bdCumandocEntity;
}
public HeaderDto getHeader() {
return header;
}
public void setHeader(HeaderDto header) {
this.header = header;
}
public BdCubasdocEntity getBdCubasdocEntity() {
return bdCubasdocEntity;
}
public void setBdCubasdocEntity(BdCubasdocEntity bdCubasdocEntity) {
this.bdCubasdocEntity = bdCubasdocEntity;
}
} }

View File

@ -2,6 +2,10 @@ package com.hzya.frame.plugin.lets.util;
import com.hzya.frame.plugin.lets.dao.*; import com.hzya.frame.plugin.lets.dao.*;
import com.hzya.frame.plugin.lets.entity.*; import com.hzya.frame.plugin.lets.entity.*;
import com.hzya.frame.plugin.lets.plugin.sales.SoSaleOutPluginInitializerToC;
import com.hzya.frame.plugin.lets.resultvo.CacheTocMapVo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -22,6 +26,8 @@ import java.util.Map;
@Component @Component
public class TocOrderBasicArchivesCacheUtil { public class TocOrderBasicArchivesCacheUtil {
Logger logger = LoggerFactory.getLogger(TocOrderBasicArchivesCacheUtil.class);
@Autowired @Autowired
private IBdCorpDao iBdCorpDao; private IBdCorpDao iBdCorpDao;
@ -55,13 +61,17 @@ public class TocOrderBasicArchivesCacheUtil {
@Autowired @Autowired
private IBdDefdocDao iBdDefdocDao; private IBdDefdocDao iBdDefdocDao;
@Autowired
private IBdRdclDao iBdRdclDao;
/** /**
* 初始化公司档案-表头公司 * 初始化公司档案-表头公司
* 2024年7月31日 11:16:23 * 2024年7月31日 11:16:23
*/ */
public static Map<String, BdCorpEntity> stringBdCorpEntityMap = new HashMap<>(); // public static Map<String, BdCorpEntity> stringBdCorpEntityMap = new HashMap<>();
private Map<String, BdCorpEntity> initShop() throws Exception {
Map<String, BdCorpEntity> stringBdCorpEntityMap = new HashMap<>();
private void initShop() throws Exception {
BdCorpEntity bdCorpEntity = new BdCorpEntity(); BdCorpEntity bdCorpEntity = new BdCorpEntity();
bdCorpEntity.setDr(0); bdCorpEntity.setDr(0);
bdCorpEntity.setDataSourceCode("lets_u8c"); bdCorpEntity.setDataSourceCode("lets_u8c");
@ -69,9 +79,10 @@ public class TocOrderBasicArchivesCacheUtil {
if (bdCorpEntityList != null && bdCorpEntityList.size() > 0) { if (bdCorpEntityList != null && bdCorpEntityList.size() > 0) {
for (int i = 0; i < bdCorpEntityList.size(); i++) { for (int i = 0; i < bdCorpEntityList.size(); i++) {
BdCorpEntity bdCorpEntity1 = bdCorpEntityList.get(i); BdCorpEntity bdCorpEntity1 = bdCorpEntityList.get(i);
stringBdCorpEntityMap.put(bdCorpEntity1.getUnitname(), bdCorpEntity1); stringBdCorpEntityMap.put(bdCorpEntity1.getUnitcode(), bdCorpEntity1);
} }
} }
return stringBdCorpEntityMap;
} }
/** /**
@ -79,9 +90,10 @@ public class TocOrderBasicArchivesCacheUtil {
* 2024年7月31日 11:16:27 * 2024年7月31日 11:16:27
* 202403011513仓库根据仓库编码+库存组织编码去查询之前是仓库编码+公司主键和李佳妮确认好了 * 202403011513仓库根据仓库编码+库存组织编码去查询之前是仓库编码+公司主键和李佳妮确认好了
*/ */
public static Map<String, BdStordocEntity> stringBdStordocEntityMap = new HashMap<>(); // public static Map<String, BdStordocEntity> stringBdStordocEntityMap = new HashMap<>();
private Map<String, BdStordocEntity> initBdStordoc() throws Exception {
Map<String, BdStordocEntity> stringBdStordocEntityMap = new HashMap<>();
private void initBdStordoc() throws Exception {
BdStordocEntity bdStordocEntity = new BdStordocEntity(); BdStordocEntity bdStordocEntity = new BdStordocEntity();
bdStordocEntity.setDr(0L); bdStordocEntity.setDr(0L);
bdStordocEntity.setDataSourceCode("lets_u8c"); bdStordocEntity.setDataSourceCode("lets_u8c");
@ -92,14 +104,16 @@ public class TocOrderBasicArchivesCacheUtil {
stringBdStordocEntityMap.put(bdStordocEntity1.getStorcode() + bdStordocEntity1.getPkCalbody(), bdStordocEntity1); stringBdStordocEntityMap.put(bdStordocEntity1.getStorcode() + bdStordocEntity1.getPkCalbody(), bdStordocEntity1);
} }
} }
return stringBdStordocEntityMap;
} }
/** /**
* 2024年7月31日 11:09:12 查询发货库存组织 * 2024年7月31日 11:09:12 查询发货库存组织
*/ */
public static Map<String, BdCalbodyEntity> stringBdCalbodyEntityMap = new HashMap<>(); // public static Map<String, BdCalbodyEntity> stringBdCalbodyEntityMap = new HashMap<>();
private Map<String, BdCalbodyEntity> initBdCalbody() throws Exception {
Map<String, BdCalbodyEntity> stringBdCalbodyEntityMap = new HashMap<>();
private void initBdCalbody() throws Exception {
BdCalbodyEntity bdCalbodyEntity = new BdCalbodyEntity(); BdCalbodyEntity bdCalbodyEntity = new BdCalbodyEntity();
bdCalbodyEntity.setDr(0); bdCalbodyEntity.setDr(0);
bdCalbodyEntity.setDataSourceCode("lets_u8c"); bdCalbodyEntity.setDataSourceCode("lets_u8c");
@ -110,14 +124,16 @@ public class TocOrderBasicArchivesCacheUtil {
stringBdCalbodyEntityMap.put(bdCalbodyEntity1.getPkCorp(), bdCalbodyEntity1); stringBdCalbodyEntityMap.put(bdCalbodyEntity1.getPkCorp(), bdCalbodyEntity1);
} }
} }
return stringBdCalbodyEntityMap;
} }
/** /**
* 初始化销售组织 * 初始化销售组织
*/ */
public static Map<String, BdSalestruEntity> stringBdSalestruEntityMap = new HashMap<>(); // public static Map<String, BdSalestruEntity> stringBdSalestruEntityMap = new HashMap<>();
private Map<String, BdSalestruEntity> initBdSalestru() throws Exception {
Map<String, BdSalestruEntity> stringBdSalestruEntityMap = new HashMap<>();
private void initBdSalestru() throws Exception {
BdSalestruEntity bdSalestruEntity = new BdSalestruEntity(); BdSalestruEntity bdSalestruEntity = new BdSalestruEntity();
bdSalestruEntity.setDr(0); bdSalestruEntity.setDr(0);
bdSalestruEntity.setDataSourceCode("lets_u8c"); bdSalestruEntity.setDataSourceCode("lets_u8c");
@ -128,6 +144,7 @@ public class TocOrderBasicArchivesCacheUtil {
stringBdSalestruEntityMap.put(bdSalestruEntity1.getVsalestruname(), bdSalestruEntity1); stringBdSalestruEntityMap.put(bdSalestruEntity1.getVsalestruname(), bdSalestruEntity1);
} }
} }
return stringBdSalestruEntityMap;
} }
/** /**
@ -135,9 +152,10 @@ public class TocOrderBasicArchivesCacheUtil {
* *
* @author liuyang * @author liuyang
*/ */
public static Map<String, BdDeptdocEntity> stringBdDeptdocEntityMap = new HashMap<>(); // public static Map<String, BdDeptdocEntity> stringBdDeptdocEntityMap = new HashMap<>();
private Map<String, BdDeptdocEntity> initDept() {
Map<String, BdDeptdocEntity> stringBdDeptdocEntityMap = new HashMap<>();
private void initDept() {
BdDeptdocEntity bdDeptdocEntity = new BdDeptdocEntity(); BdDeptdocEntity bdDeptdocEntity = new BdDeptdocEntity();
bdDeptdocEntity.setDataSourceCode("lets_u8c"); bdDeptdocEntity.setDataSourceCode("lets_u8c");
bdDeptdocEntity.setDr(0); bdDeptdocEntity.setDr(0);
@ -149,6 +167,7 @@ public class TocOrderBasicArchivesCacheUtil {
stringBdDeptdocEntityMap.put(bdDeptdocEntity1.getPkCorp(), bdDeptdocEntity1); stringBdDeptdocEntityMap.put(bdDeptdocEntity1.getPkCorp(), bdDeptdocEntity1);
} }
} }
return stringBdDeptdocEntityMap;
} }
/** /**
@ -156,9 +175,10 @@ public class TocOrderBasicArchivesCacheUtil {
* *
* @author liuyang * @author liuyang
*/ */
public static Map<String, BdCubasdocEntity> stringBdCubasdocEntityHashMap = new HashMap<>(); // public static Map<String, BdCubasdocEntity> stringBdCubasdocEntityHashMap = new HashMap<>();
private Map<String, BdCubasdocEntity> initBdCubasdoc() {
Map<String, BdCubasdocEntity> stringBdCubasdocEntityHashMap = new HashMap<>();
private void initBdCubasdoc() {
BdCubasdocEntity bdCubasdocEntity = new BdCubasdocEntity(); BdCubasdocEntity bdCubasdocEntity = new BdCubasdocEntity();
bdCubasdocEntity.setDataSourceCode("lets_u8c"); bdCubasdocEntity.setDataSourceCode("lets_u8c");
bdCubasdocEntity.setDr(0L); bdCubasdocEntity.setDr(0L);
@ -166,9 +186,14 @@ public class TocOrderBasicArchivesCacheUtil {
if (bdCumandocEntityList != null && bdCumandocEntityList.size() > 0) { if (bdCumandocEntityList != null && bdCumandocEntityList.size() > 0) {
for (int i = 0; i < bdCumandocEntityList.size(); i++) { for (int i = 0; i < bdCumandocEntityList.size(); i++) {
BdCubasdocEntity bdCubasdocEntity1 = bdCumandocEntityList.get(i); BdCubasdocEntity bdCubasdocEntity1 = bdCumandocEntityList.get(i);
stringBdCubasdocEntityHashMap.put(bdCubasdocEntity1.getCustname(), bdCubasdocEntity1); if (stringBdCubasdocEntityHashMap.get(bdCubasdocEntity1.getDef1()) == null) {
stringBdCubasdocEntityHashMap.put(bdCubasdocEntity1.getDef1(), bdCubasdocEntity1);
} else {
logger.warn("客商档案def1重复客商编码{}", bdCubasdocEntity1.getCustcode());
}
} }
} }
return stringBdCubasdocEntityHashMap;
} }
/** /**
@ -176,9 +201,10 @@ public class TocOrderBasicArchivesCacheUtil {
* *
* @author liuyang * @author liuyang
*/ */
public static Map<String, BdCumandocEntity> stringBdCumandocEntityMap = new HashMap<>(); // public static Map<String, BdCumandocEntity> stringBdCumandocEntityMap = new HashMap<>();
private Map<String, BdCumandocEntity> initBdCumandoc() {
Map<String, BdCumandocEntity> stringBdCumandocEntityMap = new HashMap<>();
private void initBdCumandoc() {
BdCumandocEntity bdCumandocEntity1 = new BdCumandocEntity(); BdCumandocEntity bdCumandocEntity1 = new BdCumandocEntity();
bdCumandocEntity1.setDataSourceCode("lets_u8c"); bdCumandocEntity1.setDataSourceCode("lets_u8c");
bdCumandocEntity1.setDr(0L); bdCumandocEntity1.setDr(0L);
@ -190,14 +216,16 @@ public class TocOrderBasicArchivesCacheUtil {
stringBdCumandocEntityMap.put(bdCumandocEntity.getPkCubasdoc() + bdCumandocEntity.getPkCorp(), bdCumandocEntity); stringBdCumandocEntityMap.put(bdCumandocEntity.getPkCubasdoc() + bdCumandocEntity.getPkCorp(), bdCumandocEntity);
} }
} }
return stringBdCumandocEntityMap;
} }
/** /**
* 初始化存货管理档案 * 初始化存货管理档案
*/ */
public static Map<String, BdInvmandocEntity> stringBdInvmandocEntityMap = new HashMap<>(); // public static Map<String, BdInvmandocEntity> stringBdInvmandocEntityMap = new HashMap<>();
private Map<String, BdInvmandocEntity> initInventoryFile() throws Exception {
Map<String, BdInvmandocEntity> stringBdInvmandocEntityMap = new HashMap<>();
private void initInventoryFile() throws Exception {
BdInvmandocEntity bdInvmandocEntity = new BdInvmandocEntity(); BdInvmandocEntity bdInvmandocEntity = new BdInvmandocEntity();
// bdInvmandocEntity.setInvcode(copyRowDetailsListVo.getSpec_no()); // bdInvmandocEntity.setInvcode(copyRowDetailsListVo.getSpec_no());
// bdInvmandocEntity.setPkCorp(shippingCompanyBdCorpEntity.getPkCorp()); // bdInvmandocEntity.setPkCorp(shippingCompanyBdCorpEntity.getPkCorp());
@ -209,15 +237,17 @@ public class TocOrderBasicArchivesCacheUtil {
stringBdInvmandocEntityMap.put(bdInvmandocEntity1.getInvcode() + bdInvmandocEntity1.getPkCorp(), bdInvmandocEntity1); stringBdInvmandocEntityMap.put(bdInvmandocEntity1.getInvcode() + bdInvmandocEntity1.getPkCorp(), bdInvmandocEntity1);
} }
} }
return stringBdInvmandocEntityMap;
} }
/** /**
* 初始化存货基本档案 * 初始化存货基本档案
* 2024年8月7日 10:57:55 * 2024年8月7日 10:57:55
*/ */
public static Map<String, BdInvbasdocEntity> stringBdInvbasdocEntityHashMap = new HashMap<>(); // public static Map<String, BdInvbasdocEntity> stringBdInvbasdocEntityHashMap = new HashMap<>();
private Map<String, BdInvbasdocEntity> initBasicInventoryFile() throws Exception {
Map<String, BdInvbasdocEntity> stringBdInvbasdocEntityHashMap = new HashMap<>();
private void initBasicInventoryFile() throws Exception {
BdInvbasdocEntity bdInvbasdocEntity = new BdInvbasdocEntity(); BdInvbasdocEntity bdInvbasdocEntity = new BdInvbasdocEntity();
// bdInvbasdocEntity.setPk_invmandoc(bdInvmandocEntity1.getPkInvmandoc()); // bdInvbasdocEntity.setPk_invmandoc(bdInvmandocEntity1.getPkInvmandoc());
// bdInvbasdocEntity.setPk_corp(shippingCompanyBdCorpEntity.getPkCorp()); // bdInvbasdocEntity.setPk_corp(shippingCompanyBdCorpEntity.getPkCorp());
@ -228,6 +258,7 @@ public class TocOrderBasicArchivesCacheUtil {
stringBdInvbasdocEntityHashMap.put(bdInvbasdocEntity1.getPk_invmandoc() + bdInvbasdocEntity1.getPk_corp_man(), bdInvbasdocEntity1); stringBdInvbasdocEntityHashMap.put(bdInvbasdocEntity1.getPk_invmandoc() + bdInvbasdocEntity1.getPk_corp_man(), bdInvbasdocEntity1);
} }
} }
return stringBdInvbasdocEntityHashMap;
} }
/** /**
@ -236,9 +267,10 @@ public class TocOrderBasicArchivesCacheUtil {
* *
* @author liuyang * @author liuyang
*/ */
public static Map<String, BdTaxitemsEntity> stringBdTaxitemsEntityHashMap = new HashMap<>(); // public static Map<String, BdTaxitemsEntity> stringBdTaxitemsEntityHashMap = new HashMap<>();
private Map<String, BdTaxitemsEntity> initBdTaxitemsEntity() throws Exception {
Map<String, BdTaxitemsEntity> stringBdTaxitemsEntityHashMap = new HashMap<>();
private void initBdTaxitemsEntity() throws Exception {
BdTaxitemsEntity bdTaxitemsEntity = new BdTaxitemsEntity(); BdTaxitemsEntity bdTaxitemsEntity = new BdTaxitemsEntity();
List<BdTaxitemsEntity> bdTaxitemsEntityList = iBdTaxitemsDao.queryBdInvbasdocByInvcodeV2(bdTaxitemsEntity); List<BdTaxitemsEntity> bdTaxitemsEntityList = iBdTaxitemsDao.queryBdInvbasdocByInvcodeV2(bdTaxitemsEntity);
if (bdTaxitemsEntityList != null && bdTaxitemsEntityList.size() > 0) { if (bdTaxitemsEntityList != null && bdTaxitemsEntityList.size() > 0) {
@ -247,6 +279,8 @@ public class TocOrderBasicArchivesCacheUtil {
stringBdTaxitemsEntityHashMap.put(bdTaxitemsEntity1.getInvcode(), bdTaxitemsEntity1); stringBdTaxitemsEntityHashMap.put(bdTaxitemsEntity1.getInvcode(), bdTaxitemsEntity1);
} }
} }
return stringBdTaxitemsEntityHashMap;
} }
/** /**
@ -254,9 +288,10 @@ public class TocOrderBasicArchivesCacheUtil {
* *
* @author liuyang * @author liuyang
*/ */
public static Map<String, BdDefdocEntity> stringBdDefdocEntityHashMap = new HashMap<>(); // public static Map<String, BdDefdocEntity> stringBdDefdocEntityHashMap = new HashMap<>();
private Map<String, BdDefdocEntity> initSourcePlatform() {
Map<String, BdDefdocEntity> stringBdDefdocEntityHashMap = new HashMap<>();
private void initSourcePlatform() {
BdDefdocEntity bdDefdocEntity = new BdDefdocEntity(); BdDefdocEntity bdDefdocEntity = new BdDefdocEntity();
bdDefdocEntity.setPkDefdoclist("0001A210000000000JUD"); bdDefdocEntity.setPkDefdoclist("0001A210000000000JUD");
bdDefdocEntity.setDr(0); bdDefdocEntity.setDr(0);
@ -268,14 +303,16 @@ public class TocOrderBasicArchivesCacheUtil {
stringBdDefdocEntityHashMap.put(bdDefdocEntity1.getDoccode(), bdDefdocEntity1); stringBdDefdocEntityHashMap.put(bdDefdocEntity1.getDoccode(), bdDefdocEntity1);
} }
} }
return stringBdDefdocEntityHashMap;
} }
/** /**
* 2024年8月14日 15:17:48 缓存U8C店铺自定义档案逻辑 * 2024年8月14日 15:17:48 缓存U8C店铺自定义档案逻辑
*/ */
public static Map<String, BdDefdocEntity> shopDefdocEntityHashMap = new HashMap<>(); // public static Map<String, BdDefdocEntity> shopDefdocEntityHashMap = new HashMap<>();
private Map<String, BdDefdocEntity> initShopDiy() {
Map<String, BdDefdocEntity> shopDefdocEntityHashMap = new HashMap<>();
private void initShopDiy() {
BdDefdocEntity bdDefdocEntity = new BdDefdocEntity(); BdDefdocEntity bdDefdocEntity = new BdDefdocEntity();
bdDefdocEntity.setPkDefdoclist("0001A210000000000XZX"); bdDefdocEntity.setPkDefdoclist("0001A210000000000XZX");
bdDefdocEntity.setDr(0); bdDefdocEntity.setDr(0);
@ -287,6 +324,25 @@ public class TocOrderBasicArchivesCacheUtil {
shopDefdocEntityHashMap.put(bdDefdocEntity1.getDoccode(), bdDefdocEntity1); shopDefdocEntityHashMap.put(bdDefdocEntity1.getDoccode(), bdDefdocEntity1);
} }
} }
return shopDefdocEntityHashMap;
}
/**
* 初始化收发类别
*/
private Map<String, BdRdclEntity> initBdRdcl() {
Map<String, BdRdclEntity> stringBdRdclEntityHashMap = new HashMap<>();
BdRdclEntity bdRdclEntity = new BdRdclEntity();
bdRdclEntity.setDr(0);
bdRdclEntity.setDataSourceCode("lets_u8c");
List<BdRdclEntity> bdRdclEntityList = iBdRdclDao.query(bdRdclEntity);
if (bdRdclEntityList != null && bdRdclEntityList.size() > 0) {
for (int i = 0; i < bdRdclEntityList.size(); i++) {
BdRdclEntity bdRdclEntity1 = bdRdclEntityList.get(i);
stringBdRdclEntityHashMap.put(bdRdclEntity1.getRdcode(), bdRdclEntity1);
}
}
return stringBdRdclEntityHashMap;
} }
/** /**
@ -294,40 +350,61 @@ public class TocOrderBasicArchivesCacheUtil {
* *
* @author liuyang * @author liuyang
*/ */
public void clearCache() throws Exception { // public void clearCache() throws Exception {
stringBdCorpEntityMap.clear(); // stringBdCorpEntityMap.clear();
stringBdStordocEntityMap.clear(); // stringBdStordocEntityMap.clear();
stringBdCalbodyEntityMap.clear(); // stringBdCalbodyEntityMap.clear();
stringBdSalestruEntityMap.clear(); // stringBdSalestruEntityMap.clear();
stringBdDeptdocEntityMap.clear(); // stringBdDeptdocEntityMap.clear();
stringBdCumandocEntityMap.clear(); // stringBdCumandocEntityMap.clear();
stringBdInvmandocEntityMap.clear(); // stringBdInvmandocEntityMap.clear();
stringBdInvbasdocEntityHashMap.clear(); // stringBdInvbasdocEntityHashMap.clear();
stringBdTaxitemsEntityHashMap.clear(); // stringBdTaxitemsEntityHashMap.clear();
stringBdCubasdocEntityHashMap.clear(); // stringBdCubasdocEntityHashMap.clear();
stringBdDefdocEntityHashMap.clear(); // stringBdDefdocEntityHashMap.clear();
shopDefdocEntityHashMap.clear(); // shopDefdocEntityHashMap.clear();
} // }
/** /**
* 初始化缓存 * 初始化缓存
* *
* @author liuyang * @author liuyang
*/ */
public void initCache() throws Exception { public CacheTocMapVo initCache() throws Exception {
clearCache(); // clearCache();
initShop(); long startMillis = System.currentTimeMillis();
initBdStordoc(); logger.info("初始化缓存开始");
initBdCalbody(); Map<String, BdCorpEntity> stringBdCorpEntityMap = initShop();
initBdSalestru(); Map<String, BdStordocEntity> stringBdStordocEntityMap = initBdStordoc();
initDept(); Map<String, BdCalbodyEntity> stringBdCalbodyEntityMap = initBdCalbody();
initBdCumandoc(); Map<String, BdSalestruEntity> stringBdSalestruEntityMap = initBdSalestru();
initInventoryFile(); Map<String, BdDeptdocEntity> stringBdDeptdocEntityMap = initDept();
initBasicInventoryFile(); Map<String, BdCumandocEntity> stringBdCumandocEntityMap = initBdCumandoc();
initBdTaxitemsEntity(); Map<String, BdInvmandocEntity> stringBdInvmandocEntityMap = initInventoryFile();
initBdCubasdoc(); Map<String, BdInvbasdocEntity> stringBdInvbasdocEntityMap = initBasicInventoryFile();
initSourcePlatform(); Map<String, BdTaxitemsEntity> stringBdTaxitemsEntityMap = initBdTaxitemsEntity();
initShopDiy(); Map<String, BdCubasdocEntity> stringBdCubasdocEntityMap = initBdCubasdoc();
Map<String, BdDefdocEntity> stringBdDefdocEntityMap = initSourcePlatform();
Map<String, BdDefdocEntity> stringBdDefdocEntityMap1 = initShopDiy();
Map<String, BdRdclEntity> stringBdRdclEntityMap = initBdRdcl();
long endMillis = System.currentTimeMillis();
logger.info("初始化缓存完成 耗时:{}", (endMillis - startMillis));
CacheTocMapVo cacheTocMapVo = new CacheTocMapVo();
cacheTocMapVo.setStringBdCorpEntityMap(stringBdCorpEntityMap);
cacheTocMapVo.setStringBdStordocEntityMap(stringBdStordocEntityMap);
cacheTocMapVo.setStringBdCalbodyEntityMap(stringBdCalbodyEntityMap);
cacheTocMapVo.setStringBdSalestruEntityMap(stringBdSalestruEntityMap);
cacheTocMapVo.setStringBdDeptdocEntityMap(stringBdDeptdocEntityMap);
cacheTocMapVo.setStringBdCumandocEntityMap(stringBdCumandocEntityMap);
cacheTocMapVo.setStringBdInvmandocEntityMap(stringBdInvmandocEntityMap);
cacheTocMapVo.setStringBdInvbasdocEntityMap(stringBdInvbasdocEntityMap);
cacheTocMapVo.setStringBdTaxitemsEntityMap(stringBdTaxitemsEntityMap);
cacheTocMapVo.setStringBdCubasdocEntityMap(stringBdCubasdocEntityMap);
cacheTocMapVo.setStringBdDefdocPlatformEntityMap(stringBdDefdocEntityMap);
cacheTocMapVo.setStringBdDefdocShopEntityMap(stringBdDefdocEntityMap1);
cacheTocMapVo.setStringBdRdclEntityMap(stringBdRdclEntityMap);
return cacheTocMapVo;
} }
} }

View File

@ -32,10 +32,10 @@ class SoSaleOutPluginInitializerToCTest {
try { try {
// QueryOfsSoSaleOutVo queryOfsSoSaleOutVo = new QueryOfsSoSaleOutVo(); // QueryOfsSoSaleOutVo queryOfsSoSaleOutVo = new QueryOfsSoSaleOutVo();
// queryOfsSoSaleOutVo.setCode("LETS-SO2024070500000001"); soSaleOutPluginInitializerToC.startImplementStockByCode("LETS-SH2024081500000001");
// soSaleOutPluginInitializerToC.getOfsOrder(queryOfsSoSaleOutVo, 1L); // soSaleOutPluginInitializerToC.getOfsOrder(queryOfsSoSaleOutVo, 1L);
soSaleOutPluginInitializerToC.startImplement("2024-04-28 00:00:00", "2024-04-28 23:59:59"); // soSaleOutPluginInitializerToC.startImplement("2024-04-28 00:00:00", "2024-04-28 23:59:59");
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }

View File

@ -34,9 +34,6 @@ public class DetailsDto {
private String createdBy; private String createdBy;
private String lastUpdated; private String lastUpdated;
private String lastUpdatedBy; private String lastUpdatedBy;
//表头对象
/**
* 表头对象
*/
private HeaderDto headerDto; private HeaderDto headerDto;
} }

View File

@ -68,13 +68,9 @@ public class HeaderDto {
private String tradeSuccessAt; private String tradeSuccessAt;
private String sourceOrderStatus; private String sourceOrderStatus;
/** //发货日期
* 发货日期
*/
private String shipAt; private String shipAt;
/** //出库类型
* 出库类型
*/
private String shipmentType; private String shipmentType;
} }