| package com.zy.asrs.controller; | 
|   | 
| import com.alibaba.excel.EasyExcel; | 
| import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy; | 
| import com.alibaba.fastjson.JSONArray; | 
| import com.alibaba.fastjson.JSONObject; | 
| import com.baomidou.mybatisplus.mapper.EntityWrapper; | 
| import com.baomidou.mybatisplus.mapper.Wrapper; | 
| import com.baomidou.mybatisplus.plugins.Page; | 
| import com.core.annotations.ManagerAuth; | 
| import com.core.common.BaseRes; | 
| import com.core.common.Cools; | 
| import com.core.common.DateUtils; | 
| import com.core.common.R; | 
| import com.zy.asrs.entity.LocDetl; | 
| import com.zy.asrs.entity.ManLocDetl; | 
| import com.zy.asrs.entity.Mat; | 
| import com.zy.asrs.entity.StockStatisDTO; | 
| import com.zy.asrs.mapper.LocDetlMapper; | 
| import com.zy.asrs.service.LocDetlService; | 
| import com.zy.asrs.service.ManLocDetlService; | 
| import com.zy.asrs.service.MatService; | 
| import com.zy.common.web.BaseController; | 
| import org.springframework.beans.factory.annotation.Autowired; | 
| import org.springframework.web.bind.annotation.*; | 
|   | 
| import javax.servlet.http.HttpServletResponse; | 
| import java.io.IOException; | 
| import java.net.URLEncoder; | 
| import java.util.*; | 
|   | 
| @RestController | 
| public class LocDetlController extends BaseController { | 
|   | 
|     @Autowired | 
|     private LocDetlService locDetlService; | 
|   | 
|     @Autowired | 
|     private LocDetlMapper locDetlMapper; | 
|     @Autowired | 
|     private MatService matService; | 
|   | 
|     @RequestMapping(value = "/locDetl/update") | 
|     public R update1() { | 
|         if (!locDetlService.updateLocNo("0402805", "0402804")) { | 
|             return R.error(); | 
|         } | 
|         return R.ok(); | 
|     } | 
|   | 
|     @RequestMapping(value = "/locDetl/{id}/auth") | 
|     @ManagerAuth | 
|     public R get(@PathVariable("id") String id) { | 
|         return R.ok(locDetlService.selectById(String.valueOf(id))); | 
|     } | 
|   | 
|     @RequestMapping(value = "/locDetl/auth") | 
|     @ManagerAuth | 
|     public R stockOutList(@RequestParam(value = "locNos[]") List<String> locNos){ | 
|         if (!locNos.isEmpty()) { | 
|             List<LocDetl> res = new ArrayList<>(); | 
|             for (String locNo : new HashSet<>(locNos)) { | 
|                 List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", locNo)); | 
|                 if (!locDetls.isEmpty()) { | 
|                     res.addAll(locDetls); | 
|                 } | 
|             } | 
|             return R.ok().add(res); | 
|         } | 
|         return R.parse(BaseRes.EMPTY); | 
|     } | 
|   | 
|     @RequestMapping(value = "/stock/out/list/auth") | 
|     @ManagerAuth | 
|     public R stockOutList(@RequestParam(defaultValue = "1")Integer curr, | 
|                           @RequestParam(defaultValue = "10")Integer limit, | 
|                           @RequestParam Map<String, Object> param){ | 
|         if (!Cools.isEmpty(param.get("modi_time"))){ | 
|             String val = String.valueOf(param.get("modi_time")); | 
|             if (val.contains(RANGE_TIME_LINK)) { | 
|                 String[] dates = val.split(RANGE_TIME_LINK); | 
|                 param.put("startTime", DateUtils.convert(dates[0])); | 
|                 param.put("endTime", DateUtils.convert(dates[1])); | 
|                 param.remove("modi_time"); | 
|             } | 
|         } | 
|         Page<LocDetl> stockOut = locDetlService.getStockOut(toPage(curr, limit, param, LocDetl.class)); | 
|         if (stockOut.getRecords().size()==0){ | 
|             stockOut = locDetlService.getStockOut(toPage(1, limit, param, LocDetl.class)); | 
|         } | 
|         return R.ok(stockOut); | 
|     } | 
|   | 
|     @RequestMapping(value = "/locDetl/list/auth")// /locDetl/list/auth 接口问题 | 
|     @ManagerAuth | 
|     public R list(@RequestParam(defaultValue = "1")Integer curr, | 
|                   @RequestParam(defaultValue = "10")Integer limit, | 
|                   @RequestParam(required = false)String orderByField, | 
|                   @RequestParam(required = false)String orderByType, | 
|                   @RequestParam(required = false)String condition, | 
|                   @RequestParam Map<String, Object> param){ | 
| //        String row = ""; | 
|         EntityWrapper<LocDetl> wrapper = new EntityWrapper<>(); | 
| //        if (param.get("row") != null) { | 
| //            String chooseRow = (String) param.get("row"); | 
| //            if (chooseRow.length() == 1) { | 
| //                row = "0" + chooseRow; | 
| //                param.remove("row"); | 
| //            }else { | 
| //                row = chooseRow; | 
| //                param.remove("row"); | 
| //            } | 
| //        } | 
|         Object query_date = param.get("query_date"); | 
|         param.remove("query_date"); | 
|         excludeTrash(param); | 
|         convert(param, wrapper); | 
|         allLike(LocDetl.class, param.keySet(), wrapper, condition); | 
|         if (!Cools.isEmpty(orderByField)){wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));} | 
| //        if (!row.equals("")){ | 
| //            wrapper.and() | 
| //                    .where("loc_no like '" +row +"%'"); | 
| //        } | 
|         if (query_date!=null){ | 
|             if (query_date.toString().contains(" - ")) { | 
|                 String[] dates = query_date.toString().split(" - "); | 
|                 wrapper.ge("appe_time", dates[0]).le("appe_time",dates[1]); | 
|             } | 
|         } | 
|         return R.ok(locDetlService.selectPage(new Page<>(curr, limit), wrapper)); | 
|     } | 
|   | 
|   | 
|     private <T> void convert(Map<String, Object> map, EntityWrapper<T> wrapper){ | 
|         for (Map.Entry<String, Object> entry : map.entrySet()){ | 
|             String val = String.valueOf(entry.getValue()); | 
|             if (val.contains(RANGE_TIME_LINK)){ | 
|                 String[] dates = val.split(RANGE_TIME_LINK); | 
|                 wrapper.ge(entry.getKey(), DateUtils.convert(dates[0])); | 
|                 wrapper.le(entry.getKey(), DateUtils.convert(dates[1])); | 
|             } else { | 
|                 if (entry.getKey().equals("locNo")) { | 
|                     wrapper.eq("loc_no", String.valueOf(entry.getValue())); | 
|                 } else { | 
|                     wrapper.like(entry.getKey(), String.valueOf(entry.getValue())); | 
|                 } | 
|             } | 
|         } | 
|     } | 
|   | 
|     @RequestMapping(value = "/locDetl/add/auth") | 
|     @ManagerAuth(memo = "库位明细添加") | 
|     public R add(LocDetl locDetl) { | 
|         locDetl.setModiUser(getUserId()); | 
|         locDetl.setModiTime(new Date()); | 
|         locDetl.setAppeUser(getUserId()); | 
|         locDetl.setAppeTime(new Date()); | 
|         locDetlService.insert(locDetl); | 
|         return R.ok(); | 
|     } | 
|   | 
|     @RequestMapping(value = "/locDetl/update/auth") | 
|     @ManagerAuth(memo = "库位明细修改") | 
|     public R update(LocDetl locDetl){ | 
|         if (Cools.isEmpty(locDetl) || null==locDetl.getMatnr()){ | 
|             return R.error(); | 
|         } | 
|         locDetl.setModiUser(getUserId()); | 
|         locDetl.setModiTime(new Date()); | 
|         locDetlService.updateById(locDetl); | 
|         return R.ok(); | 
|     } | 
|   | 
|     @RequestMapping(value = "/locDetl/delete/auth") | 
|     @ManagerAuth(memo = "库位明细删除") | 
|     public R delete(@RequestParam String param){ | 
|         List<LocDetl> list = JSONArray.parseArray(param, LocDetl.class); | 
|         if (Cools.isEmpty(list)){ | 
|             return R.error(); | 
|         } | 
|         for (LocDetl entity : list){ | 
|             locDetlService.delete(new EntityWrapper<>(entity)); | 
|         } | 
|         return R.ok(); | 
|     } | 
|   | 
|     @RequestMapping(value = "/locDetl/export/auth") | 
|     @ManagerAuth(memo = "库位明细导出") | 
|     public R export(@RequestBody JSONObject param){ | 
|         List<String> fields = JSONObject.parseArray(param.getJSONArray("fields").toJSONString(), String.class); | 
|         EntityWrapper<LocDetl> wrapper = new EntityWrapper<>(); | 
|         Map<String, Object> map = excludeTrash(param.getJSONObject("locDetl")); | 
|         String row = ""; | 
|         if (map.get("row") != null) { | 
|             String chooseRow = (String) map.get("row"); | 
|             if (chooseRow.length() == 1) { | 
|                 row = "0" + chooseRow; | 
|                 map.remove("row"); | 
|             }else { | 
|                 row = chooseRow; | 
|                 map.remove("row"); | 
|             } | 
|         } | 
|         convert(map, wrapper); | 
|         if (!row.equals("")){ | 
|             wrapper.and() | 
|                     .where("loc_no like '" +row +"%'"); | 
|         } | 
|         List<LocDetl> list = locDetlService.selectList(wrapper); | 
|         return R.ok(exportSupport(list, fields)); | 
|     } | 
|   | 
|     @RequestMapping(value = "/locDetlQuery/auth") | 
|     @ManagerAuth | 
|     public R query(String condition) { | 
|         EntityWrapper<LocDetl> wrapper = new EntityWrapper<>(); | 
|         wrapper.like("matnr", condition); | 
|         Page<LocDetl> page = locDetlService.selectPage(new Page<>(0, 10), wrapper); | 
|         List<Map<String, Object>> result = new ArrayList<>(); | 
|         for (LocDetl locDetl : page.getRecords()){ | 
|             Map<String, Object> map = new HashMap<>(); | 
|             map.put("id", locDetl.getMatnr()); | 
|             map.put("value", locDetl.getMatnr()); | 
|             result.add(map); | 
|         } | 
|         return R.ok(result); | 
|     } | 
|   | 
|     @RequestMapping(value = "/locDetl/check/column/auth") | 
|     @ManagerAuth | 
|     public R query(@RequestBody JSONObject param) { | 
|         Wrapper<LocDetl> wrapper = new EntityWrapper<LocDetl>().eq(humpToLine(String.valueOf(param.get("key"))), param.get("val")); | 
|         if (null != locDetlService.selectOne(wrapper)){ | 
|             return R.parse(BaseRes.REPEAT).add(getComment(LocDetl.class, String.valueOf(param.get("key")))); | 
|         } | 
|         return R.ok(); | 
|     } | 
|   | 
|     @RequestMapping(value = "/locDetl/statis/auth") | 
|     @ManagerAuth | 
|     public R statis(@RequestParam(defaultValue = "1")Integer curr, | 
|                     @RequestParam(defaultValue = "10")Integer limit, | 
|                     @RequestParam Map<String, Object> param) { | 
|         Page<StockStatisDTO> stockStatis = locDetlService.getStockStatis(toPage(curr, limit, param, StockStatisDTO.class)); | 
|         return R.ok().add(stockStatis); | 
|     } | 
|   | 
|     @Autowired | 
|     private LocDetlMapper LocDetlMapper; | 
|   | 
|     @RequestMapping(value = "/locDetl/statis/export") | 
| //    @ManagerAuth | 
|     public void statisExport(HttpServletResponse response) throws IOException { | 
|         List<LocDetl> excel = LocDetlMapper.getStockStatisExcel(); | 
|         for (LocDetl locDetl : excel) { | 
|             Mat mat = matService.selectByMatnr(locDetl.getMatnr()); | 
|             if (mat != null) { | 
|                 locDetl.sync(mat); | 
|             } | 
|         } | 
|         response.setContentType("application/vnd.ms-excel"); | 
|         response.setCharacterEncoding("utf-8"); | 
|         String fileName = URLEncoder.encode("库存明细统计报表", "UTF-8"); | 
|         response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".xlsx"); | 
|         EasyExcel.write(response.getOutputStream(), LocDetl.class) | 
|                 .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) | 
|                 .sheet("表1") | 
|                 .doWrite(excel); | 
|     } | 
|   | 
|     /** | 
|      * 获取库存总数 | 
|      * @return | 
|      */ | 
|     @RequestMapping("/locDetl/count") | 
|     public R getAllCount(){ | 
|         Integer sum = locDetlService.sum(); | 
|         return R.ok(sum); | 
|     } | 
|   | 
| } |