|
@@ -0,0 +1,131 @@
|
|
|
+package com.github.zuihou.business.controller.productionResourceCenter;
|
|
|
+
|
|
|
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
+import com.github.zuihou.authority.entity.common.DictionaryItem;
|
|
|
+import com.github.zuihou.base.R;
|
|
|
+import com.github.zuihou.base.controller.SuperController;
|
|
|
+import com.github.zuihou.business.productionResourceCenter.dto.StationUserPageDTO;
|
|
|
+import com.github.zuihou.business.productionResourceCenter.dto.StationUserSaveDTO;
|
|
|
+import com.github.zuihou.business.productionResourceCenter.dto.StationUserUpdateDTO;
|
|
|
+import com.github.zuihou.business.productionResourceCenter.entity.StationUser;
|
|
|
+import com.github.zuihou.business.productionResourceCenter.service.StationUserService;
|
|
|
+import com.github.zuihou.common.util.StringUtil;
|
|
|
+import com.github.zuihou.database.mybatis.conditions.Wraps;
|
|
|
+import com.github.zuihou.database.mybatis.conditions.query.LbqWrapper;
|
|
|
+import com.github.zuihou.log.annotation.SysLog;
|
|
|
+import io.swagger.annotations.Api;
|
|
|
+import io.swagger.annotations.ApiOperation;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.apache.commons.compress.utils.Lists;
|
|
|
+import org.springframework.validation.annotation.Validated;
|
|
|
+import org.springframework.web.bind.annotation.*;
|
|
|
+
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
+import java.util.stream.Collectors;
|
|
|
+
|
|
|
+
|
|
|
+/**
|
|
|
+ * <p>
|
|
|
+ * 前端控制器
|
|
|
+ * 上下料用户管理
|
|
|
+ * </p>
|
|
|
+ *
|
|
|
+ * @author imcs
|
|
|
+ * @date 2020-11-24
|
|
|
+ */
|
|
|
+@Slf4j
|
|
|
+@Validated
|
|
|
+@RestController
|
|
|
+@RequestMapping("/stationUser")
|
|
|
+@Api(value = "stationUser", tags = "上下料站用户管理")
|
|
|
+@SysLog(enabled = true)
|
|
|
+public class StationUserController extends SuperController<StationUserService, Long, StationUser, StationUserPageDTO, StationUserSaveDTO, StationUserUpdateDTO> {
|
|
|
+
|
|
|
+ @ApiOperation(value = "查询上下料用户管理", notes = "查询上下料用户管理")
|
|
|
+ @GetMapping("/all")
|
|
|
+ public R<List<StationUser>> list() {
|
|
|
+ return success(baseService.list());
|
|
|
+ }
|
|
|
+
|
|
|
+ /*
|
|
|
+ @Override
|
|
|
+ public R<StationUser> handlerSave(StationUserSaveDTO model) {
|
|
|
+ StationUser stationUser = baseService.save(model);
|
|
|
+ return success(stationUser);
|
|
|
+ } */
|
|
|
+
|
|
|
+ @ApiOperation(value = "修改上下料用户管理", notes = "修改上下料用户管理")
|
|
|
+ @PostMapping("/update")
|
|
|
+ public R<StationUser> update(StationUserUpdateDTO model) {
|
|
|
+ StationUser stationUser = baseService.update(model);
|
|
|
+ return success(stationUser);
|
|
|
+ }
|
|
|
+
|
|
|
+ @ApiOperation(value = "新增上下料用户", notes = "新增上下料用户")
|
|
|
+ @PostMapping("/saveAll")
|
|
|
+ public R<Boolean> saveAll(@RequestParam(value = "stationIds[]") List<String> stationIds, @RequestParam(value = "userIds[]") List<String> userIds) {
|
|
|
+ List<StationUser> stationUserList = Lists.newArrayList();
|
|
|
+ for(int i=0; i<stationIds.size(); i++){
|
|
|
+ String[] idArr = userIds.get(i).split(",");
|
|
|
+ for(int j=0;j<idArr.length; j++){
|
|
|
+ StationUser stationUser = new StationUser();
|
|
|
+ stationUser.setStationId(Long.parseLong(stationIds.get(i)));
|
|
|
+ stationUser.setUserId(Long.parseLong(idArr[j]));
|
|
|
+ stationUserList.add(stationUser);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ Boolean bool = baseService.saveOrUpdateBatch(stationUserList) ;
|
|
|
+ return success(bool);
|
|
|
+ }
|
|
|
+
|
|
|
+ @ApiOperation(value = "更新上下料用户", notes = "更新上下料用户")
|
|
|
+ @PostMapping("/updateAll")
|
|
|
+ public R<Boolean> updateAll(@RequestParam(value = "ids[]") List<String> ids,@RequestParam(value = "stationIds[]") List<String> stationIds, @RequestParam(value = "userIds[]") List<String> userIds) {
|
|
|
+ //baseService.removeByIds(ids.stream().filter(id->!id.equals("0")).collect(Collectors.toList()));
|
|
|
+ //清空数据表
|
|
|
+ baseService.truncate();
|
|
|
+ List<StationUser> stationUserList = Lists.newArrayList();
|
|
|
+ for(int i=0; i<ids.size(); i++){
|
|
|
+ StationUser stationUser = new StationUser();
|
|
|
+ stationUser.setUserId(Long.parseLong(userIds.get(i)));
|
|
|
+ stationUser.setStationId(Long.parseLong(stationIds.get(i)));
|
|
|
+ stationUserList.add(stationUser);
|
|
|
+ }
|
|
|
+ Boolean bool = baseService.saveOrUpdateBatch(stationUserList) ;
|
|
|
+ return success(bool);
|
|
|
+ }
|
|
|
+
|
|
|
+ @ApiOperation(value = "查询上下料站", notes = "查询上下料站")
|
|
|
+ @GetMapping("/allStation")
|
|
|
+ public R<List<StationUser>> getAllStations() {
|
|
|
+ return success(baseService.getAllStation(new LbqWrapper<>()));
|
|
|
+ }
|
|
|
+
|
|
|
+ @ApiOperation(value = "查询上下料用户", notes = "查询上下料用户")
|
|
|
+ @GetMapping("/allUser")
|
|
|
+ public R<List<StationUser>> getAllUser() {
|
|
|
+ return success(baseService.getAllUser(new LbqWrapper<>()));
|
|
|
+ }
|
|
|
+
|
|
|
+ @ApiOperation(value = "查询上下料用户", notes = "查询上下料用户")
|
|
|
+ @GetMapping("/stationUser")
|
|
|
+ public R<List<StationUser>> getStationUser(@RequestParam(value="userId",required = false) Long userId) {
|
|
|
+ LbqWrapper<StationUser> wrapper = Wraps.<StationUser>lbQ();
|
|
|
+ if(userId!= null){
|
|
|
+ wrapper.eq(StationUser::getUserId, userId);
|
|
|
+ }
|
|
|
+ return success(baseService.getStationUser(wrapper));
|
|
|
+ }
|
|
|
+
|
|
|
+ @ApiOperation(value = "查询上下料用户", notes = "查询上下料用户")
|
|
|
+ @GetMapping("/getStation")
|
|
|
+ public R<List<StationUser>> getStationByUser(@RequestParam(value="userId",required = false) String userId) {
|
|
|
+ LbqWrapper<StationUser> wrapper = Wraps.<StationUser>lbQ();
|
|
|
+ if(userId!= null){
|
|
|
+ wrapper.eq(StationUser::getUserId, userId);
|
|
|
+ }
|
|
|
+ return success(baseService.getStationByUser(wrapper));
|
|
|
+ }
|
|
|
+}
|