Init_11_NoticeMessage.groovy 1.1 KB

12345678910111213141516171819202122232425
  1. import com.sdtool.business.dao.SystemDao
  2. import com.sdtool.common.api.NoSqlKeysService
  3. import com.sdtool.common.datas.RedisKeys
  4. import com.sdtool.common.entity.system.NoticeMessage
  5. import com.dySweetFishPlugin.redis.RedisService
  6. import com.sweetfish.convert.json.JsonConvert
  7. import org.rex.RMap
  8. static def createRunnable(RedisService redisService, NoSqlKeysService keysService, SystemDao systemDao, JsonConvert jsonConvert, String dataSourceId, long supplierCode) {
  9. return {
  10. RMap params = new RMap()
  11. redisService.del(keysService.getRedisKey(RedisKeys.KEY_ERP_NOTICEMESSAGE, supplierCode))
  12. List<NoticeMessage> dataList = systemDao.selectAllNoticeMessage(params, dataSourceId, supplierCode)
  13. if (!dataList.isEmpty()) {
  14. Map<String, String> redisMap = dataList.collectEntries { [String.valueOf(it.getId()), jsonConvert.convertTo(it)] }
  15. redisService.hmset(keysService.getRedisKey(RedisKeys.KEY_ERP_NOTICEMESSAGE, supplierCode), redisMap)
  16. }
  17. } as Runnable
  18. }
  19. //groovy最后一个表达式的值为返回
  20. createRunnable(redisService, keysService, systemDao, jsonConvert, dataSourceId, supplierCode)