1. //request json
    2. {
    3.     "data": [
    4.         {
    5.             "shop_id": 410,
    6.             "tiktok": "tiktok1,tiktok2,tiktok3,tiktok4,tiktok5,tiktok6,tiktok7,tiktok8,tiktok1"
    7.         }
    8.     ]
    9. }
    12. type SetTraceResult struct {
    13.     ShopId int  `json:"shop_id"`
    14.     Result bool `json:"result"`
    15. }
    17. resCh := make(chan SetTraceResult, 1) //结果channel
    19.     for _, info := range data.Data {
    20.         go func(info TraceInfo) {
    21.             record := models.GetShopSettingByShopId(info.ShopId, []string{"id", "shop_id"}) //查询店铺设置
    23.             res := SetTraceResult{         //默认的返回result
    24.                 ShopId: info.ShopId,
    25.                 Result: true,
    26.             }
    27.             if record.ID > 0 {
    28.                 var infoMap = make(map[string]interface{})
    29.                 infoMap, err = utils.Struct2MapWithJson(info)
    30.                 if err != nil {
    31.                     res.Result = false //转义失败
    32.                     resCh <- res
    33.                     return
    34.                 }
    35.             } else {
    36.                 record := models.SailShopSetting{}
    37.                 utils.StructCopy(info, &record)
    38.                 err = models.CreateShopSetting(record) //增加表记录
    39.                 if err != nil {
    40.                     res.Result = false
    41.                 }
    42.             }
    45.             // 自定义代码应用
    46.             if info.CustomGlobalScript != nil && *info.CustomGlobalScript != "" {
    47.                 appInfo := models.GetAppByName("customCode")
    48.                 installRecord := models.GetInstallationRecord(record.ShopId, appInfo.ID)
    49.                 customConfig := fmt.Sprintf(`{"customCode":"%s"}`, *info.CustomGlobalScript)
    50.                 if installRecord.ID > 0 {
    51.                     err = models.UpdateInstallationRecord(record.ShopId, appInfo.ID, "config", customConfig)
    52.                 } else {
    53.                     installRecode := models.SailShopInstalledApplications{
    54.                         ShopID:        record.ShopId,
    55.                         ApplicationID: appInfo.ID,
    56.                         AppType:       appInfo.AppType,
    57.                         Config:        customConfig,
    58.                         Status:        1,
    59.                         InstalledAt:   time.Now(),
    60.                         Installed:     1,
    61.                         IsNew:         1,
    62.                     }
    63.                     err = models.CreateInstallationRecord(installRecode)
    64.                 }
    65.                 if err != nil {
    66.                     res.Result = false
    67.                 }
    68.             }
    70.             resCh <- res
    71.         }(info)
    72.     }
    73.     var r []SetTraceResult
    74.     for i := 0; i < len(data.Data); i++ {
    75.         r = append(r, <-resCh)
    76.     }
    77.     app.Success(c, r)