整合other mq

master
fangjiakai 2024-01-05 09:57:31 +08:00
parent 0afe99435e
commit c40f40d58d
16 changed files with 31 additions and 839 deletions

View File

@ -4,7 +4,7 @@ import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.PageData;
import com.zcloud.logs.LogAnno;
import com.zcloud.service.corp.CorpInfoService;
import com.zcloud.service.sms.BillingManageService;
import com.zcloud.service.invoice.BillingManageService;
import com.zcloud.service.sms.PayManagerService;
import com.zcloud.service.sms.PayService;
import com.zcloud.util.DateUtil;

View File

@ -4,9 +4,9 @@ import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.logs.LogAnno;
import com.zcloud.service.check.SysDateService;
import com.zcloud.service.speEquip.SpecialEquipmentChangeService;
import com.zcloud.service.speEquip.SpecialEquipmentService;
import com.zcloud.service.speEquip.SysDateService;
import com.zcloud.service.system.DepartmentService;
import com.zcloud.service.system.DictionariesService;
import com.zcloud.service.system.UsersService;

View File

@ -64,5 +64,8 @@ public interface MfolderStipulateMapper{
*/
List<Mfolder> listByParentId(PageData pd);
List<Mfolder> findByParentId(String parentid);
List<PageData> findByName(PageData pd);
}

View File

@ -1,60 +0,0 @@
package com.zcloud.mapper.datasource.sms;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
*
* luoxiaobao
* 2021-03-23
* www.zcloudchina.com
*/
public interface BillingManageMapper {
/**
* @param pd
* @throws Exception
*/
void save(PageData pd);
/**
* @param pd
* @throws Exception
*/
void delete(PageData pd);
/**
* @param pd
* @throws Exception
*/
void edit(PageData pd);
void editkp(PageData pd);
/**
* @param page
* @throws Exception
*/
List<PageData> datalistPage(Page page);
/**()
* @param pd
* @throws Exception
*/
List<PageData> listAll(PageData pd);
/**id
* @param pd
* @throws Exception
*/
PageData findById(PageData pd);
/**
* @param ArrayDATA_IDS
* @throws Exception
*/
void deleteAll(String[] ArrayDATA_IDS);
}

View File

@ -1,28 +0,0 @@
package com.zcloud.mapper.datasource.speEquip;
import com.zcloud.entity.PageData;
import java.util.List;
/**
*
* luoxiaobao
* 2021-05-07
* www.zcloudchina.com
*/
public interface SysDateMapper {
/**
* @param pd
* @throws Exception
*/
List<PageData> listAllByJjr(PageData pd);
/**Date
* @param pd
* @throws Exception
*/
PageData findByDate(PageData pd);
}

View File

@ -1,71 +0,0 @@
package com.zcloud.mapper.datasource.study;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.entity.system.Mfolder;
import java.util.List;
/**
* Mapper
* zCloud
*
* @version
*/
public interface MfolderStipulateMapper {
/**
* @param pd
* @throws Exception
*/
void save(PageData pd);
/**
* @param pd
* @throws Exception
*/
void delete(PageData pd);
/**
* @param pd
* @throws Exception
*/
void edit(PageData pd);
/**
* @param pd
* @throws Exception
*/
void makeAll(PageData pd);
/**
* @param page
* @throws Exception
*/
List<PageData> datalistPage(Page page);
/**()
* @param pd
* @throws Exception
*/
List<PageData> listAll(PageData pd);
/**id
* @param pd
* @throws Exception
*/
PageData findById(PageData pd);
/**
* ID
* @param parentId
* @return
* @throws Exception
*/
List<Mfolder> listByParentId(PageData pd);
List<Mfolder> findByParentId(String parentid);
List<PageData> findByName(PageData pd);
}

View File

@ -1,60 +0,0 @@
package com.zcloud.service.sms;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import java.util.List;
/**
*
* luoxiaobao
* 2021-03-23
* www.zcloudchina.com
*/
public interface BillingManageService {
/**
* @param pd
* @throws Exception
*/
public void save(PageData pd)throws Exception;
/**
* @param pd
* @throws Exception
*/
public void delete(PageData pd)throws Exception;
/**
* @param pd
* @throws Exception
*/
public void edit(PageData pd)throws Exception;
public void editkp(PageData pd)throws Exception;
/**
* @param page
* @throws Exception
*/
public List<PageData> list(Page page)throws Exception;
/**()
* @param pd
* @throws Exception
*/
public List<PageData> listAll(PageData pd)throws Exception;
/**id
* @param pd
* @throws Exception
*/
public PageData findById(PageData pd)throws Exception;
/**
* @param ArrayDATA_IDS
* @throws Exception
*/
public void deleteAll(String[] ArrayDATA_IDS)throws Exception;
}

