体检更新

conf/app.conf

@@ -29,3 +29,8 @@ guest = "/guest/:org"
 common = "/common/:org"
 wechat = "/wechat/:org"
 
+
+postwechatInfo = http://testapi.chioy.com.cn/api/network/postwechatInfo
+qrcodePrefix = bodycheck_
+followText = 您正在使用悦琦设备进行体检~
+resultURL = http://dev.ycjcjy.com/bodyCheck

conf/wechat.conf

@@ -0,0 +1 @@
+messageTplID = 1ft8YDwqOYwIHxTXXVlJh5Q7ST5qU1a0qlnF6B6TCBU

controllers/base.go

@@ -48,6 +48,13 @@ func (c *BaseController) ResponseError(err error, code ...int) {
 	c.ResponseData(nil, err, http.StatusBadRequest)
 }
 
+// ResponseRaw 返回
+func (c *BaseController) ResponseRaw(msg []byte) {
+	c.destroyContext(true)
+	c.Ctx.ResponseWriter.Write(msg)
+	c.StopRun()
+}
+
 // ResponseData 自定义的JSON返回
 func (c *BaseController) ResponseData(data interface{}, msg interface{}, code int) {
 	status := code

controllers/bodycheck/bodycheck.go

@@ -0,0 +1,52 @@
+package bodycheck
+
+import (
+	"encoding/json"
+	"io/ioutil"
+	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/service/bodycheck"
+	"spaceofcheng/services/utils"
+)
+
+// BodyCheckController 商品
+type BodyCheckController struct {
+	serv *bodycheck.BodyCheckServ
+	controllers.BaseController
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *BodyCheckController) Constructor() {
+	c.serv = bodycheck.NewBodyCheckServ(c.Context)
+}
+
+// GetCheckByUser 根据用户获取体检报告
+func (c *BodyCheckController) GetCheckByUser() {
+	info, err := c.serv.GetCheckByUser()
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(info)
+}
+
+// PostCheckResult 测量结果返回
+func (c *BodyCheckController) PostCheckResult() {
+	r := c.Ctx.Request
+	defer r.Body.Close()
+	con, _ := ioutil.ReadAll(r.Body) //获取post的数据
+
+	var formVal map[string]interface{}
+	err := json.Unmarshal(con, &formVal)
+	if err != nil {
+		utils.LogError("参数错误：", err)
+		c.ResponseError(err)
+	}
+
+	err = c.serv.PostCheckResult(formVal)
+	if err != nil {
+		utils.LogError("操作错误：", err)
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("")
+}

controllers/statistics/cardcoupon.go

@@ -1,6 +1,11 @@
 package statistics
 
-import "spaceofcheng/services/models/model"
+import (
+	"errors"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strconv"
+)
 
 // CardCouponStatistics 获取卡券统计数据
 func (c *StatisticsController) CardCouponStatistics() {
@@ -22,6 +27,72 @@ func (c *StatisticsController) CardCouponStatistics() {
 	c.ResponseJSON(list)
 }
 
+// CardCouponStatisticsExcel 获取卡券统计数据
+func (c *StatisticsController) CardCouponStatisticsExcel() {
+	caseids := c.GetString("caseid")
+	name := c.GetString("name")
+	ctype := c.GetString("ctype")
+
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+
+	list, err := c.serv.CardCouponStatisticsExcel(caseids, ctype, name)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	excel, err := utils.NewTinyXLSXEngine()
+	if err != nil {
+		utils.LogError("初始化Excel服务失败: " + err.Error())
+		c.ResponseError(errors.New("初始化Excel服务失败"))
+	}
+
+	excel.SetCell(excel.InsertRow(), []string{
+		"案场",
+		"卡券名称",
+		"卡券类型",
+		"发送类型",
+		"价格",
+		"领取数",
+		"实际使用数",
+		"总费用",
+	})
+
+	for _, item := range list {
+		row := excel.InsertRow()
+		sendtype := ""
+		switch item.SendType {
+		case "system":
+			sendtype = "系统"
+			break
+		case "case":
+			sendtype = "案场"
+			break
+		case "channel":
+			sendtype = "渠道"
+			break
+		}
+		price, err := strconv.ParseFloat(item.Price, 64)
+		if err != nil {
+			c.ResponseError(errors.New("金额类型不正确！"))
+		}
+		amount := price * float64(item.UsedCount)
+
+		excel.SetCell(row, []string{
+			item.CaseName,
+			item.CName,
+			item.TypeName,
+			sendtype,
+			item.Price,
+			strconv.Itoa(item.SentCount),
+			strconv.Itoa(item.UsedCount),
+			strconv.FormatFloat(amount, 'f', -1, 64),
+		})
+	}
+	c.SaveToExcel("卡券统计列表.xlsx", excel)
+}
+
 // CardCouponUsedStatistics 获取卡券使用统计数据
 func (c *StatisticsController) CardCouponUsedStatistics() {
 	page, _ := c.GetInt("page")
@@ -46,6 +117,94 @@ func (c *StatisticsController) CardCouponUsedStatistics() {
 	c.ResponseJSON(list)
 }
 
+// CardCouponUsedStatisticsExcel 卡券使用导出
+func (c *StatisticsController) CardCouponUsedStatisticsExcel() {
+	caseids := c.GetString("caseid")
+	name := c.GetString("name")
+	receivetype := c.GetString("receivetype")
+	tel := c.GetString("tel")
+	begindate := c.GetString("begindate")
+	enddate := c.GetString("enddate")
+	status := c.GetString("status")
+
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	list, err := c.serv.CardCouponUsedStatisticsExcel(caseids, tel, name, receivetype, begindate, enddate, status)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	excel, err := utils.NewTinyXLSXEngine()
+	if err != nil {
+		utils.LogError("初始化Excel服务失败: " + err.Error())
+		c.ResponseError(errors.New("初始化Excel服务失败"))
+	}
+
+	excel.SetCell(excel.InsertRow(), []string{
+		"案场",
+		"卡券名称",
+		"使用商品",
+		"获取方式",
+		"微信昵称",
+		"手机号",
+		"有效期",
+		"获取时间",
+		"使用时间",
+		"状态",
+	})
+
+	for _, item := range list {
+		row := excel.InsertRow()
+		receivetype := ""
+		switch item.ReceivingType {
+		case "event":
+			receivetype = "系统"
+			break
+		case "case":
+			receivetype = "案场"
+			break
+		case "channel":
+			receivetype = "渠道"
+			break
+		case "give":
+			receivetype = "后台赠送"
+			break
+		}
+
+		verifystatus := ""
+		switch item.VerifyStatus {
+		case "useable":
+			verifystatus = "未使用"
+			break
+		case "used":
+			verifystatus = "已使用"
+			break
+		case "late":
+			verifystatus = "逾期核销"
+			break
+		case "expire":
+			verifystatus = "已失效"
+			break
+		}
+
+		excel.SetCell(row, []string{
+			item.CaseName,
+			item.CardCouponName,
+			item.TargetName,
+			receivetype,
+			item.CustomerName,
+			item.Phone,
+			item.EndDate.Format("2006-01-02 15:04:05"),
+			item.ReceiveDate.Format("2006-01-02 15:04:05"),
+			item.UsedDate.Format("2006-01-02 15:04:05"),
+			verifystatus,
+		})
+	}
+	c.SaveToExcel("卡券使用列表.xlsx", excel)
+}
+
 // CardCouponVerifyStatistics 获取卡券核销统计数据
 func (c *StatisticsController) CardCouponVerifyStatistics() {
 	page, _ := c.GetInt("page")
@@ -66,3 +225,72 @@ func (c *StatisticsController) CardCouponVerifyStatistics() {
 
 	c.ResponseJSON(list)
 }
+
+// CardCouponVerifyStatisticsExcel 卡券核销统计导出
+func (c *StatisticsController) CardCouponVerifyStatisticsExcel() {
+	caseids := c.GetString("caseid")
+	name := c.GetString("name")
+	tel := c.GetString("tel")
+	status := c.GetString("status")
+
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	list, err := c.serv.CardCouponVerifyStatisticsExcel(caseids, tel, name, status)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	excel, err := utils.NewTinyXLSXEngine()
+	if err != nil {
+		utils.LogError("初始化Excel服务失败: " + err.Error())
+		c.ResponseError(errors.New("初始化Excel服务失败"))
+	}
+
+	excel.SetCell(excel.InsertRow(), []string{
+		"案场",
+		"课程名称",
+		"课程时间",
+		"姓名",
+		"微信昵称",
+		"手机号",
+		"下单时间",
+		"核销时间",
+		"状态",
+	})
+
+	for _, item := range list {
+		row := excel.InsertRow()
+		verifystatus := ""
+		switch item.Status {
+		case "useable":
+			verifystatus = "未使用"
+			break
+		case "used":
+			verifystatus = "已使用"
+			break
+		case "late":
+			verifystatus = "逾期核销"
+			break
+		}
+
+		verifydate := ""
+		if !item.VerifyDate.IsZero() {
+			verifydate = item.VerifyDate.Format("2006-01-02 15:04:05")
+		}
+
+		excel.SetCell(row, []string{
+			item.CaseName,
+			item.CourseName,
+			item.BeginDate.Format("2006-01-02 15:04:05") + "~" + item.EndDate.Format("2006-01-02 15:04:05"),
+			item.Name,
+			item.CustomerName,
+			item.Phone,
+			item.CreateDate.Format("2006-01-02 15:04:05"),
+			verifydate,
+			verifystatus,
+		})
+	}
+	c.SaveToExcel("卡券核销列表.xlsx", excel)
+}

controllers/statistics/course.go

@@ -1,6 +1,11 @@
 package statistics
 
-import "spaceofcheng/services/models/model"
+import (
+	"errors"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strconv"
+)
 
 // GetCourseOrdersStatistics 获取课程订单统计数据
 func (c *StatisticsController) GetCourseOrdersStatistics() {
@@ -24,6 +29,56 @@ func (c *StatisticsController) GetCourseOrdersStatistics() {
 	c.ResponseJSON(ordersList)
 }
 
+// GetCourseOrdersStatisticsExcel 课程订单导出
+func (c *StatisticsController) GetCourseOrdersStatisticsExcel() {
+	caseids := c.GetString("caseid")
+	name := c.GetString("name")
+	typeid := c.GetString("typeid")
+	begindate := c.GetString("begindate")
+	enddate := c.GetString("enddate")
+
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	list, err := c.serv.GetCourseOrdersStatisticsExcel(typeid, caseids, name, begindate, enddate)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	excel, err := utils.NewTinyXLSXEngine()
+	if err != nil {
+		utils.LogError("初始化Excel服务失败: " + err.Error())
+		c.ResponseError(errors.New("初始化Excel服务失败"))
+	}
+
+	excel.SetCell(excel.InsertRow(), []string{
+		"订单编号",
+		"课程名称",
+		"案场",
+		"课程类别",
+		"课程时间",
+		"用户姓名",
+		"手机号",
+		"下单时间",
+	})
+
+	for _, item := range list {
+		row := excel.InsertRow()
+		excel.SetCell(row, []string{
+			item.OrdersNo,
+			item.CourseName,
+			item.CaseName,
+			item.LocationName,
+			item.BeginDate.Format("2006-01-02 15:04:05") + "~" + item.EndDate.Format("2006-01-02 15:04:05"),
+			item.CustomerName,
+			item.Phone,
+			item.CreateDate.Format("2006-01-02 15:04:05"),
+		})
+	}
+	c.SaveToExcel("课程订单列表.xlsx", excel)
+}
+
 // GetCourseStatistics 获取课程统计数据
 func (c *StatisticsController) GetCourseStatistics() {
 	page, _ := c.GetInt("page")
@@ -43,3 +98,58 @@ func (c *StatisticsController) GetCourseStatistics() {
 
 	c.ResponseJSON(ordersList)
 }
+
+// GetCourseStatisticsExcel 课程统计数据导出
+func (c *StatisticsController) GetCourseStatisticsExcel() {
+
+	caseids := c.GetString("caseid")
+	name := c.GetString("name")
+	typeid := c.GetString("typeid")
+
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	list, err := c.serv.GetCourseStatisticsExcel(typeid, caseids, name)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	excel, err := utils.NewTinyXLSXEngine()
+	if err != nil {
+		utils.LogError("初始化Excel服务失败: " + err.Error())
+		c.ResponseError(errors.New("初始化Excel服务失败"))
+	}
+
+	excel.SetCell(excel.InsertRow(), []string{
+		"案场",
+		"课程名称",
+		"课程类别",
+		"课程时间",
+		"课程价格",
+		"报名人数",
+		"核销人数",
+		"总费用",
+	})
+
+	for _, item := range list {
+		row := excel.InsertRow()
+		price, err := strconv.ParseFloat(item.Price, 64)
+		if err != nil {
+			c.ResponseError(errors.New("金额类型不正确！"))
+		}
+		amount := price * float64(item.JoinTotal)
+
+		excel.SetCell(row, []string{
+			item.CaseName,
+			item.CourseName,
+			item.LocationName,
+			item.BeginDate.Format("2006-01-02 15:04:05") + "~" + item.EndDate.Format("2006-01-02 15:04:05"),
+			item.Price,
+			strconv.Itoa(item.Total),
+			strconv.Itoa(item.JoinTotal),
+			strconv.FormatFloat(amount, 'f', -1, 64),
+		})
+	}
+	c.SaveToExcel("课程统计列表.xlsx", excel)
+}

controllers/statistics/goods.go

@@ -1,6 +1,11 @@
 package statistics
 
-import "spaceofcheng/services/models/model"
+import (
+	"errors"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strconv"
+)
 
 // GetGoodsStatistics 获取商品统计数据
 func (c *StatisticsController) GetGoodsStatistics() {
@@ -22,6 +27,58 @@ func (c *StatisticsController) GetGoodsStatistics() {
 	c.ResponseJSON(goodsList)
 }
 
+// GetGoodsStatisticsExcel 商品统计导出
+func (c *StatisticsController) GetGoodsStatisticsExcel() {
+	caseids := c.GetString("caseid")
+	name := c.GetString("name")
+	typeid := c.GetString("typeid")
+
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	list, err := c.serv.GetGoodsStatisticsExcel(caseids, typeid, name)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	excel, err := utils.NewTinyXLSXEngine()
+	if err != nil {
+		utils.LogError("初始化Excel服务失败: " + err.Error())
+		c.ResponseError(errors.New("初始化Excel服务失败"))
+	}
+
+	excel.SetCell(excel.InsertRow(), []string{
+		"案场",
+		"商品名称",
+		"分类",
+		"价格",
+		"下单数",
+		"完成数",
+		"总费用",
+	})
+
+	for _, item := range list {
+		row := excel.InsertRow()
+		price, err := strconv.ParseFloat(item.Price, 64)
+		if err != nil {
+			c.ResponseError(errors.New("金额类型不正确！"))
+		}
+		amount := price * float64(item.FinishTotal)
+
+		excel.SetCell(row, []string{
+			item.CaseName,
+			item.GoodsName,
+			item.TypeName,
+			item.Price,
+			strconv.Itoa(item.Total),
+			strconv.Itoa(item.FinishTotal),
+			strconv.FormatFloat(amount, 'f', -1, 64),
+		})
+	}
+	c.SaveToExcel("商品统计列表.xlsx", excel)
+}
+
 // GetGoodsOrdersStatistics 获取商品订单统计数据
 func (c *StatisticsController) GetGoodsOrdersStatistics() {
 	page, _ := c.GetInt("page")
@@ -43,3 +100,84 @@ func (c *StatisticsController) GetGoodsOrdersStatistics() {
 
 	c.ResponseJSON(goodsList)
 }
+
+// GetGoodsOrdersStatisticsExcel 商品订单统计导出
+func (c *StatisticsController) GetGoodsOrdersStatisticsExcel() {
+	caseids := c.GetString("caseid")
+	status := c.GetString("status")
+	usertype := c.GetString("usertype")
+	begindate := c.GetString("begindate")
+	enddate := c.GetString("enddate")
+
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	list, err := c.serv.GetGoodsOrdersStatisticsExcel(status, usertype, caseids, begindate, enddate)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	excel, err := utils.NewTinyXLSXEngine()
+	if err != nil {
+		utils.LogError("初始化Excel服务失败: " + err.Error())
+		c.ResponseError(errors.New("初始化Excel服务失败"))
+	}
+
+	excel.SetCell(excel.InsertRow(), []string{
+		"订单编号",
+		"案场",
+		"用户类型",
+		"下单时间",
+		"订单状态",
+		"商品",
+		"数量",
+		"金额",
+		"桌位",
+		"下单人",
+		"电话",
+	})
+
+	for _, item := range list {
+		row := excel.InsertRow()
+		usertype := ""
+		switch item.UserType {
+		case "customer":
+			usertype = "用户"
+			break
+		case "sales":
+			usertype = "销售"
+			break
+		case "manager":
+			usertype = "主管"
+			break
+		}
+
+		orderStatus := ""
+		if item.Status == 1 {
+			orderStatus = "已完成"
+		} else {
+			orderStatus = "已取消"
+		}
+		for _, detail := range item.Details {
+			name := detail.GoodsName
+			if detail.SpecName != "" {
+				name = name + "(" + detail.SpecName + ")"
+			}
+			excel.SetCell(row, []string{
+				item.OrdersNo,
+				item.CaseName,
+				usertype,
+				item.CreateDate.Format("2006-01-02 15:04:05"),
+				orderStatus,
+				name,
+				strconv.Itoa(detail.Number),
+				item.AreaName + item.TableNo,
+				item.CustomerName,
+				item.Phone,
+			})
+		}
+
+	}
+	c.SaveToExcel("商品订单统计列表.xlsx", excel)
+}

controllers/wechat.go

@@ -1,12 +1,175 @@
 package controllers
 
 import (
+	"bytes"
+	"encoding/json"
 	"errors"
+	"io/ioutil"
+	"net/http"
 	"net/url"
 	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service/customer"
 	"spaceofcheng/services/utils"
+	"strings"
+
+	"github.com/astaxie/beego"
 )
 
+// WechatInfo 微信接入
+func (c *BaseController) WechatInfo() {
+	// signature := c.GetString("signature")
+	// timestamp := c.GetString("timestamp")
+	// nonce := c.GetString("nonce")
+	echostr := c.GetString("echostr")
+	c.ResponseRaw([]byte(echostr))
+}
+
+// GetQrcodeURL 获取二维码信息
+func (c *BaseController) GetQrcodeURL() {
+	EquipmentID := c.GetString("EquipmentId")
+	qrcodePrefix := beego.AppConfig.String("qrcodePrefix")
+	org := c.Context.Get("org").(model.SysOrg)
+
+	qrcode, err := utils.WxClientFor(org.OrgId).GetTempStrQRCode(qrcodePrefix + EquipmentID)
+	if err != nil {
+		utils.LogError("获取二维码失败！")
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(map[string]interface{}{
+		"QrcodeUrl": qrcode,
+	})
+}
+
+// WxReceive
+func (c *BaseController) WxReceive() {
+	org := c.Context.Get("org").(model.SysOrg)
+	wechat := utils.WxClientFor(org.OrgId)
+	r := c.Ctx.Request
+	defer r.Body.Close()
+	con, _ := ioutil.ReadAll(r.Body) //获取post的数据
+	val, err := wechat.TransformMessage(string(con))
+	if err != nil {
+		beego.Error(err.Error())
+		c.ResponseRaw([]byte(""))
+	}
+
+	if val["MsgType"] == "event" {
+		qrcodePrefix := beego.AppConfig.String("qrcodePrefix")
+		if (val["Event"] == "subscribe" && strings.Contains(val["EventKey"], "qrscene_"+qrcodePrefix)) || val["Event"] == "SCAN" {
+			EquipmentID := strings.Split(val["EventKey"], qrcodePrefix)[1]
+			messagetxt, err := c.scanDo(val, EquipmentID)
+			if err != nil {
+				beego.Error(err.Error())
+				c.ResponseRaw([]byte(""))
+			}
+			c.ResponseRaw(messagetxt)
+		}
+	}
+	c.ResponseRaw([]byte(""))
+}
+
+func (c *BaseController) scanDo(val map[string]string, EquipmentID string) ([]byte, error) {
+	org := c.Context.Get("org").(model.SysOrg)
+	wechat := utils.WxClientFor(org.OrgId)
+
+	if val["FromUserName"] == "" {
+		return nil, errors.New("openid为空")
+	}
+
+	user, err := wechat.GetUserDetail(val["FromUserName"])
+	if err != nil {
+		return nil, err
+	}
+
+	var customerserv = customer.NewCustomerServ(c.Context)
+
+	// 判断用户是否存在
+	getUser, err := customerserv.GetCustUserByOpenID(user["openid"].(string))
+	if err != nil {
+		return nil, err
+	}
+	name := user["nickname"].(string)
+	name = UnicodeEmojiCode(name)
+	user["nickname"] = name
+	if getUser == nil || getUser.CustomerId != "" {
+		// 新增用户
+		_, err := customerserv.SaveNewCustomer(user, "", "", "", "")
+		if err != nil {
+			utils.LogError("用户保存失败：", err)
+			return nil, err
+		}
+	}
+
+	type WechatInfo struct {
+		EquipmentId    string
+		WXID           int
+		WechatUserInfo map[string]interface{}
+	}
+	appid := wechat.GetAppID()
+	user["wechataccount"] = user["openid"].(string)
+	user["wechatofficial"] = appid
+	var userinfo = WechatInfo{}
+	userinfo.EquipmentId = EquipmentID
+	userinfo.WechatUserInfo = user
+	userinfo.WXID = 1
+
+	apiPrefix := beego.AppConfig.String("postwechatInfo")
+
+	b, err := json.Marshal(userinfo)
+	if err != nil {
+		return nil, err
+	}
+
+	body := bytes.NewBuffer([]byte(b))
+
+	res, err := http.Post(apiPrefix, "application/json;charset=utf-8", body)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	result, err := ioutil.ReadAll(res.Body)
+	res.Body.Close()
+	if err != nil {
+		utils.LogError("发送消息失败：", err)
+		return nil, err
+	}
+	var postResult struct {
+		Status  bool
+		Message string
+	}
+	if err = json.Unmarshal(result, &postResult); err != nil {
+		utils.LogError("发送消息失败：", err)
+		return nil, err
+	}
+
+	if !postResult.Status {
+		beego.Error(postResult.Message)
+		return nil, errors.New(postResult.Message)
+	}
+
+	messagetxt, err := wechat.ResponseMessageText(user["openid"].(string), beego.AppConfig.String("followText"))
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	return messagetxt, nil
+}
+
+// UnicodeEmojiCode 过滤表情
+func UnicodeEmojiCode(s string) string {
+	ret := ""
+	rs := []rune(s)
+	for i := 0; i < len(rs); i++ {
+		if len(string(rs[i])) == 4 {
+			// u := `[\u` + strconv.FormatInt(int64(rs[i]), 16) + `]`
+			ret += ""
+		} else {
+			ret += string(rs[i])
+		}
+	}
+	return ret
+}
+
 // GetWxJsSDKSignature 获取 微信 jssdk 签名
 func (c *BaseController) GetWxJsSDKSignature() {
 	org := c.Context.Get("org").(model.SysOrg)

log/common.log

@@ -73,3 +73,272 @@
 2018/09/16 17:39:13 [E] 用户没有设置默认案场
 2018/09/16 18:43:58 [E] 用户没有设置默认案场
 2018/09/16 18:43:58 [E] 用户没有设置默认案场
+2018/09/16 19:21:38 [E] 用户没有设置默认案场
+2018/09/16 19:21:38 [E] 用户没有设置默认案场
+2018/09/16 19:23:09 [E] 用户没有设置默认案场
+2018/09/16 19:23:09 [E] 用户没有设置默认案场
+2018/09/16 19:23:14 [E] 用户没有设置默认案场
+2018/09/16 19:23:15 [E] 用户没有设置默认案场
+2018/09/16 19:24:16 [E] 用户没有设置默认案场
+2018/09/16 19:24:16 [E] 用户没有设置默认案场
+2018/09/16 19:24:16 [E] 用户没有设置默认案场
+2018/09/16 19:25:07 [E] 用户没有设置默认案场
+2018/09/16 19:25:07 [E] 用户没有设置默认案场
+2018/09/16 19:25:07 [E] 用户没有设置默认案场
+2018/09/16 19:26:15 [E] 用户没有设置默认案场
+2018/09/16 19:26:42 [E] 用户没有设置默认案场
+2018/09/16 19:26:45 [E] 用户没有设置默认案场
+2018/09/16 19:26:45 [E] 用户没有设置默认案场
+2018/09/16 19:27:06 [E] 用户没有设置默认案场
+2018/09/16 19:27:06 [E] 用户没有设置默认案场
+2018/09/16 19:29:45 [E] 用户没有设置默认案场
+2018/09/16 19:30:00 [E] 用户没有设置默认案场
+2018/09/16 19:30:00 [E] 用户没有设置默认案场
+2018/09/16 19:30:26 [E] 用户没有设置默认案场
+2018/09/16 19:33:11 [E] 用户没有设置默认案场
+2018/09/16 19:34:19 [E] 用户没有设置默认案场
+2018/09/16 19:35:56 [E] 用户没有设置默认案场
+2018/09/16 19:36:33 [E] 用户没有设置默认案场
+2018/09/16 19:37:06 [E] 用户没有设置默认案场
+2018/09/16 19:37:17 [E] 用户没有设置默认案场
+2018/09/16 19:37:19 [E] 用户没有设置默认案场
+2018/09/16 19:37:20 [E] 用户没有设置默认案场
+2018/09/16 19:37:21 [E] 用户没有设置默认案场
+2018/09/16 19:37:36 [E] 用户没有设置默认案场
+2018/09/16 19:37:46 [E] 用户没有设置默认案场
+2018/09/16 19:37:46 [E] 用户没有设置默认案场
+2018/09/16 19:38:13 [E] 用户没有设置默认案场
+2018/09/16 19:38:24 [E] 用户没有设置默认案场
+2018/09/16 19:38:31 [E] 用户没有设置默认案场
+2018/09/16 19:38:31 [E] 用户没有设置默认案场
+2018/09/16 19:38:33 [E] 用户没有设置默认案场
+2018/09/16 19:38:38 [E] 用户没有设置默认案场
+2018/09/16 19:38:43 [E] 用户没有设置默认案场
+2018/09/16 19:38:43 [E] 用户没有设置默认案场
+2018/09/16 19:38:56 [E] 用户没有设置默认案场
+2018/09/16 19:39:00 [E] 用户没有设置默认案场
+2018/09/16 19:41:09 [E] 用户没有设置默认案场
+2018/09/16 19:41:48 [E] 用户没有设置默认案场
+2018/09/16 19:41:48 [E] 用户没有设置默认案场
+2018/09/16 19:43:37 [E] 用户没有设置默认案场
+2018/09/16 19:43:38 [E] 用户没有设置默认案场
+2018/09/16 19:43:39 [E] 用户没有设置默认案场
+2018/09/16 19:43:40 [E] 用户没有设置默认案场
+2018/09/16 19:43:40 [E] 用户没有设置默认案场
+2018/09/16 19:43:41 [E] 用户没有设置默认案场
+2018/09/16 19:43:41 [E] 用户没有设置默认案场
+2018/09/16 19:43:42 [E] 用户没有设置默认案场
+2018/09/16 19:43:44 [E] 用户没有设置默认案场
+2018/09/16 19:43:44 [E] 用户没有设置默认案场
+2018/09/16 19:43:50 [E] 用户没有设置默认案场
+2018/09/16 19:43:52 [E] 用户没有设置默认案场
+2018/09/16 19:43:53 [E] 用户没有设置默认案场
+2018/09/16 19:43:54 [E] 用户没有设置默认案场
+2018/09/16 19:43:55 [E] 用户没有设置默认案场
+2018/09/16 19:44:13 [E] 用户没有设置默认案场
+2018/09/16 19:44:13 [E] 用户没有设置默认案场
+2018/09/16 19:44:14 [E] 用户没有设置默认案场
+2018/09/16 19:45:09 [E] 用户没有设置默认案场
+2018/09/16 19:45:44 [E] 用户没有设置默认案场
+2018/09/16 19:45:47 [E] 用户没有设置默认案场
+2018/09/16 19:45:50 [E] 用户没有设置默认案场
+2018/09/16 19:46:15 [E] 用户没有设置默认案场
+2018/09/16 19:46:15 [E] 用户没有设置默认案场
+2018/09/16 20:00:54 [E] 用户没有设置默认案场
+2018/09/16 20:02:25 [E] 用户没有设置默认案场
+2018/09/16 20:04:08 [E] 用户没有设置默认案场
+2018/09/16 20:06:11 [E] 用户没有设置默认案场
+2018/09/16 20:06:17 [E] 用户没有设置默认案场
+2018/09/16 20:08:16 [E] 用户没有设置默认案场
+2018/09/16 20:13:41 [E] 用户没有设置默认案场
+2018/09/16 20:13:45 [E] 用户没有设置默认案场
+2018/09/16 20:13:45 [E] 用户没有设置默认案场
+2018/09/16 20:15:55 [E] 用户没有设置默认案场
+2018/09/16 20:15:55 [E] 用户没有设置默认案场
+2018/09/16 20:15:58 [E] 用户没有设置默认案场
+2018/09/16 20:15:58 [E] 用户没有设置默认案场
+2018/09/16 20:16:07 [E] 用户没有设置默认案场
+2018/09/16 20:16:07 [E] 用户没有设置默认案场
+2018/09/16 20:16:08 [E] 用户没有设置默认案场
+2018/09/16 20:16:31 [E] 用户没有设置默认案场
+2018/09/16 20:16:36 [E] 用户没有设置默认案场
+2018/09/16 20:16:36 [E] 用户没有设置默认案场
+2018/09/16 20:16:37 [E] 用户没有设置默认案场
+2018/09/16 20:18:25 [E] 用户没有设置默认案场
+2018/09/16 20:18:25 [E] 用户没有设置默认案场
+2018/09/16 20:22:33 [E] 用户没有设置默认案场
+2018/09/16 20:34:05 [E] 用户没有设置默认案场
+2018/09/16 20:36:10 [E] 用户没有设置默认案场
+2018/09/16 20:38:03 [E] 用户没有设置默认案场
+2018/09/16 20:38:03 [E] 用户没有设置默认案场
+2018/09/16 20:42:12 [E] 用户没有设置默认案场
+2018/09/16 20:42:12 [E] 用户没有设置默认案场
+2018/09/16 20:42:45 [E] 用户没有设置默认案场
+2018/09/16 20:42:45 [E] 用户没有设置默认案场
+2018/09/16 20:44:07 [E] 用户没有设置默认案场
+2018/09/16 20:44:07 [E] 用户没有设置默认案场
+2018/09/16 20:46:02 [E] 用户没有设置默认案场
+2018/09/16 20:46:20 [E] 用户没有设置默认案场
+2018/09/16 20:46:46 [E] 用户没有设置默认案场
+2018/09/16 20:47:04 [E] 用户没有设置默认案场
+2018/09/16 20:47:13 [E] 用户没有设置默认案场
+2018/09/16 20:47:18 [E] 用户没有设置默认案场
+2018/09/16 20:47:18 [E] 用户没有设置默认案场
+2018/09/16 20:48:47 [E] 用户没有设置默认案场
+2018/09/16 21:00:31 [E] 用户没有设置默认案场
+2018/09/16 21:00:31 [E] 用户没有设置默认案场
+2018/09/16 21:00:37 [E] 用户没有设置默认案场
+2018/09/16 21:00:37 [E] 用户没有设置默认案场
+2018/09/16 21:01:37 [E] 用户没有设置默认案场
+2018/09/16 21:01:37 [E] 用户没有设置默认案场
+2018/09/16 21:01:37 [E] 用户没有设置默认案场
+2018/09/16 21:01:41 [E] 用户没有设置默认案场
+2018/09/16 21:01:41 [E] 用户没有设置默认案场
+2018/09/16 21:01:41 [E] 用户没有设置默认案场
+2018/09/16 21:01:45 [E] 用户没有设置默认案场
+2018/09/16 21:01:45 [E] 用户没有设置默认案场
+2018/09/16 21:01:45 [E] 用户没有设置默认案场
+2018/09/16 21:05:12 [E] 用户没有设置默认案场
+2018/09/16 21:05:12 [E] 用户没有设置默认案场
+2018/09/16 21:05:19 [E] 用户没有设置默认案场
+2018/09/16 21:05:19 [E] 用户没有设置默认案场
+2018/09/16 21:10:23 [E] 用户没有设置默认案场
+2018/09/16 21:10:23 [E] 用户没有设置默认案场
+2018/09/16 21:10:26 [E] 用户没有设置默认案场
+2018/09/16 21:10:26 [E] 用户没有设置默认案场
+2018/09/16 21:15:42 [E] 用户没有设置默认案场
+2018/09/16 21:15:42 [E] 用户没有设置默认案场
+2018/09/16 21:16:22 [E] 用户没有设置默认案场
+2018/09/16 21:16:22 [E] 用户没有设置默认案场
+2018/09/16 21:16:35 [E] 用户没有设置默认案场
+2018/09/16 21:16:36 [E] 用户没有设置默认案场
+2018/09/16 21:21:26 [E] 用户没有设置默认案场
+2018/09/16 21:21:26 [E] 用户没有设置默认案场
+2018/09/16 21:21:35 [E] 用户没有设置默认案场
+2018/09/16 21:21:35 [E] 用户没有设置默认案场
+2018/09/16 21:23:58 [E] 用户没有设置默认案场
+2018/09/16 21:23:58 [E] 用户没有设置默认案场
+2018/09/16 21:24:05 [E] 用户没有设置默认案场
+2018/09/16 21:24:05 [E] 用户没有设置默认案场
+2018/09/16 21:29:34 [E] 用户没有设置默认案场
+2018/09/16 21:29:34 [E] 用户没有设置默认案场
+2018/09/16 21:29:38 [E] 用户没有设置默认案场
+2018/09/16 21:29:38 [E] 用户没有设置默认案场
+2018/09/16 21:31:47 [E] 用户没有设置默认案场
+2018/09/16 21:33:12 [E] 用户没有设置默认案场
+2018/09/16 21:33:12 [E] 用户没有设置默认案场
+2018/09/16 21:33:13 [E] 用户没有设置默认案场
+2018/09/16 21:33:15 [E] 用户没有设置默认案场
+2018/09/16 21:33:15 [E] 用户没有设置默认案场
+2018/09/16 21:33:16 [E] 用户没有设置默认案场
+2018/09/16 21:33:17 [E] 用户没有设置默认案场
+2018/09/16 21:33:18 [E] 用户没有设置默认案场
+2018/09/16 21:33:19 [E] 用户没有设置默认案场
+2018/09/16 21:33:20 [E] 用户没有设置默认案场
+2018/09/16 21:33:34 [E] 用户没有设置默认案场
+2018/09/16 21:33:35 [E] 用户没有设置默认案场
+2018/09/16 21:33:36 [E] 用户没有设置默认案场
+2018/09/16 21:33:36 [E] 用户没有设置默认案场
+2018/09/16 21:33:39 [E] 用户没有设置默认案场
+2018/09/16 21:33:39 [E] 用户没有设置默认案场
+2018/09/16 21:33:39 [E] 用户没有设置默认案场
+2018/09/16 21:33:39 [E] 用户没有设置默认案场
+2018/09/16 21:33:40 [E] 用户没有设置默认案场
+2018/09/16 21:33:40 [E] 用户没有设置默认案场
+2018/09/16 21:33:41 [E] 用户没有设置默认案场
+2018/09/16 21:33:41 [E] 用户没有设置默认案场
+2018/09/16 21:33:42 [E] 用户没有设置默认案场
+2018/09/16 21:33:43 [E] 用户没有设置默认案场
+2018/09/16 21:33:43 [E] 用户没有设置默认案场
+2018/09/16 21:33:43 [E] 用户没有设置默认案场
+2018/09/16 21:33:44 [E] 用户没有设置默认案场
+2018/09/16 21:33:44 [E] 用户没有设置默认案场
+2018/09/16 21:33:44 [E] 用户没有设置默认案场
+2018/09/16 21:33:52 [E] 用户没有设置默认案场
+2018/09/16 21:33:57 [E] 用户没有设置默认案场
+2018/09/16 21:37:56 [E] 用户没有设置默认案场
+2018/09/16 21:37:59 [E] 用户没有设置默认案场
+2018/09/16 21:39:29 [E] 用户没有设置默认案场
+2018/09/16 21:39:29 [E] 用户没有设置默认案场
+2018/09/16 21:40:26 [E] 用户没有设置默认案场
+2018/09/16 21:40:26 [E] 用户没有设置默认案场
+2018/09/16 21:41:01 [E] 用户没有设置默认案场
+2018/09/16 21:41:01 [E] 用户没有设置默认案场
+2018/09/16 21:41:11 [E] 用户没有设置默认案场
+2018/09/16 21:41:48 [E] 用户没有设置默认案场
+2018/09/16 21:41:59 [E] 用户没有设置默认案场
+2018/09/16 21:42:01 [E] 用户没有设置默认案场
+2018/09/16 21:47:50 [E] 用户没有设置默认案场
+2018/09/16 21:47:51 [E] 解密 Base64 字串失败: illegal base64 data at input byte 0
+2018/09/16 21:47:51 [E] 获取组织信息失败: 没有查询到机构信息
+2018/09/16 21:48:05 [E] 用户没有设置默认案场
+2018/09/16 21:48:05 [E] 用户没有设置默认案场
+2018/09/16 21:48:09 [E] 解密 Base64 字串失败: illegal base64 data at input byte 0
+2018/09/16 21:48:09 [E] 获取组织信息失败: 没有查询到机构信息
+2018/09/16 21:49:17 [E] 用户没有设置默认案场
+2018/09/16 21:49:17 [E] 用户没有设置默认案场
+2018/09/16 21:51:16 [E] 用户没有设置默认案场
+2018/09/16 21:51:16 [E] 用户没有设置默认案场
+2018/09/16 21:52:15 [E] 用户没有设置默认案场
+2018/09/16 21:52:15 [E] 用户没有设置默认案场
+2018/09/16 21:58:57 [E] 用户没有设置默认案场
+2018/09/16 21:58:57 [E] 用户没有设置默认案场
+2018/09/16 21:59:01 [E] 用户没有设置默认案场
+2018/09/16 21:59:01 [E] 用户没有设置默认案场
+2018/09/16 22:01:01 [E] 用户没有设置默认案场
+2018/09/16 22:01:10 [E] 用户没有设置默认案场
+2018/09/16 22:02:34 [E] 用户没有设置默认案场
+2018/09/16 22:02:34 [E] 用户没有设置默认案场
+2018/09/16 22:03:01 [E] 用户没有设置默认案场
+2018/09/16 22:03:05 [E] 用户没有设置默认案场
+2018/09/16 22:03:05 [E] 用户没有设置默认案场
+2018/09/16 22:07:01 [E] 用户没有设置默认案场
+2018/09/16 22:07:01 [E] 用户没有设置默认案场
+2018/09/16 22:07:05 [E] 用户没有设置默认案场
+2018/09/16 22:07:05 [E] 用户没有设置默认案场
+2018/09/16 22:12:51 [E] 用户没有设置默认案场
+2018/09/16 22:18:09 [E] 用户没有设置默认案场
+2018/09/16 22:18:13 [E] 用户没有设置默认案场
+2018/09/16 22:18:13 [E] 用户没有设置默认案场
+2018/09/16 22:18:17 [E] 用户没有设置默认案场
+2018/09/16 22:18:17 [E] 用户没有设置默认案场
+2018/09/16 22:19:23 [E] 用户没有设置默认案场
+2018/09/16 22:19:36 [E] 用户没有设置默认案场
+2018/09/16 22:20:28 [E] 用户没有设置默认案场
+2018/09/16 22:20:32 [E] 用户没有设置默认案场
+2018/09/16 22:20:33 [E] 用户没有设置默认案场
+2018/09/16 22:26:31 [E] 用户没有设置默认案场
+2018/09/16 22:26:54 [E] 用户没有设置默认案场
+2018/09/16 22:26:54 [E] 用户没有设置默认案场
+2018/09/16 22:27:39 [E] 用户没有设置默认案场
+2018/09/16 22:27:48 [E] 用户没有设置默认案场
+2018/09/16 22:27:49 [E] 用户没有设置默认案场
+2018/09/16 22:28:15 [E] 用户没有设置默认案场
+2018/09/16 22:28:15 [E] 用户没有设置默认案场
+2018/09/16 22:28:15 [E] 用户没有设置默认案场
+2018/09/16 22:28:57 [E] 用户没有设置默认案场
+2018/09/16 22:28:57 [E] 用户没有设置默认案场
+2018/09/16 22:29:11 [E] 用户没有设置默认案场
+2018/09/16 22:29:12 [E] 用户没有设置默认案场
+2018/09/16 22:29:36 [E] 用户没有设置默认案场
+2018/09/16 22:29:36 [E] 用户没有设置默认案场
+2018/09/16 22:29:36 [E] 用户没有设置默认案场
+2018/09/16 22:30:14 [E] 用户没有设置默认案场
+2018/09/16 22:30:14 [E] 用户没有设置默认案场
+2018/09/16 22:30:18 [E] 用户没有设置默认案场
+2018/09/16 22:30:55 [E] 用户没有设置默认案场
+2018/09/16 22:30:55 [E] 用户没有设置默认案场
+2018/09/16 22:31:13 [E] 用户没有设置默认案场
+2018/09/16 22:31:15 [E] 用户没有设置默认案场
+2018/09/16 22:31:15 [E] 用户没有设置默认案场
+2018/09/16 22:31:57 [E] 用户没有设置默认案场
+2018/09/16 22:31:57 [E] 用户没有设置默认案场
+2018/09/16 22:32:21 [E] 用户没有设置默认案场
+2018/09/16 22:32:21 [E] 用户没有设置默认案场
+2018/09/16 22:32:22 [E] 用户没有设置默认案场
+2018/09/16 22:32:27 [E] 用户没有设置默认案场
+2018/09/16 22:32:56 [E] 用户没有设置默认案场
+2018/09/16 22:32:56 [E] 用户没有设置默认案场
+2018/09/16 22:33:10 [E] 用户没有设置默认案场
+2018/09/16 22:33:16 [E] 用户没有设置默认案场
+2018/09/16 22:33:58 [E] 用户没有设置默认案场

models/bodycheck/bodycheck.go

@@ -1,10 +1,10 @@
 package bodycheck
 
 import (
+	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
 	"strconv"
-	"time"
 
 	"github.com/go-xorm/xorm"
 )
@@ -24,10 +24,10 @@ func NewDAO(ctx *utils.Context) *DAO {
 }
 
 // GetBodyCheckByUser 根据用户信息获取体检信息
-func (m *DAO) GetBodyCheckByUser(userID int) ([]model.TaBodyCheck, error) {
+func (m *DAO) GetBodyCheckByUser(userID string) ([]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)
+	err = m.db.Where("user_id=?", userID).And("status=?", models.STATUS_NORMAL).Desc("create_date").Find(&bodychecks)
 	return bodychecks, err
 }
 
@@ -39,9 +39,9 @@ func (m *DAO) GetCheckSpecs() ([]model.TdCheckSpec, error) {
 }
 
 // GetCheckByUserAndEquipmentID 根据用户与设备ID获取体检信息
-func (m *DAO) GetCheckByUserAndEquipmentID(userID int, EquipmentID string) (*model.TaBodyCheck, error) {
+func (m *DAO) GetCheckByUserAndEquipmentID(userID string, 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)
+	err := m.db.Where("user_id=?", userID).And("equipment_id=?", EquipmentID).And("status=?", models.STATUS_NORMAL).Desc("create_date").Find(&check)
 	if err != nil {
 		return nil, err
 	}
@@ -53,41 +53,21 @@ func (m *DAO) GetCheckByUserAndEquipmentID(userID int, EquipmentID string) (*mod
 
 // SaveBodyCheckInfo 用户体检信息新增
 func (m *DAO) SaveBodyCheckInfo(checkNew model.TaBodyCheck) (*model.TaBodyCheck, error) {
-	checkNew.Status = 1
+	checkNew.Status = models.STATUS_NORMAL
+	checkNew.Id = utils.GetGUID()
 	// 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)
+	_, err := m.db.Where("equipment_id=?", EquipmentID).And("status=?", models.STATUS_NORMAL).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
@@ -95,9 +75,9 @@ type Presentation struct {
 }
 
 // GetPresentationByCheckID 根据体检ID获取项目信息
-func (m *DAO) GetPresentationByCheckID(checkID int) ([]Presentation, error) {
+func (m *DAO) GetPresentationByCheckID(checkID string) ([]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)
+	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='` + checkID + `'`
 
 	err := m.db.Sql(sql).Find(&presentations)
 	if err != nil {
@@ -117,21 +97,22 @@ func (m *DAO) GetPresentationByCheckID(checkID int) ([]Presentation, error) {
 }
 
 // GetDetailsByPresentID 根据项目ID获取详情
-func (m *DAO) GetDetailsByPresentID(ID int) ([]model.TaPresentationDetail, error) {
+func (m *DAO) GetDetailsByPresentID(ID string) ([]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) {
+func (m *DAO) GetPresentation(checkID string, typeID int) (*model.TaPresentation, error) {
 	var presentation model.TaPresentation
-	_, err := m.db.Where("check_id=?", checkID).And("check_type=?", typeID).Get(&presentation)
+	_, err := m.db.Where("check_id=?", checkID).And("check_type='" + strconv.Itoa(typeID) + "'").Get(&presentation)
 	return &presentation, err
 }
 
 // SavePresentation 新增体检项目信息
 func (m *DAO) SavePresentation(info model.TaPresentation) (*model.TaPresentation, error) {
+	info.Id = utils.GetGUID()
 	_, err := m.db.Insert(&info)
 	return &info, err
 }
@@ -154,8 +135,8 @@ func (m *DAO) SavePresentationDetail(details []model.TaPresentationDetail) error
 }
 
 // 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)
+func (m *DAO) DeletePresentionDetail(ID string) error {
+	sql := "delete from ta_presentation_detail where presentation_id=?"
+	_, err := m.db.Exec(sql, ID)
 	return err
 }

models/model/ta_body_check.go

@@ -5,11 +5,11 @@ import (
 )
 
 type TaBodyCheck struct {
-	Id          int       `xorm:"not null pk autoincr INT(11)"`
-	UserId      int       `xorm:"not null INT(11)"`
-	EquipmentId string    `xorm:"not null VARCHAR(100)"`
+	Id          string    `xorm:"not null pk VARCHAR(64)"`
+	UserId      string    `xorm:"VARCHAR(64)"`
+	EquipmentId string    `xorm:"not null VARCHAR(200)"`
 	CreateDate  time.Time `xorm:"not null DATETIME"`
 	Status      int       `xorm:"not null comment('1为正常') INT(11)"`
-	CaseId      int       `xorm:"INT(11)"`
+	CaseId      string    `xorm:"VARCHAR(64)"`
 	ReportUrl   string    `xorm:"TEXT"`
 }

models/model/ta_case_equipment.go

@@ -5,8 +5,8 @@ import (
 )
 
 type TaCaseEquipment struct {
-	Id          int       `xorm:"not null pk autoincr INT(11)"`
-	CaseId      int       `xorm:"not null INT(11)"`
+	Id          string    `xorm:"not null pk VARCHAR(64)"`
+	CaseId      string    `xorm:"not null pk VARCHAR(64)"`
 	EquipmentId string    `xorm:"VARCHAR(200)"`
 	Status      int       `xorm:"INT(11)"`
 	CreateDate  time.Time `xorm:"DATETIME"`

models/model/ta_presentation.go

@@ -5,8 +5,8 @@ import (
 )
 
 type TaPresentation struct {
-	Id          int       `xorm:"not null pk autoincr INT(11)"`
-	CheckId     int       `xorm:"not null INT(11)"`
+	Id          string    `xorm:"not null pk VARCHAR(64)"`
+	CheckId     string    `xorm:"not null pk VARCHAR(64)"`
 	CheckType   int       `xorm:"SMALLINT(6)"`
 	CheckDate   time.Time `xorm:"DATETIME"`
 	CheckResult string    `xorm:"TEXT"`

models/model/ta_presentation_detail.go

@@ -1,8 +1,8 @@
 package model
 
 type TaPresentationDetail struct {
-	Id             int    `xorm:"not null pk autoincr INT(11)"`
-	PresentationId int    `xorm:"not null INT(11)"`
+	Id             string `xorm:"not null pk VARCHAR(64)"`
+	PresentationId string `xorm:"not null pk VARCHAR(64)"`
 	CheckName      string `xorm:"VARCHAR(50)"`
 	CheckVal       string `xorm:"VARCHAR(500)"`
 	SpecName       string `xorm:"VARCHAR(50)"`

models/model/td_check_spec.go

@@ -1,7 +1,7 @@
 package model
 
 type TdCheckSpec struct {
-	Id       int    `xorm:"not null pk autoincr INT(11)"`
+	Id       string `xorm:"not null pk VARCHAR(64)"`
 	Name     string `xorm:"not null VARCHAR(50)"`
 	SortName string `xorm:"not null VARCHAR(50)"`
 	Standard string `xorm:"VARCHAR(50)"`

models/model/td_check_type.go

@@ -1,6 +1,6 @@
 package model
 
 type TdCheckType struct {
-	Id       int    `xorm:"not null pk autoincr INT(11)"`
+	Id       string `xorm:"not null pk VARCHAR(64)"`
 	TypeName string `xorm:"VARCHAR(50)"`
 }

models/statistics/cardcoupon.go

@@ -105,7 +105,7 @@ func (m *StatisticsDAO) CardCouponStatistics(caseids, ctype, name string, page,
 }
 
 // CardCouponStatisticsCount 获取总数
-func (m *StatisticsDAO) CardCouponStatisticsCount(caseids, ctype, name string) (int, error) {
+func (m *StatisticsDAO) CardCouponStatisticsCount(caseids, ctype, name string) ([]CardCouponStatistics, error) {
 	var cardCoupons []CardCouponStatistics
 	couponsql := `SELECT
 		b.case_name,
@@ -175,7 +175,7 @@ func (m *StatisticsDAO) CardCouponStatisticsCount(caseids, ctype, name string) (
 		// 	sql = "select * from (" + gymcardsql + ") tab"
 		// 	break
 		default:
-			return 0, errors.New("类型不正确")
+			return cardCoupons, errors.New("类型不正确")
 		}
 	} else {
 		sql = "select * from (" + cardsql + " union " + couponsql + ") tab"
@@ -185,7 +185,7 @@ func (m *StatisticsDAO) CardCouponStatisticsCount(caseids, ctype, name string) (
 		sql = sql + ` where c_name like '%` + name + `%'`
 	}
 	err := m.db.Sql(sql).Find(&cardCoupons)
-	return len(cardCoupons), err
+	return cardCoupons, err
 }
 
 // CardCouponUsedStatistics 卡券使用情况
@@ -308,7 +308,7 @@ func (m *StatisticsDAO) CardCouponUsedStatistics(caseids, tel, name, receivetype
 }
 
 // CardCouponUsedCountStatistics 获取卡券使用情况统计
-func (m *StatisticsDAO) CardCouponUsedCountStatistics(caseids, tel, name, receivetype, begindate, enddate, status string) (int, error) {
+func (m *StatisticsDAO) CardCouponUsedCountStatistics(caseids, tel, name, receivetype, begindate, enddate, status string) ([]CardCouponUsedStatistics, error) {
 	var cardCoupons []CardCouponUsedStatistics
 	cardsql := `SELECT
 							d.case_name,
@@ -402,7 +402,7 @@ func (m *StatisticsDAO) CardCouponUsedCountStatistics(caseids, tel, name, receiv
 		sql = sql + ` and DATE_FORMAT(tab.receive_date, '%Y-%m-%d') <= '` + enddate + `'`
 	}
 	err := m.db.Sql(sql).Find(&cardCoupons)
-	return len(cardCoupons), err
+	return cardCoupons, err
 }
 
 // CardCouponVerifyStatistics 卡券使用情况
@@ -481,7 +481,7 @@ func (m *StatisticsDAO) CardCouponVerifyStatistics(caseids, tel, name, status st
 }
 
 // CardCouponVerifyStatisticsCount 获取卡券核销情况数量统计
-func (m *StatisticsDAO) CardCouponVerifyStatisticsCount(caseids, tel, name, status string) (int, error) {
+func (m *StatisticsDAO) CardCouponVerifyStatisticsCount(caseids, tel, name, status string) ([]CardCouponVerifyStatistics, error) {
 	var cardCoupons []CardCouponVerifyStatistics
 	sql := `SELECT
 							c.case_id,
@@ -535,5 +535,5 @@ func (m *StatisticsDAO) CardCouponVerifyStatisticsCount(caseids, tel, name, stat
 		}
 	}
 	err := m.db.Sql(sql).Find(&cardCoupons)
-	return len(cardCoupons), err
+	return cardCoupons, err
 }

models/statistics/course.go

@@ -63,7 +63,7 @@ func (m *StatisticsDAO) GetCourseOrdersStatistics(typeid, caseids, name, beginda
 }
 
 // GetCourseOrdersStatisticsCount 获取课程订单统计数量
-func (m *StatisticsDAO) GetCourseOrdersStatisticsCount(typeid, caseids, name, begindate, enddate string) (int, error) {
+func (m *StatisticsDAO) GetCourseOrdersStatisticsCount(typeid, caseids, name, begindate, enddate string) ([]CourseOrdersStatistics, error) {
 	var courseOrders []CourseOrdersStatistics
 	sql := `SELECT
 					a.orders_id,
@@ -98,7 +98,7 @@ func (m *StatisticsDAO) GetCourseOrdersStatisticsCount(typeid, caseids, name, be
 	}
 
 	err := m.db.Sql(sql).Find(&courseOrders)
-	return len(courseOrders), err
+	return courseOrders, err
 }
 
 // CourseStatistics 课程统计数据
@@ -166,7 +166,7 @@ func (m *StatisticsDAO) GetCourseStatistics(typeid, caseids, name string, page,
 }
 
 // GetCourseStatisticsCount 获取课程统计信息数量
-func (m *StatisticsDAO) GetCourseStatisticsCount(typeid, caseids, name string) (int, error) {
+func (m *StatisticsDAO) GetCourseStatisticsCount(typeid, caseids, name string) ([]CourseStatistics, error) {
 	var courses []CourseStatistics
 	sql := `SELECT
 					a.course_id,
@@ -188,5 +188,5 @@ func (m *StatisticsDAO) GetCourseStatisticsCount(typeid, caseids, name string) (
 		sql = sql + ` and a.course_name like '%` + name + `%'`
 	}
 	err := m.db.Sql(sql).Find(&courses)
-	return len(courses), err
+	return courses, err
 }

models/statistics/goods.go

@@ -63,7 +63,7 @@ func (m *StatisticsDAO) GetGoodsStatistics(caseids, typeid, name string, page, p
 }
 
 // GetGoodsStatisticsCount 获取总数
-func (m *StatisticsDAO) GetGoodsStatisticsCount(caseids, typeid, name string) (int, error) {
+func (m *StatisticsDAO) GetGoodsStatisticsCount(caseids, typeid, name string) ([]GoodsStatistics, error) {
 	var goods []GoodsStatistics
 	sql := `SELECT
 					e.case_name,
@@ -103,7 +103,7 @@ func (m *StatisticsDAO) GetGoodsStatisticsCount(caseids, typeid, name string) (i
 					c.type_name,
 					b.price`
 	err := m.db.Sql(sql).Find(&goods)
-	return len(goods), err
+	return goods, err
 }
 
 // GoodsOrdersStatistics 商品订单统计信息
@@ -120,6 +120,7 @@ type GoodsOrdersStatistics struct {
 	CustomerName string
 	Phone        string
 	Name         string
+	Remark       string
 	Details      []model.TaGoodsOrdersDetail
 }
 
@@ -138,7 +139,8 @@ func (m *StatisticsDAO) GetGoodsOrderStatistics(status, usertype, caseids, begin
 						a.table_no,
 						c.customer_name,
 						c. NAME,
-						c.phone
+						c.phone,
+						a.remark
 					FROM
 						ta_goods_orders a
 					INNER JOIN ta_customer b ON a.user_id = b.customer_id
@@ -176,7 +178,7 @@ func (m *StatisticsDAO) GetGoodsOrderStatistics(status, usertype, caseids, begin
 }
 
 // GetGoodsOrderStatisticsCount 获取商品订单Count
-func (m *StatisticsDAO) GetGoodsOrderStatisticsCount(status, usertype, caseids, begindate, enddate string) (int, error) {
+func (m *StatisticsDAO) GetGoodsOrderStatisticsCount(status, usertype, caseids, begindate, enddate string) ([]GoodsOrdersStatistics, error) {
 	var orders []GoodsOrdersStatistics
 	sql := `SELECT
 						a.orders_id,
@@ -190,7 +192,8 @@ func (m *StatisticsDAO) GetGoodsOrderStatisticsCount(status, usertype, caseids,
 						a.table_no,
 						c.customer_name,
 						c. NAME,
-						c.phone
+						c.phone,
+						a.remark
 					FROM
 						ta_goods_orders a
 					INNER JOIN ta_customer b ON a.user_id = b.customer_id
@@ -212,5 +215,5 @@ func (m *StatisticsDAO) GetGoodsOrderStatisticsCount(status, usertype, caseids,
 	}
 
 	err := m.db.Sql(sql).Find(&orders)
-	return len(orders), err
+	return orders, err
 }

routers/common.go

@@ -280,11 +280,18 @@ func getCommonRoutes() beego.LinkNamespace {
 
 		// 统计类
 		beego.NSRouter("/statistics/goods", &statistics.StatisticsController{}, "get:GetGoodsStatistics"),
+		beego.NSRouter("/statistics/goods/excel", &statistics.StatisticsController{}, "get:GetGoodsStatisticsExcel"),
 		beego.NSRouter("/statistics/goodsorders", &statistics.StatisticsController{}, "get:GetGoodsOrdersStatistics"),
+		beego.NSRouter("/statistics/goodsorders/excel", &statistics.StatisticsController{}, "get:GetGoodsOrdersStatisticsExcel"),
 		beego.NSRouter("/statistics/courseorders", &statistics.StatisticsController{}, "get:GetCourseOrdersStatistics"),
+		beego.NSRouter("/statistics/courseorders/excel", &statistics.StatisticsController{}, "get:GetCourseOrdersStatisticsExcel"),
 		beego.NSRouter("/statistics/courses", &statistics.StatisticsController{}, "get:GetCourseStatistics"),
+		beego.NSRouter("/statistics/courses/excel", &statistics.StatisticsController{}, "get:GetCourseStatisticsExcel"),
 		beego.NSRouter("/statistics/cardcoupon", &statistics.StatisticsController{}, "get:CardCouponStatistics"),
+		beego.NSRouter("/statistics/cardcoupon/excel", &statistics.StatisticsController{}, "get:CardCouponStatisticsExcel"),
 		beego.NSRouter("/statistics/cardcouponused", &statistics.StatisticsController{}, "get:CardCouponUsedStatistics"),
+		beego.NSRouter("/statistics/cardcouponused/excel", &statistics.StatisticsController{}, "get:CardCouponUsedStatisticsExcel"),
 		beego.NSRouter("/statistics/cardcouponverify", &statistics.StatisticsController{}, "get:CardCouponVerifyStatistics"),
+		beego.NSRouter("/statistics/cardcouponverify/excel", &statistics.StatisticsController{}, "get:CardCouponVerifyStatisticsExcel"),
 	)
 }

routers/guest.go

@@ -1,6 +1,7 @@
 package routers
 
 import (
+	"cdkj-check/controllers/bodycheck"
 	"spaceofcheng/services/controllers"
 	"spaceofcheng/services/controllers/cases"
 	"spaceofcheng/services/controllers/course"
@@ -57,5 +58,8 @@ func getGuestRoutes() beego.LinkNamespace {
 		beego.NSRouter("/wechat/mini/decodedata", &controllers.BaseController{}, "post:DecodeMiniData"),
 
 		beego.NSRouter("/websocket/:grps/:id", &controllers.BaseController{}, "get:Ws"),
+
+		// 体检参数接收
+		beego.NSRouter("/PostCheckResult", &bodycheck.BodyCheckController{}, "post:PostCheckResult"),
 	)
 }

routers/wechat.go

@@ -1,6 +1,7 @@
 package routers
 
 import (
+	"cdkj-check/controllers/bodycheck"
 	"spaceofcheng/services/controllers/card"
 	"spaceofcheng/services/controllers/coupon"
 	"spaceofcheng/services/controllers/course"
@@ -69,5 +70,8 @@ func getWechatRoutes() beego.LinkNamespace {
 		beego.NSRouter("/card/detail/:id", &card.CardController{}, "get:GetCardWithCustomer"),
 		beego.NSRouter("/card/:id", &card.CardController{}, "post:ReceiveCard"),
 		beego.NSRouter("/channel/card/:id", &card.CardController{}, "post:ChannelReceiveCard"),
+
+		// 体检
+		beego.NSRouter("/GetCheckByUser", &bodycheck.BodyCheckController{}, "get:GetCheckByUser"),
 	)
 }

service/bodycheck/bodycheck.go

@@ -3,130 +3,214 @@ package bodycheck
 import (
 	"errors"
 	"spaceofcheng/services/models/bodycheck"
+	"spaceofcheng/services/models/customer"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
+	"strconv"
+	"time"
+
+	"github.com/astaxie/beego"
+	"github.com/astaxie/beego/config"
+	"github.com/zjxpcyc/wechat/wx"
 )
 
-// BodycheckServ 系统处理
-type BodycheckServ struct {
-	ctx *utils.Context
-	dao *bodycheck.DAO
+// BodyCheckServ 系统处理
+type BodyCheckServ struct {
+	ctx         *utils.Context
+	dao         *bodycheck.DAO
+	customerdao *customer.CustomerDAO
 }
 
-// NewBodycheckServ 初始化
-func NewBodycheckServ(ctx *utils.Context) *BodycheckServ {
-	return &BodycheckServ{
-		ctx: ctx,
-		dao: bodycheck.NewDAO(ctx),
+// NewBodyCheckServ 初始化
+func NewBodyCheckServ(ctx *utils.Context) *BodyCheckServ {
+	return &BodyCheckServ{
+		ctx:         ctx,
+		dao:         bodycheck.NewDAO(ctx),
+		customerdao: customer.NewCustomerDAO(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()
+
+// GetCheckByUser 根据用户获取体检报告
+func (s *BodyCheckServ) GetCheckByUser() (map[string]interface{}, error) {
+	customer := s.ctx.Get("customer").(model.TaCustomer)
+	bodyCheck, err := s.dao.GetBodyCheckByUser(customer.CustomerId)
 	if err != nil {
-		utils.LogError("获取项目指标信息失败: " + err.Error())
-		return nil, errors.New("获取项目指标信息失败")
+		return nil, err
 	}
-	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获取体检信息失败")
+	if len(bodyCheck) == 0 {
+		return nil, errors.New("没有查询到数据")
 	}
-	return check, nil
-}
-func (s *BodycheckServ) SaveBodyCheckInfo(checkNew model.TaBodyCheck) (*model.TaBodyCheck, error) {
-	checkNews, err := s.dao.SaveBodyCheckInfo(checkNew)
+	presentations, err := s.dao.GetPresentationByCheckID(bodyCheck[0].Id)
 	if err != nil {
-		utils.LogError("用户体检信息新增失败: " + err.Error())
-		return nil, errors.New("用户体检信息新增失败")
+		return nil, err
 	}
-	return checkNews, nil
+
+	return map[string]interface{}{
+		"Message":  presentations,
+		"Info":     bodyCheck,
+		"UserInfo": customer,
+	}, 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("获取设备案场信息失败")
+
+// PostCheckResult 测量结果返回
+func (s *BodyCheckServ) PostCheckResult(formVal map[string]interface{}) error {
+	type CheckResult struct {
+		WechatAccount string
+		EquipmentId   string
+		CheckType     int
+		CheckDate     time.Time
+		CheckResult   string
+		ReportUrl     string
+		HMSReportUrl  string
 	}
-	return caseEquipment, nil
-}
-func (s *BodycheckServ) GetUserByOpenID(openid string) (*model.TaCustomer, error) {
-	customer, err := s.dao.GetUserByOpenID(openid)
+	var result = CheckResult{}
+
+	result.EquipmentId = formVal["EquipmentId"].(string)
+	result.WechatAccount = formVal["WechatAccount"].(string)
+	// result.CheckResult = formVal["CheckResult"].(string)
+	result.CheckResult = ""
+	result.ReportUrl = formVal["ReportUrl"].(string)
+	result.HMSReportUrl = formVal["HMSReportUrl"].(string)
+	result.CheckType = int(formVal["CheckType"].(float64))
+
+	var err error
+	loc, _ := time.LoadLocation("Local")
+	result.CheckDate, err = time.ParseInLocation("2006-01-02 15:04:05", formVal["CheckDate"].(string), loc)
 	if err != nil {
-		utils.LogError("根据openid获取用户信息失败: " + err.Error())
-		return nil, errors.New("根据openid获取用户信息失败")
+		utils.LogError("参数错误：", err)
+		return errors.New("参数错误")
 	}
-	return customer, nil
-}
 
-func (s *BodycheckServ) GetPresentationByCheckID(checkID int) ([]bodycheck.Presentation, error) {
-	presentations, err := s.dao.GetPresentationByCheckID(checkID)
+	openid := result.WechatAccount
+	customer, err := s.customerdao.GetCustWithWXByOpenID(openid)
 	if err != nil {
-		utils.LogError("根据体检ID获取项目信息失败: " + err.Error())
-		return nil, errors.New("根据体检ID获取项目信息失败")
+		utils.LogError("获取用户信息失败：", err)
+		return errors.New("获取用户信息失败")
 	}
-	return presentations, nil
-}
-
-func (s *BodycheckServ) GetDetailsByPresentID(ID int) ([]model.TaPresentationDetail, error) {
-	detail, err := s.dao.GetDetailsByPresentID(ID)
+	if customer == nil || customer.CustomerId == "" {
+		return errors.New("没有当前用户信息！")
+	}
+	userid := customer.CustomerId
+	checkinfo, err := s.dao.GetCheckByUserAndEquipmentID(userid, result.EquipmentId)
 	if err != nil {
-		utils.LogError("根据项目ID获取详情失败: " + err.Error())
-		return nil, errors.New("根据项目ID获取详情失败")
+		utils.LogError("获取体检信息失败：", err)
+		return errors.New("获取体检信息失败")
 	}
-	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("获取体检项目信息失败")
+	if checkinfo == nil || checkinfo.Id != "" || time.Now().Local().Format("2006-01-02") != checkinfo.CreateDate.Format("2006-01-02") {
+		caseEquipment, err := s.dao.GetCaseEquipment(result.EquipmentId)
+		if err != nil {
+			utils.LogError("获取设备信息失败：", err)
+			return errors.New("获取设备信息失败")
+		}
+		if caseEquipment == nil || caseEquipment.Id == "" {
+			return errors.New("设备未维护！")
+		}
+
+		var checkNew = model.TaBodyCheck{}
+		checkNew.CaseId = caseEquipment.CaseId
+		checkNew.EquipmentId = result.EquipmentId
+		checkNew.UserId = userid
+		checkNew.ReportUrl = result.HMSReportUrl
+		checkNew.CreateDate = result.CheckDate
+		checkinfo, err = s.dao.SaveBodyCheckInfo(checkNew)
+
+		wxconf, _ := config.NewConfig("ini", "conf/wechat.conf")
+		messageTplID := wxconf.String("messageTplID")
+
+		org := s.ctx.Get("org").(model.SysOrg)
+
+		utils.WxClientFor(org.OrgId).SendTplMessage(result.WechatAccount, messageTplID, beego.AppConfig.String("resultURL"), map[string]wx.TplMessageData{
+			"first": wx.TplMessageData{
+				Value: "您的体检报告已生成",
+			},
+			"keyword1": wx.TplMessageData{
+				Value: checkinfo.Id,
+			},
+			"keyword2": wx.TplMessageData{
+				Value: result.CheckDate.Format("2006-01-02 15:04"),
+			},
+			"remark": wx.TplMessageData{
+				Value: "",
+			},
+		})
 	}
-	return presentation, nil
-}
 
-func (s *BodycheckServ) SavePresentation(info model.TaPresentation) (*model.TaPresentation, error) {
-	presentation, err := s.dao.SavePresentation(info)
+	presentation, err := s.dao.GetPresentation(checkinfo.Id, result.CheckType)
 	if err != nil {
-		utils.LogError("新增体检项目信息失败: " + err.Error())
-		return nil, errors.New("新增体检项目信息失败")
+		utils.LogError("获取报告明细失败：", err)
+		return 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("更新体检项目信息失败")
+	if presentation == nil || presentation.Id != "" {
+		// 新增
+		var preNew = model.TaPresentation{}
+		preNew.CheckId = checkinfo.Id
+		preNew.CheckDate = result.CheckDate
+		preNew.CheckResult = result.CheckResult
+		preNew.CheckType = result.CheckType
+		preNew.ReportUrl = result.ReportUrl
+		presentation, err = s.dao.SavePresentation(preNew)
+		if err != nil {
+			utils.LogError("保存报告明细失败：", err)
+			return errors.New("保存报告明细失败")
+		}
+	} else {
+		// 修改
+		presentation.CheckDate = result.CheckDate
+		presentation.CheckResult = result.CheckResult
+		presentation.ReportUrl = result.ReportUrl
+		err = s.dao.UpdatePresentation(presentation)
+		if err != nil {
+			utils.LogError("修改报告明细失败：", err)
+			return errors.New("修改报告明细失败")
+		}
+		// 删除之前的记录
+		err = s.dao.DeletePresentionDetail(presentation.Id)
+		if err != nil {
+			utils.LogError("删除报告明细失败：", err)
+			return errors.New("删除报告明细失败")
+		}
 	}
-	return nil
-}
 
-func (s *BodycheckServ) SavePresentationDetail(details []model.TaPresentationDetail) error {
-	err := s.dao.SavePresentationDetail(details)
+	specs, err := s.dao.GetCheckSpecs()
 	if err != nil {
-		utils.LogError("保存体检项目明细失败: " + err.Error())
-		return errors.New("保存体检项目明细失败")
+		utils.LogError("获取spec信息失败：", err)
+		return errors.New("获取spec信息失败")
 	}
-	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删除明细信息失败")
+	if len(formVal) > 0 {
+		var details []model.TaPresentationDetail
+		for k, v := range formVal {
+			if k != "WechatAccount" && k != "EquipmentId" && k != "CheckType" && k != "CheckDate" && k != "CheckResult" && k != "ReportUrl" && k != "HMSReportUrl" && k != "WXID" {
+				var detail model.TaPresentationDetail
+				detail.CheckName = k
+				switch vx := v.(type) {
+				case string:
+					detail.CheckVal = vx
+				case float64:
+					detail.CheckVal = strconv.FormatFloat(vx, 'f', 2, 64)
+				}
+
+				detail.PresentationId = presentation.Id
+				var specName = ""
+				for _, spec := range specs {
+					if spec.SortName == k {
+						specName = spec.Name
+						break
+					}
+				}
+				detail.SpecName = specName
+				detail.Id = utils.GetGUID()
+				details = append(details, detail)
+			}
+		}
+		if len(details) > 0 {
+			err := s.dao.SavePresentationDetail(details)
+			if err != nil {
+				utils.LogError("保存体检明细失败：", err)
+				return errors.New("保存体检明细失败")
+			}
+		}
 	}
 	return nil
 }

service/card/card.go

@@ -4,6 +4,7 @@ import (
 	"errors"
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/card"
+	"spaceofcheng/services/models/coupon"
 	"spaceofcheng/services/models/course"
 	"spaceofcheng/services/models/customer"
 	"spaceofcheng/services/models/model"
@@ -23,6 +24,7 @@ type CardServ struct {
 	custDao   *customer.CustomerDAO
 	userDao   *system.UserDAO
 	courseDao *course.CourseDAO
+	coupondao *coupon.CouponDAO
 }
 
 // NewCardServ 初始化
@@ -33,6 +35,7 @@ func NewCardServ(ctx *utils.Context) *CardServ {
 		custDao:   customer.NewCustomerDAO(ctx),
 		userDao:   system.NewUserDAO(ctx),
 		courseDao: course.NewCourseDAO(ctx),
+		coupondao: coupon.NewCouponDAO(ctx),
 	}
 }
 
@@ -195,6 +198,7 @@ func (s *CardServ) GiveCard(CardID string, uids []string) error {
 		if err := s.GiveCardTo(&user, cust, card); err != nil {
 			return err
 		}
+
 	}
 
 	return nil
@@ -246,12 +250,29 @@ func (s *CardServ) GiveCardTo(from *model.SysUser, to *model.TaCustomer, card *c
 		Price:            card.Price,
 	}
 
+	// 放入赠送记录
+	rec := model.TaCouponGiveRecord{
+		GiftType:   models.GIVE_GIFT_COUPON,
+		GiftId:     card.CardId,
+		GiftName:   card.CardName,
+		FromId:     from.UserId,
+		FromName:   from.UserName,
+		ToId:       to.CustomerId,
+		ToName:     to.CustomerName,
+		CreateDate: time.Now().Local(),
+	}
+
 	// 入库
 	if err := s.dao.SaveCustomerCards([]model.TaCustomerCard{custcard}); err != nil {
 		utils.LogError("保存客户卡失败: " + err.Error())
 		return errors.New("保存客户卡失败")
 	}
 
+	if err := s.coupondao.SaveCouponRecoreds([]model.TaCouponGiveRecord{rec}); err != nil {
+		utils.LogError("保存卡赠送记录失败: " + err.Error())
+		return errors.New("保存卡赠送记录失败")
+	}
+
 	// 加入我的课程信息
 	err := s.SaveCustomerCourseByCard(&custcard)
 	if err != nil {

service/statistics/cardcoupon.go

@@ -2,6 +2,7 @@ package statistics
 
 import (
 	"errors"
+	"spaceofcheng/services/models/statistics"
 	"spaceofcheng/services/service"
 	"spaceofcheng/services/utils"
 )
@@ -24,7 +25,7 @@ func (s *StatisticsServ) CardCouponStatistics(caseids, ctype, name string, page,
 		utils.LogError("获取卡券统计数据失败: " + err.Error())
 		return nil, errors.New("获取卡券统计数据失败")
 	}
-	total, err := s.dao.CardCouponStatisticsCount(caseids, ctype, name)
+	all, err := s.dao.CardCouponStatisticsCount(caseids, ctype, name)
 	if err != nil {
 		utils.LogError("获取卡券统计数据失败: " + err.Error())
 		return nil, errors.New("获取卡券统计数据失败")
@@ -33,11 +34,26 @@ func (s *StatisticsServ) CardCouponStatistics(caseids, ctype, name string, page,
 	return map[string]interface{}{
 		"list":     list,
 		"pagesize": pageSize,
-		"pagenum":  total,
+		"pagenum":  len(all),
 		"page":     page,
 	}, nil
 }
 
+// CardCouponStatisticsExcel 导出
+func (s *StatisticsServ) CardCouponStatisticsExcel(caseids, ctype, name string) ([]statistics.CardCouponStatistics, error) {
+	if caseids == "" {
+		return nil, errors.New("请先选择案场信息")
+	}
+
+	all, err := s.dao.CardCouponStatisticsCount(caseids, ctype, name)
+	if err != nil {
+		utils.LogError("获取卡券统计数据失败: " + err.Error())
+		return nil, errors.New("获取卡券统计数据失败")
+	}
+
+	return all, nil
+}
+
 // CardCouponUsedStatistics 获取卡券使用统计信息
 func (s *StatisticsServ) CardCouponUsedStatistics(caseids, tel, name, receivetype, begindate, enddate, status string, page, pageSize int) (map[string]interface{}, error) {
 	if pageSize == 0 {
@@ -56,7 +72,7 @@ func (s *StatisticsServ) CardCouponUsedStatistics(caseids, tel, name, receivetyp
 		utils.LogError("获取卡券统计数据失败: " + err.Error())
 		return nil, errors.New("获取卡券统计数据失败")
 	}
-	total, err := s.dao.CardCouponUsedCountStatistics(caseids, tel, name, receivetype, begindate, enddate, status)
+	all, err := s.dao.CardCouponUsedCountStatistics(caseids, tel, name, receivetype, begindate, enddate, status)
 	if err != nil {
 		utils.LogError("获取卡券统计数据失败: " + err.Error())
 		return nil, errors.New("获取卡券统计数据失败")
@@ -65,12 +81,22 @@ func (s *StatisticsServ) CardCouponUsedStatistics(caseids, tel, name, receivetyp
 	return map[string]interface{}{
 		"list":     list,
 		"pagesize": pageSize,
-		"pagenum":  total,
+		"pagenum":  len(all),
 		"page":     page,
 	}, nil
 }
 
-// CardCouponVerifyStatistics 获取卡券使用统计信息
+// CardCouponUsedStatisticsExcel 卡券使用数据导出
+func (s *StatisticsServ) CardCouponUsedStatisticsExcel(caseids, tel, name, receivetype, begindate, enddate, status string) ([]statistics.CardCouponUsedStatistics, error) {
+	all, err := s.dao.CardCouponUsedCountStatistics(caseids, tel, name, receivetype, begindate, enddate, status)
+	if err != nil {
+		utils.LogError("获取卡券统计数据失败: " + err.Error())
+		return nil, errors.New("获取卡券统计数据失败")
+	}
+	return all, nil
+}
+
+// CardCouponVerifyStatistics 获取卡券核销统计信息
 func (s *StatisticsServ) CardCouponVerifyStatistics(caseids, tel, name, status string, page, pageSize int) (map[string]interface{}, error) {
 	if pageSize == 0 {
 		pageSize = service.PAGENUM
@@ -88,7 +114,7 @@ func (s *StatisticsServ) CardCouponVerifyStatistics(caseids, tel, name, status s
 		utils.LogError("获取卡券统计数据失败: " + err.Error())
 		return nil, errors.New("获取卡券统计数据失败")
 	}
-	total, err := s.dao.CardCouponVerifyStatisticsCount(caseids, tel, name, status)
+	all, err := s.dao.CardCouponVerifyStatisticsCount(caseids, tel, name, status)
 	if err != nil {
 		utils.LogError("获取卡券统计数据失败: " + err.Error())
 		return nil, errors.New("获取卡券统计数据失败")
@@ -97,7 +123,20 @@ func (s *StatisticsServ) CardCouponVerifyStatistics(caseids, tel, name, status s
 	return map[string]interface{}{
 		"list":     list,
 		"pagesize": pageSize,
-		"pagenum":  total,
+		"pagenum":  len(all),
 		"page":     page,
 	}, nil
 }
+
+// CardCouponVerifyStatisticsExcel 卡券核销统计导出
+func (s *StatisticsServ) CardCouponVerifyStatisticsExcel(caseids, tel, name, status string) ([]statistics.CardCouponVerifyStatistics, error) {
+	if caseids == "" {
+		return nil, errors.New("请先选择案场信息")
+	}
+	all, err := s.dao.CardCouponVerifyStatisticsCount(caseids, tel, name, status)
+	if err != nil {
+		utils.LogError("获取卡券统计数据失败: " + err.Error())
+		return nil, errors.New("获取卡券统计数据失败")
+	}
+	return all, nil
+}

service/statistics/course.go

@@ -2,6 +2,7 @@ package statistics
 
 import (
 	"errors"
+	"spaceofcheng/services/models/statistics"
 	"spaceofcheng/services/service"
 	"spaceofcheng/services/utils"
 )
@@ -24,7 +25,7 @@ func (s *StatisticsServ) GetCourseOrdersStatistics(typeid, caseids, name, begind
 		utils.LogError("获取课程订单统计数据失败: " + err.Error())
 		return nil, errors.New("获取课程订单统计数据失败")
 	}
-	total, err := s.dao.GetCourseOrdersStatisticsCount(typeid, caseids, name, begindate, enddate)
+	all, err := s.dao.GetCourseOrdersStatisticsCount(typeid, caseids, name, begindate, enddate)
 	if err != nil {
 		utils.LogError("获取课程订单统计数据失败: " + err.Error())
 		return nil, errors.New("获取课程订单统计数据失败")
@@ -33,11 +34,24 @@ func (s *StatisticsServ) GetCourseOrdersStatistics(typeid, caseids, name, begind
 	return map[string]interface{}{
 		"list":     list,
 		"pagesize": pageSize,
-		"pagenum":  total,
+		"pagenum":  len(all),
 		"page":     page,
 	}, nil
 }
 
+// GetCourseOrdersStatisticsExcel 课程订单导出
+func (s *StatisticsServ) GetCourseOrdersStatisticsExcel(typeid, caseids, name, begindate, enddate string) ([]statistics.CourseOrdersStatistics, error) {
+	if caseids == "" {
+		return nil, errors.New("请先选择案场信息")
+	}
+	all, err := s.dao.GetCourseOrdersStatisticsCount(typeid, caseids, name, begindate, enddate)
+	if err != nil {
+		utils.LogError("获取课程订单统计数据失败: " + err.Error())
+		return nil, errors.New("获取课程订单统计数据失败")
+	}
+	return all, nil
+}
+
 // GetCourseStatistics 获取课程统计信息
 func (s *StatisticsServ) GetCourseStatistics(typeid, caseids, name string, page, pageSize int) (map[string]interface{}, error) {
 	if pageSize == 0 {
@@ -56,7 +70,7 @@ func (s *StatisticsServ) GetCourseStatistics(typeid, caseids, name string, page,
 		utils.LogError("获取课程统计数据失败: " + err.Error())
 		return nil, errors.New("获取课程统计数据失败")
 	}
-	total, err := s.dao.GetCourseStatisticsCount(typeid, caseids, name)
+	all, err := s.dao.GetCourseStatisticsCount(typeid, caseids, name)
 	if err != nil {
 		utils.LogError("获取课程统计数据失败: " + err.Error())
 		return nil, errors.New("获取课程统计数据失败")
@@ -65,7 +79,21 @@ func (s *StatisticsServ) GetCourseStatistics(typeid, caseids, name string, page,
 	return map[string]interface{}{
 		"list":     list,
 		"pagesize": pageSize,
-		"pagenum":  total,
+		"pagenum":  len(all),
 		"page":     page,
 	}, nil
 }
+
+// GetCourseStatisticsExcel 课程统计导出
+func (s *StatisticsServ) GetCourseStatisticsExcel(typeid, caseids, name string) ([]statistics.CourseStatistics, error) {
+	if caseids == "" {
+		return nil, errors.New("请先选择案场信息")
+	}
+
+	all, err := s.dao.GetCourseStatisticsCount(typeid, caseids, name)
+	if err != nil {
+		utils.LogError("获取课程统计数据失败: " + err.Error())
+		return nil, errors.New("获取课程统计数据失败")
+	}
+	return all, nil
+}

service/statistics/goods.go

@@ -2,6 +2,7 @@ package statistics
 
 import (
 	"errors"
+	"spaceofcheng/services/models/statistics"
 	"spaceofcheng/services/service"
 	"spaceofcheng/services/utils"
 )
@@ -24,7 +25,7 @@ func (s *StatisticsServ) GetGoodsStatistics(caseids, typeid, name string, page,
 		utils.LogError("获取商品统计数据失败: " + err.Error())
 		return nil, errors.New("获取商品统计数据失败")
 	}
-	total, err := s.dao.GetGoodsStatisticsCount(caseids, typeid, name)
+	all, err := s.dao.GetGoodsStatisticsCount(caseids, typeid, name)
 	if err != nil {
 		utils.LogError("获取商品统计数据失败: " + err.Error())
 		return nil, errors.New("获取商品统计数据失败")
@@ -33,11 +34,21 @@ func (s *StatisticsServ) GetGoodsStatistics(caseids, typeid, name string, page,
 	return map[string]interface{}{
 		"list":     list,
 		"pagesize": pageSize,
-		"pagenum":  total,
+		"pagenum":  len(all),
 		"page":     page,
 	}, nil
 }
 
+// GetGoodsStatisticsExcel 获取商品统计信息导出
+func (s *StatisticsServ) GetGoodsStatisticsExcel(caseids, typeid, name string) ([]statistics.GoodsStatistics, error) {
+	all, err := s.dao.GetGoodsStatisticsCount(caseids, typeid, name)
+	if err != nil {
+		utils.LogError("获取商品统计数据失败: " + err.Error())
+		return nil, errors.New("获取商品统计数据失败")
+	}
+	return all, nil
+}
+
 // GetGoodsOrdersStatistics 获取商品订单统计信息
 func (s *StatisticsServ) GetGoodsOrdersStatistics(status, usertype, caseids, begindate, enddate string, page, pageSize int) (map[string]interface{}, error) {
 	if pageSize == 0 {
@@ -56,7 +67,7 @@ func (s *StatisticsServ) GetGoodsOrdersStatistics(status, usertype, caseids, beg
 		utils.LogError("获取商品订单统计数据失败: " + err.Error())
 		return nil, errors.New("获取商品订单统计数据失败")
 	}
-	total, err := s.dao.GetGoodsOrderStatisticsCount(status, usertype, caseids, begindate, enddate)
+	all, err := s.dao.GetGoodsOrderStatisticsCount(status, usertype, caseids, begindate, enddate)
 	if err != nil {
 		utils.LogError("获取商品订单统计数据失败: " + err.Error())
 		return nil, errors.New("获取商品订单统计数据失败")
@@ -65,7 +76,22 @@ func (s *StatisticsServ) GetGoodsOrdersStatistics(status, usertype, caseids, beg
 	return map[string]interface{}{
 		"list":     list,
 		"pagesize": pageSize,
-		"pagenum":  total,
+		"pagenum":  len(all),
 		"page":     page,
 	}, nil
 }
+
+// GetGoodsOrdersStatisticsExcel 商品订单导出
+func (s *StatisticsServ) GetGoodsOrdersStatisticsExcel(status, usertype, caseids, begindate, enddate string) ([]statistics.GoodsOrdersStatistics, error) {
+	if caseids == "" {
+		return nil, errors.New("请先选择案场信息")
+	}
+
+	all, err := s.dao.GetGoodsOrderStatisticsCount(status, usertype, caseids, begindate, enddate)
+	if err != nil {
+		utils.LogError("获取商品订单统计数据失败: " + err.Error())
+		return nil, errors.New("获取商品订单统计数据失败")
+	}
+
+	return all, nil
+}