yunzerwebsiteallinone/go/controllers/app_oa_dailyreport.go

package controllers

import (
	"encoding/json"
	"io"
	"strconv"
	"strings"

	"server/pkg/identity"
	"server/services/dailyreport"
)

// OA 工作日报（小程序端）。与后台 /backend/oa/dailyreport/* 共用
// services/dailyreport 的权限与校验逻辑，仅在响应包装与上传入口上有差异。

// dailyReportCtx 解析移动端令牌并组装日报身份。
func (c *AppOaController) dailyReportCtx() (*dailyreport.UserContext, bool) {
	claims, err := c.oaClaims()
	if err != nil {
		code := identity.Status(err)
		c.oaErr(code, code, err.Error())
		return nil, false
	}
	u, err := dailyreport.BuildContext(
		uint64(claims.TenantId), uint64(claims.UserID), claims.Username, claims.UserType == "platform")
	if err != nil {
		code := dailyreport.StatusOf(err, 500)
		msg := err.Error()
		if code == 500 {
			msg = "操作失败，请稍后重试"
		}
		c.oaErr(code, code, msg)
		return nil, false
	}
	return u, true
}

func (c *AppOaController) dailyReportFail(err error) {
	code := dailyreport.StatusOf(err, 500)
	msg := err.Error()
	if code == 500 {
		msg = "操作失败，请稍后重试"
	}
	c.oaErr(code, code, msg)
}

func (c *AppOaController) dailyReportID() uint64 {
	id, _ := strconv.ParseUint(c.Ctx.Input.Param(":id"), 10, 64)
	if id == 0 {
		c.oaErr(400, 400, "无效ID")
	}
	return id
}

// DailyReportProfile GET /api/oa/dailyreport/profile
func (c *AppOaController) DailyReportProfile() {
	u, ok := c.dailyReportCtx()
	if !ok {
		return
	}
	teamOrgs := u.TeamOrgIDs
	if teamOrgs == nil {
		teamOrgs = []uint64{}
	}
	c.oaOk(map[string]interface{}{
		"user_id":       u.UID,
		"user_name":     u.Name,
		"org_id":        u.OrgID,
		"org_name":      u.OrgName,
		"is_admin":      u.IsAdmin,
		"can_view_team": u.CanViewTeam,
		"team_org_ids":  teamOrgs,
		"window_start":  dailyreport.WindowStart(),
		"window_end":    dailyreport.Today(),
		"backfill_days": dailyreport.BackfillDays,
	})
}

// DailyReportMineList GET /api/oa/dailyreport/mine/list
func (c *AppOaController) DailyReportMineList() {
	u, ok := c.dailyReportCtx()
	if !ok {
		return
	}
	page, _ := c.GetInt("page", 1)
	pageSize, _ := c.GetInt("pageSize", 20)
	res, err := dailyreport.ListMine(u, dailyreport.MineQuery{
		StartDate: strings.TrimSpace(c.GetString("start_date")),
		EndDate:   strings.TrimSpace(c.GetString("end_date")),
		Page:      page,
		PageSize:  pageSize,
	})
	if err != nil {
		c.dailyReportFail(err)
		return
	}
	c.oaOk(res)
}

// DailyReportCalendar GET /api/oa/dailyreport/calendar
// 我的日报近期热力图：months 默认 3，返回区间内逐日状态（草稿/已提交）。
func (c *AppOaController) DailyReportCalendar() {
	u, ok := c.dailyReportCtx()
	if !ok {
		return
	}
	months, _ := c.GetInt("months", 3)
	res, err := dailyreport.Calendar(u, months)
	if err != nil {
		c.dailyReportFail(err)
		return
	}
	c.oaOk(res)
}

// DailyReportSave POST /api/oa/dailyreport/save
func (c *AppOaController) DailyReportSave() {
	u, ok := c.dailyReportCtx()
	if !ok {
		return
	}
	var in dailyreport.SaveInput
	raw, err := io.ReadAll(c.Ctx.Request.Body)
	if err != nil || json.Unmarshal(raw, &in) != nil {
		c.oaErr(400, 400, "参数错误")
		return
	}
	item, err := dailyreport.Save(u, in)
	if err != nil {
		c.dailyReportFail(err)
		return
	}
	c.oaOk(item)
}

