花城-智慧社区
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
mitao
2025-05-06 0135fa289418c5fd231fa4e7c60ee7b8f06f17a7 
 springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/controller/ComplaintController.java


@@ -1,37 +1,29 @@


package com.panzhihua.sangeshenbian.controller;






import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.panzhihua.common.controller.BaseController;


import com.panzhihua.common.model.vos.LoginUserInfoVO;


import com.panzhihua.common.model.vos.R;


import com.panzhihua.sangeshenbian.annotation.DistributedLock;


import com.panzhihua.sangeshenbian.model.dto.*;


import com.panzhihua.sangeshenbian.model.entity.Complaint;


import com.panzhihua.sangeshenbian.model.entity.ComplaintAuditRecord;


import com.panzhihua.sangeshenbian.model.entity.ComplaintProgress;


import com.panzhihua.sangeshenbian.model.entity.ProblemType;


import com.panzhihua.sangeshenbian.model.entity.*;


import com.panzhihua.sangeshenbian.model.query.ComplaintQuery;


import com.panzhihua.sangeshenbian.model.vo.ComplaintVO;


import com.panzhihua.sangeshenbian.model.vo.DispatchVO;


import com.panzhihua.sangeshenbian.service.IComplaintCommentService;


import com.panzhihua.sangeshenbian.service.IComplaintService;


import com.panzhihua.sangeshenbian.service.IProblemTypeService;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiOperation;


import io.swagger.annotations.ApiParam;


import io.swagger.annotations.ApiParam;


import lombok.RequiredArgsConstructor;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.context.annotation.Lazy;


import org.springframework.validation.annotation.Validated;


import org.springframework.web.bind.annotation.GetMapping;


import org.springframework.web.bind.annotation.PostMapping;


import org.springframework.web.bind.annotation.RequestBody;


import org.springframework.web.bind.annotation.RequestMapping;


import org.springframework.web.bind.annotation.RestController;


import org.springframework.web.bind.annotation.*;




import javax.validation.Valid;


import java.util.Date;


import java.util.List;




/**


@@ -51,6 +43,7 @@




    private final IComplaintService complaintService;


    private final IProblemTypeService problemTypeService;


    private final IComplaintCommentService complaintCommentService;


    @GetMapping("/problem-type/list")


    @ApiOperation("获取诉求问题类型列表")


    public R<List<ProblemType>> problemTypeList() {


@@ -62,10 +55,42 @@


    @PostMapping("/save")


    @ApiOperation(value = "录入诉求")


    @DistributedLock(lockName = "complaint_serial_number_lock")


    public R<?> save(@RequestBody Complaint complaint) {


        complaintService.saveComplaint(complaint, getUserId());


    public R<?> save(@Valid @RequestBody Complaint complaint) {


        complaintService.saveComplaint(complaint, getLoginUserInfo());


        return R.ok();


    }




    /**


     * 诉求录入并上报


     */


    @PostMapping("/saveAndReport")


    @ApiOperation(value = "诉求录入并上报")


    public R<?> saveAndReport(@Valid @RequestBody ComplaintVO complaintVO) {


        complaintService.saveAndReport(complaintVO, getLoginUserInfo());


        return R.ok();


    }




    /**


     * 诉求录入并办结


     */


    @PostMapping("/saveAndComplete")


    @ApiOperation(value = "诉求录入并办结")


    public R<?> saveAndComplete(@Valid @RequestBody ComplaintSaveAndCompleteDTO complaintVO) {


        complaintService.saveAndComplete(complaintVO, getLoginUserInfo());


        return R.ok();


    }






    /**


     * 上报撤回


     */


    @PostMapping("/revoke")


    @ApiOperation(value = "诉求上报撤回")


    public R<?> reportWithdraw(@RequestBody ComplaintReportWithdrawDTO dto) {


        complaintService.reportWithdraw(dto, getLoginUserInfo());


        return R.ok();


    }






    @PostMapping("/list")


    @ApiOperation("工单列表")


@@ -76,7 +101,7 @@


    @GetMapping("/detail")


    @ApiOperation("工单详情")


    public R<ComplaintVO> detail(@ApiParam(name = "id", value = "工单id", required = true) Long id) {


        return R.ok(complaintService.detail(id));


        return R.ok(complaintService.detail(id,getLoginUserInfo()));


    }




    @GetMapping("/progress/{complaintId}")


@@ -84,6 +109,8 @@


    public R<List<ComplaintProgress>> progress(@ApiParam(name = "complaintId", value = "诉求id", required = true) @PathVariable("complaintId") Long complaintId) {


        return R.ok(complaintService.progress(complaintId));


    }








    @PostMapping("/save-process")


    @ApiOperation("办理进度录入")


@@ -115,6 +142,7 @@


        return R.ok();


    }






    /**


     * 诉求下派


     */


@@ -130,7 +158,7 @@


     */


    @PostMapping("/saveDelay")


    @ApiOperation(value = "延期申请")


    public R<?> saveDelay(@RequestBody ComplaintDelayDTO dto){


    public R<?> saveDelay(@Valid @RequestBody ComplaintDelayDTO dto){


        complaintService.saveDelay(dto, getLoginUserInfo());


        return R.ok();


    }


@@ -163,7 +191,41 @@


    public R<List<DispatchVO>> getDispatchList() {


        return R.ok(complaintService.getDispatchList(getLoginUserInfo()));


    }


    


    


    /**


     * 评价诉求


     * @param complaintComment


     * @return


     */


    @PostMapping("/commentComplaint")


    @ApiOperation(value = "评价诉求")


    public R<?> commentComplaint(@RequestBody ComplaintComment complaintComment){


        int count = complaintCommentService.count(new LambdaQueryWrapper<ComplaintComment>().eq(ComplaintComment::getComplaintId, complaintComment.getComplaintId())


                .eq(ComplaintComment::getDelFlag, 0));


        if(0 != count){


            return R.fail("不能重复评价");


        }


        Long userId = getLoginUserInfo().getUserId();


        complaintComment.setUserId(userId);


        complaintComment.setCreateTime(new Date());


        complaintComment.setCreateBy(userId);


        complaintComment.setUpdateBy(userId);


        complaintComment.setUpdateTime(new Date());


        complaintComment.setDelFlag(0);


        complaintCommentService.save(complaintComment);


        Complaint complaint = complaintService.getById(complaintComment.getComplaintId());


        complaint.setStatus(8);


        complaint.setCommentRate(complaintComment.getRate());


        complaintService.updateById(complaint);


        return R.ok();


    }








    @GetMapping("/getComplaintCommentInfo/{id}")


    @ApiOperation(value = "获取诉求评价")


    public R<ComplaintComment> getComplaintCommentInfo(@PathVariable("id") Long id){


        ComplaintComment one = complaintCommentService.getOne(new LambdaQueryWrapper<ComplaintComment>().eq(ComplaintComment::getComplaintId, id).eq(ComplaintComment::getDelFlag, 0));


        return R.ok(one);


    }


}