From 2fcd97552d16718cc7997629fd637a73a5a4483f Mon Sep 17 00:00:00 2001 From: 郑永安 <zyazyz250@sina.com> Date: 星期一, 19 六月 2023 14:44:19 +0800 Subject: [PATCH] 删除 --- src/main/java/com/gk/firework/Controller/WarningController.java | 577 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 577 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/gk/firework/Controller/WarningController.java b/src/main/java/com/gk/firework/Controller/WarningController.java new file mode 100644 index 0000000..df6f420 --- /dev/null +++ b/src/main/java/com/gk/firework/Controller/WarningController.java @@ -0,0 +1,577 @@ +package com.gk.firework.Controller; + +import com.alibaba.fastjson.JSONObject; +import com.gk.firework.Controller.Base.BaseController; +import com.gk.firework.Domain.*; +import com.gk.firework.Domain.Utils.Msg; +import com.gk.firework.Domain.Utils.PageInfo; +import com.gk.firework.Domain.Utils.StringUtils; +import com.gk.firework.Domain.Vo.NoEntryVo; +import com.gk.firework.Domain.Vo.WarnContentVo; +import com.gk.firework.Service.*; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiImplicitParams; +import io.swagger.annotations.ApiOperation; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import java.text.SimpleDateFormat; +import java.util.Calendar; +import java.util.Date; +import java.util.HashMap; +import java.util.List; + +@Api(tags = "流向预警接口") +@RestController +public class WarningController extends BaseController { + @Autowired + WarningService warningService; + @Autowired + WarnContentService warnContentService; + @Autowired + UserService userService; + @Autowired + EnterpriseService enterpriseService; + @Autowired + SaleOrderDetailService saleOrderDetailService; + @Autowired + StockService stockService; + + private final String WARN_TYPE_ENTRY = "超期未入库"; + private final String WARN_TYPE_CERT = "运输证超期"; + + @GetMapping("/warning") + @ApiOperation(value = "获取报警阈值",response = Msg.class) + @ApiImplicitParams({ + @ApiImplicitParam(name = "pageIndex",value = "当前页码"), + @ApiImplicitParam(name = "pageSize",value = "每页行数"), + @ApiImplicitParam(name = "sort",value = "排序规则"), + @ApiImplicitParam(name = "order",value = "排序字段"), + @ApiImplicitParam(name = "warntype",value = "警告类型"), + @ApiImplicitParam(name = "enterprisetype",value = "企业类型"), + }) + public Msg getWarningList(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "20") Integer pageSize, String sort, String order, + String warntype, String enterprisetype){ + Msg msg = new Msg(); + msg.setCode("200"); + msg.setMessage("success"); + + PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order); + HashMap<String, Object> condition = new HashMap<String, Object>(); + + if (StringUtils.isNotBlank(warntype)) { + condition.put("warntype", warntype.trim()); + } + + if (StringUtils.isNotBlank(enterprisetype)) { + condition.put("enterprisetype", enterprisetype.trim()); + } + + pageInfo.setCondition(condition); + warningService.selectDataGrid(pageInfo); + msg.setResult(pageInfo); + return msg; + } + + @PostMapping("/warning") + @ApiOperation(value = "修改报警阈值",response = Msg.class) + public Msg editWarningInfo(@RequestBody WarningInfo warningInfo){ + Msg msg = new Msg(); + msg.setCode("200"); + msg.setMessage("success"); + + if (warningInfo.getMinimum() == null){ + msg.setCode("999"); + msg.setMessage("预警值不能为空"); + return msg; + }else if (warningInfo.getMaximum() == null){ + msg.setCode("999"); + msg.setMessage("报警值不能为空"); + return msg; + }else if (warningInfo.getIssms() == null){ + msg.setCode("999"); + msg.setMessage("报警是否开启短信通知不能为空"); + return msg; + } + if (warningInfo.getWarntype().equals("购买超量") && warningInfo.getPeriod() == null){ + msg.setCode("999"); + msg.setMessage("计算周期不能为空"); + return msg; + } + + warningInfo.setModifiedby(getUser().getUsername()); + warningInfo.setModifieddate(new Date()); + warningService.updateById(warningInfo); + return msg; + } + + @GetMapping("/stockWarning") + @ApiOperation(value = "获取库存超量",response = Msg.class) + @ApiImplicitParams({ + @ApiImplicitParam(name = "pageIndex",value = "当前页码"), + @ApiImplicitParam(name = "pageSize",value = "每页行数"), + @ApiImplicitParam(name = "sort",value = "排序规则"), + @ApiImplicitParam(name = "order",value = "排序字段"), + @ApiImplicitParam(name = "warnlevel",value = "警告级别"), + @ApiImplicitParam(name = "enterprisetype",value = "企业类型"), + @ApiImplicitParam(name = "enterprisename",value = "企业名称"), + @ApiImplicitParam(name = "starttime",value = "开始时间"), + @ApiImplicitParam(name = "endtime",value = "结束时间"), + @ApiImplicitParam(name = "province",value = "省份"), + @ApiImplicitParam(name = "city",value = "城市"), + @ApiImplicitParam(name = "area",value = "区县"), + @ApiImplicitParam(name = "town",value = "乡镇"), + @ApiImplicitParam(name = "community",value = "社区"), + @ApiImplicitParam(name = "ismend",value = "是否处理"), + }) + public Msg getStockWarningList(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "20") Integer pageSize, String sort, String order, + String warnlevel, String enterprisetype, String enterprisename, String starttime, String endttime, + String province, String city, String area, String town, String community, Byte ismend){ + Msg msg = new Msg(); + msg.setCode("200"); + msg.setMessage("success"); + + PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order); + HashMap<String, Object> condition = new HashMap<String, Object>(); + + if (StringUtils.isNotBlank(warnlevel)) { + condition.put("warnlevel", warnlevel.trim()); + } + + if (StringUtils.isNotBlank(enterprisetype)) { + condition.put("enterprisetype", enterprisetype.trim()); + } + + if (StringUtils.isNotBlank(enterprisename)) { + condition.put("enterprisename", enterprisetype.trim()); + } + + if (StringUtils.isNotBlank(starttime)) { + condition.put("starttime", starttime.trim()); + } + + if (StringUtils.isNotBlank(endttime)) { + condition.put("endttime", endttime.trim()); + } + + UserInfo userInfo = userService.getById(getUser().getId()); + if (userInfo.getCompanyid() != null){ + Enterprise enterprise = enterpriseService.getById(userInfo.getCompanyid()); + condition.put("enterprisename", enterprise.getEnterprisename()); + }else if (userInfo.getType() == 3){ + condition.put("province",userInfo.getProvince()); + condition.put("city",userInfo.getCity()); + condition.put("area",userInfo.getArea()); + condition.put("town",userInfo.getTown()); + condition.put("community",userInfo.getCommunity()); + } + + if (StringUtils.isNotBlank(province) && condition.get("province") == null) { + condition.put("province", province.trim()); + if (StringUtils.isNotBlank(city)) { + condition.put("city", city.trim()); + } + + if (StringUtils.isNotBlank(area)) { + condition.put("area", area.trim()); + } + + if (StringUtils.isNotBlank(town)) { + condition.put("town", town.trim()); + } + + if (StringUtils.isNotBlank(community)){ + condition.put("community", community.trim()); + } + } + if (ismend != null){ + condition.put("ismend",ismend); + } + condition.put("warntype", "库存超量"); + pageInfo.setCondition(condition); + warnContentService.selectStockDataGrid(pageInfo); + msg.setResult(pageInfo); + return msg; + } + + @GetMapping("/purchaseWarning") + @ApiOperation(value = "获取购买超量",response = Msg.class) + @ApiImplicitParams({ + @ApiImplicitParam(name = "pageIndex",value = "当前页码"), + @ApiImplicitParam(name = "pageSize",value = "每页行数"), + @ApiImplicitParam(name = "sort",value = "排序规则"), + @ApiImplicitParam(name = "order",value = "排序字段"), + @ApiImplicitParam(name = "starttime",value = "开始时间"), + @ApiImplicitParam(name = "endtime",value = "结束时间"), + @ApiImplicitParam(name = "warnlevel",value = "警告级别"), + @ApiImplicitParam(name = "customer",value = "购买人"), + @ApiImplicitParam(name = "idcard",value = "身份证"), + @ApiImplicitParam(name = "ismend",value = "是否处理"), + }) + public Msg getPurchaseWarningList(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "20") Integer pageSize, String sort, String order, + String warnlevel, String customer, String idcard, String starttime, String endtime, Byte ismend){ + Msg msg = new Msg(); + msg.setCode("200"); + msg.setMessage("success"); + + PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order); + HashMap<String, Object> condition = new HashMap<String, Object>(); + + if (StringUtils.isNotBlank(warnlevel)) { + condition.put("warnlevel", warnlevel.trim()); + } + + if (StringUtils.isNotBlank(customer)) { + condition.put("customer", customer.trim()); + } + + if (StringUtils.isNotBlank(idcard)) { + condition.put("idcard", idcard.trim()); + } + + if (StringUtils.isNotBlank(starttime)) { + condition.put("starttime", starttime.trim()); + } + + if (StringUtils.isNotBlank(endtime)) { + condition.put("endtime", endtime.trim()); + } + + if (ismend != null){ + condition.put("ismend",ismend); + } + condition.put("warntype", "购买超量"); + pageInfo.setCondition(condition); + warnContentService.selectPurchaseDataGrid(pageInfo); + msg.setResult(pageInfo); + return msg; + } + + @GetMapping("/purchaseDetail") + @ApiOperation(value = "获取购买明细",response = Msg.class) + @ApiImplicitParams({ + @ApiImplicitParam(name = "warnid",value = "警告id"), + }) + public Msg getPurchaseDetailList(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "10") Integer pageSize, String sort, String order, + Long warnid){ + Msg msg = new Msg(); + msg.setCode("200"); + msg.setMessage("success"); + PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order); + + WarnContentInfo warningContentInfo = warnContentService.getById(warnid); + if (warningContentInfo != null && warningContentInfo.getCustomid() != null){ + //分页 datagrid content添加周期 开始结束时间 + HashMap<String, Object> condition = new HashMap<String, Object>(); + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Date endtime = warningContentInfo.getCreateddate(); + Integer period = warningContentInfo.getPeriod(); + Calendar calendar = Calendar.getInstance(); + calendar.setTime(endtime); + calendar.add(Calendar.DATE,-period); + String starttime = sdf.format(calendar.getTime()); + condition.put("starttime", starttime); + condition.put("endtime", sdf.format(warningContentInfo.getCreateddate())); + condition.put("customid", warningContentInfo.getCustomid()); + pageInfo.setCondition(condition); + saleOrderDetailService.selectByCustomId(pageInfo); + } + msg.setResult(pageInfo); + return msg; + } + + @GetMapping("/alarmList") + @ApiOperation(value = "获取报警未处理的列表",response = Msg.class) + public Msg getAlarmList(){ + Msg msg = new Msg(); + msg.setCode("200"); + msg.setMessage("success"); + List<WarnContentVo> warningContentInfos = warnContentService.selectIsNotMend(); + msg.setResult(warningContentInfos); + return msg; + } + + @GetMapping("/warningList") + @ApiOperation(value = "获取报警预警列表",response = Msg.class) + @ApiImplicitParams({ + @ApiImplicitParam(name = "pageIndex",value = "当前页码"), + @ApiImplicitParam(name = "pageSize",value = "每页行数"), + @ApiImplicitParam(name = "sort",value = "排序规则"), + @ApiImplicitParam(name = "order",value = "排序字段"), + @ApiImplicitParam(name = "warnlevel",value = "警告级别"), + @ApiImplicitParam(name = "enterprisetype",value = "企业类型"), + @ApiImplicitParam(name = "enterprisename",value = "企业名称"), + @ApiImplicitParam(name = "starttime",value = "开始时间"), + @ApiImplicitParam(name = "endtime",value = "结束时间"), + @ApiImplicitParam(name = "customer",value = "购买人"), + @ApiImplicitParam(name = "idcard",value = "身份证"), + @ApiImplicitParam(name = "ismend",value = "是否处理"), + }) + public Msg getWarningList(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "20") Integer pageSize, String sort, String order, + String warnlevel, String enterprisetype, String enterprisename, String starttime, String endttime, Byte ismend, String customer, String idcard + ){ + Msg msg = new Msg(); + msg.setCode("200"); + msg.setMessage("success"); + + PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order); + HashMap<String, Object> condition = new HashMap<String, Object>(); + + if (StringUtils.isNotBlank(warnlevel)) { + condition.put("warnlevel", warnlevel.trim()); + } + + if (StringUtils.isNotBlank(enterprisetype)) { + condition.put("enterprisetype", enterprisetype.trim()); + } + + if (StringUtils.isNotBlank(enterprisename)) { + condition.put("enterprisename", enterprisetype.trim()); + } + + if (StringUtils.isNotBlank(starttime)) { + condition.put("starttime", starttime.trim()); + } + + if (StringUtils.isNotBlank(endttime)) { + condition.put("endttime", endttime.trim()); + } + + if (ismend != null){ + condition.put("ismend",ismend); + } + + if (StringUtils.isNotBlank(customer)) { + condition.put("customer", customer.trim()); + } + + if (StringUtils.isNotBlank(idcard)) { + condition.put("idcard", idcard.trim()); + } + + pageInfo.setCondition(condition); + warnContentService.selectWarningDataGrid(pageInfo); + return msg; + } + + @PostMapping("/mendAlarm") + @ApiOperation(value = "处理报警信息",response = Msg.class) + @ApiImplicitParams({ + @ApiImplicitParam(name = "id",value = "报警id"), + }) + public Msg mendAlarm(@RequestBody JSONObject jsonObject){ + Msg msg = new Msg(); + msg.setCode("200"); + msg.setMessage("success"); + Long id = jsonObject.getLong("id"); + WarnContentInfo warningContentInfo = warnContentService.getById(id); + if (warningContentInfo != null){ + warningContentInfo.setIsmend((byte)1); + warnContentService.updateById(warningContentInfo); + } + return msg; + } + + @GetMapping("/entryWarning") + @ApiOperation(value = "获取超期未入库",response = Msg.class) + @ApiImplicitParams({ + @ApiImplicitParam(name = "pageIndex",value = "当前页码"), + @ApiImplicitParam(name = "pageSize",value = "每页行数"), + @ApiImplicitParam(name = "sort",value = "排序规则"), + @ApiImplicitParam(name = "order",value = "排序字段"), + @ApiImplicitParam(name = "warnlevel",value = "警告级别"), + @ApiImplicitParam(name = "enterprisetype",value = "企业类型"), + @ApiImplicitParam(name = "enterprisename",value = "企业名称"), + @ApiImplicitParam(name = "starttime",value = "开始时间"), + @ApiImplicitParam(name = "endtime",value = "结束时间"), + @ApiImplicitParam(name = "province",value = "省份"), + @ApiImplicitParam(name = "city",value = "城市"), + @ApiImplicitParam(name = "area",value = "区县"), + @ApiImplicitParam(name = "town",value = "乡镇"), + @ApiImplicitParam(name = "community",value = "社区"), + @ApiImplicitParam(name = "ismend",value = "是否处理"), + }) + public Msg getEntryWarningList(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "20") Integer pageSize, String sort, String order, + String warnlevel, String enterprisetype, String enterprisename, String starttime, String endttime, + String province, String city, String area, String town, String community, Byte ismend){ + Msg msg = new Msg(); + msg.setCode("200"); + msg.setMessage("success"); + PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order); + HashMap<String, Object> condition = new HashMap<String, Object>(); + + if (StringUtils.isNotBlank(warnlevel)) { + condition.put("warnlevel", warnlevel.trim()); + } + if (StringUtils.isNotBlank(enterprisetype)) { + condition.put("enterprisetype", enterprisetype.trim()); + } + if (StringUtils.isNotBlank(enterprisename)) { + condition.put("enterprisename", enterprisetype.trim()); + } + if (StringUtils.isNotBlank(starttime)) { + condition.put("starttime", starttime.trim()); + } + if (StringUtils.isNotBlank(endttime)) { + condition.put("endttime", endttime.trim()); + } + + UserInfo userInfo = userService.getById(getUser().getId()); + if (userInfo.getCompanyid() != null){ + Enterprise enterprise = enterpriseService.getById(userInfo.getCompanyid()); + condition.put("enterprisename", enterprise.getEnterprisename()); + }else if (userInfo.getType() == 3){ + condition.put("province",userInfo.getProvince()); + condition.put("city",userInfo.getCity()); + condition.put("area",userInfo.getArea()); + condition.put("town",userInfo.getTown()); + condition.put("community",userInfo.getCommunity()); + } + + if (StringUtils.isNotBlank(province) && condition.get("province") == null) { + condition.put("province", province.trim()); + if (StringUtils.isNotBlank(city)) { + condition.put("city", city.trim()); + } + if (StringUtils.isNotBlank(area)) { + condition.put("area", area.trim()); + } + if (StringUtils.isNotBlank(town)) { + condition.put("town", town.trim()); + } + if (StringUtils.isNotBlank(community)){ + condition.put("community", community.trim()); + } + } + if (ismend != null){ + condition.put("ismend",ismend); + } + condition.put("warntype", WARN_TYPE_ENTRY); + pageInfo.setCondition(condition); + warnContentService.selectStockDataGrid(pageInfo); + msg.setResult(pageInfo); + return msg; + } + + @GetMapping("/entryDetail") + @ApiOperation(value = "获取超期未入库明细",response = Msg.class) + @ApiImplicitParams({ + @ApiImplicitParam(name = "warnid",value = "警告id"), + }) + public Msg getEntryDetailList(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "10") Integer pageSize, String sort, String order, + Long warnid){ + Msg msg = new Msg(); + msg.setCode("200"); + msg.setMessage("success"); + PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order); + + WarnContentInfo warningContentInfo = warnContentService.getById(warnid); + if (warningContentInfo != null){ + //分页 datagrid content添加周期 开始结束时间 + HashMap<String, Object> condition = new HashMap<String, Object>(); + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Date endtime = warningContentInfo.getCreateddate(); + Integer period = warningContentInfo.getPeriod(); + Calendar calendar = Calendar.getInstance(); + calendar.setTime(endtime); + calendar.add(Calendar.DATE,-period); + String starttime = sdf.format(calendar.getTime()); + condition.put("enterpriseid",warningContentInfo.getEnterpriseid()); + condition.put("starttime", starttime); + pageInfo.setCondition(condition); + stockService.selectNoEntryDetail(pageInfo); + } + msg.setResult(pageInfo); + return msg; + } + + @GetMapping("/certWarning") + @ApiOperation(value = "获取运输证超期",response = Msg.class) + @ApiImplicitParams({ + @ApiImplicitParam(name = "pageIndex",value = "当前页码"), + @ApiImplicitParam(name = "pageSize",value = "每页行数"), + @ApiImplicitParam(name = "sort",value = "排序规则"), + @ApiImplicitParam(name = "order",value = "排序字段"), + @ApiImplicitParam(name = "warnlevel",value = "警告级别"), + @ApiImplicitParam(name = "enterprisetype",value = "企业类型"), + @ApiImplicitParam(name = "enterprisename",value = "企业名称"), + @ApiImplicitParam(name = "starttime",value = "开始时间"), + @ApiImplicitParam(name = "endtime",value = "结束时间"), + @ApiImplicitParam(name = "province",value = "省份"), + @ApiImplicitParam(name = "city",value = "城市"), + @ApiImplicitParam(name = "area",value = "区县"), + @ApiImplicitParam(name = "town",value = "乡镇"), + @ApiImplicitParam(name = "community",value = "社区"), + @ApiImplicitParam(name = "ismend",value = "是否处理"), + }) + public Msg getCertWarningList(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "20") Integer pageSize, String sort, String order, + String warnlevel, String enterprisetype, String enterprisename, String starttime, String endttime, + String province, String city, String area, String town, String community, Byte ismend){ + Msg msg = new Msg(); + msg.setCode("200"); + msg.setMessage("success"); + + PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order); + HashMap<String, Object> condition = new HashMap<String, Object>(); + + if (StringUtils.isNotBlank(warnlevel)) { + condition.put("warnlevel", warnlevel.trim()); + } + + if (StringUtils.isNotBlank(enterprisetype)) { + condition.put("enterprisetype", enterprisetype.trim()); + } + + if (StringUtils.isNotBlank(enterprisename)) { + condition.put("enterprisename", enterprisetype.trim()); + } + + if (StringUtils.isNotBlank(starttime)) { + condition.put("starttime", starttime.trim()); + } + + if (StringUtils.isNotBlank(endttime)) { + condition.put("endttime", endttime.trim()); + } + + UserInfo userInfo = userService.getById(getUser().getId()); + if (userInfo.getCompanyid() != null){ + Enterprise enterprise = enterpriseService.getById(userInfo.getCompanyid()); + condition.put("enterprisename", enterprise.getEnterprisename()); + }else if (userInfo.getType() == 3){ + condition.put("province",userInfo.getProvince()); + condition.put("city",userInfo.getCity()); + condition.put("area",userInfo.getArea()); + condition.put("town",userInfo.getTown()); + condition.put("community",userInfo.getCommunity()); + } + + if (StringUtils.isNotBlank(province) && condition.get("province") == null) { + condition.put("province", province.trim()); + if (StringUtils.isNotBlank(city)) { + condition.put("city", city.trim()); + } + + if (StringUtils.isNotBlank(area)) { + condition.put("area", area.trim()); + } + + if (StringUtils.isNotBlank(town)) { + condition.put("town", town.trim()); + } + + if (StringUtils.isNotBlank(community)){ + condition.put("community", community.trim()); + } + } + if (ismend != null){ + condition.put("ismend",ismend); + } + condition.put("warntype", WARN_TYPE_CERT); + pageInfo.setCondition(condition); + warnContentService.selectStockDataGrid(pageInfo); + msg.setResult(pageInfo); + return msg; + } +} -- Gitblit v1.9.2