| | |
| | | @Override |
| | | @DS("ztznwh") |
| | | public boolean exportSkxsQkTj(SkxsQkTj skxsQkTj) { |
| | | // 查询库中是否包含当前日期,当前行政区的数据,如果有,则更新,没有则新增 |
| | | // 查询库中是否包含当前日期,当前行政区的数据,如果有,则更新,没有则新增 ---有问题 |
| | | QueryWrapper<SkxsQkTj> wrapper = new QueryWrapper<>(); |
| | | wrapper.eq("\"statistic_time\"",skxsQkTj.getStatisticTime()) |
| | | .eq("\"res_code\"",skxsQkTj.getResCode()); |
| | |
| | | */ |
| | | @Override |
| | | public Object getStatisticList(SkxsQkTjVO skxsQkTj) { |
| | | // 通过adCode 获取adGrad |
| | | String adGrad = baseMapper.getAdGradByAdCode(skxsQkTj.getAdCode()); |
| | | if (null!= adGrad && !adGrad.equals("")){ |
| | | skxsQkTj.setAdGrad(adGrad); |
| | | } |
| | | return baseMapper.getStatisticList(skxsQkTj); |
| | | } |
| | | |
| | |
| | | data.forEach(skxsQkTjExcel -> { |
| | | SkxsQkTj skxsQkTj = Objects.requireNonNull(BeanUtil.copy(skxsQkTjExcel, SkxsQkTj.class)); |
| | | // 查询库中是否包含当前日期,当前行政区的数据,如果有,则更新,没有则新增 |
| | | QueryWrapper<SkxsQkTj> wrapper = new QueryWrapper<>(); |
| | | wrapper.eq("\"statistic_time\"",skxsQkTj.getStatisticTime()) |
| | | .eq("\"res_code\"",skxsQkTj.getResCode()); |
| | | SkxsQkTj qkTj = baseMapper.selectOne(wrapper); |
| | | SkxsQkTj qkTj = baseMapper.selectSkxsQkTj(skxsQkTjExcel); |
| | | // 设置更新人员,更新时间,来源信息 |
| | | skxsQkTj.setUpdateTime(new Date()); |
| | | skxsQkTj.setUpdateUser(AuthUtil.getUserId()); |