aa

business/model/dao/common.go

@@ -30,3 +30,22 @@ func GetNeedUploadDataResource(db *DaoDB) (dataResList []*model.DataResource, er
 	err = GetRows(db, &dataResList, sql)
 	return dataResList, err
 }
+
+func GetVendorOrgCode(db *DaoDB, vendorID int, vendorOrgCode string) (vendorOrgs []*model.VendorOrgCode, err error) {
+	sql := ` 
+		SELECT *
+		  FROM vendor_org_code 
+		 WHERE deleted_at = ? 
+	`
+	sqlParams := []interface{}{}
+	if vendorID != -1 {
+		sql += " AND vendor_id = ?"
+		sqlParams = append(sqlParams, vendorID)
+	}
+	if vendorOrgCode != "" {
+		sql += " AND vendor_org_code = ?"
+		sqlParams = append(sqlParams, vendorOrgCode)
+	}
+	err = GetRows(db, &vendorOrgs, sql, sqlParams)
+	return vendorOrgs, err
+}