material_k3cloud_dao.go
2.6 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
package dao
import (
pgTransaction "github.com/linmadan/egglib-go/transaction/pg"
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/infrastructure/pg/models"
)
type MaterialK3cloudDao struct {
transactionContext *pgTransaction.TransactionContext
}
//SyncDataMaterialK3cloud 同步MaterialK3cloud表数据
func (d *MaterialK3cloudDao) SyncDataMaterialK3cloud(data []models.MaterialK3cloud) error {
// -- 插入或者更新
// INSERT INTO "manufacture"."material_k3cloud" (
// "material_id","name","number","specification","forbid_status",
// "erp_cls_id","base_unit_id","base_unit_name","create_date",
// "modify_date","forbid_date","approve_date","material_group",
// "material_group_number","material_group_name","ref_status ",
// "join_product_id","data_version" )
// VALUES
// (
// '1',2,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,
// NULL,NULL,NULL,NULL,nextval( 'manufacture.manufacture_seq_id_seq' ),NULL
// ) ON conflict ( material_id ) DO
// UPDATE
// SET (
// "name","number","specification","forbid_status","erp_cls_id",
// "base_unit_id","base_unit_name","create_date","modify_date",
// "forbid_date","approve_date","material_group","material_group_number",
// "material_group_name","ref_status ","data_version" ) = (
// EXCLUDED."name",EXCLUDED."number",EXCLUDED."specification",
// EXCLUDED."forbid_status",EXCLUDED."erp_cls_id",EXCLUDED."base_unit_id",
// EXCLUDED."base_unit_name",EXCLUDED."create_date",EXCLUDED."modify_date",
// EXCLUDED."forbid_date",EXCLUDED."approve_date",EXCLUDED."material_group",
// EXCLUDED."material_group_number",EXCLUDED."material_group_name",
// EXCLUDED."ref_status ",EXCLUDED."data_version" )
return nil
}
//SyncDataProudct 同步Proudct表数据
func (d *MaterialK3cloudDao) SyncDataProudct(version int) error {
// -- 插入或者更新
// INSERT INTO "manufacture"."product"(
// "company_id", "org_id", "product_id", "product_code", "product_name",
// "product_category", "product_spec", "created_at", "updated_at"
// )
// SELECT 0,0,"join_product_id","number","name","material_group_name",'{}',now(),now()
// FROM "manufacture"."material_k3cloud" WHERE "data_version"=0000
// ON conflict ( product_id ) DO
// UPDATE
// SET (
// "company_id", "org_id", "product_id", "product_code", "product_name",
// "product_category", "product_spec", "created_at", "updated_at")=(
// EXCLUDED."company_id", EXCLUDED."org_id",EXCLUDED."product_id",
// EXCLUDED."product_code",EXCLUDED."product_name",EXCLUDED."product_category",
// EXCLUDED."product_spec", EXCLUDED."created_at", EXCLUDED."updated_at")
return nil
}