add物料拉取

dsk-admin/src/main/resources/application.yml

@@ -204,6 +204,7 @@ tenant:
     - cb_scene_expense_month
     - cb_subject
     - cb_project_other
+    - s_materiel_project
 
 # MyBatisPlus配置
 # https://baomidou.com/config/

dsk-module/dsk-biz-api/pom.xml

@@ -56,6 +56,36 @@
             <artifactId>elasticsearch-java</artifactId>
             <version>8.7.0</version>
         </dependency>
+        <!-- https://mvnrepository.com/artifact/commons-logging/commons-logging -->
+        <dependency>
+            <groupId>commons-logging</groupId>
+            <artifactId>commons-logging</artifactId>
+            <version>1.2</version>
+        </dependency>
+        <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.61</version>
+        </dependency>
+        <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient -->
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>4.3.2</version>
+        </dependency>
+        <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpcore -->
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpcore</artifactId>
+            <version>4.3.1</version>
+        </dependency>
+        <dependency>
+            <groupId>com.zjyj</groupId>
+            <artifactId>cloudt-rest-client</artifactId>
+            <version>2.8.0-SNAPSHOT</version>
+        </dependency>
+
 
         <!--        <dependency>-->
 <!--            <groupId>com.tencentcloudapi</groupId>-->

dsk-module/dsk-biz-api/src/main/java/com/dsk/component/MaterielComponent.java

