company.go 55 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354
  1. package company
  2. import (
  3. "fmt"
  4. "github.com/beego/beego/v2/client/orm"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "hongze/hz_eta_api/utils"
  7. "time"
  8. )
  9. type Company struct {
  10. CompanyId int `orm:"column(company_id);pk"`
  11. CompanyName string `description:"客户名称"`
  12. CompanyType int `orm:"column(type)"`
  13. CreditCode string `description:"社会统一信用码"`
  14. CompanyCode string `description:"客户编码"`
  15. Sort int `description:"优先级"`
  16. IsFeeCustomer int `description:"是否付费用户"`
  17. Country string `description:"国家编码"`
  18. Province string `description:"省"`
  19. City string `description:"市"`
  20. Address string `description:"详细地址"`
  21. Enabled int `description:"用户状态"`
  22. CreatedTime time.Time `description:"创建时间"`
  23. LastUpdatedTime time.Time `description:"最后一次阅读时间"`
  24. Seller string `description:"销售员"`
  25. SellsId int `description:"销售员id"`
  26. ShareSeller string `description:"共享销售员"`
  27. ShareSellerId int `description:"共享销售员id"`
  28. CompanyBelong string `description:"客户所属,ficc:ficc客户,public_offering:公募客户,partner:合作伙伴"`
  29. StartDate string `description:"合同开始日期"`
  30. EndDate string `description:"合同结束日期"`
  31. LastType int `description:"原客户标签"`
  32. IsVip int `description:"0:普通用户,1:大客户"`
  33. IsShare int `description:"0:非共享用户,1:共享客户"`
  34. FirstStartDate string `description:"首次设置为试用客户开始时间"`
  35. FirstEndDate string `description:"首次设置为试用客户结束时间"`
  36. DateType int `description:"设置流失类型,1:1个月,2:2个月,3:3个月"`
  37. Remark string `description:"备注信息"`
  38. RegionType string `description:"地区类型,国内,国外"`
  39. OpenCompanyCode string `description:"开放给第三方的客户编码,不让第三方定位我们的客户信息"`
  40. }
  41. // 新增客户
  42. func AddCompany(item *Company) (lastId int64, err error) {
  43. o := orm.NewOrm()
  44. lastId, err = o.Insert(item)
  45. return
  46. }
  47. // 根据企业id获取企业信息
  48. func GetCompanyById(companyId int) (items *Company, err error) {
  49. o := orm.NewOrm()
  50. sql := ` SELECT * FROM company where company_id= ? `
  51. err = o.Raw(sql, companyId).QueryRow(&items)
  52. return
  53. }
  54. type CompanySearchItem struct {
  55. CompanyId int `orm:"column(company_id);pk"`
  56. CompanyName string `description:"客户名称"`
  57. CreditCode string `description:"社会统一信用码"`
  58. CompanyCode string `description:"客户编码"`
  59. StartDate string `description:"合同开始日期"`
  60. EndDate string `description:"合同结束日期"`
  61. LoseReason string `description:"流失原因"`
  62. LossTime string `description:"流失时间"`
  63. Status string `description:"客户状态:'试用','永续','冻结','流失','正式' "`
  64. CompanyType string `description:"客户类型:ficc/权益"`
  65. ApproveStatus string `description:"审批状态:'审批中','通过','驳回' 审批状态为空时,表示没有审批申请"`
  66. SellerName string `description:"销售:吉根龙/颖丹"`
  67. SellerIds string `description:"销售ID集合,包含ficc和权益的销售id" json:"-"`
  68. Duration string `description:"时长"`
  69. FreezeTime string `description:"冻结时间"`
  70. GroupId int `description:"分组id"`
  71. GroupIds string `json:"-" description:"分组id集合,包含ficc和权益的小组id"`
  72. DepartmentId int `description:"部门id"`
  73. IsSuspend int `description:"是否暂停:1:暂停,0:启用 "`
  74. ProductId int `description:"产品id"`
  75. ProductIds string `json:"-";description:"分组id集合,包含ficc和权益的小组id"`
  76. IsMoveShow int `description:"按钮显示控制:1:显示,移动按钮,0:不显示移动按钮"`
  77. SellerId int `description:"销售id"`
  78. BtnItem *ButtonPermission
  79. FormalTime string `description:"转正时间"`
  80. FreezeStartDate string `description:"冻结开始日期"`
  81. FreezeEndDate string `description:"冻结结束日期"`
  82. RegionType string `description:"地区类型,国内,国外"`
  83. ShareSeller string `description:"共享销售员"`
  84. ShareSellerId int `description:"共享销售员id"`
  85. IsShare int `description:"0:非共享用户,1:共享客户"`
  86. }
  87. type CompanySearchListResp struct {
  88. Paging *paging.PagingItem
  89. List []*CompanySearchItem
  90. }
  91. func GetCompanySearchList(condition string, pars []interface{}, limitParam ...int) (items []*CompanySearchItem, err error) {
  92. o := orm.NewOrm()
  93. sql := `SELECT DISTINCT a.company_id,a.company_name,a.credit_code,a.company_code,a.region_type,a.share_seller_id,a.share_seller,a.is_share,
  94. GROUP_CONCAT(b.status ORDER BY b.product_id ASC SEPARATOR '/') AS status,
  95. GROUP_CONCAT(DISTINCT b.seller_name ORDER BY b.product_id ASC SEPARATOR '/' ) AS seller_name,
  96. GROUP_CONCAT(DISTINCT b.seller_id ORDER BY b.product_id ASC SEPARATOR '/') AS seller_ids,
  97. GROUP_CONCAT(DISTINCT b.group_id ORDER BY b.product_id ASC SEPARATOR '/' ) AS group_ids,
  98. GROUP_CONCAT(DISTINCT b.product_id ORDER BY b.product_id ASC SEPARATOR '/' ) AS product_ids,
  99. b.freeze_time,b.loss_time,a.lose_reason,b.is_suspend,b.seller_id,b.product_id,b.group_id,b.formal_time,b.freeze_time,
  100. GROUP_CONCAT(b.start_date ORDER BY b.product_id ASC SEPARATOR '/') AS start_date,
  101. GROUP_CONCAT(b.end_date ORDER BY b.product_id ASC SEPARATOR '/') AS end_date,
  102. GROUP_CONCAT(DISTINCT b.company_type ORDER BY b.product_id ASC SEPARATOR '/') AS company_type,
  103. GROUP_CONCAT(DISTINCT b.approve_status ORDER BY b.product_id ASC SEPARATOR '/') AS approve_status,
  104. GROUP_CONCAT(DISTINCT b.freeze_start_date ORDER BY b.product_id ASC SEPARATOR '/') AS freeze_start_date,
  105. GROUP_CONCAT(DISTINCT b.freeze_end_date ORDER BY b.product_id ASC SEPARATOR '/') AS freeze_end_date
  106. FROM company AS a
  107. INNER JOIN company_product AS b ON a.company_id=b.company_id
  108. WHERE a.enabled=1 `
  109. if condition != "" {
  110. sql += condition
  111. }
  112. sql += ` GROUP BY a.company_id ORDER BY a.last_updated_time DESC LIMIT ?,? `
  113. _, err = o.Raw(sql, pars, limitParam).QueryRows(&items)
  114. return
  115. }
  116. func GetCompanySearchCount(condition string, pars []interface{}) (count int, err error) {
  117. o := orm.NewOrm()
  118. sql := `SELECT COUNT(1) AS count
  119. FROM company AS a
  120. INNER JOIN company_product AS b ON a.company_id=b.company_id
  121. WHERE a.enabled=1 `
  122. if condition != "" {
  123. sql += condition
  124. }
  125. sql += ` GROUP BY a.company_id `
  126. qsql := `SELECT COUNT(1) AS count FROM (` + sql + `) AS t`
  127. err = o.Raw(qsql, pars).QueryRow(&count)
  128. return
  129. }
  130. type CompanyItem struct {
  131. CompanyId int `orm:"column(company_id);pk"`
  132. CompanyName string `description:"客户名称"`
  133. CreditCode string `description:"社会统一信用码"`
  134. CompanyCode string `description:"客户编码"`
  135. StartDate string `description:"合同开始日期"`
  136. EndDate string `description:"合同结束日期"`
  137. LoseReason string `description:"流失原因"`
  138. RenewalReason string `description:"续约说明"`
  139. FreezeReason string `description:"冻结理由"`
  140. LossTime string `description:"流失时间"`
  141. Status string `description:"客户状态:'试用','永续','冻结','流失','正式' "`
  142. CompanyType string `description:"客户类型:ficc/权益"`
  143. ApproveStatus string `description:"审批状态:'待审批','已审批','驳回' 审批状态为空时,表示没有审批申请"`
  144. SellerName string `description:"销售:吉根龙/颖丹"`
  145. SellerId int `description:"销售ID"`
  146. SellerIds string `description:"销售ID集合,包含ficc和权益的销售id"`
  147. ShareSeller string `description:"共享销售员"`
  148. ShareSellerId int `description:"共享销售员id"`
  149. PackageTypes string `description:"套餐类型集合,包含ficc和权益的套餐类型" json:"-"`
  150. FiccPackageType int `description:"ficc的套餐类型"`
  151. ExpireDay string `description:"到期天数"`
  152. FreezeTime string `description:"冻结时间"`
  153. GroupId int `description:"分组id"`
  154. GroupIds string `description:"分组id集合,包含ficc和权益的小组id" json:"-"`
  155. DepartmentId int `description:"部门id"`
  156. IndustryName string `description:"所属行业"`
  157. IsSuspend int `description:"是否暂停:1:暂停,0:启用 "`
  158. CreatedTime string `description:"创建时间"`
  159. Source string `description:"客户来源"`
  160. Province string `description:"省"`
  161. City string `description:"市"`
  162. Address string `description:"详细地址"`
  163. Reasons string `description:"新增理由"`
  164. FreezeStartDate string `description:"冻结开始日期"`
  165. FreezeEndDate string `description:"冻结结束日期"`
  166. FreezeExpireDays int `description:"冻结到期天数"`
  167. BtnItem *ButtonPermission
  168. ProductId int `json:"-"`
  169. ProductIds string `description:"产品id集合,包含ficc和权益的产品id" json:"-"`
  170. FormalTime string `description:"转正时间"`
  171. IsShared bool `description:"是否共享客户"`
  172. RegionType string `description:"区域:国内,海外"`
  173. FiccLastViewTime string `description:"ficc最近一次阅读时间"`
  174. RaiLastViewTime string `description:"权益最近一次阅读时间"`
  175. ViewTotals string `description:"阅读次数集合,包含ficc和权益的阅读次数" json:"-"`
  176. LastViewTimes string `description:"最近一次阅读时间集合,包含ficc和权益的最近一次阅读时间" json:"-"`
  177. FiccView int `description:"Ficc报告阅读次数" json:"-"`
  178. RaiView int `description:"权益报告阅读次数" json:"-"`
  179. RoadShowTotal int `description:"累计路演次数"`
  180. TodoStatuss string `description:"任务状态"`
  181. TryStageStr string `description:"试用客户子标签"`
  182. TryStageSlice []*TryStageSliceItem `description:"试用状态相关"`
  183. AllViewTotal int `description:"总阅读数"`
  184. Deadline string `description:"未完成的todo任务的截止日期,截止目前还剩余的天数"`
  185. TodoEndTimeStr string `description:"未完成的todo任务的截止日期拼接格式"`
  186. TodoEndTime time.Time `description:"未完成的todo任务的截止日期"`
  187. TryOutDayTotals string `description:"试用天数集合,包含ficc和权益的试用天数" json:"-"`
  188. FiccTryOutDay int `description:"Ficc试用天数" json:"-"`
  189. RaiTryOutDay int `description:"权益试用天数" json:"-"`
  190. WeekViewActive int `description:"周阅读活跃: 0-七日内无阅读; 1-活跃"`
  191. IsShare int `description:"0:非共享用户,1:共享客户"`
  192. LastServiceTime string `description:"最后服务时间"`
  193. ServiceTimes int `description:"服务次数"`
  194. }
  195. type CompanyListItem struct {
  196. CompanyId int `orm:"column(company_id);pk"`
  197. CompanyName string `description:"客户名称"`
  198. CreditCode string `description:"社会统一信用码"`
  199. CompanyCode string `description:"客户编码"`
  200. StartDate string `description:"合同开始日期"`
  201. EndDate string `description:"合同结束日期"`
  202. LoseReason string `description:"流失原因"`
  203. RenewalReason string `description:"续约说明"`
  204. FreezeReason string `description:"冻结理由"`
  205. LossTime string `description:"流失时间"`
  206. Status string `description:"客户状态:'试用','永续','冻结','流失','正式' "`
  207. CompanyType string `description:"客户类型:ficc/权益"`
  208. ApproveStatus string `description:"审批状态:'待审批','已审批','驳回' 审批状态为空时,表示没有审批申请"`
  209. SellerName string `description:"销售:吉根龙/颖丹"`
  210. SellerId int `description:"销售ID"`
  211. SellerIds string `description:"销售ID集合,包含ficc和权益的销售id"`
  212. FiccPackageType int `description:"ficc的套餐类型"`
  213. ExpireDay string `description:"到期天数"`
  214. FreezeTime string `description:"冻结时间"`
  215. GroupId int `description:"分组id"`
  216. GroupIds string `description:"分组id集合,包含ficc和权益的小组id" json:"-"`
  217. DepartmentId int `description:"部门id"`
  218. IndustryName string `description:"所属行业"`
  219. IsSuspend int `description:"是否暂停:1:暂停,0:启用 "`
  220. CreatedTime string `description:"创建时间"`
  221. Source string `description:"客户来源"`
  222. Province string `description:"省"`
  223. City string `description:"市"`
  224. Address string `description:"详细地址"`
  225. Reasons string `description:"新增理由"`
  226. FreezeStartDate string `description:"冻结开始日期"`
  227. FreezeEndDate string `description:"冻结结束日期"`
  228. FreezeExpireDays int `description:"冻结到期天数"`
  229. BtnItem *ButtonPermission
  230. ProductId int `json:"-"`
  231. FormalTime string `description:"转正时间"`
  232. IsShared bool `description:"是否共享客户"`
  233. RegionType string `description:"区域:国内,海外"`
  234. FiccView int `description:"Ficc报告阅读次数"`
  235. RaiView int `description:"权益报告阅读次数"`
  236. FiccLastViewTime string `description:"ficc最近一次阅读时间"`
  237. RaiLastViewTime string `description:"权益最近一次阅读时间"`
  238. RoadShowTotal int `description:"累计路演次数"`
  239. TodoStatus bool `description:"是否存在进行中任务,true:存在待处理的任务"`
  240. CanConfirm bool `description:"是否允许完成任务,true:允许完成任务"`
  241. HiddenConfirm bool `description:"是否隐藏完成任务按钮,true:隐藏完成任务按钮"`
  242. HiddenCreate bool `description:"是否隐藏新增/编辑按钮,true:隐藏新增/编辑按钮"`
  243. TodoButtonColor string `description:"任务按钮颜色:red,green,gray"`
  244. TryStageSlice []*TryStageSliceItem `description:"试用状态相关"`
  245. AllViewTotal int `description:"总阅读数"`
  246. Deadline string `description:"未完成的todo任务的截止日期,截止目前还剩余的天数"`
  247. FiccTryOutDay int `description:"Ficc总试用天数"`
  248. RaiTryOutDay int `description:"权益总试用天数"`
  249. WeekViewActive int `description:"周阅读活跃: 0-七日内无阅读; 1-活跃"`
  250. IsShare int `description:"0:非共享用户,1:共享客户"`
  251. ShareSeller string `description:"共享销售员"`
  252. ShareSellerId int `description:"共享销售员id"`
  253. LastServiceTime string `description:"最后服务时间"`
  254. ServiceTimes int `description:"服务次数"`
  255. }
  256. type TryStageSliceItem struct {
  257. ProductId int `description:"产品ID"`
  258. TryStage int `description:"试用客户子标签1未分类、2 推进、3 跟踪、4 预备"`
  259. HasPermission bool `description:"是否有权限设置标签"`
  260. }
  261. type CompanyListResp struct {
  262. Paging *paging.PagingItem
  263. List []*CompanyListItem
  264. StatusCount []*CompanyStatus
  265. TryStageCount []*CompanyTryStageCount
  266. AddCompanyBtn bool
  267. }
  268. func GetCompanyListCount(condition string, pars []interface{}) (count int, err error) {
  269. o := orm.NewOrm()
  270. sql := `SELECT COUNT(DISTINCT b.company_id) AS count
  271. FROM company AS a
  272. INNER JOIN company_product AS b ON a.company_id=b.company_id
  273. WHERE a.enabled=1 `
  274. if condition != "" {
  275. sql += condition
  276. }
  277. err = o.Raw(sql, pars).QueryRow(&count)
  278. return
  279. }
  280. func GetCompanyList(condition, status, sortStr string, pars []interface{}, startSize, pageSize int) (items []*CompanyItem, err error) {
  281. o := orm.NewOrm()
  282. // 七天前的时间-用于查询周阅读活跃, 此处的需求是
  283. // FICC客户、共享客户: 以FICC最后一次阅读时间作为参考, 七日内有阅读量则为活跃
  284. // 权益客户: 以权益最后一次阅读时间作为参考
  285. t := time.Now().Local().AddDate(0, 0, -7).Format(utils.FormatDate)
  286. sql := `SELECT a.company_id,a.company_name,a.credit_code,a.company_code,a.created_time,a.province,a.city,a.address,a.region_type,b.group_id,b.road_show_total,a.is_share,
  287. CASE
  288. WHEN GROUP_CONCAT(b.status) LIKE "%永续%" THEN 1
  289. WHEN GROUP_CONCAT(b.status) LIKE "%正式%" THEN 2
  290. WHEN GROUP_CONCAT(b.status) LIKE "%试用%" THEN 3
  291. WHEN GROUP_CONCAT(b.status) LIKE "%冻结%" THEN 4
  292. WHEN GROUP_CONCAT(b.status) LIKE "%流失%" THEN 5
  293. ELSE 10 END
  294. as sort_status,
  295. CASE
  296. WHEN GROUP_CONCAT(b.try_stage) LIKE "%2%" THEN 1
  297. WHEN GROUP_CONCAT(b.try_stage) LIKE "%3%" THEN 2
  298. WHEN GROUP_CONCAT(b.try_stage) LIKE "%4%" THEN 3
  299. WHEN GROUP_CONCAT(b.try_stage) LIKE "%1%" THEN 4
  300. ELSE 10 END
  301. as sort_try_stage,
  302. CASE
  303. WHEN GROUP_CONCAT(b.todo_status) LIKE "%未完成%" AND GROUP_CONCAT(b.todo_end_time) is not null THEN GROUP_CONCAT(b.todo_end_time)
  304. ELSE "9999-01-01" END
  305. as sort_todo_end_time,
  306. GROUP_CONCAT(b.status ORDER BY b.product_id ASC SEPARATOR '/') AS status,
  307. GROUP_CONCAT(DISTINCT b.seller_name ORDER BY b.product_id ASC SEPARATOR '/') AS seller_name,
  308. GROUP_CONCAT(DISTINCT b.seller_id ORDER BY b.product_id ASC SEPARATOR '/') AS seller_ids,
  309. GROUP_CONCAT(DISTINCT b.package_type ORDER BY b.product_id ASC SEPARATOR '/') AS package_types,
  310. GROUP_CONCAT(DISTINCT b.industry_name ORDER BY b.product_id ASC SEPARATOR '/') AS industry_name,
  311. GROUP_CONCAT(DISTINCT b.product_name ORDER BY b.product_id ASC SEPARATOR '/') AS company_type,
  312. GROUP_CONCAT(DISTINCT b.product_id ORDER BY b.product_id ASC SEPARATOR '/') AS product_ids,
  313. GROUP_CONCAT(DISTINCT b.view_total ORDER BY b.product_id ASC SEPARATOR '/') AS view_totals,
  314. GROUP_CONCAT(DISTINCT b.last_view_time ORDER BY b.product_id ASC SEPARATOR '/') AS last_view_times,
  315. GROUP_CONCAT(b.start_date ORDER BY b.product_id ASC SEPARATOR '/') AS start_date,
  316. GROUP_CONCAT(b.end_date ORDER BY b.product_id ASC SEPARATOR '/') AS end_date,
  317. GROUP_CONCAT(DISTINCT b.loss_time ORDER BY b.product_id ASC SEPARATOR '/') AS loss_time,
  318. GROUP_CONCAT(DISTINCT b.lose_reason ORDER BY b.product_id ASC SEPARATOR '/') AS lose_reason,
  319. GROUP_CONCAT(DISTINCT b.source ORDER BY b.product_id ASC SEPARATOR '/') AS source,
  320. GROUP_CONCAT(DISTINCT b.reasons ORDER BY b.product_id ASC SEPARATOR '/') AS reasons,
  321. GROUP_CONCAT(DISTINCT b.approve_status ORDER BY b.product_id ASC SEPARATOR '/') AS approve_status,
  322. GROUP_CONCAT(b.try_stage ORDER BY b.product_id ASC SEPARATOR '/') AS try_stage_str,
  323. GROUP_CONCAT(DISTINCT b.group_id ORDER BY b.product_id ASC SEPARATOR '/') AS group_ids,
  324. GROUP_CONCAT(DISTINCT b.todo_status ORDER BY b.product_id ASC SEPARATOR '/') AS todo_statuss,
  325. GROUP_CONCAT(DISTINCT b.todo_end_time ORDER BY b.product_id ASC SEPARATOR '/') AS todo_end_time_str,
  326. GROUP_CONCAT(DISTINCT b.try_out_day_total ORDER BY b.product_id ASC SEPARATOR '/') AS try_out_day_totals,
  327. b.is_suspend,
  328. b.freeze_start_date,
  329. b.freeze_end_date,
  330. b.seller_id,
  331. b.product_id,
  332. b.formal_time,
  333. b.freeze_time,b.freeze_reason,b.renewal_reason,
  334. b.view_total,
  335. b.last_view_time,
  336. MAX(b.last_view_time) as max_last_view_time,
  337. MIN(b.last_view_time) as min_last_view_time,
  338. MAX(b.end_date) as max_end_date,
  339. MIN(b.end_date) as min_end_date,
  340. SUM(b.view_total) as all_view_total,
  341. SUM(b.try_out_day_total) as all_try_out_day_total,
  342. IF(LEFT(GROUP_CONCAT(DISTINCT b.last_view_time ORDER BY b.product_id), 19) >= "` + t + `", 1, 0) AS week_view_active
  343. FROM company AS a
  344. INNER JOIN company_product AS b ON a.company_id=b.company_id
  345. WHERE a.enabled=1 `
  346. if condition != "" {
  347. sql += condition
  348. }
  349. //sortStr := ``
  350. //如果没有传入排序字段,那么按照状态排序
  351. if sortStr == "" {
  352. if status == "全部" || status == utils.COMPANY_STATUS_TRY_OUT { //试用
  353. sortStr = " ORDER BY a.created_time DESC "
  354. } else if status == utils.COMPANY_STATUS_FORMAL { //正式
  355. // 正式客户默认按照周阅读活跃ASC, 同为不活跃则按照转正时间DESC
  356. sortStr = " ORDER BY week_view_active ASC, b.formal_time DESC"
  357. //sortStr = " ORDER BY b.formal_time DESC "
  358. } else if status == utils.COMPANY_STATUS_FREEZE { //冻结
  359. sortStr = " ORDER BY b.freeze_time DESC "
  360. } else if status == utils.COMPANY_STATUS_LOSE { //流失
  361. sortStr = " ORDER BY b.loss_time DESC "
  362. } else {
  363. sortStr = " ORDER BY a.created_time DESC "
  364. }
  365. }
  366. sql += ` GROUP BY a.company_id ` + sortStr + ` LIMIT ?,? `
  367. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  368. return
  369. }
  370. // GetCountCygxArticleHistoryRecordByCompanyName 查研观向阅读次数
  371. func GetCountCygxArticleHistoryRecordByCompanyName(companyName string) (count int, err error) {
  372. o := orm.NewOrm()
  373. sql := `SELECT count(1) total FROM cygx_article_history_record WHERE company_name=? `
  374. _ = o.Raw(sql, companyName).QueryRow(&count)
  375. return
  376. }
  377. // GetCountUserViewHistoryByCompanyName 晨报阅读次数
  378. func GetCountUserViewHistoryByCompanyName(companyName string) (count int, err error) {
  379. o := orm.NewOrm()
  380. sql := `SELECT count(1) total FROM user_view_history WHERE company_name=? `
  381. _ = o.Raw(sql, companyName).QueryRow(&count)
  382. return
  383. }
  384. // GetCountReportViewRecordByCompanyName 日评阅读次数
  385. func GetCountReportViewRecordByCompanyName(companyName string) (count int, err error) {
  386. o := orm.NewOrm()
  387. sql := `SELECT count(1) total FROM report_view_record WHERE company_name=? `
  388. _ = o.Raw(sql, companyName).QueryRow(&count)
  389. return
  390. }
  391. // GetCountAdvisoryUserChartArticleRecordByCompanyName 每日资讯阅读次数
  392. func GetCountAdvisoryUserChartArticleRecordByCompanyName(companyName string) (count int, err error) {
  393. o := orm.NewOrm()
  394. sql := `SELECT count(1) total FROM advisory_user_chart_article_record WHERE company_name=? `
  395. _ = o.Raw(sql, companyName).QueryRow(&count)
  396. return
  397. }
  398. type CompanyStatus struct {
  399. Status string `description:"客户状态:'试用','永续','冻结','流失','正式','试用-活跃','试用-非活跃' "`
  400. Count int `description:"数量 "`
  401. }
  402. type CompanyTryStageCount struct {
  403. TryStageStr string `description:"试用客户子标签:未分类、推进、跟踪、预备"`
  404. TryStage int `description:"试用客户子标签:1未分类、2 推进、3 跟踪、4 预备"`
  405. Count int `description:"数量 "`
  406. }
  407. func GetCompanyStatusCount(condition string, pars []interface{}) (items []*CompanyStatus, err error) {
  408. o := orm.NewOrm()
  409. sql := ` SELECT b.status,COUNT(DISTINCT a.company_id) AS count FROM company AS a
  410. INNER JOIN company_product AS b ON a.company_id=b.company_id
  411. WHERE a.enabled=1 AND b.status IN('正式','试用','冻结','永续') `
  412. if condition != "" {
  413. sql += condition
  414. }
  415. //sql += `GROUP BY b.status `
  416. //_, err = o.Raw(sql, pars).QueryRows(&items)
  417. sql += ` GROUP BY b.status `
  418. _, err = o.Raw(sql, pars).QueryRows(&items)
  419. return
  420. }
  421. // GetCompanyTryStageCount 获取试用客户标签的总数
  422. func GetCompanyTryStageCount(condition string, pars []interface{}) (items []*CompanyTryStageCount, err error) {
  423. o := orm.NewOrm()
  424. sql := ` SELECT b.try_stage,COUNT(DISTINCT a.company_id) AS count FROM company AS a
  425. INNER JOIN company_product AS b ON a.company_id=b.company_id
  426. WHERE a.enabled=1 AND b.status = "试用"`
  427. if condition != "" {
  428. sql += condition
  429. }
  430. //sql += `GROUP BY b.status `
  431. //_, err = o.Raw(sql, pars).QueryRows(&items)
  432. sql += ` GROUP BY b.try_stage `
  433. _, err = o.Raw(sql, pars).QueryRows(&items)
  434. return
  435. }
  436. // GetCompanyTryOutStatusCount 获取试用状态的客户数
  437. func GetCompanyTryOutStatusCount(condition string, pars []interface{}) (item *CompanyStatus, err error) {
  438. o := orm.NewOrm()
  439. sql := ` SELECT b.status,COUNT(DISTINCT a.company_id) AS count FROM company AS a
  440. INNER JOIN company_product AS b ON a.company_id=b.company_id
  441. WHERE a.enabled=1 AND b.status = "试用" `
  442. if condition != "" {
  443. sql += condition
  444. }
  445. //sql += `GROUP BY b.status `
  446. //_, err = o.Raw(sql, pars).QueryRows(&items)
  447. err = o.Raw(sql, pars).QueryRow(&item)
  448. return
  449. }
  450. func GetCompanyStatusLoseCount(condition string, pars []interface{}) (items *CompanyStatus, err error) {
  451. o := orm.NewOrm()
  452. sql := ` SELECT b.status,COUNT(DISTINCT a.company_id) AS count FROM company AS a
  453. INNER JOIN company_product AS b ON a.company_id=b.company_id
  454. WHERE a.enabled=1 AND b.status='流失' `
  455. if condition != "" {
  456. sql += condition
  457. }
  458. err = o.Raw(sql, pars).QueryRow(&items)
  459. return
  460. }
  461. func GetCompanyStatusFreezeCount(condition string, pars []interface{}) (items *CompanyStatus, err error) {
  462. o := orm.NewOrm()
  463. sql := ` SELECT b.status,COUNT(DISTINCT a.company_id) AS count FROM company AS a
  464. INNER JOIN company_product AS b ON a.company_id=b.company_id
  465. WHERE a.enabled=1 AND b.status='冻结' `
  466. if condition != "" {
  467. sql += condition
  468. }
  469. err = o.Raw(sql, pars).QueryRow(&items)
  470. return
  471. }
  472. func GetCompanyStatusForverCount(condition string, pars []interface{}) (items *CompanyStatus, err error) {
  473. o := orm.NewOrm()
  474. sql := ` SELECT b.status,COUNT(DISTINCT a.company_id) AS count FROM company AS a
  475. INNER JOIN company_product AS b ON a.company_id=b.company_id
  476. WHERE a.enabled=1 AND b.status='永续' `
  477. if condition != "" {
  478. sql += condition
  479. }
  480. err = o.Raw(sql, pars).QueryRow(&items)
  481. return
  482. }
  483. // 新增客户请求参数
  484. type CompanyAddReq struct {
  485. CompanyName string `description:"客户名称"`
  486. CreditCode string `description:"社会统一信用码"`
  487. CompanyCode string `description:"客户编码"`
  488. Province string `description:"省"`
  489. City string `description:"市"`
  490. Status string `description:"客户状态,'试用','永续','冻结','流失','正式','潜在'"`
  491. CompanyType string `description:"客户类型,ficc/权益"`
  492. IndustryId int `description:"所属行业id"`
  493. Source string `description:"来源"`
  494. SellsId int `description:"销售员id"`
  495. Reasons string `description:"新增理由,备注"`
  496. PermissionIds string `description:"权限id,多个用英文逗号隔开"`
  497. RegionType string `description:"地区类型,国内,海外"`
  498. UserId int `description:"联系人ID"`
  499. Scale string `description:"管理规模,空不填,1::50亿以下,2:50~100亿,3:100亿以上。"`
  500. }
  501. // 新增客户请求参数
  502. type CompanyAddResp struct {
  503. CompanyId int `description:"客户ID"`
  504. }
  505. func GetCompanyCode() (companyCode string, err error) {
  506. var num int
  507. o := orm.NewOrm()
  508. sql := `SELECT COUNT(1) AS num FROM company WHERE created_time >=? `
  509. err = o.Raw(sql, time.Now().Format(utils.FormatDate)).QueryRow(&num)
  510. if err != nil {
  511. return
  512. }
  513. fmt.Println("num", num)
  514. companyCode = "KH" + time.Now().Format("20060102") + fmt.Sprintf("%03d", num)
  515. return
  516. }
  517. type CompanyDetail struct {
  518. CompanyId int `orm:"column(company_id);pk"`
  519. CompanyName string `description:"客户名称"`
  520. CreditCode string `description:"社会统一信用码"`
  521. CompanyCode string `description:"客户编码"`
  522. Province string `description:"省"`
  523. City string `description:"市"`
  524. Address string `description:"详细地址"`
  525. RegionType string `description:"地区类型,1:国内,2:国外"`
  526. OpenCompanyCode string `description:"开放给第三方的客户编码,不让第三方定位我们的客户信息"`
  527. IsShare int `description:"0:非共享用户,1:共享客户"`
  528. ShareSeller string `description:"共享销售员"`
  529. ShareSellerId int `description:"共享销售员id"`
  530. }
  531. // 客户权限列表
  532. type CompanyPermissionResp struct {
  533. FiccPermissionList []*PermissionLookList `description:"Ficc权限列表"`
  534. PermissionList []*PermissionLookList `description:"权益权限列表"`
  535. }
  536. func GetCompanyDetailById(companyId int) (item *CompanyDetail, err error) {
  537. o := orm.NewOrm()
  538. sql := `SELECT * FROM company WHERE company_id =? `
  539. err = o.Raw(sql, companyId).QueryRow(&item)
  540. return
  541. }
  542. func GetCompanyCountByCompanyName(companyName string) (count int, err error) {
  543. o := orm.NewOrm()
  544. sql := ` SELECT COUNT(1) AS COUNT FROM company AS a WHERE a.company_name=? `
  545. err = o.Raw(sql, companyName).QueryRow(&count)
  546. return
  547. }
  548. func GetCompanyCountByCreditCode(creditCode string) (count int, err error) {
  549. o := orm.NewOrm()
  550. sql := ` SELECT COUNT(1) AS COUNT FROM company AS a WHERE a.credit_code=? `
  551. err = o.Raw(sql, creditCode).QueryRow(&count)
  552. return
  553. }
  554. func GetCompanyCountByCompanyNameAndCompanyId(companyId int, companyName string) (count int, err error) {
  555. o := orm.NewOrm()
  556. sql := ` SELECT COUNT(1) AS COUNT FROM company AS a WHERE a.company_id<>? AND a.company_name=? `
  557. err = o.Raw(sql, companyId, companyName).QueryRow(&count)
  558. return
  559. }
  560. func GetCompanyCountByCreditCodeAndCompanyId(companyId int, creditCode string) (count int, err error) {
  561. o := orm.NewOrm()
  562. sql := ` SELECT COUNT(1) AS COUNT FROM company AS a WHERE a.company_id<>? AND a.credit_code=? `
  563. err = o.Raw(sql, companyId, creditCode).QueryRow(&count)
  564. return
  565. }
  566. // GetCompanyByCreditCode 根据社会信用码获取客户信息
  567. func GetCompanyByCreditCode(creditCode string) (companyInfo *Company, err error) {
  568. o := orm.NewOrm()
  569. sql := ` SELECT * FROM company AS a WHERE a.credit_code=? `
  570. err = o.Raw(sql, creditCode).QueryRow(&companyInfo)
  571. return
  572. }
  573. // GetCompanyDetailByCreditCode 根据社会信用码获取客户详情接口
  574. func GetCompanyDetailByCreditCode(creditCode string) (companyDetail *CompanyDetail, err error) {
  575. o := orm.NewOrm()
  576. sql := ` SELECT * FROM company AS a WHERE a.credit_code=? `
  577. err = o.Raw(sql, creditCode).QueryRow(&companyDetail)
  578. return
  579. }
  580. func GetCompanyTryOutCount(status string, sellerId int) (count int, err error) {
  581. o := orm.NewOrm()
  582. sql := ` SELECT COUNT(DISTINCT a.company_id) AS count FROM company AS a
  583. INNER JOIN company_product AS b ON a.company_id=b.company_id
  584. WHERE b.status=?
  585. AND b.seller_id=? `
  586. err = o.Raw(sql, status, sellerId).QueryRow(&count)
  587. return
  588. }
  589. type CompanySearchResp struct {
  590. List []*CompanyItem
  591. }
  592. func GetCompanyBySearch(keyWord string) (item []*CompanyItem, err error) {
  593. o := orm.NewOrm()
  594. var sql string
  595. if keyWord == "##" {
  596. sql = ` SELECT * FROM company ORDER BY RAND() LIMIT 5 `
  597. } else {
  598. sql = `SELECT * FROM company WHERE company_name LIKE '%` + keyWord + `%' LIMIT 50`
  599. }
  600. _, err = o.Raw(sql).QueryRows(&item)
  601. return
  602. }
  603. // 编辑客户请求参数
  604. type CompanyEditReq struct {
  605. CompanyId int `description:"客户id"`
  606. CompanyName string `description:"客户名称"`
  607. CreditCode string `description:"社会统一信用码"`
  608. Province string `description:"省"`
  609. City string `description:"市"`
  610. Products []*CompanyProductEditReq `description:"产品信息"`
  611. }
  612. // 编辑客户信息请求参数
  613. type CompanyInfoEditReq struct {
  614. CompanyId int `description:"客户id"`
  615. CompanyName string `description:"客户名称"`
  616. CreditCode string `description:"社会统一信用码"`
  617. Province string `description:"省"`
  618. City string `description:"市"`
  619. IndustryId int `description:"所属行业id"`
  620. IndustryName string `description:"所属行业id"`
  621. Source string `description:"来源"`
  622. }
  623. type CompanyProductEditReq struct {
  624. CompanyProductId int `description:"客户产品id"`
  625. Status string `description:"客户状态,试用,永续"`
  626. CompanyType string `description:"客户类型,ficc/权益"`
  627. IndustryId int `description:"所属行业id"`
  628. Source string `description:"来源"`
  629. SellsId int `description:"销售员id"`
  630. Reasons string `description:"新增理由"`
  631. PermissionIds string `description:"权限id,多个用英文逗号隔开"`
  632. Scale string `description:"管理规模,空不填,1::50亿以下,2:50~100亿,3:100亿以上。"`
  633. }
  634. type CompanyFuzzySearch struct {
  635. CompanyId int `orm:"column(company_id);pk"`
  636. CompanyName string `description:"客户名称"`
  637. CreditCode string `description:"社会统一信用码"`
  638. CompanyCode string `description:"客户编码"`
  639. }
  640. // 新增客户请求参数
  641. type CompanyFuzzySearchReq struct {
  642. List []*CompanyFuzzySearch
  643. }
  644. func GetCompanyFuzzySearch(keyWord string) (items []*CompanyFuzzySearch, err error) {
  645. o := orm.NewOrm()
  646. sql := `SELECT * FROM company WHERE company_name LIKE '%` + keyWord + `%' `
  647. _, err = o.Raw(sql).QueryRows(&items)
  648. return
  649. }
  650. // 修改客户
  651. func ModifyCompany(item *Company) (err error) {
  652. o := orm.NewOrm()
  653. sql := `UPDATE company
  654. SET
  655. company_name = ?,
  656. credit_code = ?,
  657. address = ?,
  658. last_updated_time = NOW(),
  659. province = ?,
  660. city = ?
  661. WHERE company_id =?`
  662. _, err = o.Raw(sql, item.CompanyName, item.CreditCode, item.Address, item.Province, item.City, item.CompanyId).Exec()
  663. return
  664. }
  665. // 更新客户基础信息
  666. func (company *Company) Update(cols []string) (err error) {
  667. o := orm.NewOrm()
  668. _, err = o.Update(company, cols...)
  669. return
  670. }
  671. type DeletePptReq struct {
  672. CompanyId int `description:"客户id"`
  673. }
  674. func DeleteCompanyById(companyId int) (err error) {
  675. o := orm.NewOrm()
  676. to, err := o.Begin()
  677. if err != nil {
  678. return
  679. }
  680. defer func() {
  681. if err != nil {
  682. _ = to.Rollback()
  683. } else {
  684. _ = to.Commit()
  685. }
  686. }()
  687. sql := `DELETE FROM company_product WHERE company_id=? `
  688. _, err = to.Raw(sql, companyId).Exec()
  689. if err != nil {
  690. return
  691. }
  692. sql = `DELETE FROM company_report_permission WHERE company_id=? `
  693. _, err = to.Raw(sql, companyId).Exec()
  694. if err != nil {
  695. return
  696. }
  697. //联系人表
  698. sql = `DELETE FROM wx_user WHERE company_id=? `
  699. _, err = to.Raw(sql, companyId).Exec()
  700. if err != nil {
  701. return
  702. }
  703. //联系人 与 销售 关系表
  704. sql = `DELETE FROM user_seller_relation WHERE company_id=? `
  705. _, err = to.Raw(sql, companyId).Exec()
  706. if err != nil {
  707. return
  708. }
  709. //sql = `DELETE FROM company_operation_record WHERE company_id=? `
  710. //_, err = to.Raw(sql, companyId).Exec()
  711. //if err != nil {
  712. // return
  713. //}
  714. sql = `DELETE FROM company_contract WHERE company_id=? `
  715. _, err = to.Raw(sql, companyId).Exec()
  716. if err != nil {
  717. return
  718. }
  719. sql = `DELETE FROM company_contract_permission WHERE company_id=? `
  720. _, err = to.Raw(sql, companyId).Exec()
  721. if err != nil {
  722. return
  723. }
  724. sql = `DELETE FROM company WHERE company_id=? `
  725. _, err = to.Raw(sql, companyId).Exec()
  726. return
  727. }
  728. type CompanyReceiveItem struct {
  729. CompanyId int `orm:"column(company_id);pk"`
  730. CompanyName string `description:"客户名称"`
  731. StartDate string `description:"合同开始日期"`
  732. EndDate string `description:"合同结束日期"`
  733. Status string `description:"客户状态:'试用','永续','冻结','流失','正式' "`
  734. ProductName string `description:"客户类型:ficc/权益"`
  735. SellerName string `description:"销售:吉根龙/颖丹"`
  736. CreatedTime string `description:"创建时间"`
  737. ExpireDay string `description:"到期天数"`
  738. IndustryName string `description:"行业"`
  739. }
  740. type CompanyReceiveListResp struct {
  741. Paging *paging.PagingItem
  742. List []*CompanyReceiveItem
  743. }
  744. func GetCompanyReceiveListCount(condition string, pars []interface{}, productId, receiveProductId int) (count int, err error) {
  745. o := orm.NewOrm()
  746. sql := `SELECT
  747. COUNT(DISTINCT a.company_id ) AS COUNT
  748. FROM company AS a
  749. LEFT JOIN wx_user AS b ON a.company_id=b.company_id
  750. LEFT JOIN company_product AS c ON a.company_id=c.company_id
  751. WHERE a.enabled=1
  752. AND c.product_id=?
  753. AND c.company_id NOT IN (SELECT company_id FROM company_product WHERE product_id=?) `
  754. if condition != "" {
  755. sql += condition
  756. }
  757. err = o.Raw(sql, receiveProductId, productId, pars).QueryRow(&count)
  758. return
  759. }
  760. func GetCompanyReceiveList(condition string, pars []interface{}, productId, receiveProductId, startSize, pageSize int) (items []*CompanyReceiveItem, err error) {
  761. o := orm.NewOrm()
  762. sql := `SELECT
  763. c.company_id,a.company_name,c.product_name,c.industry_name,c.seller_name,c.status,c.start_date,c.end_date,a.created_time
  764. FROM company AS a
  765. LEFT JOIN wx_user AS b ON a.company_id=b.company_id
  766. LEFT JOIN company_product AS c ON a.company_id=c.company_id
  767. WHERE a.enabled=1
  768. AND c.product_id=?
  769. AND c.company_id NOT IN (SELECT company_id FROM company_product WHERE product_id=?) `
  770. if condition != "" {
  771. sql += condition
  772. }
  773. sql += ` GROUP BY a.company_id ORDER BY a.last_updated_time DESC LIMIT ?,? `
  774. _, err = o.Raw(sql, receiveProductId, productId, pars, startSize, pageSize).QueryRows(&items)
  775. return
  776. }
  777. // 编辑客户请求参数
  778. type CompanyReceiveReq struct {
  779. CompanyId int `description:"客户id"`
  780. Status string `description:"客户状态,试用,永续"`
  781. IndustryId int `description:"所属行业id"`
  782. Source string `description:"来源"`
  783. SellsId int `description:"销售员id,流失状态下直接领取,请传 0"`
  784. Reasons string `description:"新增理由"`
  785. PermissionIds string `description:"权限id,多个用英文逗号隔开"`
  786. CompanyType string `description:"客户类型"`
  787. }
  788. // 移动销售
  789. type MoveSellerReq struct {
  790. CompanyId int `description:"客户id"`
  791. SellsId int `description:"销售员id"`
  792. CompanyType string `description:"客户类型"`
  793. }
  794. // 修改试用客户标签
  795. type UpdateTryStageReq struct {
  796. CompanyId int `description:"客户id"`
  797. ProductId int `description:"产品ID"`
  798. TryStage int `description:"试用客户子标签:1未分类、2 推进、3 跟踪、4 预备"`
  799. }
  800. type ExportUser struct {
  801. RealName string
  802. Mobile string
  803. Email string
  804. Position string
  805. IsMaker int
  806. DepartmentName string
  807. CompanyId int
  808. IsSubscribe int `description:"是否关注了公众号(弘则研究)"`
  809. }
  810. type ExportCompanyProduct struct {
  811. CompanyName string
  812. ProductId int
  813. ProductName string
  814. IndustryName string
  815. SellerName string
  816. Status string
  817. StartDate time.Time
  818. EndDate time.Time
  819. CreateTime string
  820. Source string
  821. CreditCode string
  822. RegionType string
  823. LossTime string
  824. IsSuspend int
  825. }
  826. // 移动销售
  827. type SuspendReq struct {
  828. CompanyId int `description:"客户id"`
  829. }
  830. // 新增客户请求参数
  831. type CheckCompanyInfoResp struct {
  832. Status int `description:"检测状态:1:跳转到领取页面,0:不跳转,继续操作"`
  833. CompanyId int `description:"客户id"`
  834. ProductName string `description:"产品名称"`
  835. }
  836. type CheckCompanyInfoRepeatResp struct {
  837. Status int `description:"检测状态:1:跳转到领取页面,0:不跳转,继续操作"`
  838. RepeatStatus int `description:"检测状态:0:无重复 1:信用码重复 2:公司名重复"`
  839. CompanyId int `description:"客户id"`
  840. ProductName string `description:"产品名称"`
  841. }
  842. type ButtonPermission struct {
  843. BtnView bool `description:"查看按钮权限:true显示,false不显示"`
  844. BtnEdit bool `description:"编辑按钮权限:true显示,false不显示"`
  845. BtnDelete bool `description:"删除按钮权限:true显示,false不显示"`
  846. BtnSuspend bool `description:"暂停/启用按钮权限:true显示,false不显示"`
  847. BtnDelay bool `description:"申请延期按钮权限:true显示,false不显示"`
  848. BtnTurnPositive bool `description:"申请转正按钮权限:true显示,false不显示"`
  849. BtnUpdate bool `description:"服务更新按钮权限:true显示,false不显示"`
  850. BtnAddAgreement bool `description:"补充协议按钮权限:true显示,false不显示"`
  851. BtnThaw bool `description:"申请解冻按钮权限:true显示,false不显示"`
  852. BtnApplyReceive bool `description:"申请领取按钮权限:true显示,false不显示"`
  853. BtnReceive bool `description:"领取客户按钮权限:true显示,false不显示"`
  854. BtnModifySeller bool `description:"修改销售按钮权限:true显示,false不显示"`
  855. BtnReceiveOther bool `description:"领取其他部门客户按钮权限:true显示,false不显示"`
  856. BtnFreeze bool `description:"冻结按钮权限:true显示,false不显示"`
  857. BtnTryOut bool `description:"增开试用:true显示,false不显示"`
  858. BtnDetail bool `description:"详情按钮:true显示,false不显示"`
  859. BtnRemarkEdit bool `description:"编辑备注按钮:true显示,false不显示"`
  860. BtnRemarkView bool `description:"查看备注按钮:true显示,false不显示"`
  861. BtnShare bool `description:"设置共享按钮:true显示,false不显示"`
  862. BtnServiceRecord bool `description:"查看服务记录按钮:true显示,false不显示"`
  863. }
  864. type ButtonSearchPermission struct {
  865. BtnView bool `description:"查看按钮权限:true显示,false不显示"`
  866. BtnUpdate bool `description:"服务更新按钮权限:true显示,false不显示"`
  867. BtnEdit bool `description:"编辑按钮权限:true显示,false不显示"`
  868. BtnDelete bool `description:"删除按钮权限:true显示,false不显示"`
  869. BtnSuspend bool `description:"暂停/启用按钮权限:true显示,false不显示"`
  870. BtnDelay bool `description:"申请延期按钮权限:true显示,false不显示"`
  871. BtnTurnPositive bool `description:"申请转正按钮权限:true显示,false不显示"`
  872. BtnThaw bool `description:"申请解冻按钮权限:true显示,false不显示"`
  873. BtnApplyReceive bool `description:"申请领取按钮权限:true显示,false不显示"`
  874. BtnReceive bool `description:"领取客户按钮权限:true显示,false不显示"`
  875. BtnModifySeller bool `description:"修改销售按钮权限:true显示,false不显示"`
  876. BtnReceiveOther bool `description:"领取其他部门客户按钮权限:true显示,false不显示"`
  877. }
  878. type ButtonDetailPermission struct {
  879. BtnEdit bool `description:"编辑按钮权限:true显示,false不显示"`
  880. BtnDelete bool `description:"删除按钮权限:true显示,false不显示"`
  881. BtnHistoryList bool `description:"历史签约按钮权限:true显示,false不显示"`
  882. BaseInfoEdit bool `description:"客户基础信息编辑操作:true可操作,false不可操作"`
  883. FiccEdit bool `description:"ficc类型,编辑按钮权限:true显示,false不显示"`
  884. FiccDelete bool `description:"ficc类型,删除按钮权限:true显示,false不显示"`
  885. RaiEdit bool `description:"权益类型,编辑按钮权限:true显示,false不显示"`
  886. RaiDelete bool `description:"权益类型,删除按钮权限:true显示,false不显示"`
  887. }
  888. func GetCompanyListExport(condition string, pars []interface{}) (items []*CompanyItem, err error) {
  889. o := orm.NewOrm()
  890. sql := `SELECT a.company_id,a.company_name,a.credit_code,a.company_code,a.created_time,a.address,
  891. GROUP_CONCAT(b.status ORDER BY b.product_id ASC SEPARATOR '/') AS status,
  892. GROUP_CONCAT(DISTINCT b.seller_name ORDER BY b.product_id ASC SEPARATOR '/') AS seller_name,
  893. GROUP_CONCAT(DISTINCT b.industry_name ORDER BY b.product_id ASC SEPARATOR '/') AS industry_name,
  894. GROUP_CONCAT(DISTINCT b.product_name ORDER BY b.product_id ASC SEPARATOR '/') AS company_type,
  895. GROUP_CONCAT(b.start_date ORDER BY b.product_id ASC SEPARATOR '/') AS start_date,
  896. GROUP_CONCAT(b.end_date ORDER BY b.product_id ASC SEPARATOR '/') AS end_date,
  897. GROUP_CONCAT(DISTINCT b.loss_time ORDER BY b.product_id ASC SEPARATOR '/') AS loss_time,
  898. GROUP_CONCAT(DISTINCT b.lose_reason ORDER BY b.product_id ASC SEPARATOR '/') AS lose_reason,
  899. GROUP_CONCAT(DISTINCT b.source ORDER BY b.product_id ASC SEPARATOR '/') AS source,
  900. GROUP_CONCAT(DISTINCT b.reasons ORDER BY b.product_id ASC SEPARATOR '/') AS reasons,
  901. GROUP_CONCAT(DISTINCT b.approve_status ORDER BY b.product_id ASC SEPARATOR '/') AS approve_status,
  902. GROUP_CONCAT(DISTINCT b.group_id ORDER BY b.product_id ASC SEPARATOR '/') AS group_id,
  903. b.is_suspend,
  904. b.freeze_start_date,
  905. b.freeze_end_date,
  906. b.seller_id,
  907. b.product_id
  908. FROM company AS a
  909. INNER JOIN company_product AS b ON a.company_id=b.company_id
  910. WHERE a.enabled=1 AND a.company_id<>1 `
  911. if condition != "" {
  912. sql += condition
  913. }
  914. sql += ` GROUP BY a.company_id ORDER BY a.last_updated_time DESC `
  915. _, err = o.Raw(sql, pars).QueryRows(&items)
  916. return
  917. }
  918. // 冻结客户请求参数
  919. type CompanyFreezeReq struct {
  920. CompanyId int `description:"客户id"`
  921. CompanyType string `description:"客户类型:ficc/权益"`
  922. Remark string `description:"备注"`
  923. }
  924. // 冻结客户
  925. func CompanyFreeze(companyId, productId int, freezeReason string) (err error) {
  926. o := orm.NewOrm()
  927. to, err := o.Begin()
  928. if err != nil {
  929. return
  930. }
  931. defer func() {
  932. if err != nil {
  933. _ = to.Rollback()
  934. } else {
  935. _ = to.Commit()
  936. }
  937. }()
  938. freezeStartDate := time.Now().Format(utils.FormatDate)
  939. freezeEndDate := time.Now().AddDate(0, 3, 0).Format(utils.FormatDate)
  940. // ficc是两个月的冻结期
  941. if productId == 1 {
  942. freezeEndDate = time.Now().AddDate(0, 2, 0).Format(utils.FormatDate)
  943. }
  944. // 权益也调整为 两个月的冻结期
  945. if productId == 2 {
  946. freezeEndDate = time.Now().AddDate(0, 2, 0).Format(utils.FormatDate)
  947. }
  948. //修改用户产品状态
  949. sql := `UPDATE company_product SET status='冻结',is_formal=0,is_suspend=0,freeze_time=NOW(),modify_time=NOW(),start_date=?,end_date=?,freeze_start_date=?,freeze_end_date=?,freeze_reason=?,try_stage=1 WHERE company_id=? AND product_id=? `
  950. _, err = to.Raw(sql, freezeStartDate, freezeEndDate, freezeStartDate, freezeEndDate, freezeReason, companyId, productId).Exec()
  951. if err != nil {
  952. return err
  953. }
  954. //修改产品权限状态为关闭
  955. sql = `UPDATE company_report_permission SET status='关闭',modify_time=NOW() WHERE company_id= ? AND product_id = ? `
  956. _, err = to.Raw(sql, companyId, productId).Exec()
  957. if err != nil {
  958. return err
  959. }
  960. //修改客户为关闭
  961. sql = `UPDATE company SET type=3,last_updated_time=NOW(),start_date=?,end_date=? WHERE company_id=? `
  962. _, err = to.Raw(sql, freezeStartDate, freezeEndDate, companyId).Exec()
  963. if err != nil {
  964. return err
  965. }
  966. return
  967. }
  968. func ModifyCompanyGroupId(sellerId, groupId int) (err error) {
  969. o := orm.NewOrm()
  970. sql := `UPDATE company_product SET group_id=? WHERE seller_id=? `
  971. _, err = o.Raw(sql, groupId, sellerId).Exec()
  972. return
  973. }
  974. func ModifyCompanyDepartmentId(sellerId, departmentId int) (err error) {
  975. o := orm.NewOrm()
  976. sql := `UPDATE company_product SET department_id=? WHERE seller_id=? `
  977. _, err = o.Raw(sql, departmentId, sellerId).Exec()
  978. return
  979. }
  980. // CompanyTryOutReasonReq 编辑客户未续约情况说明请求参数
  981. type CompanyTryOutReasonReq struct {
  982. CompanyId int `description:"客户id"`
  983. ProductId int `description:"客户产品id:ficc:1;权益:2"`
  984. Remark string `description:"备注"`
  985. }
  986. // RenewalReasonReq 新增客户未续约情况说明请求参数
  987. type RenewalReasonReq struct {
  988. CompanyId int `description:"客户id"`
  989. ProductId int `description:"客户产品id:ficc:1;权益:2"`
  990. Remark string `description:"未续约理由"`
  991. Renew int `description:"是否勾选不再跟进 1:勾选,0:未勾选"`
  992. RenewalTodo string `description:"待办事项说明"`
  993. }
  994. // TryOutReq 新增客户未续约情况说明请求参数
  995. type TryOutReq struct {
  996. CompanyId int `description:"客户id"`
  997. ProductId int `description:"客户产品id:ficc:1;权益:2"`
  998. OperationId int `description:"operation record id"`
  999. Remark string `description:"未续约理由"`
  1000. Renew int `description:"是否勾选不再跟进 1:勾选,0:未勾选"`
  1001. RenewalTodo string `description:"待办事项说明"`
  1002. }
  1003. func GetFiccReportListByMobile(mobiles string) (items []*ViewReportList, err error) {
  1004. dataName := ""
  1005. sql := ``
  1006. if utils.RunMode == "debug" {
  1007. dataName = "test_v2_hongze_rddp"
  1008. } else {
  1009. dataName = "hongze_rddp"
  1010. }
  1011. ficcSql := `SELECT
  1012. rr.research_report_name,
  1013. rr.type AS report_type,
  1014. 'ficc' AS txt_type,
  1015. '--' AS match_type_name,
  1016. '--' AS stop_time,
  1017. uvh.created_time AS created_time
  1018. FROM
  1019. user_view_history uvh
  1020. LEFT JOIN research_report rr ON rr.research_report_id = uvh.research_report_id
  1021. WHERE
  1022. uvh.mobile in (` + mobiles + `)
  1023. UNION ALL
  1024. SELECT
  1025. r.title AS research_report_name,
  1026. 'rddp' AS report_type,
  1027. 'ficc' AS txt_type,
  1028. r.classify_name_first AS match_type_name,
  1029. '--' AS stop_time,
  1030. rvr.create_time AS created_time
  1031. FROM %s.report_view_record rvr
  1032. LEFT JOIN %s.report r ON r.id = rvr.report_id
  1033. WHERE
  1034. rvr.mobile in (` + mobiles + `)
  1035. UNION ALL
  1036. SELECT
  1037. cha.permission_name AS research_report_name,
  1038. 'advisory' AS report_type,
  1039. 'ficc' AS txt_type,
  1040. cha.classify_name AS match_type_name,
  1041. '--' AS stop_time,
  1042. auc.create_time AS created_time
  1043. FROM
  1044. advisory_user_chart_article_record auc
  1045. LEFT JOIN chart_permission cha ON cha.chart_permission_id = auc.chart_permission_id
  1046. WHERE
  1047. auc.mobile in (` + mobiles + `)`
  1048. sql = ` SELECT * FROM ( ` + ficcSql + `
  1049. )AS t ORDER BY t.created_time DESC`
  1050. o := orm.NewOrm()
  1051. sql = fmt.Sprintf(sql, dataName, dataName)
  1052. _, err = o.Raw(sql).QueryRows(&items)
  1053. return
  1054. }
  1055. func GetRightsReportListByMobile(mobiles string) (items []*ViewReportList, err error) {
  1056. rightsSql := `SELECT
  1057. art.title AS research_report_name,
  1058. 'cygx' AS report_type,
  1059. 'rights' AS txt_type,
  1060. art.match_type_name,
  1061. h.stop_time,
  1062. h.create_time AS created_time
  1063. FROM
  1064. cygx_article_history_record_newpv h
  1065. LEFT JOIN cygx_article art ON art.article_id = h.article_id
  1066. WHERE
  1067. h.mobile in (` + mobiles + `) AND h.company_id != 16 `
  1068. sql := ` SELECT * FROM ( ` + rightsSql + `
  1069. )AS t ORDER BY t.created_time DESC`
  1070. o := orm.NewOrm()
  1071. _, err = o.Raw(sql).QueryRows(&items)
  1072. return
  1073. }
  1074. func GetFiccReportListByEmail(emails string) (items []*ViewReportList, err error) {
  1075. dataName := ""
  1076. sql := ``
  1077. if utils.RunMode == "debug" {
  1078. dataName = "test_v2_hongze_rddp"
  1079. } else {
  1080. dataName = "hongze_rddp"
  1081. }
  1082. ficcSql := `SELECT
  1083. rr.research_report_name,
  1084. rr.type AS report_type,
  1085. 'ficc' AS txt_type,
  1086. '--' AS match_type_name,
  1087. '--' AS stop_time,
  1088. uvh.created_time AS created_time
  1089. FROM
  1090. user_view_history uvh
  1091. INNER JOIN research_report rr ON rr.research_report_id = uvh.research_report_id
  1092. WHERE
  1093. uvh.email in (` + emails + `)
  1094. UNION ALL
  1095. SELECT
  1096. r.title AS research_report_name,
  1097. 'rddp' AS report_type,
  1098. 'ficc' AS txt_type,
  1099. r.classify_name_first AS match_type_name,
  1100. '--' AS stop_time,
  1101. rvr.create_time AS created_time
  1102. FROM %s.report_view_record rvr
  1103. INNER JOIN %s.report r ON r.id = rvr.report_id
  1104. WHERE
  1105. rvr.email in (` + emails + `)
  1106. UNION ALL
  1107. SELECT
  1108. cha.permission_name AS research_report_name,
  1109. 'advisory' AS report_type,
  1110. 'ficc' AS txt_type,
  1111. cha.classify_name AS match_type_name,
  1112. '--' AS stop_time,
  1113. auc.create_time AS created_time
  1114. FROM
  1115. advisory_user_chart_article_record auc
  1116. INNER JOIN chart_permission cha ON cha.chart_permission_id = auc.chart_permission_id
  1117. WHERE
  1118. auc.email in (` + emails + `) `
  1119. sql = ` SELECT * FROM ( ` + ficcSql + `
  1120. )AS t ORDER BY t.created_time DESC`
  1121. o := orm.NewOrm()
  1122. sql = fmt.Sprintf(sql, dataName, dataName)
  1123. _, err = o.Raw(sql).QueryRows(&items)
  1124. return
  1125. }
  1126. func GetRightsReportListByEmail(emails string) (items []*ViewReportList, err error) {
  1127. rightsSql := `SELECT
  1128. art.title AS research_report_name,
  1129. 'cygx' AS report_type,
  1130. 'rights' AS txt_type,
  1131. art.match_type_name,
  1132. h.stop_time,
  1133. h.create_time AS created_time
  1134. FROM
  1135. cygx_article_history_record_newpv h
  1136. INNER JOIN cygx_article art ON art.article_id = h.article_id
  1137. WHERE
  1138. h.email in (` + emails + `) AND h.company_id != 16 `
  1139. sql := ` SELECT * FROM ( ` + rightsSql + `
  1140. )AS t ORDER BY t.created_time DESC`
  1141. o := orm.NewOrm()
  1142. _, err = o.Raw(sql).QueryRows(&items)
  1143. return
  1144. }
  1145. // ModifyCompanyProductLastViewData 修改客户产品的总共阅读次数以及最近阅读时间
  1146. func ModifyCompanyProductLastViewData(companyId, productId, viewTotal int, lastViewTime string) (err error) {
  1147. o := orm.NewOrm()
  1148. sql := `UPDATE company_product SET view_total=?,last_view_time=? WHERE company_id=? AND product_id=? `
  1149. _, err = o.Raw(sql, viewTotal, lastViewTime, companyId, productId).Exec()
  1150. if err != nil {
  1151. return err
  1152. }
  1153. return
  1154. }
  1155. // RemarkReq 新增备注请求
  1156. type RemarkReq struct {
  1157. CompanyId int `description:"客户id"`
  1158. Remark string `description:"备注"`
  1159. }
  1160. // RemarkResp 备注说明
  1161. type RemarkResp struct {
  1162. Remark string `description:"未续约说明"`
  1163. ProductName string `description:"客户产品:ficc:权益:"`
  1164. CreateTime string `description:"添加时间"`
  1165. }
  1166. type RoadShowTotalSlice struct {
  1167. Total int `description:"总路演数"`
  1168. CompanyId int `description:"用户id"`
  1169. }
  1170. type RoadShowCalendar struct {
  1171. RsCalendarId int `orm:"column(rs_calendar_id);pk"`
  1172. SysUserId int `description:"创建人id"`
  1173. SysUserRealName string `description:"创建人名称"`
  1174. ActivityType string `description:"活动类型"`
  1175. RoadshowType string `description:"路演形式"`
  1176. RoadshowPlatform string `description:"路演平台"`
  1177. CompanyId int `description:"客户id"`
  1178. CompanyName string `description:"客户名称"`
  1179. Province string `description:"省"`
  1180. ProvinceCode string `description:"省编码"`
  1181. City string `description:"市"`
  1182. CityCode string `description:"市编码"`
  1183. Theme string `description:"会议主题"`
  1184. CooperationName string `description:"合作方名称"`
  1185. Title string `description:"展示在日历的标题"`
  1186. Source int8 `description:"来源,0:自系统,1:上海方的"`
  1187. CreateTime time.Time
  1188. ModifyTime time.Time
  1189. ActivityCategory string `description:"活动类别"`
  1190. IsSynced int `description:"是否与上海同步 0:未同步 1:已同步"`
  1191. EndDate time.Time
  1192. }
  1193. type RoadShowListResp struct {
  1194. SysUserRealName string `description:"对接销售"`
  1195. RoadshowType string `description:"路演形式"`
  1196. RoadshowPlatform string `description:"路演平台:线上时为平台,线下时为省市"`
  1197. RoadShowTime string `description:"路演时间"`
  1198. Researchers string `description:"研究员"`
  1199. }
  1200. type CompanyNameAndId struct {
  1201. CompanyId int `description:"公司id"`
  1202. CompanyName string `description:"公司名称"`
  1203. }
  1204. type CompanyNameAndIdListResp struct {
  1205. List []*CompanyNameAndId
  1206. }
  1207. // CompanyTryOutDayListResp 客户累计试用天数
  1208. type CompanyTryOutDayListResp struct {
  1209. Paging *paging.PagingItem
  1210. List []*CompanyProductTryOutUpdateLog
  1211. }
  1212. // 共享客户
  1213. type CompanyShareReq struct {
  1214. CompanyId int `description:"客户id"`
  1215. IsShare int `description:"0取消共享 1共享"`
  1216. }
  1217. // 分配共享销售
  1218. type MoveShareSellerReq struct {
  1219. CompanyId int `description:"客户id"`
  1220. SellsId int `description:"销售员id"`
  1221. }
  1222. // ExportUserCompanyStatus 联系人导出客户状态
  1223. type ExportUserCompanyStatus struct {
  1224. CompanyId int `description:"客户ID"`
  1225. CompanyName string `description:"客户名称"`
  1226. CompanyStatus string `description:"客户状态: FICC状态/权益状态"`
  1227. }