gym body check

conf/app.conf

@@ -7,6 +7,12 @@ EnableDocs = true
 excelpath = ./
 clienturl = http://dev.ycjcjy.com/c-v2
 
+postwechatInfo = http://testapi.chioy.com.cn/api/network/postwechatInfo
+qrcodePrefix = bodycheck_
+followText = 您正在使用悦琦设备进行体检~
+resultURL = http://dev.ycjcjy.com/bodyCheck
+
+
 
 [cros]
 allowMode = dev
@@ -16,6 +22,7 @@ allowOrigin = http://localhost:9528
 # GET, POST etc
 allowMethods = *
 
+
 [api]
 prefix = "/api"
 guest = "/guest/:org"

controllers/gymcard/gymcard.go

@@ -119,6 +119,19 @@ func (c *GymcardController) SendGymToCustomer() {
 	c.ResponseJSON(customerGym)
 }
 
+// SendGymToCustomer 后台发卡给客户
+func (c *GymcardController) BackSendGymToCustomer() {
+	gymcardId := c.GetString(":gymcardId")
+	customerId := c.GetString(":customerId")
+	sysUser := c.Context.Get("user").(model.SysUser)
+	userId := sysUser.UserId
+	customerGym, err := c.dao.BackSendGymCardToUser(gymcardId, userId, customerId)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(customerGym)
+}
+
 // VerifyCustomerGymcard 核销客户健身卡
 func (c *GymcardController) VerifyCustomerGymcard() {
 	cases := c.Context.Get("cases").([]model.SysUserCase)

models/bodycheck/bodycheck.go

@@ -0,0 +1,161 @@
+package bodycheck
+
+import (
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strconv"
+	"time"
+
+	"github.com/go-xorm/xorm"
+)
+
+// DAO 当前数据库操作对象
+type DAO struct {
+	ctx *utils.Context
+	db  *xorm.Session
+}
+
+// NewDAO 初始化DAO
+func NewDAO(ctx *utils.Context) *DAO {
+	return &DAO{
+		ctx: ctx,
+		db:  ctx.DB,
+	}
+}
+
+// GetBodyCheckByUser 根据用户信息获取体检信息
+func (m *DAO) GetBodyCheckByUser(userID int) ([]model.TaBodyCheck, error) {
+	var bodychecks []model.TaBodyCheck
+	var err error
+	err = m.db.Where("user_id=?", userID).And("status=?", 1).Desc("create_date").Find(&bodychecks)
+	return bodychecks, err
+}
+
+// GetCheckSpecs 获取项目指标信息
+func (m *DAO) GetCheckSpecs() ([]model.TdCheckSpec, error) {
+	var specs []model.TdCheckSpec
+	err := m.db.Find(&specs)
+	return specs, err
+}
+
+// GetCheckByUserAndEquipmentID 根据用户与设备ID获取体检信息
+func (m *DAO) GetCheckByUserAndEquipmentID(userID int, EquipmentID string) (*model.TaBodyCheck, error) {
+	var check []model.TaBodyCheck
+	err := m.db.Where("user_id=?", userID).And("equipment_id=?", EquipmentID).And("status=?", 1).Desc("create_date").Find(&check)
+	if err != nil {
+		return nil, err
+	}
+	if len(check) > 0 {
+		return &check[0], nil
+	}
+	return nil, nil
+}
+
+// SaveBodyCheckInfo 用户体检信息新增
+func (m *DAO) SaveBodyCheckInfo(checkNew model.TaBodyCheck) (*model.TaBodyCheck, error) {
+	checkNew.Status = 1
+	// checkNew.CreateDate = time.Now()
+	_, err := m.db.Insert(&checkNew)
+	return &checkNew, err
+}
+
+// SaveUser 新增用户信息
+func (m *DAO) SaveUser(user model.TaCustomer) (*model.TaCustomer, error) {
+	user.CreateDate = time.Now()
+	_, err := m.db.Insert(&user)
+	return &user, err
+}
+
+// GetCaseEquipment 获取设备案场信息
+func (m *DAO) GetCaseEquipment(EquipmentID string) (*model.TaCaseEquipment, error) {
+	var caseEquipment model.TaCaseEquipment
+
+	_, err := m.db.Where("equipment_id=?", EquipmentID).And("status=?", 1).Get(&caseEquipment)
+	return &caseEquipment, err
+}
+
+// GetUserByOpenID 根据openid获取用户信息
+func (m *DAO) GetUserByOpenID(openid string) (*model.TaCustomer, error) {
+	var user model.TaCustomer
+	_, err := m.db.Where("open_id=?", openid).Get(&user)
+	return &user, err
+}
+
+// GetCustomerByID 根据客户ID 获取用户信息
+func (m *DAO) GetCustomerByID(id int) (*model.TaCustomer, error) {
+	var cust model.TaCustomer
+	_, err := m.db.Where("id=?", id).Get(&cust)
+	return &cust, err
+}
+
+type Presentation struct {
+	model.TaPresentation `xorm:"extends"`
+	TypeName             string
+	Details              []model.TaPresentationDetail
+}
+
+// GetPresentationByCheckID 根据体检ID获取项目信息
+func (m *DAO) GetPresentationByCheckID(checkID int) ([]Presentation, error) {
+	var presentations []Presentation
+	sql := `select a.*,b.type_name from ta_presentation a inner join td_check_type b on a.check_type=b.id where a.check_id=` + strconv.Itoa(checkID)
+
+	err := m.db.Sql(sql).Find(&presentations)
+	if err != nil {
+		return nil, err
+	}
+	var Info []Presentation
+	for _, presentation := range presentations {
+		details, err := m.GetDetailsByPresentID(presentation.Id)
+		if err != nil {
+			return nil, err
+		}
+		presentation.Details = details
+		Info = append(Info, presentation)
+	}
+
+	return Info, nil
+}
+
+// GetDetailsByPresentID 根据项目ID获取详情
+func (m *DAO) GetDetailsByPresentID(ID int) ([]model.TaPresentationDetail, error) {
+	var details []model.TaPresentationDetail
+	err := m.db.Where("presentation_id=?", ID).Find(&details)
+	return details, err
+}
+
+// GetPresentation 获取体检项目信息
+func (m *DAO) GetPresentation(checkID, typeID int) (*model.TaPresentation, error) {
+	var presentation model.TaPresentation
+	_, err := m.db.Where("check_id=?", checkID).And("check_type=?", typeID).Get(&presentation)
+	return &presentation, err
+}
+
+// SavePresentation 新增体检项目信息
+func (m *DAO) SavePresentation(info model.TaPresentation) (*model.TaPresentation, error) {
+	_, err := m.db.Insert(&info)
+	return &info, err
+}
+
+// UpdatePresentation 更新体检项目信息
+func (m *DAO) UpdatePresentation(info *model.TaPresentation) error {
+	cols := []string{
+		"check_date",
+		"check_result",
+		"report_url",
+	}
+	_, err := m.db.Update(info, cols, "id=?", info.Id)
+	return err
+}
+
+// SavePresentationDetail 保存体检项目明细
+func (m *DAO) SavePresentationDetail(details []model.TaPresentationDetail) error {
+	_, err := m.db.Insert(&details)
+	return err
+}
+
+// DeletePresentionDetail 根据项目ID删除明细信息
+func (m *DAO) DeletePresentionDetail(ID int) error {
+	sql := "delete from ta_presentation_detail where presentation_id=" + strconv.Itoa(ID)
+	_, err := m.db.Exec(sql)
+	return err
+}

routers/common.go

@@ -179,6 +179,7 @@ func getCommonRoutes() beego.LinkNamespace {
 		beego.NSRouter("/gymcard", &gymcard.GymcardController{}, "post:SaveGymcard"),
 		beego.NSRouter("/gymcard", &gymcard.GymcardController{}, "put:SaveGymcard"),
 		beego.NSRouter("/gymcard/:customerGymId", &gymcard.GymcardController{}, "put:VerifyCustomerGymcard"),
+		beego.NSRouter("/gymcard/:gymcardId/:customerId", &gymcard.GymcardController{}, "post:VerifyCustomerGymcard"),
 		// luckdrawlist 抽奖
 		beego.NSRouter("luckdrawlist", &luckdrawlist.LuckdrawlistController{}, "get:GetLuckdrawList"),
 		beego.NSRouter("luckdrawlist/:toPhone/:fromPhone", &luckdrawlist.LuckdrawlistController{}, "get:GetLuckShareList"),

service/bodycheck/bodycheck.go

@@ -0,0 +1,132 @@
+package bodycheck
+
+import (
+	"errors"
+	"spaceofcheng/services/models/bodycheck"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+)
+
+// BodycheckServ 系统处理
+type BodycheckServ struct {
+	ctx *utils.Context
+	dao *bodycheck.DAO
+}
+
+// NewBodycheckServ 初始化
+func NewBodycheckServ(ctx *utils.Context) *BodycheckServ {
+	return &BodycheckServ{
+		ctx: ctx,
+		dao: bodycheck.NewDAO(ctx),
+	}
+}
+func (s *BodycheckServ) GetBodyCheckByUser(userID int) ([]model.TaBodyCheck, error) {
+	bodychecks, err := s.dao.GetBodyCheckByUser(userID)
+	if err != nil {
+		utils.LogError("查询用户体检信息失败: " + err.Error())
+		return nil, errors.New("查询用户体检信息失败")
+	}
+	return bodychecks, nil
+}
+func (s *BodycheckServ) GetCheckSpecs() ([]model.TdCheckSpec, error) {
+	specs, err := s.dao.GetCheckSpecs()
+	if err != nil {
+		utils.LogError("获取项目指标信息失败: " + err.Error())
+		return nil, errors.New("获取项目指标信息失败")
+	}
+	return specs, nil
+}
+func (s *BodycheckServ) GetCheckByUserAndEquipmentID(userID int, EquipmentID string) (*model.TaBodyCheck, error) {
+	check, err := s.dao.GetCheckByUserAndEquipmentID(userID, EquipmentID)
+	if err != nil {
+		utils.LogError("根据用户与设备ID获取体检信息失败: " + err.Error())
+		return nil, errors.New("根据用户与设备ID获取体检信息失败")
+	}
+	return check, nil
+}
+func (s *BodycheckServ) SaveBodyCheckInfo(checkNew model.TaBodyCheck) (*model.TaBodyCheck, error) {
+	checkNews, err := s.dao.SaveBodyCheckInfo(checkNew)
+	if err != nil {
+		utils.LogError("用户体检信息新增失败: " + err.Error())
+		return nil, errors.New("用户体检信息新增失败")
+	}
+	return checkNews, nil
+}
+func (s *BodycheckServ) GetCaseEquipment(EquipmentID string) (*model.TaCaseEquipment, error) {
+	caseEquipment, err := s.dao.GetCaseEquipment(EquipmentID)
+	if err != nil {
+		utils.LogError("获取设备案场信息失败: " + err.Error())
+		return nil, errors.New("获取设备案场信息失败")
+	}
+	return caseEquipment, nil
+}
+func (s *BodycheckServ) GetUserByOpenID(openid string) (*model.TaCustomer, error) {
+	customer, err := s.dao.GetUserByOpenID(openid)
+	if err != nil {
+		utils.LogError("根据openid获取用户信息失败: " + err.Error())
+		return nil, errors.New("根据openid获取用户信息失败")
+	}
+	return customer, nil
+}
+
+func (s *BodycheckServ) GetPresentationByCheckID(checkID int) ([]bodycheck.Presentation, error) {
+	presentations, err := s.dao.GetPresentationByCheckID(checkID)
+	if err != nil {
+		utils.LogError("根据体检ID获取项目信息失败: " + err.Error())
+		return nil, errors.New("根据体检ID获取项目信息失败")
+	}
+	return presentations, nil
+}
+
+func (s *BodycheckServ) GetDetailsByPresentID(ID int) ([]model.TaPresentationDetail, error) {
+	detail, err := s.dao.GetDetailsByPresentID(ID)
+	if err != nil {
+		utils.LogError("根据项目ID获取详情失败: " + err.Error())
+		return nil, errors.New("根据项目ID获取详情失败")
+	}
+	return detail, nil
+}
+
+func (s *BodycheckServ) GetPresentation(checkID, typeID int) (*model.TaPresentation, error) {
+	presentation, err := s.dao.GetPresentation(checkID, typeID)
+	if err != nil {
+		utils.LogError("获取体检项目信息失败: " + err.Error())
+		return nil, errors.New("获取体检项目信息失败")
+	}
+	return presentation, nil
+}
+
+func (s *BodycheckServ) SavePresentation(info model.TaPresentation) (*model.TaPresentation, error) {
+	presentation, err := s.dao.SavePresentation(info)
+	if err != nil {
+		utils.LogError("新增体检项目信息失败: " + err.Error())
+		return nil, errors.New("新增体检项目信息失败")
+	}
+	return presentation, err
+}
+func (s *BodycheckServ) UpdatePresentation(info *model.TaPresentation) error {
+	err := s.dao.UpdatePresentation(info)
+	if err != nil {
+		utils.LogError("更新体检项目信息失败: " + err.Error())
+		return errors.New("更新体检项目信息失败")
+	}
+	return nil
+}
+
+func (s *BodycheckServ) SavePresentationDetail(details []model.TaPresentationDetail) error {
+	err := s.dao.SavePresentationDetail(details)
+	if err != nil {
+		utils.LogError("保存体检项目明细失败: " + err.Error())
+		return errors.New("保存体检项目明细失败")
+	}
+	return nil
+
+}
+func (s *BodycheckServ) DeletePresentionDetail(ID int) error {
+	err := s.dao.DeletePresentionDetail(ID)
+	if err != nil {
+		utils.LogError("根据项目ID删除明细信息失败: " + err.Error())
+		return errors.New("根据项目ID删除明细信息失败")
+	}
+	return nil
+}

service/gymcard/gymcard.go

@@ -192,6 +192,35 @@ func (s *GymcardServ) SendGymCardToUser(gymcardId, sysuserId string) (*model.TaC
 	return customerGym, nil
 }
 
+// SendGymCardToUser 后台给客户发卡
+func (s *GymcardServ) BackSendGymCardToUser(gymcardId, sysuserId, customerId string) (*model.TaCustomerGym, error) {
+	var customerGym *model.TaCustomerGym
+	var sysuser *model.SysUser
+	gymCard, err := s.dao.GetGymcardById(gymcardId)
+	if err != nil {
+		utils.LogError("发送游泳健身卡给客户失败" + err.Error())
+		return nil, errors.New("发送游泳健身卡给客户失败")
+	}
+	sysuser, err = s.cdao.GetUserByID(sysuserId)
+	if err != nil {
+		utils.LogError("发送游泳健身卡给客户失败" + err.Error())
+		return nil, errors.New("发送游泳健身卡给客户失败")
+	}
+	gymCard.SentCount = gymCard.SentCount + 1
+	customerGym, err = s.dao.SendGymcardToCustomer(&gymCard.TaGymCard, customerId, sysuserId, sysuser.RealName)
+	if err != nil {
+		utils.LogError("发送游泳健身卡给客户失败" + err.Error())
+		return nil, errors.New("发送游泳健身卡给客户失败")
+	}
+
+	err = s.dao.EditGymcard(&gymCard.TaGymCard)
+	if err != nil {
+		utils.LogError("发送游泳健身卡给客户失败" + err.Error())
+		return nil, errors.New("发送游泳健身卡给客户失败")
+	}
+	return customerGym, nil
+}
+
 // UpdateCustomerGym 核销游泳健身卡
 func (s *GymcardServ) UpdateCustomerGym(customerGymId, caseid string) error {
 	var gymCard *gymcard.Gymcard