+package com.dsk.component;
+
+import cn.hutool.core.date.DatePattern;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.dsk.common.exception.ServiceException;
+import com.dsk.common.utils.DateUtils;
+import com.dsk.cscec.domain.CbProjectRecord;
+import com.dsk.cscec.domain.CbQuantitySummary;
+import com.dsk.cscec.domain.CbSubject;
+import com.dsk.cscec.domain.SMaterielProject;
+import com.dsk.cscec.mapper.CbSubjectMapper;
+import com.dsk.cscec.service.CbProjectRecordService;
+import com.dsk.cscec.service.ICbQuantitySummaryService;
+import com.dsk.cscec.service.ISMaterielProjectService;
+import com.glodon.cloudt.rest.client.RestServiceClient;
+import com.glodon.cloudt.rest.client.data.HmacRestAuthInfo;
+import com.glodon.cloudt.rest.client.data.RestResponseInfo;
+import com.glodon.cloudt.rest.client.exception.AuthenticateException;
+import com.glodon.cloudt.rest.client.exception.InvalidUriException;
+import com.glodon.cloudt.rest.client.exception.NoAuthenticateException;
+import com.glodon.cloudt.rest.client.impl.HmacRestServiceClient;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 物料相关组件
+ *
+ * @Author lcl
+ * @Data 2024/3/14 15:56
+ */
+@Component
+public class MaterielComponent {
+
+    @Resource
+    private ISMaterielProjectService materielProjectService;
+    @Resource
+    private ICbQuantitySummaryService quantitySummaryService;
+    @Resource
+    private CbProjectRecordService projectRecordService;
+    @Resource
+    private CbSubjectMapper subjectMapper;
+
+    /**
+     * 物料项目定时拉取
+     */
+    @Scheduled(cron = "0 0 1 20 * ? ")
+    public void materielProjectPull() {
+        String apiURI = "/api/inspection/v1.0/project/getTenantHasCodeProject";
+        String resStr = materielRequest(apiURI);
+        JSONObject jsonObject = JSONObject.parseObject(resStr);
+        if (!ObjectUtils.isEmpty(jsonObject.getString("data"))) {
+            List<SMaterielProject> list = JSON.parseArray(jsonObject.getString("data"), SMaterielProject.class);
+            materielProjectService.saveOrUpdateBatch(list);
+        }
+    }
+
+    /**
+     * 物料数据定时拉取
+     */
+    @Scheduled(cron = "0 0 2 20 * ? ")
+    public void materielDataPull() {
+        String beginTimestamp = DatePattern.PURE_DATETIME_MS_FORMAT.format(DateUtils.addMonths(new Date(), -1));
+        String apiURI = "/gys/inspection-api-service/integrate-v2/getSLlist?beginTimestamp=" + beginTimestamp;
+        String resStr = materielRequest(apiURI);
+        JSONObject jsonObject = JSONObject.parseObject(resStr);
+        JSONObject data = JSONObject.parseObject(jsonObject.getString("data"));
+        JSONArray bills = JSONObject.parseArray(data.getString("Bills"));
+        if(ObjectUtils.isEmpty(bills)) return;
+        List<CbQuantitySummary> list = new ArrayList<>();
+        for (int i = 0; i < bills.size(); i++) {
+            JSONObject obj = bills.getJSONObject(i);
+            JSONArray bdcls = JSONObject.parseArray(obj.getString("BDCL"));
+            for (int j = 0; j < bdcls.size(); j++) {
+                JSONObject bean = bdcls.getJSONObject(j);
+                //材料code
+                String code = bean.getString("CLLBBM").substring(bean.getString("CLLBBM").lastIndexOf(".") + 1);
+                CbSubject subject = subjectMapper.selectOne(Wrappers.<CbSubject>lambdaQuery().eq(CbSubject::getCode, code));
+                //获取项目id 通过第三方项目id->ipm编码->系统项目id
+                String projectId = bean.getString("projectId");
+                if (ObjectUtils.isEmpty(projectId)) {
+                    continue;
+                }
+                SMaterielProject materielProject = materielProjectService.getById(projectId);
+                if (ObjectUtils.isEmpty(materielProject) || ObjectUtils.isEmpty(materielProject.getSyncCode())) {
+                    continue;
+                }
+                CbProjectRecord one = projectRecordService.getOne(Wrappers.<CbProjectRecord>lambdaQuery()
+                        .eq(CbProjectRecord::getIpmProjectNo, materielProject.getSyncCode())
+                        .orderByDesc(CbProjectRecord::getCbStage));
+                if(ObjectUtils.isEmpty(one)){
+                    continue;
+                }
+
+                CbQuantitySummary cb = new CbQuantitySummary();
+                cb.setProjectId(one.getId());
+                cb.setCbStage(one.getCbStage());
+                cb.setCbSubjectName(bean.getString("CLLBMC"));
+                cb.setCbSubjectNo(subject.getCbSubjectNo());
+                cb.setCbName(bean.getString("CLMC"));
+                cb.setUnit(bean.getString("JLDW"));
+                cb.setQuantity(bean.getDouble("SJSL"));
+
+
+                list.add(cb);
+            }
+        }
+        quantitySummaryService.batchInsert(list);
+        System.out.println(list);
+    }
+
+    private String materielRequest(String apiURI) {
+        try {
+            /** ------------ 授权认证 --------------*/
+            //第3步：创建客户端实例
+            RestServiceClient serviceClient = HmacRestServiceClient.getInstance();
+            //第4步：加载/验证授权文件
+            //4.1构建认证信息
+            HmacRestAuthInfo restAuthInfo = new HmacRestAuthInfo();
+            //4.2设置授权文件路径
+//            restAuthInfo.setLicPath("src/main/resource/auth/auth.lic");
+            restAuthInfo.setLicStream(this.getClass().getResourceAsStream("/auth/auth.lic"));
+            //4.3权限认证
+            serviceClient.authenticate(restAuthInfo);
+
+            /** ------------ 拼接请求地址 --------------*/
+            //第5步：获取授权文件关联的GYS平台地址hostAddress
+            String hostAddress = serviceClient.getRestRootAddress();
+            //第6步：设置请求接口的URI地址apiURI(以获取集成项目列表信息为例)
+            //第7步：拼装完整的请求网址
+            String fullURL = hostAddress + apiURI;
+            //第8步：请求数据准备（本例中为从GYS平台获取数据，无需进行请求数据的准备）
+
+            //第9步：发送请求，用来推送/获取数据
+            RestResponseInfo restResponseInfo = serviceClient.get(fullURL);
+
+            /** ------------ 处理请求返回结果 --------------*/
+            if (restResponseInfo.isSuccess()) {
+                //请求成功：
+                //第10步：处理请求结果（第三方系统自行处理）
+                return restResponseInfo.getStringContent();
+            } else {
+                //请求失败:
+                //第11步：拼接完整的上报请求失败地址
+                String faultLogApiURI = "/gys/tl/services/trace/api-fault-log";
+                String faultLogFullURL = hostAddress + faultLogApiURI;
+                //第12步：构建上报请求失败数据
+                JSONObject faultLog = new JSONObject();
+                faultLog.put("requestUrl", fullURL);
+                faultLog.put("requestMethod", "GET");
+                faultLog.put("requestBody", "");
+                faultLog.put("statusCode", restResponseInfo.getErrorCode());
+                faultLog.put("response", restResponseInfo.getStringContent());
+                faultLog.put("description", restResponseInfo.getErrorMessage());
+                DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMddHHmmss");//时间戳格式，到秒
+                LocalDateTime dateTime = LocalDateTime.now();
+                String searchKey = formatter.format(dateTime);
+                faultLog.put("searchKey", searchKey);  //能表征本次请求记录的标识，方便进行问题排查
+                //第13步：上报请求失败数据
+                serviceClient.post(faultLogFullURL, faultLog.toJSONString());
+            }
+        } catch (AuthenticateException e) {
+            e.printStackTrace();
+        } catch (InvalidUriException e) {
+            e.printStackTrace();
+        } catch (NoAuthenticateException e) {
+            e.printStackTrace();
+        }
+        throw new ServiceException("物料接口调用失败！");
+    }
+}

