wip:pdf导出流量包到期

service/balanceService.go

@@ -505,37 +505,48 @@ func (service *BalanceService) ExpireHandle() {
 	endTime := time.Now().AddDate(0, 0, -1).Format("2006-01-02")
 	expireList := []map[string]interface{}{}
 	//endTime = "2023-10-21"
-	orm.Table(AccountResources).Where("resourceType=? and  endTime=? and  number >0  ", "附件下载包", endTime).Find(&expireList)
+	orm.Table(AccountResources).Where("(resourceType=? or name=? ) and endTime=? and  number >0  ", "附件下载包", "pdf下载包", endTime).Find(&expireList)
 	for _, m := range expireList {
 		//流水生成
-		sourceType := gconv.Int64(m["sourceType"])
-		accountId := gconv.String(m["accountId"])
-		number := gconv.Int64(m["number"])
-		resourcesId := gconv.Int64(m["id"])
-		userType := int64(5)
-		remarks := ""
-		remarksMap := map[string]interface{}{}
-		switch sourceType {
-		case 1:
-			remarksMap["describe"] = "购买附件下载包权益未使用失效"
-		case 2:
-			remarksMap["describe"] = "剑鱼币兑换权益未使用失效"
-		case 3:
-			remarksMap["describe"] = fmt.Sprintf("超级订阅%s附件下载权益未使用失效。", time.Now().Format("2006年01月"))
-		}
-		jsonData, err := json.Marshal(remarksMap)
-		if err != nil {
-			fmt.Println(err)
-		}
-		remarks = string(jsonData)
+		var (
+			sourceType   = gconv.Int64(m["sourceType"])
+			resourcesId  = gconv.Int64(m["id"])
+			resourceType = gconv.String(m["resourceType"])
+			name         = gconv.String(m["name"])
+		)
+
+		remarks := func() string {
+			remarksMap := map[string]interface{}{}
+
+			switch resourceType {
+			case "附件下载包":
+				switch sourceType {
+				case 1:
+					remarksMap["describe"] = "购买附件下载包权益未使用失效"
+				case 2:
+					remarksMap["describe"] = "剑鱼币兑换权益未使用失效"
+				case 3:
+					remarksMap["describe"] = fmt.Sprintf("超级订阅%s附件下载权益未使用失效。", time.Now().Format("2006年01月"))
+				}
+			default:
+				remarksMap["describe"] = "未使用权益到期失效"
+			}
+
+			jsonData, err := json.Marshal(remarksMap)
+			if err != nil {
+				fmt.Println(err)
+			}
+			return string(jsonData)
+		}()
+
 		detailed := entity.Detailed{
-			AccountId:    accountId,
-			ResourceType: "附件下载包",
-			Number:       number,
-			Name:         "附件下载包",
+			AccountId:    gconv.String(m["accountId"]),
+			Name:         name,
+			ResourceType: resourceType,
+			Number:       gconv.Int64(m["number"]),
 			CreateTime:   time.Now().Local(),
+			UserType:     5, //作废标识
 			Remarks:      remarks,
-			UserType:     userType,
 		}
 		orm.Table(ConsumeRecord).Insert(&detailed)
 		//jie结存清空