123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771 |
- package yb
- import (
- "encoding/json"
- "fmt"
- "github.com/rdlucklib/rdluck_tools/paging"
- "github.com/tealeg/xlsx"
- "hongze/hz_crm_api/models"
- "hongze/hz_crm_api/models/yb"
- "hongze/hz_crm_api/models/yb/request"
- ybResp "hongze/hz_crm_api/models/yb/response"
- "hongze/hz_crm_api/utils"
- "os"
- "path/filepath"
- "time"
- )
- func (this *ActivityController) ComeInList() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- keyword := this.GetString("Keyword")
- startDate := this.GetString("StartDate")
- endDate := this.GetString("EndDate")
- pageSize, _ := this.GetInt("PageSize")
- currentIndex, _ := this.GetInt("CurrentIndex")
- var startSize int
- if pageSize <= 0 {
- pageSize = utils.PageSize20
- }
- if currentIndex <= 0 {
- currentIndex = 1
- }
- startSize = paging.StartIndex(currentIndex, pageSize)
- condition := ""
- pars := make([]interface{}, 0)
-
- if keyword != "" {
- condition += ` AND a.title LIKE '%` + keyword + `%' `
- }
-
-
-
-
-
-
- if startDate != "" && endDate != "" {
- condition += ` AND a.start_time >= ? and a.start_time <= ?`
- pars = append(pars, startDate+" 00:00:00", endDate+" 23:59:59")
- }
-
- total, list, err := yb.GetComeinList(condition, pars, startSize, pageSize)
- if err != nil {
- br.Msg = "获取活动列表失败!"
- br.ErrMsg = "获取活动列表失败,Err:" + err.Error()
- return
- }
-
-
-
-
-
-
-
- page := paging.GetPaging(currentIndex, pageSize, total)
- resp := ybResp.ComeinListResp{
- List: list,
- Paging: page,
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = resp
- }
- func (this *ActivityController) ComeInUserList() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- dataType, _ := this.GetInt("DataType", 0)
- comeinEventId, _ := this.GetInt("ComeinEventId", 0)
- if comeinEventId <= 0 {
- br.Msg = "请选择活动"
- br.ErrMsg = "请选择活动"
- return
- }
- if dataType <= 0 {
- br.Msg = "请选择类型"
- br.ErrMsg = "请选择类型"
- return
- }
- pageSize, _ := this.GetInt("PageSize")
- currentIndex, _ := this.GetInt("CurrentIndex")
- var startSize int
- if pageSize <= 0 {
- pageSize = utils.PageSize20
- }
- if currentIndex <= 0 {
- currentIndex = 1
- }
- startSize = paging.StartIndex(currentIndex, pageSize)
- condition := ""
- pars := make([]interface{}, 0)
- condition += ` AND a.comein_event_id = ? `
- pars = append(pars, comeinEventId)
- switch dataType {
- case 1:
- condition += ` AND a.product_id = ? `
- pars = append(pars, 1)
- case 2:
- condition += ` AND a.product_id = ? `
- pars = append(pars, 2)
- case 3:
- condition += ` AND a.product_id = ? `
- pars = append(pars, 0)
- }
-
- total, list, err := yb.GetComeinUserList(condition, pars, startSize, pageSize)
- if err != nil {
- br.Msg = "获取活动列表失败!"
- br.ErrMsg = "获取活动列表失败,Err:" + err.Error()
- return
- }
- page := paging.GetPaging(currentIndex, pageSize, total)
- resp := ybResp.ComeinUserListResp{
- List: list,
- Paging: page,
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = resp
- }
- func (this *ActivityController) ExportComeInUserList() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- comeinEventId, _ := this.GetInt("ComeinEventId", 0)
- if comeinEventId <= 0 {
- br.Msg = "请选择活动"
- br.ErrMsg = "请选择活动"
- return
- }
- dir, _ := os.Executable()
- exPath := filepath.Dir(dir)
- downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
- xlsxFile := xlsx.NewFile()
- for i := 1; i <= 3; i++ {
- var sheetName string
- switch i {
- case 1:
- sheetName = "ficc联系人"
- case 2:
- sheetName = "权益联系人"
- case 3:
- sheetName = "未知联系人"
- }
- sheet, err := xlsxFile.AddSheet(sheetName)
- if err != nil {
- fmt.Println("新增Sheet失败", err.Error())
- br.Msg = "新增Sheet失败"
- br.ErrMsg = "新增Sheet失败," + err.Error()
- br.Ret = 408
- return
- }
- row := sheet.AddRow()
- row.AddCell().SetValue("手机号")
- row.AddCell().SetValue("姓名")
- row.AddCell().SetValue("公司名称")
- if i < 3 {
- row.AddCell().SetValue("客户类型")
- row.AddCell().SetValue("状态")
- row.AddCell().SetValue("销售")
- } else if i == 3 {
- row.AddCell().SetValue("职位")
- }
- row.AddCell().SetValue("首次入会时间")
- row.AddCell().SetValue("最后退出时间")
- row.AddCell().SetValue("参与总时长")
- row.AddCell().SetValue("参会方式")
- row.AddCell().SetValue("参会鉴权")
- row.AddCell().SetValue("参会状态")
-
- condition := ""
- pars := make([]interface{}, 0)
- condition += ` AND a.comein_event_id = ? `
- pars = append(pars, comeinEventId)
- switch i {
- case 1:
- condition += ` AND a.product_id = ? `
- pars = append(pars, 1)
- case 2:
- condition += ` AND a.product_id = ? `
- pars = append(pars, 2)
- case 3:
- condition += ` AND a.product_id = ? `
- pars = append(pars, 0)
- }
- total, list, err := yb.GetComeinUserListForExport(condition, pars)
- if err != nil {
- br.Msg = "获取活动列表失败!"
- br.ErrMsg = "获取活动列表失败,Err:" + err.Error()
- return
- }
- if len(list) <= 0 {
- for n := 0; n < total; n++ {
- rowIndex := n + 1
- row := sheet.Row(rowIndex)
- row.AddCell()
- row.AddCell()
- row.AddCell()
- }
- } else {
- for j, item := range list {
- row := sheet.Row(j + 1)
- row.AddCell().SetValue(item.Mobile)
- row.AddCell().SetValue(item.Name)
- row.AddCell().SetValue(item.CompanyName)
- if i < 3 {
- productName := ""
- switch item.ProductId {
- case 1:
- productName = "FICC"
- case 2:
- productName = "权益"
- }
- row.AddCell().SetValue(productName)
- row.AddCell().SetValue(item.Status)
- row.AddCell().SetValue(item.SellerName)
- } else if i == 3 {
- row.AddCell().SetValue(item.Occupation)
- }
- row.AddCell().SetValue(item.FirstWatchTime)
- row.AddCell().SetValue(item.LastWatchTime)
- min := item.JoinTime / 60
- sec := item.JoinTime % 60
- stringTime := fmt.Sprintf("%v分%v秒", min, sec)
- row.AddCell().SetValue(stringTime)
- joinType := ""
- switch item.JoinType {
- case 1:
- joinType = "网络"
- case 2:
- joinType = "电话"
- }
- row.AddCell().SetValue(joinType)
- row.AddCell().SetValue(item.AuthInfo)
- dataType := ""
- switch item.DataType {
- case 1:
- dataType = "直播"
- case 2:
- dataType = "回放"
- }
- row.AddCell().SetValue(dataType)
- }
- }
- }
- err := xlsxFile.Save(downLoadnFilePath)
- if err != nil {
- br.Msg = "保存文件失败"
- br.ErrMsg = "保存文件失败"
- return
- }
- fileName := `进门到会详情`
- fileName += time.Now().Format("06.01.02") + `.xlsx`
- this.Ctx.Output.Download(downLoadnFilePath, fileName)
- defer func() {
- os.Remove(downLoadnFilePath)
- }()
- br.Ret = 200
- br.Success = true
- br.Msg = "success"
- }
- func (this *ActivityController) ComeInShare2Seller() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- var req request.ComeInShare2SellerReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ComeinEventId <= 0 {
- br.Msg = "参数异常!"
- return
- }
- if req.SellerId <= 0 {
- br.Msg = "请选择销售"
- return
- }
- item, e := yb.GetComeInEventById(req.ComeinEventId)
- if e != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "获取进门到会信息失败, Err: " + e.Error()
- return
- }
- item.ShareSellerId = req.SellerId
- if e = item.Update([]string{"ShareSellerId"}); e != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "更新进门到会销售失败, Err: " + e.Error()
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- }
|