|  |  |  | 
|---|
|  |  |  | import com.core.common.DateUtils; | 
|---|
|  |  |  | import com.core.common.R; | 
|---|
|  |  |  | import com.core.exception.CoolException; | 
|---|
|  |  |  | import com.zy.asrs.entity.LocMast; | 
|---|
|  |  |  | import com.zy.asrs.entity.ManLocDetl; | 
|---|
|  |  |  | import com.zy.asrs.entity.Node; | 
|---|
|  |  |  | import com.zy.asrs.entity.param.InitPakoutParam; | 
|---|
|  |  |  | import com.zy.asrs.entity.param.LocMastInitParam; | 
|---|
|  |  |  | import com.zy.asrs.entity.param.NodeInitPatam; | 
|---|
|  |  |  | import com.zy.asrs.entity.param.PakinParam; | 
|---|
|  |  |  | import com.zy.asrs.entity.result.KeyValueVo; | 
|---|
|  |  |  | 
|---|
|  |  |  | import com.zy.common.entity.NodeExcel; | 
|---|
|  |  |  | import com.zy.common.entity.NodeExcelListener; | 
|---|
|  |  |  | import com.zy.common.entity.Parameter; | 
|---|
|  |  |  | import com.zy.common.model.Shelves; | 
|---|
|  |  |  | import com.zy.common.utils.ListUtils; | 
|---|
|  |  |  | import com.zy.common.utils.NodeUtils; | 
|---|
|  |  |  | import com.zy.common.utils.TreeUtils; | 
|---|
|  |  |  | 
|---|
|  |  |  | import java.io.IOException; | 
|---|
|  |  |  | import java.net.URLEncoder; | 
|---|
|  |  |  | import java.util.*; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import static jdk.nashorn.api.scripting.ScriptUtils.convert; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @RestController | 
|---|
|  |  |  | public class NodeController extends BaseController { | 
|---|
|  |  |  | 
|---|
|  |  |  | @RequestParam(required = false)String orderByType, | 
|---|
|  |  |  | @RequestParam Map<String, Object> param){ | 
|---|
|  |  |  | EntityWrapper<Node> wrapper = new EntityWrapper<>(); | 
|---|
|  |  |  | wrapper.eq("type",3); | 
|---|
|  |  |  | excludeTrash(param); | 
|---|
|  |  |  | convert(param, wrapper); | 
|---|
|  |  |  | hostEq(wrapper); | 
|---|
|  |  |  | if (!Cools.isEmpty(orderByField)){wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));} | 
|---|
|  |  |  | return R.ok(nodeService.selectPage(new Page<>(curr, limit), wrapper)); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | @RequestParam(required = false)String orderByType, | 
|---|
|  |  |  | @RequestParam Map<String, Object> param){ | 
|---|
|  |  |  | EntityWrapper<Node> wrapper = new EntityWrapper<>(); | 
|---|
|  |  |  | wrapper.ne("type",3); | 
|---|
|  |  |  | excludeTrash(param); | 
|---|
|  |  |  | convert(param, wrapper); | 
|---|
|  |  |  | hostEq(wrapper); | 
|---|
|  |  |  | 
|---|
|  |  |  | @RequestMapping(value = "/node/update/auth") | 
|---|
|  |  |  | @ManagerAuth | 
|---|
|  |  |  | public R update(Node node){ | 
|---|
|  |  |  | Node node1 = nodeService.selectByUuid(node.getName()); | 
|---|
|  |  |  | if (!Cools.isEmpty(node1)) { | 
|---|
|  |  |  | throw new CoolException("该编号/名称已存在"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //        Node node1 = nodeService.selectByUuid(node.getName()); | 
|---|
|  |  |  | //        if (!Cools.isEmpty(node1)) { | 
|---|
|  |  |  | //            throw new CoolException("该编号/名称已存在"); | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | if (Cools.isEmpty(node) || null==node.getId()){ | 
|---|
|  |  |  | return R.error(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | if (node.getType() != 3) { | 
|---|
|  |  |  | return R.error("仅可选择货位"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return nodeService.stockPakin(number, getUserId(), getHostId()); | 
|---|
|  |  |  | return nodeService.stockPakin(number, getUserId(), getHostId(),getUser()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @RequestMapping("/work/stock/pakout") | 
|---|
|  |  |  | @ManagerAuth(memo = "出库") | 
|---|
|  |  |  | public R initPakout(@RequestBody List<InitPakoutParam> params) { | 
|---|
|  |  |  | return nodeService.initPakout(params, getUserId(), getHostId()); | 
|---|
|  |  |  | return nodeService.initPakout(params, getUserId(), getHostId(),getUser()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @PostMapping(value = "/work/empty/stock") | 
|---|
|  |  |  | 
|---|
|  |  |  | @ManagerAuth(memo = "库位移转") | 
|---|
|  |  |  | public R locMoveStart(@RequestParam String sourceLocNo, | 
|---|
|  |  |  | @RequestParam String targetLocNo) { | 
|---|
|  |  |  | nodeService.locMove(sourceLocNo, targetLocNo, getUserId()); | 
|---|
|  |  |  | nodeService.locMove(sourceLocNo, targetLocNo, getUserId(),getUser()); | 
|---|
|  |  |  | return R.ok("移库启动成功"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | @RequestMapping(value = "/node/select/{id}/auth") | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @RequestMapping(value = "/node/init/auth") | 
|---|
|  |  |  | @ManagerAuth(memo = "初始化库位") | 
|---|
|  |  |  | //    @Transactional | 
|---|
|  |  |  | @ManagerAuth(memo = "平库库位初始化") | 
|---|
|  |  |  | @Transactional | 
|---|
|  |  |  | public R init(NodeInitPatam param) { | 
|---|
|  |  |  | List<Node> list = new ArrayList<>(); | 
|---|
|  |  |  | EntityWrapper<Node> nodeEntityWrapper = new EntityWrapper<>(); | 
|---|
|  |  |  | nodeEntityWrapper.eq("id",param.getValue()); | 
|---|
|  |  |  | nodeEntityWrapper.eq("name",param.getName()); | 
|---|
|  |  |  | //        nodeService.delete(new EntityWrapper<Node>().eq("parent_id",param.getValue())); | 
|---|
|  |  |  | Node node = nodeService.selectOne(nodeEntityWrapper); | 
|---|
|  |  |  | for (int r=param.getStartRow(); r<=param.getEndRow(); r++){ | 
|---|
|  |  |  | for (int b=param.getStartBay(); b<=param.getEndBay(); b++) { | 
|---|
|  |  |  | String[] string = node.getNamePath().split(","); | 
|---|
|  |  |  | int tno=1; int no=1; | 
|---|
|  |  |  | for (int b=param.getStartBay(); b<=param.getEndBay(); b++) { | 
|---|
|  |  |  | for (int r=param.getStartRow(); r<=param.getEndRow(); r++){ | 
|---|
|  |  |  | for (int l=param.getStartLev(); l<=param.getEndLev(); l++) { | 
|---|
|  |  |  | // 获取库位号 | 
|---|
|  |  |  | String locNo = param.getName()+"-" +String.format("%02d", r) + String.format("%02d", b) + String.format("%02d", l); | 
|---|
|  |  |  | String locNo; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (param.getName().equals("DT-B")){ | 
|---|
|  |  |  | if (b == 2 || b ==4 || b == 7){ | 
|---|
|  |  |  | if (l == 1){ | 
|---|
|  |  |  | locNo = param.getName()+"T-" +String.format("%02d", tno) + String.format("%02d", r) + String.format("%02d", l); | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | locNo = null; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | locNo = param.getName()+"-" +String.format("%02d", no) + String.format("%02d", r) + String.format("%02d", l); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }else if (param.getName().equals("DT-C") || param.getName().equals("DT-D")){ | 
|---|
|  |  |  | if (b == 3 || b ==6 || b == 9 || b == 12 || b == 15 || b == 17 || b == 20 || b == 23){ | 
|---|
|  |  |  | if (l == 1){ | 
|---|
|  |  |  | locNo = param.getName()+"T-" +String.format("%02d", tno) + String.format("%02d", r) + String.format("%02d", l); | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | locNo = null; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | locNo = param.getName()+"-" +String.format("%02d", no) + String.format("%02d", r) + String.format("%02d", l); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | locNo = param.getName()+String.format("%02d", r) + String.format("%02d", b) + String.format("%02d", l); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //客户要求格式位A-01-01-01 | 
|---|
|  |  |  | StringBuilder sb = new StringBuilder(locNo); | 
|---|
|  |  |  | sb.insert(sb.length()-4,"-"); | 
|---|
|  |  |  | sb.insert(sb.length()-2,"-"); | 
|---|
|  |  |  | locNo = sb.toString(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (locNo == null){ | 
|---|
|  |  |  | continue; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | List<Node> nodeList = nodeService.selectList(new EntityWrapper<Node>().eq("name", locNo)); | 
|---|
|  |  |  | if (!Cools.isEmpty(nodeList)){ | 
|---|
|  |  |  | throw new CoolException("库位号重复"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Date now =  new Date(); | 
|---|
|  |  |  | Node node1 = new Node(); | 
|---|
|  |  |  | 
|---|
|  |  |  | node1.setRow1(r); | 
|---|
|  |  |  | node1.setBay1(b); | 
|---|
|  |  |  | node1.setLev1(l); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (!nodeService.insert(node1)){ | 
|---|
|  |  |  | return R.error("数据插入失败"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (param.getName().equals("DT-B")){ | 
|---|
|  |  |  | if (b == 2 || b ==4 || b == 7){ | 
|---|
|  |  |  | tno++; | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | no++; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }else if (param.getName().equals("DT-C") || param.getName().equals("DT-D")){ | 
|---|
|  |  |  | if (b == 3 || b ==6 || b == 9 || b == 12 || b == 15 || b == 17 || b == 20 || b == 23){ | 
|---|
|  |  |  | tno++; | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | no++; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | // | 
|---|
|  |  |  | //        nodeService.delete(new EntityWrapper<Node>().eq("parent_id",param.getValue())); | 
|---|
|  |  |  | 
|---|
|  |  |  | return R.ok(keyValueVoList); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | @RequestMapping(value = "/node/recommendLoc") | 
|---|
|  |  |  | public R recommendLoc(@RequestParam String matnr){ | 
|---|
|  |  |  | List<String> remmendLoc = nodeService.getRemmendLoc(matnr); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return R.ok(remmendLoc); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @RequestMapping(value = "/node/updateStatus") | 
|---|
|  |  |  | @ManagerAuth(memo = "库位冻结") | 
|---|
|  |  |  | public R updateStockFreeze(@RequestParam String param){ | 
|---|
|  |  |  | List<Node> list = JSONArray.parseArray(param, Node.class); | 
|---|
|  |  |  | if (Cools.isEmpty(list)){ | 
|---|
|  |  |  | return R.error("无数据"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | for (Node node : list){ | 
|---|
|  |  |  | node.setStatus(0); | 
|---|
|  |  |  | if (nodeService.updateStockFreeze(node.getName(), node.getStatus()) != 1){ | 
|---|
|  |  |  | return R.error(node.getName()+"冻结失败"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return R.ok("冻结成功"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @RequestMapping(value = "/node/updateDisStatus") | 
|---|
|  |  |  | @ManagerAuth(memo = "库位解除冻结") | 
|---|
|  |  |  | public R updateStockDisFreeze(@RequestParam String param){ | 
|---|
|  |  |  | List<Node> list = JSONArray.parseArray(param, Node.class); | 
|---|
|  |  |  | if (Cools.isEmpty(list)){ | 
|---|
|  |  |  | return R.error("无数据"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | for (Node node : list){ | 
|---|
|  |  |  | node.setStatus(1); | 
|---|
|  |  |  | if (nodeService.updateStockFreeze(node.getName(), node.getStatus()) != 1){ | 
|---|
|  |  |  | return R.error(node.getName()+"解除冻结失败"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return R.ok("解冻成功"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|