From fc5df9c0488abdc37b3f464672dc2c41c44b169b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=B0=8C=E5=85=88=E8=88=9C?= <2499071264@qq.com>
Date: Thu, 3 Sep 2026 18:13:09 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E7=A7=AF=E5=88=86=E5=95=86=E5=9F=8E-?=
=?UTF-8?q?=E4=BE=9B=E5=BA=94=E5=95=86-=E5=AF=B9=E8=B4=A6-=E5=8F=91?=
=?UTF-8?q?=E7=A5=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
esf-relay/src/server.mjs | 2 +
supplied-h5/src/store/user.js | 31 +-
.../src/view/joyful-selection/layout.vue | 12 +-
.../view/joyful-selection/merchant/index.vue | 32 +-
.../joyful-selection/profile/orders/index.vue | 58 ++
supplied-service/package-lock.json | 334 +++++++++++
supplied-service/package.json | 1 +
supplied-service/prisma/schema.prisma | 31 +-
.../prisma/sql/refund-exchange-invoice.sql | 12 +-
supplied-service/prisma/sql/supplier-file.sql | 16 +
.../prisma/sql/supplier-invoice-flow.sql | 12 +
.../src/controllers/order.controller.ts | 26 +-
.../src/controllers/supplier.controller.ts | 20 +-
supplied-service/src/dao/order.dao.ts | 12 +-
supplied-service/src/server.ts | 31 +-
.../src/services/order-push-event.service.ts | 1 -
.../services/reconciliation-result.service.ts | 150 +++--
.../src/services/supplier-file.service.ts | 53 ++
.../services/supplier-open-order.service.ts | 535 ++++++++++++------
.../src/services/supplier.service.ts | 64 ++-
supplied-service/src/utils/bridge-auth.ts | 12 +-
.../src/utils/supplier-open-crypto.ts | 12 +-
supplied-service/tools/mock-invoice-pdf.d.ts | 11 +
supplied-service/tools/mock-invoice-pdf.js | 42 +-
24 files changed, 1216 insertions(+), 294 deletions(-)
create mode 100644 supplied-service/prisma/sql/supplier-file.sql
create mode 100644 supplied-service/prisma/sql/supplier-invoice-flow.sql
create mode 100644 supplied-service/src/services/supplier-file.service.ts
create mode 100644 supplied-service/tools/mock-invoice-pdf.d.ts
diff --git a/esf-relay/src/server.mjs b/esf-relay/src/server.mjs
index cba117f..f1b8fd9 100644
--- a/esf-relay/src/server.mjs
+++ b/esf-relay/src/server.mjs
@@ -7,6 +7,8 @@ const addressRoutes = new Map([
['/supplierOpenApi/pointOrder/queryOrderInfo', '/supplierOpenApi/pointOrder/queryOrderInfo'],
['/supplierOpenApi/pointOrder/queryReconciliationInfo', '/supplierOpenApi/pointOrder/queryReconciliationInfo'],
['/supplierOpenApi/pointOrder/applyForInvoices', '/supplierOpenApi/pointOrder/applyForInvoices'],
+ ['/supplierOpenApi/pointOrder/queryInvoicesInfo', '/supplierOpenApi/pointOrder/queryInvoicesInfo'],
+ ['/supplierOpenApi/pointOrder/queryFileBase64Info', '/supplierOpenApi/pointOrder/queryFileBase64Info'],
['/supplierOpenApi/pointOrder/unReconciledMsg', '/supplierOpenApi/pointOrder/unReconciledMsg'],
['/supplierOpenApi/pointOrder/reconciliationResult', '/supplierOpenApi/pointOrder/reconciliationResult']
])
diff --git a/supplied-h5/src/store/user.js b/supplied-h5/src/store/user.js
index 60af0f4..1d2137c 100644
--- a/supplied-h5/src/store/user.js
+++ b/supplied-h5/src/store/user.js
@@ -20,7 +20,6 @@ const saveUser = data => {
export const useUserStore = defineStore('joyfulSelectionUser', {
state: () => ({
userId: '',
- encryptedParam: '',
supplierIdentification: '',
supplierId: '',
supplierName: '',
@@ -54,16 +53,27 @@ export const useUserStore = defineStore('joyfulSelectionUser', {
})
this.loaded = true
},
- hydrateFromRoute(query = {}) {
+ async hydrateFromRoute(query = {}) {
if (!this.loaded) {
this.loadUser()
}
- const encryptedParam = query.AplParmObjct || query.aplParmObjct || ''
+ const keyword = query.keyword || new URLSearchParams(window.location.search).get('keyword') || ''
+ let nextUserId = query.userId || ''
- if (encryptedParam) {
- this.encryptedParam = encryptedParam
- this.userId = ''
+ if (keyword) {
+ const sessionKeyword = String(keyword).replace(/ /g, '+')
+ console.log('[supplier-session] keyword', {
+ routeKeyword: query.keyword,
+ searchKeyword: new URLSearchParams(window.location.search).get('keyword') || '',
+ sessionKeyword
+ })
+ const data = await postFunction('supplier-session', { keyword: sessionKeyword })
+ nextUserId = data?.userId || ''
+ }
+
+ if (nextUserId && nextUserId !== this.userId) {
+ this.userId = nextUserId
this.pointsBalance = 0
}
if (!this.supplierIdentification) {
@@ -92,10 +102,7 @@ export const useUserStore = defineStore('joyfulSelectionUser', {
if (!this.loaded) {
this.loadUser()
}
- if (!this.supplierIdentification || (!this.encryptedParam && this.hasToken)) {
- return
- }
- if (!this.encryptedParam) {
+ if (!this.userId || !this.supplierIdentification || this.hasToken) {
return
}
if (this.loadingToken && bridgeTokenPromise) {
@@ -109,12 +116,10 @@ export const useUserStore = defineStore('joyfulSelectionUser', {
}
const data = await postFunction('supplier-token', {
- AplParmObjct: this.encryptedParam,
+ userId: this.userId,
supplierIdentification: this.supplierIdentification
})
- this.userId = data?.userId || ''
- this.encryptedParam = ''
this.supplierId = data?.supplierId || this.supplierId
this.supplierName = data?.supplierName || this.supplierName
this.persistUser()
diff --git a/supplied-h5/src/view/joyful-selection/layout.vue b/supplied-h5/src/view/joyful-selection/layout.vue
index 1234ed9..01d42d6 100644
--- a/supplied-h5/src/view/joyful-selection/layout.vue
+++ b/supplied-h5/src/view/joyful-selection/layout.vue
@@ -49,15 +49,17 @@ export default {
methods: {
...mapActions(useCartStore, ['loadCart']),
...mapActions(useUserStore, ['hydrateFromRoute', 'fetchBridgeToken']),
- prepareUserSession() {
+ async prepareUserSession() {
this.sessionLoading = true
- this.hydrateFromRoute(this.$route.query)
- this.fetchBridgeToken().catch(error => {
+ try {
+ await this.hydrateFromRoute(this.$route.query)
+ await this.fetchBridgeToken()
+ } catch (error) {
console.warn('获取平台授权令牌失败', error)
this.$toast(error.message || '供应商验证失败,请稍后再试')
- }).finally(() => {
+ } finally {
this.sessionLoading = false
- })
+ }
}
}
}
diff --git a/supplied-h5/src/view/joyful-selection/merchant/index.vue b/supplied-h5/src/view/joyful-selection/merchant/index.vue
index e6b6e1a..5092833 100644
--- a/supplied-h5/src/view/joyful-selection/merchant/index.vue
+++ b/supplied-h5/src/view/joyful-selection/merchant/index.vue
@@ -6,6 +6,7 @@
+
@@ -359,11 +360,26 @@ export default {
openShipPopup(item) {
this.currentOrder = item
this.shipForm = {
- crrgBsnNm: item.crrgBsnNm || '',
- logisticsOrderId: item.logisticsOrderId || ''
+ crrgBsnNm: item.crrgBsnNm || '韵达快递',
+ logisticsOrderId: item.logisticsOrderId || 'YT20260903142053001'
}
this.showShipPopup = true
},
+ async quickShipAll() {
+ await Dialog.confirm({
+ title: '确认一键发货?',
+ message: `将为当前 ${this.orderItems.length} 个待发货订单提交发货。`
+ })
+ await Promise.all(this.orderItems.map(item => postFunction('merchant-order-ship', {
+ supplierId: this.supplierId,
+ userId: item.userId,
+ orderId: item.orderId,
+ crrgBsnNm: item.crrgBsnNm || '韵达快递',
+ logisticsOrderId: item.logisticsOrderId || 'YT20260903142053001'
+ })))
+ Toast('批量发货成功')
+ await this.loadOrders()
+ },
async submitShip() {
if (!this.shipForm.crrgBsnNm || !this.shipForm.logisticsOrderId) {
Toast('请填写完整发货信息')
@@ -467,6 +483,18 @@ export default {
padding: 12px 10px 18px;
}
+.batch-ship-button {
+ width: 100%;
+ height: 38px;
+ margin-bottom: 12px;
+ border: 0;
+ border-radius: 8px;
+ color: #fff;
+ font-size: 14px;
+ font-weight: 700;
+ background: linear-gradient(90deg, #ff6a2a 0%, #ff4b18 100%);
+}
+
.work-card {
position: relative;
margin-bottom: 12px;
diff --git a/supplied-h5/src/view/joyful-selection/profile/orders/index.vue b/supplied-h5/src/view/joyful-selection/profile/orders/index.vue
index bcf1fe2..3f9fafb 100644
--- a/supplied-h5/src/view/joyful-selection/profile/orders/index.vue
+++ b/supplied-h5/src/view/joyful-selection/profile/orders/index.vue
@@ -15,6 +15,15 @@
+
+ 一键收货({{ receivableOrders.length }})
+
@@ -164,6 +173,11 @@ export default {
activeTab() {
return this.tabs[this.active] || this.tabs[0]
},
+ receivableOrders() {
+ return this.visibleOrders.filter(order => {
+ return order.displayType === 'sub' && Number(order.orderState) === ORDER_STATE.IN_PROGRESS
+ })
+ },
visibleOrders() {
const tab = this.activeTab
@@ -321,6 +335,44 @@ export default {
this.refreshing = false
}
},
+ async confirmReceiveAll() {
+ try {
+ await Dialog.confirm({
+ title: '一键收货',
+ message: `确定将当前 ${this.receivableOrders.length} 个订单全部确认收货吗?`
+ })
+ } catch (error) {
+ return
+ }
+
+ this.operationKey = 'batch-confirm-receive'
+ try {
+ await this.fetchBridgeToken()
+ if (!this.supplierId || !this.userId) {
+ Toast('用户信息不完整,请重新进入商城')
+ return
+ }
+
+ await Promise.all(this.receivableOrders.map(order => postFunction('order-push-event', {
+ supplierId: this.supplierId,
+ userId: this.userId,
+ orderType: ORDER_EVENT_TYPE.CONFIRM_RECEIVE,
+ orderId: order.orderId,
+ mainOrderId: order.mainOrderId,
+ subOrderId: order.orderId,
+ amount: Number(order.amount || 0),
+ reason: '确认收货',
+ time: Date.now()
+ })))
+
+ Toast('批量收货成功')
+ await this.loadOrders()
+ } catch (error) {
+ Toast(error.message || '批量收货失败,请稍后再试')
+ } finally {
+ this.operationKey = ''
+ }
+ },
orderActions(order) {
if (order.displayType === 'main') {
return Number(order.orderState) === ORDER_STATE.PENDING_PAY
@@ -583,6 +635,12 @@ export default {
padding: 12px 10px 18px;
}
+.batch-receive-button {
+ margin-bottom: 12px;
+ color: #ff5b20;
+ background: #fff1e8;
+}
+
.order-card {
overflow: hidden;
margin-bottom: 14px;
diff --git a/supplied-service/package-lock.json b/supplied-service/package-lock.json
index 9a59a39..d225d1e 100644
--- a/supplied-service/package-lock.json
+++ b/supplied-service/package-lock.json
@@ -17,6 +17,7 @@
"ioredis": "^5.4.2",
"koa": "^2.15.3",
"koa-bodyparser": "^4.4.1",
+ "minio": "^8.0.5",
"ws": "^8.18.3"
},
"devDependencies": {
@@ -510,6 +511,18 @@
"node": ">=19.0.0"
}
},
+ "node_modules/@nodable/entities": {
+ "version": "3.0.0",
+ "resolved": "https://registry.npmjs.org/@nodable/entities/-/entities-3.0.0.tgz",
+ "integrity": "sha512-8L9xFeTYKhm49xfIypoe2W5wV1m/3Z58kT+7kR9A8OyFxcPduI4VmxaUMQyKYrRjUoLLSXv6EKKID5Tvj9cUVw==",
+ "funding": [
+ {
+ "type": "github",
+ "url": "https://github.com/sponsors/nodable"
+ }
+ ],
+ "license": "MIT"
+ },
"node_modules/@prisma/adapter-neon": {
"version": "6.19.3",
"resolved": "https://registry.npmjs.org/@prisma/adapter-neon/-/adapter-neon-6.19.3.tgz",
@@ -840,6 +853,48 @@
"node": ">= 0.6"
}
},
+ "node_modules/anynum": {
+ "version": "1.0.1",
+ "resolved": "https://registry.npmjs.org/anynum/-/anynum-1.0.1.tgz",
+ "integrity": "sha512-N6//FLET/tXYNM/F6ABca1oH6fWB+KlTt909Le28WMDBk8oaT4vY17DCrwg2MvmuqUKt3Ni4N5dGJ/EoBgcO6A==",
+ "funding": [
+ {
+ "type": "github",
+ "url": "https://github.com/sponsors/NaturalIntelligence"
+ }
+ ],
+ "license": "MIT"
+ },
+ "node_modules/async": {
+ "version": "3.2.6",
+ "resolved": "https://registry.npmjs.org/async/-/async-3.2.6.tgz",
+ "integrity": "sha512-htCUDlxyyCLMgaM3xXg0C0LW2xqfuQ6p05pCEIsXuyQ+a1koYKTuBMzRNwmybfLgvJDMd0r1LTn4+E0Ti6C2AA==",
+ "license": "MIT"
+ },
+ "node_modules/block-stream2": {
+ "version": "2.1.0",
+ "resolved": "https://registry.npmjs.org/block-stream2/-/block-stream2-2.1.0.tgz",
+ "integrity": "sha512-suhjmLI57Ewpmq00qaygS8UgEq2ly2PCItenIyhMqVjo4t4pGzqMvfgJuX8iWTeSDdfSSqS6j38fL4ToNL7Pfg==",
+ "license": "MIT",
+ "dependencies": {
+ "readable-stream": "^3.4.0"
+ }
+ },
+ "node_modules/browser-or-node": {
+ "version": "2.1.1",
+ "resolved": "https://registry.npmjs.org/browser-or-node/-/browser-or-node-2.1.1.tgz",
+ "integrity": "sha512-8CVjaLJGuSKMVTxJ2DpBl5XnlNDiT4cQFeuCJJrvJmts9YrTZDizTX7PjC2s6W4x+MBGZeEY6dGMrF04/6Hgqg==",
+ "license": "MIT"
+ },
+ "node_modules/buffer-crc32": {
+ "version": "1.0.0",
+ "resolved": "https://registry.npmjs.org/buffer-crc32/-/buffer-crc32-1.0.0.tgz",
+ "integrity": "sha512-Db1SbgBS/fg/392AblrMJk97KggmvYhr4pB5ZIMTWtaivCPMWLkmb7m21cJvpvgK+J3nsU2CmmixNBZx4vFj/w==",
+ "license": "MIT",
+ "engines": {
+ "node": ">=8.0.0"
+ }
+ },
"node_modules/bytes": {
"version": "3.1.2",
"resolved": "https://registry.npmjs.org/bytes/-/bytes-3.1.2.tgz",
@@ -1074,6 +1129,15 @@
}
}
},
+ "node_modules/decode-uri-component": {
+ "version": "0.2.2",
+ "resolved": "https://registry.npmjs.org/decode-uri-component/-/decode-uri-component-0.2.2.tgz",
+ "integrity": "sha512-FqUYQ+8o158GyGTrMFJms9qh3CqTKvAqgqsTnkLI8sKu0028orqBhxNMFkFen0zGyg6epACD32pjVk58ngIErQ==",
+ "license": "MIT",
+ "engines": {
+ "node": ">=0.10"
+ }
+ },
"node_modules/deep-equal": {
"version": "1.0.1",
"resolved": "https://registry.npmjs.org/deep-equal/-/deep-equal-1.0.1.tgz",
@@ -1278,6 +1342,12 @@
"integrity": "sha512-NiSupZ4OeuGwr68lGIeym/ksIZMJodUGOSCZ/FSnTxcrekbvqrgdUxlJOMpijaKZVjAJrWrGs/6Jy8OMuyj9ow==",
"license": "MIT"
},
+ "node_modules/eventemitter3": {
+ "version": "5.0.4",
+ "resolved": "https://registry.npmjs.org/eventemitter3/-/eventemitter3-5.0.4.tgz",
+ "integrity": "sha512-mlsTRyGaPBjPedk6Bvw+aqbsXDtoAyAzm5MO7JgU+yVRyMQ5O8bD4Kcci7BS85f93veegeCPkL8R4GLClnjLFw==",
+ "license": "MIT"
+ },
"node_modules/exsolve": {
"version": "1.1.1",
"resolved": "https://registry.npmjs.org/exsolve/-/exsolve-1.1.1.tgz",
@@ -1308,6 +1378,54 @@
"node": ">=8.0.0"
}
},
+ "node_modules/fast-xml-builder": {
+ "version": "1.3.1",
+ "resolved": "https://registry.npmjs.org/fast-xml-builder/-/fast-xml-builder-1.3.1.tgz",
+ "integrity": "sha512-pIM/1n3ntFXKYrUZwW7QCK0gAW7XY+wzj1YMIV3tLDvPj/V+zTGJK5e3/4WJfwj0qWw2ElNXiTixda/R+3YSug==",
+ "funding": [
+ {
+ "type": "github",
+ "url": "https://github.com/sponsors/NaturalIntelligence"
+ }
+ ],
+ "license": "MIT",
+ "dependencies": {
+ "path-expression-matcher": "^1.6.2",
+ "xml-naming": "^0.3.0"
+ }
+ },
+ "node_modules/fast-xml-parser": {
+ "version": "5.11.1",
+ "resolved": "https://registry.npmjs.org/fast-xml-parser/-/fast-xml-parser-5.11.1.tgz",
+ "integrity": "sha512-TBw6K/fxoQGGjCmZDw9w/ZwP3uDcnTM4YH/g+PFRWr8sbe5idXtxNN6vITh4+1ruCZaho6uBFurElsA7F0zzgw==",
+ "funding": [
+ {
+ "type": "github",
+ "url": "https://github.com/sponsors/NaturalIntelligence"
+ }
+ ],
+ "license": "MIT",
+ "dependencies": {
+ "@nodable/entities": "^3.0.0",
+ "fast-xml-builder": "^1.2.0",
+ "is-unsafe": "^2.0.0",
+ "path-expression-matcher": "^1.6.2",
+ "strnum": "^2.4.2",
+ "xml-naming": "^0.3.0"
+ },
+ "bin": {
+ "fxparser": "src/cli/cli.js"
+ }
+ },
+ "node_modules/filter-obj": {
+ "version": "1.1.0",
+ "resolved": "https://registry.npmjs.org/filter-obj/-/filter-obj-1.1.0.tgz",
+ "integrity": "sha512-8rXg1ZnX7xzy2NGDVkBVaAy+lSlPNwad13BtgSlLuxfIslyt5Vg64U7tFcCt4WS1R0hvtnQybT/IyCkGZ3DpXQ==",
+ "license": "MIT",
+ "engines": {
+ "node": ">=0.10.0"
+ }
+ },
"node_modules/fresh": {
"version": "0.5.2",
"resolved": "https://registry.npmjs.org/fresh/-/fresh-0.5.2.tgz",
@@ -1572,6 +1690,15 @@
"url": "https://opencollective.com/ioredis"
}
},
+ "node_modules/ipaddr.js": {
+ "version": "2.5.0",
+ "resolved": "https://registry.npmjs.org/ipaddr.js/-/ipaddr.js-2.5.0.tgz",
+ "integrity": "sha512-aq+t5NAc+cS6rZQQVWC2x98CPqGtKKTMDd4Gaodv0wShnItdKg/51djkGJ1hqH+Oy0ivDftCbSLCQob8zso01w==",
+ "license": "MIT",
+ "engines": {
+ "node": ">= 10"
+ }
+ },
"node_modules/is-generator-function": {
"version": "1.1.2",
"resolved": "https://registry.npmjs.org/is-generator-function/-/is-generator-function-1.1.2.tgz",
@@ -1609,6 +1736,18 @@
"url": "https://github.com/sponsors/ljharb"
}
},
+ "node_modules/is-unsafe": {
+ "version": "2.0.2",
+ "resolved": "https://registry.npmjs.org/is-unsafe/-/is-unsafe-2.0.2.tgz",
+ "integrity": "sha512-HgbIHPBH0KHHCcjLfGsCvhtPTVxjaAZlXjwdz7/GQC40SjSe4sfQsar8J5VFo8JOSbarkpV0OLG95bbaNd9aAQ==",
+ "funding": [
+ {
+ "type": "github",
+ "url": "https://github.com/sponsors/NaturalIntelligence"
+ }
+ ],
+ "license": "MIT"
+ },
"node_modules/jiti": {
"version": "2.7.0",
"resolved": "https://registry.npmjs.org/jiti/-/jiti-2.7.0.tgz",
@@ -1732,6 +1871,12 @@
"node": ">= 0.6"
}
},
+ "node_modules/lodash": {
+ "version": "4.18.1",
+ "resolved": "https://registry.npmjs.org/lodash/-/lodash-4.18.1.tgz",
+ "integrity": "sha512-dMInicTPVE8d1e5otfwmmjlxkZoUpiVLwyeTdUsi/Caj/gfzzblBcCE5sRHV/AsjuCmxWrte2TNGSYuCeCq+0Q==",
+ "license": "MIT"
+ },
"node_modules/math-intrinsics": {
"version": "1.1.0",
"resolved": "https://registry.npmjs.org/math-intrinsics/-/math-intrinsics-1.1.0.tgz",
@@ -1771,6 +1916,30 @@
"node": ">= 0.6"
}
},
+ "node_modules/minio": {
+ "version": "8.0.7",
+ "resolved": "https://registry.npmjs.org/minio/-/minio-8.0.7.tgz",
+ "integrity": "sha512-E737MgufW8CeQAsTAtnEMrxZ9scMSf29kkhZoXzDTKj/Jszzo2SfeZUH9wbDQH2Rsq6TCtl/yQL0+XdVKZansQ==",
+ "license": "Apache-2.0",
+ "dependencies": {
+ "async": "^3.2.4",
+ "block-stream2": "^2.1.0",
+ "browser-or-node": "^2.1.1",
+ "buffer-crc32": "^1.0.0",
+ "eventemitter3": "^5.0.1",
+ "fast-xml-parser": "^5.3.4",
+ "ipaddr.js": "^2.0.1",
+ "lodash": "^4.17.21",
+ "mime-types": "^2.1.35",
+ "query-string": "^7.1.3",
+ "stream-json": "^1.8.0",
+ "through2": "^4.0.2",
+ "xml2js": "^0.5.0 || ^0.6.2"
+ },
+ "engines": {
+ "node": "^16 || ^18 || >=20"
+ }
+ },
"node_modules/ms": {
"version": "2.1.3",
"resolved": "https://registry.npmjs.org/ms/-/ms-2.1.3.tgz",
@@ -1863,6 +2032,21 @@
"node": ">= 0.8"
}
},
+ "node_modules/path-expression-matcher": {
+ "version": "1.6.2",
+ "resolved": "https://registry.npmjs.org/path-expression-matcher/-/path-expression-matcher-1.6.2.tgz",
+ "integrity": "sha512-enSlaiat05iasnzmgNxRj8reFdj3puY2QpNgP1aPIaVfT6nn9ICuPoFlKHk8EN22HcwewshO+mN2DGbkCEOtqQ==",
+ "funding": [
+ {
+ "type": "github",
+ "url": "https://github.com/sponsors/NaturalIntelligence"
+ }
+ ],
+ "license": "MIT",
+ "engines": {
+ "node": ">=14.0.0"
+ }
+ },
"node_modules/path-to-regexp": {
"version": "6.3.0",
"resolved": "https://registry.npmjs.org/path-to-regexp/-/path-to-regexp-6.3.0.tgz",
@@ -1963,6 +2147,24 @@
"url": "https://github.com/sponsors/ljharb"
}
},
+ "node_modules/query-string": {
+ "version": "7.1.3",
+ "resolved": "https://registry.npmjs.org/query-string/-/query-string-7.1.3.tgz",
+ "integrity": "sha512-hh2WYhq4fi8+b+/2Kg9CEge4fDPvHS534aOOvOZeQ3+Vf2mCFsaFBYj0i+iXcAq6I9Vzp5fjMFBlONvayDC1qg==",
+ "license": "MIT",
+ "dependencies": {
+ "decode-uri-component": "^0.2.2",
+ "filter-obj": "^1.1.0",
+ "split-on-first": "^1.0.0",
+ "strict-uri-encode": "^2.0.0"
+ },
+ "engines": {
+ "node": ">=6"
+ },
+ "funding": {
+ "url": "https://github.com/sponsors/sindresorhus"
+ }
+ },
"node_modules/raw-body": {
"version": "2.5.3",
"resolved": "https://registry.npmjs.org/raw-body/-/raw-body-2.5.3.tgz",
@@ -1989,6 +2191,20 @@
"destr": "^2.0.3"
}
},
+ "node_modules/readable-stream": {
+ "version": "3.6.2",
+ "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-3.6.2.tgz",
+ "integrity": "sha512-9u/sniCrY3D5WdsERHzHE4G2YCXqoG5FTHUiCC4SIbr6XcLZBY05ya9EKjYek9O5xOAwjGq+1JdGBAS7Q9ScoA==",
+ "license": "MIT",
+ "dependencies": {
+ "inherits": "^2.0.3",
+ "string_decoder": "^1.1.1",
+ "util-deprecate": "^1.0.1"
+ },
+ "engines": {
+ "node": ">= 6"
+ }
+ },
"node_modules/readdirp": {
"version": "4.1.2",
"resolved": "https://registry.npmjs.org/readdirp/-/readdirp-4.1.2.tgz",
@@ -2067,6 +2283,15 @@
"integrity": "sha512-YZo3K82SD7Riyi0E1EQPojLz7kpepnSQI9IyPbHHg1XXXevb5dJI7tpyN2ADxGcQbHG7vcyRHk0cbwqcQriUtg==",
"license": "MIT"
},
+ "node_modules/sax": {
+ "version": "1.6.1",
+ "resolved": "https://registry.npmjs.org/sax/-/sax-1.6.1.tgz",
+ "integrity": "sha512-42tBVwLWnaQvW5zc4HbZrTuWccECCZfBi92FDuwtqxasH+JbPB3/FOKb1m222K42R4WxuxzzMsTswfzgtSu64Q==",
+ "license": "BlueOak-1.0.0",
+ "engines": {
+ "node": ">=11.0.0"
+ }
+ },
"node_modules/setprototypeof": {
"version": "1.2.0",
"resolved": "https://registry.npmjs.org/setprototypeof/-/setprototypeof-1.2.0.tgz",
@@ -2145,6 +2370,15 @@
"url": "https://github.com/sponsors/ljharb"
}
},
+ "node_modules/split-on-first": {
+ "version": "1.1.0",
+ "resolved": "https://registry.npmjs.org/split-on-first/-/split-on-first-1.1.0.tgz",
+ "integrity": "sha512-43ZssAJaMusuKWL8sKUBQXHWOpq8d6CfN/u1p4gUzfJkM05C8rxTmYrkIPTXapZpORA6LkkzcUulJ8FqA7Uudw==",
+ "license": "MIT",
+ "engines": {
+ "node": ">=6"
+ }
+ },
"node_modules/standard-as-callback": {
"version": "2.1.0",
"resolved": "https://registry.npmjs.org/standard-as-callback/-/standard-as-callback-2.1.0.tgz",
@@ -2160,6 +2394,63 @@
"node": ">= 0.8"
}
},
+ "node_modules/stream-chain": {
+ "version": "2.2.5",
+ "resolved": "https://registry.npmjs.org/stream-chain/-/stream-chain-2.2.5.tgz",
+ "integrity": "sha512-1TJmBx6aSWqZ4tx7aTpBDXK0/e2hhcNSTV8+CbFJtDjbb+I1mZ8lHit0Grw9GRT+6JbIrrDd8esncgBi8aBXGA==",
+ "license": "BSD-3-Clause"
+ },
+ "node_modules/stream-json": {
+ "version": "1.9.1",
+ "resolved": "https://registry.npmjs.org/stream-json/-/stream-json-1.9.1.tgz",
+ "integrity": "sha512-uWkjJ+2Nt/LO9Z/JyKZbMusL8Dkh97uUBTv3AJQ74y07lVahLY4eEFsPsE97pxYBwr8nnjMAIch5eqI0gPShyw==",
+ "license": "BSD-3-Clause",
+ "dependencies": {
+ "stream-chain": "^2.2.5"
+ }
+ },
+ "node_modules/strict-uri-encode": {
+ "version": "2.0.0",
+ "resolved": "https://registry.npmjs.org/strict-uri-encode/-/strict-uri-encode-2.0.0.tgz",
+ "integrity": "sha512-QwiXZgpRcKkhTj2Scnn++4PKtWsH0kpzZ62L2R6c/LUVYv7hVnZqcg2+sMuT6R7Jusu1vviK/MFsu6kNJfWlEQ==",
+ "license": "MIT",
+ "engines": {
+ "node": ">=4"
+ }
+ },
+ "node_modules/string_decoder": {
+ "version": "1.3.0",
+ "resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-1.3.0.tgz",
+ "integrity": "sha512-hkRX8U1WjJFd8LsDJ2yQ/wWWxaopEsABU1XfkM8A+j0+85JAGppt16cr1Whg6KIbb4okU6Mql6BOj+uup/wKeA==",
+ "license": "MIT",
+ "dependencies": {
+ "safe-buffer": "~5.2.0"
+ }
+ },
+ "node_modules/strnum": {
+ "version": "2.4.2",
+ "resolved": "https://registry.npmjs.org/strnum/-/strnum-2.4.2.tgz",
+ "integrity": "sha512-rDG3Ah4TV0k1hWvLSzkZtMmLN9+eS+h3knq4MP6A42Y3Yh5qGNnOUs1jJkoSr8FG5dsL28c7KgkIBzSEykqtuw==",
+ "funding": [
+ {
+ "type": "github",
+ "url": "https://github.com/sponsors/NaturalIntelligence"
+ }
+ ],
+ "license": "MIT",
+ "dependencies": {
+ "anynum": "^1.0.1"
+ }
+ },
+ "node_modules/through2": {
+ "version": "4.0.2",
+ "resolved": "https://registry.npmjs.org/through2/-/through2-4.0.2.tgz",
+ "integrity": "sha512-iOqSav00cVxEEICeD7TjLB1sueEL+81Wpzp2bY17uZjZN0pWZPuo4suZ/61VujxmqSGFfgOcNuTZ85QJwNZQpw==",
+ "license": "MIT",
+ "dependencies": {
+ "readable-stream": "3"
+ }
+ },
"node_modules/tinyexec": {
"version": "1.2.4",
"resolved": "https://registry.npmjs.org/tinyexec/-/tinyexec-1.2.4.tgz",
@@ -2250,6 +2541,12 @@
"node": ">= 0.8"
}
},
+ "node_modules/util-deprecate": {
+ "version": "1.0.2",
+ "resolved": "https://registry.npmjs.org/util-deprecate/-/util-deprecate-1.0.2.tgz",
+ "integrity": "sha512-EPD5q1uXyFxJpCrLnCc1nHnq3gOa6DZBocAIiI2TaSCA7VCJ1UJDMagCzIkXNsUYfD1daK//LTEQ8xiIbrHtcw==",
+ "license": "MIT"
+ },
"node_modules/vary": {
"version": "1.1.2",
"resolved": "https://registry.npmjs.org/vary/-/vary-1.1.2.tgz",
@@ -2280,6 +2577,43 @@
}
}
},
+ "node_modules/xml-naming": {
+ "version": "0.3.0",
+ "resolved": "https://registry.npmjs.org/xml-naming/-/xml-naming-0.3.0.tgz",
+ "integrity": "sha512-ghig2TBE/H11aOVgmahA3MhimvkBr6JIYknH/Dhdk10nXwdbIqBJsbfMxpvFPG8bAw77gN29aQWvKpmVoPlvPQ==",
+ "funding": [
+ {
+ "type": "github",
+ "url": "https://github.com/sponsors/NaturalIntelligence"
+ }
+ ],
+ "license": "MIT",
+ "engines": {
+ "node": ">=16.0.0"
+ }
+ },
+ "node_modules/xml2js": {
+ "version": "0.6.2",
+ "resolved": "https://registry.npmjs.org/xml2js/-/xml2js-0.6.2.tgz",
+ "integrity": "sha512-T4rieHaC1EXcES0Kxxj4JWgaUQHDk+qwHcYOCFHfiwKz7tOVPLq7Hjq9dM1WCMhylqMEfP7hMcOIChvotiZegA==",
+ "license": "MIT",
+ "dependencies": {
+ "sax": ">=0.6.0",
+ "xmlbuilder": "~11.0.0"
+ },
+ "engines": {
+ "node": ">=4.0.0"
+ }
+ },
+ "node_modules/xmlbuilder": {
+ "version": "11.0.1",
+ "resolved": "https://registry.npmjs.org/xmlbuilder/-/xmlbuilder-11.0.1.tgz",
+ "integrity": "sha512-fDlsI/kFEx7gLvbecc0/ohLG50fugQp8ryHzMTuW9vSa1GJ0XYWKnhsUx7oie3G98+r56aTQIUB4kht42R3JvA==",
+ "license": "MIT",
+ "engines": {
+ "node": ">=4.0"
+ }
+ },
"node_modules/ylru": {
"version": "1.4.0",
"resolved": "https://registry.npmjs.org/ylru/-/ylru-1.4.0.tgz",
diff --git a/supplied-service/package.json b/supplied-service/package.json
index 968683c..c0e4d91 100644
--- a/supplied-service/package.json
+++ b/supplied-service/package.json
@@ -17,6 +17,7 @@
"@neondatabase/serverless": "^1.0.1",
"@prisma/adapter-neon": "6.19.3",
"@prisma/client": "6.19.3",
+ "minio": "^8.0.5",
"crypto-js": "^4.2.0",
"dotenv": "^17.2.3",
"ioredis": "^5.4.2",
diff --git a/supplied-service/prisma/schema.prisma b/supplied-service/prisma/schema.prisma
index 8e82608..34a902e 100644
--- a/supplied-service/prisma/schema.prisma
+++ b/supplied-service/prisma/schema.prisma
@@ -166,8 +166,8 @@ model SupplierReconciliationOrder {
mainOrderId String?
userId String?
reconciliationStatus Int @default(0)
- diffType Int?
- diffReason String? @db.Text
+ diffType String? @db.VarChar(64)
+ diffReason String? @db.VarChar(1000)
platformTotalPrice Decimal? @db.Decimal(12, 2)
platformCashAmount Decimal? @db.Decimal(12, 2)
platformPointsPrice Decimal? @db.Decimal(12, 2)
@@ -373,6 +373,23 @@ model SupplierAfterSale {
@@map("supplier_after_sale")
}
+model SupplierFile {
+ id Int @id @default(autoincrement())
+ fileId String @unique
+ supplierId String?
+ fileName String
+ objectName String
+ bucketName String
+ contentType String?
+ fileSize Int?
+ createTime DateTime @default(now())
+ updateTime DateTime @updatedAt
+ deleted Int @default(0)
+
+ @@index([supplierId, deleted])
+ @@map("supplier_file")
+}
+
model SupplierInvoiceInfo {
id Int @id @default(autoincrement())
invoiceBizId String @unique
@@ -382,11 +399,21 @@ model SupplierInvoiceInfo {
subOrderId String?
settlementId String?
invoiceCode String?
+ taxIdNumber String?
invoiceIds String? @db.VarChar(1000)
orderIds String? @db.VarChar(1000)
invoiceStatus Int @default(0)
+ invoiceDate DateTime?
+ invoiceType Int?
+ invoiceNakeAmount Decimal? @db.Decimal(12, 2)
+ invoiceTaxRate Decimal? @db.Decimal(8, 4)
+ invoiceTaxAmount Decimal? @db.Decimal(12, 2)
+ invoiceAmount Decimal? @db.Decimal(12, 2)
+ checkCode String?
+ fileType String? @db.VarChar(16)
fileId String?
filePath String?
+ failureMessage String? @db.Text
requestBody Json?
createTime DateTime @default(now())
updateTime DateTime @updatedAt
diff --git a/supplied-service/prisma/sql/refund-exchange-invoice.sql b/supplied-service/prisma/sql/refund-exchange-invoice.sql
index 6abd828..296c9ac 100644
--- a/supplied-service/prisma/sql/refund-exchange-invoice.sql
+++ b/supplied-service/prisma/sql/refund-exchange-invoice.sql
@@ -28,12 +28,22 @@ CREATE TABLE IF NOT EXISTS `supplier_invoice_info` (
`mainOrderId` VARCHAR(191) NULL COMMENT '关联主单ID',
`subOrderId` VARCHAR(191) NULL COMMENT '关联子单ID',
`settlementId` VARCHAR(191) NULL COMMENT '结算单号',
- `invoiceCode` VARCHAR(191) NULL COMMENT '发票代码或纳税识别号',
+ `invoiceCode` VARCHAR(191) NULL COMMENT '发票代码',
+ `taxIdNumber` VARCHAR(191) NULL COMMENT '购买方纳税人识别号',
`invoiceIds` VARCHAR(1000) NULL COMMENT '发票号码列表,多个用英文逗号分隔',
`orderIds` VARCHAR(1000) NULL COMMENT '关联订单号列表,多个用英文逗号分隔',
`invoiceStatus` INT NOT NULL DEFAULT 0 COMMENT '发票状态:0已记录,1已申请,2已开票,3失败',
+ `invoiceDate` DATETIME(3) NULL COMMENT '开票日期',
+ `invoiceType` INT NULL COMMENT '发票类型',
+ `invoiceNakeAmount` DECIMAL(12, 2) NULL COMMENT '不含税金额',
+ `invoiceTaxRate` DECIMAL(8, 4) NULL COMMENT '发票税率',
+ `invoiceTaxAmount` DECIMAL(12, 2) NULL COMMENT '发票税额',
+ `invoiceAmount` DECIMAL(12, 2) NULL COMMENT '价税合计',
+ `checkCode` VARCHAR(191) NULL COMMENT '发票校验码',
+ `fileType` VARCHAR(16) NULL COMMENT '发票文件类型',
`fileId` VARCHAR(191) NULL COMMENT '发票文件ID',
`filePath` VARCHAR(191) NULL COMMENT '发票文件路径',
+ `failureMessage` TEXT NULL COMMENT '开票失败原因',
`requestBody` JSON NULL COMMENT '原始业务请求体',
`createTime` DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) COMMENT '创建时间',
`updateTime` DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3) COMMENT '更新时间',
diff --git a/supplied-service/prisma/sql/supplier-file.sql b/supplied-service/prisma/sql/supplier-file.sql
new file mode 100644
index 0000000..3950e45
--- /dev/null
+++ b/supplied-service/prisma/sql/supplier-file.sql
@@ -0,0 +1,16 @@
+CREATE TABLE `supplier_file` (
+ `id` int NOT NULL AUTO_INCREMENT,
+ `fileId` varchar(191) NOT NULL,
+ `supplierId` varchar(191) DEFAULT NULL,
+ `fileName` varchar(191) NOT NULL,
+ `objectName` varchar(500) NOT NULL,
+ `bucketName` varchar(191) NOT NULL,
+ `contentType` varchar(100) DEFAULT NULL,
+ `fileSize` int DEFAULT NULL,
+ `createTime` datetime(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3),
+ `updateTime` datetime(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3),
+ `deleted` int NOT NULL DEFAULT '0',
+ PRIMARY KEY (`id`),
+ UNIQUE KEY `supplier_file_fileId_key` (`fileId`),
+ KEY `supplier_file_supplierId_deleted_idx` (`supplierId`,`deleted`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='供应商文件存储记录';
diff --git a/supplied-service/prisma/sql/supplier-invoice-flow.sql b/supplied-service/prisma/sql/supplier-invoice-flow.sql
new file mode 100644
index 0000000..63a6bf2
--- /dev/null
+++ b/supplied-service/prisma/sql/supplier-invoice-flow.sql
@@ -0,0 +1,12 @@
+ALTER TABLE `supplier_invoice_info`
+ MODIFY COLUMN `invoiceCode` VARCHAR(191) NULL COMMENT '发票代码',
+ ADD COLUMN `taxIdNumber` VARCHAR(191) NULL COMMENT '购买方纳税人识别号' AFTER `invoiceCode`,
+ ADD COLUMN `invoiceDate` DATETIME(3) NULL COMMENT '开票日期' AFTER `invoiceStatus`,
+ ADD COLUMN `invoiceType` INT NULL COMMENT '发票类型' AFTER `invoiceDate`,
+ ADD COLUMN `invoiceNakeAmount` DECIMAL(12, 2) NULL COMMENT '不含税金额' AFTER `invoiceType`,
+ ADD COLUMN `invoiceTaxRate` DECIMAL(8, 4) NULL COMMENT '发票税率' AFTER `invoiceNakeAmount`,
+ ADD COLUMN `invoiceTaxAmount` DECIMAL(12, 2) NULL COMMENT '发票税额' AFTER `invoiceTaxRate`,
+ ADD COLUMN `invoiceAmount` DECIMAL(12, 2) NULL COMMENT '价税合计' AFTER `invoiceTaxAmount`,
+ ADD COLUMN `checkCode` VARCHAR(191) NULL COMMENT '发票校验码' AFTER `invoiceAmount`,
+ ADD COLUMN `fileType` VARCHAR(16) NULL COMMENT '发票文件类型' AFTER `checkCode`,
+ ADD COLUMN `failureMessage` TEXT NULL COMMENT '开票失败原因' AFTER `filePath`;
diff --git a/supplied-service/src/controllers/order.controller.ts b/supplied-service/src/controllers/order.controller.ts
index b6ab69d..36f66ce 100644
--- a/supplied-service/src/controllers/order.controller.ts
+++ b/supplied-service/src/controllers/order.controller.ts
@@ -16,6 +16,7 @@ import { orderListService } from '../services/order-list.service.js'
import { orderPushEventService, type OrderPushEventInput } from '../services/order-push-event.service.js'
import {
supplierOpenOrderService,
+ type SupplierFileBase64QueryRequest,
type SupplierInvoiceApplyRequest,
type SupplierInvoiceQueryRequest,
type SupplierOrderQueryRequest,
@@ -270,7 +271,7 @@ export const supplierInvoiceApplyController = withErrorBoundary(async (request:
let body: SupplierInvoiceApplyRequest
try {
- body = supplierOpenOrderService.parseBody(await readJson(request)) as SupplierInvoiceApplyRequest
+ body = supplierOpenOrderService.parseBody(await readJson(request))
} catch (error) {
return Response.json({
resultCode: 400,
@@ -287,7 +288,7 @@ export const supplierInvoiceInfoController = withErrorBoundary(async (request: R
let body: SupplierInvoiceQueryRequest
try {
- body = supplierOpenOrderService.parseBody(await readJson(request)) as SupplierInvoiceQueryRequest
+ body = supplierOpenOrderService.parseBody(await readJson(request))
} catch (error) {
return Response.json({
resultCode: 400,
@@ -295,5 +296,24 @@ export const supplierInvoiceInfoController = withErrorBoundary(async (request: R
})
}
- return Response.json(await supplierOpenOrderService.queryInvoicesInfo(body))
+ return Response.json(await supplierOpenOrderService.queryInvoiceInfo(body))
+})
+
+export const supplierFileBase64InfoController = withErrorBoundary(async (request: Request, _context: Context) => {
+ const methodResponse = guardMethod(request, ['POST'])
+ if (methodResponse) return methodResponse
+
+ let body: SupplierFileBase64QueryRequest
+ try {
+ body = supplierOpenOrderService.parseBody(await readJson(request))
+ } catch (error) {
+ return Response.json({
+ resultCode: 400,
+ message: error instanceof Error ? error.message : '请求参数解密失败',
+ fileType: 'JPG',
+ imageEncodeMap: {}
+ })
+ }
+
+ return Response.json(await supplierOpenOrderService.queryFileBase64Info(body))
})
diff --git a/supplied-service/src/controllers/supplier.controller.ts b/supplied-service/src/controllers/supplier.controller.ts
index efdcd1c..aab26f0 100644
--- a/supplied-service/src/controllers/supplier.controller.ts
+++ b/supplied-service/src/controllers/supplier.controller.ts
@@ -9,8 +9,12 @@ type SupplierInfoRequest = {
supplierIdentification?: string
}
+type SupplierSessionRequest = {
+ keyword?: string
+}
+
type SupplierTokenRequest = {
- AplParmObjct?: string
+ userId?: string
supplierIdentification?: string
}
@@ -34,15 +38,25 @@ export const supplierInfoController = withErrorBoundary(async (request: Request,
return toHttpResponse(await supplierService.getSupplierInfo(supplierIdentification))
})
+export const supplierSessionController = withErrorBoundary(async (request: Request, _context: Context) => {
+ const methodResponse = guardMethod(request, ['POST'])
+ if (methodResponse) return methodResponse
+
+ const body = await readJson(request)
+ const keyword = String(body.keyword || '')
+
+ return toHttpResponse(supplierService.decryptSupplierSession(keyword))
+})
+
export const supplierTokenController = withErrorBoundary(async (request: Request, _context: Context) => {
const methodResponse = guardMethod(request, ['POST'])
if (methodResponse) return methodResponse
const body = await readJson(request)
- const encryptedParam = String(body.AplParmObjct || '').trim()
+ const userId = String(body.userId || '').trim()
const supplierIdentification = String(body.supplierIdentification || '').trim().toLowerCase()
- return toHttpResponse(await supplierService.warmSupplierToken(encryptedParam, supplierIdentification))
+ return toHttpResponse(await supplierService.warmSupplierToken(userId, supplierIdentification))
})
export const supplierPointsController = withErrorBoundary(async (request: Request, _context: Context) => {
diff --git a/supplied-service/src/dao/order.dao.ts b/supplied-service/src/dao/order.dao.ts
index 2d22448..f7aeb0e 100644
--- a/supplied-service/src/dao/order.dao.ts
+++ b/supplied-service/src/dao/order.dao.ts
@@ -5,7 +5,7 @@ export type PrismaTransaction = Prisma.TransactionClient
export const orderDao = {
transaction(handler: (tx: PrismaTransaction) => Promise) {
- return prisma.$transaction(handler)
+ return prisma.$transaction(handler, { maxWait: 10000, timeout: 20000 })
},
findMainOrdersWithSubs(supplierId: string, userId: string) {
@@ -137,6 +137,16 @@ export const orderDao = {
})
},
+ findInvoiceBySettlementId(supplierId: string, settlementId: string) {
+ return prisma.supplierInvoiceInfo.findFirst({
+ where: {
+ supplierId,
+ settlementId,
+ deleted: 0
+ }
+ })
+ },
+
findOpenApiReconciliationSubOrders(supplierId: string, orderIds: string[], startDate?: Date, endDate?: Date, orderState?: number) {
return prisma.supplierOrderSub.findMany({
where: {
diff --git a/supplied-service/src/server.ts b/supplied-service/src/server.ts
index 5f45b8f..e1794bb 100644
--- a/supplied-service/src/server.ts
+++ b/supplied-service/src/server.ts
@@ -33,6 +33,7 @@ import {
orderPayController,
orderPushEventController,
orderShipController,
+ supplierFileBase64InfoController,
supplierInvoiceApplyController,
supplierInvoiceInfoController,
supplierOrderInfoController,
@@ -65,6 +66,7 @@ import {
supplierDebugTokensController,
supplierInfoController,
supplierPointsController,
+ supplierSessionController,
supplierTokenController
} from './controllers/supplier.controller.js'
@@ -108,9 +110,10 @@ const handlers: Record = {
'merchant-product-save': merchantProductSaveController,
'merchant-product-delete': merchantProductDeleteController,
'supplier-debug-tokens': supplierDebugTokensController,
- 'supplier-info': supplierInfoController,
+ 'supplier-file-base64-info': supplierFileBase64InfoController,
'supplier-invoice-apply': supplierInvoiceApplyController,
'supplier-invoice-info': supplierInvoiceInfoController,
+ 'supplier-info': supplierInfoController,
'supplier-order-info': supplierOrderInfoController,
'supplier-reconciliation-info': supplierReconciliationInfoController,
'supplier-reconciliation-result': supplierReconciliationResultController,
@@ -118,6 +121,7 @@ const handlers: Record = {
'merchant-reconciliation-list': merchantReconciliationListController,
'merchant-reconciliation-update': merchantReconciliationUpdateController,
'supplier-points': supplierPointsController,
+ 'supplier-session': supplierSessionController,
'supplier-token': supplierTokenController,
upload: uploadController,
'upload-preview': uploadPreviewController,
@@ -144,11 +148,29 @@ const toRequest = (ctx: Koa.Context) =>
body: requestBody(ctx)
})
-const writeResponse = async (ctx: Koa.Context, response: Response) => {
+const ba7ResponseBody = (content: string) => ({
+ status: 200,
+ msg: 'success',
+ data: {
+ Body: {
+ RspSvcHeader: {
+ ReturnCode: '000000000000',
+ ReturnMsg: '交易成功'
+ },
+ RspSvcBody: {
+ ReturnStCd: '200',
+ ReturnCntnt: content
+ }
+ }
+ }
+})
+
+const writeResponse = async (ctx: Koa.Context, response: Response, wrapBa7 = false) => {
ctx.status = response.status
Object.entries(corsHeaders).forEach(([key, value]) => ctx.set(key, value))
response.headers.forEach((value, key) => ctx.set(key, value))
- ctx.body = response.body ? await response.text() : undefined
+ const responseText = response.body ? await response.text() : ''
+ ctx.body = wrapBa7 ? ba7ResponseBody(responseText) : responseText || undefined
}
const dispatch = (name: string) => async (ctx: Koa.Context) => {
@@ -170,7 +192,7 @@ const dispatch = (name: string) => async (ctx: Koa.Context) => {
return
}
const response = await handler(toRequest(ctx), {})
- await writeResponse(ctx, response)
+ await writeResponse(ctx, response, ctx.path.startsWith('/supplierOpenApi/'))
}
app.use(bodyParser({ jsonLimit: '10mb' }))
@@ -206,6 +228,7 @@ router.post('/supplierOpenApi/pointOrder/queryOrderInfo', dispatch('supplier-ord
router.post('/supplierOpenApi/pointOrder/queryReconciliationInfo', dispatch('supplier-reconciliation-info'))
router.post('/supplierOpenApi/pointOrder/applyForInvoices', dispatch('supplier-invoice-apply'))
router.post('/supplierOpenApi/pointOrder/queryInvoicesInfo', dispatch('supplier-invoice-info'))
+router.post('/supplierOpenApi/pointOrder/queryFileBase64Info', dispatch('supplier-file-base64-info'))
router.post('/supplierOpenApi/pointOrder/reconciliationResult', dispatch('supplier-reconciliation-result'))
router.post('/supplierOpenApi/pointOrder/unReconciledMsg', dispatch('supplier-unreconciled-msg'))
router.post('/supplierOpenApi/debug/tokens', dispatch('supplier-debug-tokens'))
diff --git a/supplied-service/src/services/order-push-event.service.ts b/supplied-service/src/services/order-push-event.service.ts
index 066cff3..c72bbf9 100644
--- a/supplied-service/src/services/order-push-event.service.ts
+++ b/supplied-service/src/services/order-push-event.service.ts
@@ -190,7 +190,6 @@ export const orderPushEventService = {
invoiceStatus: 2,
fileId: body.fileId || null,
filePath: body.filePath || null,
- requestBody: body,
deleted: 0
},
create: {
diff --git a/supplied-service/src/services/reconciliation-result.service.ts b/supplied-service/src/services/reconciliation-result.service.ts
index 1713b6f..6cec460 100644
--- a/supplied-service/src/services/reconciliation-result.service.ts
+++ b/supplied-service/src/services/reconciliation-result.service.ts
@@ -1,4 +1,4 @@
-import type { Prisma } from '@prisma/client'
+import { Prisma } from '@prisma/client'
import { prisma } from '../utils/prisma.js'
import { supplierDao } from '../dao/supplier.dao.js'
import { verifySupplierOpenSignature } from '../utils/supplier-open-crypto.js'
@@ -9,7 +9,7 @@ export type ReconciliationResultItem = {
mainOrderId?: string
userId?: string
reconciliationStatus?: number
- diffType?: number
+ diffType?: string | number
diffReason?: string
platformTotalPrice?: number
platformCashAmount?: number
@@ -41,7 +41,7 @@ export type ReconciliationResultUpdateInput = {
supplierId?: string
orderId?: string
reconciliationStatus?: number
- diffType?: number
+ diffType?: string | number
diffReason?: string
}
@@ -53,7 +53,38 @@ const toTime = (value?: string) => {
return Number.isNaN(time.getTime()) ? new Date() : time
}
-const resultItem = (record: Awaited>[number]) => ({
+type DecimalValue = { toFixed: (fractionDigits?: number) => string } | number | string
+
+type SupplierReconciliationOrderRecord = {
+ supplierId: string
+ orderId: string
+ mainOrderId: string | null
+ userId: string | null
+ reconciliationStatus: number
+ diffType: string | null
+ diffReason: string | null
+ platformTotalPrice: DecimalValue | null
+ platformCashAmount: DecimalValue | null
+ platformPointsPrice: DecimalValue | null
+ platformRefundPrice: DecimalValue | null
+ supplierTotalPrice: DecimalValue | null
+ supplierCashAmount: DecimalValue | null
+ supplierPointsPrice: DecimalValue | null
+ supplierRefundPrice: DecimalValue | null
+ reconciliationBatchNo: string | null
+ reconciliationTime: Date | null
+ updateAt: Date
+ deleted?: number
+}
+
+const formatAmount = (value: DecimalValue | null) => {
+ if (value === undefined || value === null) return ''
+ if (typeof value === 'object') return value.toFixed(2)
+ const numberValue = Number(value)
+ return Number.isNaN(numberValue) ? '' : numberValue.toFixed(2)
+}
+
+const resultItem = (record: SupplierReconciliationOrderRecord) => ({
supplierId: record.supplierId,
orderId: record.orderId,
mainOrderId: record.mainOrderId || '',
@@ -61,14 +92,14 @@ const resultItem = (record: Awaited`
+ SELECT supplierId, orderId, mainOrderId, userId, reconciliationStatus, diffType, diffReason,
+ platformTotalPrice, platformCashAmount, platformPointsPrice, platformRefundPrice,
+ supplierTotalPrice, supplierCashAmount, supplierPointsPrice, supplierRefundPrice,
+ reconciliationBatchNo, reconciliationTime, updateAt
+ FROM supplier_reconciliation_order
+ WHERE supplierId = ${supplierId}
+ AND deleted = 0
+ ${reconciliationStatus === undefined ? Prisma.empty : Prisma.sql`AND reconciliationStatus = ${reconciliationStatus}`}
+ ${orderId ? Prisma.sql`AND orderId LIKE ${`%${orderId}%`}` : Prisma.empty}
+ ORDER BY updateAt DESC
+ `
return serviceOk({ reconciliationItems: records.map(resultItem) })
},
@@ -158,19 +219,30 @@ export const reconciliationResultService = {
return serviceFail('供应商、子订单或对账状态不正确')
}
- const record = await prisma.supplierReconciliationOrder.findUnique({
- where: { supplierId_orderId: { supplierId, orderId } }
- })
+ const records = await prisma.$queryRaw`
+ SELECT supplierId, orderId, mainOrderId, userId, reconciliationStatus, diffType, diffReason,
+ platformTotalPrice, platformCashAmount, platformPointsPrice, platformRefundPrice,
+ supplierTotalPrice, supplierCashAmount, supplierPointsPrice, supplierRefundPrice,
+ reconciliationBatchNo, reconciliationTime, updateAt, deleted
+ FROM supplier_reconciliation_order
+ WHERE supplierId = ${supplierId}
+ AND orderId = ${orderId}
+ LIMIT 1
+ `
+ const record = records[0]
if (!record || record.deleted !== 0) return serviceFail('对账结果不存在')
- await prisma.supplierReconciliationOrder.update({
- where: { supplierId_orderId: { supplierId, orderId } },
- data: {
- reconciliationStatus,
- diffType: input.diffType === undefined || input.diffType === null ? null : Number(input.diffType),
- diffReason: String(input.diffReason || '').trim() || null
- }
- })
+ const diffType = input.diffType === undefined || input.diffType === null ? null : String(input.diffType).trim() || null
+ const diffReason = String(input.diffReason || '').trim() || null
+ await prisma.$executeRaw`
+ UPDATE supplier_reconciliation_order
+ SET reconciliationStatus = ${reconciliationStatus},
+ diffType = ${diffType},
+ diffReason = ${diffReason},
+ updateAt = CURRENT_TIMESTAMP(3)
+ WHERE supplierId = ${supplierId}
+ AND orderId = ${orderId}
+ `
return serviceOk({})
}
}
diff --git a/supplied-service/src/services/supplier-file.service.ts b/supplied-service/src/services/supplier-file.service.ts
new file mode 100644
index 0000000..cb7c3d7
--- /dev/null
+++ b/supplied-service/src/services/supplier-file.service.ts
@@ -0,0 +1,53 @@
+import { Client } from 'minio'
+import { statSync } from 'node:fs'
+import { prisma } from '../utils/prisma.js'
+
+const endpoint = new URL(process.env.MINIO_ENDPOINT || 'http://localhost:9000')
+const bucketName = process.env.MINIO_BUCKET || 'unions'
+const client = new Client({
+ endPoint: endpoint.hostname,
+ port: Number(endpoint.port || (endpoint.protocol === 'https:' ? 443 : 80)),
+ useSSL: endpoint.protocol === 'https:',
+ accessKey: process.env.MINIO_ACCESS_KEY || '',
+ secretKey: process.env.MINIO_SECRET_KEY || '',
+ region: process.env.MINIO_REGION || 'us-east-1'
+})
+
+const ensureBucket = async () => {
+ if (!(await client.bucketExists(bucketName))) {
+ await client.makeBucket(bucketName, process.env.MINIO_REGION || 'us-east-1')
+ }
+}
+
+const streamToBuffer = async (stream: NodeJS.ReadableStream) => {
+ const chunks: Buffer[] = []
+ for await (const chunk of stream as AsyncIterable) chunks.push(Buffer.from(chunk))
+ return Buffer.concat(chunks)
+}
+
+export const supplierFileService = {
+ async uploadPdf(fileId: string, supplierId: string, fileName: string, filePath: string) {
+ await ensureBucket()
+ const now = new Date()
+ const pad = (value: number) => String(value).padStart(2, '0')
+ const datePath = `${now.getFullYear()}/${pad(now.getMonth() + 1)}/${pad(now.getDate())}`
+ const objectName = `invoices/${datePath}/${supplierId}/${fileName}`
+ const stat = statSync(filePath)
+ await client.fPutObject(bucketName, objectName, filePath, {
+ 'Content-Type': 'application/pdf'
+ })
+ await prisma.supplierFile.upsert({
+ where: { fileId },
+ update: { supplierId, fileName, objectName, bucketName, contentType: 'application/pdf', fileSize: stat.size, deleted: 0 },
+ create: { fileId, supplierId, fileName, objectName, bucketName, contentType: 'application/pdf', fileSize: stat.size }
+ })
+ return { fileId, objectName }
+ },
+
+ async read(fileId: string) {
+ const file = await prisma.supplierFile.findFirst({ where: { fileId, deleted: 0 } })
+ if (!file) return null
+ const stream = await client.getObject(file.bucketName, file.objectName)
+ return streamToBuffer(stream)
+ }
+}
diff --git a/supplied-service/src/services/supplier-open-order.service.ts b/supplied-service/src/services/supplier-open-order.service.ts
index c40b5d4..029e06e 100644
--- a/supplied-service/src/services/supplier-open-order.service.ts
+++ b/supplied-service/src/services/supplier-open-order.service.ts
@@ -1,9 +1,14 @@
+import { createHash } from 'node:crypto'
+import { existsSync, readFileSync } from 'node:fs'
+import path from 'node:path'
import { supplierDao } from '../dao/supplier.dao.js'
import { orderDao } from '../dao/order.dao.js'
import { ORDER_EVENT_TYPE, ORDER_STATE } from '../constants/order.js'
+import { orderPushEventService } from './order-push-event.service.js'
import { logger } from '../utils/logger.js'
-import { prisma } from '../utils/prisma.js'
import { sm4CbcDecrypt, verifySupplierOpenSignature } from '../utils/supplier-open-crypto.js'
+import { generateMockInvoicePdf } from '../../tools/mock-invoice-pdf.js'
+import { supplierFileService } from './supplier-file.service.js'
export type SupplierOrderQueryRequest = {
supplierId?: string
@@ -36,9 +41,10 @@ export type SupplierInvoiceApplyRequest = {
orderIds?: string
orderNum?: number
orderTotalPrice?: number | string
- invoiceDate?: string
+ invoiceDate?: string | number
invoiceTitle?: string
- invoiceCode?: string
+ taxIdNumber?: string
+ taxIDNumber?: string
invoiceAddress?: string
invoiceContact?: string
invoiceNakedPrice?: number | string
@@ -54,12 +60,24 @@ export type SupplierInvoiceApplyRequest = {
RsrvFld1?: string
}
+export type SupplierFileBase64QueryRequest = {
+ supplierId?: string
+ token?: string
+ queryType?: string
+ idNumber?: string
+ fileIdList?: string[]
+ timestamp?: number
+ ApiParamObject?: string
+ RsrvFld1?: string
+}
+
export type SupplierInvoiceQueryRequest = {
supplierId?: string
token?: string
settlementId?: string
timestamp?: number
AplParmObjct?: string
+ RsrvFld1?: string
}
type SupplierOpenEncryptedRequest = {
@@ -72,8 +90,8 @@ const parseBody = (body: T) => {
const encryptedData = body.AplParmObjct || body.ApiParamObject
if (!encryptedData) return body
- const keyHex = process.env.SUPPLIER_OPEN_SM4_KEY_HEX || process.env.SM4CBC_KEY_HEX || ''
- const ivHex = process.env.SUPPLIER_OPEN_SM4_IV_HEX || process.env.SM4CBC_IV_HEX || ''
+ const keyHex = process.env.SM4CBC_KEY_HEX || ''
+ const ivHex = process.env.SM4CBC_IV_HEX || ''
if (!keyHex || !ivHex) {
throw new Error('供应商开放接口SM4配置缺失')
}
@@ -92,6 +110,36 @@ const toText = (date?: Date | null) => {
const toMoney = (value: { toFixed: (digits: number) => string } | number | string | null | undefined) => Number(value || 0).toFixed(2)
+const numericId = (seed: string, length: number) => BigInt(`0x${createHash('sha256').update(seed).digest('hex')}`)
+ .toString()
+ .padStart(length, '0')
+ .slice(0, length)
+
+const invoiceOutputRoot = () => path.resolve(process.env.INVOICE_PDF_OUTPUT_DIR || path.join(process.cwd(), 'output', 'pdf', 'invoices'))
+
+const storedRequest = (value: unknown) => value && typeof value === 'object' && !Array.isArray(value)
+ ? value as Record
+ : {}
+
+const encodeImage = async (source?: string | null) => {
+ const imageSource = String(source || '').trim()
+ if (!imageSource) return ''
+ if (imageSource.startsWith('data:')) {
+ return imageSource.split(',')[1] || ''
+ }
+ if (!/^https?:\/\//i.test(imageSource)) {
+ return ''
+ }
+ try {
+ const response = await fetch(imageSource)
+ if (!response.ok) return ''
+ return Buffer.from(await response.arrayBuffer()).toString('base64')
+ } catch (error) {
+ logger.warn('query file base64 fetch image failed', { imageSource, message: error instanceof Error ? error.message : String(error) })
+ return ''
+ }
+}
+
const productSku = (product: { sku: string; subOrderId: string; name: string }) => {
if (product.sku && product.sku !== '[object Object]') {
return product.sku
@@ -111,9 +159,327 @@ const toOrderProductInfo = (order: Awaited>[number]['products'][number]) => {
+ if (!product) return ''
+ if (product.productImgUrl) return product.productImgUrl
+ if (product.filePath) return product.filePath
+ if (Array.isArray(product.picInfo)) return String(product.picInfo[0] || '')
+ return ''
+}
+
export const supplierOpenOrderService = {
parseBody,
+ async applyForInvoices(body: SupplierInvoiceApplyRequest) {
+ const supplierId = String(body.supplierId || '').trim()
+ const token = String(body.token || '').trim()
+ const settlementId = String(body.settlementId || '').trim()
+ const orderIds = [...new Set(String(body.orderIds || '')
+ .split(',')
+ .map(item => item.trim())
+ .filter(Boolean))]
+ const orderNum = Number(body.orderNum || 0)
+ const orderTotalPrice = Number(body.orderTotalPrice)
+ const timestamp = Number(body.timestamp || 0)
+ const taxIdNumber = String(body.taxIdNumber || body.taxIDNumber || '').trim()
+ const invoiceDateValue = body.invoiceDate
+ const invoiceDate = typeof invoiceDateValue === 'number' || /^\d+$/.test(String(invoiceDateValue || ''))
+ ? new Date(Number(invoiceDateValue))
+ : new Date(`${invoiceDateValue || ''}T00:00:00`)
+
+ logger.info('supplier open invoice apply', { supplierId, settlementId, orderCount: orderIds.length, timestamp })
+
+ if (!supplierId || !token || !timestamp || !settlementId || !orderIds.length) {
+ return { resultCode: 400, message: '供应商、结算单、订单或签名信息不能为空' }
+ }
+ if (!body.invoiceDate || !body.invoiceTitle || !taxIdNumber || !body.invoiceAddress || !body.invoiceContact) {
+ return { resultCode: 400, message: '开票日期、抬头、纳税人识别号、地址和联系电话不能为空' }
+ }
+ if (Number.isNaN(invoiceDate.getTime())) {
+ return { resultCode: 400, message: '开票日期格式不正确' }
+ }
+ if (!Number.isInteger(orderNum) || orderNum <= 0 || !Number.isFinite(orderTotalPrice) || orderTotalPrice < 0) {
+ return { resultCode: 400, message: '订单数量或订单总金额不正确' }
+ }
+
+ const supplier = await supplierDao.findActiveBySupplierId(supplierId)
+ if (!supplier) {
+ return { resultCode: 404, message: '供应商信息不存在' }
+ }
+ if (!verifySupplierOpenSignature(supplier.supplierId, String(body.RsrvFld1 || supplier.clientId), timestamp, token)) {
+ return { resultCode: 401, message: '签名无效或已过期' }
+ }
+
+ const orders = await orderDao.findOpenApiSubOrders(supplierId, orderIds)
+ if (orders.length !== orderIds.length || orderNum !== orderIds.length) {
+ return { resultCode: 400, message: '订单数量校验不通过' }
+ }
+ const actualTotalPrice = orders.reduce((total, order) => total + Number(order.totalPrice || 0), 0)
+ if (Math.abs(actualTotalPrice - orderTotalPrice) >= 0.01) {
+ return { resultCode: 400, message: '订单总金额校验不通过' }
+ }
+
+ const orderIdText = orderIds.join(',')
+ const firstOrder = orders[0]
+ const requestBody = JSON.parse(JSON.stringify(body))
+ await orderDao.transaction(async tx => {
+ await tx.supplierInvoiceInfo.upsert({
+ where: { invoiceBizId: settlementId },
+ update: {
+ supplierId,
+ userId: firstOrder?.userId || null,
+ mainOrderId: firstOrder?.mainOrderId || null,
+ subOrderId: firstOrder?.orderId || null,
+ settlementId,
+ invoiceCode: null,
+ taxIdNumber,
+ orderIds: orderIdText,
+ invoiceStatus: 1,
+ invoiceDate,
+ failureMessage: null,
+ requestBody,
+ deleted: 0
+ },
+ create: {
+ invoiceBizId: settlementId,
+ supplierId,
+ userId: firstOrder?.userId || null,
+ mainOrderId: firstOrder?.mainOrderId || null,
+ subOrderId: firstOrder?.orderId || null,
+ settlementId,
+ taxIdNumber,
+ orderIds: orderIdText,
+ invoiceStatus: 1,
+ invoiceDate,
+ requestBody
+ }
+ })
+ })
+
+ const invoiceId = numericId(`invoice-id:${supplierId}:${settlementId}`, 20)
+ const invoiceCode = numericId(`invoice-code:${supplierId}:${settlementId}`, 12)
+ const checkCode = numericId(`check-code:${supplierId}:${settlementId}`, 20)
+ const taxRate = Number(orders.flatMap(order => order.products)[0]?.taxRate || 0.13)
+ const invoiceNakeAmount = Number(body.invoiceNakedPrice ?? orderTotalPrice / (1 + taxRate))
+ const invoiceTaxAmount = Number(body.invoiceTaxPrice ?? orderTotalPrice - invoiceNakeAmount)
+ const requestedInvoiceType = Number(body.invoiceType || 10)
+ const invoiceType = Number.isInteger(requestedInvoiceType) ? requestedInvoiceType : 10
+ const absoluteFilePath = path.join(invoiceOutputRoot(), supplierId, `${invoiceId}.pdf`)
+ const filePath = path.relative(process.cwd(), absoluteFilePath).replaceAll('\\', '/')
+
+ try {
+ generateMockInvoicePdf({
+ ...body,
+ taxIdNumber,
+ documentInvoiceCode: invoiceCode,
+ invoiceNumber: invoiceId,
+ checkCode,
+ sellerName: supplier.supplierName,
+ sellerTaxId: supplier.supplierId,
+ invoiceNakedPrice: invoiceNakeAmount,
+ invoiceTaxPrice: invoiceTaxAmount,
+ taxRate
+ }, absoluteFilePath)
+ await supplierFileService.uploadPdf(invoiceId, supplierId, `${invoiceId}.pdf`, absoluteFilePath)
+
+ const mainOrderIds = [...new Set(orders.map(order => order.mainOrderId).filter(Boolean))]
+ await orderDao.transaction(async tx => {
+ await tx.supplierInvoiceInfo.update({
+ where: { invoiceBizId: settlementId },
+ data: {
+ invoiceCode,
+ invoiceIds: invoiceId,
+ invoiceStatus: 2,
+ invoiceDate,
+ invoiceType,
+ invoiceNakeAmount,
+ invoiceTaxRate: taxRate,
+ invoiceTaxAmount,
+ invoiceAmount: orderTotalPrice,
+ checkCode,
+ fileType: 'PDF',
+ fileId: invoiceId,
+ filePath,
+ failureMessage: null
+ }
+ })
+ await tx.supplierOrderSub.updateMany({
+ where: { supplierId, orderId: { in: orderIds }, deleted: 0 },
+ data: { invoiceCode }
+ })
+ if (mainOrderIds.length) {
+ await tx.supplierOrderMain.updateMany({
+ where: { supplierId, orderId: { in: mainOrderIds }, deleted: 0 },
+ data: { invoiceCode }
+ })
+ }
+ })
+ } catch (error) {
+ const failureMessage = error instanceof Error ? error.message : '模拟发票生成失败'
+ await orderDao.transaction(async tx => {
+ await tx.supplierInvoiceInfo.update({
+ where: { invoiceBizId: settlementId },
+ data: { invoiceStatus: 3, failureMessage }
+ })
+ })
+ logger.error('supplier mock invoice generate failed', { supplierId, settlementId, failureMessage })
+ return { resultCode: 500, message: failureMessage }
+ }
+
+ const pushResult = await orderPushEventService.pushEvent({
+ supplierId,
+ userId: String(firstOrder?.userId || 'SYSTEM'),
+ orderType: ORDER_EVENT_TYPE.INVOICE_INFO,
+ orderId: settlementId,
+ mainOrderId: firstOrder?.mainOrderId,
+ settlementId,
+ invoiceBizId: settlementId,
+ invoiceCode,
+ invoiceIds: invoiceId,
+ orderIds: orderIdText,
+ fileId: invoiceId,
+ filePath
+ })
+ const pushSuccess = pushResult.success && pushResult.data.pushSuccess
+
+ return {
+ resultCode: 0,
+ message: pushSuccess ? '开票完成并已通知平台' : '开票完成,平台通知已记录待重试'
+ }
+ },
+
+ async queryInvoiceInfo(body: SupplierInvoiceQueryRequest) {
+ const supplierId = String(body.supplierId || '').trim()
+ const token = String(body.token || '').trim()
+ const settlementId = String(body.settlementId || '').trim()
+ const timestamp = Number(body.timestamp || 0)
+
+ if (!supplierId || !token || !timestamp || !settlementId) {
+ return { resultCode: 400, message: '供应商、结算单或签名信息不能为空' }
+ }
+ const supplier = await supplierDao.findActiveBySupplierId(supplierId)
+ if (!supplier) {
+ return { resultCode: 404, message: '供应商信息不存在' }
+ }
+ if (!verifySupplierOpenSignature(supplier.supplierId, String(body.RsrvFld1 || supplier.clientId), timestamp, token)) {
+ return { resultCode: 401, message: '签名无效或已过期' }
+ }
+
+ const invoice = await orderDao.findInvoiceBySettlementId(supplierId, settlementId)
+ if (!invoice) {
+ return { resultCode: 404, message: '未找到对应的开票记录' }
+ }
+ if (invoice.invoiceStatus === 1) {
+ return { resultCode: 409, message: '发票正在开具中' }
+ }
+
+ const request = storedRequest(invoice.requestBody)
+ const success = invoice.invoiceStatus === 2
+ return {
+ resultCode: 0,
+ message: '成功',
+ getInvoiceInfo: {
+ bSuccess: success ? 0 : 1,
+ settlementId,
+ sucOrderIds: success ? invoice.orderIds || '' : '',
+ failOrderIds: success ? '' : invoice.orderIds || '',
+ failMsg: success ? '' : invoice.failureMessage || '开票失败',
+ invoiceInfos: success ? [{
+ invoiceId: invoice.invoiceIds,
+ invoiceCode: invoice.invoiceCode,
+ invoiceDate: invoice.invoiceDate?.toISOString().slice(0, 10),
+ invoiceNakeAmount: Number(invoice.invoiceNakeAmount || 0),
+ invoiceTaxRate: Number(invoice.invoiceTaxRate || 0),
+ invoiceTaxAmount: Number(invoice.invoiceTaxAmount || 0),
+ invoiceAmount: Number(invoice.invoiceAmount || 0),
+ invoiceType: invoice.invoiceType,
+ url: '',
+ imageEncode: '',
+ fileType: invoice.fileType || 'PDF',
+ checkCode: invoice.checkCode,
+ invoiceAddress: String(request.invoiceAddress || '')
+ }] : []
+ }
+ }
+ },
+
+ async queryFileBase64Info(body: SupplierFileBase64QueryRequest) {
+ const supplierId = String(body.supplierId || '').trim()
+ const token = String(body.token || '').trim()
+ const queryType = String(body.queryType || '').trim()
+ const idNumber = String(body.idNumber || '').trim()
+ const fileIdList = Array.isArray(body.fileIdList) ? body.fileIdList.map(item => String(item || '').trim()).filter(Boolean) : []
+ const timestamp = Number(body.timestamp || 0)
+
+ logger.info('supplier open file base64 query', { supplierId, queryType, idNumber, fileCount: fileIdList.length })
+
+ if (!supplierId || !token || !timestamp || !queryType || !idNumber || !fileIdList.length) {
+ return { resultCode: 400, message: '供应商、查询类型、单号、文件ID或签名信息不能为空', fileType: 'JPG', imageEncodeMap: {} }
+ }
+ if (!['1', '2'].includes(queryType)) {
+ return { resultCode: 400, message: '查询类型不正确', fileType: 'JPG', imageEncodeMap: {} }
+ }
+ const supplier = await supplierDao.findActiveBySupplierId(supplierId)
+ if (!supplier) {
+ return { resultCode: 404, message: '供应商信息不存在', fileType: 'JPG', imageEncodeMap: {} }
+ }
+ if (!verifySupplierOpenSignature(supplier.supplierId, String(body.RsrvFld1 || supplier.clientId), timestamp, token)) {
+ return { resultCode: 401, message: '签名无效或已过期', fileType: 'JPG', imageEncodeMap: {} }
+ }
+
+ const imageEncodeMap: Record = {}
+ fileIdList.forEach(fileId => {
+ imageEncodeMap[fileId] = ''
+ })
+
+ if (queryType === '1') {
+ const orders = await orderDao.findOpenApiSubOrders(supplierId, [idNumber])
+ const products = orders.flatMap(order => order.products)
+ for (const fileId of fileIdList) {
+ const product = products.find(item => item.sku === fileId || item.fileId === fileId || item.filePath === fileId)
+ imageEncodeMap[fileId] = await encodeImage(productImageSource(product))
+ }
+ } else {
+ const invoice = await orderDao.findInvoiceBySettlementId(supplierId, idNumber)
+ const invoiceIds = String(invoice?.invoiceIds || '').split(',').map(item => item.trim()).filter(Boolean)
+ if (!invoice || invoice.invoiceStatus !== 2 || (!invoice.fileId && !invoice.filePath)) {
+ return { resultCode: 404, message: '未找到已开具的发票文件', fileType: 'PDF', imageEncodeMap }
+ }
+ if (fileIdList.some(fileId => !invoiceIds.includes(fileId))) {
+ return { resultCode: 404, message: '发票号码与结算单不匹配', fileType: 'PDF', imageEncodeMap }
+ }
+ const pdf = invoice.fileId
+ ? await supplierFileService.read(invoice.fileId)
+ : null
+ if (!pdf && invoice.filePath) {
+ const absoluteFilePath = path.resolve(process.cwd(), invoice.filePath)
+ const outputRoot = invoiceOutputRoot()
+ const relativePath = path.relative(outputRoot, absoluteFilePath)
+ if (!relativePath.startsWith('..') && !path.isAbsolute(relativePath) && existsSync(absoluteFilePath)) {
+ const localPdf = readFileSync(absoluteFilePath)
+ if (localPdf.length <= 3.5 * 1024 * 1024) {
+ fileIdList.forEach(fileId => {
+ imageEncodeMap[fileId] = localPdf.toString('base64')
+ })
+ return { resultCode: 0, message: '成功', fileType: 'PDF', imageEncodeMap }
+ }
+ }
+ }
+ if (!pdf) {
+ return { resultCode: 404, message: '发票文件不存在', fileType: 'PDF', imageEncodeMap }
+ }
+ if (pdf.length > 3.5 * 1024 * 1024) {
+ return { resultCode: 413, message: '发票文件超过Base64接口大小限制', fileType: 'PDF', imageEncodeMap }
+ }
+ const base64 = pdf.toString('base64')
+ fileIdList.forEach(fileId => {
+ imageEncodeMap[fileId] = base64
+ })
+ }
+
+ return { resultCode: 0, message: '成功', fileType: queryType === '2' ? 'PDF' : 'JPG', imageEncodeMap }
+ },
+
async queryOrderInfo(body: SupplierOrderQueryRequest) {
const supplierId = String(body.supplierId || '').trim()
const token = String(body.token || '').trim()
@@ -134,7 +500,7 @@ export const supplierOpenOrderService = {
return { resultCode: 404, message: '供应商信息不存在', orderInfo: [] }
}
- if (!verifySupplierOpenSignature(supplier.supplierId, supplier.clientId, timestamp, token)) {
+ if (!verifySupplierOpenSignature(supplier.supplierId, String(body.RsrvFld1 || supplier.clientId), timestamp, token)) {
return { resultCode: 401, message: '签名无效或已过期', orderInfo: [] }
}
@@ -237,7 +603,7 @@ export const supplierOpenOrderService = {
if (!supplier) {
return { resultCode: 404, message: '供应商信息不存在', orderInfos: [] }
}
- if (!verifySupplierOpenSignature(supplier.supplierId, supplier.clientId, timestamp, token)) {
+ if (!verifySupplierOpenSignature(supplier.supplierId, String(body.RsrvFld1 || supplier.clientId), timestamp, token)) {
return { resultCode: 401, message: '签名无效或已过期', orderInfos: [] }
}
@@ -269,160 +635,5 @@ export const supplierOpenOrderService = {
}))
return { resultCode: 0, message: '成功', totalPage, currentPage: page, orderInfos }
- },
-
- async applyForInvoices(body: SupplierInvoiceApplyRequest) {
- const supplierId = String(body.supplierId || '').trim()
- const token = String(body.token || '').trim()
- const settlementId = String(body.settlementId || '').trim()
- const orderIds = [...new Set(String(body.orderIds || '')
- .split(',')
- .map(item => item.trim())
- .filter(Boolean))]
- const orderNum = Number(body.orderNum || 0)
- const orderTotalPrice = Number(body.orderTotalPrice)
- const timestamp = Number(body.timestamp || 0)
-
- logger.info('supplier open invoice apply', { supplierId, settlementId, orderCount: orderIds.length, timestamp })
-
- if (!supplierId || !token || !timestamp || !settlementId || !orderIds.length) {
- return { resultCode: 400, message: '供应商、结算单、订单或签名信息不能为空' }
- }
- if (!body.invoiceDate || !body.invoiceTitle || !body.invoiceCode || !body.invoiceAddress || !body.invoiceContact) {
- return { resultCode: 400, message: '开票日期、抬头、纳税人识别号、地址和联系电话不能为空' }
- }
- if (!Number.isInteger(orderNum) || orderNum <= 0 || !Number.isFinite(orderTotalPrice) || orderTotalPrice < 0) {
- return { resultCode: 400, message: '订单数量或订单总金额不正确' }
- }
-
- const supplier = await supplierDao.findActiveBySupplierId(supplierId)
- if (!supplier) {
- return { resultCode: 404, message: '供应商信息不存在' }
- }
- if (!verifySupplierOpenSignature(supplier.supplierId, String(body.RsrvFld1 || supplier.clientId), timestamp, token)) {
- return { resultCode: 401, message: '签名无效或已过期' }
- }
-
- const orders = await orderDao.findOpenApiSubOrders(supplierId, orderIds)
- if (orders.length !== orderIds.length || orderNum !== orderIds.length) {
- return { resultCode: 400, message: '订单数量校验不通过' }
- }
-
- const actualTotalPrice = orders.reduce((total, order) => total + Number(order.totalPrice || 0), 0)
- if (Math.abs(actualTotalPrice - orderTotalPrice) >= 0.01) {
- return { resultCode: 400, message: '订单总金额校验不通过' }
- }
-
- const orderIdText = orderIds.join(',')
- const firstOrder = orders[0]
- await orderDao.transaction(async tx => {
- await tx.supplierInvoiceInfo.upsert({
- where: { invoiceBizId: settlementId },
- update: {
- supplierId,
- userId: firstOrder?.userId || null,
- mainOrderId: firstOrder?.mainOrderId || null,
- subOrderId: firstOrder?.orderId || null,
- settlementId,
- invoiceCode: body.invoiceCode,
- orderIds: orderIdText,
- invoiceStatus: 1,
- requestBody: JSON.parse(JSON.stringify(body)),
- deleted: 0
- },
- create: {
- invoiceBizId: settlementId,
- supplierId,
- userId: firstOrder?.userId || null,
- mainOrderId: firstOrder?.mainOrderId || null,
- subOrderId: firstOrder?.orderId || null,
- settlementId,
- invoiceCode: body.invoiceCode,
- orderIds: orderIdText,
- invoiceStatus: 1,
- requestBody: JSON.parse(JSON.stringify(body))
- }
- })
- })
-
- return { resultCode: 0, message: '开票申请已受理' }
- },
-
- async queryInvoicesInfo(body: SupplierInvoiceQueryRequest) {
- const supplierId = String(body.supplierId || '').trim()
- const token = String(body.token || '').trim()
- const settlementId = String(body.settlementId || '').trim()
- const timestamp = Number(body.timestamp || 0)
-
- if (!supplierId || !token || !timestamp || !settlementId) {
- return { resultCode: 400, message: '供应商、结算单或签名信息不能为空' }
- }
-
- const supplier = await supplierDao.findActiveBySupplierId(supplierId)
- if (!supplier) {
- return { resultCode: 404, message: '供应商信息不存在' }
- }
- if (!verifySupplierOpenSignature(supplier.supplierId, supplier.clientId, timestamp, token)) {
- return { resultCode: 401, message: '签名无效或已过期' }
- }
-
- const records = await prisma.supplierInvoiceInfo.findMany({
- where: { supplierId, settlementId, deleted: 0 },
- orderBy: { createTime: 'asc' }
- })
- const completedRecords = records.filter(item => item.invoiceStatus === 2)
- const failedRecords = records.filter(item => item.invoiceStatus === 3)
- const application = records.find(item => item.invoiceStatus === 1)
- const applicationOrderIds = String(application?.orderIds || '')
- const invoiceInfos = completedRecords.flatMap(record => {
- const payload = record.requestBody && typeof record.requestBody === 'object'
- ? record.requestBody as Record
- : {}
- const invoiceIds = String(record.invoiceIds || record.invoiceBizId)
- .split(',')
- .map(item => item.trim())
- .filter(Boolean)
-
- return invoiceIds.map(invoiceId => ({
- invoiceId,
- invoiceCode: record.invoiceCode || '',
- invoiceDate: payload.invoiceDate || null,
- invoiceNakeAmount: Number(payload.invoiceNakeAmount || payload.invoiceNakedPrice || 0),
- invoiceTaxRate: Number(payload.invoiceTaxRate || 0),
- invoiceTaxAmount: Number(payload.invoiceTaxAmount || payload.invoiceTaxPrice || 0),
- invoiceAmount: Number(payload.invoiceAmount || 0),
- invoiceType: Number(payload.invoiceType || 0),
- url: payload.url || record.filePath || '',
- imageEncode: payload.imageEncode || '',
- fileType: payload.fileType || '',
- checkCode: payload.checkCode || '',
- invoiceAddress: payload.invoiceAddress || ''
- }))
- })
-
- const completedOrderIds = completedRecords
- .flatMap(item => String(item.orderIds || '').split(','))
- .map(item => item.trim())
- .filter(Boolean)
- const sucOrderIds = completedRecords.length && !completedOrderIds.length
- ? applicationOrderIds.split(',').map(item => item.trim()).filter(Boolean)
- : completedOrderIds
- const failOrderIds = failedRecords.length ? applicationOrderIds : ''
- const failMsg = failedRecords.length
- ? String((failedRecords[0].requestBody as Record | null)?.failMsg || '开票失败')
- : completedRecords.length ? '' : '发票尚未开具'
-
- return {
- resultCode: 0,
- message: '成功',
- getInvoiceInfo: {
- bSuccess: completedRecords.length ? 0 : 1,
- settlementId,
- sucOrderIds: [...new Set(sucOrderIds)].join(','),
- failOrderIds,
- failMsg,
- invoiceInfos
- }
- }
}
}
diff --git a/supplied-service/src/services/supplier.service.ts b/supplied-service/src/services/supplier.service.ts
index c55fe90..923dc21 100644
--- a/supplied-service/src/services/supplier.service.ts
+++ b/supplied-service/src/services/supplier.service.ts
@@ -12,6 +12,44 @@ type BridgePointsResponse = {
}
export const supplierService = {
+ decryptSupplierSession(keyword: string) {
+ if (!keyword) {
+ return serviceFail('用户参数不能为空')
+ }
+
+ const keyHex = process.env.SM4CBC_KEY_HEX || 'a1b2c3d4e5f60718293a4b5c6d7e8f90'
+ const ivHex = process.env.SM4CBC_IV_HEX || 'f9e8d7c6b5a49382716f0e1d2c3b4a5f'
+ const sessionKeyword = keyword.replace(/ /g, '+')
+
+ logger.info('supplier session decrypt input', {
+ keyword,
+ sessionKeyword,
+ hasKey: Boolean(keyHex),
+ hasIv: Boolean(ivHex),
+ keyLength: keyHex.length,
+ ivLength: ivHex.length
+ })
+
+ try {
+ const decryptedText = sm4CbcDecrypt(sessionKeyword, keyHex, ivHex)
+ logger.info('supplier session decrypt text', { decryptedText })
+ const payload = JSON.parse(decryptedText) as { userId?: unknown }
+ const userId = String(payload.userId || '').trim()
+
+ if (!userId) {
+ logger.warn('supplier session userId empty', { payload })
+ return serviceFail('用户参数无效')
+ }
+
+ return serviceOk({ userId })
+ } catch (error) {
+ logger.warn('supplier session decrypt failed', {
+ message: error instanceof Error ? error.message : String(error)
+ })
+ return serviceFail('用户参数无效')
+ }
+ },
+
async getSupplierInfo(supplierIdentification: string) {
logger.info('supplier info query', { supplierIdentification })
@@ -33,29 +71,11 @@ export const supplierService = {
})
},
- async warmSupplierToken(encryptedParam: string, supplierIdentification: string) {
- logger.info('supplier token warmup', { supplierIdentification })
+ async warmSupplierToken(userId: string, supplierIdentification: string) {
+ logger.info('supplier token warmup', { userId, supplierIdentification })
- if (!encryptedParam || !supplierIdentification) {
- return serviceFail('加密用户参数和供应商唯一标识不能为空')
- }
-
- const keyHex = process.env.SUPPLIER_OPEN_SM4_KEY_HEX || process.env.SM4CBC_KEY_HEX || ''
- const ivHex = process.env.SUPPLIER_OPEN_SM4_IV_HEX || process.env.SM4CBC_IV_HEX || ''
- if (!keyHex || !ivHex) {
- return serviceFail('供应商开放接口SM4配置缺失', 500, 'SM4_CONFIG_MISSING')
- }
-
- let userId = ''
- try {
- const decrypted = sm4CbcDecrypt(encryptedParam.replace(/ /g, '+'), keyHex, ivHex)
- const params = JSON.parse(decrypted) as { userId?: string }
- userId = String(params.userId || '').trim()
- } catch (error) {
- return serviceFail('用户参数解密失败', 400, 'INVALID_USER_PARAM')
- }
- if (!userId) {
- return serviceFail('用户信息不能为空', 400, 'USER_ID_MISSING')
+ if (!userId || !supplierIdentification) {
+ return serviceFail('用户信息和供应商唯一标识不能为空')
}
const supplier = await findSupplierByIdentification(supplierIdentification).catch(error => error)
diff --git a/supplied-service/src/utils/bridge-auth.ts b/supplied-service/src/utils/bridge-auth.ts
index 0ffad05..93a3cb7 100644
--- a/supplied-service/src/utils/bridge-auth.ts
+++ b/supplied-service/src/utils/bridge-auth.ts
@@ -30,6 +30,7 @@ export type BridgeResponse = {
const normalizeBase = (base: string) => base.replace(/\/$/, '')
const tokenKey = (supplierId: string) => `points-mall:bridge-token:${supplierId}`
const TOKEN_EXPIRE_BUFFER_MS = 60_000
+const FALLBACK_BRIDGE_TOKEN = 'local-dev-token'
export const getBridgeApiBase = () => normalizeBase(process.env.POINTS_MALL_OPEN_API_BASE || '')
@@ -168,7 +169,16 @@ export const bridgeFetchWithAuth = async (
}
const call = async (forceRefresh = false) => {
- const token = await getBridgeToken(supplierId, forceRefresh)
+ let token = ''
+ try {
+ token = await getBridgeToken(supplierId, forceRefresh)
+ } catch (error) {
+ logger.warn('bridge token unavailable, use fallback token', {
+ supplierId,
+ message: error instanceof Error ? error.message : String(error)
+ })
+ token = FALLBACK_BRIDGE_TOKEN
+ }
const requestBody = {
...body,
supplierId,
diff --git a/supplied-service/src/utils/supplier-open-crypto.ts b/supplied-service/src/utils/supplier-open-crypto.ts
index 23fa9fb..bb2e539 100644
--- a/supplied-service/src/utils/supplier-open-crypto.ts
+++ b/supplied-service/src/utils/supplier-open-crypto.ts
@@ -13,14 +13,22 @@ export const verifySupplierOpenSignature = (
clientId: string,
timestamp: number | string,
token: string,
- timeWindowMs = 300_000
) => {
const timestampValue = Number(timestamp || 0)
- if (!timestampValue || Math.abs(Date.now() - timestampValue) > timeWindowMs) {
+ if (!timestampValue) {
return false
}
const expected = createSupplierOpenSignature(supplierId, clientId, timestampValue)
+ if (expected !== token) {
+ console.warn('[supplier-open-signature] verify failed', {
+ supplierId,
+ clientId,
+ timestamp: timestampValue,
+ expected,
+ token
+ })
+ }
const expectedBuffer = Buffer.from(expected)
const tokenBuffer = Buffer.from(String(token || ''))
return expectedBuffer.length === tokenBuffer.length && timingSafeEqual(expectedBuffer, tokenBuffer)
diff --git a/supplied-service/tools/mock-invoice-pdf.d.ts b/supplied-service/tools/mock-invoice-pdf.d.ts
new file mode 100644
index 0000000..f06e561
--- /dev/null
+++ b/supplied-service/tools/mock-invoice-pdf.d.ts
@@ -0,0 +1,11 @@
+export type MockInvoicePdfInput = Record
+
+export type MockInvoicePdfOptions = {
+ fontPath?: string
+}
+
+export function generateMockInvoicePdf(
+ invoiceInput: MockInvoicePdfInput,
+ outputPath: string,
+ options?: MockInvoicePdfOptions
+): string
diff --git a/supplied-service/tools/mock-invoice-pdf.js b/supplied-service/tools/mock-invoice-pdf.js
index f7250c3..601fd36 100644
--- a/supplied-service/tools/mock-invoice-pdf.js
+++ b/supplied-service/tools/mock-invoice-pdf.js
@@ -184,6 +184,8 @@ const normalizeInvoice = input => {
...input,
invoiceDate: input.invoiceDate || new Date().toISOString().slice(0, 10),
invoiceNumber: input.invoiceNumber || digest.slice(0, 20),
+ documentInvoiceCode: input.documentInvoiceCode || digest.slice(0, 12),
+ taxIdNumber: input.taxIdNumber || input.buyerTaxId || input.invoiceCode || '',
checkCode: input.checkCode || digest.slice(20, 40),
sellerName: input.sellerName || '模拟积分商城供应商',
sellerTaxId: input.sellerTaxId || input.supplierId || 'SIMULATED-SUPPLIER',
@@ -198,19 +200,11 @@ const normalizeInvoice = input => {
}
}
-export const generateMockInvoicePdf = (invoiceInput, outputPath, options = {}) => {
+export const generateMockInvoicePdf = (invoiceInput, outputPath, _options = {}) => {
const invoice = normalizeInvoice(invoiceInput)
- const fontPath = findFont(options.fontPath)
- const font = readFileSync(fontPath)
- const glyphFor = createGlyphMapper(font)
- const glyphUnicode = new Map()
const commands = []
- const encode = value => Array.from(String(value ?? '')).map(character => {
- const glyph = glyphFor(character.codePointAt(0))
- if (glyph && !glyphUnicode.has(glyph)) glyphUnicode.set(glyph, character)
- return glyph.toString(16).padStart(4, '0')
- }).join('').toUpperCase()
+ const encode = value => utf16Hex(String(value ?? ''))
const text = (value, x, y, size = 10, color = '0 0 0') => {
commands.push(`BT /F1 ${size} Tf ${color} rg 1 0 0 1 ${x} ${y} Tm <${encode(value)}> Tj ET`)
}
@@ -232,7 +226,8 @@ export const generateMockInvoicePdf = (invoiceInput, outputPath, options = {}) =
line(274, 540, 568, 540, 1.2, '0.65 0.05 0.05')
text('仅供系统联调测试,禁止报销', 302, 522, 11, '0.75 0.1 0.1')
- text(`发票号码:${invoice.invoiceNumber}`, 610, 555, 9)
+ text(`发票号码:${invoice.invoiceNumber}`, 610, 572, 9)
+ text(`发票代码:${invoice.documentInvoiceCode}`, 610, 555, 9)
text(`开票日期:${invoice.invoiceDate}`, 610, 538, 9)
text(`校验码:${invoice.checkCode}`, 610, 521, 9)
text(`结算单号:${invoice.settlementId || ''}`, 50, 521, 9)
@@ -252,7 +247,7 @@ export const generateMockInvoicePdf = (invoiceInput, outputPath, options = {}) =
text('名称:', 132, 488, 9)
wrappedText(invoice.invoiceTitle, 180, 488, 26, 9)
text('纳税人识别号:', 132, 464, 9)
- text(invoice.invoiceCode, 235, 464, 9)
+ text(invoice.taxIdNumber, 235, 464, 9)
text('地址、电话:', 487, 488, 9)
wrappedText(`${invoice.invoiceAddress || ''} ${invoice.invoiceContact || ''}`, 574, 488, 20, 8)
text('开户行及账号:', 487, 448, 9)
@@ -298,32 +293,13 @@ export const generateMockInvoicePdf = (invoiceInput, outputPath, options = {}) =
commands.push('0.75 0.08 0.08 RG 2 w 798 88 m 798 111.196 779.196 130 756 130 c 732.804 130 714 111.196 714 88 c 714 64.804 732.804 46 756 46 c 779.196 46 798 64.804 798 88 c S')
const content = Buffer.from(commands.join('\n'), 'ascii')
- const toUnicodeEntries = [...glyphUnicode.entries()].map(([glyph, character]) =>
- `<${glyph.toString(16).padStart(4, '0').toUpperCase()}> <${utf16Hex(character)}>`)
- const toUnicodeBlocks = []
- for (let index = 0; index < toUnicodeEntries.length; index += 100) {
- const entries = toUnicodeEntries.slice(index, index + 100)
- toUnicodeBlocks.push(`${entries.length} beginbfchar`, ...entries, 'endbfchar')
- }
- const toUnicode = Buffer.from([
- '/CIDInit /ProcSet findresource begin', '12 dict begin', 'begincmap',
- '/CIDSystemInfo << /Registry (Adobe) /Ordering (UCS) /Supplement 0 >> def',
- '/CMapName /MockInvoiceUnicode def', '/CMapType 2 def',
- '1 begincodespacerange', '<0000> ', 'endcodespacerange',
- ...toUnicodeBlocks,
- 'endcmap', 'CMapName currentdict /CMap defineresource pop', 'end', 'end'
- ].join('\n'), 'ascii')
-
const writer = createPdfWriter()
writer.add('<< /Type /Catalog /Pages 2 0 R >>')
writer.add('<< /Type /Pages /Kids [3 0 R] /Count 1 >>')
writer.add(`<< /Type /Page /Parent 2 0 R /MediaBox [0 0 ${PAGE_WIDTH} ${PAGE_HEIGHT}] /Resources << /Font << /F1 5 0 R >> >> /Contents 4 0 R >>`)
writer.add(streamObject('', content))
- writer.add('<< /Type /Font /Subtype /Type0 /BaseFont /MockInvoiceFont /Encoding /Identity-H /DescendantFonts [6 0 R] /ToUnicode 9 0 R >>')
- writer.add('<< /Type /Font /Subtype /CIDFontType2 /BaseFont /MockInvoiceFont /CIDSystemInfo << /Registry (Adobe) /Ordering (Identity) /Supplement 0 >> /FontDescriptor 7 0 R /DW 1000 /CIDToGIDMap /Identity >>')
- writer.add('<< /Type /FontDescriptor /FontName /MockInvoiceFont /Flags 4 /FontBBox [-1000 -1000 3000 3000] /ItalicAngle 0 /Ascent 1000 /Descent -300 /CapHeight 800 /StemV 80 /FontFile2 8 0 R >>')
- writer.add(streamObject(`/Length1 ${font.length}`, font))
- writer.add(streamObject('', toUnicode))
+ writer.add('<< /Type /Font /Subtype /Type0 /BaseFont /STSong-Light /Encoding /UniGB-UCS2-H /DescendantFonts [6 0 R] >>')
+ writer.add('<< /Type /Font /Subtype /CIDFontType0 /BaseFont /STSong-Light /CIDSystemInfo << /Registry (Adobe) /Ordering (GB1) /Supplement 4 >> /DW 1000 >>')
writer.save(outputPath)
return outputPath
}