自定义时间

test/openPower.go

@@ -84,7 +84,7 @@ func main() {
 			MaxIdleConns: 2,
 		}
 	} else {
-		etcdAddress = []string{"127.0.0.1:2379"}
+		etcdAddress = []string{"192.168.3.206:2379"}
 		BaseService = &ml.Mysql{
 			Address:      "192.168.3.14:4000",
 			UserName:     "root",
@@ -364,6 +364,7 @@ func (y *Yxy) isOK(phone string, user map[string]interface{}) (bool, bool, *[]ma
 // 生成医械通订单
 func (y *Yxy) createYxtOrder(phone string, user map[string]interface{}, orderVip bool, vipRs, bigMemberRs *[]map[string]interface{}) {
 	var insertOrder map[string]interface{}
+	filterMap := map[string]interface{}{}
 	// 超级订阅
 	if orderVip {
 		insertOrder = (*vipRs)[0]
@@ -371,14 +372,13 @@ func (y *Yxy) createYxtOrder(phone string, user map[string]interface{}, orderVip
 		orderMoney := Float64All(insertOrder["order_money"])
 		endTime := Int64All(user["l_vip_endtime"])
 		var money int
+		filterData := (*vipRs)[0]["filter"]
+		err := json.Unmarshal([]byte(filterData.(string)), &filterMap)
+		if err != nil {
+			log.Println("反序列化失败", err)
+			return
+		}
 		if IntAll(insertOrder["is_backstage_order"]) == 1 {
-			filterData := (*vipRs)[0]["filter"]
-			filterMap := map[string]interface{}{}
-			err := json.Unmarshal([]byte(filterData.(string)), &filterMap)
-			if err != nil {
-				log.Println("反序列化失败", err)
-				return
-			}
 			cycle := Float64All(filterMap["cyclecount"])
 			cycleUnit := Float64All(filterMap["cycleunit"])
 			money = y.getPriceBack(orderMoney, time.Unix(endTime, 0), cycle, cycleUnit)
@@ -392,7 +392,6 @@ func (y *Yxy) createYxtOrder(phone string, user map[string]interface{}, orderVip
 		// 大会员
 		endTime := Int64All(user["i_member_endtime"])
 		filterData := (*bigMemberRs)[0]["filter"]
-		filterMap := map[string]interface{}{}
 		err := json.Unmarshal([]byte(filterData.(string)), &filterMap)
 		if err != nil {
 			log.Println("反序列化失败", err)
@@ -400,13 +399,15 @@ func (y *Yxy) createYxtOrder(phone string, user map[string]interface{}, orderVip
 		}
 		filterMap["area"] = "-"
 		insertOrder = (*bigMemberRs)[0]
-		filter, _ := json.Marshal(filterMap)
-		insertOrder["filter"] = string(filter)
 		insertOrder["order_money"] = 0
 		insertOrder["original_price"] = 0
 		insertOrder["vip_endtime"] = time.Unix(endTime, 0).Format(date.Date_Full_Layout)
 	}
+	filterMap["source"] = "qmx" // 后台订单
 	// 生订单信息
+	filter, _ := json.Marshal(filterMap)
+	insertOrder["filter"] = string(filter)
+	insertOrder["is_backstage_order"] = 1 // 后台创建
 	insertOrder["product_type"] = "医械通"
 	insertOrder["order_code"] = fmt.Sprintf("%s%s", time.Now().Format("150405"), GetRandom(6))
 	insertOrder["prepay_id"] = ""