zjh 2024/05/14-1

zjh

2024-05-14 3ef44331e3bd3e8b61513c88b7439631f49f05c7

 ltkj-admin/src/main/java/com/ltkj/web/tduck/UserFormResultController.java

@@ -1,254 +1,254 @@
package com.ltkj.web.tduck;

import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.ltkj.common.core.domain.AjaxResult;
import com.ltkj.common.utils.SecurityUtils;
import com.ltkj.common.utils.http.HttpUtils;
import com.ltkj.tduck.domain.UserFormDataEntity;
import com.ltkj.tduck.domain.UserFormViewCountEntity;
import com.ltkj.tduck.request.QueryFormResultRequest;
import com.ltkj.tduck.service.UserFormDataService;
import com.ltkj.tduck.service.UserFormViewCountService;
import com.ltkj.tduck.utils.Result;
import com.ltkj.tduck.utils.ValidatorUtils;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;

import javax.annotation.security.PermitAll;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;


/**
 * 表单数据
 *
 * @author : smalljop
 * @description : 表单数据页 当前用户自己使用接口
 * @create : 2020-11-18 18:17
 **/

@Slf4j
@RestController
@RequiredArgsConstructor
@RequestMapping("/user/form/data")
public class UserFormResultController {
    private final UserFormDataService formResultService;
//    private final UserFormSettingService userFormSettingService;
//    private final FormDataImportUtils formDataImportUtils;
//    private final FormDataExportUtils formDataExportUtils;
//    private final UserFormService userFormService;
    private final UserFormViewCountService userFormViewCountService;
//    private final MailService mailService;
//    private final WxMpUserMsgService userMsgService;
    private final ConcurrentMap<String, Integer> viewFormMap = new ConcurrentHashMap<>();



    /**
     * 根据体检号获取问卷记录
     */
    @GetMapping("getRecordByTjNumber")
    public AjaxResult getRecordByTjNumber(String tjNumber) {
        LambdaQueryWrapper<UserFormDataEntity> wq=new LambdaQueryWrapper<>();
        wq.eq(UserFormDataEntity::getTjNumber,tjNumber);
        final List<UserFormDataEntity> list = formResultService.list(wq);
        AjaxResult ajaxResult = new AjaxResult();
        ajaxResult.put("code", 200);
        ajaxResult.put("data", list);
        ajaxResult.put("msg", null);
        return ajaxResult;
    }


    /***
     * 查看表单
     * 记录查看的IP 统计查看用户数
     */
    @GetMapping("view/{formKey}")
    @PermitAll
    public Result<Void> viewForm(HttpServletRequest request, @PathVariable("formKey") String formKey) {
        if (viewFormMap.containsKey(formKey)) {
            userFormViewCountService.increment(formKey);
        } else {
            // 不存在则添加
            Long count = userFormViewCountService.count(formKey);
            if (count == 0) {
                UserFormViewCountEntity entity = new UserFormViewCountEntity();
                entity.setFormKey(formKey);
                entity.setCount(1L);
                userFormViewCountService.save(entity);
            }
            viewFormMap.put(formKey, 1);
        }
        return Result.success();
    }

    /**
     * 查询数据
     *
     * @param request 查询条件
     * @return 数据
     */
    @PostMapping("query")
    public Result queryFormDataTable(@RequestBody QueryFormResultRequest request) {
//        FormAuthUtils.hasPermission(request.getFormKey());
        return Result.success(formResultService.listFormDataTable(request));
    }

    /**
     * 获取某条数据详情
     *
     * @param dataId 数据ID
     * @return 数据详情
     */
    @GetMapping("details/{dataId}")
    @PermitAll
    public Result getFormDataDetails(@PathVariable("dataId") String dataId) {
        return formResultService.getFormDataDetails(dataId);
    }
//package com.ltkj.web.tduck;
//
//import cn.hutool.core.date.DateUtil;
//import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
//import com.ltkj.common.core.domain.AjaxResult;
//import com.ltkj.common.utils.SecurityUtils;
//import com.ltkj.common.utils.http.HttpUtils;
//import com.ltkj.tduck.domain.UserFormDataEntity;
//import com.ltkj.tduck.domain.UserFormViewCountEntity;
//import com.ltkj.tduck.request.QueryFormResultRequest;
//import com.ltkj.tduck.service.UserFormDataService;
//import com.ltkj.tduck.service.UserFormViewCountService;
//import com.ltkj.tduck.utils.Result;
//import com.ltkj.tduck.utils.ValidatorUtils;
//import lombok.RequiredArgsConstructor;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.web.bind.annotation.*;
//
//import javax.annotation.security.PermitAll;
//import javax.servlet.http.HttpServletRequest;
//import java.util.List;
//import java.util.Map;
//import java.util.concurrent.ConcurrentHashMap;
//import java.util.concurrent.ConcurrentMap;
//
//
//    /**
//     * 填写附件导出
// * 表单数据
//     *
//     * @param request 请求
//     * @return 文件
//     */
//    @PostMapping("/download/file")
//    public Result downloadFormResultFile(@RequestBody QueryFormResultRequest request) {
//        return formResultService.downloadFormResultFile(request);
//    }

