| @@ -2,9 +2,13 @@ package com.iformall.service.impl; | |||||
| import com.github.pagehelper.PageHelper; | import com.github.pagehelper.PageHelper; | ||||
| import com.github.pagehelper.PageInfo; | import com.github.pagehelper.PageInfo; | ||||
| import com.iformall.domain.po.WxAppinfo; | |||||
| import com.iformall.domain.po.WxAuthorizerInfo; | import com.iformall.domain.po.WxAuthorizerInfo; | ||||
| import com.iformall.domain.po.WxWeappExtSet; | |||||
| import com.iformall.domain.vo.WxWeappInfo; | import com.iformall.domain.vo.WxWeappInfo; | ||||
| import com.iformall.mapper.WxAppinfoMapper; | |||||
| import com.iformall.mapper.WxAuthorizerInfoMapper; | import com.iformall.mapper.WxAuthorizerInfoMapper; | ||||
| import com.iformall.mapper.WxWeappExtSetMapper; | |||||
| import com.iformall.service.WxAuthorizerInfoService; | import com.iformall.service.WxAuthorizerInfoService; | ||||
| import org.slf4j.Logger; | import org.slf4j.Logger; | ||||
| import org.slf4j.LoggerFactory; | import org.slf4j.LoggerFactory; | ||||
| @@ -20,58 +24,83 @@ public class WxAuthorizerInfoServiceImpl implements WxAuthorizerInfoService { | |||||
| private final Logger logger = LoggerFactory.getLogger(this.getClass()); | private final Logger logger = LoggerFactory.getLogger(this.getClass()); | ||||
| @Autowired | @Autowired | ||||
| WxAuthorizerInfoMapper wxAuthorizerInfoMapper; | |||||
| WxAuthorizerInfoMapper authorizerInfoMapper; | |||||
| @Autowired | |||||
| WxWeappExtSetMapper weappExtSetMapper; | |||||
| @Autowired | |||||
| WxAppinfoMapper appinfoMapper; | |||||
| @Override | @Override | ||||
| public PageInfo<WxAuthorizerInfo> listAsPage(WxAuthorizerInfo record, Integer pageIndex, Integer pageSize) { | public PageInfo<WxAuthorizerInfo> listAsPage(WxAuthorizerInfo record, Integer pageIndex, Integer pageSize) { | ||||
| return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> wxAuthorizerInfoMapper.findList(record)); | |||||
| return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> authorizerInfoMapper.findList(record)); | |||||
| } | } | ||||
| @Override | @Override | ||||
| public PageInfo<WxWeappInfo> listVoAsPage(WxWeappInfo record, Integer pageIndex, Integer pageSize) { | public PageInfo<WxWeappInfo> listVoAsPage(WxWeappInfo record, Integer pageIndex, Integer pageSize) { | ||||
| return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> wxAuthorizerInfoMapper.findVoList(record)); | |||||
| return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> authorizerInfoMapper.findVoList(record)); | |||||
| } | } | ||||
| @Override | @Override | ||||
| public List<WxWeappInfo> getList(WxWeappInfo record) { | public List<WxWeappInfo> getList(WxWeappInfo record) { | ||||
| return wxAuthorizerInfoMapper.findVoList(record); | |||||
| return authorizerInfoMapper.findVoList(record); | |||||
| } | } | ||||
| @Override | @Override | ||||
| public WxAuthorizerInfo getById(Long id) { | public WxAuthorizerInfo getById(Long id) { | ||||
| return wxAuthorizerInfoMapper.selectByPrimaryKey(id); | |||||
| return authorizerInfoMapper.selectByPrimaryKey(id); | |||||
| } | } | ||||
| @Override | @Override | ||||
| public void saveOrUpdate(WxAuthorizerInfo record) { | public void saveOrUpdate(WxAuthorizerInfo record) { | ||||
| // 1. 添加到wx_authorizer_info表中 | |||||
| // 2. 同时在wx_weapp_ext_set中添加一条记录 | |||||
| Date curDate = new Date(); | |||||
| logger.info(record.toString()); | logger.info(record.toString()); | ||||
| WxAuthorizerInfo authorizerInfo = null; | WxAuthorizerInfo authorizerInfo = null; | ||||
| try { | try { | ||||
| WxAuthorizerInfo aiQ = new WxAuthorizerInfo(); | WxAuthorizerInfo aiQ = new WxAuthorizerInfo(); | ||||
| aiQ.setAuthorizerAppid(record.getAuthorizerAppid()); | aiQ.setAuthorizerAppid(record.getAuthorizerAppid()); | ||||
| authorizerInfo = wxAuthorizerInfoMapper.selectOne(aiQ); | |||||
| authorizerInfo = authorizerInfoMapper.selectOne(aiQ); | |||||
| } catch (Exception e) { | } catch (Exception e) { | ||||
| logger.error(e.getMessage()); | logger.error(e.getMessage()); | ||||
| } | } | ||||
| if (authorizerInfo == null) { | if (authorizerInfo == null) { | ||||
| //record.setId(UUID.randomUUID().toString().replaceAll("-", "")); | |||||
| final IdWorker idWorker = IdWorker.get(); | |||||
| record.setId(idWorker.nextId()); | |||||
| record.setCreateTime(new Date()); | |||||
| record.setUpdateTime(new Date()); | |||||
| wxAuthorizerInfoMapper.insertSelective(record); | |||||
| WxAppinfo appinfo = appinfoMapper.findByAppId(record.getAuthorizerAppid()); | |||||
| if(appinfo != null) { | |||||
| record.setId(appinfo.getId()); | |||||
| } else { | |||||
| //record.setId(UUID.randomUUID().toString().replaceAll("-", "")); | |||||
| final IdWorker idWorker = IdWorker.get(); | |||||
| record.setId(idWorker.nextId()); | |||||
| } | |||||
| record.setCreateTime(curDate); | |||||
| record.setUpdateTime(curDate); | |||||
| // 授权表 添加 | |||||
| authorizerInfoMapper.insertSelective(record); | |||||
| // 扩展配置表添加 | |||||
| WxWeappExtSet weappExtSet = new WxWeappExtSet(); | |||||
| weappExtSet.setId(record.getId()); | |||||
| weappExtSet.setAppId(record.getAuthorizerAppid()); | |||||
| if(appinfo != null) { | |||||
| weappExtSet.setType(appinfo.getType()); | |||||
| } | |||||
| weappExtSet.setCreateDate(curDate); | |||||
| weappExtSet.setUpdateDate(curDate); | |||||
| weappExtSetMapper.insertSelective(weappExtSet); | |||||
| } else { | } else { | ||||
| record.setId(authorizerInfo.getId()); | record.setId(authorizerInfo.getId()); | ||||
| record.setUpdateTime(new Date()); | |||||
| record.setUpdateTime(curDate); | |||||
| logger.info(record.toString()); | logger.info(record.toString()); | ||||
| wxAuthorizerInfoMapper.updateByPrimaryKeySelective(record); | |||||
| authorizerInfoMapper.updateByPrimaryKeySelective(record); | |||||
| } | } | ||||
| } | } | ||||
| @Override | @Override | ||||
| public void deleteById(Long id) { | public void deleteById(Long id) { | ||||
| wxAuthorizerInfoMapper.deleteByPrimaryKey(id); | |||||
| authorizerInfoMapper.deleteByPrimaryKey(id); | |||||
| } | } | ||||