去掉获取工艺参数重试，增加plc写入失败重试

zhangqian

2023-08-28 adc5f83146f898cd2743313e619fff47141799f7

去掉获取工艺参数重试，增加plc写入失败重试

 api/v1/task.go

@@ -267,29 +267,22 @@
    }

    logx.Info("----------------开始下发工艺参数-----------------")
    var missNumbers int
    var failedNumbers int
    for k, v := range paramsMap {
        if address, ok := plc_address.Get(k); ok {
            result, err := plc.WriteHoldingRegister(conn, address, v)
            if err != nil {
                logx.Errorf("WriteHoldingRegister err:%v, address: %v, key: %v value: %v", err.Error(), address, k, v)
                failedNumbers++
                logx.Errorf("plc write err:%v, address: %v, key: %v value: %v", err.Error(), address, k, v)
            } else {
                delete(paramsMap, k)
                logx.Infof("WriteHoldingRegister ok: key: %v, value: %v, result: %v", k, v, result)
                logx.Infof("plc write ok: key: %v, value: %v, result: %v", k, v, result)
            }
        } else {
            logx.Errorf("miss param address, k:%v, v:%v", k, v)
            missNumbers++
        }
    }
    if missNumbers >= 1 {
        caller := nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicGetPlcAddress, conf.Conf.NsqConf.NodeId), fmt.Sprintf(constvar.NsqTopicSendPlcAddress, conf.Conf.NsqConf.NodeId))
        var addressResult common.ResponsePlcAddress
        err := caller.Call(common.RequestPlcAddress{DeviceId: conf.Conf.System.DeviceId}, &addressResult, time.Second*2)
        if err != nil {
            logx.Infof("SendParams2 err: %v", err.Error())
            return err
        }
    if failedNumbers >= 1 { //写入plc失败, 重试
        tryTimes++
        return SendParams(paramsMap, tryTimes)
    }

 pkg/plc/plc4x.go

@@ -46,8 +46,8 @@
            return conn, nil
        }
    }
    // 创建一个上下文，并设置 5 秒超时
    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    // 创建一个上下文，并设置 3 秒超时
    ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
    defer cancel()
    conn, err := NewGetModbusConnection(ctx, ipAddr)
    if err != nil {