Init_43_SiteContent.groovy 1.3 KB

1234567891011121314151617181920212223242526272829303132
  1. import com.yinjie.printerAuthorize.business.dao.SystemDao
  2. import com.yinjie.printerAuthorize.common.api.NoSqlKeysService
  3. import com.yinjie.printerAuthorize.common.datas.RedisKeys
  4. import com.yinjie.printerAuthorize.common.entity.site.SiteContent
  5. import com.dySweetFishPlugin.redis.RedisService
  6. import com.sweetfish.convert.json.JsonConvert
  7. import com.sweetfish.source.PageFlipper
  8. import org.rex.RMap
  9. static def createRunnable(RedisService redisService, NoSqlKeysService keysService, SystemDao systemDao, JsonConvert jsonConvert, String dataSourceId, long supplierCode) {
  10. return {
  11. RMap params = new RMap()
  12. redisService.del(keysService.getRedisKey(RedisKeys.KEY_SITE_CONTENT, supplierCode))
  13. Ignore_ExecPageFlipper.execute(500, { PageFlipper p ->
  14. List<SiteContent> siteContentList = systemDao.selectSiteContent(params, p, dataSourceId, supplierCode)
  15. Map<String, String> siteContentMap = siteContentList.collectEntries { [String.valueOf(it.getId()), jsonConvert.convertTo(it)] }
  16. if (!siteContentMap.isEmpty()) {
  17. redisService.hmset(keysService.getRedisKey(RedisKeys.KEY_SITE_CONTENT, supplierCode), siteContentMap)
  18. }
  19. })
  20. } as Runnable
  21. }
  22. //groovy最后一个表达式的值为返回
  23. createRunnable(redisService, keysService, systemDao, jsonConvert, dataSourceId, supplierCode)