    /**
     * 填写
     *
     * @param entity  填写数据
     * @param request 请求
     * @return
     */
    @PostMapping("/create")
    public AjaxResult createFormResult(@RequestBody UserFormDataEntity entity, HttpServletRequest request) {
        ValidatorUtils.validateEntity(entity);
        entity.setSubmitRequestIp(HttpUtils.getIpAddr(request));
        // 如果已经登陆了也记录用户信息 try catch 避免抛出异常
        entity.setCreateBy(SecurityUtils.getUserId() != null ? String.valueOf(SecurityUtils.getUserId()) : null);
        Map<String, Object> result = formResultService.saveFormResult(entity);
        return AjaxResult.success(result);
    }


    /**
     * 公开填写
     *
     * @param entity  填写数据
     * @param request 请求
     */
    @PostMapping("/public/create")
    @PermitAll
    public Result<Map<String, Object>> createPublicFormResult(@RequestBody UserFormDataEntity entity, HttpServletRequest request) {

        ValidatorUtils.validateEntity(entity);
        entity.setSubmitRequestIp(HttpUtils.getIpAddr(request));
//        Result<Boolean> userFormSettingStatus = userFormSettingService.getUserFormWriteSettingStatus(entity.getFormKey(), entity.getSubmitRequestIp(), entity.getWxOpenId(), CommonConstants.ConstantNumber.ONE);
//        if (StrUtil.isNotBlank(userFormSettingStatus.getMsg())) {
//            return Result.failed(userFormSettingStatus.getMsg());
//        }
        // 如果已经登陆了也记录用户信息 try catch 避免抛出异常
        entity.setCreateBy(SecurityUtils.getUserId() != null ? String.valueOf(SecurityUtils.getUserId()) : null);
        Map<String, Object> result = formResultService.saveFormResult(entity);
//        ThreadUtil.execAsync(() -> {
//            sendWriteResultNotify(entity.getFormKey());
//        });
        return Result.success(result);
//        return Result.success();
    }

// * @author : smalljop
// * @description : 表单数据页 当前用户自己使用接口
// * @create : 2020-11-18 18:17
// **/
//
//@Slf4j
//@RestController
//@RequiredArgsConstructor
//@RequestMapping("/user/form/data")
//public class UserFormResultController {
//    private final UserFormDataService formResultService;
////    private final UserFormSettingService userFormSettingService;
////    private final FormDataImportUtils formDataImportUtils;
////    private final FormDataExportUtils formDataExportUtils;
////    private final UserFormService userFormService;
//    private final UserFormViewCountService userFormViewCountService;
////    private final MailService mailService;
////    private final WxMpUserMsgService userMsgService;
//    private final ConcurrentMap<String, Integer> viewFormMap = new ConcurrentHashMap<>();
//
//
//
//    /**
//     * 批量删除
//     *
//     * @param formKey    表单key
//     * @param dataIdList 数据ID
//     * @return Result
//     * 根据体检号获取问卷记录
//     */
//    @PostMapping("/delete/{formKey}")
//    public Result deleteFormData(@RequestBody List<String> dataIdList, @PathVariable("formKey") String formKey) {
//        formResultService.deleteByIds(dataIdList, formKey);
//    @GetMapping("getRecordByTjNumber")
//    public AjaxResult getRecordByTjNumber(String tjNumber) {
//        LambdaQueryWrapper<UserFormDataEntity> wq=new LambdaQueryWrapper<>();
//        wq.eq(UserFormDataEntity::getTjNumber,tjNumber);
//        final List<UserFormDataEntity> list = formResultService.list(wq);
//        AjaxResult ajaxResult = new AjaxResult();
//        ajaxResult.put("code", 200);
//        ajaxResult.put("data", list);
//        ajaxResult.put("msg", null);
//        return ajaxResult;
//    }
//
//
//    /***
//     * 查看表单
//     * 记录查看的IP 统计查看用户数
//     */
//    @GetMapping("view/{formKey}")
//    @PermitAll
//    public Result<Void> viewForm(HttpServletRequest request, @PathVariable("formKey") String formKey) {
//        if (viewFormMap.containsKey(formKey)) {
//            userFormViewCountService.increment(formKey);
//        } else {
//            // 不存在则添加
//            Long count = userFormViewCountService.count(formKey);
//            if (count == 0) {
//                UserFormViewCountEntity entity = new UserFormViewCountEntity();
//                entity.setFormKey(formKey);
//                entity.setCount(1L);
//                userFormViewCountService.save(entity);
//            }
//            viewFormMap.put(formKey, 1);
//        }
//        return Result.success();
//    }


//
//    /**
//     * 更新
//     * 查询数据
//     *
//     * @param request 查询条件
//     * @return 数据
//     */
//    @PostMapping("query")
//    public Result queryFormDataTable(@RequestBody QueryFormResultRequest request) {
////        FormAuthUtils.hasPermission(request.getFormKey());
//        return Result.success(formResultService.listFormDataTable(request));
//    }
//
//    /**
//     * 获取某条数据详情
//     *
//     * @param dataId 数据ID
//     * @return 数据详情
//     */
//    @GetMapping("details/{dataId}")
//    @PermitAll
//    public Result getFormDataDetails(@PathVariable("dataId") String dataId) {
//        return formResultService.getFormDataDetails(dataId);
//    }
////
////
////    /**
////     * 填写附件导出
////     *
////     * @param request 请求
////     * @return 文件
////     */
////    @PostMapping("/download/file")
////    public Result downloadFormResultFile(@RequestBody QueryFormResultRequest request) {
////        return formResultService.downloadFormResultFile(request);
////    }
//
//    /**
//     * 填写
//     *
//     * @param entity  填写数据
//     * @param request 请求
//     * @return Result
//     * @return
//     */
//    @PostMapping("/update")
//    @PermitAll
//    public Result<Void> updateFormResult(@RequestBody UserFormDataEntity entity, HttpServletRequest request) {
//    @PostMapping("/create")
//    public AjaxResult createFormResult(@RequestBody UserFormDataEntity entity, HttpServletRequest request) {
//        ValidatorUtils.validateEntity(entity);
//        try {
//            entity.setUpdateBy(String.valueOf(SecurityUtils.getUserId()));
//        } catch (Exception ignored) {
//        }
//        formResultService.updateFormResult(entity);
//        return Result.success();
//        entity.setSubmitRequestIp(HttpUtils.getIpAddr(request));
//        // 如果已经登陆了也记录用户信息 try catch 避免抛出异常
//        entity.setCreateBy(SecurityUtils.getUserId() != null ? String.valueOf(SecurityUtils.getUserId()) : null);
//        Map<String, Object> result = formResultService.saveFormResult(entity);
//        return AjaxResult.success(result);
//    }
//
//
//    /**
//     * 下载导入模板
//     * 公开填写
//     *
//     * @param response 响应
//     * @param formKey  表单key
//     * @param entity  填写数据
//     * @param request 请求
//     */
//    @GetMapping("/import/template")
//    public void downloadImportTemplate(HttpServletResponse response, String formKey) {
//        formDataImportUtils.importTemplateExcel(response, formKey);
//    @PostMapping("/public/create")
//    @PermitAll
//    public Result<Map<String, Object>> createPublicFormResult(@RequestBody UserFormDataEntity entity, HttpServletRequest request) {
//
//        ValidatorUtils.validateEntity(entity);
//        entity.setSubmitRequestIp(HttpUtils.getIpAddr(request));
////        Result<Boolean> userFormSettingStatus = userFormSettingService.getUserFormWriteSettingStatus(entity.getFormKey(), entity.getSubmitRequestIp(), entity.getWxOpenId(), CommonConstants.ConstantNumber.ONE);
////        if (StrUtil.isNotBlank(userFormSettingStatus.getMsg())) {
////            return Result.failed(userFormSettingStatus.getMsg());
////        }
//        // 如果已经登陆了也记录用户信息 try catch 避免抛出异常
//        entity.setCreateBy(SecurityUtils.getUserId() != null ? String.valueOf(SecurityUtils.getUserId()) : null);
//        Map<String, Object> result = formResultService.saveFormResult(entity);
////        ThreadUtil.execAsync(() -> {
////            sendWriteResultNotify(entity.getFormKey());
////        });
//        return Result.success(result);
////        return Result.success();
//    }
//
//    /**
//     * 导出表单数据
//     */
//    @PostMapping("export")
//    public void exportFormData(@RequestBody ExportRequest.FormData exportRequest) {
//        formDataExportUtils.exportData(exportRequest);
//    }
//
//    /**
//     * 导入表单数据
//     *
//     * @param file 文件
//     * @return Result
//     */
//    @PostMapping("import")
//    public Result importFormData(@RequestParam("file") MultipartFile file, UserFormDataEntity dataEntity) throws IOException {
//        return Result.success(formDataImportUtils.importFile(file.getInputStream(), dataEntity.getFormKey()));
//    }
////
////    /**
////     * 批量删除
////     *
////     * @param formKey    表单key
////     * @param dataIdList 数据ID
////     * @return Result
////     */
////    @PostMapping("/delete/{formKey}")
////    public Result deleteFormData(@RequestBody List<String> dataIdList, @PathVariable("formKey") String formKey) {
////        formResultService.deleteByIds(dataIdList, formKey);
////        return Result.success();
////    }
//
//
//    private void sendWriteResultNotify(String formKey) {
//        FormSettingSchemaStruct formSettingSchema = userFormSettingService.getFormSettingSchema(formKey);
//        if (ObjectUtil.isNull(formSettingSchema)) {
//            return;
//        }
//        UserFormEntity form = userFormService.getByKey(formKey);
//        if (StrUtil.isNotBlank(formSettingSchema.getNewWriteNotifyEmail())) {
//            mailService.sendTemplateHtmlMail(formSettingSchema.getNewWriteNotifyEmail(), "新回复通知", "mail/form-write-notify", MapUtil.of("projectName", form.getName()));
//        }
////    /**
////     * 更新
////     *
////     * @param entity  填写数据
////     * @param request 请求
////     * @return Result
////     */
////    @PostMapping("/update")
////    @PermitAll
////    public Result<Void> updateFormResult(@RequestBody UserFormDataEntity entity, HttpServletRequest request) {
////        ValidatorUtils.validateEntity(entity);
////        try {
////            entity.setUpdateBy(String.valueOf(SecurityUtils.getUserId()));
////        } catch (Exception ignored) {
////        }
////        formResultService.updateFormResult(entity);
////        return Result.success();
////    }
////
////    /**
////     * 下载导入模板
////     *
////     * @param response 响应
////     * @param formKey  表单key
////     */
////    @GetMapping("/import/template")
////    public void downloadImportTemplate(HttpServletResponse response, String formKey) {
////        formDataImportUtils.importTemplateExcel(response, formKey);
////    }
////
////    /**
////     * 导出表单数据
////     */
////    @PostMapping("export")
////    public void exportFormData(@RequestBody ExportRequest.FormData exportRequest) {
////        formDataExportUtils.exportData(exportRequest);
////    }
////
////    /**
////     * 导入表单数据
////     *
////     * @param file 文件
////     * @return Result
////     */
////    @PostMapping("import")
////    public Result importFormData(@RequestParam("file") MultipartFile file, UserFormDataEntity dataEntity) throws IOException {
////        return Result.success(formDataImportUtils.importFile(file.getInputStream(), dataEntity.getFormKey()));
////    }
////
////
////    private void sendWriteResultNotify(String formKey) {
////        FormSettingSchemaStruct formSettingSchema = userFormSettingService.getFormSettingSchema(formKey);
////        if (ObjectUtil.isNull(formSettingSchema)) {
////            return;
////        }
////        UserFormEntity form = userFormService.getByKey(formKey);
////        if (StrUtil.isNotBlank(formSettingSchema.getNewWriteNotifyEmail())) {
////            mailService.sendTemplateHtmlMail(formSettingSchema.getNewWriteNotifyEmail(), "新回复通知", "mail/form-write-notify", MapUtil.of("projectName", form.getName()));
////        }
////
////        if (StrUtil.isNotBlank(formSettingSchema.getNewWriteNotifyWx())) {
////            List<String> openIdList = StrUtil.splitTrim(formSettingSchema.getNewWriteNotifyWx(), ";");
////            openIdList.stream().forEach(openId -> {
////                userMsgService.sendKfTextMsg("", openId, "收到新的反馈，请去Pc端查看");
////            });
////        }
////    }
//
//        if (StrUtil.isNotBlank(formSettingSchema.getNewWriteNotifyWx())) {
//            List<String> openIdList = StrUtil.splitTrim(formSettingSchema.getNewWriteNotifyWx(), ";");
//            openIdList.stream().forEach(openId -> {
//                userMsgService.sendKfTextMsg("", openId, "收到新的反馈，请去Pc端查看");
//            });
//        }
//    }

}