/*************************************************** ** @Desc : This file for 批量提现 ** @Time : 19.12.6 17:07 ** @Author : Joker ** @File : multi_withdraw ** @Last Modified by : Joker ** @Last Modified time: 19.12.6 17:07 ** @Software: GoLand ****************************************************/ package controllers import ( "dongfeng-pay/jhagent/sys/enum" "dongfeng-pay/jhagent/utils" "dongfeng-pay/service/common" "dongfeng-pay/service/models" "fmt" "github.com/rs/xid" "github.com/tealeg/xlsx" "path" "regexp" "strconv" "strings" "time" ) type MultiWithdraw struct { KeepSession } // @router /multi_withdraw/show_multi_ui func (c *MultiWithdraw) ShowMultiWithdrawUI() { us := c.GetSession(enum.UserSession) u := us.(models.AgentInfo) ranMd5 := encrypt.EncodeMd5([]byte(pubMethod.RandomString(46))) c.Ctx.SetCookie(enum.UserCookie, ranMd5, enum.CookieExpireTime) c.Ctx.SetSecureCookie(ranMd5, enum.UserCookie, ranMd5, enum.CookieExpireTime) c.SetSession(enum.UserCookie, ranMd5) c.Data["userName"] = u.AgentName c.TplName = "withdraw/multi_withdraw.html" } // 申请批量提现 // @router /multi_withdraw/launch_multi_withdraw/?:params [post] func (c *Withdraw) LaunchMultiWithdraw() { mobileCode := strings.TrimSpace(c.GetString("mobileCode")) file, header, err := c.GetFile("file") us := c.GetSession(enum.UserSession) u := us.(models.AgentInfo) var ( msg = enum.FailedString flag = enum.FailedFlag b bool url string ) fileName := header.Filename defer file.Close() split := strings.Split(fileName, ".") if len(split) < 2 { msg = "请选择批量文件!" goto stopRun } if strings.Compare(strings.ToLower(split[1]), "xls") != 0 && strings.Compare(strings.ToLower(split[1]), "xlsx") != 0 { msg = "仅支持“xls”、“xlsx”格式文件!" goto stopRun } if err != nil { msg = "请上传批量文件! " + err.Error() goto stopRun } if u.PayPassword == "" { msg = "请设置支付密码!" goto stopRun } if strings.Compare(strings.ToUpper(encrypt.EncodeMd5([]byte(mobileCode))), u.PayPassword) != 0 { msg = "支付密码输入错误!" goto stopRun } u = models.GetAgentInfoByAgentUid(u.AgentUid) if strings.Compare(enum.ACTIVE, u.Status) != 0 { msg = "商户状态异常,请联系管理人员!" goto stopRun } b, msg = handleFileContent(split[0], u, c) if b { flag = enum.SuccessFlag url = "/withdraw/show_list_ui" } stopRun: c.Data["json"] = pubMethod.JsonFormat(flag, "", msg, url) c.ServeJSON() c.StopRun() } func handleFileContent(name string, u models.AgentInfo, c *Withdraw) (bool, string) { // 重命名文件 fileName := name + " - " + pubMethod.GetNowTimeV2() + pubMethod.RandomString(4) + ".xlsx" // 保存文件 _ = c.SaveToFile("file", path.Join(enum.ExcelPath, fileName)) // 读取文件内容 xlFile, err := xlsx.OpenFile(enum.ExcelPath + fileName) if err != nil { msg := "文件内容错误:" + err.Error() utils.LogInfo(msg) return false, msg } // 只读取文档中第一个工作表,忽略其他工作表 sheet := xlFile.Sheets[0] line, err := sheet.Row(0).Cells[1].Int() if err != nil { msg := "请输入正确的总笔数:" + err.Error() utils.LogInfo(msg) return false, msg } if line <= 0 { msg := "请输入正确的总笔数!" return false, msg } if line > 300 { line = 300 } ac := models.GetAccountByUid(u.AgentUid) if strings.Compare(enum.ACTIVE, ac.Status) != 0 { msg := "账户状态异常,请联系管理人员!" return false, msg } // 后台处理文件,不让用户等待 go func() { for k, row := range sheet.Rows { if k == 0 || k == 1 { continue } // 数据行数不得超过指定行数 if k == line+2 || k == 301 { break } // 出现空行,则忽略后面记录 if row.Cells[0].String() == "" || row.Cells[4].String() == "" { break } bankAccountType := row.Cells[3].String() ac := models.GetAccountByUid(u.AgentUid) b, msg, code := verifyFileContent(row.Cells[0].String(), row.Cells[1].String(), row.Cells[2].String(), bankAccountType, row.Cells[4].String(), ac) if !b { utils.LogInfo(fmt.Sprintf("用户:%s 批量代付中,第 %d 行记录出现错误:%s", u.AgentName, k+1, msg)) // 账户可用余额不足,终止读取记录 if code == 5009 { break } continue } if strings.Compare("对公", bankAccountType) == 0 { bankAccountType = enum.PublicAccount } else { bankAccountType = enum.PrivateDebitAccount } money, _ := strconv.ParseFloat(row.Cells[4].String(), 10) payFor := models.PayforInfo{ PayforUid: "pppp" + xid.New().String(), MerchantUid: u.AgentUid, MerchantName: u.AgentName, PhoneNo: u.AgentPhone, MerchantOrderId: xid.New().String(), BankOrderId: "4444" + xid.New().String(), PayforFee: common.PAYFOR_FEE, Type: common.SELF_MERCHANT, PayforAmount: money, PayforTotalAmount: money + common.PAYFOR_FEE, BankCode: "C", BankName: row.Cells[2].String(), IsSend: common.NO, BankAccountName: row.Cells[0].String(), BankAccountNo: row.Cells[1].String(), BankAccountType: bankAccountType, BankAccountAddress: row.Cells[2].String(), Status: common.PAYFOR_COMFRIM, CreateTime: pubMethod.GetNowTime(), UpdateTime: pubMethod.GetNowTime(), } models.InsertPayfor(payFor) time.Sleep(500 * time.Millisecond) } }() return true, "提交成功,等待审核中,请在结算信息中查询状态!" } // 验证文件内容是否规范 func verifyFileContent(accountName, cardNo, bankAccountAddress, bankAccountType, amount string, ac models.AccountInfo) (bool, string, int) { if accountName == "" || cardNo == "" { msg := "账户名或卡号不能为空!" return false, msg, 5001 } // 账户类型 if strings.Compare("对公", bankAccountType) == 0 { if bankAccountAddress == "" { msg := "收款方开户机构名称不能为空!" return false, msg, 5002 } } if amount == "" { msg := "金额不能为空!" return false, msg, 5003 } matched, _ := regexp.MatchString(enum.MoneyReg, amount) if !matched { msg := "请输入正确的金额!" return false, msg, 5004 } f, err := strconv.ParseFloat(amount, 10) if err != nil { msg := "请输入正确的金额! " + err.Error() return false, msg, 5007 } if f > enum.WithdrawalMaxAmount || f < enum.WithdrawalMinAmount || f+enum.SettlementFee > ac.WaitAmount { msg := fmt.Sprintf("单笔提现金额超出限制,提现金额:%f,账户可结算余额:%f,提现最小额:%d,最大额:%d,手续费:%d", f, ac.WaitAmount, enum.WithdrawalMinAmount, enum.WithdrawalMaxAmount, enum.SettlementFee) return false, msg, 5008 } if f+enum.SettlementFee > ac.Balance || ac.Balance <= 0 { msg := fmt.Sprintf("账户金额不足,提现金额:%f,账户余额:%f,手续费:%d", f, ac.Balance, enum.SettlementFee) return false, msg, 5009 } return true, "", 5000 }