路泰科技体检后端
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zjh
2024-05-15 cebb05f8d1ddbf5ac415c5471e17d2d94ea1a6de 
 ltkj-system/src/main/java/com/ltkj/tduck/service/impl/UserFormDataServiceImpl.java


@@ -1,159 +1,159 @@


//package com.ltkj.tduck.service.impl;


//


//import cn.hutool.core.bean.BeanUtil;


//import cn.hutool.core.map.MapUtil;


//import cn.hutool.core.util.ObjectUtil;


//import cn.hutool.core.util.StrUtil;


//import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


//import com.ltkj.common.utils.ip.AddressUtils;


//import com.ltkj.tduck.constant.CommonConstants;


//import com.ltkj.tduck.domain.UserFormDataEntity;


//import com.ltkj.tduck.mapper.UserFormDataMapper;


//import com.ltkj.tduck.request.QueryFormResultRequest;


//import com.ltkj.tduck.service.UserFormDataService;


//import com.ltkj.tduck.service.UserFormItemService;


//import com.ltkj.tduck.utils.CacheUtils;


//import com.ltkj.tduck.utils.FormDataUtils;


//import com.ltkj.tduck.utils.Result;


//import com.ltkj.tduck.vo.FormDataTableVO;


//import com.ltkj.tduck.vo.FormFieldVO;


//import lombok.RequiredArgsConstructor;


//import lombok.extern.slf4j.Slf4j;


//import org.springframework.stereotype.Service;


//import org.springframework.transaction.annotation.Transactional;


//


//import java.util.HashMap;


//import java.util.List;


//import java.util.Map;


//


//import static com.ltkj.tduck.constant.FormRedisKeyConstants.FORM_RESULT_NUMBER;


//


//


///**


// * 表单表单项(FormResult)表服务实现类


// *


// * @author smalljop


// * @since 2020-11-23 14:09:22


// */


//@Service


//@Slf4j


//@RequiredArgsConstructor


//public class UserFormDataServiceImpl extends ServiceImpl<UserFormDataMapper, UserFormDataEntity> implements UserFormDataService {


//


//    private final UserFormItemService userFormItemService;


//    private final CacheUtils redisUtils;


//    private final FormDataUtils formDataUtils;


//


//


package com.ltkj.tduck.service.impl;




import cn.hutool.core.bean.BeanUtil;


import cn.hutool.core.map.MapUtil;


import cn.hutool.core.util.ObjectUtil;


import cn.hutool.core.util.StrUtil;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ltkj.common.utils.ip.AddressUtils;


import com.ltkj.tduck.constant.CommonConstants;


import com.ltkj.tduck.domain.UserFormDataEntity;


import com.ltkj.tduck.mapper.UserFormDataMapper;


import com.ltkj.tduck.request.QueryFormResultRequest;


import com.ltkj.tduck.service.UserFormDataService;


import com.ltkj.tduck.service.UserFormItemService;


import com.ltkj.tduck.utils.CacheUtils;


import com.ltkj.tduck.utils.FormDataUtils;


import com.ltkj.tduck.utils.Result;


import com.ltkj.tduck.vo.FormDataTableVO;


import com.ltkj.tduck.vo.FormFieldVO;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import java.util.HashMap;


import java.util.List;


import java.util.Map;




import static com.ltkj.tduck.constant.FormRedisKeyConstants.FORM_RESULT_NUMBER;






/**


 * 表单表单项(FormResult)表服务实现类


 *


 * @author smalljop


 * @since 2020-11-23 14:09:22


 */


@Service


@Slf4j


@RequiredArgsConstructor


public class UserFormDataServiceImpl extends ServiceImpl<UserFormDataMapper, UserFormDataEntity> implements UserFormDataService {




    private final UserFormItemService userFormItemService;


    private final CacheUtils redisUtils;


    private final FormDataUtils formDataUtils;






    @Override


    @Transactional(rollbackFor = Exception.class)


    public Map<String, Object> saveFormResult(UserFormDataEntity entity) {


        HashMap<String, Object> result = MapUtil.newHashMap();


        String formKey = entity.getFormKey();


        entity.setSubmitAddress(AddressUtils.getRealAddressByIP(entity.getSubmitRequestIp()));


        entity.setSerialNumber(redisUtils.incr(StrUtil.format(FORM_RESULT_NUMBER, formKey), CommonConstants.ConstantNumber.ONE));


        this.save(entity);


//        formDataUtils.syncSaveFormData(entity);


        result.put("id", entity.getId());


        return result;


    }






