Browse Source

feat:xiugai

wangchuanjin 2 months ago
parent
commit
d95c9d0f7f
2 changed files with 12 additions and 13 deletions
  1. 1 1
      openPower/config.json
  2. 11 12
      openPower/openPower.go

+ 1 - 1
openPower/config.json

@@ -22,7 +22,7 @@
 	      	"maxIdleConns": 2
 	    }
   	},
-	"products": [14,15,16,17,18,19,20,22,23,24,27,28,25,26,29,30,31,32,33,34,35],
+	"products": [14,15,16,17,18,19,20,22,23,24,27,28,25,26,29,30,31,32,33,34,35,43],
 	"redis": "session=172.20.45.129:1713",
 	"domain": "https://jybx-webtest.jydev.jianyu360.com"
 }

+ 11 - 12
openPower/openPower.go

@@ -143,14 +143,14 @@ func main() {
 	resetPower := flag.Bool("rp", false, "是否重新开通权益")
 	inputProductType := flag.String("pt", "", "订单的产品类型")
 	flag.Parse()
-	//*phone = "15037870753"
-	//*t = 22
-	//*entName = "王传进的测试企业99"
+	//*phone = "18221111364"
+	//*t = 43
+	//*entName = "人脉管理企业"
 	//*isCreateUser = true
-	//*inputOrderCode = "259519348822"
-	//*inputStartTime = 1746028800
-	//*inputEndTime = 1747584000
-	//*inputProductType = "历史数据"
+	//*inputOrderCode = "160007591541"
+	//*inputStartTime = 1747670400
+	//*inputEndTime = 1747670400
+	//*inputProductType = "人脉管理"
 	//*m = 2
 	//
 	if *phone == "" {
@@ -345,7 +345,7 @@ func main() {
 						if *powerWay < 2 {
 							isEmpower = true
 						} else if *powerWay == 2 {
-							log.Fatalln(msg, powerType, "权益已存在!")
+							log.Println(msg, powerType, "权益已存在!")
 						}
 					}
 					// for _, v := range all {
@@ -490,7 +490,7 @@ func main() {
 				if MysqlMain.UpdateOrDeleteBySql(`update jianyu.dataexport_order set `+strings.Join(array, ",")+` where order_code=?`, updateArgs...) < 0 {
 					log.Fatalln("更新订单主表" + strings.Join(updateFields, "、") + "失败!")
 				} else {
-					log.Fatalln("更新订单主表" + strings.Join(updateFields, "、") + "成功!")
+					log.Println("更新订单主表" + strings.Join(updateFields, "、") + "成功!")
 				}
 			}
 		}()
@@ -532,7 +532,7 @@ func main() {
 					if MysqlMain.UpdateOrDeleteBySql(`update jianyu.jy_order_detail set `+strings.Join(array, ",")+` where id=?`, updateArgs...) < 0 {
 						log.Fatalln(id, "更新订单子表"+strings.Join(updateFields, "、")+"失败!")
 					} else {
-						log.Fatalln(id, "更新订单子表"+strings.Join(updateFields, "、")+"成功!")
+						log.Println(id, "更新订单子表"+strings.Join(updateFields, "、")+"成功!")
 					}
 				}
 			}
@@ -802,11 +802,10 @@ func createUser(phone string, isCreateUser bool) (bool, *[]map[string]interface{
 			"l_registedate": time.Now().Unix(),
 			"s_regsource":   "openpower",
 		})
-		MgoLog.Save("user", map[string]interface{}{
+		MgoLog.Save("register_log", map[string]interface{}{
 			"userid":      newUserId,
 			"phone":       phone,
 			"way":         "phone",
-			"system":      "pc",
 			"source":      "openpower",
 			"create_time": date.NowFormat(date.Date_Full_Layout),
 		})