View File

@ -1,87 +0,0 @@
package com.zcloud.service.sms.impl;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.sms.BillingManageMapper;
import com.zcloud.service.sms.BillingManageService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/**
*
* luoxiaobao
* 2021-03-23
* www.zcloudchina.com
*/
@Service
@Transactional //开启事物
public class BillingManageServiceImpl implements BillingManageService {
@Autowired
private BillingManageMapper billingmanageMapper;
/**
* @param pd
* @throws Exception
*/
public void save(PageData pd)throws Exception{
billingmanageMapper.save(pd);
}
/**
* @param pd
* @throws Exception
*/
public void delete(PageData pd)throws Exception{
billingmanageMapper.delete(pd);
}
/**
* @param pd
* @throws Exception
*/
public void edit(PageData pd)throws Exception{
billingmanageMapper.edit(pd);
}
public void editkp(PageData pd)throws Exception{
billingmanageMapper.editkp(pd);
}
/**
* @param page
* @throws Exception
*/
public List<PageData> list(Page page)throws Exception{
return billingmanageMapper.datalistPage(page);
}
/**()
* @param pd
* @throws Exception
*/
public List<PageData> listAll(PageData pd)throws Exception{
return billingmanageMapper.listAll(pd);
}
/**id
* @param pd
* @throws Exception
*/
public PageData findById(PageData pd)throws Exception{
return billingmanageMapper.findById(pd);
}
/**
* @param ArrayDATA_IDS
* @throws Exception
*/
public void deleteAll(String[] ArrayDATA_IDS)throws Exception{
billingmanageMapper.deleteAll(ArrayDATA_IDS);
}
}

View File

@ -1,28 +0,0 @@
package com.zcloud.service.speEquip;
import com.zcloud.entity.PageData;
import java.util.List;
/**
*
* luoxiaobao
* 2021-05-07
* www.zcloudchina.com
*/
public interface SysDateService {
/**
* @param pd
* @throws Exception
*/
public List<PageData> listAllByJjr(PageData pd)throws Exception;
/**Date
* @param pd
* @throws Exception
*/
public PageData findByDate(PageData pd)throws Exception;
}

View File

@ -1,41 +0,0 @@
package com.zcloud.service.speEquip.impl;
import com.zcloud.entity.PageData;
import com.zcloud.mapper.datasource.speEquip.SysDateMapper;
import com.zcloud.service.speEquip.SysDateService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/**
*
* luoxiaobao
* 2021-05-07
* www.zcloudchina.com
*/
@Service
@Transactional //开启事物
public class SysDateServiceImpl implements SysDateService {
@Autowired
private SysDateMapper sysdateMapper;
/**
* @param pd
* @throws Exception
*/
public List<PageData> listAllByJjr(PageData pd)throws Exception{
return sysdateMapper.listAllByJjr(pd);
}
/**Date
* @param pd
* @throws Exception
*/
public PageData findByDate(PageData pd)throws Exception{
return sysdateMapper.findByDate(pd);
}
}

View File

@ -3,7 +3,7 @@ package com.zcloud.service.study.impl;
import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.entity.system.Mfolder;
import com.zcloud.mapper.datasource.study.MfolderStipulateMapper;
import com.zcloud.mapper.datasource.filemanager.MfolderStipulateMapper;
import com.zcloud.service.study.MfolderStipulateService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

View File

@ -51,7 +51,7 @@ spring.activiti.check-process-definitions=false
#Mq配置
rocketmq.consumer.group2=edu-admin-edit
rocketmq.consumer.group1=edu-admin-add
rocketmq.name-server=172.24.151.18:9876
rocketmq.name-server=192.168.0.31:9876
rocketmq.producer.group=libmiddle
rocketmq.producer.send-message-timeout=3000
rocketmq.producer.compress-message-body-threshold=4096

View File