    /**


     * 下载表单结果中的附件


     *


     * @param request


     * @return


     */


//    @Override


//    @Transactional(rollbackFor = Exception.class)


//    public Map<String, Object> saveFormResult(UserFormDataEntity entity) {


//        HashMap<String, Object> result = MapUtil.newHashMap();


//        String formKey = entity.getFormKey();


//        entity.setSubmitAddress(AddressUtils.getRealAddressByIP(entity.getSubmitRequestIp()));


//        entity.setSerialNumber(redisUtils.incr(StrUtil.format(FORM_RESULT_NUMBER, formKey), CommonConstants.ConstantNumber.ONE));


//        this.save(entity);


////        formDataUtils.syncSaveFormData(entity);


//        result.put("id", entity.getId());


//        return result;


//    }


//


//


//    /**


//     * 下载表单结果中的附件


//     *


//     * @param request


//     * @return


//     */


////    @Override


////    public Result downloadFormResultFile(QueryFormResultRequest request) {


////        String uuid = IdUtil.simpleUUID();


////        List<UserFormItemEntity> userFormItemEntityList = userFormItemService.list(Wrappers.<UserFormItemEntity>lambdaQuery().eq(UserFormItemEntity::getFormKey, request.getFormKey()).in(UserFormItemEntity::getType, CollUtil.newArrayList(FormItemTypeEnum.UPLOAD.toString(), FormItemTypeEnum.IMAGE_UPLOAD.toString())));


////        //结果


////        List<Map> rows = null;


////        if (ObjectUtil.isNull(request.getCurrent()) && ObjectUtil.isNull(request.getSize())) {


////            rows = formDataUtils.searchAll(request);


////        } else {


////            FormDataTableVO formDataTableVO = this.listFormDataTable(request);


////            rows = formDataTableVO.getRows();


////        }


////        if (CollectionUtil.isEmpty(rows) || CollectionUtil.isEmpty(userFormItemEntityList)) {


////            return Result.failed("暂无收集附件，无法下载");


////        }


////        List<Map> finalRows = rows;


////        ThreadUtil.execAsync(() -> {


////            TimeInterval timer = DateUtil.timer();


////            List<String> paths = new ArrayList<>();


////            List<InputStream> ins = new ArrayList<>();


////            try {


////                finalRows.forEach(result -> {


////                    int index = 0;


////                    userFormItemEntityList.forEach(item -> {


////                        List<UploadResultStruct> uploadResults = JsonUtils.jsonToList(JsonUtils.objToJson(MapUtil.get(result, item.getFormItemId(), List.class)), UploadResultStruct.class);


////                        if (CollectionUtil.isNotEmpty(uploadResults)) {


////                            uploadResults.forEach(uFile -> {


////                                if (StrUtil.isNotBlank(uFile.getUrl())) {


////                                    paths.add(FileNameUtil.getName(uFile.getUrl()));


////                                    byte[] bytes = HttpUtil.downloadBytes(uFile.getUrl());


////                                    ins.add(IoUtil.toStream(bytes));


////                                }


////                            });


////                        }


////                    });


////                    AsyncProcessUtils.setProcess(uuid, ++index / finalRows.size());


////                });


////                // 压缩上传oss


////                ByteArrayOutputStream zipOutputStream = new ByteArrayOutputStream();


////                ZipUtil.zip(zipOutputStream, paths.toArray(new String[]{}), ins.toArray(new InputStream[]{}));


////                String downloadUrl = OssStorageFactory.getStorageService().upload(zipOutputStream.toByteArray(), StorageUtils.generateFileName("download", ".zip"));


////                AsyncProcessUtils.setProcess(uuid, downloadUrl);


////                log.info("export file cost time: {}", timer.interval());


////            } catch (Exception e) {


////                log.error("download file", e);


////            }


////        });


////        return Result.success(uuid);


////    }


////


////


//    @Override


//    public FormDataTableVO listFormDataTable(QueryFormResultRequest request) {


//        return formDataUtils.search(request);


//    }


////


////


////    @Override


////    public Boolean deleteByIds(List<String> dataIdList, String formKey) {


////        baseMapper.deleteBatchIds(dataIdList);


////        formDataUtils.asyncDeleteEsDocument(dataIdList, formKey);


////        return true;


////    }


////


////    @Override


////    public Boolean updateFormResult(UserFormDataEntity entity) {


////        UserFormDataEntity dataEntity = this.getById(entity.getId());


////        dataEntity.setOriginalData(entity.getOriginalData());


////        dataEntity.setUpdateBy(entity.getUpdateBy());


////        boolean update = this.updateById(dataEntity);


////        // 查询数据 同步到es 避免数据变空被覆盖


////        formDataUtils.asyncUpdateEsDocument(dataEntity);


////        return update;


////    }


//


//    @Override


//    public Result getFormDataDetails(String dataId) {


//        Map<String, Object> result =new HashMap<>();


//        UserFormDataEntity dataEntity = this.getById(dataId);


//        List<FormFieldVO> formFields = userFormItemService.listFormFields(dataEntity.getFormKey());


//        // 表单字段


//        result.put("formFields", formFields);


//        // 表单填写数据


//        if (ObjectUtil.isNotNull(dataEntity)) {


//            Map<String, Object> originalData = dataEntity.getOriginalData();


//            dataEntity.setOriginalData(null);


//            originalData.putAll(BeanUtil.beanToMap(dataEntity, false, true));


//            result.put("formData", originalData);


//    public Result downloadFormResultFile(QueryFormResultRequest request) {


//        String uuid = IdUtil.simpleUUID();


//        List<UserFormItemEntity> userFormItemEntityList = userFormItemService.list(Wrappers.<UserFormItemEntity>lambdaQuery().eq(UserFormItemEntity::getFormKey, request.getFormKey()).in(UserFormItemEntity::getType, CollUtil.newArrayList(FormItemTypeEnum.UPLOAD.toString(), FormItemTypeEnum.IMAGE_UPLOAD.toString())));


//        //结果


//        List<Map> rows = null;


//        if (ObjectUtil.isNull(request.getCurrent()) && ObjectUtil.isNull(request.getSize())) {


//            rows = formDataUtils.searchAll(request);


//        } else {


//            FormDataTableVO formDataTableVO = this.listFormDataTable(request);


//            rows = formDataTableVO.getRows();


//        }


//        return Result.success(result);


//        if (CollectionUtil.isEmpty(rows) || CollectionUtil.isEmpty(userFormItemEntityList)) {


//            return Result.failed("暂无收集附件，无法下载");


//        }


//        List<Map> finalRows = rows;


//        ThreadUtil.execAsync(() -> {


//            TimeInterval timer = DateUtil.timer();


//            List<String> paths = new ArrayList<>();


//            List<InputStream> ins = new ArrayList<>();


//            try {


//                finalRows.forEach(result -> {


//                    int index = 0;


//                    userFormItemEntityList.forEach(item -> {


//                        List<UploadResultStruct> uploadResults = JsonUtils.jsonToList(JsonUtils.objToJson(MapUtil.get(result, item.getFormItemId(), List.class)), UploadResultStruct.class);


//                        if (CollectionUtil.isNotEmpty(uploadResults)) {


//                            uploadResults.forEach(uFile -> {


//                                if (StrUtil.isNotBlank(uFile.getUrl())) {


//                                    paths.add(FileNameUtil.getName(uFile.getUrl()));


//                                    byte[] bytes = HttpUtil.downloadBytes(uFile.getUrl());


//                                    ins.add(IoUtil.toStream(bytes));


//                                }


//                            });


//                        }


//                    });


//                    AsyncProcessUtils.setProcess(uuid, ++index / finalRows.size());


//                });


//                // 压缩上传oss


//                ByteArrayOutputStream zipOutputStream = new ByteArrayOutputStream();


//                ZipUtil.zip(zipOutputStream, paths.toArray(new String[]{}), ins.toArray(new InputStream[]{}));


//                String downloadUrl = OssStorageFactory.getStorageService().upload(zipOutputStream.toByteArray(), StorageUtils.generateFileName("download", ".zip"));


//                AsyncProcessUtils.setProcess(uuid, downloadUrl);


//                log.info("export file cost time: {}", timer.interval());


//            } catch (Exception e) {


//                log.error("download file", e);


//            }


//        });


//        return Result.success(uuid);


//    }


//}


//


//


