rongchao
/
epmet-cloud-rizhao
1
0
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

调用ruoyi接口获取wgh_jdb数据

dev
HAHA 3 years ago
parent
33b73c6312
commit
c8df11700b
7 changed files with 128 additions and 9 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 1
      epmet-module/open-data-worker/open-data-worker-client/src/main/java/com/epmet/opendata/dto/constant/CaWghDataConstant.java
  2. 27
      epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/controller/WghJdbController.java
  3. 1
      epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/dao/WghJdbDao.java
  4. 11
      epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/WghJdbService.java
  5. 6
      epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/GuardarDatosTaskServiceImpl.java
  6. 88
      epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/WghJdbServiceImpl.java
  7. 3
      epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/WghJdbDao.xml

1
epmet-module/open-data-worker/open-data-worker-client/src/main/java/com/epmet/opendata/dto/constant/CaWghDataConstant.java
View File

@ -24,6 +24,7 @@ public interface CaWghDataConstant {
String SHARE_BM_GRID = "bm_grid";
String SHARE_COMMUNITY = "community";
String SHARE_WGH_DYWG = "wgh_dywg";
String SHARE_WGH_JDB = "wgh_jdb";
String DATA_URL_UNICON = "http://120.221.72.83:9090/bridge/unicom/page";
String DATA_URL_SHARE = "http://120.221.72.83:9090/bridge/share/sharePage";

27
epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/controller/WghJdbController.java
View File

@ -10,6 +10,7 @@ import com.epmet.commons.tools.validator.group.AddGroup;
import com.epmet.commons.tools.validator.group.UpdateGroup;
import com.epmet.commons.tools.validator.group.DefaultGroup;
import com.epmet.opendata.dto.form.PreserVationFormDTO;
import com.epmet.opendata.dto.wgh.WghJdbDTO;
import com.epmet.opendata.excel.WghJdbExcel;
import com.epmet.opendata.service.WghJdbService;
@ -35,20 +36,20 @@ public class WghJdbController {
private WghJdbService wghJdbService;
@RequestMapping("page")
public Result<PageData<WghJdbDTO>> page(@RequestParam Map<String, Object> params){
public Result<PageData<WghJdbDTO>> page(@RequestParam Map<String, Object> params) {
PageData<WghJdbDTO> page = wghJdbService.page(params);
return new Result<PageData<WghJdbDTO>>().ok(page);
}
@RequestMapping(value = "{id}",method = {RequestMethod.POST,RequestMethod.GET})
public Result<WghJdbDTO> get(@PathVariable("id") String id){
@RequestMapping(value = "{id}", method = {RequestMethod.POST, RequestMethod.GET})
public Result<WghJdbDTO> get(@PathVariable("id") String id) {
WghJdbDTO data = wghJdbService.get(id);
return new Result<WghJdbDTO>().ok(data);
}
@NoRepeatSubmit
@PostMapping("save")
public Result save(@RequestBody WghJdbDTO dto){
public Result save(@RequestBody WghJdbDTO dto) {
//效验数据
ValidatorUtils.validateEntity(dto, AddGroup.class, DefaultGroup.class);
wghJdbService.save(dto);
@ -57,7 +58,7 @@ public class WghJdbController {
@NoRepeatSubmit
@PostMapping("update")
public Result update(@RequestBody WghJdbDTO dto){
public Result update(@RequestBody WghJdbDTO dto) {
//效验数据
ValidatorUtils.validateEntity(dto, UpdateGroup.class, DefaultGroup.class);
wghJdbService.update(dto);
@ -65,7 +66,7 @@ public class WghJdbController {
}
@PostMapping("delete")
public Result delete(@RequestBody String[] ids){
public Result delete(@RequestBody String[] ids) {
//效验数据
AssertUtils.isArrayEmpty(ids, "id");
wghJdbService.delete(ids);
@ -78,6 +79,18 @@ public class WghJdbController {
ExcelUtils.exportExcelToTarget(response, null, list, WghJdbExcel.class);
}
/**
* 调用ruoyi接口获取wgh_jdb数据
*
* @param dto
* @return com.epmet.commons.tools.utils.Result
* @author LZN
* @date 2022/6/14 15:31
*/
@PostMapping("/preserWghJdbVation")
public Result getPreserWghJdbVation(@RequestBody PreserVationFormDTO dto) {
wghJdbService.getPreserWghJdbVation(dto);
return new Result();
}
}

1
epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/dao/WghJdbDao.java
View File

@ -14,4 +14,5 @@ import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface WghJdbDao extends BaseDao<WghJdbEntity> {
int deleteAll();
}

11
epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/WghJdbService.java
View File

@ -2,6 +2,7 @@ package com.epmet.opendata.service;
import com.epmet.commons.mybatis.service.BaseService;
import com.epmet.commons.tools.page.PageData;
import com.epmet.opendata.dto.form.PreserVationFormDTO;
import com.epmet.opendata.dto.wgh.WghJdbDTO;
import com.epmet.opendata.entity.WghJdbEntity;
@ -76,4 +77,14 @@ public interface WghJdbService extends BaseService<WghJdbEntity> {
* @date 2022-06-14
*/
void delete(String[] ids);
/**
* 调用ruoyi接口获取wgh_jdb数据
*
* @param dto
* @return void
* @author LZN
* @date 2022/6/14 15:31
*/
void getPreserWghJdbVation(PreserVationFormDTO dto);
}

6
epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/GuardarDatosTaskServiceImpl.java
View File

@ -38,6 +38,9 @@ public class GuardarDatosTaskServiceImpl implements GuardarDatosTaskService {
@Autowired
private WghDywgService wghDywgService;
@Autowired
private WghJdbService wghJdbService;
@Override
public void guardarDatosTask(PreserVationFormDTO dto) {
if (StringUtils.isBlank(dto.getTableName())) {
@ -80,6 +83,9 @@ public class GuardarDatosTaskServiceImpl implements GuardarDatosTaskService {
case CaWghDataConstant.SHARE_WGH_DYWG:
wghDywgService.getPreserDywgVation(dto);
break;
case CaWghDataConstant.SHARE_WGH_JDB:
wghJdbService.getPreserWghJdbVation(dto);
break;
}
}
}

88
epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/WghJdbServiceImpl.java
View File

@ -1,16 +1,25 @@
package com.epmet.opendata.service.impl;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
import com.epmet.commons.tools.constant.FieldConstant;
import com.epmet.commons.tools.constant.NumConstant;
import com.epmet.commons.tools.page.PageData;
import com.epmet.commons.tools.utils.ConvertUtils;
import com.epmet.commons.tools.utils.HttpClientManager;
import com.epmet.commons.tools.utils.Result;
import com.epmet.opendata.dao.WghJdbDao;
import com.epmet.opendata.dto.constant.CaWghDataConstant;
import com.epmet.opendata.dto.form.PreserVationFormDTO;
import com.epmet.opendata.dto.wgh.WghJdbDTO;
import com.epmet.opendata.entity.CaLoudongEntity;
import com.epmet.opendata.entity.WghJdbEntity;
import com.epmet.opendata.redis.WghJdbRedis;
import com.epmet.opendata.service.WghJdbService;
import com.epmet.opendata.util.AesUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -48,8 +57,8 @@ public class WghJdbServiceImpl extends BaseServiceImpl<WghJdbDao, WghJdbEntity>
return ConvertUtils.sourceToTarget(entityList, WghJdbDTO.class);
}
private QueryWrapper<WghJdbEntity> getWrapper(Map<String, Object> params){
String id = (String)params.get(FieldConstant.ID_HUMP);
private QueryWrapper<WghJdbEntity> getWrapper(Map<String, Object> params) {
String id = (String) params.get(FieldConstant.ID_HUMP);
QueryWrapper<WghJdbEntity> wrapper = new QueryWrapper<>();
wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id);
@ -84,4 +93,79 @@ public class WghJdbServiceImpl extends BaseServiceImpl<WghJdbDao, WghJdbEntity>
baseDao.deleteBatchIds(Arrays.asList(ids));
}
/**
* 调用ruoyi接口获取wgh_jdb数据
*
* @param dto
* @return void
* @author LZN
* @date 2022/6/14 15:31
*/
@Override
public void getPreserWghJdbVation(PreserVationFormDTO dto) {
int i = baseDao.deleteAll();
if (i >= 0) {
dto.setPageNo(NumConstant.ONE);
dto.setPageSize(NumConstant.FIFTY);
dto.setTableSchema(CaWghDataConstant.TABLESCHEMA_SHARE);
dto.setTableName(CaWghDataConstant.SHARE_WGH_JDB);
dto.setWhereCase("1=1");
dto.setOrderBy("insert_time");
int pageNo = 1;
int total = 0;
do {
try {
total = listWghJdb(dto);
pageNo++;
dto.setPageNo(pageNo);
} catch (Exception e) {
e.printStackTrace();
}
} while (total > (pageNo * NumConstant.FIFTY));
}
}
private int listWghJdb(PreserVationFormDTO dto) throws Exception {
String aes = AesUtils.encryptByAES(JSONObject.toJSONString(dto), CaWghDataConstant.AESKEY);
JSONObject obj = new JSONObject();
obj.put(CaWghDataConstant.SHARE_CONDITION, aes);
String data = HttpClientManager.getInstance().sendPostByJSON(CaWghDataConstant.DATA_URL_SHARE, obj.toJSONString()).getData();
JSONObject toResult = JSON.parseObject(data);
Result result = ConvertUtils.mapToEntity(toResult, Result.class);
if (!result.success()) {
return dto.getPageNo() + 1;
}
ReturnDate returnDate = JSONObject.parseObject(JSONObject.toJSONString(result.getData()), ReturnDate.class);
this.insertBatch(returnDate.getList());
return returnDate.getTotal();
}
static class ReturnDate {
private int total;
private List<WghJdbEntity> list;
public int getTotal() {
return total;
}
public void setTotal(int total) {
this.total = total;
}
public List<WghJdbEntity> getList() {
return list;
}
public void setList(List<WghJdbEntity> list) {
this.list = list;
}
}
}

3
epmet-module/open-data-worker/open-data-worker-server/src/main/resources/mapper/WghJdbDao.xml
View File

@ -12,6 +12,9 @@
<result property="shapeLeng" column="SHAPE_LENG"/>
<result property="insertTime" column="insert_time"/>
</resultMap>
<delete id="deleteAll">
delete from wgh_jdb
</delete>
</mapper>

Write Preview
Loading…
Cancel
Save