| | |
| | | } |
| | | finishNumber := cast.ToInt64(value) |
| | | if finishNumber != 0 { |
| | | service.PlcCacheSet(addressItem.Position, constvar.PlcCacheKeyFinishNumber, finishNumber) |
| | | _ = service.NewProgressService().UpdateProgress(addressItem.Position, cast.ToInt64(finishNumber)) |
| | | service.PlcCacheSet(addressItem.Channel, constvar.PlcCacheKeyFinishNumber, finishNumber) |
| | | _ = service.NewProgressService().UpdateProgress(addressItem.Channel, cast.ToInt64(finishNumber)) |
| | | } |
| | | logx.Infof("plc read finish number: %v", finishNumber) |
| | | } |
| | |
| | | } |
| | | totalNumber := cast.ToInt64(value) |
| | | if totalNumber != 0 { |
| | | service.PlcCacheSet(addressItem.Position, constvar.PlcCacheKeyTotalNumber, totalNumber) |
| | | _ = service.NewProgressService().UpdateProgress(addressItem.Position, cast.ToInt64(totalNumber)) |
| | | service.PlcCacheSet(addressItem.Channel, constvar.PlcCacheKeyTotalNumber, totalNumber) |
| | | _ = service.NewProgressService().UpdateProgress(addressItem.Channel, cast.ToInt64(totalNumber)) |
| | | } |
| | | logx.Infof("plc read total number: %v", totalNumber) |
| | | } |
| | |
| | | if code != ecode.OK { |
| | | return |
| | | } |
| | | var positions []int |
| | | var channels []int32 |
| | | for _, item := range plcConfig.Details { |
| | | if item.FieldName == constvar.PlcStartAddressTypeFinishNumber { |
| | | positions = append(positions, item.Position) |
| | | channels = append(channels, item.Channel) |
| | | } |
| | | } |
| | | for _, position := range positions { |
| | | progress, err := service.NewProgressService().GetCurrentProgress(position) |
| | | for _, channel := range channels { |
| | | progress, err := service.NewProgressService().GetCurrentProgress(channel) |
| | | if err != nil { |
| | | return |
| | | } |