package doumeemes.api.ext;
|
import com.alibaba.fastjson.JSONObject;
|
import doumeemes.config.rocketmq.MqConfig;
|
import doumeemes.config.rocketmq.RocketMessageProducer;
|
import doumeemes.core.utils.DateUtil;
|
import doumeemes.dao.business.model.Workorder;
|
import doumeemes.dao.ext.vo.PlansExtListCountVO;
|
import doumeemes.dao.ext.vo.PlansExtListH5VO;
|
import doumeemes.service.ext.WorkorderExtService;
|
import org.apache.poi.ss.usermodel.Cell;
|
import doumeemes.api.BaseController;
|
import doumeemes.core.annotation.excel.ExcelExporter;
|
import doumeemes.core.annotation.pr.PreventRepeat;
|
import doumeemes.core.model.ApiResponse;
|
import doumeemes.core.model.PageWrap;
|
import doumeemes.core.model.PageData;
|
import doumeemes.core.utils.Constants;
|
import doumeemes.dao.business.model.Plans;
|
import doumeemes.dao.ext.dto.QueryPlansExtDTO;
|
import doumeemes.dao.ext.vo.PlansExtListVO;
|
import doumeemes.service.business.PlansService;
|
import doumeemes.service.ext.PlansExtService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import org.apache.shiro.authz.annotation.RequiresPermissions;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.multipart.MultipartFile;
|
import org.springframework.web.multipart.MultipartHttpServletRequest;
|
import org.springframework.web.multipart.commons.CommonsMultipartResolver;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
|
import java.util.ArrayList;
|
import java.util.Iterator;
|
import java.util.List;
|
|
/**
|
* 生产计划接口
|
* @author 江蹄蹄
|
* @date 2022/04/20 11:01
|
*/
|
@RestController
|
@RequestMapping("/ext/plansExt")
|
@Api(tags = "生产计划接口")
|
public class PlansExtController extends BaseController {
|
|
@Autowired
|
private PlansExtService plansExtService;
|
@Autowired
|
private WorkorderExtService workorderExtService;
|
@Autowired
|
private PlansService plansService;
|
|
@PreventRepeat
|
@ApiOperation("新建")
|
@PostMapping("/create")
|
@RequiresPermissions("ext:plansext:create")
|
public ApiResponse create(@RequestBody Plans plans) {
|
return ApiResponse.success(plansExtService.create(plans));
|
}
|
|
@ApiOperation("根据ID删除")
|
@GetMapping("/delete/{id}")
|
@RequiresPermissions("ext:plansext:delete")
|
public ApiResponse deleteById(@PathVariable Integer id) {
|
plansExtService.deleteById(id);
|
return ApiResponse.success(null);
|
}
|
|
@ApiOperation("批量删除")
|
@GetMapping("/delete/batch")
|
@RequiresPermissions("ext:plansext:delete")
|
public ApiResponse deleteByIds(@RequestParam String ids) {
|
String [] idArray = ids.split(",");
|
List<Integer> idList = new ArrayList<>();
|
for (String id : idArray) {
|
idList.add(Integer.valueOf(id));
|
}
|
plansExtService.deleteByIdInBatch(idList);
|
return ApiResponse.success(null);
|
}
|
|
@ApiOperation("根据ID修改")
|
@PostMapping("/updateById")
|
@RequiresPermissions("ext:plansext:update")
|
public ApiResponse updateById(@RequestBody Plans plans) {
|
plansExtService.updateById(plans);
|
return ApiResponse.success(null);
|
}
|
@ApiOperation("根据ID关闭计划")
|
@PostMapping("/closeById")
|
@RequiresPermissions("ext:plansext:control")
|
public ApiResponse closeById(@RequestBody Plans plans) {
|
plansExtService.closeById(plans);
|
return ApiResponse.success(null);
|
}
|
@ApiOperation("根据ID分配计划")
|
@PostMapping("/distributeById")
|
@RequiresPermissions("ext:plansext:distribute")
|
public ApiResponse distributeById(@RequestBody Workorder order) {
|
plansExtService.distributeById(order);
|
//发送消息队列处理分享操作
|
workorderExtService.statisticNum(order);
|
// RocketMessageProducer.producerMsg(Constants.MQ_TAG.statistics,null, JSONObject.toJSONString(order));
|
// rabbitTemplate.convertAndSend(Constants.MqTopicKeys.TOPIC_STATISTIC_NUM, Constants.MqTopicKeys.TOPIC_STATISTIC_NUM, JSONObject.toJSONString(order));
|
return ApiResponse.success(null);
|
}
|
@ApiOperation("根据ID发布计划")
|
@PostMapping("/publishById")
|
@RequiresPermissions("ext:plansext:publish")
|
public ApiResponse publishById(@RequestBody Plans plans) {
|
plansExtService.publishById(plans);
|
return ApiResponse.success(null);
|
}
|
@ApiOperation("根据ID撤回计划")
|
@PostMapping("/backById")
|
@RequiresPermissions("ext:plansext:control")
|
public ApiResponse backById(@RequestBody Plans plans) {
|
plansExtService.backById(plans);
|
return ApiResponse.success(null);
|
}
|
@ApiOperation("根据ID暂停计划")
|
@PostMapping("/pauseById")
|
@RequiresPermissions("ext:plansext:control")
|
public ApiResponse pauseById(@RequestBody Plans plans) {
|
plansExtService.pauseById(plans);
|
return ApiResponse.success(null);
|
}
|
@ApiOperation("根据ID恢复计划")
|
@PostMapping("/regainById")
|
@RequiresPermissions("ext:plansext:control")
|
public ApiResponse regainById(@RequestBody Plans plans) {
|
plansExtService.regainById(plans);
|
return ApiResponse.success(null);
|
}
|
|
@ApiOperation("根据ID取消计划")
|
@PostMapping("/cancelById")
|
@RequiresPermissions("ext:plansext:control")
|
public ApiResponse cancelById(@RequestBody Plans plans) {
|
plansExtService.cancelById(plans);
|
return ApiResponse.success(null);
|
}
|
|
|
@ApiOperation("批量发布计划")
|
@GetMapping("/publish/batch")
|
@RequiresPermissions("ext:plansext:publish")
|
public ApiResponse publishByIds(@RequestParam String ids) {
|
String [] idArray = ids.split(",");
|
List<Integer> idList = new ArrayList<>();
|
for (String id : idArray) {
|
idList.add(Integer.valueOf(id));
|
}
|
plansExtService.publishByIdInBatch(idList);
|
return ApiResponse.success(null);
|
}
|
|
@ApiOperation("批量分配计划")
|
@PostMapping("/distribute/batch")
|
@RequiresPermissions("ext:plansext:distribute")
|
public ApiResponse distributeByOrders(@RequestBody List<Workorder> orders) {
|
plansExtService.distributeByBatch(orders);
|
if(orders!=null){
|
for(Workorder order :orders){
|
//发送消息队列处理分享操作
|
workorderExtService.statisticNum(order);
|
// RocketMessageProducer.producerMsg(Constants.MQ_TAG.statistics,null, JSONObject.toJSONString(order));
|
// rabbitTemplate.convertAndSend(Constants.MqTopicKeys.TOPIC_STATISTIC_NUM, Constants.MqTopicKeys.TOPIC_STATISTIC_NUM, JSONObject.toJSONString(order));
|
}
|
}
|
return ApiResponse.success(null);
|
}
|
@ApiOperation("批量撤回计划")
|
@GetMapping("/back/batch")
|
@RequiresPermissions("ext:plansext:control")
|
public ApiResponse backByIds(@RequestParam String ids) {
|
String [] idArray = ids.split(",");
|
List<Integer> idList = new ArrayList<>();
|
for (String id : idArray) {
|
idList.add(Integer.valueOf(id));
|
}
|
plansExtService.backByIdInBatch(idList);
|
return ApiResponse.success(null);
|
}
|
@ApiOperation("分页查询")
|
@PostMapping("/page")
|
@RequiresPermissions("ext:plansext:query")
|
public ApiResponse<PageData<PlansExtListVO>> findPage (@RequestBody PageWrap<QueryPlansExtDTO> pageWrap) {
|
return ApiResponse.success(plansExtService.findPage(pageWrap));
|
}
|
|
@ApiOperation("导出Excel")
|
@PostMapping("/exportExcel")
|
@RequiresPermissions("ext:plansext:exportExcel")
|
public void exportExcel (@RequestBody PageWrap<QueryPlansExtDTO> pageWrap, HttpServletResponse response) throws Exception{
|
ExcelExporter.build(PlansExtListVO.class).export(plansExtService.findPage(pageWrap).getRecords(), "生产计划"+ DateUtil.getNowLongTime(), response);
|
}
|
|
@ApiOperation("根据ID查询")
|
@GetMapping("/{id}")
|
@RequiresPermissions("ext:plansext:query")
|
public ApiResponse<PlansExtListVO> findById(@PathVariable Integer id) {
|
return ApiResponse.success(plansExtService.findById(id));
|
}
|
@ApiOperation("根据ID查询(H5端）")
|
@GetMapping("/h5/{id}")
|
@RequiresPermissions("ext:plansext:query")
|
public ApiResponse<PlansExtListH5VO> findByIdH5(@PathVariable Integer id) {
|
return ApiResponse.success(plansExtService.findByIdH5(id));
|
}
|
|
@ApiOperation("查询统计列表数量")
|
@PostMapping("/pageCount")
|
@RequiresPermissions("ext:plansext:query")
|
public ApiResponse<PlansExtListCountVO> pageCount (@RequestBody QueryPlansExtDTO param) {
|
return ApiResponse.success(plansExtService.pageCount(param));
|
}
|
|
/**
|
* 批量导入计划
|
*
|
* @param request
|
* @param response
|
* @throws Exception
|
*/
|
@ApiOperation(value = "批量导入计划", notes = "批量导入计划", httpMethod = "POST", position = 6)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "folder", value = "文件夹", required = true, paramType = "query", dataType = "String", dataTypeClass = String.class),
|
})
|
@PostMapping(value = "/importBatch", headers = "content-type=multipart/form-data")
|
@RequiresPermissions("ext:plansext:create")
|
public ApiResponse importBatch(String folder,HttpServletRequest request, HttpServletResponse response) throws Exception {
|
CommonsMultipartResolver multipartResovler = new CommonsMultipartResolver();
|
if (multipartResovler.isMultipart(request)) {
|
MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
|
Iterator<String> it = multipartRequest.getFileNames();
|
while (it.hasNext()) {
|
MultipartFile file = multipartRequest.getFile((String) it.next());// file
|
plansExtService.importPlans(file);
|
break;
|
}
|
}
|
|
return ApiResponse.success( null);
|
}
|
}
|
