internal/sync/generated_table_fun.go - main - iezhelev/cppsh_micro

internal/sync/generated_table_fun.go
66 строк5 KB
iezhelev
mrm_data_for_incident sync timer
27 июн 2025, 12:57
27 июн 2025, 12:570c3e5ba
// Code generated by generator.js; DO NOT EDIT.
  package sync 
  
  import (
       "context"
       "database/sql"
       "fmt"
       "time"
  
       "github.com/streadway/amqp"
       //"golang.org/x/sync/errgroup"
  )
  
  func SyncTable(ctx context.Context, mainDB, dockerDB *sql.DB, rabbitConn *amqp.Connection, tableName string, lastSyncTime time.Time) (time.Time, error) {
  switch tableName {
  	case "activity_norm":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "activity_norm_b0", "activity_norm","");
	case "activity_sh":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "activity_sh_b0", "activity_sh","");
	case "ipattachment":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "system", "ipattachment", "ipattachment","and extention in ('JPG','JPEG','PNG')");
	case "ciparam":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "ciparam_b0", "ciparam","and is_active=1");
	case "citype":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "citype_b0", "citype","");
	case "citypeparams":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "ciparams_b0", "citypeparams","");
	case "citypicalfault":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "citypicalfault_b0", "citypicalfault","");
	case "comment":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "system", "comment", "comment","and is_active=1 and entitytype_id in (3692, 4314, 4444, 4387)");
	case "edizm":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "edizm_b0", "edizm","");
	case "ipentityattachment":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "system", "ipentityattachment", "ipentityattachment","and short_name in (select short_name from system.ipattachment where extention in ('JPG','JPEG','PNG'))");
	case "mrm_data_for_incident":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "mrm_data_for_incident_b0", "mrm_data_for_incident","and integer_0 in (select plannedactivity_b0.plannedactivity_id from fkv39o1z.plannedactivity_b0 where  (date(coalesce(datetime_14,datetime_12,datetime_0)) between date(CURRENT_DATE - INTERVAL '10 DAY') and date(CURRENT_DATE  + INTERVAL '15 DAY')))");
	case "obj_inf":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "obj_inf_b0", "obj_inf","");
	case "obj_osn_inf":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "obj_osn_inf_b0", "obj_osn_inf","");
	case "obor_szb":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "obor_szb_b0", "obor_szb","");
	case "pa_works":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "pa_works_b0", "pa_works","and pa_works_id in (select plannedactivity_b0.integer_15 from fkv39o1z.plannedactivity_b0 where (date(coalesce(datetime_14,datetime_12,datetime_0)) between date(CURRENT_DATE - INTERVAL '10 DAY') and date(CURRENT_DATE + INTERVAL '15 DAY')))");
	case "personal":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "personal_b0", "personal","and integer_2 is not null");
	case "plannedactivity":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "plannedactivity_b0", "plannedactivity","and  (date(coalesce(datetime_14,datetime_12,datetime_0)) between date(CURRENT_DATE - INTERVAL '10 DAY') and date(CURRENT_DATE  + INTERVAL '15 DAY'))");
	case "planned_activity_params":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "planned_activity_params_b0", "planned_activity_params","and integer_0 in (select plannedactivity_b0.plannedactivity_id from fkv39o1z.plannedactivity_b0 where  (date(coalesce(datetime_14,datetime_12,datetime_0)) between date(CURRENT_DATE - INTERVAL '10 DAY') and date(CURRENT_DATE  + INTERVAL '15 DAY')))");
	case "plannedactivity_persons":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "plannedactivity_persons_b0", "plannedactivity_persons","and integer_0 in (select plannedactivity_b0.plannedactivity_id from fkv39o1z.plannedactivity_b0 where  (date(coalesce(datetime_14,datetime_12,datetime_0)) between date(CURRENT_DATE - INTERVAL '10 DAY') and date(CURRENT_DATE  + INTERVAL '15 DAY')))");
	case "rel_personal_workspace_users":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "rel_personal_workspace_users_b0", "rel_personal_workspace_users","");
	case "ipuser":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "system", "ipuser", "ipuser","and role_id in (68, 69, 70)");
	case "ipworkflowstep":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "system", "ipworkflowstep", "ipworkflowstep","and workflow_id = 231");
	case "workspace_user":
		return SyncDataGeneric(ctx, mainDB, dockerDB, lastSyncTime, "fkv39o1z", "workspace_user_b0", "workspace_user","and integer_3 is not null");

       default:
           return lastSyncTime, fmt.Errorf("unknown table: %s", tableName)
       }
  }