政府采购数据统计

src/main/java/com/trs/ggzyexchange/datacentercontroller/DataController.java

@@ -65,6 +65,9 @@ public class DataController {
     @Autowired
     private ZcPurchaseBulletinService zcPurchaseBulletinService;
 
+    @Autowired
+    private ZfcgGongaoService zfcgGongaoService;
+
     @Autowired
     private QtjyNoticeService qtjyNoticeService;
 
@@ -746,7 +749,7 @@ public class DataController {
             */
             CategoryDataZf categoryDataZf = new CategoryDataZf();
 
-            QueryWrapper<ZcProject> zcPurchaseBulletinQueryWrapper = new QueryWrapper<ZcProject>();
+/*            QueryWrapper<ZcProject> zcPurchaseBulletinQueryWrapper = new QueryWrapper<ZcProject>();
             zcPurchaseBulletinQueryWrapper.gt("CREATE_TIME",formatStartTime);
             zcPurchaseBulletinQueryWrapper.le("CREATE_TIME",formatDateEnd);
             int countZcPurchaseBulletin = zcProjectService.count(zcPurchaseBulletinQueryWrapper);
@@ -755,7 +758,20 @@ public class DataController {
             zcPurchaseBulletinQueryWrapperSelf.gt("CREATE_TIME",formatStartTime);
             zcPurchaseBulletinQueryWrapperSelf.le("CREATE_TIME",formatDateEnd);
             zcPurchaseBulletinQueryWrapperSelf.eq("PLATFORM_CODE",platformCode);
-            int countZcPurchaseBulletinSelf = zcProjectService.count(zcPurchaseBulletinQueryWrapperSelf);
+            int countZcPurchaseBulletinSelf = zcProjectService.count(zcPurchaseBulletinQueryWrapperSelf);*/
+
+            QueryWrapper<ZfcgGongao> zcPurchaseBulletinQueryWrapper = new QueryWrapper<ZfcgGongao>();
+            zcPurchaseBulletinQueryWrapper.gt("NOTICE_TIME",dateStart.getTime());
+            zcPurchaseBulletinQueryWrapper.le("NOTICE_TIME",dateEnd.getTime());
+            zcPurchaseBulletinQueryWrapper.in("NOTICE_TYPE","001011","001012","001013","001014","001015","001016","001019");
+            int countZcPurchaseBulletin = zfcgGongaoService.count(zcPurchaseBulletinQueryWrapper);
+
+            QueryWrapper<ZfcgGongao> zcPurchaseBulletinQueryWrapperSelf = new QueryWrapper<ZfcgGongao>();
+            zcPurchaseBulletinQueryWrapperSelf.gt("NOTICE_TIME",dateStart.getTime());
+            zcPurchaseBulletinQueryWrapperSelf.le("NOTICE_TIME",dateEnd.getTime());
+            zcPurchaseBulletinQueryWrapperSelf.in("NOTICE_TYPE","001011","001012","001013","001014","001015","001016","001019");
+            zcPurchaseBulletinQueryWrapperSelf.likeRight("REGION_CODE",regionCode);
+            int countZcPurchaseBulletinSelf = zfcgGongaoService.count(zcPurchaseBulletinQueryWrapperSelf);
 
             categoryDataZf.setTotalAssemble(countZcPurchaseBulletin);
             categoryDataZf.setTotalSelf(countZcPurchaseBulletinSelf);

src/main/java/com/trs/ggzyexchange/datacentercontroller/HomePageMSDataController.java

@@ -40,6 +40,9 @@ public class HomePageMSDataController {
     @Autowired
     private ZcProjectService zcProjectService;
 
+    @Autowired
+    private ZfcgGongaoService zfcgGongaoService;
+
     @Autowired
     private CqGqIssueBulletinService cqGqIssueBulletinService;
 
@@ -214,8 +217,11 @@ public class HomePageMSDataController {
             QueryWrapper<ZcProject> zcPurchaseBulletinQueryWrapper = new QueryWrapper<ZcProject>();
             zcPurchaseBulletinQueryWrapper.eq("PLATFORM_CODE",platformCode);
             int countZcPurchaseBulletin = zcProjectService.count(zcPurchaseBulletinQueryWrapper);
-            totalZFCG = totalZFCG + countZcPurchaseBulletin;
-            total = total + countZcPurchaseBulletin;
+            QueryWrapper<ZfcgGongao> zcPurchaseBulletinQueryWrapperSelf = new QueryWrapper<ZfcgGongao>();
+            zcPurchaseBulletinQueryWrapperSelf.likeRight("REGION_CODE",regionCode).in("NOTICE_TYPE","001011","001012","001013","001014","001015","001016","001019");
+            int countZcPurchaseBulletin2 = zfcgGongaoService.count(zcPurchaseBulletinQueryWrapperSelf);
+            totalZFCG = totalZFCG + countZcPurchaseBulletin +countZcPurchaseBulletin2;
+            total = total + countZcPurchaseBulletin +countZcPurchaseBulletin2;
         }catch (Exception e){
             e.printStackTrace();
         }
@@ -328,7 +334,11 @@ public class HomePageMSDataController {
             QueryWrapper<ZcBidpublicity> zcBidpublicityQueryWrapper = new QueryWrapper<ZcBidpublicity>();
             zcBidpublicityQueryWrapper.eq("PLATFORM_CODE",platformCode);
             int countGcProject = zcBidpublicityService.count(zcBidpublicityQueryWrapper);
-            totalTransaction = totalTransaction + countGcProject;
+            QueryWrapper<ZfcgGongao> zcPurchaseBulletinQueryWrapperSelf = new QueryWrapper<ZfcgGongao>();
+            zcPurchaseBulletinQueryWrapperSelf.likeRight("REGION_CODE",regionCode).in("NOTICE_TYPE","001021","001022","001023","001024","001025","001026","001029");
+            int countGcProject2 = zfcgGongaoService.count(zcPurchaseBulletinQueryWrapperSelf);
+
+            totalTransaction = totalTransaction + countGcProject +countGcProject2;
         }catch (Exception e){
             e.printStackTrace();
         }

src/main/java/com/trs/ggzyexchange/datacentercontroller/HomePageNmgDataController.java

@@ -37,6 +37,9 @@ public class HomePageNmgDataController {
     @Autowired
     private ZcProjectService zcProjectService;
 
+    @Autowired
+    private ZfcgGongaoService zfcgGongaoService;
+
     @Autowired
     private CqGqIssueBulletinService cqGqIssueBulletinService;
 
@@ -172,15 +175,22 @@ public class HomePageNmgDataController {
             QueryWrapper<ZcProject> zcPurchaseBulletinQueryWrapperSelf = new QueryWrapper<ZcProject>();
             zcPurchaseBulletinQueryWrapperSelf.eq("PLATFORM_CODE","121500004600236091");
             int countZcPurchaseBulletinSelf = zcProjectService.count(zcPurchaseBulletinQueryWrapperSelf);
-            totalzzq = totalzzq + countZcPurchaseBulletinSelf;
+            QueryWrapper<ZfcgGongao> zcPurchaseBulletinQueryWrapperSelf2 = new QueryWrapper<ZfcgGongao>();
+            zcPurchaseBulletinQueryWrapperSelf2.eq("REGION_CODE","150001").in("NOTICE_TYPE","001011","001012","001013","001014","001015","001016","001019");
+            int countZcPurchaseBulletinSelf2 = zfcgGongaoService.count(zcPurchaseBulletinQueryWrapperSelf2);
+            totalzzq = totalzzq + countZcPurchaseBulletinSelf+countZcPurchaseBulletinSelf2;
         }catch (Exception e){
             e.printStackTrace();
         }
         try {
             QueryWrapper<ZcProject> zcPurchaseBulletinQueryWrapper = new QueryWrapper<ZcProject>();
             int countZcPurchaseBulletin = zcProjectService.count(zcPurchaseBulletinQueryWrapper);
-            totalZFCG = totalZFCG + countZcPurchaseBulletin;
-            total = total + countZcPurchaseBulletin;
+            QueryWrapper<ZfcgGongao> zcPurchaseBulletinQueryWrapperSelf = new QueryWrapper<ZfcgGongao>();
+            zcPurchaseBulletinQueryWrapperSelf.in("NOTICE_TYPE","001011","001012","001013","001014","001015","001016","001019");
+            int countZcPurchaseBulletin2 = zfcgGongaoService.count(zcPurchaseBulletinQueryWrapperSelf);
+
+            totalZFCG = totalZFCG + countZcPurchaseBulletin +countZcPurchaseBulletin2;
+            total = total + countZcPurchaseBulletin +countZcPurchaseBulletin2;
         }catch (Exception e){
             e.printStackTrace();
         }
@@ -362,14 +372,20 @@ public class HomePageNmgDataController {
             QueryWrapper<ZcBidpublicity> zcBidpublicityQueryWrapper = new QueryWrapper<ZcBidpublicity>();
             zcBidpublicityQueryWrapper.eq("PLATFORM_CODE","121500004600236091");
             int countGcProjectSelf = zcBidpublicityService.count(zcBidpublicityQueryWrapper);
-            totalTransactionzzq = totalTransactionzzq + countGcProjectSelf;
+            QueryWrapper<ZfcgGongao> zcPurchaseBulletinQueryWrapperSelf = new QueryWrapper<ZfcgGongao>();
+            zcPurchaseBulletinQueryWrapperSelf.eq("REGION_CODE","150000").in("NOTICE_TYPE","001021","001022","001023","001024","001025","001026","001029");
+            int countZcPurchaseBulletinSelf = zfcgGongaoService.count(zcPurchaseBulletinQueryWrapperSelf);
+            totalTransactionzzq = totalTransactionzzq + countGcProjectSelf +countZcPurchaseBulletinSelf;
         }catch (Exception e){
             e.printStackTrace();
         }
         try {
             QueryWrapper<ZcBidpublicity> zcBidpublicityQueryWrapper = new QueryWrapper<ZcBidpublicity>();
             int countGcProject = zcBidpublicityService.count(zcBidpublicityQueryWrapper);
-            totalTransaction = totalTransaction + countGcProject;
+            QueryWrapper<ZfcgGongao> zcPurchaseBulletinQueryWrapperSelf = new QueryWrapper<ZfcgGongao>();
+            zcPurchaseBulletinQueryWrapperSelf.in("NOTICE_TYPE","001021","001022","001023","001024","001025","001026","001029");
+            int countZcPurchaseBulletinSelf = zfcgGongaoService.count(zcPurchaseBulletinQueryWrapperSelf);
+            totalTransaction = totalTransaction + countGcProject + countZcPurchaseBulletinSelf;
         }catch (Exception e){
             e.printStackTrace();
         }

src/main/java/com/trs/ggzyexchange/entity/ZfcgGongao.java

@@ -0,0 +1,49 @@
+package com.trs.ggzyexchange.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author trs
+ * @since 2024-02-27
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class ZfcgGongao extends BaseEntity {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId("SOURCE_DATA_KEY")
+    private String sourceDataKey;
+
+    @TableField("NOTICE_NAME")
+    private String noticeName;
+
+    @TableField("NOTICE_CONTENT")
+    private String noticeContent;
+
+    @TableField("NOTICE_TIME")
+    private Long noticeTime;
+
+    @TableField("NOTICE_GUID")
+    private String noticeGuid;
+
+    @TableField("NOTICE_TYPE")
+    private String noticeType;
+
+    @TableField("REGION_CODE")
+    private String regionCode;
+
+    @TableField("REGION_NAME")
+    private String regionName;
+
+    @TableField("DATA_TIMESTAMP")
+    private String dataTimeStamp;
+
+}

src/main/java/com/trs/ggzyexchange/mapper/ZfcgGongaoMapper.java

@@ -0,0 +1,22 @@
+package com.trs.ggzyexchange.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.trs.ggzyexchange.entity.TenderDetailsVo;
+import com.trs.ggzyexchange.entity.ZfcgGongao;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author trs
+ * @since 2024-02-27
+ */
+@Mapper
+public interface ZfcgGongaoMapper extends BaseMapper<ZfcgGongao> {
+
+}

src/main/java/com/trs/ggzyexchange/service/ZfcgGongaoService.java

@@ -0,0 +1,19 @@
+package com.trs.ggzyexchange.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.trs.ggzyexchange.entity.TenderDetailsVo;
+import com.trs.ggzyexchange.entity.ZfcgGongao;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author trs
+ * @since 2024-02-27
+ */
+public interface ZfcgGongaoService extends IService<ZfcgGongao> {
+
+}

src/main/java/com/trs/ggzyexchange/service/impl/ZfcgGongaoServiceImpl.java

@@ -0,0 +1,28 @@
+package com.trs.ggzyexchange.service.impl;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.trs.ggzyexchange.entity.TenderDetailsVo;
+import com.trs.ggzyexchange.entity.ZfcgGongao;
+import com.trs.ggzyexchange.mapper.ZfcgGongaoMapper;
+import com.trs.ggzyexchange.service.ZfcgGongaoService;
+import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author trs
+ * @since 2024-02-27
+ */
+@Service
+public class ZfcgGongaoServiceImpl extends ServiceImpl<ZfcgGongaoMapper, ZfcgGongao> implements ZfcgGongaoService {
+
+
+
+
+}

src/main/resources/mapper/ZfcgGongaoMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.trs.ggzyexchange.mapper.ZfcgGongaoMapper">
+
+</mapper>