package com.smartearth.poiexcel.controller;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.metadata.OrderItem;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.smartearth.poiexcel.entity.DkEntity;
|
import com.smartearth.poiexcel.entity.ResponseMsg;
|
import com.smartearth.poiexcel.mapper.DkMapper;
|
import com.smartearth.poiexcel.service.DkService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
|
/**
|
* 地块控制器
|
* @author WWW
|
* @date 2023-10-07
|
*/
|
@Api(tags = "地块控制器")
|
@RestController
|
@RequestMapping("/dk")
|
@SuppressWarnings("ALL")
|
public class DkController extends BaseController {
|
@Resource
|
DkMapper dkMapper;
|
|
@Resource
|
DkService dkService;
|
|
@ApiOperation(value = "分页查询地块")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "pageSize", value = "每页条数", dataType = "Integer", paramType = "query", example = "10"),
|
@ApiImplicitParam(name = "pageIndex", value = "分页数（从1开始）", dataType = "Integer", paramType = "query", example = "1")
|
})
|
@GetMapping(value = "/selectByPage")
|
public ResponseMsg<Object> selectByPage(Integer pageSize, Integer pageIndex) {
|
try {
|
if (null == pageSize || pageSize < 1) {
|
pageSize = 10;
|
}
|
if (null == pageIndex || pageIndex < 1) {
|
pageIndex = 1;
|
}
|
|
QueryWrapper<DkEntity> wrapper = new QueryWrapper<>();
|
// wrapper.ge("age",20);
|
|
Page<DkEntity> page = new Page<>(pageIndex, pageSize);
|
page.addOrder(OrderItem.desc("id"));
|
|
IPage<DkEntity> iPage = dkMapper.selectPage(page, wrapper);
|
List<DkEntity> list = iPage.getRecords();
|
|
return success(iPage.getTotal(), list);
|
} catch (Exception ex) {
|
return fail(ex, -1);
|
}
|
}
|
|
@ApiOperation(value = "根据编号更新")
|
@GetMapping(value = "/updateByBh")
|
public ResponseMsg<Object> updateByBh() {
|
try {
|
QueryWrapper<DkEntity> wrapper = new QueryWrapper<>();
|
wrapper.apply("length(dikuaibianhao) > 0");
|
|
List<DkEntity> list = dkMapper.selectList(wrapper);
|
if (null == list || list.isEmpty()) {
|
return success("没需要更新的地块", 0);
|
}
|
|
int rows = 0;
|
for (DkEntity dk : list) {
|
boolean flag = dkService.updateByBh(dk);
|
if (flag) {
|
rows += dkMapper.updateById(dk);
|
}
|
}
|
|
return success(rows);
|
} catch (Exception ex) {
|
return fail(ex, -1);
|
}
|
}
|
|
@ApiOperation(value = "根据坐标更新")
|
@GetMapping(value = "/updateByCoord")
|
public ResponseMsg<Object> updateByCoord() {
|
try {
|
QueryWrapper<DkEntity> wrapper = new QueryWrapper<>();
|
wrapper.apply("point_area is null and lng is not null and lat is not null");
|
|
List<DkEntity> list = dkMapper.selectList(wrapper);
|
if (null == list || list.isEmpty()) {
|
return success("没需要更新的地块", 0);
|
}
|
|
int rows = 0;
|
for (DkEntity dk : list) {
|
boolean flag = dkService.updateByCoord(dk);
|
if (flag) {
|
rows += dkMapper.updateById(dk);
|
}
|
}
|
|
return success(rows);
|
} catch (Exception ex) {
|
return fail(ex, -1);
|
}
|
}
|
}
|
