|
|
@@ -130,23 +130,25 @@ func (s DeliverOrderProgressService) Add(ctx context.Context, req *work.DeliverO
|
|
|
var id int
|
|
|
txerr := s.Dao.DB.Transaction(ctx, func(ctx context.Context, tx *gdb.TX) error {
|
|
|
pid, err := tx.InsertAndGetId("deliver_order_imp_progress", work.DeliverOrderImpProgress{
|
|
|
- PlanId: req.PlanId,
|
|
|
- DeliverOrderId: req.DeliverOrderId,
|
|
|
- ProgressTitle: req.ProgressTitle,
|
|
|
- ProgressContext: req.ProgressContext,
|
|
|
- StartDate: req.StartDate,
|
|
|
- EndDate: req.EndDate,
|
|
|
- ReaStartDate: req.ReaStartDate,
|
|
|
- ReaEndDate: req.ReaEndDate,
|
|
|
- ProgressStatus: "10",
|
|
|
- ProgressLevel: req.ProgressLevel,
|
|
|
- Remark: req.Remark,
|
|
|
- CreatedBy: int(s.userInfo.Id),
|
|
|
- CreatedName: s.userInfo.NickName,
|
|
|
- CreatedTime: gtime.Now(),
|
|
|
- UpdatedBy: int(s.userInfo.Id),
|
|
|
- UpdatedName: s.userInfo.NickName,
|
|
|
- UpdatedTime: gtime.Now(),
|
|
|
+ PlanId: req.PlanId,
|
|
|
+ DeliverOrderId: req.DeliverOrderId,
|
|
|
+ ProgressTitle: req.ProgressTitle,
|
|
|
+ ProgressContext: req.ProgressContext,
|
|
|
+ StartDate: req.StartDate,
|
|
|
+ EndDate: req.EndDate,
|
|
|
+ ReaStartDate: req.ReaStartDate,
|
|
|
+ ReaEndDate: req.ReaEndDate,
|
|
|
+ ProgressStatus: "10",
|
|
|
+ ProgressLevel: req.ProgressLevel,
|
|
|
+ PrincipalPersonId: req.PrincipalPersonId,
|
|
|
+ PrincipalPerson: req.PrincipalPerson,
|
|
|
+ Remark: req.Remark,
|
|
|
+ CreatedBy: int(s.userInfo.Id),
|
|
|
+ CreatedName: s.userInfo.NickName,
|
|
|
+ CreatedTime: gtime.Now(),
|
|
|
+ UpdatedBy: int(s.userInfo.Id),
|
|
|
+ UpdatedName: s.userInfo.NickName,
|
|
|
+ UpdatedTime: gtime.Now(),
|
|
|
})
|
|
|
if err != nil {
|
|
|
return err
|
|
|
@@ -238,7 +240,7 @@ func (s DeliverOrderProgressService) Start(ctx context.Context, req *work.Delive
|
|
|
}
|
|
|
|
|
|
txerr := s.Dao.DB.Transaction(ctx, func(ctx context.Context, tx *gdb.TX) error {
|
|
|
- // 10发货任务单/20组装任务单/30部署安装单
|
|
|
+ // 10发货任务单/20组装任务单/30部署安装单/40软件交付验收任务单(30部署安装单无需启动)
|
|
|
if ent.ProgressType == "10" {
|
|
|
_, err = tx.Update("deliver_order_imp_progress", map[string]interface{}{
|
|
|
"progress_status": "20",
|
|
|
@@ -246,13 +248,13 @@ func (s DeliverOrderProgressService) Start(ctx context.Context, req *work.Delive
|
|
|
"rea_start_date": gtime.Now(),
|
|
|
"remark": req.Remark,
|
|
|
}, "id = ?", req.Id)
|
|
|
- } else if ent.ProgressType == "20" {
|
|
|
+ } else if ent.ProgressType == "20" || ent.ProgressType == "40" || ent.ProgressType == "" {
|
|
|
_, err = tx.Update("deliver_order_imp_progress", map[string]interface{}{
|
|
|
"progress_status": "20",
|
|
|
"rea_start_date": gtime.Now(),
|
|
|
"remark": req.Remark,
|
|
|
}, "id = ?", req.Id)
|
|
|
- } else {
|
|
|
+ } else if ent.ProgressType == "30" {
|
|
|
_, err = tx.Update("deliver_order_imp_progress", map[string]interface{}{
|
|
|
"progress_status": "15",
|
|
|
"expect_install_time": req.ExpectInstallTime,
|
|
|
@@ -375,11 +377,11 @@ func (s DeliverOrderProgressService) StartDeliverGoodsProgress(ctx context.Conte
|
|
|
assembleProgress.StartDate = deliverProgress.StartDate
|
|
|
assembleProgress.EndDate = deliverProgress.EndDate
|
|
|
assembleProgress.ProgressLevel = deliverProgress.ProgressLevel
|
|
|
- //assembleProgress.PrincipalPersonId, assembleProgress.PrincipalPerson, err = s.getUserInfo("于洋")
|
|
|
- //if err != nil {
|
|
|
- // return err
|
|
|
- //}
|
|
|
- assembleProgress.PrincipalPersonId, assembleProgress.PrincipalPerson = 1052, "于洋"
|
|
|
+ assembleProgress.PrincipalPersonId, assembleProgress.PrincipalPerson, err = s.getUserInfo("姜辉")
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ //assembleProgress.PrincipalPersonId, assembleProgress.PrincipalPerson = 1052, "于洋"
|
|
|
service.SetCreatedInfo(&assembleProgress, s.userInfo.Id, s.userInfo.NickName)
|
|
|
|
|
|
var indexArr []int
|
|
|
@@ -534,11 +536,11 @@ func (s DeliverOrderProgressService) DeliverGoods(ctx context.Context, req *work
|
|
|
insProgress.ProgressLevel = "10" // 优先级
|
|
|
insProgress.ProgressType = "30" // 10发货任务单/20组装任务单/30部署安装单
|
|
|
if insProgress.PrincipalPerson == "" {
|
|
|
- //insProgress.PrincipalPersonId, insProgress.PrincipalPerson, err = s.getUserInfo("于洋")
|
|
|
- //if err != nil {
|
|
|
- // return err
|
|
|
- //}
|
|
|
- insProgress.PrincipalPersonId, insProgress.PrincipalPerson = 1052, "于洋"
|
|
|
+ insProgress.PrincipalPersonId, insProgress.PrincipalPerson, err = s.getUserInfo("姜辉")
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ //insProgress.PrincipalPersonId, insProgress.PrincipalPerson = 1052, "于洋"
|
|
|
}
|
|
|
service.SetCreatedInfo(&insProgress, s.userInfo.Id, s.userInfo.NickName)
|
|
|
|
|
|
@@ -592,11 +594,11 @@ func (s DeliverOrderProgressService) StartInstallProgress(ctx context.Context, r
|
|
|
progress.ProgressStatus = "10" // 状态(10未开始20进行中30已完成)
|
|
|
progress.ProgressType = "30" // 10发货任务单/20组装任务单/30部署安装单
|
|
|
if progress.PrincipalPerson == "" {
|
|
|
- //progress.PrincipalPersonId, progress.PrincipalPerson, err = s.getUserInfo("于洋")
|
|
|
- //if err != nil {
|
|
|
- // return err
|
|
|
- //}
|
|
|
- progress.PrincipalPersonId, progress.PrincipalPerson = 1052, "于洋"
|
|
|
+ progress.PrincipalPersonId, progress.PrincipalPerson, err = s.getUserInfo("姜辉")
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ //progress.PrincipalPersonId, progress.PrincipalPerson = 1052, "于洋"
|
|
|
}
|
|
|
service.SetCreatedInfo(&progress, s.userInfo.Id, s.userInfo.NickName)
|
|
|
|
|
|
@@ -837,21 +839,22 @@ func (s DeliverOrderProgressService) CompleteSoftware(ctx context.Context, req *
|
|
|
}
|
|
|
err = s.Dao.Transaction(ctx, func(ctx context.Context, tx *gdb.TX) error {
|
|
|
data := g.Map{
|
|
|
- "progress_status": "30",
|
|
|
- "software_check_time": req.SoftwareCheckTime,
|
|
|
- "software_check_file_url": req.SoftwareCheckFileUrl,
|
|
|
- "software_check_file_name": req.SoftwareCheckFileName,
|
|
|
- "software_check_person_id": s.userInfo.Id,
|
|
|
- "software_check_person": s.userInfo.NickName,
|
|
|
- "completed_content": req.CompletedContent,
|
|
|
- "completed_work": req.CompletedWork,
|
|
|
- "uncompleted_content": req.UncompletedContent,
|
|
|
- "uncompleted_work": req.UncompletedWork,
|
|
|
- "rea_end_date": gtime.Now(),
|
|
|
- "is_delay": isDelay,
|
|
|
- "updated_by": s.userInfo.Id,
|
|
|
- "updated_name": s.userInfo.NickName,
|
|
|
- "updated_time": gtime.Now(),
|
|
|
+ "progress_status": "30",
|
|
|
+ "software_check_time": req.SoftwareCheckTime,
|
|
|
+ "software_check_file_url": req.SoftwareCheckFileUrl,
|
|
|
+ "software_check_file_name": req.SoftwareCheckFileName,
|
|
|
+ "software_check_person_id": s.userInfo.Id,
|
|
|
+ "software_check_person": s.userInfo.NickName,
|
|
|
+ "completed_content": req.CompletedContent,
|
|
|
+ "software_spot_delivery_time": req.SoftwareSpotDeliveryTime,
|
|
|
+ "completed_work": req.CompletedWork,
|
|
|
+ "uncompleted_content": req.UncompletedContent,
|
|
|
+ "uncompleted_work": req.UncompletedWork,
|
|
|
+ "rea_end_date": gtime.Now(),
|
|
|
+ "is_delay": isDelay,
|
|
|
+ "updated_by": s.userInfo.Id,
|
|
|
+ "updated_name": s.userInfo.NickName,
|
|
|
+ "updated_time": gtime.Now(),
|
|
|
}
|
|
|
// 更新验收单信息
|
|
|
_, err := tx.Update("deliver_order_imp_progress", data, fmt.Sprintf("id='%v'", req.Id))
|