diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportMapper.java b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportMapper.java index ff7c1efc..19b584c4 100644 --- a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportMapper.java +++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportMapper.java @@ -20,6 +20,18 @@ import java.util.Map; */ @Mapper public interface DailySalesReportMapper extends BaseMapper { - @Select("select * from daily_sales_report") - List getSalesByDate(); + @Select("select * from daily_sales_report where orderDate>#{endDate} and orderDate<=#{startDate}") + List getSalesByDate(@Param("endDate")String endDate,@Param("startDate")String startDate); + + double lwlsdTotalSales(@Param("orderDate")String orderDate); + @Select("select lsnjnTotalSales from daily_sales_report where orderDate=#{orderDate} ") + double lsnjnTotalSales(@Param("orderDate")String orderDate); + @Select("select pszxTotalSales from daily_sales_report where orderDate=#{orderDate} ") + double pszxTotalSales(@Param("orderDate")String orderDate); + @Select("select lswjmTotalSales from daily_sales_report where orderDate=#{orderDate} ") + double lswjmTotalSales(@Param("orderDate")String orderDate); + @Select("select bymdcTotalSales from daily_sales_report where orderDate=#{orderDate} ") + double bymdcTotalSales(@Param("orderDate")String orderDate); + @Select("select yclswjmTotalSales from daily_sales_report where orderDate=#{orderDate} ") + double yclswjmTotalSales(@Param("orderDate")String orderDate); } diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportMapper.xml b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportMapper.xml index e54e973d..8055367c 100644 --- a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportMapper.xml +++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportMapper.xml @@ -5,4 +5,7 @@ + \ No newline at end of file diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportRest.java b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportRest.java index d97178b1..c2a77bea 100644 --- a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportRest.java +++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportRest.java @@ -27,10 +27,10 @@ public class DailySalesReportRest { ResultBean rb = ResultBean.fireFail(); return DailySalesReportService.saveSales(orderDate); } - @PostMapping("/getSalesByDate") - public ResultBean getSalesByDate(@RequestBody DailySalesReportQuery pq){ + @GetMapping("/getSalesByDate/{orderDate}") + public ResultBean getSalesByDate(@PathVariable("orderDate") String orderDate){ ResultBean rb = ResultBean.fireFail(); - return DailySalesReportService.getSalesByDate(pq); + return DailySalesReportService.getSalesByDate(orderDate); } @PostMapping("/test") public ResultBean test( ) throws ParseException { diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportService.java b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportService.java index 19e2b81c..e8ea4144 100644 --- a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportService.java +++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/dailysalesreport/DailySalesReportService.java @@ -1,8 +1,11 @@ package com.yxt.supervise.report.biz.dailysalesreport; +import cn.hutool.Hutool; +import cn.hutool.core.date.DateField; import cn.hutool.core.date.DateUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.yxt.common.base.service.MybatisBaseService; +import com.yxt.common.base.utils.StringUtils; import com.yxt.common.core.result.ResultBean; import com.yxt.supervise.report.api.dailysalesreport.DailySalesReport; import com.yxt.supervise.report.api.dailysalesreport.DailySalesReportQuery; @@ -54,64 +57,72 @@ public class DailySalesReportService extends MybatisBaseService(); - List dailySalesReports=baseMapper.getSalesByDate(); - List> financialAnalysisChartData=convert(dailySalesReports); + String startDate=""; + String endDate=""; + SimpleDateFormat ft = new SimpleDateFormat("yyyy-MM-dd"); + if(StringUtils.isNull(orderDate)){ + startDate=ft.format(DateUtil.yesterday()); + endDate=ft.format(DateUtil.offset(DateUtil.yesterday(), DateField.DAY_OF_MONTH,-7)); + }else { + startDate=ft.format(DateUtil.parse(orderDate)); + Date ent=DateUtil.parse(orderDate); + endDate=ft.format(DateUtil.offset(ent, DateField.DAY_OF_MONTH,-7)); + } + + List dailySalesReports=baseMapper.getSalesByDate(endDate,startDate); + List financialAnalysisChartData=convert(dailySalesReports); Map map=new HashMap<>(); map.put("financialAnalysisChartData",financialAnalysisChartData); - List listSalesChannelData=salesChanne(pq.getOrderDate()); + List listSalesChannelData=salesChanne(startDate); map.put("listSalesChannelData",listSalesChannelData); -// List financialData=new ArrayList<>(); -// FinancialData financialData1=new FinancialData(); -// financialData1.setName("销售商品收到的现金(元)"); -// financialData1.setTotalPrice("637774.16"); -// FinancialData financialData2=new FinancialData(); -// financialData2.setName("销售商品收到的现金(元)"); -// financialData2.setTotalPrice("637774.16"); -// financialData.add(financialData1); -// financialData.add(financialData2); -// map.put("financialData",financialData); return rb.success().setData(map); } public List salesChanne(String orderDate){ List list=new ArrayList<>(); - double lwlsdTotalSales=baseMapper.selectOne(new QueryWrapper().eq("orderDate",orderDate)).getLwlsdTotalSales(); - ListSalesChannelData lwlsd=new ListSalesChannelData(); - lwlsd.setDeductionAccountsReceivable(String.valueOf(lwlsdTotalSales)); - lwlsd.setSalesChannelCategory("连网连锁店"); - lwlsd.setTotalAmount(String.valueOf(lwlsdTotalSales)); - lwlsd.setAccountsReceivable("0"); - double lsnjnTotalSales=baseMapper.selectOne(new QueryWrapper().eq("orderDate",orderDate)).getLsnjnTotalSales(); - ListSalesChannelData lsnjn=new ListSalesChannelData(); - lsnjn.setDeductionAccountsReceivable(String.valueOf(lsnjnTotalSales)); - lsnjn.setSalesChannelCategory("连锁内加盟"); - lsnjn.setTotalAmount(String.valueOf(lsnjnTotalSales)); - lsnjn.setAccountsReceivable("0"); - double pszxTotalSales=baseMapper.selectOne(new QueryWrapper().eq("orderDate",orderDate)).getPszxTotalSales(); - ListSalesChannelData pszx=new ListSalesChannelData(); - pszx.setDeductionAccountsReceivable(String.valueOf(pszxTotalSales)); - pszx.setSalesChannelCategory("配送中心"); - pszx.setTotalAmount(String.valueOf(pszxTotalSales)); - pszx.setAccountsReceivable("0"); - double lswjmTotalSales=baseMapper.selectOne(new QueryWrapper().eq("orderDate",orderDate)).getLswjmTotalSales(); - ListSalesChannelData lswjm=new ListSalesChannelData(); - lswjm.setDeductionAccountsReceivable(String.valueOf(lswjmTotalSales)); - lswjm.setSalesChannelCategory("连锁外加盟"); - lswjm.setTotalAmount(String.valueOf(lswjmTotalSales)); - lswjm.setAccountsReceivable("0"); - double bymdcTotalSales=baseMapper.selectOne(new QueryWrapper().eq("orderDate",orderDate)).getBymdcTotalSales(); - ListSalesChannelData bymdc=new ListSalesChannelData(); - bymdc.setDeductionAccountsReceivable(String.valueOf(bymdcTotalSales)); - bymdc.setSalesChannelCategory("36524集团报烟门店仓"); - bymdc.setTotalAmount(String.valueOf(bymdcTotalSales)); - bymdc.setAccountsReceivable("0"); - double yclswjmTotalSales=baseMapper.selectOne(new QueryWrapper().eq("orderDate",orderDate)).getYclswjmTotalSales(); - ListSalesChannelData yclswjm=new ListSalesChannelData(); - yclswjm.setDeductionAccountsReceivable(String.valueOf(yclswjmTotalSales)); - yclswjm.setSalesChannelCategory("烟草连锁外加盟"); - yclswjm.setTotalAmount(String.valueOf(yclswjmTotalSales)); - yclswjm.setAccountsReceivable("0"); + double lwlsdTotalSales=0; + double lsnjnTotalSales=0; + double pszxTotalSales=0; + double lswjmTotalSales=0; + double bymdcTotalSales=0; + double yclswjmTotalSales=0; + lwlsdTotalSales=baseMapper.lwlsdTotalSales(orderDate); + ListSalesChannelData lwlsd=new ListSalesChannelData(); + lwlsd.setDeductionAccountsReceivable(String.valueOf(lwlsdTotalSales)); + lwlsd.setSalesChannelCategory("连网连锁店"); + lwlsd.setTotalAmount(String.valueOf(lwlsdTotalSales)); + lwlsd.setAccountsReceivable("0"); + lsnjnTotalSales=baseMapper.lsnjnTotalSales(orderDate); + ListSalesChannelData lsnjn=new ListSalesChannelData(); + lsnjn.setDeductionAccountsReceivable(String.valueOf(lsnjnTotalSales)); + lsnjn.setSalesChannelCategory("连锁内加盟"); + lsnjn.setTotalAmount(String.valueOf(lsnjnTotalSales)); + lsnjn.setAccountsReceivable("0"); + pszxTotalSales=baseMapper.pszxTotalSales(orderDate); + ListSalesChannelData pszx=new ListSalesChannelData(); + pszx.setDeductionAccountsReceivable(String.valueOf(pszxTotalSales)); + pszx.setSalesChannelCategory("配送中心"); + pszx.setTotalAmount(String.valueOf(pszxTotalSales)); + pszx.setAccountsReceivable("0"); + lswjmTotalSales=baseMapper.lswjmTotalSales(orderDate); + ListSalesChannelData lswjm=new ListSalesChannelData(); + lswjm.setDeductionAccountsReceivable(String.valueOf(lswjmTotalSales)); + lswjm.setSalesChannelCategory("连锁外加盟"); + lswjm.setTotalAmount(String.valueOf(lswjmTotalSales)); + lswjm.setAccountsReceivable("0"); + bymdcTotalSales=baseMapper.bymdcTotalSales(orderDate); + ListSalesChannelData bymdc=new ListSalesChannelData(); + bymdc.setDeductionAccountsReceivable(String.valueOf(bymdcTotalSales)); + bymdc.setSalesChannelCategory("36524集团报烟门店仓"); + bymdc.setTotalAmount(String.valueOf(bymdcTotalSales)); + bymdc.setAccountsReceivable("0"); + yclswjmTotalSales=baseMapper.yclswjmTotalSales(orderDate); + ListSalesChannelData yclswjm=new ListSalesChannelData(); + yclswjm.setDeductionAccountsReceivable(String.valueOf(yclswjmTotalSales)); + yclswjm.setSalesChannelCategory("烟草连锁外加盟"); + yclswjm.setTotalAmount(String.valueOf(yclswjmTotalSales)); + yclswjm.setAccountsReceivable("0"); list.add(lwlsd); list.add(lsnjn); list.add(pszx); @@ -120,25 +131,16 @@ public class DailySalesReportService extends MybatisBaseService> convert(List list){ - List> lists=new ArrayList<>(); - List date=new ArrayList<>(); - date.add("日期"); - date.add("连网连锁店"); - date.add("连锁内加盟"); - date.add("配送中心"); - date.add("连锁外加盟"); - date.add("36524集团报烟门店仓"); - date.add("烟草连锁外加盟"); - lists.add(date); + public List convert(List list){ + List lists=new ArrayList<>(); + //List date=new ArrayList<>(); + String [] strings={"日期","连网连锁店","连锁内加盟","配送中心","连锁外加盟","36524集团报烟门店仓","烟草连锁外加盟"}; + lists.add(strings); for(DailySalesReport dailySalesReport:list){ - date.add(dailySalesReport.getOrderDate()); - date.add(String.valueOf(dailySalesReport.getLwlsdTotalSales())); - date.add(String.valueOf(dailySalesReport.getLsnjnTotalSales())); - date.add(String.valueOf(dailySalesReport.getPszxTotalSales())); - date.add(String.valueOf(dailySalesReport.getLswjmTotalSales())); - date.add(String.valueOf(dailySalesReport.getBymdcTotalSales())); - date.add(String.valueOf(dailySalesReport.getYclswjmTotalSales())); + String [] strings1={dailySalesReport.getOrderDate(),String.valueOf(dailySalesReport.getLwlsdTotalSales()),String.valueOf(dailySalesReport.getLsnjnTotalSales()), + String.valueOf(dailySalesReport.getPszxTotalSales()),String.valueOf(dailySalesReport.getLswjmTotalSales()),String.valueOf(dailySalesReport.getBymdcTotalSales()), + String.valueOf(dailySalesReport.getYclswjmTotalSales())}; + lists.add(strings1); } return lists; } diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/wechat/WechatRest.java b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/wechat/WechatRest.java index 0dcd1548..40b24ab1 100644 --- a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/wechat/WechatRest.java +++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/wechat/WechatRest.java @@ -314,16 +314,16 @@ public class WechatRest { List mobiles=new ArrayList<>(); openIds.add("oA-GE69cBwiWG5Tx5R3vvy60o8qk"); mobiles.add("15932270269"); - openIds.add("oA-GE68JFODQucAXkJQYHPoFOAgs"); - mobiles.add("18603312020"); - openIds.add("oA-GE68gus7lbb-oy4iqCF0ZhNgo"); - mobiles.add("13513219196"); - openIds.add("oA-GE67j581HgEsim_waItx2KOzE"); - mobiles.add("13513211777"); - openIds.add("oA-GE67P_1xD1uKBcexK3wWtFO5Y"); - mobiles.add("13623307393"); - openIds.add("oA-GE6zKB_5wQsVX6USlRQYV39vE"); - mobiles.add("13131170271"); +// openIds.add("oA-GE68JFODQucAXkJQYHPoFOAgs"); +// mobiles.add("18603312020"); +// openIds.add("oA-GE68gus7lbb-oy4iqCF0ZhNgo"); +// mobiles.add("13513219196"); +// openIds.add("oA-GE67j581HgEsim_waItx2KOzE"); +// mobiles.add("13513211777"); +// openIds.add("oA-GE67P_1xD1uKBcexK3wWtFO5Y"); +// mobiles.add("13623307393"); +// openIds.add("oA-GE6zKB_5wQsVX6USlRQYV39vE"); +// mobiles.add("13131170271"); // for(UserProject u:user){ // SysUser sysUser=systemMapper.getAppletOpenidByUsersid(u.getUserSid()); // if(null!=sysUser) { @@ -351,16 +351,16 @@ public class WechatRest { List mobiles=new ArrayList<>(); openIds.add("oA-GE69cBwiWG5Tx5R3vvy60o8qk"); mobiles.add("15932270269"); - openIds.add("oA-GE68JFODQucAXkJQYHPoFOAgs"); - mobiles.add("18603312020"); - openIds.add("oA-GE68gus7lbb-oy4iqCF0ZhNgo"); - mobiles.add("13513219196"); - openIds.add("oA-GE67j581HgEsim_waItx2KOzE"); - mobiles.add("13513211777"); - openIds.add("oA-GE67P_1xD1uKBcexK3wWtFO5Y"); - mobiles.add("13623307393"); - openIds.add("oA-GE6zKB_5wQsVX6USlRQYV39vE"); - mobiles.add("13131170271"); +// openIds.add("oA-GE68JFODQucAXkJQYHPoFOAgs"); +// mobiles.add("18603312020"); +// openIds.add("oA-GE68gus7lbb-oy4iqCF0ZhNgo"); +// mobiles.add("13513219196"); +// openIds.add("oA-GE67j581HgEsim_waItx2KOzE"); +// mobiles.add("13513211777"); +// openIds.add("oA-GE67P_1xD1uKBcexK3wWtFO5Y"); +// mobiles.add("13623307393"); +// openIds.add("oA-GE6zKB_5wQsVX6USlRQYV39vE"); +// mobiles.add("13131170271"); // for(UserProject u:user){ // SysUser sysUser=systemMapper.getAppletOpenidByUsersid(u.getUserSid()); // if(null!=sysUser) { @@ -387,16 +387,16 @@ public class WechatRest { List mobiles=new ArrayList<>(); openIds.add("oA-GE69cBwiWG5Tx5R3vvy60o8qk"); mobiles.add("15932270269"); - openIds.add("oA-GE68JFODQucAXkJQYHPoFOAgs"); - mobiles.add("18603312020"); - openIds.add("oA-GE68gus7lbb-oy4iqCF0ZhNgo"); - mobiles.add("13513219196"); - openIds.add("oA-GE67j581HgEsim_waItx2KOzE"); - mobiles.add("13513211777"); - openIds.add("oA-GE67P_1xD1uKBcexK3wWtFO5Y"); - mobiles.add("13623307393"); - openIds.add("oA-GE6zKB_5wQsVX6USlRQYV39vE"); - mobiles.add("13131170271"); +// openIds.add("oA-GE68JFODQucAXkJQYHPoFOAgs"); +// mobiles.add("18603312020"); +// openIds.add("oA-GE68gus7lbb-oy4iqCF0ZhNgo"); +// mobiles.add("13513219196"); +// openIds.add("oA-GE67j581HgEsim_waItx2KOzE"); +// mobiles.add("13513211777"); +// openIds.add("oA-GE67P_1xD1uKBcexK3wWtFO5Y"); +// mobiles.add("13623307393"); +// openIds.add("oA-GE6zKB_5wQsVX6USlRQYV39vE"); +// mobiles.add("13131170271"); // for(UserProject u:user){ // SysUser sysUser=systemMapper.getAppletOpenidByUsersid(u.getUserSid()); // if(null!=sysUser) { diff --git a/yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/riskalarm/RiskAlarmRest.java b/yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/riskalarm/RiskAlarmRest.java index b2baa316..4fb0c258 100644 --- a/yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/riskalarm/RiskAlarmRest.java +++ b/yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/riskalarm/RiskAlarmRest.java @@ -52,4 +52,6 @@ public class RiskAlarmRest implements RiskAlarmFeign { // public ResultBean sendVerificationCode(@PathVariable("mobile") String mobile,@PathVariable("type") String type){ // return riskAlarmService.sendVerificationCode(mobile, type); // } + + } diff --git a/yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/riskalarm/RiskAlarmService.java b/yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/riskalarm/RiskAlarmService.java index 535bcdc1..0f8061b1 100644 --- a/yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/riskalarm/RiskAlarmService.java +++ b/yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/riskalarm/RiskAlarmService.java @@ -123,7 +123,7 @@ public class RiskAlarmService extends MybatisBaseService list=new ArrayList<>(); + Device device=new Device(); + device.setName("东北角的摄像头"); + device.setSerialNumber("L28475439"); + device.setStatus("断网"); + list.add(device); + dto.setSid("19eea5cc-005d-494b-b52b-4e948bc35345"); + dto.setSendTime("2023-09-03 11:20:36"); + dto.setName("中通樊家屯仓"); + dto.setErrorCount("1"); + dto.setDevices(list); + saveRisk(dto); + } + //@Scheduled(cron = "0/30 * * * * ?") + public void build1() throws InterruptedException { + System.out.println("图片对比"); + RiskAlarmDto dto=new RiskAlarmDto(); + List list=new ArrayList<>(); + DeviceImages deviceImages=new DeviceImages(); + deviceImages.setName("东北角的摄像头"); + deviceImages.setStartImage("202309031430433.png"); + deviceImages.setEndImage("202309031431563.png"); + deviceImages.setSimilarity("80%"); + deviceImages.setStartTime("2023-09-03 14:30:44"); + deviceImages.setEndTime("2023-09-03 14:31:56"); + list.add(deviceImages); + dto.setSid("19eea5cc-005d-494b-b52b-4e948bc35345"); + dto.setSendTime("2023-09-03 11:20:36"); + dto.setName("中通樊家屯仓"); + dto.setDeviceImages(list); + contrast(dto); + } } diff --git a/yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/riskrecord/RiskRecordService.java b/yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/riskrecord/RiskRecordService.java index deb57a86..12548872 100644 --- a/yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/riskrecord/RiskRecordService.java +++ b/yxt_supervise/supervise-rms/supervise-rms-biz/src/main/java/com/supervise/rms/biz/riskrecord/RiskRecordService.java @@ -49,10 +49,11 @@ public class RiskRecordService extends MybatisBaseService