package com.zy.asrs.wms.controller; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.zy.asrs.common.wms.entity.WaitPakinLog; import com.zy.asrs.common.wms.service.WaitPakinLogService; import com.zy.asrs.framework.annotations.ManagerAuth; import com.zy.asrs.framework.common.Cools; import com.zy.asrs.framework.common.R; import com.zy.asrs.framework.domain.KeyValueVo; import com.zy.asrs.framework.common.DateUtils; import com.zy.asrs.common.web.BaseController; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import java.util.*; @RestController public class WaitPakinLogController extends BaseController { @Autowired private WaitPakinLogService waitPakinLogService; @RequestMapping(value = "/waitPakinLog/{id}/auth") @ManagerAuth public R get(@PathVariable("id") String id) { return R.ok(waitPakinLogService.getById(String.valueOf(id))); } @RequestMapping(value = "/waitPakinLog/page/auth") @ManagerAuth public R page(@RequestParam(defaultValue = "1") Integer curr, @RequestParam(defaultValue = "10") Integer limit, @RequestParam(required = false) String condition, @RequestParam(required = false) String timeRange, @RequestParam Map param) { LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); if (!Cools.isEmpty(condition)) { wrapper.like(WaitPakinLog::getId, condition); } if (!Cools.isEmpty(timeRange)) { String[] range = timeRange.split(RANGE_TIME_LINK); wrapper.ge(WaitPakinLog::getAppeTime, DateUtils.convert(range[0])); wrapper.le(WaitPakinLog::getAppeTime, DateUtils.convert(range[1])); } return R.ok(waitPakinLogService.page(new Page<>(curr, limit), wrapper)); } @RequestMapping(value = "/waitPakinLog/add/auth") @ManagerAuth public R add(WaitPakinLog waitPakinLog) { waitPakinLogService.save(waitPakinLog); return R.ok(); } @RequestMapping(value = "/waitPakinLog/update/auth") @ManagerAuth public R update(WaitPakinLog waitPakinLog){ if (Cools.isEmpty(waitPakinLog) || null==waitPakinLog.getId()){ return R.error(); } waitPakinLogService.updateById(waitPakinLog); return R.ok(); } @RequestMapping(value = "/waitPakinLog/delete/auth") @ManagerAuth public R delete(@RequestParam(value="ids[]") Long[] ids){ for (Long id : ids){ waitPakinLogService.removeById(id); } return R.ok(); } @RequestMapping(value = "/waitPakinLogQuery/auth") @ManagerAuth public R query(String condition) { LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); wrapper.like(WaitPakinLog::getId, condition); Page page = waitPakinLogService.page(new Page<>(0, 10), wrapper); List> result = new ArrayList<>(); for (WaitPakinLog waitPakinLog : page.getRecords()){ Map map = new HashMap<>(); map.put("id", waitPakinLog.getId()); map.put("value", waitPakinLog.getId()); result.add(map); } return R.ok(result); } @RequestMapping("/waitPakinLog/all/get/kv") @ManagerAuth public R getDataKV(@RequestParam(required = false) String condition) { List vos = new ArrayList<>(); LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); if (!Cools.isEmpty(condition)) { wrapper.like(WaitPakinLog::getId, condition); } waitPakinLogService.page(new Page<>(1, 30), wrapper).getRecords().forEach(item -> vos.add(new KeyValueVo(String.valueOf(item.getId()), item.getId()))); return R.ok().add(vos); } }