网络配置获取和删除，品牌增删改查

zhangqian

2023-08-19 066a30751bdc20f9e83b34539de71ae392783e1b

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
package nsq
 
import (
    "apsClient/conf"
    "apsClient/pkg/logx"
    "apsClient/pkg/nsqclient"
)
 
var producer nsqclient.Producer
 
func GetProducer() nsqclient.Producer {
    return producer
}
 
func initProducer() (err error) {
    producer, err = nsqclient.NewProducer(conf.Conf.NsqConf.NsqdAddr)
    if err != nil {
        logx.Errorf("NewProducer err:%v", err)
        return err
    }
    // 测试发布数据
    //go func() {
    //    for {
    //        time.Sleep(time.Second)
    //        _ = producer.Publish("test", []byte("123"))
    //    }
    //}()
 
    //go func() {
    //    for {
    //        time.Sleep(time.Second * 2)
    //        err := producer.Publish("aps.wangpengfei.erp.cstReply", []byte("456"))
    //        logx.Infof("=====err:%v", err)
    //    }
    //}()
 
    //go func() {
    //    for {
    //        time.Sleep(time.Second * 5)
    //        applyMaterial := ApplyOrderMaterial{
    //            FBillNo:   "123",
    //            FNumber:   "456",
    //            UseAmount: 1,
    //        }
    //
    //        applyBytes, err := json.Marshal([]*ApplyOrderMaterial{&applyMaterial})
    //        if err != nil {
    //            return
    //        }
    //
    //        producer := GetProducer()
    //        err = producer.Publish(fmt.Sprintf("aps.%v.erp.cstApply", conf.WebConf.NodeId), applyBytes)
    //        logx.Infof("===============ApplyMaterialByProduct topic:%v, applyBytes:%v, err:%v", fmt.Sprintf("aps.%v.erp.cstApply", conf.WebConf.NodeId), string(applyBytes), err)
    //        if err != nil {
    //            return
    //        }
    //    }
    //}()
    return nil
}