// DailyReportDetail GET /api/oa/dailyreport/detail/:id
func (c *AppOaController) DailyReportDetail() {
	u, ok := c.dailyReportCtx()
	if !ok {
		return
	}
	id := c.dailyReportID()
	if id == 0 {
		return
	}
	detail, err := dailyreport.GetDetail(u, id)
	if err != nil {
		c.dailyReportFail(err)
		return
	}
	c.oaOk(detail)
}

// DailyReportDelete DELETE /api/oa/dailyreport/delete/:id
func (c *AppOaController) DailyReportDelete() {
	u, ok := c.dailyReportCtx()
	if !ok {
		return
	}
	id := c.dailyReportID()
	if id == 0 {
		return
	}
	if err := dailyreport.Delete(u, id); err != nil {
		c.dailyReportFail(err)
		return
	}
	c.oaOk(map[string]interface{}{"id": id})
}

// DailyReportWithdraw POST /api/oa/dailyreport/withdraw/:id
// 撤销提交：已提交日报退回草稿并留存本次提交的内容快照，改完需重新提交。
func (c *AppOaController) DailyReportWithdraw() {
	u, ok := c.dailyReportCtx()
	if !ok {
		return
	}
	id := c.dailyReportID()
	if id == 0 {
		return
	}
	item, err := dailyreport.Withdraw(u, id)
	if err != nil {
		c.dailyReportFail(err)
		return
	}
	c.oaOk(item)
}

// DailyReportTeamStatus GET /api/oa/dailyreport/team/status
func (c *AppOaController) DailyReportTeamStatus() {
	u, ok := c.dailyReportCtx()
	if !ok {
		return
	}
	page, _ := c.GetInt("page", 1)
	pageSize, _ := c.GetInt("pageSize", 20)
	orgID, _ := c.GetInt64("org_id", 0)
	res, err := dailyreport.TeamStatus(u, dailyreport.TeamQuery{
		Date:     strings.TrimSpace(c.GetString("date")),
		OrgID:    uint64(orgID),
		Keyword:  strings.TrimSpace(c.GetString("keyword")),
		Page:     page,
		PageSize: pageSize,
	})
	if err != nil {
		c.dailyReportFail(err)
		return
	}
	c.oaOk(res)
}

// DailyReportTeamOrgs GET /api/oa/dailyreport/team/orgs
func (c *AppOaController) DailyReportTeamOrgs() {
	u, ok := c.dailyReportCtx()
	if !ok {
		return
	}
	orgs, err := dailyreport.TeamOrgs(u)
	if err != nil {
		c.dailyReportFail(err)
		return
	}
	c.oaOk(map[string]interface{}{"list": orgs})
}

// DailyReportComment POST /api/oa/dailyreport/comment
func (c *AppOaController) DailyReportComment() {
	u, ok := c.dailyReportCtx()
	if !ok {
		return
	}
	var payload oaDailyReportCommentPayload
	raw, err := io.ReadAll(c.Ctx.Request.Body)
	if err != nil || json.Unmarshal(raw, &payload) != nil {
		c.oaErr(400, 400, "参数错误")
		return
	}
	if payload.ReportID == 0 {
		c.oaErr(400, 400, "缺少日报ID")
		return
	}
	comment, err := dailyreport.AddComment(u, payload.ReportID, payload.Content, payload.ReplyToID)
	if err != nil {
		c.dailyReportFail(err)
		return
	}
	c.oaOk(comment)
}

// DailyReportCommentDelete DELETE /api/oa/dailyreport/comment/:id
func (c *AppOaController) DailyReportCommentDelete() {
	u, ok := c.dailyReportCtx()
	if !ok {
		return
	}
	id := c.dailyReportID()
	if id == 0 {
		return
	}
	if err := dailyreport.DeleteComment(u, id); err != nil {
		c.dailyReportFail(err)
		return
	}
	c.oaOk(map[string]interface{}{"id": id})
}

// DailyReportUpload POST /api/oa/dailyreport/upload（multipart，字段名 file）
// 复用 OA 附件上传：图片 / PDF，单个文件 ≤10MB，落入租户文件管理。
func (c *AppOaController) DailyReportUpload() {
	c.uploadTenantImage()
}