    @Override


    public FormDataTableVO listFormDataTable(QueryFormResultRequest request) {


        return formDataUtils.search(request);


    }


//


//


//    @Override


//    public Boolean deleteByIds(List<String> dataIdList, String formKey) {


//        baseMapper.deleteBatchIds(dataIdList);


//        formDataUtils.asyncDeleteEsDocument(dataIdList, formKey);


//        return true;


//    }


//


//    @Override


//    public Boolean updateFormResult(UserFormDataEntity entity) {


//        UserFormDataEntity dataEntity = this.getById(entity.getId());


//        dataEntity.setOriginalData(entity.getOriginalData());


//        dataEntity.setUpdateBy(entity.getUpdateBy());


//        boolean update = this.updateById(dataEntity);


//        // 查询数据 同步到es 避免数据变空被覆盖


//        formDataUtils.asyncUpdateEsDocument(dataEntity);


//        return update;


//    }




    @Override


    public Result getFormDataDetails(String dataId) {


        Map<String, Object> result =new HashMap<>();


        UserFormDataEntity dataEntity = this.getById(dataId);


        List<FormFieldVO> formFields = userFormItemService.listFormFields(dataEntity.getFormKey());


        // 表单字段


        result.put("formFields", formFields);


        // 表单填写数据


        if (ObjectUtil.isNotNull(dataEntity)) {


            Map<String, Object> originalData = dataEntity.getOriginalData();


            dataEntity.setOriginalData(null);


            originalData.putAll(BeanUtil.beanToMap(dataEntity, false, true));


            result.put("formData", originalData);


        }


        return Result.success(result);


    }


}