import Ignore_ExecPageFlipper as ExecPageFlipper
import com.yinjie.heating.business.dao.DocDao
import com.yinjie.heating.common.api.NoSqlKeysService
import com.yinjie.heating.common.datas.RedisKeys
import com.yinjie.heating.common.entity.doc.BusinessScript
import com.yinjie.heating.common.tool.ERPUtils
import com.dySweetFishPlugin.redis.RedisService
import com.sweetfish.convert.json.JsonConvert
import com.sweetfish.source.PageFlipper
import org.apache.commons.lang3.StringUtils
import org.rex.RMap

static def createRunnable(String runEnvironment, RedisService redisService, NoSqlKeysService keysService, DocDao docDao, JsonConvert jsonConvert, String dataSourceId, long supplierCode) {
    return {

        if (!StringUtils.equalsIgnoreCase(runEnvironment, "dev")) {
            redisService.del(keysService.getRedisKey(RedisKeys.KEY_BUSINESSSCRIPT, supplierCode))
        }


        ExecPageFlipper.execute(300, { PageFlipper p ->
            RMap scriptParams = ERPUtils.ofRMap("voidFlag", -1, "businessModule", -1)
            List<BusinessScript> scriptList = docDao.selectBusinessScript(scriptParams, dataSourceId, supplierCode, p)
            Map<String, String> redisMap = scriptList.collectEntries { [it.businessCode, jsonConvert.convertTo(it)] }
            if (!redisMap.isEmpty()) {
                redisService.hmset(keysService.getRedisKey(RedisKeys.KEY_BUSINESSSCRIPT, supplierCode), redisMap)
            }
        })
    } as Runnable
}

//groovy最后一个表达式的值为返回
createRunnable(runEnvironment, redisService, keysService, docDao, jsonConvert, dataSourceId, supplierCode)