| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676 |
- package controllers
- import (
- "ColdVerify_server/conf"
- "ColdVerify_server/lib"
- "ColdVerify_server/lib/wx"
- "ColdVerify_server/models/Account"
- "ColdVerify_server/models/AllotTask"
- "ColdVerify_server/models/InfoCollection"
- "ColdVerify_server/models/System"
- "encoding/json"
- "fmt"
- "math"
- "time"
- beego "github.com/beego/beego/v2/server/web"
- )
- type AllotTaskController struct {
- beego.Controller
- }
- // 列表 -
- func (c *AllotTaskController) List() {
- // 验证登录 User_is, User_r
- User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
- if !User_is {
- c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
- c.ServeJSON()
- return
- }
- var r_jsons lib.R_JSONS
- page, _ := c.GetInt("page")
- if page < 1 {
- page = 1
- }
- page_z, _ := c.GetInt("page_z")
- if page_z < 1 {
- page_z = conf.Page_size
- }
- T_name := c.GetString("T_name")
- T_company := c.GetString("T_company") // 公司名称
- T_uuid := c.GetString("T_uuid")
- T_scheme := c.GetString("T_scheme") // 实施方案 负责人UUID
- T_project := c.GetString("T_project") // 实施方案 负责人UUID
- T_collection := c.GetString("T_collection") // 数据采集 负责人UUID
- T_reporting := c.GetString("T_reporting") // 报告编写 负责人UUID
- T_delivery := c.GetString("T_delivery") // 交付审核 负责人UUID
- T_status, _ := c.GetInt("T_status")
- UserMap := Account.UserListToMap(Account.Read_User_List_ALL_1())
- AdminMap := Account.AdminListToMap(Account.Read_Admin_List_ALL_1())
- var T_company_list []string
- if len(T_company) > 0 {
- T_company_list = Account.Read_User_T_uuid_ListByT_name(T_company)
- }
- var T_admin string
- if User_r.T_power > 2 {
- T_admin = User_r.T_uuid
- }
- // 经销商下管理员可查看自己经销商下所有的任务
- // 经销商下其他角色只能查看分配给自己的任务
- if len(User_r.T_Distributor_id) > 0 && User_r.T_power <= 2 {
- T_admin = ""
- }
- var cnt int
- List, cnt := AllotTask.Read_AllotTask_List(User_r.T_Distributor_id, T_admin, T_uuid, T_name, T_project, T_scheme, T_collection, T_reporting, T_delivery,
- T_status, T_company_list, UserMap, AdminMap, page, page_z)
- page_size := math.Ceil(float64(cnt) / float64(page_z))
- r_jsons.List = List
- r_jsons.Page = page
- r_jsons.Page_size = int(page_size)
- r_jsons.Pages = lib.Func_page(int64(page), int64(page_size))
- r_jsons.Num = cnt
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- // 获取-
- func (c *AllotTaskController) Get() {
- // 验证登录 User_is, User_r
- _, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
- if !User_is {
- c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
- c.ServeJSON()
- return
- }
- T_allot_task_id := c.GetString("T_allot_task_id")
- r, is := AllotTask.Read_AllotTask(T_allot_task_id)
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
- c.ServeJSON()
- return
- }
- userMap := Account.UserListToMap(Account.Read_User_List_ALL_1())
- adminMap := Account.AdminListToMap(Account.Read_Admin_List_ALL_1())
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: AllotTask.AllotTaskToAllotTask_(r, userMap, adminMap)}
- c.ServeJSON()
- return
- }
- // 添加-
- func (c *AllotTaskController) Add() {
- // 验证登录 User_is, User_r
- User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
- if !User_is {
- c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
- c.ServeJSON()
- return
- }
- T_name := c.GetString("T_name")
- T_uuid := c.GetString("T_uuid") // 用户uuid
- T_approach_time := c.GetString("T_approach_time") // 用户uuid
- T_scheme := c.GetString("T_scheme")
- T_collection := c.GetString("T_collection")
- T_reporting := c.GetString("T_reporting")
- T_delivery := c.GetString("T_delivery")
- T_project := c.GetString("T_project") // 项目 负责人UUID
- T_province := c.GetString("T_province") // 省
- T_city := c.GetString("T_city") // 市
- T_district := c.GetString("T_district") // 区
- T_province_code := c.GetString("T_province_code") // 省 code
- T_city_code := c.GetString("T_city_code") // 市 code
- T_district_code := c.GetString("T_district_code") // 区 code
- T_category := c.GetString("T_category") // 类别
- T_attachment := c.GetString("T_attachment") // 合同附件
- // 查询信息采集信息
- user, is := Account.Read_User(T_uuid)
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid 错误!"}
- c.ServeJSON()
- return
- }
- var_ := AllotTask.AllotTask{
- T_Distributor_id: user.T_Distributor_id,
- T_uuid: T_uuid,
- T_name: T_name,
- T_approach_time: T_approach_time,
- T_scheme: T_scheme,
- T_collection: T_collection,
- T_reporting: T_reporting,
- T_delivery: T_delivery,
- T_project: T_project,
- T_province: T_province,
- T_city: T_city,
- T_district: T_district,
- T_province_code: T_province_code,
- T_city_code: T_city_code,
- T_district_code: T_district_code,
- T_category: T_category,
- T_attachment: T_attachment,
- T_state: 1,
- T_status: AllotTask.AllotTaskStatusWaitReceive,
- T_allot_time: time.Now(),
- }
- T_sllot_task_id, is := AllotTask.Add_AllotTask(var_)
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "添加失败!"}
- c.ServeJSON()
- return
- }
- // 通知
- _, company_r := Account.Read_User_ByT_uuid(var_.T_uuid)
- go wx.WxSend(var_.T_collection, fmt.Sprintf("【%s-%s】采集任务已派发,进场时间:%s,请及时接收并提交信息确认表", company_r.T_name, var_.T_name, T_approach_time))
- System.Add_UserLogs_T(User_r.T_uuid, "采集任务管理", "添加", var_)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_sllot_task_id}
- c.ServeJSON()
- return
- }
- // 修改-
- func (c *AllotTaskController) Up() {
- // 验证登录 User_is, User_r
- User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
- if !User_is {
- c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
- c.ServeJSON()
- return
- }
- T_name := c.GetString("T_name")
- T_approach_time := c.GetString("T_approach_time")
- T_scheme := c.GetString("T_scheme")
- T_collection := c.GetString("T_collection")
- T_reporting := c.GetString("T_reporting")
- T_delivery := c.GetString("T_delivery")
- T_project := c.GetString("T_project") // 项目 负责人UUID
- T_province := c.GetString("T_province") // 省
- T_city := c.GetString("T_city") // 市
- T_district := c.GetString("T_district") // 区
- T_province_code := c.GetString("T_province_code") // 省 code
- T_city_code := c.GetString("T_city_code") // 市 code
- T_district_code := c.GetString("T_district_code") // 区 code
- T_category := c.GetString("T_category") // 类别
- T_attachment := c.GetString("T_attachment") // 合同附件
- T_allot_task_id := c.GetString("T_allot_task_id")
- r, is := AllotTask.Read_AllotTask(T_allot_task_id)
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
- c.ServeJSON()
- return
- }
- old_collection := r.T_collection
- // .......
- clos := make([]string, 0)
- r.T_attachment = T_attachment
- if len(T_name) > 0 {
- r.T_name = T_name
- clos = append(clos, "T_name")
- }
- if len(T_approach_time) > 0 {
- r.T_approach_time = T_approach_time
- clos = append(clos, "T_approach_time")
- }
- if len(T_scheme) > 0 {
- r.T_scheme = T_scheme
- clos = append(clos, "T_scheme")
- }
- if len(T_collection) > 0 {
- r.T_collection = T_collection
- clos = append(clos, "T_collection")
- }
- if len(T_reporting) > 0 {
- r.T_reporting = T_reporting
- clos = append(clos, "T_reporting")
- }
- if len(T_delivery) > 0 {
- r.T_delivery = T_delivery
- clos = append(clos, "T_delivery")
- }
- if len(T_project) > 0 {
- r.T_project = T_project
- clos = append(clos, "T_project")
- }
- if len(T_province) > 0 {
- r.T_province = T_province
- clos = append(clos, "T_province")
- }
- if len(T_city) > 0 {
- r.T_city = T_city
- clos = append(clos, "T_city")
- }
- if len(T_district) > 0 {
- r.T_district = T_district
- clos = append(clos, "T_district")
- }
- if len(T_province_code) > 0 {
- r.T_province_code = T_province_code
- clos = append(clos, "T_province_code")
- }
- if len(T_city_code) > 0 {
- r.T_city_code = T_city_code
- clos = append(clos, "T_city_code")
- }
- if len(T_district_code) > 0 {
- r.T_district_code = T_district_code
- clos = append(clos, "T_district_code")
- }
- if len(T_category) > 0 {
- r.T_category = T_category
- clos = append(clos, "T_category")
- }
- if len(T_attachment) > 0 {
- r.T_attachment = T_attachment
- clos = append(clos, "T_attachment")
- }
- if r.T_status == AllotTask.AllotTaskStatusRefused {
- r.T_status = AllotTask.AllotTaskStatusWaitReceive
- r.T_allot_time = time.Now()
- clos = append(clos, "T_status")
- _, company_r := Account.Read_User_ByT_uuid(r.T_uuid)
- go wx.WxSend(r.T_collection, fmt.Sprintf("【%s-%s】采集任务已派发,进场时间:%s,请及时接收并提交信息确认表", company_r.T_name, r.T_name, T_approach_time))
- } else if r.T_collection != old_collection {
- _, company_r := Account.Read_User_ByT_uuid(r.T_uuid)
- go wx.WxSend(r.T_collection, fmt.Sprintf("【%s-%s】采集任务已派发,进场时间:%s,请及时接收并提交信息确认表", company_r.T_name, r.T_name, T_approach_time))
- }
- if !AllotTask.Update_AllotTask(r, clos...) {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs_T(User_r.T_uuid, "采集任务管理", "修改", r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 删除-
- func (c *AllotTaskController) Del() {
- // 验证登录 User_is, User_r
- User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
- if !User_is {
- c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
- c.ServeJSON()
- return
- }
- T_allot_task_id := c.GetString("T_allot_task_id")
- if r, is := AllotTask.Read_AllotTask(T_allot_task_id); is {
- if !AllotTask.Delete_AllotTask(r) {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败!"}
- c.ServeJSON()
- return
- }
- // 添加任务操作日志
- System.Add_UserLogs_T(User_r.T_uuid, "采集任务管理", "删除", r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
- c.ServeJSON()
- return
- }
- // 复制-
- func (c *AllotTaskController) Copy() {
- // 验证登录 User_is, User_r
- User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
- if !User_is {
- c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
- c.ServeJSON()
- return
- }
- T_name := c.GetString("T_name")
- T_approach_time := c.GetString("T_approach_time")
- T_allot_task_id := c.GetString("T_allot_task_id")
- r, is := AllotTask.Read_AllotTask(T_allot_task_id)
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
- c.ServeJSON()
- return
- }
- var_ := AllotTask.AllotTask{
- T_Distributor_id: r.T_Distributor_id,
- T_uuid: r.T_uuid,
- T_name: T_name,
- T_approach_time: T_approach_time,
- T_scheme: r.T_scheme,
- T_collection: r.T_collection,
- T_reporting: r.T_reporting,
- T_delivery: r.T_delivery,
- T_project: r.T_project,
- T_province: r.T_province,
- T_city: r.T_city,
- T_district: r.T_district,
- T_province_code: r.T_province_code,
- T_city_code: r.T_city_code,
- T_district_code: r.T_district_code,
- T_category: r.T_category,
- T_state: 1,
- T_status: AllotTask.AllotTaskStatusWaitReceive,
- T_allot_time: time.Now(),
- }
- // 通知
- _, company_r := Account.Read_User_ByT_uuid(var_.T_uuid)
- go wx.WxSend(var_.T_collection, fmt.Sprintf("【%s-%s】采集任务已派发,进场时间:%s,请及时接收并提交信息确认表", company_r.T_name, var_.T_name, T_approach_time))
- T_sllot_task_id, is := AllotTask.Add_AllotTask(var_)
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "添加失败!"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs_T(User_r.T_uuid, "采集任务管理", "复制", var_)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: T_sllot_task_id}
- c.ServeJSON()
- return
- }
- // 接收
- func (c *AllotTaskController) Receive() {
- // 验证登录 User_is, User_r
- User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
- if !User_is {
- c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
- c.ServeJSON()
- return
- }
- T_status, _ := c.GetInt("T_status") // 2-接收 3-拒绝
- T_reason := c.GetString("T_reason")
- T_allot_task_id := c.GetString("T_allot_task_id")
- r, is := AllotTask.Read_AllotTask(T_allot_task_id)
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
- c.ServeJSON()
- return
- }
- // 验证权限
- if User_r.T_uuid != r.T_collection {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "您不是该任务单的接收人!"}
- c.ServeJSON()
- return
- }
- // 获取r.T_record,转换为json,添加新的记录
- var existingRecords = make([]AllotTask.AllotTaskRecord, 0)
- if len(r.T_record) > 0 {
- json.Unmarshal([]byte(r.T_record), &existingRecords)
- }
- // 创建新的记录条目
- newRecord := AllotTask.AllotTaskRecord{
- T_collection: User_r.T_uuid,
- T_status: T_status,
- T_reason: T_reason,
- T_time: time.Now().Format("2006-01-02 15:04:05"),
- }
- existingRecords = append(existingRecords, newRecord)
- // 将更新后的记录数组转换为JSON字符串
- updatedRecordsJSON, err := json.Marshal(existingRecords)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "记录更新失败!"}
- c.ServeJSON()
- return
- }
- // 更新r.T_record字段
- r.T_record = string(updatedRecordsJSON)
- r.T_status = T_status
- if r.T_status == AllotTask.AllotTaskStatusRefused && len(T_reason) > 0 {
- r.T_reason = T_reason
- }
- // 更新数据库中的记录
- if !AllotTask.Update_AllotTask(r, "T_record", "T_status", "T_reason") {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "更新记录失败!"}
- c.ServeJSON()
- return
- }
- // 添加任务操作日志
- System.Add_UserLogs_T(User_r.T_uuid, "采集任务管理", "接收", r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 上传信息确认表
- func (c *AllotTaskController) UploadConfirmForm() {
- // 验证登录 User_is, User_r
- User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
- if !User_is {
- c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
- c.ServeJSON()
- return
- }
- T_confirm_form := c.GetString("T_confirm_form")
- T_allot_task_id := c.GetString("T_allot_task_id")
- r, is := AllotTask.Read_AllotTask(T_allot_task_id)
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id 错误!"}
- c.ServeJSON()
- return
- }
- if len(T_confirm_form) > 0 {
- r.T_confirm_form = T_confirm_form
- if r.T_status == AllotTask.AllotTaskStatusReceived {
- r.T_status = AllotTask.AllotTaskStatusSubmit // 修改为已提交
- }
- if len(r.T_submit_time) == 0 {
- r.T_submit_time = time.Now().Format("2006-01-02 15:04:05") // 设置提交时间
- }
- }
- // 获取r.T_record,转换为json,添加新的记录
- var existingRecords = make([]AllotTask.AllotTaskRecord, 0)
- if len(r.T_record) > 0 {
- json.Unmarshal([]byte(r.T_record), &existingRecords)
- }
- // 创建新的记录条目
- newRecord := AllotTask.AllotTaskRecord{
- T_collection: User_r.T_uuid,
- T_status: AllotTask.AllotTaskStatusSubmit,
- T_reason: "",
- T_time: time.Now().Format("2006-01-02 15:04:05"),
- }
- existingRecords = append(existingRecords, newRecord)
- // 将更新后的记录数组转换为JSON字符串
- updatedRecordsJSON, err := json.Marshal(existingRecords)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "记录更新失败!"}
- c.ServeJSON()
- return
- }
- // 更新r.T_record字段
- r.T_record = string(updatedRecordsJSON)
- if !AllotTask.Update_AllotTask(r, "T_confirm_form", "T_status", "T_submit_time", "T_record") {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs_T(User_r.T_uuid, "采集任务管理", "修改", r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 采集任务统计
- func (c *AllotTaskController) Statistics() {
- // 验证登录 User_is, User_r
- User_r, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
- if !User_is {
- c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
- c.ServeJSON()
- return
- }
- List, cnt := AllotTask.Read_AllotTask_List(User_r.T_Distributor_id, User_r.T_uuid, "", "", "", "", "", "", "",
- 0, []string{}, map[string]string{}, map[string]string{}, 0, 9999)
- res := make(map[int]int)
- for k, _ := range AllotTask.AllotTaskStateMap {
- res[k] = 0
- }
- res[0] = cnt
- for _, r := range List {
- res[r.T_status] += 1
- }
- // 按指定格式返回统计结果
- result := []map[string]interface{}{
- {
- "name": "全部",
- "num": res[0],
- "T_status": 0,
- },
- {
- "name": "待接收",
- "num": res[AllotTask.AllotTaskStatusWaitReceive],
- "T_status": AllotTask.AllotTaskStatusWaitReceive,
- },
- {
- "name": "已接收",
- "num": res[AllotTask.AllotTaskStatusReceived],
- "T_status": AllotTask.AllotTaskStatusReceived,
- },
- {
- "name": "已提交",
- "num": res[AllotTask.AllotTaskStatusSubmit],
- "T_status": AllotTask.AllotTaskStatusSubmit,
- },
- {
- "name": "已拒绝",
- "num": res[AllotTask.AllotTaskStatusRefused],
- "T_status": AllotTask.AllotTaskStatusRefused,
- },
- }
- c.Data["json"] = lib.JSONS{Data: result, Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 获取任务负责人列表
- func (c *AllotTaskController) GetAllotTaskUserList() {
- // 验证登录 User_is, User_r
- _, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
- if !User_is {
- c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
- c.ServeJSON()
- return
- }
- T_type := c.GetString("T_type") // T_project项目 T_scheme方案 T_collection数据采集 T_reporting报告
- list := AllotTask.Get_AllotTask_UserList(T_type)
- AdminMap := Account.AdminListToMap(Account.Read_Admin_List_ALL_1())
- var User_list []Account.Admin_R
- for _, v := range list {
- if len(v) == 0 {
- continue
- }
- User_list = append(User_list, Account.Admin_R{T_uuid: v, T_name: AdminMap[v]})
- }
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: User_list}
- c.ServeJSON()
- return
- }
- // 通过信息采集ID获取指派任务详情
- func (c *AllotTaskController) GetByInfoCollectionId() {
- // 验证登录
- _, User_is := Account.Verification_Admin(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
- if !User_is {
- c.Data["json"] = lib.JSONS{Code: 201, Msg: "请重新登录!"}
- c.ServeJSON()
- return
- }
- T_InfoCollection_id := c.GetString("T_InfoCollection_id")
- if len(T_InfoCollection_id) == 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "信息采集ID不能为空!"}
- c.ServeJSON()
- return
- }
- // 先通过信息采集ID获取信息采集详情
- infoCollection, is := InfoCollection.Read_InfoCollection(T_InfoCollection_id)
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "信息采集ID错误!"}
- c.ServeJSON()
- return
- }
- // 检查是否有关联的指派任务ID
- if len(infoCollection.T_allot_task_id) == 0 {
- c.Data["json"] = lib.JSONS{Code: 200, Data: AllotTask.AllotTask_{}, Msg: "该信息采集没有关联的指派任务!"}
- c.ServeJSON()
- return
- }
- // 通过指派任务ID获取指派任务详情
- allotTask, is := AllotTask.Read_AllotTask(infoCollection.T_allot_task_id)
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "指派任务不存在!"}
- c.ServeJSON()
- return
- }
- allotTaskDetail := AllotTask.AllotTaskToAllotTask_(allotTask, map[string]string{}, map[string]string{})
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: allotTaskDetail}
- c.ServeJSON()
- return
- }
|