no message

models/company.go

@@ -67,7 +67,7 @@ func GetCompany() (items []*Company, err error) {
 	return
 }
 
-//待冻结客户
+// 待冻结客户
 type CompanyNeedFreeze struct {
 	CompanyId        int
 	CompanyProductId int
@@ -94,19 +94,19 @@ func GetCompanyNeedLoss(endDate string) (items []*CompanyNeedFreeze, err error)
             FROM  company AS a
 			INNER JOIN company_product AS b ON a.company_id=b.company_id
 			WHERE b.status='冻结'
-			AND b.freeze_end_date<=? `
+			AND b.freeze_end_date<=?  AND b.init_status != '永续'  ` // 权益的永续客户冻结不转流失
 	_, err = o.Raw(sql, endDate).QueryRows(&items)
 	return
 }
 
-//正式
+// 正式
 func GetCompanyNeedTryOut(endDate string) (items []*CompanyNeedFreeze, err error) {
 	o := orm.NewOrm()
 	sql := `SELECT a.company_id,b.company_product_id,b.product_id,a.company_name,b.product_name,b.status
             FROM  company AS a
 			INNER JOIN company_product AS b ON a.company_id=b.company_id
 			WHERE b.status='正式'
-			AND b.end_date<=? `
+			AND b.end_date<=?  AND b.init_status != '永续'  ` //权益的永续客户正式不转试用
 	_, err = o.Raw(sql, endDate).QueryRows(&items)
 	return
 }
@@ -138,3 +138,15 @@ func ModifyCompanyIndustry(industryId, companyId int, industryName string) (err
 	_, err = o.Raw(sql, industryId, industryName, companyId).Exec()
 	return
 }
+
+// 正式
+func GetCompanyNeedTryOutXClassRai(endDate string) (items []*CompanyNeedFreeze, err error) {
+	o := orm.NewOrm()
+	sql := `SELECT a.company_id,b.company_product_id,b.product_id,a.company_name,b.product_name,b.status
+            FROM  company AS a
+			INNER JOIN company_product AS b ON a.company_id=b.company_id
+			WHERE b.status='正式'
+			AND b.end_date<=?  AND b.init_status = '永续'  ` //权益的永续客户正式不转试用
+	_, err = o.Raw(sql, endDate).QueryRows(&items)
+	return
+}

models/company_product.go

@@ -142,6 +142,44 @@ func CompanyTryOut(companyId, productId int) (companyReportPermissionList []*Com
 	return
 }
 
+// 权益正式转X类试用(永续)
+func CompanyTryOutXClassRai(companyId, productId int) (companyReportPermissionList []*CompanyReportPermission, err error) {
+	o := orm.NewOrm()
+	startDate := time.Now().Format(utils.FormatDate)
+	endDate := time.Now().AddDate(0, 3, 0).Format(utils.FormatDate)
+
+	//客户产品 状态 变更
+	sql := `UPDATE company_product SET status='永续',start_date=?,end_date=?,modify_time=NOW(),try_out_time=NOW(),renewal_reason="",package_type=0,try_stage=1 WHERE company_id=? AND product_id=? `
+	_, err = o.Raw(sql, startDate, endDate, companyId, productId).Exec()
+	if err != nil {
+		return
+	}
+
+	//客户产品权限 状态 变更
+	//获取需要变更的 客户产品权限
+	oldPermissionEndDate := time.Now().AddDate(0, 0, -1).Format(utils.FormatDate)
+	sql = `SELECT *
+          FROM company_report_permission
+			WHERE status='正式' AND end_date<=? AND company_id=? AND product_id=? `
+	total, err := o.Raw(sql, oldPermissionEndDate, companyId, productId).QueryRows(&companyReportPermissionList)
+	if err != nil {
+		return
+	}
+	if total > 0 {
+		sql = `UPDATE company_report_permission SET status='永续',start_date=?,end_date=?,modify_time=NOW() 
+			WHERE status='正式' AND end_date<=? AND company_id=? AND product_id=? `
+		_, err = o.Raw(sql, startDate, endDate, oldPermissionEndDate, companyId, productId).Exec()
+		if err != nil {
+			return
+		}
+	}
+
+	//客户状态变更
+	sql = `UPDATE company SET type=2,last_updated_time=NOW(),start_date=?,end_date=? WHERE company_id=? `
+	_, err = o.Raw(sql, startDate, endDate, companyId).Exec()
+	return
+}
+
 func GetCompanyOldDataSync() (items []*Company, err error) {
 	sql := `SELECT * FROM company WHERE company_id NOT IN(
 			SELECT company_id FROM company_product

services/company_contract/company_contract.go

@@ -136,9 +136,9 @@ func HandleCompanyContract(cont context.Context) (err error) {
 		{
 			cygx.YanXuanCompanyApproval(v.CompanyId)
 			cygx.ActivitySpecialCompanyApproval(v.CompanyId, v.CompanyContractId, companyProduct.CompanyName) //审批通过的时候专项调研次数更新
-			cygx.HandleAllocationCompanyContractByYanXuan(v.CompanyContractId)                                //如果合同只有研选的时候，自动处理派点
-			cygx.HandleCompanyContractPackageDifference(v.CompanyContractId)                                  //更新与上一份合同的金额的对比 '增加套餐','减少套餐','维持套餐'
-			cygx.HandleCompanyContractPermissionContractType(v.CompanyContractId)                             //更新合同权限表中的权限名称，以及对应的行业权限类型（行业新签、行业续约）
+			//cygx.HandleAllocationCompanyContractByYanXuan(v.CompanyContractId)                                //如果合同只有研选的时候，自动处理派点
+			cygx.HandleCompanyContractPackageDifference(v.CompanyContractId)      //更新与上一份合同的金额的对比 '增加套餐','减少套餐','维持套餐'
+			cygx.HandleCompanyContractPermissionContractType(v.CompanyContractId) //更新合同权限表中的权限名称，以及对应的行业权限类型（行业新签、行业续约）
 		}
 	}
 

services/company_product.go

@@ -767,3 +767,64 @@ func StaticCompanyTryDay(cont context.Context) (err error) {
 
 	return
 }
+
+// 权益正式客户自动转X类试用(永续)->合同到期未续约转X类试用(永续)
+func CompanyTryOutXClassRai() (err error) {
+	defer func() {
+		if err != nil {
+			go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "正式客户自动试用->合同到期未续约转试用 ErrMsg:"+err.Error(), utils.EmailSendToUsers)
+		}
+	}()
+	endDate := time.Now().AddDate(0, 0, -1).Format(utils.FormatDate)
+	items, err := models.GetCompanyNeedTryOutXClassRai(endDate)
+	if err != nil {
+		fmt.Println("GetCompanyNeedTryOutRai Err:" + err.Error())
+		utils.FileLog.Info("GetCompanyNeedTryOutRai Err:%s" + err.Error())
+		return
+	}
+	for k, v := range items {
+		count, err := models.GetCompanyApprovalCount(v.CompanyId, v.ProductId)
+		if err != nil {
+			return err
+		}
+		if count > 0 {
+			continue
+		}
+		fmt.Println(k, v.CompanyId)
+
+		// 更新专项调研点数,需要在状态变更之前
+		if v.ProductId == 2 {
+			cygx.ActivitySpecialCompanyTryOutReduce(v.CompanyId)
+		}
+		//客户正式转试用
+		companyReportPermissionList, err := models.CompanyTryOutXClassRai(v.CompanyId, v.ProductId)
+		if err != nil {
+			utils.FileLog.Info("CompanyLoss Err:%s" + err.Error())
+			return err
+		}
+		//新增操作记录
+		{
+			remark := "正式转X类试用"
+			operation := "try_out_x_class"
+			approveContent := "X类试用"
+			AddCompanyOperationRecord(v.CompanyId, utils.AdminId, v.ProductId, utils.AdminId, v.CompanyName,
+				v.ProductName, utils.RealName, remark, operation, approveContent, approveContent, "", v.Status)
+
+			//新增 客户产品权限 正式 转 试用 的日志
+			for _, v := range companyReportPermissionList {
+				_ = AddCompanyReportPermissionLog(v.CompanyReportPermissionId, v.CompanyId, v.ProductId, utils.AdminId, v.ProductName, utils.RealName, remark, operation, v.Status)
+			}
+		}
+
+		{
+			//正式转试用，删除不续约归因内容
+			company.DeleteCompanNoRenewedAscribe(v.CompanyId, v.ProductId)
+		}
+
+		//正式转试用定时任务更新研选扣点
+		{
+			cygx.YanXuanCompanyCompanyTryOut(v.CompanyId)
+		}
+	}
+	return
+}