forked from free-lancers/electricity_bill_calc_service
		
	feat(meter):增加分页获取户表表计列表功能。
This commit is contained in:
		| @@ -6,6 +6,7 @@ import ( | ||||
| 	"electricity_bill_calc/service" | ||||
| 	"fmt" | ||||
| 	"net/http" | ||||
| 	"strconv" | ||||
|  | ||||
| 	"github.com/gin-gonic/gin" | ||||
| ) | ||||
| @@ -22,6 +23,7 @@ func InitializeMeter04kVController(router *gin.Engine) { | ||||
| 	} | ||||
|  | ||||
| 	Meter04kVController.Router.GET("/park/:pid/meter/template", security.EnterpriseAuthorize, download04kvMeterArchiveTemplate) | ||||
| 	Meter04kVController.Router.GET("/park/:pid/meters", security.EnterpriseAuthorize, ListPaged04kVMeter) | ||||
| } | ||||
|  | ||||
| func download04kvMeterArchiveTemplate(c *gin.Context) { | ||||
| @@ -51,3 +53,39 @@ func download04kvMeterArchiveTemplate(c *gin.Context) { | ||||
| 	c.Header("Content-Transfer-Encoding", "binary") | ||||
| 	c.FileAttachment("./assets/meter_04kv_template.xlsx", fmt.Sprintf("%s-户表档案.xlsx", parkDetail.Name)) | ||||
| } | ||||
|  | ||||
| func ListPaged04kVMeter(c *gin.Context) { | ||||
| 	result := response.NewResult(c) | ||||
| 	requestParkId := c.Param("pid") | ||||
| 	userSession, err := _retreiveSession(c) | ||||
| 	if err != nil { | ||||
| 		result.Unauthorized(err.Error()) | ||||
| 		return | ||||
| 	} | ||||
| 	sure, err := service.ParkService.EnsurePark(userSession.Uid, requestParkId) | ||||
| 	if err != nil { | ||||
| 		result.Error(http.StatusInternalServerError, err.Error()) | ||||
| 		return | ||||
| 	} | ||||
| 	if !sure { | ||||
| 		result.Unauthorized("不能访问不属于自己的园区。") | ||||
| 		return | ||||
| 	} | ||||
| 	requestPage, err := strconv.Atoi(c.DefaultQuery("page", "1")) | ||||
| 	if err != nil { | ||||
| 		result.NotAccept("查询参数[page]格式不正确。") | ||||
| 		return | ||||
| 	} | ||||
| 	requestKeyword := c.DefaultQuery("keyword", "") | ||||
| 	meters, totalItem, err := service.Meter04kVService.ListMeterDetail(requestParkId, requestKeyword, requestPage) | ||||
| 	if err != nil { | ||||
| 		result.NotFound(err.Error()) | ||||
| 		return | ||||
| 	} | ||||
| 	result.Json( | ||||
| 		http.StatusOK, | ||||
| 		"已获取到符合条件的0.4kV表计集合。", | ||||
| 		response.NewPagedResponse(requestPage, totalItem).ToMap(), | ||||
| 		gin.H{"meters": meters}, | ||||
| 	) | ||||
| } | ||||
|   | ||||
							
								
								
									
										36
									
								
								service/meter04kv.go
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										36
									
								
								service/meter04kv.go
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,36 @@ | ||||
| package service | ||||
|  | ||||
| import ( | ||||
| 	"electricity_bill_calc/config" | ||||
| 	"electricity_bill_calc/global" | ||||
| 	"electricity_bill_calc/model" | ||||
|  | ||||
| 	"xorm.io/builder" | ||||
| ) | ||||
|  | ||||
| type _Meter04kVService struct{} | ||||
|  | ||||
| var Meter04kVService _Meter04kVService | ||||
|  | ||||
| func (_Meter04kVService) ListMeterDetail(park, keyword string, page int) ([]model.Meter04KV, int64, error) { | ||||
| 	cond := builder.NewCond() | ||||
| 	if len(keyword) > 0 { | ||||
| 		cond = cond.And( | ||||
| 			builder.Like{"address", keyword}. | ||||
| 				Or(builder.Like{"customer_name", keyword}). | ||||
| 				Or(builder.Like{"code", keyword}). | ||||
| 				Or(builder.Like{"contact_name", keyword}). | ||||
| 				Or(builder.Like{"contact_phone", keyword})) | ||||
| 	} | ||||
| 	total, err := global.DBConn.Where(cond).Count(new(model.Meter04KV)) | ||||
| 	if err != nil { | ||||
| 		return make([]model.Meter04KV, 0), -1, err | ||||
| 	} | ||||
| 	var meters = make([]model.Meter04KV, 0) | ||||
| 	startItem := (page - 1) * config.ServiceSettings.ItemsPageSize | ||||
| 	err = global.DBConn. | ||||
| 		Where(cond). | ||||
| 		Limit(config.ServiceSettings.ItemsPageSize, startItem). | ||||
| 		Find(&meters) | ||||
| 	return meters, total, err | ||||
| } | ||||
		Reference in New Issue
	
	Block a user