| | |
| | | package com.zy.asrs.task.handler; |
| | | |
| | | import com.core.common.Cools; |
| | | import com.zy.asrs.entity.Mat; |
| | | import com.zy.asrs.entity.dto.MatnrCountDto; |
| | | import com.zy.asrs.service.MatService; |
| | |
| | | public ReturnT<String> start() { |
| | | try { |
| | | Date now = new Date(); |
| | | List<MatnrCountDto> matnrCountDtos = jdbcTemplate.queryForList("select\n" + |
| | | List<Map<String, Object>> list = jdbcTemplate.queryForList("select\n" + |
| | | "matnr,\n" + |
| | | "count(1) as count\n" + |
| | | "from (\n" + |
| | |
| | | "\tand io_type not in (103,104,107)\n" + |
| | | "\tand (manu_type is null or manu_type != '手动取消')\n" + |
| | | ") a\n" + |
| | | "group by matnr", MatnrCountDto.class); |
| | | for (MatnrCountDto dto : matnrCountDtos) { |
| | | if (dto.getCount() >= 3) { |
| | | Mat mat = matService.selectByMatnr(dto.getMatnr()); |
| | | mat.setInoutEveryday(Boolean.TRUE); |
| | | mat.setUpdateTime(now); |
| | | if (!matService.updateById(mat)) { |
| | | log.error("{}商品修改为高频属性失败!", dto.getMatnr()); |
| | | "group by matnr"); |
| | | if (!Cools.isEmpty(list)) { |
| | | for (Map<String, Object> map : list) { |
| | | MatnrCountDto dto = Cools.conver(map, MatnrCountDto.class); |
| | | if (dto.getCount() >= 3) { |
| | | Mat mat = matService.selectByMatnr(dto.getMatnr()); |
| | | mat.setInoutEveryday(Boolean.TRUE); |
| | | mat.setUpdateTime(now); |
| | | if (!matService.updateById(mat)) { |
| | | log.error("{}商品修改为高频属性失败!", dto.getMatnr()); |
| | | } |
| | | } |
| | | } |
| | | } |