pre_register.go 37 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201
  1. package contract
  2. import (
  3. "fmt"
  4. "github.com/gin-gonic/gin"
  5. "github.com/go-playground/validator/v10"
  6. "hongze/fms_api/controller/resp"
  7. "hongze/fms_api/global"
  8. "hongze/fms_api/models/base"
  9. "hongze/fms_api/models/crm"
  10. "hongze/fms_api/models/fms"
  11. "hongze/fms_api/models/system"
  12. crmService "hongze/fms_api/services/crm"
  13. fmsService "hongze/fms_api/services/fms"
  14. "hongze/fms_api/utils"
  15. "strconv"
  16. "strings"
  17. "time"
  18. )
  19. // // RegisterController 合同登记
  20. type PreRegisterController struct{}
  21. // InvoiceList
  22. // @Title 开票/到款列表
  23. // @Description 开票/到款列表
  24. // @Param Keyword query string false "关键词"
  25. // @Success 200 {object} fms.ContractInvoiceItem
  26. // @router /contract/pre_register/list [get]
  27. func (rg *PreRegisterController) List(c *gin.Context) {
  28. var req fms.PreRegisterListReq
  29. if e := c.BindQuery(&req); e != nil {
  30. err, ok := e.(validator.ValidationErrors)
  31. if !ok {
  32. resp.FailData("参数解析失败", "Err:"+e.Error(), c)
  33. return
  34. }
  35. resp.FailData("参数解析失败", err.Translate(global.Trans), c)
  36. return
  37. }
  38. pageSize := req.PageSize
  39. pageIndex := req.Current
  40. if pageSize <= 0 {
  41. pageSize = utils.PageSize20
  42. }
  43. if pageIndex <= 0 {
  44. pageIndex = 1
  45. }
  46. cond := ` invoice_type IN (3, 4) `
  47. pars := make([]interface{}, 0)
  48. if req.Keyword != "" {
  49. kw := "%" + req.Keyword + "%"
  50. cond += ` AND company_name LIKE ? `
  51. pars = append(pars, kw)
  52. }
  53. // 货币列表
  54. currencyOB := new(fms.CurrencyUnit)
  55. currencyCond := `enable = 1`
  56. currencyPars := make([]interface{}, 0)
  57. currencyList, e := currencyOB.List(currencyCond, currencyPars)
  58. if e != nil {
  59. resp.FailMsg("获取失败", "获取货币列表失败, Err: "+e.Error(), c)
  60. return
  61. }
  62. unitMap := make(map[string]string)
  63. for i := range currencyList {
  64. unitMap[currencyList[i].Code] = currencyList[i].UnitName
  65. }
  66. page := new(base.Page)
  67. page.SetPageSize(req.PageSize)
  68. page.SetCurrent(req.Current)
  69. sortTypeMap := map[int]bool{0: false, 1: true, 2: false}
  70. page.AddOrderItem(base.OrderItem{Column: "create_time", Asc: sortTypeMap[0]})
  71. total, list, e := fms.GetContractPreRegisterItemPageList(page, cond, pars)
  72. if e != nil {
  73. resp.FailMsg("获取失败", "获取预登记列表失败, Err: "+e.Error(), c)
  74. return
  75. }
  76. serviceMap := make(map[int]string, 0)
  77. registerIds := make([]int, 0)
  78. for i := range list {
  79. list[i].UnitName = unitMap[list[i].CurrencyUnit]
  80. registerIds = append(registerIds, list[i].ContractRegisterId)
  81. }
  82. if len(registerIds) > 0 {
  83. serviceMap, _, e = fmsService.GetContractServiceNameFormat(registerIds)
  84. if e != nil {
  85. resp.FailMsg("获取失败", e.Error(), c)
  86. return
  87. }
  88. }
  89. respList := make([]*fms.ContractPreRegisterList, 0)
  90. for _, v := range list {
  91. item := new(fms.ContractPreRegisterList)
  92. item.ContractPreRegisterItem = v
  93. item.ServicesName = serviceMap[v.ContractRegisterId]
  94. respList = append(respList, item)
  95. }
  96. page.SetTotal(total)
  97. baseData := new(base.BaseData)
  98. baseData.SetPage(page)
  99. baseData.SetList(respList)
  100. resp.OkData("获取成功", baseData, c)
  101. }
  102. // Add
  103. // @Title 新增预登记
  104. // @Description 新增预登记
  105. // @Param request body fms.PrepayAddReq true "type json string"
  106. // @Success 200 string "操作成功"
  107. // @router /contract/pre_register/add [post]
  108. func (rg *PreRegisterController) Add(c *gin.Context) {
  109. req := new(fms.PreRegisterAddReq)
  110. err := c.ShouldBind(&req)
  111. if err != nil {
  112. errs, ok := err.(validator.ValidationErrors)
  113. if !ok {
  114. resp.FailData("参数解析失败", "Err:"+err.Error(), c)
  115. return
  116. }
  117. resp.FailData("参数解析失败", errs.Translate(global.Trans), c)
  118. return
  119. }
  120. claims, _ := c.Get("adminInfo")
  121. adminInfo := claims.(*system.SysAdmin)
  122. // 日期校验
  123. var startDate, endDate time.Time
  124. if req.StartDate != "" && req.EndDate != "" {
  125. startDate, err = time.ParseInLocation(utils.FormatDate, req.StartDate, time.Local)
  126. if err != nil {
  127. resp.FailMsg("约定开始日期格式有误", "合同开始日期格式有误, Err: "+err.Error(), c)
  128. return
  129. }
  130. endDate, err = time.ParseInLocation(utils.FormatDate, req.EndDate, time.Local)
  131. if err != nil {
  132. resp.FailMsg("约定结束日期格式有误", "合同结束日期格式有误, Err: "+err.Error(), c)
  133. return
  134. }
  135. }
  136. var currencyUnit string
  137. if len(req.List) > 0 {
  138. currencyUnit = req.List[0].CurrencyUnit
  139. }
  140. // 获取销售分组信息
  141. sellerList, e := crmService.GetSellerDepartmentListWithGroupAndTeam()
  142. if e != nil {
  143. resp.FailData("获取销售失败", "Err:"+e.Error(), c)
  144. return
  145. }
  146. sellerMap := make(map[int]*crm.SellerAdminWithGroupTeam)
  147. for i := range sellerList {
  148. sellerMap[sellerList[i].SellerId] = sellerList[i]
  149. }
  150. admin := new(crm.Admin)
  151. sellerIds := strings.Split(req.SellerIds, ",")
  152. if len(sellerIds) > 2 {
  153. resp.Fail("最多只能选择两个销售", c)
  154. return
  155. }
  156. var sellers []*crm.Admin
  157. var pars []interface{}
  158. cond := ``
  159. if len(sellerIds) > 0 {
  160. cond = ` admin_id in (?) `
  161. pars = append(pars, sellerIds)
  162. sellers, e = admin.List(cond, pars)
  163. if e != nil {
  164. resp.FailMsg("获取销售信息失败", "获取销售信息失败, Err: "+e.Error(), c)
  165. return
  166. }
  167. }
  168. //新增合同
  169. ob := new(fms.ContractRegister)
  170. //ob.ContractCode = req.ContractCode
  171. ob.CompanyName = req.CompanyName
  172. ob.ProductIds = req.ProductIds
  173. ob.StartDate = startDate
  174. ob.EndDate = endDate
  175. ob.HasInvoice = 1
  176. ob.Set()
  177. ob.CurrencyUnit = currencyUnit
  178. if req.RegisterType == fms.ContractInvoiceTypePreMake {
  179. //sellerItem := sellerMap[r.SellerId]
  180. //if sellerItem == nil {
  181. // resp.Fail("销售信息异常", c)
  182. // return
  183. //}
  184. for _, v := range sellers {
  185. if v.DepartmentId == crm.SellerDepartmentId {
  186. ob.SellerId = v.AdminId
  187. ob.SellerName = v.AdminName
  188. } else if v.DepartmentId == crm.RaiSellerDepartmentId {
  189. ob.RaiSellerId = v.AdminId
  190. ob.RaiSellerName = v.AdminName
  191. }
  192. }
  193. }
  194. // 套餐信息
  195. serviceAmountMap := make(map[int]float64)
  196. serviceList, e := fmsService.HandleContractServiceAndDetail(req.Services, true, serviceAmountMap)
  197. if e != nil {
  198. resp.FailMsg("操作失败", "获取合同套餐详情失败, Err: "+e.Error(), c)
  199. return
  200. }
  201. if e = ob.Create(); e != nil {
  202. resp.FailMsg("操作失败", "新增合同失败, Err: "+e.Error(), c)
  203. return
  204. }
  205. if ob.ContractRegisterId == 0 {
  206. resp.FailMsg("操作失败", "新增合同失败,合同ID为0", c)
  207. return
  208. }
  209. if e = fms.CreateContractRegisterAndServicesAndPayMent(ob, serviceList); e != nil {
  210. resp.FailMsg("操作失败", "新增合同及套餐失败, Err: "+e.Error(), c)
  211. return
  212. }
  213. for _, r := range req.List {
  214. // 货币及汇率
  215. rateList, e := fmsService.GetTodayCurrencyRateList()
  216. if e != nil {
  217. resp.FailMsg("操作失败", "获取今日货币汇率失败, Err: "+e.Error(), c)
  218. return
  219. }
  220. var rate float64
  221. for i := range rateList {
  222. if r.CurrencyUnit == rateList[i].Code {
  223. rate = rateList[i].RMBRate
  224. break
  225. }
  226. }
  227. if rate <= 0 {
  228. resp.FailMsg("操作失败", "货币汇率信息有误", c)
  229. return
  230. }
  231. registerDate, e := time.Parse(utils.FormatDate, r.RegisterDate)
  232. if e != nil {
  233. resp.FailMsg("日期转换失败", "日期转换失败, Err: "+e.Error(), c)
  234. return
  235. }
  236. v := &fms.ContractInvoice{
  237. ContractRegisterId: ob.ContractRegisterId,
  238. OriginAmount: r.Amount,
  239. CurrencyUnit: r.CurrencyUnit,
  240. InvoiceType: req.RegisterType,
  241. InvoiceDate: registerDate,
  242. AdminId: int(adminInfo.AdminId),
  243. AdminName: adminInfo.AdminName,
  244. Remark: r.Remark,
  245. ServiceProductId: r.ServiceProductId,
  246. IsPrePay: 1,
  247. StartDate: startDate,
  248. EndDate: endDate,
  249. TimeBase: base.TimeBase{},
  250. }
  251. v.Set()
  252. a, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", v.OriginAmount/rate), 64)
  253. v.Amount = a
  254. sellerItem := sellerMap[r.SellerId]
  255. if sellerItem == nil {
  256. resp.Fail("销售信息异常", c)
  257. return
  258. }
  259. v.SellerId = sellerItem.SellerId
  260. v.SellerName = sellerItem.SellerName
  261. v.SellerGroupId = sellerItem.GroupId
  262. v.SellerGroupName = sellerItem.GroupName
  263. v.SellerTeamId = sellerItem.TeamId
  264. v.SellerTeamName = sellerItem.TeamName
  265. // 新增开票到款记录
  266. if e = v.Create(); e != nil {
  267. resp.FailMsg("操作失败", "新增预登记失败, Err: "+e.Error(), c)
  268. return
  269. }
  270. //预登记列表
  271. pp := &fms.ContractPreRegister{
  272. ContractRegisterId: ob.ContractRegisterId,
  273. CompanyName: req.CompanyName,
  274. InvoiceType: req.RegisterType,
  275. AdminId: int(adminInfo.AdminId),
  276. AdminName: adminInfo.AdminName,
  277. ServiceProductId: r.ServiceProductId,
  278. IsPrePay: 1,
  279. StartDate: startDate,
  280. EndDate: endDate,
  281. TimeBase: base.TimeBase{},
  282. }
  283. pp.Set()
  284. pp.CurrencyUnit = r.CurrencyUnit
  285. if pp.InvoiceType == fms.ContractInvoiceTypePreMake {
  286. //开票走开票字段
  287. pp.InvoiceId = v.ContractInvoiceId
  288. pp.InvoiceDate = registerDate
  289. pp.OriginAmount = r.Amount
  290. a, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", pp.OriginAmount/rate), 64)
  291. pp.Amount = a
  292. pp.Remark = r.Remark
  293. sellerItem := sellerMap[r.SellerId]
  294. if sellerItem == nil {
  295. resp.Fail("销售信息异常", c)
  296. return
  297. }
  298. pp.SellerId = sellerItem.SellerId
  299. pp.SellerName = sellerItem.SellerName
  300. pp.SellerGroupId = sellerItem.GroupId
  301. pp.SellerGroupName = sellerItem.GroupName
  302. pp.SellerTeamId = sellerItem.TeamId
  303. pp.SellerTeamName = sellerItem.TeamName
  304. pp.PaymentSellerId = sellerItem.SellerId
  305. pp.PaymentSellerName = sellerItem.SellerName
  306. pp.PaymentSellerGroupId = sellerItem.GroupId
  307. pp.PaymentSellerGroupName = sellerItem.GroupName
  308. pp.PaymentSellerTeamId = sellerItem.TeamId
  309. pp.PaymentSellerTeamName = sellerItem.TeamName
  310. } else {
  311. //到款
  312. pp.ArriveId = v.ContractInvoiceId
  313. pp.ArriveDate = registerDate
  314. pp.ArriveOriginAmount = r.Amount
  315. a, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", pp.ArriveOriginAmount/rate), 64)
  316. pp.ArriveAmount = a
  317. pp.ArriveRemark = r.Remark
  318. sellerItem := sellerMap[r.SellerId]
  319. if sellerItem == nil {
  320. resp.Fail("销售信息异常", c)
  321. return
  322. }
  323. pp.PaymentSellerId = sellerItem.SellerId
  324. pp.PaymentSellerName = sellerItem.SellerName
  325. pp.PaymentSellerGroupId = sellerItem.GroupId
  326. pp.PaymentSellerGroupName = sellerItem.GroupName
  327. pp.PaymentSellerTeamId = sellerItem.TeamId
  328. pp.PaymentSellerTeamName = sellerItem.TeamName
  329. }
  330. // 新增开票到款记录
  331. if pp.ContractRegisterId == 0 {
  332. resp.FailMsg("操作失败", "新增预登记失败,合同ID为0", c)
  333. return
  334. }
  335. if e = pp.Create(); e != nil {
  336. resp.FailMsg("操作失败", "新增预登记失败, Err: "+e.Error(), c)
  337. return
  338. }
  339. v.PreRegisterId = pp.PreRegisterId
  340. if e = v.Update([]string{"PreRegisterId"}); e != nil {
  341. fmt.Println("更新开票登记失败, Err: " + e.Error())
  342. return
  343. }
  344. }
  345. // 开票到款汇总
  346. go fmsService.SummaryInvoicePaymentByContractRegisterId(ob.ContractRegisterId)
  347. resp.Ok("操作成功", c)
  348. }
  349. // Edit
  350. // @Title 编辑预登记
  351. // @Description 编辑预登记
  352. // @Param request body fms.ContractRegisterEditReq true "type json string"
  353. // @Success 200 string "操作成功"
  354. // @router /contract/pre_register/edit [post]
  355. func (rg *PreRegisterController) Edit(c *gin.Context) {
  356. req := new(fms.PreRegisterEditReq)
  357. err := c.ShouldBind(&req)
  358. if err != nil {
  359. errs, ok := err.(validator.ValidationErrors)
  360. if !ok {
  361. resp.FailData("参数解析失败", "Err:"+err.Error(), c)
  362. return
  363. }
  364. resp.FailData("参数解析失败", errs.Translate(global.Trans), c)
  365. return
  366. }
  367. claims, _ := c.Get("adminInfo")
  368. adminInfo := claims.(*system.SysAdmin)
  369. // 日期校验
  370. var startDate, endDate time.Time
  371. if req.StartDate != "" && req.EndDate != "" {
  372. startDate, err = time.ParseInLocation(utils.FormatDate, req.StartDate, time.Local)
  373. if err != nil {
  374. resp.FailMsg("约定开始日期格式有误", "合同开始日期格式有误, Err: "+err.Error(), c)
  375. return
  376. }
  377. endDate, err = time.ParseInLocation(utils.FormatDate, req.EndDate, time.Local)
  378. if err != nil {
  379. resp.FailMsg("约定结束日期格式有误", "合同结束日期格式有误, Err: "+err.Error(), c)
  380. return
  381. }
  382. }
  383. var currencyUnit string
  384. if len(req.List) > 0 {
  385. currencyUnit = req.List[0].CurrencyUnit
  386. }
  387. // 获取销售分组信息
  388. sellerList, e := crmService.GetSellerDepartmentListWithGroupAndTeam()
  389. if e != nil {
  390. resp.FailData("获取销售失败", "Err:"+e.Error(), c)
  391. return
  392. }
  393. sellerMap := make(map[int]*crm.SellerAdminWithGroupTeam)
  394. for i := range sellerList {
  395. sellerMap[sellerList[i].SellerId] = sellerList[i]
  396. }
  397. admin := new(crm.Admin)
  398. sellerIds := strings.Split(req.SellerIds, ",")
  399. if len(sellerIds) > 2 {
  400. resp.Fail("最多只能选择两个销售", c)
  401. return
  402. }
  403. var sellers []*crm.Admin
  404. var pars []interface{}
  405. cond := ``
  406. if len(sellerIds) > 0 {
  407. cond = ` admin_id in (?) `
  408. pars = append(pars, sellerIds)
  409. sellers, e = admin.List(cond, pars)
  410. if e != nil {
  411. resp.FailMsg("获取销售信息失败", "获取销售信息失败, Err: "+e.Error(), c)
  412. return
  413. }
  414. }
  415. //修改合同
  416. ob := new(fms.ContractRegister)
  417. //ob.ContractCode = req.ContractCode
  418. ob.ContractRegisterId = req.ContractRegisterId
  419. ob.CompanyName = req.CompanyName
  420. ob.ProductIds = req.ProductIds
  421. ob.StartDate = startDate
  422. ob.EndDate = endDate
  423. ob.ModifyTime = time.Now().Local()
  424. ob.CurrencyUnit = currencyUnit
  425. if req.RegisterType == fms.ContractInvoiceTypePreMake {
  426. //sellerItem := sellerMap[r.SellerId]
  427. //if sellerItem == nil {
  428. // resp.Fail("销售信息异常", c)
  429. // return
  430. //}
  431. for _, v := range sellers {
  432. if v.DepartmentId == crm.SellerDepartmentId {
  433. ob.SellerId = v.AdminId
  434. ob.SellerName = v.AdminName
  435. } else if v.DepartmentId == crm.RaiSellerDepartmentId {
  436. ob.RaiSellerId = v.AdminId
  437. ob.RaiSellerName = v.AdminName
  438. }
  439. }
  440. }
  441. // 套餐信息
  442. serviceAmountMap := make(map[int]float64)
  443. serviceList, e := fmsService.HandleContractServiceAndDetail(req.Services, true, serviceAmountMap)
  444. if e != nil {
  445. resp.FailMsg("操作失败", "获取合同套餐详情失败, Err: "+e.Error(), c)
  446. return
  447. }
  448. updateCols := []string{
  449. "ProductIds", "CompanyName", "SellerId", "SellerName", "StartDate", "EndDate",
  450. "RaiSellerId", "RaiSellerName", "ModifyTime", "CurrencyUnit",
  451. }
  452. invoiceList := make([]*fms.ContractInvoice, 0)
  453. ppList := make([]*fms.ContractPreRegister, 0)
  454. var sellerItem *crm.SellerAdminWithGroupTeam
  455. for _, r := range req.List {
  456. // 货币及汇率
  457. rateList, e := fmsService.GetTodayCurrencyRateList()
  458. if e != nil {
  459. resp.FailMsg("操作失败", "获取今日货币汇率失败, Err: "+e.Error(), c)
  460. return
  461. }
  462. var rate float64
  463. for i := range rateList {
  464. if r.CurrencyUnit == rateList[i].Code {
  465. rate = rateList[i].RMBRate
  466. break
  467. }
  468. }
  469. if rate <= 0 {
  470. resp.FailMsg("操作失败", "货币汇率信息有误", c)
  471. return
  472. }
  473. registerDate, e := time.Parse(utils.FormatDate, r.RegisterDate)
  474. if e != nil {
  475. resp.FailMsg("日期转换失败", "日期转换失败, Err: "+e.Error(), c)
  476. return
  477. }
  478. v := &fms.ContractInvoice{
  479. ContractInvoiceId: r.InvoiceId,
  480. ContractRegisterId: ob.ContractRegisterId,
  481. OriginAmount: r.Amount,
  482. CurrencyUnit: r.CurrencyUnit,
  483. InvoiceType: req.RegisterType,
  484. InvoiceDate: registerDate,
  485. AdminId: int(adminInfo.AdminId),
  486. AdminName: adminInfo.AdminName,
  487. Remark: r.Remark,
  488. ServiceProductId: r.ServiceProductId,
  489. IsPrePay: 1,
  490. StartDate: startDate,
  491. EndDate: endDate,
  492. }
  493. v.TimeBase.ModifyTime = time.Now().Local()
  494. a, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", v.OriginAmount/rate), 64)
  495. v.Amount = a
  496. sellerItem = sellerMap[r.SellerId]
  497. if sellerItem == nil {
  498. resp.Fail("销售信息异常", c)
  499. return
  500. }
  501. fmt.Println("SellerId",sellerItem.SellerId)
  502. fmt.Println("SellerName",sellerItem.SellerName)
  503. v.SellerId = sellerItem.SellerId
  504. v.SellerName = sellerItem.SellerName
  505. v.SellerGroupId = sellerItem.GroupId
  506. v.SellerGroupName = sellerItem.GroupName
  507. v.SellerTeamId = sellerItem.TeamId
  508. v.SellerTeamName = sellerItem.TeamName
  509. //预登记列表
  510. pp := &fms.ContractPreRegister{
  511. PreRegisterId: r.PreRegisterId,
  512. ContractRegisterId: ob.ContractRegisterId,
  513. CompanyName: req.CompanyName,
  514. InvoiceType: req.RegisterType,
  515. AdminId: int(adminInfo.AdminId),
  516. AdminName: adminInfo.AdminName,
  517. ServiceProductId: r.ServiceProductId,
  518. IsPrePay: 1,
  519. StartDate: startDate,
  520. EndDate: endDate,
  521. TimeBase: base.TimeBase{},
  522. }
  523. pp.Set()
  524. pp.CurrencyUnit = r.CurrencyUnit
  525. ppUpdateCols := make([]string, 0)
  526. if pp.InvoiceType == fms.ContractInvoiceTypePreMake {
  527. //开票走开票字段
  528. pp.Remark = r.Remark
  529. pp.InvoiceDate = registerDate
  530. pp.OriginAmount = r.Amount
  531. a, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", pp.OriginAmount/rate), 64)
  532. pp.Amount = a
  533. sellerItem = sellerMap[r.SellerId]
  534. if sellerItem == nil {
  535. resp.Fail("销售信息异常", c)
  536. return
  537. }
  538. pp.InvoiceId = v.ContractInvoiceId
  539. pp.SellerId = sellerItem.SellerId
  540. pp.SellerName = sellerItem.SellerName
  541. pp.SellerGroupId = sellerItem.GroupId
  542. pp.SellerGroupName = sellerItem.GroupName
  543. pp.SellerTeamId = sellerItem.TeamId
  544. pp.SellerTeamName = sellerItem.TeamName
  545. pp.PaymentSellerId = sellerItem.SellerId
  546. pp.PaymentSellerName = sellerItem.SellerName
  547. pp.PaymentSellerGroupId = sellerItem.GroupId
  548. pp.PaymentSellerGroupName = sellerItem.GroupName
  549. pp.PaymentSellerTeamId = sellerItem.TeamId
  550. pp.PaymentSellerTeamName = sellerItem.TeamName
  551. ppUpdateCols = append(ppUpdateCols, "InvoiceDate", "Amount", "OriginAmount", "SellerId",
  552. "SellerName", "SellerGroupId", "SellerGroupName", "SellerTeamId", "SellerTeamName", "InvoiceId",
  553. "PaymentSellerId", "PaymentSellerName", "PaymentSellerGroupId", "PaymentSellerGroupName", "PaymentSellerTeamId", "PaymentSellerTeamName")
  554. } else {
  555. //到款
  556. pp.ArriveRemark = r.Remark
  557. pp.ArriveDate = registerDate
  558. pp.ArriveId = v.ContractInvoiceId
  559. pp.ArriveOriginAmount = r.Amount
  560. a, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", pp.ArriveOriginAmount/rate), 64)
  561. pp.ArriveAmount = a
  562. sellerItem = sellerMap[r.SellerId]
  563. if sellerItem == nil {
  564. resp.Fail("销售信息异常", c)
  565. return
  566. }
  567. pp.PaymentSellerId = sellerItem.SellerId
  568. pp.PaymentSellerName = sellerItem.SellerName
  569. pp.PaymentSellerGroupId = sellerItem.GroupId
  570. pp.PaymentSellerGroupName = sellerItem.GroupName
  571. pp.PaymentSellerTeamId = sellerItem.TeamId
  572. pp.PaymentSellerTeamName = sellerItem.TeamName
  573. ppUpdateCols = append(ppUpdateCols, "CurrencyUnit", "ArriveDate", "ArriveAmount", "ArriveOriginAmount", "ArriveId",
  574. "PaymentSellerId", "PaymentSellerName", "PaymentSellerGroupId", "PaymentSellerGroupName", "PaymentSellerTeamId", "PaymentSellerTeamName")
  575. }
  576. if pp.PreRegisterId == 0 {
  577. if e = pp.Create(); e != nil {
  578. resp.FailMsg("操作失败", "新增预登记失败, Err: "+e.Error(), c)
  579. return
  580. }
  581. v.PreRegisterId = pp.PreRegisterId
  582. } else {
  583. ppUpdateCols = append(ppUpdateCols,
  584. "CurrencyUnit", "CompanyName", "Remark", "ArriveRemark", "InvoiceTime", "ArriveTime",
  585. "ServiceProductId", "CurrencyUnit", "StartDate", "EndDate", "ModifyTime")
  586. if e = pp.Update(ppUpdateCols); e != nil {
  587. resp.FailMsg("操作失败", "更新预登记记录失败, Err: "+e.Error(), c)
  588. return
  589. }
  590. }
  591. invoiceList = append(invoiceList, v)
  592. ppList = append(ppList, pp)
  593. }
  594. invoiceUpdateCols := []string{
  595. "CurrencyUnit", "OriginAmount", "Amount", "InvoiceDate", "AdminId", "AdminName", "Remark",
  596. "ServiceProductId", "StartDate", "EndDate", "ModifyTime", "SellerId", "SellerName", "SellerGroupId", "SellerGroupName", "SellerTeamId", "SellerTeamName",
  597. }
  598. // 更新合同登记、套餐、开票到款
  599. if e = fms.UpdateContractPreRegister(ob, updateCols, serviceList, invoiceList, invoiceUpdateCols, req.DelInvoiceIds, req.DelPreRegisterIds, ppList, sellerItem, req.RegisterType); e != nil {
  600. resp.FailMsg("操作失败", "更新合同及套餐失败, Err: "+e.Error(), c)
  601. return
  602. }
  603. // 开票到款汇总
  604. go fmsService.SummaryInvoicePaymentByContractRegisterId(ob.ContractRegisterId)
  605. resp.Ok("操作成功", c)
  606. }
  607. // Del
  608. // @Title 删除到款预登记
  609. // @Description 删除到款预登记
  610. // @Param request body fms.ContractRegisterDelReq true "type json string"
  611. // @Success 200 string "操作成功"
  612. // @router /contract/pre_register/del [post]
  613. func (rg *PreRegisterController) Del(c *gin.Context) {
  614. req := new(fms.PreRegisterDelReq)
  615. err := c.ShouldBind(&req)
  616. if err != nil {
  617. errs, ok := err.(validator.ValidationErrors)
  618. if !ok {
  619. resp.FailData("参数解析失败", "Err:"+err.Error(), c)
  620. return
  621. }
  622. resp.FailData("参数解析失败", errs.Translate(global.Trans), c)
  623. return
  624. }
  625. if req.InvoiceId != 0 {
  626. ob := new(fms.ContractInvoice)
  627. item, e := ob.Fetch(req.InvoiceId)
  628. if e != nil {
  629. if e == utils.ErrNoRow {
  630. resp.Fail("合同登记不存在或已被删除", c)
  631. return
  632. }
  633. resp.FailMsg("获取合同登记失败", "Err:"+e.Error(), c)
  634. return
  635. }
  636. e = item.Delete()
  637. if e != nil {
  638. resp.FailMsg("删除记录失败", "Err:"+e.Error(), c)
  639. return
  640. }
  641. }
  642. if req.ArriveId != 0 {
  643. ob := new(fms.ContractInvoice)
  644. item, e := ob.Fetch(req.ArriveId)
  645. if e != nil {
  646. if e == utils.ErrNoRow {
  647. resp.Fail("合同登记不存在或已被删除", c)
  648. return
  649. }
  650. resp.FailMsg("获取合同登记失败", "Err:"+e.Error(), c)
  651. return
  652. }
  653. e = item.Delete()
  654. if e != nil {
  655. resp.FailMsg("删除记录失败", "Err:"+e.Error(), c)
  656. return
  657. }
  658. }
  659. ob := new(fms.ContractPreRegister)
  660. item, e := ob.Fetch(req.PreRegisterId)
  661. if e != nil {
  662. if e == utils.ErrNoRow {
  663. resp.Fail("预登记记录不存在或已被删除", c)
  664. return
  665. }
  666. resp.FailMsg("获取预登记失败", "Err:"+e.Error(), c)
  667. return
  668. }
  669. e = item.Delete()
  670. if e != nil {
  671. resp.FailMsg("删除预登记记录失败", "Err:"+e.Error(), c)
  672. return
  673. }
  674. e = fms.DeleteInvoicePaymentSummaryByInvoiceIdAndPaymentId(req.InvoiceId, req.ArriveId, req.ContractRegisterId)
  675. if e != nil {
  676. resp.FailMsg("删除统计记录失败", "Err:"+e.Error(), c)
  677. return
  678. }
  679. //todo 合同看情况要不要删
  680. resp.Ok("操作成功", c)
  681. }
  682. // Detail
  683. // @Title 预登记记录详情
  684. // @Description 预登记记录详情
  685. // @Param request body fms.PreRegisterDetailReq true "type json string"
  686. // @Success 200 string "操作成功"
  687. // @router /contract/pre_register/detail [post]
  688. func (rg *PreRegisterController) Detail(c *gin.Context) {
  689. req := new(fms.PreRegisterDetailReq)
  690. err := c.ShouldBind(&req)
  691. if err != nil {
  692. errs, ok := err.(validator.ValidationErrors)
  693. if !ok {
  694. resp.FailData("参数解析失败", "Err:"+err.Error(), c)
  695. return
  696. }
  697. resp.FailData("参数解析失败", errs.Translate(global.Trans), c)
  698. return
  699. }
  700. ob := new(fms.ContractRegister)
  701. item, e := ob.Fetch(req.ContractRegisterId)
  702. if e != nil {
  703. if e == utils.ErrNoRow {
  704. resp.Fail("合同登记不存在或已被删除", c)
  705. return
  706. }
  707. resp.FailMsg("获取合同登记失败", "Err:"+e.Error(), c)
  708. return
  709. }
  710. nItme := fms.ContractRegisterItem{
  711. ContractRegisterId: item.ContractRegisterId,
  712. ContractCode: item.ContractCode,
  713. RelateContractCode: item.RelateContractCode,
  714. CrmContractId: item.CrmContractId,
  715. ContractSource: item.ContractSource,
  716. CompanyName: item.CompanyName,
  717. ActualCompanyName: item.ActualCompanyName,
  718. ProductIds: item.ProductIds,
  719. SellerId: item.SellerId,
  720. SellerName: item.SellerName,
  721. RaiSellerId: item.RaiSellerId,
  722. RaiSellerName: item.RaiSellerName,
  723. ContractType: item.ContractType,
  724. ContractAmount: item.ContractAmount,
  725. InvoicedAmount: item.InvoicedAmount,
  726. PaymentAmount: item.PaymentAmount,
  727. CurrencyUnit: item.CurrencyUnit,
  728. RMBRate: item.RMBRate,
  729. StartDate: item.StartDate.Format(utils.FormatDate),
  730. EndDate: item.EndDate.Format(utils.FormatDate),
  731. SignDate: item.SignDate.Format(utils.FormatDate),
  732. AgreedPayTime: item.AgreedPayTime,
  733. ContractStatus: item.ContractStatus,
  734. RegisterStatus: item.RegisterStatus,
  735. Remark: item.Remark,
  736. ServiceRemark: item.ServiceRemark,
  737. HasPayment: item.HasPayment,
  738. NewCompany: item.NewCompany,
  739. CreateTime: item.CreateTime.Format(utils.FormatDateTime),
  740. }
  741. if nItme.StartDate == "0001-01-01" {
  742. nItme.StartDate = ""
  743. }
  744. if nItme.EndDate == "0001-01-01" {
  745. nItme.EndDate = ""
  746. }
  747. cond := ``
  748. pars := make([]interface{}, 0)
  749. if req.InvoiceId == 0 && req.ArriveId == 0 {
  750. cond = `contract_register_id = ? AND invoice_type = ? `
  751. pars = append(pars, req.ContractRegisterId, req.InvoiceType)
  752. } else {
  753. cond = `contract_register_id = ? AND invoice_type = ? AND contract_invoice_id =? `
  754. pars = append(pars, req.ContractRegisterId, req.InvoiceType)
  755. }
  756. if req.InvoiceType == 4 {
  757. pars = append(pars, req.ArriveId)
  758. } else {
  759. pars = append(pars, req.InvoiceId)
  760. }
  761. list, e := fms.GetContractInvoiceDetailItemList(cond, pars)
  762. if e != nil {
  763. err = fmt.Errorf("获取开票到款列表失败, Err: %s", e.Error())
  764. return
  765. }
  766. if req.DetailType == 1 {
  767. dupList, e := fms.GetDuplicateContractInvoiceDetailItemListWithType(nItme.CompanyName, nItme.StartDate, nItme.EndDate, req.InvoiceType)
  768. if e != nil {
  769. err = fmt.Errorf("获取开票到款列表失败, Err: %s", e.Error())
  770. return
  771. }
  772. for _, v := range dupList {
  773. if v.ContractRegisterId != req.ContractRegisterId {
  774. list = append(list, v)
  775. }
  776. }
  777. }
  778. //获取ficc小套餐品种
  779. sysConf := new(system.SysConfig)
  780. confCond := `config_code = ?`
  781. confPars := make([]interface{}, 0)
  782. confPars = append(confPars, system.ConfigKeyCrmPermissionFiccClassify)
  783. confItem, e := sysConf.FetchByCondition(confCond, confPars)
  784. if e != nil {
  785. resp.FailData("获取失败", "Err:"+e.Error(), c)
  786. return
  787. }
  788. if confItem.ConfigValue == "" {
  789. resp.FailData("获取失败", "FICC品种分类配置为空", c)
  790. return
  791. }
  792. classifyArr := strings.Split(confItem.ConfigValue, ",")
  793. if len(classifyArr) == 0 {
  794. resp.FailData("获取失败", "FICC品种分类配置为空", c)
  795. return
  796. }
  797. // 获取FICC权限
  798. ficcCond := `enabled = 1 AND permission_type = 0 AND product_id = ? AND classify_name IN ?`
  799. ficcPars := make([]interface{}, 0)
  800. ficcPars = append(ficcPars, 1, classifyArr)
  801. items, e := crm.GetPermissionSetItemsByCondition(ficcCond, ficcPars)
  802. if e != nil {
  803. resp.FailData("获取失败", "获取FICC权限信息失败, Err: "+e.Error(), c)
  804. return
  805. }
  806. ficcItemMap := make(map[string][]*crm.PermissionSetItem, 0)
  807. for i := range items {
  808. if ficcItemMap[items[i].ClassifyName] == nil {
  809. ficcItemMap[items[i].ClassifyName] = make([]*crm.PermissionSetItem, 0)
  810. }
  811. ficcItemMap[items[i].ClassifyName] = append(ficcItemMap[items[i].ClassifyName], items[i])
  812. }
  813. sTempIdMap := make(map[string]int, 0)
  814. for i := range classifyArr {
  815. if classifyArr[i] == "市场策略" {
  816. continue
  817. }
  818. checkList := make([]int, 0)
  819. if classifyArr[i] == "宏观经济" {
  820. checkList = append(checkList, 1)
  821. }
  822. pItem := fms.ContractServiceTemplateItem{
  823. ServiceTemplateId: 90000 + i*100,
  824. }
  825. ficcItems := ficcItemMap[classifyArr[i]]
  826. for _, ficcItem := range ficcItems {
  827. sTempIdMap[strconv.Itoa(ficcItem.ChartPermissionId)] = pItem.ServiceTemplateId + ficcItem.ChartPermissionId
  828. }
  829. }
  830. services, e := fms.GetContractServiceAndDetailList(req.ContractRegisterId)
  831. if e != nil {
  832. err = fmt.Errorf(fmt.Sprint("查找合同服务异常", e))
  833. return
  834. }
  835. serviceTemplateIdSlice := make([]string, 0)
  836. for _, service := range services {
  837. if service.Title == "FICC小套餐" {
  838. serviceTemplateIdSlice = strings.Split(service.ChartPermissionIds, ",")
  839. }
  840. }
  841. serviceTemplateIds := make([]int, 0)
  842. for _, v := range serviceTemplateIdSlice {
  843. serviceTemplateIds = append(serviceTemplateIds, sTempIdMap[v])
  844. }
  845. respItem := fms.ContractPreRegisterDetail{
  846. ContractRegisterItem: &nItme,
  847. List: list,
  848. Services: services,
  849. ServiceTemplateIds: serviceTemplateIds,
  850. }
  851. resp.OkData("获取成功", respItem, c)
  852. }
  853. // Save
  854. // @Title 预登记保存
  855. // @Description 预登记保存
  856. // @Param request body fms.PrepayAddReq true "type json string"
  857. // @Success 200 string "操作成功"
  858. // @router /contract/pre_register/save [post]
  859. func (rg *PreRegisterController) Save(c *gin.Context) {
  860. req := new(fms.PreRegisterSaveReq)
  861. err := c.ShouldBind(&req)
  862. if err != nil {
  863. errs, ok := err.(validator.ValidationErrors)
  864. if !ok {
  865. resp.FailData("参数解析失败", "Err:"+err.Error(), c)
  866. return
  867. }
  868. resp.FailData("参数解析失败", errs.Translate(global.Trans), c)
  869. return
  870. }
  871. claims, _ := c.Get("adminInfo")
  872. adminInfo := claims.(*system.SysAdmin)
  873. // 日期校验
  874. var startDate, endDate time.Time
  875. if req.StartDate != "" && req.EndDate != "" {
  876. startDate, err = time.ParseInLocation(utils.FormatDate, req.StartDate, time.Local)
  877. if err != nil {
  878. resp.FailMsg("约定开始日期格式有误", "合同开始日期格式有误, Err: "+err.Error(), c)
  879. return
  880. }
  881. endDate, err = time.ParseInLocation(utils.FormatDate, req.EndDate, time.Local)
  882. if err != nil {
  883. resp.FailMsg("约定结束日期格式有误", "合同结束日期格式有误, Err: "+err.Error(), c)
  884. return
  885. }
  886. }
  887. // 获取销售分组信息
  888. sellerList, e := crmService.GetSellerDepartmentListWithGroupAndTeam()
  889. if e != nil {
  890. resp.FailData("获取销售失败", "Err:"+e.Error(), c)
  891. return
  892. }
  893. sellerMap := make(map[int]*crm.SellerAdminWithGroupTeam)
  894. for i := range sellerList {
  895. sellerMap[sellerList[i].SellerId] = sellerList[i]
  896. }
  897. admin := new(crm.Admin)
  898. sellerIds := strings.Split(req.SellerIds, ",")
  899. if len(sellerIds) > 2 {
  900. resp.Fail("最多只能选择两个销售", c)
  901. return
  902. }
  903. var sellers []*crm.Admin
  904. var pars []interface{}
  905. cond := ``
  906. if len(sellerIds) > 0 {
  907. cond = ` admin_id in (?) `
  908. pars = append(pars, sellerIds)
  909. sellers, e = admin.List(cond, pars)
  910. if e != nil {
  911. resp.FailMsg("获取销售信息失败", "获取销售信息失败, Err: "+e.Error(), c)
  912. return
  913. }
  914. }
  915. updateCols := []string{"CompanyName", "ProductIds", "StartDate", "EndDate", "ModifyTime"}
  916. //更新合同
  917. ob := new(fms.ContractRegister)
  918. //ob.ContractCode = req.ContractCode
  919. ob.ContractRegisterId = req.ContractRegisterId
  920. ob.CompanyName = req.CompanyName
  921. ob.ProductIds = req.ProductIds
  922. ob.StartDate = startDate
  923. ob.EndDate = endDate
  924. ob.ModifyTime = time.Now()
  925. ob.CurrencyUnit = req.List[0].CurrencyUnit
  926. if req.RegisterType == fms.ContractInvoiceTypePreMake {
  927. //sellerItem := sellerMap[r.SellerId]
  928. //if sellerItem == nil {
  929. // resp.Fail("销售信息异常", c)
  930. // return
  931. //}
  932. for _, v := range sellers {
  933. if v.DepartmentId == crm.SellerDepartmentId {
  934. ob.SellerId = v.AdminId
  935. ob.SellerName = v.AdminName
  936. updateCols = append(updateCols, "SellerId", "SellerName")
  937. } else if v.DepartmentId == crm.RaiSellerDepartmentId {
  938. ob.RaiSellerId = v.AdminId
  939. ob.RaiSellerName = v.AdminName
  940. updateCols = append(updateCols, "RaiSellerId", "RaiSellerName")
  941. }
  942. }
  943. }
  944. // 套餐信息
  945. serviceAmountMap := make(map[int]float64)
  946. serviceList, e := fmsService.HandleContractServiceAndDetail(req.Services, true, serviceAmountMap)
  947. if e != nil {
  948. resp.FailMsg("操作失败", "获取合同套餐详情失败, Err: "+e.Error(), c)
  949. return
  950. }
  951. invoiceUpdateCols := make([]string, 0)
  952. invoiceHandleType := 0
  953. invoiceList := make([]*fms.ContractInvoice, 0)
  954. ppList := make([]*fms.ContractPreRegister, 0)
  955. for _, r := range req.List {
  956. // 货币及汇率
  957. rateList, e := fmsService.GetTodayCurrencyRateList()
  958. if e != nil {
  959. resp.FailMsg("操作失败", "获取今日货币汇率失败, Err: "+e.Error(), c)
  960. return
  961. }
  962. var rate float64
  963. for i := range rateList {
  964. if r.CurrencyUnit == rateList[i].Code {
  965. rate = rateList[i].RMBRate
  966. break
  967. }
  968. }
  969. if rate <= 0 {
  970. resp.FailMsg("操作失败", "货币汇率信息有误", c)
  971. return
  972. }
  973. registerDate, e := time.Parse(utils.FormatDate, r.RegisterDate)
  974. if e != nil {
  975. resp.FailMsg("日期转换失败", "日期转换失败, Err: "+e.Error(), c)
  976. return
  977. }
  978. v := &fms.ContractInvoice{
  979. ContractInvoiceId: r.InvoiceId,
  980. ContractRegisterId: ob.ContractRegisterId,
  981. OriginAmount: r.Amount,
  982. CurrencyUnit: r.CurrencyUnit,
  983. InvoiceType: req.RegisterType,
  984. InvoiceDate: registerDate,
  985. AdminId: int(adminInfo.AdminId),
  986. AdminName: adminInfo.AdminName,
  987. Remark: r.Remark,
  988. ServiceProductId: r.ServiceProductId,
  989. IsPrePay: 1,
  990. StartDate: startDate,
  991. EndDate: endDate,
  992. TimeBase: base.TimeBase{},
  993. }
  994. v.TimeBase.ModifyTime = time.Now()
  995. a, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", v.OriginAmount/rate), 64)
  996. v.Amount = a
  997. sellerItem := sellerMap[r.SellerId]
  998. if sellerItem == nil {
  999. resp.Fail("销售信息异常", c)
  1000. return
  1001. }
  1002. v.SellerId = sellerItem.SellerId
  1003. v.SellerName = sellerItem.SellerName
  1004. v.SellerGroupId = sellerItem.GroupId
  1005. v.SellerGroupName = sellerItem.GroupName
  1006. v.SellerTeamId = sellerItem.TeamId
  1007. v.SellerTeamName = sellerItem.TeamName
  1008. invoiceUpdateCols = append(invoiceUpdateCols, "SellerId", "SellerName", "SellerGroupId",
  1009. "SellerGroupName", "SellerTeamId", "SellerTeamName")
  1010. // 新增开票到款记录
  1011. if v.ContractInvoiceId != 0 {
  1012. //更新
  1013. invoiceHandleType = 1
  1014. invoiceUpdateCols = append(invoiceUpdateCols, "OriginAmount", "CurrencyUnit",
  1015. "InvoiceDate", "Remark", "ServiceProductId", "StartDate", "EndDate", "ModifyTime")
  1016. } else {
  1017. //新增
  1018. invoiceHandleType = 2
  1019. }
  1020. invoiceList = append(invoiceList, v)
  1021. //预登记列表
  1022. ppUpdateCols := make([]string, 0)
  1023. pp := &fms.ContractPreRegister{
  1024. PreRegisterId: r.PreRegisterId,
  1025. ContractRegisterId: ob.ContractRegisterId,
  1026. CompanyName: req.CompanyName,
  1027. InvoiceType: req.RegisterType,
  1028. InvoiceDate: registerDate,
  1029. AdminId: int(adminInfo.AdminId),
  1030. AdminName: adminInfo.AdminName,
  1031. ServiceProductId: r.ServiceProductId,
  1032. IsPrePay: 1,
  1033. StartDate: startDate,
  1034. EndDate: endDate,
  1035. TimeBase: base.TimeBase{},
  1036. }
  1037. pp.Set()
  1038. pp.CurrencyUnit = r.CurrencyUnit
  1039. if pp.InvoiceType == fms.ContractInvoiceTypePreMake {
  1040. //开票走开票字段
  1041. pp.Remark = r.Remark
  1042. pp.InvoiceDate = registerDate
  1043. pp.OriginAmount = r.Amount
  1044. a, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", pp.OriginAmount/rate), 64)
  1045. pp.Amount = a
  1046. sellerItem := sellerMap[r.SellerId]
  1047. if sellerItem == nil {
  1048. resp.Fail("销售信息异常", c)
  1049. return
  1050. }
  1051. pp.SellerId = sellerItem.SellerId
  1052. pp.SellerName = sellerItem.SellerName
  1053. pp.SellerGroupId = sellerItem.GroupId
  1054. pp.SellerGroupName = sellerItem.GroupName
  1055. pp.SellerTeamId = sellerItem.TeamId
  1056. pp.SellerTeamName = sellerItem.TeamName
  1057. pp.PaymentSellerId = sellerItem.SellerId
  1058. pp.PaymentSellerName = sellerItem.SellerName
  1059. pp.PaymentSellerGroupId = sellerItem.GroupId
  1060. pp.PaymentSellerGroupName = sellerItem.GroupName
  1061. pp.PaymentSellerTeamId = sellerItem.TeamId
  1062. pp.PaymentSellerTeamName = sellerItem.TeamName
  1063. ppUpdateCols = append(ppUpdateCols, "InvoiceDate", "Amount", "OriginAmount", "SellerId",
  1064. "SellerName", "SellerGroupId", "SellerGroupName", "SellerTeamId", "SellerTeamName", "Remark",
  1065. "PaymentSellerId", "PaymentSellerName", "PaymentSellerGroupId", "PaymentSellerGroupName", "PaymentSellerTeamId", "PaymentSellerTeamName")
  1066. } else {
  1067. //到款
  1068. pp.ArriveRemark = r.Remark
  1069. pp.ArriveDate = registerDate
  1070. pp.ArriveOriginAmount = r.Amount
  1071. a, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", pp.ArriveOriginAmount/rate), 64)
  1072. pp.ArriveAmount = a
  1073. sellerItem := sellerMap[r.SellerId]
  1074. if sellerItem == nil {
  1075. resp.Fail("销售信息异常", c)
  1076. return
  1077. }
  1078. pp.PaymentSellerId = sellerItem.SellerId
  1079. pp.PaymentSellerName = sellerItem.SellerName
  1080. pp.PaymentSellerGroupId = sellerItem.GroupId
  1081. pp.PaymentSellerGroupName = sellerItem.GroupName
  1082. pp.PaymentSellerTeamId = sellerItem.TeamId
  1083. pp.PaymentSellerTeamName = sellerItem.TeamName
  1084. ppUpdateCols = append(ppUpdateCols, "ArriveRemark", "CurrencyUnit", "ArriveDate", "ArriveAmount", "ArriveOriginAmount",
  1085. "PaymentSellerId", "PaymentSellerName", "PaymentSellerGroupId", "PaymentSellerGroupName", "PaymentSellerTeamId", "PaymentSellerTeamName")
  1086. }
  1087. ppUpdateCols = append(ppUpdateCols,
  1088. "CompanyName", "AdminId", "AdminName", "ServiceProductId",
  1089. "CurrencyUnit", "StartDate", "EndDate", "ModifyTime")
  1090. if e = pp.Update(ppUpdateCols); e != nil {
  1091. resp.FailMsg("操作失败", "更新预登记记录失败, Err: "+e.Error(), c)
  1092. return
  1093. }
  1094. ppList = append(ppList, pp)
  1095. }
  1096. if e = fms.UpdateContractRegisterPre(ob, updateCols, serviceList, invoiceList, invoiceUpdateCols, invoiceHandleType, ppList); e != nil {
  1097. resp.FailMsg("操作失败", "新增合同及套餐失败, Err: "+e.Error(), c)
  1098. return
  1099. }
  1100. // 开票到款汇总
  1101. go fmsService.SummaryInvoicePaymentByContractRegisterId(ob.ContractRegisterId)
  1102. resp.Ok("操作成功", c)
  1103. }