| | |
|---|
| | | logger.Error("GetAllData Error", err) |
|---|
| | | } |
|---|
| | | fmt.Println("ruleInfo: ", ruleInfo) |
|---|
| | | statusNo := make(map[string]int) |
|---|
| | | statusNo["stranger"] = db.StatusStranger |
|---|
| | | statusNo["visitor"] = db.StatusVisitor |
|---|
| | | statusNo["resident"] = db.StatusResident |
|---|
| | | communityIDs, err := db.GetCommunityIDs() |
|---|
| | | fmt.Println("communityIDs:", communityIDs) |
|---|
| | | if err != nil { |
|---|
| | |
|---|
| | | //业务逻辑 |
|---|
| | | } |
|---|
| | | fmt.Println("社区档案总条数：", len(documentNumberIDS)) |
|---|
| | | |
|---|
| | | captureInfos := make([]db.CaptureInfo, 0) |
|---|
| | | batchSize := config.Elastic.BatchSize |
|---|
| | | //fmt.Println(batchSize) |
|---|
| | |
|---|
| | | |
|---|
| | | //continue |
|---|
| | | |
|---|
| | | postCaptureInfos := data.ProcessData(captureInfos, personStatusList, ruleInfo, communityID) |
|---|
| | | postCaptureInfos := data.ProcessData(captureInfos, personStatusList, ruleInfo, statusNo, communityID) |
|---|
| | | for _, inf := range postCaptureInfos { |
|---|
| | | fmt.Println("---->pause prepare: capture ", inf.DocumentNumber, inf.Status, inf.FrequentAddress) |
|---|
| | | //return |
|---|