dsk-module/dsk-biz-api/src/main/java/com/dsk/cscec/domain/SMaterielProject.java

+package com.dsk.cscec.domain;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+/**
+ * 物料项目类
+ *
+ * @Author lcl
+ * @Data 2024/3/15 9:15
+ */
+@Data
+@TableName("s_materiel_project")
+public class SMaterielProject {
+
+    /**
+     * 第三方项目id
+     */
+    @TableId(value = "id")
+    private Long id;
+    /**
+     * 项目名称
+     */
+    private String name;
+
+    private String ownerDeptName;
+    /**
+     * 项目对应的组织id
+     */
+    private Long ownerOrg;
+    /**
+     * 项目对应的父组织id
+     */
+    private Long parentId;
+
+    private String shortName;
+    /**
+     * 项目（建设）状态 0:未开工; 1:在建; 2:停工; 3:完工; 4:验收
+     */
+    private Integer status;
+    /**
+     * 同步编码(ipm项目编码：project_code)
+     */
+    private String syncCode;
+    /**
+     * 1:表示普通项目;3:表示搅拌站
+     */
+    private Integer type;
+}

dsk-module/dsk-biz-api/src/main/java/com/dsk/cscec/mapper/SMaterielProjectMapper.java

+package com.dsk.cscec.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.dsk.cscec.domain.SMaterielProject;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface SMaterielProjectMapper extends BaseMapper<SMaterielProject> {
+}

dsk-module/dsk-biz-api/src/main/java/com/dsk/cscec/service/ISMaterielProjectService.java

+package com.dsk.cscec.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.dsk.cscec.domain.SMaterielProject;
+
+public interface ISMaterielProjectService extends IService<SMaterielProject> {
+}

dsk-module/dsk-biz-api/src/main/java/com/dsk/cscec/service/impl/CbQuantitySummaryServiceImpl.java

