提交代码

src/main/java/com/api/bokang/xiao/sh_bigdata/service/ReportService.java

@@ -52,11 +52,11 @@ public class ReportService {
             whereSql += " and dyjbr = #{param.registrationPeople} ";
         }
         if(!"".equals(flightAndTrain)){
-            whereSql += " and hbcc like '%"+flightAndTrain+"%' ";
+            whereSql += " and hbwb like '%"+flightAndTrain+"%' ";
         }
         if(!"".equals(project)){
             //whereSql += " and exits (select 1 from uf_zwfwdjjmb_dt1 where mainid = main.id and ysdx = #{param.project}) ";
-            whereSql += " and exits (select 1 from uf_zwfwdjjmb_dt1 where mainid = main.id and wb like '%"+project+"%') ";
+            whereSql += " and EXISTS (select 1 from uf_zwfwdjjmb_dt1 where mainid = main.id and wb like '%"+project+"%') ";
         }
         if(("".equals(beginDate) || "".equals(endDate)) && "".equals(registrationPeople) && "".equals(flightAndTrain)){
             param.put("today", TimeUtil.getCurrentDateString());

src/main/java/com/api/bokang/xiao/zhenn/mapper/BankMapper.java

@@ -39,7 +39,7 @@ public interface BankMapper {
      */
     @Select("SELECT t.requestid requestId,t.$t{amountField} amount,t.$t{amountField} outAmount," +
             "   $t{inCompany} inCompany,wb.lastoperatedate outDate," +
-            "   (select top 1 xmlsend from workflowToFinanceUrl where wb.requestid = t.requestId and xmlsend IS NOT NULL order by id desc) xmlsend " +
+            "   (select top 1 xmlsend from workflowToFinanceUrl where requestid = t.requestId and xmlsend IS NOT NULL order by id desc) xmlsend " +
             "FROM $t{tableName} t " +
             "INNER JOIN workflow_requestbase wb ON t.requestid = wb.requestid " +
             "WHERE wb.currentnodetype = 3 " +

src/main/java/com/api/bokang/xiao/zhenn/service/BankService.java

@@ -98,10 +98,14 @@ public class BankService {
                     for (Map<String, Object> tempOut : tempOutList) {
                         String xmlSend = Util.null2String(tempOut.get("xmlsend"));
                         String insId = CommonUtil.getNodeValue(xmlSend, "insid");
+                        if(insId.length() > 12){
+                            insId = insId.substring(insId.length() - 12);
+                        }
                         tempOut.put("insId",insId);
                     }
                     return tempOutList.stream();
                 })
+                .filter(item -> !"".equals(item.get("insid")))
                 .collect(Collectors.toList());
         //List<Map<String, Object>> oaOutOtherList = outOtherParam.stream().flatMap(item -> {
         //    item.put("beginDate", Util.null2String(param.get("beginDate")));
@@ -152,6 +156,13 @@ public class BankService {
                 .collect(Collectors.toList());
         List<Map<String, Object>> bankTempOutList = bankMapper.queryBankOutInfo(param);
         List<Map<String, Object>> bankTempInList = bankMapper.queryBankInInfo(param);
+        log.info(Util.logStr("oaOutList =>{} \n oaOutOtherList =>{} \n oaInList =>{} \n bankTempOutList =>{} \n bankTempInList =>{} \n"
+                ,JSON.toJSONString(oaOutList)
+                ,JSON.toJSONString(oaOutOtherList)
+                ,JSON.toJSONString(oaInList)
+                ,JSON.toJSONString(bankTempOutList)
+                ,JSON.toJSONString(bankTempInList)
+        ));
         //将银行流水信息进行分组，有Insid为一组（走银企直联），无Insid（代收，划转）为一组
         Map<Boolean, List<Map<String, Object>>> bankOutMap = bankTempOutList.stream().collect(Collectors.partitioningBy(item -> StringUtils.isNotBlank(Util.null2String(item.get("insid")))));
         Map<Boolean, List<Map<String, Object>>> bankInMap = bankTempInList.stream().collect(Collectors.partitioningBy(item -> StringUtils.isNotBlank(Util.null2String(item.get("insid")))));

src/main/java/weaver/bokang/xiao/dloa/schedule/HrmSyncSchedule.java

@@ -163,6 +163,9 @@ public class HrmSyncSchedule extends CusBaseCronJob {
             logEntity.setRequestJson(JSON.toJSONString(requestParam));
             if (syncType == 0) {
                 logEntity.setSyncHrm(Util.null2String(syncMap.get("id")));
+                if(dataType == 0){
+                    //TODO 判断人员部门是否是末级部门
+                }
             } else {
                 logEntity.setSyncDepart(Util.null2String(syncMap.get("id")));
             }