//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
////    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);
//        }
//        return Result.success(result);
//    }
//}