contract_register.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550
  1. package fms
  2. import (
  3. "hongze/fms_api/global"
  4. "hongze/fms_api/models/base"
  5. "hongze/fms_api/utils"
  6. "time"
  7. )
  8. // ContractRegister 合同登记表
  9. type ContractRegister struct {
  10. ContractRegisterId int `gorm:"primaryKey;column:contract_register_id" json:"contract_register_id" description:"登记ID"`
  11. ContractCode string `gorm:"column:contract_code" json:"contract_code" description:"合同编号"`
  12. RelateContractCode string `gorm:"column:relate_contract_code" json:"relate_contract_code" description:"关联合同编号"`
  13. CrmContractId int `gorm:"column:crm_contract_id" json:"crm_contract_id" description:"CRM系统-合同ID"`
  14. ContractSource int `gorm:"column:contract_source" json:"contract_source" description:"合同来源: 0-非系统合同导入; 1-CRM合同导入"`
  15. CompanyName string `gorm:"column:company_name" json:"company_name" description:"客户名称"`
  16. ActualCompanyName string `gorm:"column:actual_company_name" json:"actual_company_name" description:"实际使用方"`
  17. ProductIds string `gorm:"column:product_ids" json:"product_ids" description:"产品ID:1-FICC; 2-权益, 如果两者都有,则用英文逗号拼接"`
  18. SellerId int `gorm:"column:seller_id" json:"seller_id" description:"CRM系统-销售ID"`
  19. SellerName string `gorm:"column:seller_name" json:"seller_name" description:"CRM系统-销售名称"`
  20. RaiSellerId int `gorm:"column:rai_seller_id" json:"rai_seller_id" description:"CRM系统-权益销售ID"`
  21. RaiSellerName string `gorm:"column:rai_seller_name" json:"rai_seller_name" description:"CRM系统-权益销售名称"`
  22. ContractType int `gorm:"column:contract_type" json:"contract_type" description:"合同类型: 1-新签; 2-续约; 3-代付; 4-补充协议"`
  23. ContractAmount float64 `gorm:"column:contract_amount" json:"contract_amount" description:"合同金额"`
  24. InvoicedAmount float64 `gorm:"column:invoiced_amount" json:"invoiced_amount" description:"开票金额"`
  25. PaymentAmount float64 `gorm:"column:payment_amount" json:"payment_amount" description:"到款金额"`
  26. CurrencyUnit string `gorm:"column:currency_unit" json:"currency_unit" description:"货币国际代码"`
  27. RMBRate float64 `gorm:"column:rmb_rate" json:"rmb_rate" description:"人民币汇率(create_time当日)"`
  28. StartDate time.Time `gorm:"column:start_date" json:"start_date" description:"合同开始日期"`
  29. EndDate time.Time `gorm:"column:end_date" json:"end_date" description:"合同结束日期"`
  30. SignDate time.Time `gorm:"column:sign_date" json:"sign_date" description:"合同签订日期"`
  31. AgreedPayTime string `gorm:"column:agreed_pay_time" json:"agreed_pay_time" description:"约定付款时间(如:生效日起10日内)"`
  32. ContractStatus int `gorm:"column:contract_status" json:"contract_status" description:"合同状态: 1-已审批; 2-单章寄出; 3-已签回"`
  33. RegisterStatus int `gorm:"column:register_status" json:"register_status" description:"登记状态: 1-进行中; 2-已完成;"`
  34. Remark string `gorm:"column:remark" json:"remark" description:"备注信息"`
  35. ServiceRemark string `gorm:"column:service_remark" json:"service_remark" description:"套餐备注信息"`
  36. HasPayment int `gorm:"column:has_payment" json:"has_payment" description:"是否有代付: 0-无; 1-有"`
  37. NewCompany int `gorm:"column:new_company" json:"new_company" description:"是否为新客户: 0-否; 1-是"`
  38. IsDeleted int `gorm:"column:is_deleted" json:"is_deleted" description:"是否已删除: 0-正常; 1-已删除"`
  39. base.TimeBase
  40. }
  41. func (c *ContractRegister) TableName() string {
  42. return "contract_register"
  43. }
  44. func (c *ContractRegister) Create() (err error) {
  45. err = global.DEFAULT_MYSQL.Create(c).Error
  46. return
  47. }
  48. func (c *ContractRegister) AddInBatches(list []*ContractRegister) (err error) {
  49. err = global.DEFAULT_MYSQL.CreateInBatches(list, len(list)).Error
  50. return
  51. }
  52. func (c *ContractRegister) Update(updateCols []string) (err error) {
  53. err = global.DEFAULT_MYSQL.Model(c).Select(updateCols).Updates(c).Error
  54. return
  55. }
  56. func (c *ContractRegister) Fetch(id int) (item *ContractRegister, err error) {
  57. err = global.DEFAULT_MYSQL.Model(c).Where("is_deleted = 0 AND contract_register_id = ?", id).First(&item).Error
  58. return
  59. }
  60. func (c *ContractRegister) FetchByCondition(condition string, pars []interface{}) (item *ContractRegister, err error) {
  61. err = global.DEFAULT_MYSQL.Model(c).
  62. Where("is_deleted = 0").
  63. Where(condition, pars...).
  64. First(&item).Error
  65. return
  66. }
  67. func (c *ContractRegister) List(condition string, pars []interface{}) (list []*ContractRegister, err error) {
  68. list = make([]*ContractRegister, 0)
  69. err = global.DEFAULT_MYSQL.Model(c).
  70. Where("is_deleted = 0").
  71. Where(condition, pars...).
  72. Find(&list).Error
  73. return
  74. }
  75. func (c *ContractRegister) PageList(page base.IPage, condition string, pars []interface{}) (count int64, results []*ContractRegister, err error) {
  76. results = make([]*ContractRegister, 0)
  77. query := global.DEFAULT_MYSQL.Model(c).
  78. Where("is_deleted = 0").
  79. Where(condition, pars...)
  80. query.Count(&count)
  81. if len(page.GetOrderItemsString()) > 0 {
  82. query = query.Order(page.GetOrderItemsString())
  83. }
  84. err = query.Limit(int(page.GetPageSize())).Offset(int(page.Offset())).Find(&results).Error
  85. return
  86. }
  87. // ContractRegisterListReq 合同登记列表请求体
  88. type ContractRegisterListReq struct {
  89. Keyword string `json:"keyword" form:"keyword" binding:"omitempty" description:"关键词"`
  90. StartDate string `json:"start_date" form:"start_date" binding:"omitempty,datetime=2006-01-02" description:"合同开始日期"`
  91. EndDate string `json:"end_date" form:"end_date" binding:"omitempty,datetime=2006-01-02" description:"合同结束日期"`
  92. ServiceTypes string `json:"service_types" form:"service_types" description:"套餐类型"`
  93. ContractType int `json:"contract_type" form:"contract_type" description:"合同类型"`
  94. RegisterStatus int `json:"register_status" form:"register_status" description:"登记状态"`
  95. base.PageReq
  96. }
  97. // ContractRegisterItem 合同登记
  98. type ContractRegisterItem struct {
  99. ContractRegisterId int `json:"contract_register_id" description:"登记ID"`
  100. ContractCode string `json:"contract_code" description:"合同编号"`
  101. RelateContractCode string `json:"relate_contract_code" description:"关联合同编号"`
  102. CrmContractId int `json:"crm_contract_id" description:"CRM系统-合同ID"`
  103. ContractSource int `json:"contract_source" description:"合同来源: 0-非系统合同导入; 1-CRM合同导入"`
  104. CompanyName string `json:"company_name" description:"客户名称"`
  105. ActualCompanyName string `json:"actual_company_name" description:"实际使用方"`
  106. ProductIds string `json:"product_ids" description:"产品ID:1-FICC; 2-权益, 如果两者都有,则用英文逗号拼接"`
  107. SellerId int `json:"seller_id" description:"CRM系统-销售ID"`
  108. SellerName string `json:"seller_name" description:"CRM系统-销售名称"`
  109. RaiSellerId int `json:"rai_seller_id" description:"CRM系统-权益销售ID"`
  110. RaiSellerName string `json:"rai_seller_name" description:"CRM系统-权益销售名称"`
  111. ContractType int `json:"contract_type" description:"合同类型: 1-新签; 2-续约"`
  112. ContractAmount float64 `json:"contract_amount" description:"合同金额"`
  113. InvoicedAmount float64 `json:"invoiced_amount" description:"开票金额"`
  114. PaymentAmount float64 `json:"payment_amount" description:"到款金额"`
  115. CurrencyUnit string `json:"currency_unit" description:"货币国际代码"`
  116. RMBRate float64 `json:"rmb_rate" description:"人民币汇率(create_time当日)"`
  117. StartDate string `json:"start_date" description:"合同开始日期"`
  118. EndDate string `json:"end_date" description:"合同结束日期"`
  119. SignDate string `json:"sign_date" description:"合同签订日期"`
  120. AgreedPayTime string `json:"agreed_pay_time" description:"约定付款时间(如:生效日起10日内)"`
  121. ContractStatus int `json:"contract_status" description:"合同状态: 1-已审批; 2-单章寄出; 3-已签回"`
  122. RegisterStatus int `json:"register_status" description:"登记状态: 1-进行中; 2-已完成;"`
  123. Remark string `json:"remark" description:"备注信息"`
  124. ServiceRemark string `json:"service_remark" description:"套餐备注信息"`
  125. HasPayment int `json:"has_payment" description:"是否有代付: 0-无; 1-有"`
  126. NewCompany int `json:"new_company" description:"是否为新客户: 0-否; 1-是"`
  127. CreateTime string `json:"create_time" description:"登记时间"`
  128. }
  129. // ContractRegisterList 合同登记列表
  130. type ContractRegisterList struct {
  131. *ContractRegisterItem
  132. ServicesName string `json:"services" description:"套餐名称"`
  133. InvoiceList []*ContractInvoiceItem `json:"invoice_list" description:"开票信息"`
  134. PaymentList []*ContractInvoiceItem `json:"payment_list" description:"到款信息"`
  135. }
  136. // ContractRegisterDelReq 合同登记-删除请求体
  137. type ContractRegisterDelReq struct {
  138. ContractRegisterId int `json:"contract_register_id" binding:"required,gte=1" description:"登记ID"`
  139. }
  140. // ContractRegisterUpdateStatusReq 合同登记-修改合同状态请求体
  141. type ContractRegisterUpdateStatusReq struct {
  142. ContractRegisterId int `json:"contract_register_id" binding:"required,gte=1" description:"登记ID"`
  143. ContractStatus int `json:"contract_status" binding:"oneof=1 2 3 4 5" description:"合同状态: 1-已审批; 2-单章寄出; 3-已签回; 4-已终止, 5-邮件备案"`
  144. }
  145. // ContractRegisterAddReq 新增合同登记请求体
  146. type ContractRegisterAddReq struct {
  147. ContractCode string `json:"contract_code" binding:"required" description:"合同编号"`
  148. RelateContractCode string `json:"relate_contract_code" description:"关联合同编号"`
  149. CrmContractId int `json:"crm_contract_id" description:"CRM系统-合同ID"`
  150. ContractSource int `json:"contract_source" binding:"oneof=0 1" description:"合同来源: 0-非系统合同导入; 1-CRM合同导入"`
  151. CompanyName string `json:"company_name" binding:"required" description:"客户名称"`
  152. ActualCompanyName string `json:"actual_company_name" description:"实际使用方"`
  153. SellerIds string `json:"seller_ids" binding:"required" description:"CRM系统-销售ID"`
  154. ContractType int `json:"contract_type" binding:"oneof=1 2 3 4" description:"合同类型: 1-新签; 2-续约; 3-代付; 4-补充协议"`
  155. ContractAmount float64 `json:"contract_amount" binding:"required" description:"合同金额"`
  156. CurrencyUnit string `json:"currency_unit" binding:"required" description:"货币单位"`
  157. StartDate string `json:"start_date" binding:"required" description:"合同开始日期"`
  158. EndDate string `json:"end_date" binding:"required" description:"合同结束日期"`
  159. SignDate string `json:"sign_date" description:"合同签订日期"`
  160. AgreedPayTime string `json:"agreed_pay_time" description:"约定付款时间(如:生效日起10日内)"`
  161. ContractStatus int `json:"contract_status" binding:"oneof=1 2 3 4 5" description:"合同状态: 1-已审批; 2-单章寄出; 3-已签回; 4-已终止; 5-邮件备案"`
  162. Remark string `json:"remark" description:"备注信息"`
  163. ProductIds string `json:"product_ids" description:"产品ID:1-FICC; 2-权益, 如果两者都有,则用英文逗号拼接"`
  164. ServiceRemark string `json:"service_remark" description:"套餐备注"`
  165. HasPayment int `json:"has_payment" description:"是否有代付: 0-无; 1-有"`
  166. NewCompany int `json:"new_company" description:"是否为新客户: 0-否; 1-是"`
  167. Supplement int `json:"supplement" description:"是否为补录合同: 0-否; 1-是"`
  168. PrePayId int `json:"pre_pay_id" description:"预到款信息ID"`
  169. Services []ContractServiceAddReq `json:"services" description:"服务套餐内容"`
  170. ServiceAmount []ContractServiceAmountAddReq `json:"service_amount" description:"服务套餐金额"`
  171. }
  172. // ContractRegisterEditReq 编辑合同登记请求体
  173. type ContractRegisterEditReq struct {
  174. ContractRegisterId int `json:"contract_register_id" binding:"required,gte=1" description:"登记ID"`
  175. ContractRegisterAddReq
  176. }
  177. // CreateContractRegisterAndServices 新增合同登记及套餐
  178. func CreateContractRegisterAndServices(item *ContractRegister, serviceDetail []*ContractServiceAndDetail, serviceAmount []*ContractServiceAmount) (err error) {
  179. tx := global.DEFAULT_MYSQL.Begin()
  180. defer func() {
  181. if err != nil {
  182. tx.Rollback()
  183. } else {
  184. tx.Commit()
  185. }
  186. }()
  187. // 合同登记
  188. tx.Create(item)
  189. //nowTime := time.Now().Local()
  190. for i := 0; i < len(serviceDetail); i++ {
  191. // 合同服务
  192. t := serviceDetail[i]
  193. contractService := &ContractService{
  194. ContractRegisterId: item.ContractRegisterId,
  195. ProductId: t.ProductId,
  196. ServiceTemplateId: t.ServiceTemplateId,
  197. Title: t.Title,
  198. Value: t.Value,
  199. TableValue: t.TableValue,
  200. HasDetail: t.HasDetail,
  201. ChartPermissionId: t.ChartPermissionId,
  202. ChartPermissionIds: t.ChartPermissionIds,
  203. }
  204. contractService.Set()
  205. tx.Create(contractService)
  206. //// 合同服务详情
  207. //for j := 0; j < len(t.Detail); j++ {
  208. // contractServiceDetail := t.Detail[j]
  209. // contractServiceDetail.ContractServiceId = contractService.ContractServiceId
  210. // contractServiceDetail.ContractRegisterId = item.ContractRegisterId
  211. // contractServiceDetail.ServiceTemplateId = contractService.ServiceTemplateId
  212. // contractServiceDetail.CreateTime = nowTime
  213. // tx.Create(contractServiceDetail)
  214. // t.Detail[j] = contractServiceDetail
  215. //}
  216. }
  217. for i := 0; i < len(serviceAmount); i++ {
  218. // 合同服务
  219. t := serviceAmount[i]
  220. tmp := &ContractServiceAmount{
  221. ContractRegisterId: item.ContractRegisterId,
  222. ProductId: t.ProductId,
  223. ServiceAmount: t.ServiceAmount,
  224. CurrencyUnit: t.CurrencyUnit,
  225. }
  226. tx.Create(tmp)
  227. }
  228. return
  229. }
  230. // UpdateContractRegister 更新合同登记
  231. func UpdateContractRegister(item *ContractRegister, updateCols []string, serviceDetail []*ContractServiceAndDetail,
  232. invoiceList []*ContractInvoice, invoiceUpdateCols []string, invoiceHandleType int, serviceAmount []*ContractServiceAmount) (err error) {
  233. tx := global.DEFAULT_MYSQL.Begin()
  234. defer func() {
  235. if err != nil {
  236. tx.Rollback()
  237. } else {
  238. tx.Commit()
  239. }
  240. }()
  241. // 更新合同登记
  242. if e := tx.Model(item).Select(updateCols).Updates(item).Error; e != nil {
  243. err = e
  244. return
  245. }
  246. // 删除原服务及详情信息
  247. sql := `DELETE FROM contract_service WHERE contract_register_id = ?`
  248. tx.Exec(sql, item.ContractRegisterId)
  249. sql = `DELETE FROM contract_service_detail WHERE contract_register_id = ?`
  250. tx.Exec(sql, item.ContractRegisterId)
  251. sql = `DELETE FROM contract_service_amount WHERE contract_register_id = ?`
  252. tx.Exec(sql, item.ContractRegisterId)
  253. // 新增合同服务
  254. //nowTime := time.Now().Local()
  255. for i := 0; i < len(serviceDetail); i++ {
  256. // 合同服务
  257. t := serviceDetail[i]
  258. contractService := &ContractService{
  259. ContractRegisterId: item.ContractRegisterId,
  260. ProductId: t.ProductId,
  261. ServiceTemplateId: t.ServiceTemplateId,
  262. Title: t.Title,
  263. Value: t.Value,
  264. TableValue: t.TableValue,
  265. HasDetail: t.HasDetail,
  266. ChartPermissionId: t.ChartPermissionId,
  267. ChartPermissionIds: t.ChartPermissionIds,
  268. }
  269. contractService.Set()
  270. tx.Create(contractService)
  271. //// 合同服务详情
  272. //for j := 0; j < len(t.Detail); j++ {
  273. // contractServiceDetail := t.Detail[j]
  274. // contractServiceDetail.ContractServiceId = contractService.ContractServiceId
  275. // contractServiceDetail.ContractRegisterId = item.ContractRegisterId
  276. // contractServiceDetail.ServiceTemplateId = contractService.ServiceTemplateId
  277. // contractServiceDetail.CreateTime = nowTime
  278. // tx.Create(contractServiceDetail)
  279. // t.Detail[j] = contractServiceDetail
  280. //}
  281. }
  282. for i := 0; i < len(serviceAmount); i++ {
  283. // 合同服务
  284. t := serviceAmount[i]
  285. tmp := &ContractServiceAmount{
  286. ContractRegisterId: item.ContractRegisterId,
  287. ProductId: t.ProductId,
  288. ServiceAmount: t.ServiceAmount,
  289. CurrencyUnit: t.CurrencyUnit,
  290. }
  291. tx.Create(tmp)
  292. }
  293. // 开票到款操作类型: 0-无; 1-更新; 2-删除;
  294. if invoiceHandleType == 2 {
  295. sql = `UPDATE contract_invoice SET is_deleted = 1 WHERE contract_register_id = ?`
  296. if e := tx.Exec(sql, item.ContractRegisterId).Error; e != nil {
  297. err = e
  298. return
  299. }
  300. }
  301. if invoiceHandleType == 1 {
  302. for i := range invoiceList {
  303. if e := tx.Model(invoiceList[i]).Select(invoiceUpdateCols).Updates(invoiceList[i]).Error; e != nil {
  304. err = e
  305. return
  306. }
  307. }
  308. }
  309. return
  310. }
  311. // ContractRegisterDetailReq 合同登记-详情请求体
  312. type ContractRegisterDetailReq struct {
  313. ContractRegisterId int `json:"contract_register_id" form:"contract_register_id" binding:"required,gte=1"`
  314. }
  315. // ContractRegisterDetail-合同登记详情
  316. type ContractRegisterDetail struct {
  317. *ContractRegisterItem
  318. ServiceList []*ContractServiceAndDetail `json:"service_list" description:"合同服务及详情"`
  319. InvoiceList []*ContractInvoiceItem `json:"invoice_list" description:"开票信息"`
  320. PaymentList []*ContractInvoiceItem `json:"payment_list" description:"到款信息"`
  321. Logs []*ContractRegisterLogItem `json:"logs" description:"登记日志"`
  322. ServiceAmountList []*ContractServiceAmountItem `json:"service_amount_list" description:"合同套餐金额"`
  323. }
  324. // GetContractRegisterItemById 获取合同登记信息
  325. func GetContractRegisterItemById(id int) (result *ContractRegisterItem, err error) {
  326. item := new(ContractRegister)
  327. err = global.DEFAULT_MYSQL.Model(ContractRegister{}).
  328. Where("is_deleted = 0 AND contract_register_id = ?", id).
  329. First(&item).Error
  330. if err != nil && err != utils.ErrNoRow {
  331. return
  332. }
  333. result = formatContractRegister2Item(item)
  334. return
  335. }
  336. // GetContractRegisterItemPageList 获取合同登记列表-分页
  337. func GetContractRegisterItemPageList(page base.IPage, condition string, pars []interface{}) (count int64, results []*ContractRegisterItem, err error) {
  338. list := make([]*ContractRegister, 0)
  339. query := global.DEFAULT_MYSQL.Table("contract_register").
  340. Where("is_deleted = 0").
  341. Where(condition, pars...)
  342. query.Count(&count)
  343. if len(page.GetOrderItemsString()) > 0 {
  344. query = query.Order(page.GetOrderItemsString())
  345. }
  346. err = query.Limit(int(page.GetPageSize())).Offset(int(page.Offset())).Find(&list).Error
  347. if err != nil {
  348. return
  349. }
  350. for i := range list {
  351. results = append(results, formatContractRegister2Item(list[i]))
  352. }
  353. return
  354. }
  355. // formatContractRegister2Item 格式化ContractRegister
  356. func formatContractRegister2Item(item *ContractRegister) (formatItem *ContractRegisterItem) {
  357. formatItem = new(ContractRegisterItem)
  358. formatItem.ContractRegisterId = item.ContractRegisterId
  359. formatItem.ContractCode = item.ContractCode
  360. formatItem.RelateContractCode = item.RelateContractCode
  361. formatItem.CrmContractId = item.CrmContractId
  362. formatItem.ContractSource = item.ContractSource
  363. formatItem.CompanyName = item.CompanyName
  364. formatItem.ActualCompanyName = item.ActualCompanyName
  365. formatItem.ProductIds = item.ProductIds
  366. formatItem.SellerId = item.SellerId
  367. formatItem.SellerName = item.SellerName
  368. formatItem.RaiSellerId = item.RaiSellerId
  369. formatItem.RaiSellerName = item.RaiSellerName
  370. formatItem.ContractType = item.ContractType
  371. formatItem.ContractAmount = item.ContractAmount
  372. formatItem.InvoicedAmount = item.InvoicedAmount
  373. formatItem.PaymentAmount = item.PaymentAmount
  374. formatItem.CurrencyUnit = item.CurrencyUnit
  375. formatItem.RMBRate = item.RMBRate
  376. formatItem.StartDate = utils.TimeTransferString(utils.FormatDate, item.StartDate)
  377. formatItem.EndDate = utils.TimeTransferString(utils.FormatDate, item.EndDate)
  378. formatItem.SignDate = utils.TimeTransferString(utils.FormatDate, item.SignDate)
  379. formatItem.AgreedPayTime = item.AgreedPayTime
  380. formatItem.ContractStatus = item.ContractStatus
  381. formatItem.RegisterStatus = item.RegisterStatus
  382. formatItem.Remark = item.Remark
  383. formatItem.ServiceRemark = item.ServiceRemark
  384. formatItem.HasPayment = item.HasPayment
  385. formatItem.NewCompany = item.NewCompany
  386. formatItem.CreateTime = utils.TimeTransferString(utils.FormatDateTime, item.CreateTime)
  387. return
  388. }
  389. // CreateImportContractRegister 新增导入的合同登记及套餐、开票到款信息
  390. func CreateImportContractRegister(item *ContractRegister, serviceList []*ContractService, invoiceList []*ContractInvoice, serviceAmountList []*ContractServiceAmount) (newId int, err error) {
  391. tx := global.DEFAULT_MYSQL.Begin()
  392. defer func() {
  393. if err != nil {
  394. tx.Rollback()
  395. } else {
  396. tx.Commit()
  397. }
  398. }()
  399. // 新增合同登记
  400. if e := tx.Create(item).Error; e != nil {
  401. err = e
  402. return
  403. }
  404. newId = item.ContractRegisterId
  405. // 新增套餐
  406. if len(serviceList) > 0 {
  407. // 过滤重复的数组
  408. serviceMap := make(map[int]struct{})
  409. addServiceList := make([]*ContractService, 0)
  410. for i := range serviceList {
  411. if _, ok := serviceMap[serviceList[i].ServiceTemplateId]; !ok {
  412. serviceList[i].ContractRegisterId = newId
  413. addServiceList = append(addServiceList, serviceList[i])
  414. serviceMap[serviceList[i].ServiceTemplateId] = struct{}{}
  415. }
  416. }
  417. if e := tx.CreateInBatches(addServiceList, len(addServiceList)).Error; e != nil {
  418. err = e
  419. return
  420. }
  421. }
  422. // 新增合同套餐金额相关信息
  423. if len(serviceAmountList) > 0 {
  424. for i := range serviceAmountList {
  425. serviceAmountList[i].ContractRegisterId = newId
  426. }
  427. if e := tx.CreateInBatches(serviceAmountList, len(serviceAmountList)).Error; e != nil {
  428. err = e
  429. return
  430. }
  431. }
  432. // 新增开票/到款
  433. if len(invoiceList) > 0 {
  434. for i := range invoiceList {
  435. invoiceList[i].ContractRegisterId = newId
  436. }
  437. if e := tx.CreateInBatches(invoiceList, len(invoiceList)).Error; e != nil {
  438. err = e
  439. return
  440. }
  441. }
  442. return
  443. }
  444. func GetContractInfoByRegisterIds(registerIds []int) (list []ContractRegister,err error) {
  445. err = global.DEFAULT_MYSQL.Model(ContractRegister{}).
  446. Where("is_deleted = 0 AND contract_register_id in ?", registerIds).
  447. Find(&list).Error
  448. return
  449. }
  450. // CreateContractRegisterAndServices 新增合同登记及套餐
  451. func CreateContractRegisterAndServicesAndPayMent(item *ContractRegister, serviceDetail []*ContractServiceAndDetail, prePayId int) (err error) {
  452. tx := global.DEFAULT_MYSQL.Begin()
  453. defer func() {
  454. if err != nil {
  455. tx.Rollback()
  456. } else {
  457. tx.Commit()
  458. }
  459. }()
  460. // 合同登记
  461. tx.Create(item)
  462. //nowTime := time.Now().Local()
  463. for i := 0; i < len(serviceDetail); i++ {
  464. // 合同服务
  465. t := serviceDetail[i]
  466. contractService := &ContractService{
  467. ContractRegisterId: item.ContractRegisterId,
  468. ProductId: t.ProductId,
  469. ServiceTemplateId: t.ServiceTemplateId,
  470. Title: t.Title,
  471. Value: t.Value,
  472. TableValue: t.TableValue,
  473. HasDetail: t.HasDetail,
  474. ChartPermissionId: t.ChartPermissionId,
  475. ChartPermissionIds: t.ChartPermissionIds,
  476. }
  477. contractService.Set()
  478. tx.Create(contractService)
  479. //// 合同服务详情
  480. //for j := 0; j < len(t.Detail); j++ {
  481. // contractServiceDetail := t.Detail[j]
  482. // contractServiceDetail.ContractServiceId = contractService.ContractServiceId
  483. // contractServiceDetail.ContractRegisterId = item.ContractRegisterId
  484. // contractServiceDetail.ServiceTemplateId = contractService.ServiceTemplateId
  485. // contractServiceDetail.CreateTime = nowTime
  486. // tx.Create(contractServiceDetail)
  487. // t.Detail[j] = contractServiceDetail
  488. //}
  489. }
  490. return
  491. }
  492. type CheckContractNameReq struct {
  493. CompanyName string `json:"company_name" form:"company_name" description:"客户名称"`
  494. StartDate string `json:"start_date" form:"start_date" description:"合同开始日期"`
  495. EndDate string `json:"end_date" form:"end_date" description:"合同结束日期"`
  496. }
  497. type CheckContractNameResp struct {
  498. Exist int `json:"exist" description:"是否存在相似的合同:0不存在,1存在"`
  499. }