diff --git a/buildpackage/src/test/java/com/hzya/frame/plugin/lets/plugin/outsourc/ConsignmachiningCinfurmInTest.java b/buildpackage/src/test/java/com/hzya/frame/plugin/lets/plugin/outsourc/ConsignmachiningCinfurmInTest.java index 578fc466..50a3cf81 100644 --- a/buildpackage/src/test/java/com/hzya/frame/plugin/lets/plugin/outsourc/ConsignmachiningCinfurmInTest.java +++ b/buildpackage/src/test/java/com/hzya/frame/plugin/lets/plugin/outsourc/ConsignmachiningCinfurmInTest.java @@ -29,7 +29,7 @@ public class ConsignmachiningCinfurmInTest { try { // consignmachiningCinfurmIn.startImplementByTime("2024-01-02 00:00:00", "2024-01-02 23:59:59"); - String code = "LETS-RE2025030400002411-confirm"; + String code = "LETS-RE2024111400002771-confirm"; consignmachiningCinfurmIn.startImplementByCode(code); } catch (Exception e) { e.printStackTrace(); diff --git a/service/src/main/java/com/hzya/frame/report/lets/dao/IOfsPassiveorderDetailDao.java b/service/src/main/java/com/hzya/frame/report/lets/dao/IOfsPassiveorderDetailDao.java new file mode 100644 index 00000000..e9cd19f8 --- /dev/null +++ b/service/src/main/java/com/hzya/frame/report/lets/dao/IOfsPassiveorderDetailDao.java @@ -0,0 +1,23 @@ +package com.hzya.frame.report.lets.dao; + +import com.hzya.frame.basedao.dao.IBaseDao; +import com.hzya.frame.report.lets.dto.OfsPassiveorderDetailDto; +import com.hzya.frame.report.lets.entity.OfsPassiveorderDetailEntity; + +import java.util.List; + +/** + * O无源件订单中台明细表(ofs_passiveorder_detail: table)表数据库访问层 + * + * @author makejava + * @since 2025-03-12 09:40:26 + */ +public interface IOfsPassiveorderDetailDao extends IBaseDao { + /** + * 导出模式查询 sql + * + * @throws Exception 抛出可能的异常 + * @author liuyang + */ + List queryPassiveComponentsExport(OfsPassiveorderDetailEntity ofsPassiveorderDetailEntity) throws Exception; +} \ No newline at end of file diff --git a/service/src/main/java/com/hzya/frame/report/lets/dao/IOfsPassiveorderHeaderDao.java b/service/src/main/java/com/hzya/frame/report/lets/dao/IOfsPassiveorderHeaderDao.java new file mode 100644 index 00000000..e16937cb --- /dev/null +++ b/service/src/main/java/com/hzya/frame/report/lets/dao/IOfsPassiveorderHeaderDao.java @@ -0,0 +1,14 @@ +package com.hzya.frame.report.lets.dao; + +import com.hzya.frame.basedao.dao.IBaseDao; +import com.hzya.frame.report.lets.entity.OfsPassiveorderHeaderEntity; + +/** + * O无源件订单中台主表(ofs_passiveorder_header: table)表数据库访问层 + * + * @author makejava + * @since 2025-03-12 09:39:53 + */ +public interface IOfsPassiveorderHeaderDao extends IBaseDao { + +} \ No newline at end of file diff --git a/service/src/main/java/com/hzya/frame/report/lets/dao/impl/OfsPassiveorderDetailDaoImpl.java b/service/src/main/java/com/hzya/frame/report/lets/dao/impl/OfsPassiveorderDetailDaoImpl.java new file mode 100644 index 00000000..0a064f03 --- /dev/null +++ b/service/src/main/java/com/hzya/frame/report/lets/dao/impl/OfsPassiveorderDetailDaoImpl.java @@ -0,0 +1,24 @@ +package com.hzya.frame.report.lets.dao.impl; + +import com.hzya.frame.basedao.dao.MybatisGenericDao; +import com.hzya.frame.report.lets.dao.IOfsPassiveorderDetailDao; +import com.hzya.frame.report.lets.dto.OfsPassiveorderDetailDto; +import com.hzya.frame.report.lets.entity.OfsPassiveorderDetailEntity; +import org.springframework.stereotype.Repository; + +import java.util.List; + +/** + * O无源件订单中台明细表(OfsPassiveorderDetail)表数据库访问层 + * + * @author makejava + * @since 2025-03-12 09:40:26 + */ +@Repository(value = "reportOfsPassiveorderDetailDao") +public class OfsPassiveorderDetailDaoImpl extends MybatisGenericDao implements IOfsPassiveorderDetailDao { + @Override + public List queryPassiveComponentsExport(OfsPassiveorderDetailEntity ofsPassiveorderDetailEntity) throws Exception { + return (List) selectList("com.hzya.frame.report.lets.dao.impl.OfsPassiveorderDetailDaoImpl.entity_list_base_export", ofsPassiveorderDetailEntity); + } +} + diff --git a/service/src/main/java/com/hzya/frame/report/lets/dao/impl/OfsPassiveorderHeaderDaoImpl.java b/service/src/main/java/com/hzya/frame/report/lets/dao/impl/OfsPassiveorderHeaderDaoImpl.java new file mode 100644 index 00000000..1a882813 --- /dev/null +++ b/service/src/main/java/com/hzya/frame/report/lets/dao/impl/OfsPassiveorderHeaderDaoImpl.java @@ -0,0 +1,17 @@ +package com.hzya.frame.report.lets.dao.impl; + +import com.hzya.frame.basedao.dao.MybatisGenericDao; +import com.hzya.frame.report.lets.dao.IOfsPassiveorderHeaderDao; +import com.hzya.frame.report.lets.entity.OfsPassiveorderHeaderEntity; +import org.springframework.stereotype.Repository; + +/** + * O无源件订单中台主表(OfsPassiveorderHeader)表数据库访问层 + * + * @author makejava + * @since 2025-03-12 09:39:53 + */ +@Repository(value = "reportOfsPassiveorderHeaderDao") +public class OfsPassiveorderHeaderDaoImpl extends MybatisGenericDao implements IOfsPassiveorderHeaderDao { + +} \ No newline at end of file diff --git a/service/src/main/java/com/hzya/frame/report/lets/dto/OfsPassiveorderDetailDto.java b/service/src/main/java/com/hzya/frame/report/lets/dto/OfsPassiveorderDetailDto.java new file mode 100644 index 00000000..64345e06 --- /dev/null +++ b/service/src/main/java/com/hzya/frame/report/lets/dto/OfsPassiveorderDetailDto.java @@ -0,0 +1,322 @@ +package com.hzya.frame.report.lets.dto; + +import com.alibaba.excel.annotation.ExcelProperty; +import com.hzya.frame.web.entity.BaseEntity; + +/** + * O无源件订单中台明细表(OfsPassiveorderDetail)实体类 + * + * @author makejava + * @since 2025-03-12 09:40:26 + */ +public class OfsPassiveorderDetailDto { + + @ExcelProperty(value = "O无源入库明细主键") + private String id; + + @ExcelProperty(value = "O无源入库单号") + private String receiptCode; + + @ExcelProperty(value = "O公司") + private String companyCode; + + @ExcelProperty(value = "O仓库") + private String facilityCode; + + @ExcelProperty(value = "O店铺") + private String storeCode; + + @ExcelProperty(value = "O关联时间") + private String relatedAt; + + @ExcelProperty(value = "业务类型") + private String businesstype; + + @ExcelProperty(value = "业务日期(关联时间)") + private String businessdate; + + @ExcelProperty(value = "O货品sku") + private String skucode; + + @ExcelProperty(value = "O货品名称") + private String skuname; + + @ExcelProperty(value = "O入库数量") + private String quantity; + + @ExcelProperty(value = "退款完成时间(取O售后订单表头)") + private String transactionDate; + + @ExcelProperty(value = "退款推送时间") + private String newpushdate2; + + @ExcelProperty(value = "退款报错详情") + private String newtransmitinfo2; + + @ExcelProperty(value = "退款推送状态") + private String newstate2; + + @ExcelProperty(value = "入库推送时间") + private String newpushdate; + + @ExcelProperty(value = "入库报错详情") + private String newtransmitinfo; + + @ExcelProperty(value = "入库推送状态") + private String newstate; + + @ExcelProperty(value = "U销售订单编码") + private String newsystemnumber; + + @ExcelProperty(value = "U销售订单主键") + private String newsystemprimary; + + @ExcelProperty(value = "U应收单号") + private String newsystemnumber2; + + @ExcelProperty(value = "U应收单主键") + private String newsystemprimary2; + + @ExcelProperty(value = "O计算应收") + private String def1; + + @ExcelProperty(value = "O计算公式") + private String def2; + + @ExcelProperty(value = "O平台优惠") + private String def3; + + @ExcelProperty(value = "O支付优惠") + private String def4; + + @ExcelProperty(value = "O达人优惠") + private String def5; + + @ExcelProperty(value = "O商家优惠") + private String def6; + + public String getReceiptCode() { + return receiptCode; + } + + public void setReceiptCode(String receiptCode) { + this.receiptCode = receiptCode; + } + + public String getCompanyCode() { + return companyCode; + } + + public void setCompanyCode(String companyCode) { + this.companyCode = companyCode; + } + + public String getFacilityCode() { + return facilityCode; + } + + public void setFacilityCode(String facilityCode) { + this.facilityCode = facilityCode; + } + + public String getStoreCode() { + return storeCode; + } + + public void setStoreCode(String storeCode) { + this.storeCode = storeCode; + } + + public String getRelatedAt() { + return relatedAt; + } + + public void setRelatedAt(String relatedAt) { + this.relatedAt = relatedAt; + } + + public String getBusinesstype() { + return businesstype; + } + + public void setBusinesstype(String businesstype) { + this.businesstype = businesstype; + } + + public String getBusinessdate() { + return businessdate; + } + + public void setBusinessdate(String businessdate) { + this.businessdate = businessdate; + } + + public String getSkucode() { + return skucode; + } + + public void setSkucode(String skucode) { + this.skucode = skucode; + } + + public String getSkuname() { + return skuname; + } + + public void setSkuname(String skuname) { + this.skuname = skuname; + } + + public String getQuantity() { + return quantity; + } + + public void setQuantity(String quantity) { + this.quantity = quantity; + } + + public String getTransactionDate() { + return transactionDate; + } + + public void setTransactionDate(String transactionDate) { + this.transactionDate = transactionDate; + } + + public String getNewpushdate2() { + return newpushdate2; + } + + public void setNewpushdate2(String newpushdate2) { + this.newpushdate2 = newpushdate2; + } + + public String getNewtransmitinfo2() { + return newtransmitinfo2; + } + + public void setNewtransmitinfo2(String newtransmitinfo2) { + this.newtransmitinfo2 = newtransmitinfo2; + } + + public String getNewstate2() { + return newstate2; + } + + public void setNewstate2(String newstate2) { + this.newstate2 = newstate2; + } + + public String getNewpushdate() { + return newpushdate; + } + + public void setNewpushdate(String newpushdate) { + this.newpushdate = newpushdate; + } + + public String getNewtransmitinfo() { + return newtransmitinfo; + } + + public void setNewtransmitinfo(String newtransmitinfo) { + this.newtransmitinfo = newtransmitinfo; + } + + public String getNewstate() { + return newstate; + } + + public void setNewstate(String newstate) { + this.newstate = newstate; + } + + public String getNewsystemnumber() { + return newsystemnumber; + } + + public void setNewsystemnumber(String newsystemnumber) { + this.newsystemnumber = newsystemnumber; + } + + public String getNewsystemprimary() { + return newsystemprimary; + } + + public void setNewsystemprimary(String newsystemprimary) { + this.newsystemprimary = newsystemprimary; + } + + public String getNewsystemnumber2() { + return newsystemnumber2; + } + + public void setNewsystemnumber2(String newsystemnumber2) { + this.newsystemnumber2 = newsystemnumber2; + } + + public String getNewsystemprimary2() { + return newsystemprimary2; + } + + public void setNewsystemprimary2(String newsystemprimary2) { + this.newsystemprimary2 = newsystemprimary2; + } + + public String getDef1() { + return def1; + } + + public void setDef1(String def1) { + this.def1 = def1; + } + + public String getDef2() { + return def2; + } + + public void setDef2(String def2) { + this.def2 = def2; + } + + public String getDef3() { + return def3; + } + + public void setDef3(String def3) { + this.def3 = def3; + } + + public String getDef4() { + return def4; + } + + public void setDef4(String def4) { + this.def4 = def4; + } + + public String getDef5() { + return def5; + } + + public void setDef5(String def5) { + this.def5 = def5; + } + + public String getDef6() { + return def6; + } + + public void setDef6(String def6) { + this.def6 = def6; + } + + public String getId() { + return id; + } + + public void setId(String id) { + this.id = id; + } +} + diff --git a/service/src/main/java/com/hzya/frame/report/lets/entity/OfsPassiveorderDetailEntity.java b/service/src/main/java/com/hzya/frame/report/lets/entity/OfsPassiveorderDetailEntity.java new file mode 100644 index 00000000..66350ef6 --- /dev/null +++ b/service/src/main/java/com/hzya/frame/report/lets/entity/OfsPassiveorderDetailEntity.java @@ -0,0 +1,486 @@ +package com.hzya.frame.report.lets.entity; + +import com.hzya.frame.web.entity.BaseEntity; + +/** + * O无源件订单中台明细表(OfsPassiveorderDetail)实体类 + * + * @author makejava + * @since 2025-03-12 09:40:26 + */ +public class OfsPassiveorderDetailEntity extends BaseEntity { + /** + * 关联主表ID[1](@ref) + */ + private String headerid; + /** + * 退货单号(与主表一致)[1](@ref) + */ + private String receiptcode; + /** + * 商品编码(示例值:6973391732529)[1](@ref) + */ + private String skucode; + /** + * 商品全称(示例值:INTO YOU心慕与你干杯唇釉OT02)[1](@ref) + */ + private String skuname; + /** + * 退货数量(示例值:1)[1](@ref) + */ + private String quantity; + /** + * 库存状态(示例值:NOT_AVAILABLE)[1](@ref) + */ + private String inventorysts; + /** + * 创建时间[1](@ref) + */ + private String created; + /** + * 创建人[1](@ref) + */ + private String createdby; + /** + * 最后更新时间[1](@ref) + */ + private String lastupdated; + /** + * 最后更新人[1](@ref) + */ + private String lastupdatedby; + /** + * 业务日期 + */ + private String businessdate; + /** + * 交易时间 + */ + private String transactionDate; + /** + * 业务类型 + */ + private String businesstype; + /** + * 推送时间-入库 + */ + private String newpushdate; + /** + * 报错详情-入库 + */ + private String newtransmitinfo; + /** + * 推送状态-入库 + */ + private String newstate; + /** + * 下游单号-入库 + */ + private String newsystemnumber; + /** + * 下游主键-入库 + */ + private String newsystemprimary; + /** + * 推送时间-交易成功 + */ + private String newpushdate2; + /** + * 报错详情-交易成功 + */ + private String newtransmitinfo2; + /** + * 推送状态-交易成功 + */ + private String newstate2; + /** + * 下游单号-交易成功 + */ + private String newsystemnumber2; + /** + * 下游主键-交易成功 + */ + private String newsystemprimary2; + + /** + * 根据 id 批量查询 + */ + private String ids; + + private String def1; + + private String def2; + + private String def3; + + private String def4; + + private String def5; + + private String def6; + + private String def7; + + private String def8; + + private String def9; + + private String def10; + + private String businessDateStart; + + private String businessDateEnd; + + /** + * 表头公司 + */ + private String companyCode; + /** + * 表头仓库 + */ + private String facilityCode; + + /** + * 表头店铺 + */ + private String storeCode; + + /** + * 表头无源入库单号 + */ + private String receiptCode; + + /** + * 关联时间 + */ + private String relatedAt; + + public String getCompanyCode() { + return companyCode; + } + + public void setCompanyCode(String companyCode) { + this.companyCode = companyCode; + } + + public String getFacilityCode() { + return facilityCode; + } + + public void setFacilityCode(String facilityCode) { + this.facilityCode = facilityCode; + } + + public String getStoreCode() { + return storeCode; + } + + public void setStoreCode(String storeCode) { + this.storeCode = storeCode; + } + + public String getReceiptCode() { + return receiptCode; + } + + public void setReceiptCode(String receiptCode) { + this.receiptCode = receiptCode; + } + + public String getRelatedAt() { + return relatedAt; + } + + public void setRelatedAt(String relatedAt) { + this.relatedAt = relatedAt; + } + + public String getBusinessDateStart() { + return businessDateStart; + } + + public void setBusinessDateStart(String businessDateStart) { + this.businessDateStart = businessDateStart; + } + + public String getBusinessDateEnd() { + return businessDateEnd; + } + + public void setBusinessDateEnd(String businessDateEnd) { + this.businessDateEnd = businessDateEnd; + } + + public String getDef1() { + return def1; + } + + public void setDef1(String def1) { + this.def1 = def1; + } + + public String getDef2() { + return def2; + } + + public void setDef2(String def2) { + this.def2 = def2; + } + + public String getDef3() { + return def3; + } + + public void setDef3(String def3) { + this.def3 = def3; + } + + public String getDef4() { + return def4; + } + + public void setDef4(String def4) { + this.def4 = def4; + } + + public String getDef5() { + return def5; + } + + public void setDef5(String def5) { + this.def5 = def5; + } + + public String getDef6() { + return def6; + } + + public void setDef6(String def6) { + this.def6 = def6; + } + + public String getDef7() { + return def7; + } + + public void setDef7(String def7) { + this.def7 = def7; + } + + public String getDef8() { + return def8; + } + + public void setDef8(String def8) { + this.def8 = def8; + } + + public String getDef9() { + return def9; + } + + public void setDef9(String def9) { + this.def9 = def9; + } + + public String getDef10() { + return def10; + } + + public void setDef10(String def10) { + this.def10 = def10; + } + + public String getIds() { + return ids; + } + + public void setIds(String ids) { + this.ids = ids; + } + + public String getHeaderid() { + return headerid; + } + + public void setHeaderid(String headerid) { + this.headerid = headerid; + } + + public String getReceiptcode() { + return receiptcode; + } + + public void setReceiptcode(String receiptcode) { + this.receiptcode = receiptcode; + } + + public String getSkucode() { + return skucode; + } + + public void setSkucode(String skucode) { + this.skucode = skucode; + } + + public String getSkuname() { + return skuname; + } + + public void setSkuname(String skuname) { + this.skuname = skuname; + } + + public String getQuantity() { + return quantity; + } + + public void setQuantity(String quantity) { + this.quantity = quantity; + } + + public String getInventorysts() { + return inventorysts; + } + + public void setInventorysts(String inventorysts) { + this.inventorysts = inventorysts; + } + + 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; + } + + public String getBusinessdate() { + return businessdate; + } + + public void setBusinessdate(String businessdate) { + this.businessdate = businessdate; + } + + public String getBusinesstype() { + return businesstype; + } + + public void setBusinesstype(String businesstype) { + this.businesstype = businesstype; + } + + public String getNewpushdate() { + return newpushdate; + } + + public void setNewpushdate(String newpushdate) { + this.newpushdate = newpushdate; + } + + public String getNewtransmitinfo() { + return newtransmitinfo; + } + + public void setNewtransmitinfo(String newtransmitinfo) { + this.newtransmitinfo = newtransmitinfo; + } + + public String getNewstate() { + return newstate; + } + + public void setNewstate(String newstate) { + this.newstate = newstate; + } + + public String getNewsystemnumber() { + return newsystemnumber; + } + + public void setNewsystemnumber(String newsystemnumber) { + this.newsystemnumber = newsystemnumber; + } + + public String getNewsystemprimary() { + return newsystemprimary; + } + + public void setNewsystemprimary(String newsystemprimary) { + this.newsystemprimary = newsystemprimary; + } + + public String getNewpushdate2() { + return newpushdate2; + } + + public void setNewpushdate2(String newpushdate2) { + this.newpushdate2 = newpushdate2; + } + + public String getNewtransmitinfo2() { + return newtransmitinfo2; + } + + public void setNewtransmitinfo2(String newtransmitinfo2) { + this.newtransmitinfo2 = newtransmitinfo2; + } + + public String getNewstate2() { + return newstate2; + } + + public void setNewstate2(String newstate2) { + this.newstate2 = newstate2; + } + + public String getNewsystemnumber2() { + return newsystemnumber2; + } + + public void setNewsystemnumber2(String newsystemnumber2) { + this.newsystemnumber2 = newsystemnumber2; + } + + public String getNewsystemprimary2() { + return newsystemprimary2; + } + + public void setNewsystemprimary2(String newsystemprimary2) { + this.newsystemprimary2 = newsystemprimary2; + } + + public String getTransactionDate() { + return transactionDate; + } + + public void setTransactionDate(String transactionDate) { + this.transactionDate = transactionDate; + } +} + diff --git a/service/src/main/java/com/hzya/frame/report/lets/entity/OfsPassiveorderDetailEntity.xml b/service/src/main/java/com/hzya/frame/report/lets/entity/OfsPassiveorderDetailEntity.xml new file mode 100644 index 00000000..bb9b2eeb --- /dev/null +++ b/service/src/main/java/com/hzya/frame/report/lets/entity/OfsPassiveorderDetailEntity.xml @@ -0,0 +1,554 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + id + ,headerId + ,receiptCode + ,skuCode + ,skuName + ,quantity + ,inventorySts + ,created + ,createdBy + ,lastUpdated + ,lastUpdatedBy + ,businessDate + ,businessType + ,newPushDate + ,newTransmitInfo + ,newState + ,newsystemnumber + ,newsystemprimary + ,newPushDate2 + ,newTransmitInfo2 + ,newState2 + ,newsystemnumber2 + ,newsystemprimary2 + + + + + + + + + + + + + + + + + + + + insert into ofs_passiveorder_detail( + + id , + headerId , + receiptCode , + skuCode , + skuName , + quantity , + inventorySts , + created , + createdBy , + lastUpdated , + lastUpdatedBy , + businessDate , + businessType , + newPushDate , + newTransmitInfo , + newState , + newsystemnumber , + newsystemprimary , + newPushDate2 , + newTransmitInfo2 , + newState2 , + newsystemnumber2 , + newsystemprimary2 , + sorts, + sts, + + )values( + + #{id} , + #{headerid} , + #{receiptcode} , + #{skucode} , + #{skuname} , + #{quantity} , + #{inventorysts} , + #{created} , + #{createdby} , + #{lastupdated} , + #{lastupdatedby} , + #{businessdate} , + #{businesstype} , + #{newpushdate} , + #{newtransmitinfo} , + #{newstate} , + #{newsystemnumber} , + #{newsystemprimary} , + #{newpushdate2} , + #{newtransmitinfo2} , + #{newstate2} , + #{newsystemnumber2} , + #{newsystemprimary2} , + (select (max(IFNULL( a.sorts, 0 )) + 1) as sort from ofs_passiveorder_detail a WHERE a.sts = 'Y' ), + 'Y', + + ) + + + + + insert into ofs_passiveorder_detail(headerId, receiptCode, skuCode, skuName, quantity, inventorySts, created, createdBy, lastUpdated, lastUpdatedBy, businessDate, businessType, newPushDate, newTransmitInfo, newState, newsystemnumber, newsystemprimary, newPushDate2, newTransmitInfo2, newState2, newsystemnumber2, newsystemprimary2, sts) + values + + (#{entity.headerid},#{entity.receiptcode},#{entity.skucode},#{entity.skuname},#{entity.quantity},#{entity.inventorysts},#{entity.created},#{entity.createdby},#{entity.lastupdated},#{entity.lastupdatedby},#{entity.businessdate},#{entity.businesstype},#{entity.newpushdate},#{entity.newtransmitinfo},#{entity.newstate},#{entity.newsystemnumber},#{entity.newsystemprimary},#{entity.newpushdate2},#{entity.newtransmitinfo2},#{entity.newstate2},#{entity.newsystemnumber2},#{entity.newsystemprimary2}, 'Y') + + + + + + insert into ofs_passiveorder_detail(id,headerId, receiptCode, skuCode, skuName, quantity, inventorySts, created, createdBy, lastUpdated, lastUpdatedBy, businessDate, businessType) + values + + (#{entity.id},#{entity.headerid},#{entity.receiptcode},#{entity.skucode},#{entity.skuname},#{entity.quantity},#{entity.inventorysts},#{entity.created},#{entity.createdby},#{entity.lastupdated},#{entity.lastupdatedby},#{entity.businessdate},#{entity.businesstype}) + + on duplicate key update + id = values(id), + headerId = values(headerId), + receiptCode = values(receiptCode), + skuCode = values(skuCode), + skuName = values(skuName), + quantity = values(quantity), + inventorySts = values(inventorySts), + created = values(created), + createdBy = values(createdBy), + lastUpdated = values(lastUpdated), + lastUpdatedBy = values(lastUpdatedBy), + businessDate = values(businessDate), + businessType = values(businessType) + + + + + insert into ofs_passiveorder_detail(id,newPushDate, newTransmitInfo, newState, newsystemnumber, newsystemprimary,transactionDate,def1,def2,def3,def4,def5,def6,def7,def8,def9,def10) + values + + (#{entity.id},#{entity.newpushdate},#{entity.newtransmitinfo},#{entity.newstate},#{entity.newsystemnumber},#{entity.newsystemprimary},#{entity.transactionDate},#{entity.def1},#{entity.def2},#{entity.def3},#{entity.def4},#{entity.def5},#{entity.def6},#{entity.def7},#{entity.def8},#{entity.def9},#{entity.def10}) + + on duplicate key update + id = values(id), + newPushDate = values(newPushDate), + newTransmitInfo = values(newTransmitInfo), + newState = values(newState), + newsystemnumber = values(newsystemnumber), + newsystemprimary = values(newsystemprimary), + transactionDate = values(transactionDate), + def1 = values(def1), + def2 = values(def2), + def3 = values(def3), + def4 = values(def4), + def5 = values(def5), + def6 = values(def6), + def7 = values(def7), + def8 = values(def8), + def9 = values(def9), + def10 = values(def10) + + + + + insert into ofs_passiveorder_detail(id,newPushDate2, newTransmitInfo2, newState2, newsystemnumber2, newsystemprimary2,transactionDate,def1,def2,def3,def4,def5,def6,def7,def8,def9,def10) + values + + (#{entity.id},#{entity.newpushdate2},#{entity.newtransmitinfo2},#{entity.newstate2},#{entity.newsystemnumber2},#{entity.newsystemprimary2},#{entity.transactionDate},#{entity.def1},#{entity.def2},#{entity.def3},#{entity.def4},#{entity.def5},#{entity.def6},#{entity.def7},#{entity.def8},#{entity.def9},#{entity.def10}) + + on duplicate key update + id = values(id), + newPushDate2 = values(newPushDate2), + newTransmitInfo2 = values(newTransmitInfo2), + newState2 = values(newState2), + newsystemnumber2 = values(newsystemnumber2), + newsystemprimary2 = values(newsystemprimary2), + transactionDate = values(transactionDate), + def1 = values(def1), + def2 = values(def2), + def3 = values(def3), + def4 = values(def4), + def5 = values(def5), + def6 = values(def6), + def7 = values(def7), + def8 = values(def8), + def9 = values(def9), + def10 = values(def10) + + + + +update ofs_passiveorder_detail set + + headerId = #{headerid}, + receiptCode = #{receiptcode}, + skuCode = #{skucode}, + skuName = #{skuname}, + quantity = #{quantity}, + inventorySts = #{inventorysts}, + created = #{created}, + createdBy = #{createdby}, + lastUpdated = #{lastupdated}, + lastUpdatedBy = #{lastupdatedby}, + businessDate = #{businessdate}, + businessType = #{businesstype}, + newPushDate = #{newpushdate}, + newTransmitInfo = #{newtransmitinfo}, + newState = #{newstate}, + newsystemnumber = #{newsystemnumber}, + newsystemprimary = #{newsystemprimary}, + newPushDate2 = #{newpushdate2}, + newTransmitInfo2 = #{newtransmitinfo2}, + newState2 = #{newstate2}, + newsystemnumber2 = #{newsystemnumber2}, + newsystemprimary2 = #{newsystemprimary2}, + +where id = #{id} + + + +update ofs_passiveorder_detail set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} +where id = #{id} + + + +update ofs_passiveorder_detail set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and headerId = #{headerid} + and receiptCode = #{receiptcode} + and skuCode = #{skucode} + and skuName = #{skuname} + and quantity = #{quantity} + and inventorySts = #{inventorysts} + and created = #{created} + and createdBy = #{createdby} + and lastUpdated = #{lastupdated} + and lastUpdatedBy = #{lastupdatedby} + and businessDate = #{businessdate} + and businessType = #{businesstype} + and newPushDate = #{newpushdate} + and newTransmitInfo = #{newtransmitinfo} + and newState = #{newstate} + and newsystemnumber = #{newsystemnumber} + and newsystemprimary = #{newsystemprimary} + and newPushDate2 = #{newpushdate2} + and newTransmitInfo2 = #{newtransmitinfo2} + and newState2 = #{newstate2} + and newsystemnumber2 = #{newsystemnumber2} + and newsystemprimary2 = #{newsystemprimary2} + and sts='Y' + + + + + delete from ofs_passiveorder_detail where id = #{id} + + + + diff --git a/service/src/main/java/com/hzya/frame/report/lets/entity/OfsPassiveorderHeaderEntity.java b/service/src/main/java/com/hzya/frame/report/lets/entity/OfsPassiveorderHeaderEntity.java new file mode 100644 index 00000000..fa97f74d --- /dev/null +++ b/service/src/main/java/com/hzya/frame/report/lets/entity/OfsPassiveorderHeaderEntity.java @@ -0,0 +1,243 @@ +package com.hzya.frame.report.lets.entity; + +import com.hzya.frame.web.entity.BaseEntity; + +/** + * O无源件订单中台主表(OfsPassiveorderHeader)实体类 + * + * @author makejava + * @since 2025-03-12 09:39:53 + */ +public class OfsPassiveorderHeaderEntity extends BaseEntity { + /** + * 客户端编码(示例值:LETS)[1](@ref) + */ + private String clientcode; + /** + * 公司编码(示例值:SHLZ)[1](@ref) + */ + private String companycode; + /** + * 仓库设施编码(示例值:B2CHA20240033)[1](@ref) + */ + private String facilitycode; + /** + * 店铺编码(示例值:pdd-intoyoucz)[1](@ref) + */ + private String storecode; + /** + * 退货单号(示例值:RH20250220000460)[1](@ref) + */ + private String receiptcode; + /** + * 仓库编码(示例值:LETS2C)[1](@ref) + */ + private String warehousecode; + /** + * 退货运单号(示例值:1376811761602)[1](@ref) + */ + private String returnwaybillcode; + /** + * 源退货单号(示例值:117180732225)[1](@ref) + */ + private String sourcereturncode; + /** + * 源订单号(示例值:250206-088457951590214)[1](@ref) + */ + private String sourceordercode; + /** + * 退货订单号(示例值:LETS-RO2025021500008714)[1](@ref) + */ + private String returnordercode; + /** + * 实际退款金额(示例值:29.9)[1](@ref) + */ + private String actualrefundamount; + /** + * 退货时间(ISO8601格式)[1](@ref) + */ + private String returntime; + /** + * 关联时间(ISO8601格式)[1](@ref) + */ + private String relatedat; + /** + * 状态码(示例值:2)[1](@ref) + */ + private String status; + /** + * 创建时间[1](@ref) + */ + private String created; + /** + * 创建人(示例值:api)[1](@ref) + */ + private String createdby; + /** + * 最后更新时间[1](@ref) + */ + private String lastupdated; + /** + * 最后更新人[1](@ref) + */ + private String lastupdatedby; + + /** + * 根据 id 多次查询 + */ + private String ids; + + public String getIds() { + return ids; + } + + public void setIds(String ids) { + this.ids = ids; + } + + public String getClientcode() { + return clientcode; + } + + public void setClientcode(String clientcode) { + this.clientcode = clientcode; + } + + public String getCompanycode() { + return companycode; + } + + public void setCompanycode(String companycode) { + this.companycode = companycode; + } + + public String getFacilitycode() { + return facilitycode; + } + + public void setFacilitycode(String facilitycode) { + this.facilitycode = facilitycode; + } + + public String getStorecode() { + return storecode; + } + + public void setStorecode(String storecode) { + this.storecode = storecode; + } + + public String getReceiptcode() { + return receiptcode; + } + + public void setReceiptcode(String receiptcode) { + this.receiptcode = receiptcode; + } + + public String getWarehousecode() { + return warehousecode; + } + + public void setWarehousecode(String warehousecode) { + this.warehousecode = warehousecode; + } + + public String getReturnwaybillcode() { + return returnwaybillcode; + } + + public void setReturnwaybillcode(String returnwaybillcode) { + this.returnwaybillcode = returnwaybillcode; + } + + public String getSourcereturncode() { + return sourcereturncode; + } + + public void setSourcereturncode(String sourcereturncode) { + this.sourcereturncode = sourcereturncode; + } + + public String getSourceordercode() { + return sourceordercode; + } + + public void setSourceordercode(String sourceordercode) { + this.sourceordercode = sourceordercode; + } + + public String getReturnordercode() { + return returnordercode; + } + + public void setReturnordercode(String returnordercode) { + this.returnordercode = returnordercode; + } + + public String getActualrefundamount() { + return actualrefundamount; + } + + public void setActualrefundamount(String actualrefundamount) { + this.actualrefundamount = actualrefundamount; + } + + public String getReturntime() { + return returntime; + } + + public void setReturntime(String returntime) { + this.returntime = returntime; + } + + public String getRelatedat() { + return relatedat; + } + + public void setRelatedat(String relatedat) { + this.relatedat = relatedat; + } + + public String getStatus() { + return status; + } + + public void setStatus(String status) { + this.status = status; + } + + 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; + } + +} + diff --git a/service/src/main/java/com/hzya/frame/report/lets/entity/OfsPassiveorderHeaderEntity.xml b/service/src/main/java/com/hzya/frame/report/lets/entity/OfsPassiveorderHeaderEntity.xml new file mode 100644 index 00000000..994aa906 --- /dev/null +++ b/service/src/main/java/com/hzya/frame/report/lets/entity/OfsPassiveorderHeaderEntity.xml @@ -0,0 +1,322 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + id + ,clientCode + ,companyCode + ,facilityCode + ,storeCode + ,receiptCode + ,warehouseCode + ,returnWaybillCode + ,sourceReturnCode + ,sourceOrderCode + ,returnOrderCode + ,actualRefundAmount + ,returnTime + ,relatedAt + ,status + ,created + ,createdBy + ,lastUpdated + ,lastUpdatedBy + + + + + + + + + + + + + + + + insert into ofs_passiveorder_header( + + id , + clientCode , + companyCode , + facilityCode , + storeCode , + receiptCode , + warehouseCode , + returnWaybillCode , + sourceReturnCode , + sourceOrderCode , + returnOrderCode , + actualRefundAmount , + returnTime , + relatedAt , + status , + created , + createdBy , + lastUpdated , + lastUpdatedBy , + sorts, + sts, + + )values( + + #{id} , + #{clientcode} , + #{companycode} , + #{facilitycode} , + #{storecode} , + #{receiptcode} , + #{warehousecode} , + #{returnwaybillcode} , + #{sourcereturncode} , + #{sourceordercode} , + #{returnordercode} , + #{actualrefundamount} , + #{returntime} , + #{relatedat} , + #{status} , + #{created} , + #{createdby} , + #{lastupdated} , + #{lastupdatedby} , + (select (max(IFNULL( a.sorts, 0 )) + 1) as sort from ofs_passiveorder_header a WHERE a.sts = 'Y' ), + 'Y', + + ) + + + + insert into ofs_passiveorder_header(clientCode, companyCode, facilityCode, storeCode, receiptCode, warehouseCode, returnWaybillCode, sourceReturnCode, sourceOrderCode, returnOrderCode, actualRefundAmount, returnTime, relatedAt, status, created, createdBy, lastUpdated, lastUpdatedBy, sts) + values + + (#{entity.clientcode},#{entity.companycode},#{entity.facilitycode},#{entity.storecode},#{entity.receiptcode},#{entity.warehousecode},#{entity.returnwaybillcode},#{entity.sourcereturncode},#{entity.sourceordercode},#{entity.returnordercode},#{entity.actualrefundamount},#{entity.returntime},#{entity.relatedat},#{entity.status},#{entity.created},#{entity.createdby},#{entity.lastupdated},#{entity.lastupdatedby}, 'Y') + + + + + + insert into ofs_passiveorder_header(id,clientCode, companyCode, facilityCode, storeCode, receiptCode, warehouseCode, returnWaybillCode, sourceReturnCode, sourceOrderCode, returnOrderCode, actualRefundAmount, returnTime, relatedAt, status, created, createdBy, lastUpdated, lastUpdatedBy) + values + + (#{entity.id},#{entity.clientcode},#{entity.companycode},#{entity.facilitycode},#{entity.storecode},#{entity.receiptcode},#{entity.warehousecode},#{entity.returnwaybillcode},#{entity.sourcereturncode},#{entity.sourceordercode},#{entity.returnordercode},#{entity.actualrefundamount},#{entity.returntime},#{entity.relatedat},#{entity.status},#{entity.created},#{entity.createdby},#{entity.lastupdated},#{entity.lastupdatedby}) + + on duplicate key update + id = values(id), + clientCode = values(clientCode), + companyCode = values(companyCode), + facilityCode = values(facilityCode), + storeCode = values(storeCode), + receiptCode = values(receiptCode), + warehouseCode = values(warehouseCode), + returnWaybillCode = values(returnWaybillCode), + sourceReturnCode = values(sourceReturnCode), + sourceOrderCode = values(sourceOrderCode), + returnOrderCode = values(returnOrderCode), + actualRefundAmount = values(actualRefundAmount), + returnTime = values(returnTime), + relatedAt = values(relatedAt), + status = values(status), + created = values(created), + createdBy = values(createdBy), + lastUpdated = values(lastUpdated), + lastUpdatedBy = values(lastUpdatedBy) + + + + +update ofs_passiveorder_header set + + clientCode = #{clientcode}, + companyCode = #{companycode}, + facilityCode = #{facilitycode}, + storeCode = #{storecode}, + receiptCode = #{receiptcode}, + warehouseCode = #{warehousecode}, + returnWaybillCode = #{returnwaybillcode}, + sourceReturnCode = #{sourcereturncode}, + sourceOrderCode = #{sourceordercode}, + returnOrderCode = #{returnordercode}, + actualRefundAmount = #{actualrefundamount}, + returnTime = #{returntime}, + relatedAt = #{relatedat}, + status = #{status}, + created = #{created}, + createdBy = #{createdby}, + lastUpdated = #{lastupdated}, + lastUpdatedBy = #{lastupdatedby}, + +where id = #{id} + + + +update ofs_passiveorder_header set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} +where id = #{id} + + + +update ofs_passiveorder_header set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and clientCode = #{clientcode} + and companyCode = #{companycode} + and facilityCode = #{facilitycode} + and storeCode = #{storecode} + and receiptCode = #{receiptcode} + and warehouseCode = #{warehousecode} + and returnWaybillCode = #{returnwaybillcode} + and sourceReturnCode = #{sourcereturncode} + and sourceOrderCode = #{sourceordercode} + and returnOrderCode = #{returnordercode} + and actualRefundAmount = #{actualrefundamount} + and returnTime = #{returntime} + and relatedAt = #{relatedat} + and status = #{status} + and created = #{created} + and createdBy = #{createdby} + and lastUpdated = #{lastupdated} + and lastUpdatedBy = #{lastupdatedby} + and sts='Y' + + + + + delete from ofs_passiveorder_header where id = #{id} + + + + diff --git a/service/src/main/java/com/hzya/frame/report/lets/service/ITocofsSaleoutService.java b/service/src/main/java/com/hzya/frame/report/lets/service/ITocofsSaleoutService.java index d5d2dba4..0ff7db69 100644 --- a/service/src/main/java/com/hzya/frame/report/lets/service/ITocofsSaleoutService.java +++ b/service/src/main/java/com/hzya/frame/report/lets/service/ITocofsSaleoutService.java @@ -37,4 +37,18 @@ public interface ITocofsSaleoutService extends IBaseService ofsPassiveorderHeaderEntityList = iOfsPassiveorderDetailDao.query(ofsPassiveorderDetailEntity); + PageInfo pageInfo = new PageInfo(ofsPassiveorderHeaderEntityList); + return BaseResult.getSuccessMessageEntity("查询成功", pageInfo); + } else if ("excel".equals(qType)) { + //导出模式 + List ofsPassiveorderDetailDtos = new ArrayList<>(); + try { + ofsPassiveorderDetailDtos = iOfsPassiveorderDetailDao.queryPassiveComponentsExport(ofsPassiveorderDetailEntity); + } catch (Exception e) { + logger.error("导出模式下,查询目标数据失败!", e); + } + return BaseResult.getSuccessMessageEntity("查询成功", ofsPassiveorderDetailDtos); + } else { + return BaseResult.getFailureMessageEntity("查询失败,无法确定查询模式!请选择:查询模式 query、导出模式 excel!"); + } + } + + @Override + public JsonResultEntity queryPassiveComponentsReportExcel(JSONObject jsonObject) throws Exception { + Assert.notNull(jsonObject, "jsonObject不能为空"); + JSONObject jsonStr = getstrObj("jsonStr", jsonObject); + Assert.notNull(jsonStr, "jsonStr对象不能为空!"); + jsonStr.put("qType", "excel"); + jsonObject.put("jsonStr", jsonStr); + + JsonResultEntity jsonResultEntity = queryPassiveComponentsReport(jsonObject); + if (jsonResultEntity != null && jsonResultEntity.getAttribute() != null) { + InputStream templateFileName = this.getClass().getClassLoader().getResourceAsStream(reportTemplatesurl); + String[] excelFile = createExcelFile(); + + List tocofsSaleoutDetailedEntityList = (List) jsonResultEntity.getAttribute(); + EasyExcel.write(excelFile[0], OfsPassiveorderDetailDto.class).withTemplate(templateFileName).sheet().doWrite(tocofsSaleoutDetailedEntityList); + return BaseResult.getSuccessMessageEntity(excelFile[1]); + } else { + return BaseResult.getFailureMessageEntity("导出Excel,查询数据失败!"); + } + } } + + + diff --git a/service/src/main/java/com/hzya/frame/ttxofs/service/impl/OfsUnifiedServiceImpl.java b/service/src/main/java/com/hzya/frame/ttxofs/service/impl/OfsUnifiedServiceImpl.java index 3317aca9..f8539501 100644 --- a/service/src/main/java/com/hzya/frame/ttxofs/service/impl/OfsUnifiedServiceImpl.java +++ b/service/src/main/java/com/hzya/frame/ttxofs/service/impl/OfsUnifiedServiceImpl.java @@ -148,6 +148,14 @@ public class OfsUnifiedServiceImpl implements OfsUnifiedService { //创建自定义的httpclient对象 CloseableHttpClient client = HttpClients.custom().build(); HttpPost post = new HttpPost(url); + // 设置超时参数,10分钟 + RequestConfig requestConfig = RequestConfig.custom() + .setConnectTimeout(600000) + .setSocketTimeout(600000) + .setConnectionRequestTimeout(600000) + .build(); + post.setConfig(requestConfig); + CloseableHttpResponse res = null; try { List nvps = new ArrayList();