@ -187,6 +187,30 @@
order by f.NAME
</select>
<!-- 通过ID获取其子级列表 -->
<select id="findByParentId" parameterType="String" resultMap="mfolderResultMap">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.PARENT_ID = #{parentId}
and f.SHARE = 'yes'
order by f.CTIME desc
</select>
<!-- 通过ID获取其子级列表 -->
<select id="findByName" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.NAME LIKE CONCAT(CONCAT('%', #{KEYWORDS}),'%')
and f.SHARE = 'yes'
order by f.CTIME desc
</select>
<!-- 根据ID组修改数据 -->
<update id="makeAll" parameterType="pd">
update

View File

@ -1,160 +0,0 @@
<?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.zcloud.mapper.datasource.sms.BillingManageMapper">
<!--表名 -->
<sql id="tableName">
BUS_BILLINGMANAGE
</sql>
<!--数据字典表名 -->
<sql id="dicTableName">
SYS_DICTIONARIES
</sql>
<!-- 字段 -->
<sql id="Field">
f.PAYMENTTIME,
f.MONEY,
f.BILLINGSTATUS,
f.INVOICEMANAGER_ID,
f.ISDELETE,
f.BILLINGMANAGE_ID,
f.CORPINFO_ID,
f.OPDATE,
f.FPURL,
f.OPUSER
</sql>
<!-- 字段用于新增 -->
<sql id="Field2">
PAYMENTTIME,
MONEY,
BILLINGSTATUS,
INVOICEMANAGER_ID,
ISDELETE,
BILLINGMANAGE_ID,
CORPINFO_ID,
OPDATE,
FPURL,
OPUSER
</sql>
<!-- 字段值 -->
<sql id="FieldValue">
#{PAYMENTTIME},
#{MONEY},
#{BILLINGSTATUS},
#{INVOICEMANAGER_ID},
#{ISDELETE},
#{BILLINGMANAGE_ID},
#{CORPINFO_ID},
#{OPDATE},
#{FPURL},
#{OPUSER}
</sql>
<!-- 新增-->
<insert id="save" parameterType="pd">
insert into
<include refid="tableName"></include>
(
<include refid="Field2"></include>
) values (
<include refid="FieldValue"></include>
)
</insert>
<!-- 删除-->
<delete id="delete" parameterType="pd">
update
<include refid="tableName"></include>
set
ISDELETE = '1'
where
BILLINGMANAGE_ID = #{BILLINGMANAGE_ID}
</delete>
<!-- 修改 -->
<update id="edit" parameterType="pd">
update
<include refid="tableName"></include>
set
BILLINGMANAGE_ID = BILLINGMANAGE_ID
where
BILLINGMANAGE_ID = #{BILLINGMANAGE_ID}
</update>
<update id="editkp" parameterType="pd">
update
<include refid="tableName"></include>
set
BILLINGSTATUS= '1',
INVOICEMANAGER_ID = #{INVOICEMANAGER_ID}
where
BILLINGMANAGE_ID = #{BILLINGMANAGE_ID}
</update>
<!-- 通过ID获取数据 -->
<select id="findById" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.BILLINGMANAGE_ID = #{BILLINGMANAGE_ID}
</select>
<!-- 列表 -->
<select id="datalistPage" parameterType="page" resultType="pd">
select
<include refid="Field"></include>,
i.ENTERPRISENAME,
i.UCODE,
i.ADDRESS,
i.PHONE,
i.SNAME,
(select FILEPATH from bus_imgfiles where FOREIGN_KEY=f.BILLINGMANAGE_ID) as FILEPATH
from
<include refid="tableName"></include> f
left join bus_invoicemanager i on f.INVOICEMANAGER_ID=i.INVOICEMANAGER_ID
where f.ISDELETE = '0'
<if test="pd.KEYWORDS != null and pd.KEYWORDS != ''"><!-- 关键词检索 -->
and
(
<!-- 根据需求自己加检索条件
字段1 LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%')
or
字段2 LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%')
-->
)
</if>
<if test="pd.CORPINFO_ID != null and pd.CORPINFO_ID != ''"><!-- 关键词检索 -->
and f.CORPINFO_ID= #{pd.CORPINFO_ID}
</if>
ORDER by BILLINGSTATUS asc,OPDATE desc
</select>
<!-- 列表(全部) -->
<select id="listAll" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
</select>
<!-- 批量删除 -->
<delete id="deleteAll" parameterType="String">
update
<include refid="tableName"></include>
set
ISDELETE = '1'
where
BILLINGMANAGE_ID in
<foreach item="item" index="index" collection="ArrayDATA_IDS" open="(" separator="," close=")">
#{item}
</foreach>
</delete>
</mapper>

View File

@ -1,53 +0,0 @@
<?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.zcloud.mapper.datasource.speEquip.SysDateMapper">
<!--表名 -->
<sql id="tableName">
V_SYSDATE
</sql>
<!--数据字典表名 -->
<sql id="dicTableName">
SYS_DICTIONARIES
</sql>
<!-- 字段 -->
<sql id="Field">
DATE_FORMAT(f.DATE,'%Y-%m-%d %H:%i:%s') DATE,
DATE_FORMAT(f.DAY_START,'%Y-%m-%d %H:%i:%s') DAY_START,
DATE_FORMAT(f.DAY_END,'%Y-%m-%d %H:%i:%s') DAY_END,
DATE_FORMAT(f.WEEK_START,'%Y-%m-%d %H:%i:%s') WEEK_START,
DATE_FORMAT(f.WEEK_END,'%Y-%m-%d %H:%i:%s') WEEK_END,
DATE_FORMAT(f.XUN_START,'%Y-%m-%d %H:%i:%s') XUN_START,
DATE_FORMAT(f.XUN_END,'%Y-%m-%d %H:%i:%s') XUN_END,
DATE_FORMAT(f.MONTH_START,'%Y-%m-%d %H:%i:%s') MONTH_START,
DATE_FORMAT(f.MONTH_END,'%Y-%m-%d %H:%i:%s') MONTH_END,
DATE_FORMAT(f.QUARTER_START,'%Y-%m-%d %H:%i:%s') QUARTER_START,
DATE_FORMAT(f.QUARTER_END,'%Y-%m-%d %H:%i:%s') QUARTER_END,
DATE_FORMAT(f.HALFYEAR_START,'%Y-%m-%d %H:%i:%s') HALFYEAR_START,
DATE_FORMAT(f.HALFYEAR_END,'%Y-%m-%d %H:%i:%s') HALFYEAR_END,
DATE_FORMAT(f.YEAR_START,'%Y-%m-%d %H:%i:%s') YEAR_START,
DATE_FORMAT(f.YEAR_END,'%Y-%m-%d %H:%i:%s') YEAR_END
</sql>
<!-- 节假日 -->
<select id="listAllByJjr" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
${SQL}
</select>
<!-- 通过ID获取数据 -->
<select id="findByDate" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.DATE = DATE_FORMAT(#{DATE},'%Y-%m-%d')
</select>
</mapper>

View File

@ -1,247 +0,0 @@
<?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.zcloud.mapper.datasource.study.MfolderStipulateMapper">
<resultMap type="Mfolder" id="mfolderResultMap">
<id column="MFOLDER_ID" property="MFOLDER_ID"/>
<result column="NAME" property="NAME"/>
<result column="PARENT_ID" property="PARENT_ID"/>
</resultMap>
<!--表名 -->
<sql id="tableName">
OA_MFOLDER_STIPULATE
</sql>
<!--数据字典表名 -->
<sql id="dicTableName">
SYS_DICTIONARIES
</sql>
<!-- 字段 -->
<sql id="Field">
f.FILEPATH,
f.CTIME,
f.UNAME,
f.MASTER,
f.FILESIZE,
f.SHARE,
f.REMARKS,
f.MFOLDER_ID,
f.PARENT_ID,
f.NAME,
f.CORPINFO_ID,
f.TYPE,
f.POSTNO,
f.UNIT,
f.STARTTIME,
f.ENDTIME,
f.ISVALID
</sql>
<!-- 字段用于新增 -->
<sql id="Field2">
FILEPATH,
CTIME,
UNAME,
MASTER,
FILESIZE,
SHARE,
REMARKS,
MFOLDER_ID,
PARENT_ID,
NAME,
CORPINFO_ID,
TYPE,
POSTNO,
UNIT,
STARTTIME,
ENDTIME,
ISVALID
</sql>
<!-- 字段值 -->
<sql id="FieldValue">
#{FILEPATH},
#{CTIME},
#{UNAME},
#{MASTER},
#{FILESIZE},
#{SHARE},
#{REMARKS},
#{MFOLDER_ID},
#{PARENT_ID},
#{NAME},
#{CORPINFO_ID},
#{TYPE},
#{POSTNO},
#{UNIT},
#{STARTTIME},
#{ENDTIME},
#{ISVALID}
</sql>
<!-- 新增-->
<insert id="save" parameterType="pd">
insert into
<include refid="tableName"></include>
(
<include refid="Field2"></include>
) values (
<include refid="FieldValue"></include>
)
</insert>
<!-- 删除-->
<delete id="delete" parameterType="pd">
delete from
<include refid="tableName"></include>
where
MFOLDER_ID = #{MFOLDER_ID}
</delete>
<!-- 修改 -->
<update id="edit" parameterType="pd">
update
<include refid="tableName"></include>
set
SHARE = #{SHARE},
REMARKS = #{REMARKS},
NAME = #{NAME},
TYPE = #{TYPE},
POSTNO = #{POSTNO},
UNIT = #{UNIT},
STARTTIME = #{STARTTIME},
ENDTIME = #{ENDTIME},
<if test="FILEPATH!= null and FILEPATH != ''"><!-- 检索 -->
FILEPATH = #{FILEPATH},
</if>
ISVALID = #{ISVALID},
MFOLDER_ID = MFOLDER_ID
where
MFOLDER_ID = #{MFOLDER_ID}
</update>
<!-- 通过ID获取数据 -->
<select id="findById" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.MFOLDER_ID = #{MFOLDER_ID}
</select>
<!-- 列表 -->
<select id="datalistPage" parameterType="page" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where 1=1
<if test="pd.CORPINFO_ID!= null and pd.CORPINFO_ID != ''"><!-- 检索 -->
and f.CORPINFO_ID = #{pd.CORPINFO_ID}
</if>
<if test="pd.MFOLDER_ID!= null and pd.MFOLDER_ID != ''"><!-- 检索 -->
and f.PARENT_ID = #{pd.MFOLDER_ID}
</if>
<if test="pd.KEYWORDS != null and pd.KEYWORDS != ''"><!-- 关键词检索 -->
and
(
f.REMARKS LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%')
or
f.NAME LIKE CONCAT(CONCAT('%', #{pd.KEYWORDS}),'%')
)
</if>
<if test="pd.USERNAME!= null and pd.USERNAME != ''">
and f.MASTER = #{pd.USERNAME}
</if>
<if test="pd.TYPE!= null and pd.TYPE != ''">
and f.TYPE = #{pd.TYPE}
</if>
<if test="pd.isBI!= null and pd.isBI != ''">
and f.PARENT_ID != 0
</if>
<if test="pd.SHARE != null and pd.SHARE == 'yes'">
and f.SHARE = 'yes'
</if>
order by f.CTIME desc
</select>
<!-- 通过ID获取其子级列表 -->
<select id="listByParentId" parameterType="pd" resultMap="mfolderResultMap">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.PARENT_ID = #{parentId}
<if test="USERNAME != null and USERNAME != ''">
and f.MASTER = #{USERNAME}
</if>
<if test="SHARE != null and SHARE == 'yes'">
and f.SHARE = 'yes'
</if>
<if test="TYPE != NULL and TYPE != ''">
and f.TYPE = #{TYPE}
</if>
order by f.NAME
</select>
<!-- 通过ID获取其子级列表 -->
<select id="findByParentId" parameterType="String" resultMap="mfolderResultMap">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.PARENT_ID = #{parentId}
and f.SHARE = 'yes'
order by f.CTIME desc
</select>
<!-- 通过ID获取其子级列表 -->
<select id="findByName" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where
f.NAME LIKE CONCAT(CONCAT('%', #{KEYWORDS}),'%')
and f.SHARE = 'yes'
order by f.CTIME desc
</select>
<!-- 根据ID组修改数据 -->
<update id="makeAll" parameterType="pd">
update
<include refid="tableName"></include>
set
SHARE = #{SHARE}
where
MFOLDER_ID in
<foreach item="item" index="index" collection="IDS" open="(" separator="," close=")">
#{item}
</foreach>
</update>
<!-- 列表(全部) -->
<select id="listAll" parameterType="pd" resultType="pd">
select
<include refid="Field"></include>
from
<include refid="tableName"></include> f
where 1 =1
<if test="CORPINFO_ID != null and CORPINFO_ID != ''"><!-- 检索 -->
and (f.CORPINFO_ID = #{CORPINFO_ID} or f.CORPINFO_ID is null or f.CORPINFO_ID = '')
</if>
<if test="PARENT_ID != null and PARENT_ID != ''"><!-- 检索 -->
and f.PARENT_ID = #{PARENT_ID}
</if>
<if test="TYPE != null and TYPE != ''"><!-- 检索 -->
and f.TYPE = #{TYPE}
</if>
</select>
<!-- fh 31 3 59 67 90 qq(青苔) -->
</mapper>