From 0a83c671e7554f4e0e68bf5f71f429d2ac558058 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Wed, 20 Feb 2019 10:24:16 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=BE=AE=E4=BF=A1=E5=BC=80=E5=8F=91=E5=B9=B3?= =?UTF-8?q?=E5=8F=B0][=E4=BF=AE=E6=94=B9]:=E6=8E=88=E6=9D=83=E5=88=9B?= =?UTF-8?q?=E5=BB=BA=E6=89=A9=E5=B1=95=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/WxAuthorizerInfoServiceImpl.java | 59 ++++++++++++++----- 1 file changed, 44 insertions(+), 15 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxAuthorizerInfoServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxAuthorizerInfoServiceImpl.java index f0130490f..1d9026202 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxAuthorizerInfoServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxAuthorizerInfoServiceImpl.java @@ -2,9 +2,13 @@ package com.iformall.service.impl; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; +import com.iformall.domain.po.WxAppinfo; import com.iformall.domain.po.WxAuthorizerInfo; +import com.iformall.domain.po.WxWeappExtSet; import com.iformall.domain.vo.WxWeappInfo; +import com.iformall.mapper.WxAppinfoMapper; import com.iformall.mapper.WxAuthorizerInfoMapper; +import com.iformall.mapper.WxWeappExtSetMapper; import com.iformall.service.WxAuthorizerInfoService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -20,58 +24,83 @@ public class WxAuthorizerInfoServiceImpl implements WxAuthorizerInfoService { private final Logger logger = LoggerFactory.getLogger(this.getClass()); @Autowired - WxAuthorizerInfoMapper wxAuthorizerInfoMapper; + WxAuthorizerInfoMapper authorizerInfoMapper; + + @Autowired + WxWeappExtSetMapper weappExtSetMapper; + + @Autowired + WxAppinfoMapper appinfoMapper; @Override public PageInfo 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 public PageInfo 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 public List getList(WxWeappInfo record) { - return wxAuthorizerInfoMapper.findVoList(record); + return authorizerInfoMapper.findVoList(record); } @Override public WxAuthorizerInfo getById(Long id) { - return wxAuthorizerInfoMapper.selectByPrimaryKey(id); + return authorizerInfoMapper.selectByPrimaryKey(id); } @Override public void saveOrUpdate(WxAuthorizerInfo record) { + // 1. 添加到wx_authorizer_info表中 + // 2. 同时在wx_weapp_ext_set中添加一条记录 + Date curDate = new Date(); logger.info(record.toString()); WxAuthorizerInfo authorizerInfo = null; try { WxAuthorizerInfo aiQ = new WxAuthorizerInfo(); aiQ.setAuthorizerAppid(record.getAuthorizerAppid()); - authorizerInfo = wxAuthorizerInfoMapper.selectOne(aiQ); + authorizerInfo = authorizerInfoMapper.selectOne(aiQ); } catch (Exception e) { logger.error(e.getMessage()); } 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 { record.setId(authorizerInfo.getId()); - record.setUpdateTime(new Date()); + record.setUpdateTime(curDate); logger.info(record.toString()); - wxAuthorizerInfoMapper.updateByPrimaryKeySelective(record); + authorizerInfoMapper.updateByPrimaryKeySelective(record); } } @Override public void deleteById(Long id) { - wxAuthorizerInfoMapper.deleteByPrimaryKey(id); + authorizerInfoMapper.deleteByPrimaryKey(id); }