import com.sdtool.business.dao.DesignDao
import com.sdtool.common.api.NoSqlKeysService
import com.sdtool.common.datas.RedisKeys
import com.dySweetFishPlugin.redis.RedisService
import com.sdtool.common.entity.design.DesignTemplate
import com.sdtool.common.entity.design.DesignTemplateItem
import com.sweetfish.convert.json.JsonConvert
import com.sweetfish.source.PageFlipper
import org.apache.commons.lang3.StringUtils
import org.apache.logging.log4j.Logger
import org.rex.RMap

import java.nio.file.Files
import java.nio.file.Paths

/**
 * @Author: xl Created on 2024-05-11
 * @Content:
 */

static def createRunnable(RedisService redisService, NoSqlKeysService keysService,
                          DesignDao designDao, Logger logger, JsonConvert jsonConvert, String dataSourceId, long supplierCode) {
    RMap params = new RMap()
    return {
        redisService.del(keysService.getRedisKey(RedisKeys.KEY_DESIGNER_DESIGN_TEMPLATE_EDIT, supplierCode))
        redisService.del(keysService.getRedisKey(RedisKeys.KEY_DESIGNER_DESIGN_TEMPLATE_IMPOSITION, supplierCode))
        Ignore_ExecPageFlipper.execute(1000, { PageFlipper p ->
            List<DesignTemplate> templates = designDao.selectDesignTemplates(params, dataSourceId, supplierCode, p)

            if (!templates.isEmpty()) {
                templates.each {
                    if (StringUtils.isNotEmpty(it.jsonContent)) {
                        File file = new File(it.jsonContent)
                        if (file.exists()) {
                            String content = new String(Files.readAllBytes(Paths.get(it.jsonContent)), "UTF-8")
                            it.setJsonContent(content)
                        }
                    }
                }
                Map<String, String> redisMap = templates.collectEntries { [String.valueOf(it.getId()), jsonConvert.convertTo(it)] }
                redisService.hmset(keysService.getRedisKey(RedisKeys.KEY_DESIGNER_DESIGN_TEMPLATE_EDIT, supplierCode), redisMap)

                RMap itemParams = new RMap()
                templates.each {
                    itemParams.set("idTemplate", it.id)
                    List<DesignTemplateItem> itemList = designDao.selectDesignTemplateItems(itemParams, dataSourceId, supplierCode)
                    it.setItemList(itemList)
                    it.setJsonContent("")
                }
                redisMap = templates.collectEntries { [String.valueOf(it.getId()), jsonConvert.convertTo(it)] }
                redisService.hmset(keysService.getRedisKey(RedisKeys.KEY_DESIGNER_DESIGN_TEMPLATE_IMPOSITION, supplierCode), redisMap)

                logger.info("设计模板共" + templates.size() + "条记录")
            }
        })
    } as Runnable
}

createRunnable(redisService, keysService, designDao, logger, jsonConvert, dataSourceId, supplierCode)