对接招标计划

src/main/java/com/trs/project/entity/GcJihuaInfo.java

@@ -0,0 +1,66 @@
+package com.trs.project.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
+public class GcJihuaInfo {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId("projectjhguid")
+    private String projectjhguid;//项目计划唯一标识
+
+    @TableField("projectjhname")
+    private String projectjhname;//项目名称
+
+    @TableField("gonggaocontent")
+    private String gonggaocontent;//公告内容
+
+    @TableField("pubtime")
+    private Long pubtime;//发布时间
+
+    @TableField("jianshedanwei")
+    private String jianshedanwei;//招标人名称
+
+    @TableField("xiaquname")
+    private String xiaquname;//项目交易场所
+
+    @TableField("xiaqucode")
+    private String xiaqucode;//行政区域代码
+
+    @TableField("touzijine")
+    private String touzijine;//计划投资额（万元）
+
+    @TableField("zhaobiaofangshi")
+    private String zhaobiaofangshi;//招标方式
+
+    @TableField("zblianxiren")
+    private String zblianxiren;//招标联系人
+
+    @TableField("zbrmobile")
+    private String zbrmobile;//招标人联系电话
+
+    @TableField("jiandubumen")
+    private String jiandubumen;//监督部门名称
+
+    @TableField("tsmobile")
+    private String tsmobile;//投诉电话
+
+    @TableField("projectmiaoshu")
+    private String projectmiaoshu;//项目概况
+
+    @TableField("DATA_TIMESTAMP")
+    private Long  dataTimestamp;
+
+}

src/main/java/com/trs/project/entity/Gongao.java

@@ -7,7 +7,7 @@ import lombok.EqualsAndHashCode;
 
 /**
  * <p>
- * 
+ *
  * </p>
  *
  * @author trs

src/main/java/com/trs/project/exchange/SampleXxlJob.java

@@ -150,6 +150,9 @@ public class SampleXxlJob {
     @Autowired
     private ZfcgGongaoService zfcgGongaoService;
 
+    @Autowired
+    private GcJihuaInfoService gcJihuaInfoService;
+
     /**
      * 1、工程-招标公告与资格预审公告【GC_NOTICEANDFILE】
      */
@@ -506,6 +509,14 @@ public class SampleXxlJob {
         detailMethod(0);//1:post  0:get
     }
 
+    /**
+     * 41、工程招标计划【GcJihuaInfo】
+     */
+    @XxlJob("task_gciihuainfo")
+    public void gciihuainfo() throws Exception {
+        detailMethod(0);//1:post  0:get
+    }
+
 
 
     private void detailMethod(Integer type){
@@ -913,6 +924,15 @@ public class SampleXxlJob {
                 XxlJobHelper.log(param+"：数据入库="+nmResultNotice.size());
                 nmResultNoticeService.saveOrUpdateBatch(nmResultNotice);
                 break;
+            case "JSGC_ProjectJHInfo"://39、工程招标计划【GC_JIHUAN_INFO】
+                List<GcJihuaInfo> gcJihuaInfos = JSONObject.parseArray(jsonArray.toJSONString(), GcJihuaInfo.class);
+                for (GcJihuaInfo gcJihuaInfo : gcJihuaInfos) {
+                    gcJihuaInfo.setDataTimestamp(Long.parseLong(simpleDateFormat.format(new Date())));
+                }
+                logger.info(param+"：数据入库="+gcJihuaInfos.size());
+                XxlJobHelper.log(param+"：数据入库="+gcJihuaInfos.size());
+                gcJihuaInfoService.saveOrUpdateBatch(gcJihuaInfos);
+                break;
             case "ZFCG_GONGAO"://38、政府采购【ZfcgGongao】
                 List<Gongao> gongaoList = JSONObject.parseArray(jsonArray.toJSONString(), Gongao.class);
                 List<ZfcgGongao> gongaoDbList = new ArrayList<>();

src/main/java/com/trs/project/mapper/GcJihuaInfoMapper.java

@@ -0,0 +1,15 @@
+package com.trs.project.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.trs.project.entity.GcJihuaInfo;
+
+/**
+ * <p>
+ * </p>
+ *
+ * @author trs
+ * @since 2023-03-04
+ */
+public interface GcJihuaInfoMapper extends BaseMapper<GcJihuaInfo> {
+
+}

src/main/java/com/trs/project/service/GcJihuaInfoService.java

@@ -0,0 +1,16 @@
+package com.trs.project.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.trs.project.entity.GcJihuaInfo;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author trs
+ * @since 2024-02-27
+ */
+public interface GcJihuaInfoService extends IService<GcJihuaInfo> {
+
+}

src/main/java/com/trs/project/service/impl/GcJihuaInfoServiceImpl.java

@@ -0,0 +1,20 @@
+package com.trs.project.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.trs.project.entity.GcJihuaInfo;
+import com.trs.project.mapper.GcJihuaInfoMapper;
+import com.trs.project.service.GcJihuaInfoService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 挂牌披露信息 服务实现类
+ * </p>
+ *
+ * @author trs
+ * @since 2023-03-04
+ */
+@Service
+public class GcJihuaInfoServiceImpl extends ServiceImpl<GcJihuaInfoMapper, GcJihuaInfo> implements GcJihuaInfoService {
+
+}