@@ -59,27 +59,36 @@ public class CbQuantitySummaryServiceImpl extends ServiceImpl<CbQuantitySummaryM
         List<Map<String, Object>> resultList = new ArrayList<>();
         List<Map<String, Object>> list = baseMapper.selectSubject(bo);
         if (!ObjectUtils.isEmpty(list)) {
-            Map<String, Map<String, Map<String, List<Map<String, Object>>>>> map = list.stream()
+            Map<String, Map<String, Map<String, Map<String, List<Map<String, Object>>>>>> map = list.stream()
                     .collect(
                             Collectors.groupingBy(item -> item.get("one").toString(),
                                     Collectors.groupingBy(item -> item.get("two").toString(),
-                                            Collectors.groupingBy(item -> item.get("three").toString()))));
+                                            Collectors.groupingBy(item -> item.get("three").toString(),
+                                                    Collectors.groupingBy(item -> item.get("four").toString()
+                                            )))));
             Map<String, Object> resMap = new HashMap<>();
             List<Map<String, Object>> resList = new ArrayList<>();
             resMap.put("name", "房建类成本科目");
             resMap.put("sort", 1);
-            for (Map.Entry<String, Map<String, Map<String, List<Map<String, Object>>>>> entry : map.entrySet()) {
+            for (Map.Entry<String,Map<String, Map<String, Map<String, List<Map<String, Object>>>>>> entry : map.entrySet()) {
                 Map<String, Object> oneMap = new HashMap<>();
                 List<Map<String, Object>> oneList = new ArrayList<>();
                 oneMap.put("name", entry.getKey());
                 oneMap.put("sort", cbSubjectMapper.selectOne(Wrappers.<CbSubject>lambdaQuery().eq(CbSubject::getCbSubjectName, entry.getKey())).getSort());
-                for (Map.Entry<String, Map<String, List<Map<String, Object>>>> twoEntry : entry.getValue().entrySet()) {
+                for (Map.Entry<String,Map<String, Map<String, List<Map<String, Object>>>>> twoEntry : entry.getValue().entrySet()) {
                     Map<String, Object> twoMap = new HashMap<>();
                     List<Map<String, Object>> twoList = new ArrayList<>();
                     twoMap.put("name", twoEntry.getKey());
-                    for (Map.Entry<String, List<Map<String, Object>>> threeEntry : twoEntry.getValue().entrySet()) {
+                    for (Map.Entry<String, Map<String,List<Map<String, Object>>>> threeEntry : twoEntry.getValue().entrySet()) {
                         Map<String, Object> threeMap = new HashMap<>();
+                        List<Map<String, Object>> threeList = new ArrayList<>();
                         threeMap.put("name", threeEntry.getKey());
+                        for (Map.Entry<String, List<Map<String, Object>>> fourEntry : threeEntry.getValue().entrySet()) {
+                            Map<String, Object> fourMap = new HashMap<>();
+                            fourMap.put("name", fourEntry.getKey());
+                            threeList.add(fourMap);
+                        }
+                        threeMap.put("children", threeList);
                         twoList.add(threeMap);
                     }
                     twoMap.put("children", twoList);

dsk-module/dsk-biz-api/src/main/java/com/dsk/cscec/service/impl/SMaterielProjectServiceImpl.java

+package com.dsk.cscec.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.dsk.cscec.domain.SMaterielProject;
+import com.dsk.cscec.mapper.SMaterielProjectMapper;
+import com.dsk.cscec.service.ISMaterielProjectService;
+import org.springframework.stereotype.Service;
+
+/**
+ * @Author lcl
+ * @Data 2024/3/15 10:00
+ */
+@Service
+public class SMaterielProjectServiceImpl extends ServiceImpl<SMaterielProjectMapper, SMaterielProject> implements ISMaterielProjectService{
+}

dsk-module/dsk-biz-api/src/main/resources/auth/auth.lic

+Fsj/9hmISdE3AkSo8tpwb2an4K+BGCrN5xafwa0p3ej89iE7bllHhR1WU25d+UVI23K9ib+YYOoYqdPpodi1tm5G1AELKEEOhXAb5cAohVJ7Z7a7ABEw4hf39qLy3AjCTWsn8XBJmszNvx9gPZ+6mUGgqOEnuwNa+smkEtV24QXqPfB+wugDXLOMB6GK/GLRzDe5vbbLEWHzoKCbZloAgnMJqfjlBrgfekQRPwwASfsreQsWCeOcuh7ValPaj7/s9fuaDqg3nSTUXZwnORiteC2BH6PJa41hKVDRGgOEZMtXROcD01LizyjbstdQE0EnCJsk3P76zvzaY2w547NCmyqwhl9sCmpoB+CbAVctDR2DXnVg22Y2QdHDe0eoa66dFR/FCZaD1/LTM/xbIGZaZ3kJyP8XzQYtrzq5Go6WkpMUSOeRcjJ4JlNPU7oN67P4AAHiG6sI5n6hZTr+6InpPoCMvqPbcyNanrc+Eo7h3ToqF0XyU9uzblgcZbRtCuvmERvoZ/siTQhl/bTntG71NsA2WT3SnWsAf0MrwlkJqnwErn1ynit5nfeStDeX2+vfL16UCvDDnCG1JU2GcbYYK3dAkPXlADD6lp//s2TJuRzeeBlGfp88rSDS5EmcwSmn1F1ZoVipP7M92vmWq4bO1sowqEaHJmXmMP99WfUiW9KYGZa223CJONINBFEH1IlDrzJ1yh79uE2KxP3E9n00RX6SjZ/TbJWVTgBP5t9oXeASFIMqetdP8ZfgjwsiL0J1ag1uYMbbbmS8nJDL13O2sII6YTPDQ2qcW/9a2Iy/MwILHENplZpWZn1ifmZifsqASVlenVnjy2brnoGXLFS0hbynVRAzt44MDHonOzHsvZ4e4ZfXU55YoBNJRPe6oLgRUCxPsA2LjXWgH5YNa9pJya0XQeI69h876z+w6fg2dFGabJdB+2dE/JTOw2J8gbfjG9N9Lf8FawtLAr5GIEFLzXpr/QusnmYzuIbXN0fxn/7f6DLArS9uABaiuNVDjDrCVuMGNyrgtIgo8rIShuZjU+7uIE3xsD6srnZ7EvV1fA+SATk+XgWNmgMaiPriRDj2y1mTOIXRWtLGHFaCi2w6yA==
\ No newline at end of file

dsk-module/dsk-biz-api/src/main/resources/mapper/cscec/CbQuantitySummaryMapper.xml

@@ -3,12 +3,12 @@
 <mapper namespace="com.dsk.cscec.mapper.CbQuantitySummaryMapper">
     <insert id="batchInsert" parameterType="com.dsk.cscec.domain.CbQuantitySummary">
         INSERT INTO cscec_bms.cb_quantity_summary
-        (project_id, `number`, cb_stage, cb_subject_name, company_no, org_no, cb_name, job_content,
+        (project_id, `number`, cb_stage, cb_subject_name, cb_subject_no, company_no, org_no, cb_name, job_content,
         calculation_rule, unit, material_description, guide_price, bid_unit_price, unit_price_difference, quantity,
         combined_price, combined_price_tax, brand_name, bid_source, remark, cb_project_file_id)
         VALUES
         <foreach collection="list" item="item" separator="," >
-            (#{item.projectId}, #{item.number}, #{item.cbStage}, #{item.cbSubjectName}, #{item.companyNo}, #{item.orgNo}, #{item.cbName},
+            (#{item.projectId}, #{item.number}, #{item.cbStage}, #{item.cbSubjectName}, #{item.cbSubjectNo}, #{item.companyNo}, #{item.orgNo}, #{item.cbName},
             #{item.jobContent},#{item.calculationRule},#{item.unit},#{item.materialDescription},#{item.guidePrice},
             #{item.bidUnitPrice},#{item.unitPriceDifference},#{item.quantity},#{item.combinedPrice},#{item.combinedPriceTax},
             #{item.brandName},#{item.bidSource},#{item.remark},#{item.cbProjectFileId})
@@ -17,13 +17,46 @@
 
     <select id="selectSubject" resultType="java.util.Map">
         select
-            cs1.cb_subject_name as one, cs2.cb_subject_name as two, cs3.cb_subject_name as three
+            cs1.cb_subject_name as one, cs2.cb_subject_name as two, cs3.cb_subject_name as three , '' as four
         from cb_subject cs1
         join cb_subject cs2 on (cs2.cb_subject_no like concat(cs1.cb_subject_no,'%') and cs2.`level` = 2 )
         join cb_subject cs3 on (cs3.cb_subject_no like concat(cs2.cb_subject_no,'%') and cs3.`level` = 3 )
         join cb_quantity_summary cqs on (cqs.cb_subject_name = cs3.cb_subject_name and cqs.del_falg = 0 and cqs.project_id = #{projectId} and cqs.cb_stage = #{cbStage} )
         where cs1.`level` = 1 and cs1.cb_subject_no != 'CL'
         group by cs1.cb_subject_name,cs2.cb_subject_name,cs3.cb_subject_name
+
+            union all
+
+        select
+            cs1.cb_subject_name as one, cs2.cb_subject_name as two, '' as three, '' as four
+        from cb_subject cs1
+        join cb_subject cs2 on (cs2.cb_subject_no like concat(cs1.cb_subject_no,'%') and cs2.`level` = 2 )
+        join cb_quantity_summary cqs on (cqs.cb_subject_no = cs2.cb_subject_no and cqs.del_falg = 0 and cqs.project_id = #{projectId} and cqs.cb_stage = #{cbStage} )
+        where cs1.`level` = 1 and cs1.cb_subject_no = 'CL'
+        group by cs1.cb_subject_name,cs2.cb_subject_name
+
+			union all
+
+		select
+            cs1.cb_subject_name as one, cs2.cb_subject_name as two, cs3.cb_subject_name as three, '' as four
+        from cb_subject cs1
+        join cb_subject cs2 on (cs2.cb_subject_no like concat(cs1.cb_subject_no,'%') and cs2.`level` = 2 )
+        join cb_subject cs3 on (cs3.cb_subject_no like concat(cs2.cb_subject_no,'%') and cs3.`level` = 3 )
+        join cb_quantity_summary cqs on (cqs.cb_subject_no = cs3.cb_subject_no and cqs.del_falg = 0 and cqs.project_id = #{projectId} and cqs.cb_stage = #{cbStage} )
+        where cs1.`level` = 1 and cs1.cb_subject_no = 'CL'
+        group by cs1.cb_subject_name,cs2.cb_subject_name,cs3.cb_subject_name
+
+				union all
+
+		select
+            cs1.cb_subject_name as one, cs2.cb_subject_name as two, cs3.cb_subject_name as three, cs4.cb_subject_name as four
+        from cb_subject cs1
+        join cb_subject cs2 on (cs2.cb_subject_no like concat(cs1.cb_subject_no,'%') and cs2.`level` = 2 )
+        join cb_subject cs3 on (cs3.cb_subject_no like concat(cs2.cb_subject_no,'%') and cs3.`level` = 3 )
+        join cb_subject cs4 on (cs4.cb_subject_no like concat(cs3.cb_subject_no,'%') and cs4.`level` = 4 )
+        join cb_quantity_summary cqs on (cqs.cb_subject_no = cs4.cb_subject_no and cqs.del_falg = 0 and cqs.project_id = #{projectId} and cqs.cb_stage = #{cbStage} )
+        where cs1.`level` = 1 and cs1.cb_subject_no = 'CL'
+        group by cs1.cb_subject_name,cs2.cb_subject_name,cs3.cb_subject_name,cs4.cb_subject_name
     </select>
 
     <select id="selectOtherSubjectCount" resultType="java.lang.Integer">