|
|
@@ -1,6 +1,7 @@
|
|
|
package oilsupplier
|
|
|
|
|
|
import (
|
|
|
+ "dashoo.cn/backend/api/business/auditsetting"
|
|
|
"dashoo.cn/backend/api/business/invoiceinfo"
|
|
|
"dashoo.cn/backend/api/business/oilcontract/contract"
|
|
|
"dashoo.cn/backend/api/business/oilcontract/contractReview"
|
|
|
@@ -14,8 +15,10 @@ import (
|
|
|
"dashoo.cn/backend/api/business/register"
|
|
|
"dashoo.cn/backend/api/business/todolist"
|
|
|
"dashoo.cn/backend/api/business/workflow"
|
|
|
+ "dashoo.cn/business2/userRole"
|
|
|
. "dashoo.cn/backend/api/controllers"
|
|
|
"dashoo.cn/utils"
|
|
|
+ "encoding/json"
|
|
|
"fmt"
|
|
|
"sort"
|
|
|
"strconv"
|
|
|
@@ -593,9 +596,53 @@ func (this *TodoListController) GetMyTaskFinishedList() {
|
|
|
this.ServeJSON()
|
|
|
}
|
|
|
|
|
|
-// @Title 获取待办发港信通提醒
|
|
|
+// @Title 获取待办-发港信通提醒
|
|
|
// @Description get user by token
|
|
|
// @Success 200 {object} []supplier.OilSupplierView
|
|
|
// @router /getToDoSend [get]
|
|
|
func (this *TodoListController) GetToDoSend() {
|
|
|
+ page := this.GetPageInfoForm()
|
|
|
+
|
|
|
+ supplierTypeCode := this.GetString("SupplierTypeCode")
|
|
|
+ supplierName := this.GetString("SupplierName")
|
|
|
+ wfNames := ""
|
|
|
+
|
|
|
+ var pagingResult workflow.ActiMyPagingResultVM
|
|
|
+ var myTasksRetWithTimes []workflow.ActiMyTasksRetWithTimeVM
|
|
|
+ actisvc := workflow.GetActivitiService(utils.DBE)
|
|
|
+ svcActiviti := workflow.GetActivitiService(utils.DBE)
|
|
|
+
|
|
|
+ var userList []userRole.Base_User
|
|
|
+ var settingList []auditsetting.Base_OilAuditSetting
|
|
|
+ usvc := userRole.GetUserService(utils.DBE)
|
|
|
+ usvc.GetEntities(&settingList, "1=1")
|
|
|
+
|
|
|
+ tempstr := ""
|
|
|
+ for _,setting := range settingList {
|
|
|
+ ids := usvc.GetUserIdsByRoleId(strconv.Itoa(setting.RoleId))
|
|
|
+ tempstr += "," + strings.Join(ids, ",")
|
|
|
+ }
|
|
|
+ uids := strings.Replace(tempstr, "uid_", "", -1)
|
|
|
+ uids = strings.Trim(uids, ",")
|
|
|
+ if uids != "" {
|
|
|
+ where := "Id in (" + uids + ")"
|
|
|
+ usvc.GetEntities(&userList, where)
|
|
|
+ }
|
|
|
+ for _,user := range userList {
|
|
|
+ pagingResult = actisvc.GetMyAllTypePagingTasksWithTime(strconv.Itoa(user.Id), page.CurrentPage, page.Size, wfNames, supplierTypeCode, supplierName)
|
|
|
+ myTasksRetWithTimes = pagingResult.TaskList
|
|
|
+ if len(myTasksRetWithTimes) > 0 {
|
|
|
+ var sendVM todolist.SendVM
|
|
|
+ //wordTempVM.Datas = datas
|
|
|
+ //wordTempVM.TemplateUrl = templateUrl
|
|
|
+ //wordTempVM.FileName = fileName
|
|
|
+ jsonParam, err := json.Marshal(sendVM)
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println(err, "生成json字符串错误")
|
|
|
+ }
|
|
|
+ params := string(jsonParam)
|
|
|
+ svcActiviti.PostOrigin("/v1.0/send-sys-msg", params, "")
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
}
|