|
|
|
package dao
|
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
"strconv"
|
|
|
|
"strings"
|
|
|
|
|
|
|
|
pgTransaction "github.com/linmadan/egglib-go/transaction/pg"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/infrastructure/pg/models"
|
|
|
|
)
|
|
...
|
...
|
@@ -9,6 +13,16 @@ type MaterialK3cloudDao struct { |
|
|
|
transactionContext *pgTransaction.TransactionContext
|
|
|
|
}
|
|
|
|
|
|
|
|
func NewMaterialK3cloudDao(transactionContext *pgTransaction.TransactionContext) (*MaterialK3cloudDao, error) {
|
|
|
|
if transactionContext == nil {
|
|
|
|
return nil, fmt.Errorf("transactionContext参数不能为nil")
|
|
|
|
} else {
|
|
|
|
return &MaterialK3cloudDao{
|
|
|
|
transactionContext: transactionContext,
|
|
|
|
}, nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
//SyncDataMaterialK3cloud 同步MaterialK3cloud表数据
|
|
|
|
func (d *MaterialK3cloudDao) SyncDataMaterialK3cloud(data []models.MaterialK3cloud) error {
|
|
|
|
// -- 插入或者更新
|
|
...
|
...
|
@@ -35,25 +49,118 @@ func (d *MaterialK3cloudDao) SyncDataMaterialK3cloud(data []models.MaterialK3clo |
|
|
|
// EXCLUDED."forbid_date",EXCLUDED."approve_date",EXCLUDED."material_group",
|
|
|
|
// EXCLUDED."material_group_number",EXCLUDED."material_group_name",
|
|
|
|
// EXCLUDED."ref_status ",EXCLUDED."data_version" )
|
|
|
|
sqlValues := []string{}
|
|
|
|
var strTemp []string
|
|
|
|
for i := range data {
|
|
|
|
strTemp = make([]string, 0, 18)
|
|
|
|
strTemp = append(strTemp, strconv.Itoa(data[i].MaterialId))
|
|
|
|
strTemp = append(strTemp, `'`+data[i].Name+`'`)
|
|
|
|
strTemp = append(strTemp, `'`+data[i].Number+`'`)
|
|
|
|
strTemp = append(strTemp, `'`+data[i].Specification+`'`)
|
|
|
|
strTemp = append(strTemp, `'`+data[i].ForbidStatus+`'`)
|
|
|
|
strTemp = append(strTemp, strconv.Itoa(data[i].ErpClsId))
|
|
|
|
strTemp = append(strTemp, strconv.Itoa(data[i].BaseUnitId))
|
|
|
|
strTemp = append(strTemp, `'`+data[i].BaseUnitName+`'`)
|
|
|
|
if data[i].CreateDate.IsZero() {
|
|
|
|
strTemp = append(strTemp, `NULL`)
|
|
|
|
} else {
|
|
|
|
strTemp = append(strTemp, `'`+data[i].CreateDate.String()+`'`)
|
|
|
|
}
|
|
|
|
if data[i].ModifyDate.IsZero() {
|
|
|
|
strTemp = append(strTemp, `NULL`)
|
|
|
|
} else {
|
|
|
|
strTemp = append(strTemp, `'`+data[i].ModifyDate.String()+`'`)
|
|
|
|
}
|
|
|
|
if data[i].ForbidDate.IsZero() {
|
|
|
|
strTemp = append(strTemp, `NULL`)
|
|
|
|
} else {
|
|
|
|
strTemp = append(strTemp, `'`+data[i].ForbidDate.String()+`'`)
|
|
|
|
}
|
|
|
|
if data[i].ApproveDate.IsZero() {
|
|
|
|
strTemp = append(strTemp, `NULL`)
|
|
|
|
} else {
|
|
|
|
strTemp = append(strTemp, `'`+data[i].ApproveDate.String()+`'`)
|
|
|
|
}
|
|
|
|
strTemp = append(strTemp, strconv.Itoa(data[i].MaterialGroup))
|
|
|
|
strTemp = append(strTemp, `'`+data[i].MaterialGroupNumber+`'`)
|
|
|
|
strTemp = append(strTemp, `'`+data[i].MaterialGroupName+`'`)
|
|
|
|
strTemp = append(strTemp, strconv.Itoa(data[i].RefStatus))
|
|
|
|
//关联的产品表id ，使用 product 产品表的自增序列表
|
|
|
|
strTemp = append(strTemp, "nextval('manufacture.product_product_id_seq'::regclass)")
|
|
|
|
strTemp = append(strTemp, strconv.Itoa(int(data[i].DataVersion)))
|
|
|
|
strTemp = append(strTemp, strconv.Itoa(data[i].UseOrgId))
|
|
|
|
sqlValues = append(sqlValues, "("+strings.Join(strTemp, ",")+")")
|
|
|
|
|
|
|
|
}
|
|
|
|
var valueTemp []string
|
|
|
|
for i := 0; i < len(sqlValues); i += 100 {
|
|
|
|
if i < len(sqlValues)-100 {
|
|
|
|
valueTemp = sqlValues[i:100]
|
|
|
|
} else {
|
|
|
|
valueTemp = sqlValues[i:]
|
|
|
|
}
|
|
|
|
sql := `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","use_org_id" )
|
|
|
|
VALUES ` + strings.Join(valueTemp, ",") +
|
|
|
|
` 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" )`
|
|
|
|
_, err := d.transactionContext.PgTx.Exec(sql)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
//SyncDataProudct 同步Proudct表数据
|
|
|
|
func (d *MaterialK3cloudDao) SyncDataProudct(version int) error {
|
|
|
|
//SyncDataProudct 同步MaterialK3cloud表数据到Proudct表
|
|
|
|
func (d *MaterialK3cloudDao) SyncDataProudct(version int64) 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
|
|
|
|
sql := `INSERT INTO "manufacture"."product"(
|
|
|
|
"company_id", "org_id", "product_id", "product_code", "product_name",
|
|
|
|
"product_category", "product_spec", "created_at", "updated_at"
|
|
|
|
)
|
|
|
|
SELECT 0,use_org_id,"join_product_id","number","name","material_group_name",
|
|
|
|
json_build_object('unit',specification),now(),now()
|
|
|
|
FROM "manufacture"."material_k3cloud" WHERE "data_version"=?
|
|
|
|
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."updated_at") `
|
|
|
|
_, err := d.transactionContext.PgTx.Exec(sql, version)
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
func (d *MaterialK3cloudDao) GetLastVersion() (int64, error) {
|
|
|
|
var materialData []models.MaterialK3cloud
|
|
|
|
err := d.transactionContext.PgTx.Model(&materialData).
|
|
|
|
Order("data_version DESC").
|
|
|
|
Limit(1).
|
|
|
|
Select()
|
|
|
|
if err != nil {
|
|
|
|
return 0, err
|
|
|
|
}
|
|
|
|
if len(materialData) == 0 {
|
|
|
|
return 0, nil
|
|
|
|
}
|
|
|
|
return materialData[0].DataVersion, nil
|
|
|
|
} |
...
|
...
|
|
