|
|
@@ -3,7 +3,7 @@
|
|
|
<html>
|
|
|
<head>
|
|
|
<meta http-equiv="Content-Type" content="text/html; charset=utf-8">
|
|
|
- <title>Go Coverage Report</title>
|
|
|
+ <title>service: Go Coverage Report</title>
|
|
|
<style>
|
|
|
body {
|
|
|
background: black;
|
|
|
@@ -55,6 +55,14 @@
|
|
|
<div id="nav">
|
|
|
<select id="files">
|
|
|
|
|
|
+ <option value="file0">bp.jydev.jianyu360.cn/ApplicationCenter/medicalField/service/AuthService.go (77.4%)</option>
|
|
|
+
|
|
|
+ <option value="file1">bp.jydev.jianyu360.cn/ApplicationCenter/medicalField/service/InstitutionService.go (89.2%)</option>
|
|
|
+
|
|
|
+ <option value="file2">bp.jydev.jianyu360.cn/ApplicationCenter/medicalField/service/claim.go (100.0%)</option>
|
|
|
+
|
|
|
+ <option value="file3">bp.jydev.jianyu360.cn/ApplicationCenter/medicalField/service/portrait.go (21.8%)</option>
|
|
|
+
|
|
|
</select>
|
|
|
</div>
|
|
|
<div id="legend">
|
|
|
@@ -76,6 +84,882 @@
|
|
|
</div>
|
|
|
<div id="content">
|
|
|
|
|
|
+ <pre class="file" id="file0" style="display: none">package service
|
|
|
+
|
|
|
+import (
|
|
|
+ "app.yhyue.com/moapp/jybase/date"
|
|
|
+ "app.yhyue.com/moapp/jybase/go-xweb/log"
|
|
|
+ "app.yhyue.com/moapp/jybase/mysql"
|
|
|
+ "bp.jydev.jianyu360.cn/ApplicationCenter/medicalField/entity"
|
|
|
+ "bp.jydev.jianyu360.cn/ApplicationCenter/medicalField/rpc/medical/medical"
|
|
|
+ "bp.jydev.jianyu360.cn/BaseService/resourceCenter/rpc/resource"
|
|
|
+ "context"
|
|
|
+ "database/sql"
|
|
|
+ "fmt"
|
|
|
+)
|
|
|
+
|
|
|
+type AuthService struct {
|
|
|
+ GoodsCode string
|
|
|
+ GoodsSpecId int64
|
|
|
+ BasesqlConn *mysql.Mysql
|
|
|
+}
|
|
|
+
|
|
|
+//认证信息保存
|
|
|
+func (b AuthService) UserAuthInfoSave(in *medical.UserInfo) (bool, string) <span class="cov10" title="4">{
|
|
|
+ //先判断用户是否存在
|
|
|
+ user := b.BasesqlConn.FindOne(entity.DOMAIN_CAPITAL_RETENTION, map[string]interface{}{
|
|
|
+ "user_id": in.UserId, "appid": in.Appid,
|
|
|
+ }, "id", "")
|
|
|
+ if user != nil </span><span class="cov8" title="3">{
|
|
|
+ if in.OperationType == "add" </span><span class="cov1" title="1">{
|
|
|
+ return false, "用户已验证"
|
|
|
+ }</span>
|
|
|
+ } else<span class="cov1" title="1"> {
|
|
|
+ if in.OperationType == "update" </span><span class="cov0" title="0">{
|
|
|
+ return false, "用户未认证，不可修改"
|
|
|
+ }</span>
|
|
|
+ }
|
|
|
+
|
|
|
+ <span class="cov8" title="3">if in.OperationType == "update" </span><span class="cov5" title="2">{
|
|
|
+ //修改处理
|
|
|
+ data := map[string]interface{}{
|
|
|
+ "name": in.Name,
|
|
|
+ "phone": in.Phone,
|
|
|
+ "position": in.Position,
|
|
|
+ "department": in.Department,
|
|
|
+ "mail": in.Mail,
|
|
|
+ "ent_name": in.EntName,
|
|
|
+ "source": entity.MEDICALDOMAIN,
|
|
|
+ }
|
|
|
+ ok1 := b.BasesqlConn.Update(entity.DOMAIN_CAPITAL_RETENTION, map[string]interface{}{"user_id": in.UserId, "appid": in.Appid, "source": entity.MEDICALDOMAIN}, data)
|
|
|
+ if ok1 </span><span class="cov5" title="2">{
|
|
|
+ return true, ""
|
|
|
+ }</span> else<span class="cov0" title="0"> {
|
|
|
+ log.Println(fmt.Sprintf("认证修改失败：入参：%v:%v,", in.UserId, data))
|
|
|
+ return false, "修改失败"
|
|
|
+ }</span>
|
|
|
+ } else<span class="cov1" title="1"> {
|
|
|
+ //新增处理
|
|
|
+ data := map[string]interface{}{
|
|
|
+ "name": in.Name,
|
|
|
+ "phone": in.Phone,
|
|
|
+ "position": in.Position,
|
|
|
+ "department": in.Department,
|
|
|
+ "mail": in.Mail,
|
|
|
+ "ent_name": in.EntName,
|
|
|
+ "user_id": in.UserId,
|
|
|
+ "create_time": date.NowFormat(date.Date_Full_Layout),
|
|
|
+ "appid": in.Appid,
|
|
|
+ "source": entity.MEDICALDOMAIN,
|
|
|
+ }
|
|
|
+ msg := ""
|
|
|
+ ok := b.BasesqlConn.ExecTx("认证信息保存", func(tx *sql.Tx) bool </span><span class="cov1" title="1">{
|
|
|
+ ok1 := b.BasesqlConn.InsertByTx(tx, entity.DOMAIN_CAPITAL_RETENTION, data)
|
|
|
+ if ok1 <= 0 </span><span class="cov0" title="0">{
|
|
|
+ log.Println(fmt.Sprintf("认证失败:参数:%v", data))
|
|
|
+ msg = "认证信息保存失败"
|
|
|
+ return false
|
|
|
+ }</span>
|
|
|
+ //开通权益
|
|
|
+ <span class="cov1" title="1">req := &resource.PowerReq{
|
|
|
+ Appid: in.Appid,
|
|
|
+ GoodsCode: b.GoodsCode,
|
|
|
+ GoodsSpecId: b.GoodsSpecId,
|
|
|
+ EntId: 0,
|
|
|
+ UserId: in.UserId,
|
|
|
+ BuyNum: 1,
|
|
|
+ Type: int64(1),
|
|
|
+ }
|
|
|
+ resq, err := entity.ResourceLib.PowerHandle(context.Background(), req)
|
|
|
+ if err != nil || resq.Status != 1 </span><span class="cov1" title="1">{
|
|
|
+ log.Println("权益开通调用失败:", req, resq)
|
|
|
+ msg = "权益开通调用失败"
|
|
|
+ return false
|
|
|
+ }</span>
|
|
|
+ <span class="cov0" title="0">return ok1 > 0</span>
|
|
|
+ })
|
|
|
+ <span class="cov1" title="1">return ok, msg</span>
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+//认证信息查询
|
|
|
+func (b AuthService) UserAuthInfo(in *medical.CommonReq) *map[string]interface{} <span class="cov5" title="2">{
|
|
|
+ //先判断用户是否存在
|
|
|
+ user := b.BasesqlConn.FindOne(entity.DOMAIN_CAPITAL_RETENTION, map[string]interface{}{
|
|
|
+ "user_id": in.UserId, "appid": in.Appid, "source": entity.MEDICALDOMAIN,
|
|
|
+ }, "*", "")
|
|
|
+ return user
|
|
|
+}</span>
|
|
|
+</pre>
|
|
|
+
|
|
|
+ <pre class="file" id="file1" style="display: none">package service
|
|
|
+
|
|
|
+import (
|
|
|
+ quitl "app.yhyue.com/moapp/jybase/common"
|
|
|
+ elastic "app.yhyue.com/moapp/jybase/esv1"
|
|
|
+ "app.yhyue.com/moapp/jybase/mysql"
|
|
|
+ "bp.jydev.jianyu360.cn/ApplicationCenter/medicalField/entity"
|
|
|
+ "bp.jydev.jianyu360.cn/ApplicationCenter/medicalField/rpc/medical/medical"
|
|
|
+ "fmt"
|
|
|
+ "log"
|
|
|
+ "strings"
|
|
|
+)
|
|
|
+
|
|
|
+type InstitutionService struct {
|
|
|
+ Bidfield string
|
|
|
+ BasesqlCon *mysql.Mysql
|
|
|
+ MysqlConn *mysql.Mysql
|
|
|
+}
|
|
|
+
|
|
|
+// GetFilterItem 医疗机构搜索条件
|
|
|
+func (b InstitutionService) GetFilterItem() (levelList, typeList *[]map[string]interface{}) <span class="cov1" title="1">{
|
|
|
+ //机构类型
|
|
|
+ levelSql := fmt.Sprintf("select * from %s where name!='%s'", entity.CODE_MEDICAL_INSTITUTION_LEVEL, "其它")
|
|
|
+ levelList = b.MysqlConn.SelectBySql(levelSql)
|
|
|
+ //医院等级
|
|
|
+ typeSql := fmt.Sprintf("select * from %s where name!='%s' and level=1", entity.CODE_MEDICAL_INSTITUTION_TYPE, "其它")
|
|
|
+ typeList = b.MysqlConn.SelectBySql(typeSql)
|
|
|
+ return
|
|
|
+}</span>
|
|
|
+
|
|
|
+// Institution 医疗机构搜索条件
|
|
|
+func (b InstitutionService) Institution(in *medical.SearchInstitutionReq) (dataList []map[string]interface{}) <span class="cov1" title="1">{
|
|
|
+ //先查询医疗机构
|
|
|
+ //医疗机构查询拼接
|
|
|
+ query := `{"query":{"bool":{"must":[%s],"must_not": [{"term": {"p_miname": ""}}],"should":[%s],"minimum_should_match": %d}},"sort":{"id":{"order":"desc"}}, "from": %d,"size": %d}`
|
|
|
+ shouldQuery := `{"bool":{"should":[%s],"minimum_should_match": %d}}`
|
|
|
+ multi_match := `{"multi_match": {"query": %s,"type": "phrase", "fields": [%s]}}`
|
|
|
+ musts := []string{}
|
|
|
+ var query_bool_must_and = `{"bool": {"must": [%s]%s}}`
|
|
|
+ shoulds := []string{}
|
|
|
+ bools := []string{}
|
|
|
+ //省份处理
|
|
|
+ cityArr := []string{}
|
|
|
+ areaArr := []string{}
|
|
|
+ if in.AreaCode != "" </span><span class="cov1" title="1">{
|
|
|
+ areaCode := quitl.ObjToMap(in.AreaCode)
|
|
|
+ for k, v := range *areaCode </span><span class="cov3" title="2">{
|
|
|
+ if len(quitl.ObjArrToStringArr(v.([]interface{}))) == 0 </span><span class="cov1" title="1">{
|
|
|
+ areaArr = append(areaArr, k)
|
|
|
+ }</span> else<span class="cov1" title="1"> {
|
|
|
+ cityArr = append(cityArr, quitl.ObjArrToStringArr(v.([]interface{}))...)
|
|
|
+ }</span>
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //省份处理
|
|
|
+ <span class="cov1" title="1">if len(areaArr) > 0 </span><span class="cov1" title="1">{
|
|
|
+ areaQuery := entity.SplicingArr("area", areaArr)
|
|
|
+ shoulds = append(shoulds, areaQuery)
|
|
|
+ }</span>
|
|
|
+ //城市处理
|
|
|
+ <span class="cov1" title="1">if len(cityArr) > 0 </span><span class="cov1" title="1">{
|
|
|
+ cityQuery := entity.SplicingArr("city", cityArr)
|
|
|
+ shoulds = append(shoulds, cityQuery)
|
|
|
+ }</span>
|
|
|
+ //医疗等级处理
|
|
|
+ <span class="cov1" title="1">if in.LevelCode != "" </span><span class="cov1" title="1">{
|
|
|
+ levelQuery := entity.SplicingString("level_code", in.LevelCode)
|
|
|
+ musts = append(musts, levelQuery)
|
|
|
+ }</span>
|
|
|
+ //机构类型处理
|
|
|
+ <span class="cov1" title="1">if in.MiTypeCode != "" </span><span class="cov1" title="1">{
|
|
|
+ miTyprQuery := entity.SplicingString("mi_type_code", in.MiTypeCode)
|
|
|
+ musts = append(musts, miTyprQuery)
|
|
|
+ }</span>
|
|
|
+ //经营性质处理
|
|
|
+ <span class="cov1" title="1">if in.BusinessTypeCode != "" </span><span class="cov1" title="1">{
|
|
|
+ businessTypeQuery := entity.SplicingString("business_type", in.BusinessTypeCode)
|
|
|
+ musts = append(musts, businessTypeQuery)
|
|
|
+ }</span>
|
|
|
+ //机构名称处理
|
|
|
+ <span class="cov1" title="1">if in.CompanyName != "" </span><span class="cov1" title="1">{
|
|
|
+ /*companyNameQuery := entity.SplicingString("p_miname", in.CompanyName)
|
|
|
+ musts = append(musts, companyNameQuery)*/
|
|
|
+ musts = append(musts, fmt.Sprintf(multi_match, "\""+in.CompanyName+"\"", "\"p_miname\""))
|
|
|
+ }</span>
|
|
|
+ //业务范围处理
|
|
|
+ <span class="cov1" title="1">boolsNum, bools := BusinessScopehandle(in.SdequipmentCode, multi_match, `"sdequipment"`, query_bool_must_and, bools)
|
|
|
+ shouldNumber := 0
|
|
|
+ if len(shoulds) > 0 </span><span class="cov1" title="1">{
|
|
|
+ shouldNumber = 1
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">shouldStr := fmt.Sprintf(shouldQuery, strings.Join(shoulds, ","), shouldNumber)
|
|
|
+ musts = append(musts, shouldStr)
|
|
|
+ queryStr := fmt.Sprintf(query, strings.Join(musts, ","), strings.Join(bools, ","), boolsNum, 0, in.ResourceUseCount)
|
|
|
+ //医疗机构查找
|
|
|
+ companyList := elastic.Get(entity.INSTITUTION_INDEX, entity.INSTITUTION_TYPE, queryStr)
|
|
|
+ log.Println(queryStr)
|
|
|
+ //再根据医疗机构名称查找项目金额总数
|
|
|
+ companyName := ""
|
|
|
+ companyMap := make(map[string]map[string]interface{})
|
|
|
+ if len(*companyList) > 0 && companyList != nil </span><span class="cov1" title="1">{
|
|
|
+ //认领数据查询
|
|
|
+ companyIdMap := b.ClaimCompanyData(in.Appid, in.NewUserId, entity.TypeInstitution)
|
|
|
+ for key, value := range *companyList </span><span class="cov10" title="14">{
|
|
|
+ if key > 0 </span><span class="cov9" title="13">{
|
|
|
+ companyName += `,`
|
|
|
+ }</span>
|
|
|
+ <span class="cov10" title="14">companyName += `"` + fmt.Sprint(value["mi_name"]) + `"`
|
|
|
+ value["project_money"] = float64(0.00)
|
|
|
+ value["project_count"] = 0
|
|
|
+ if companyIdMap[fmt.Sprint(value["company_id"])] == nil </span><span class="cov10" title="14">{
|
|
|
+ value["isClaim"] = false
|
|
|
+ }</span> else<span class="cov0" title="0"> {
|
|
|
+ value["isClaim"] = true
|
|
|
+ }</span>
|
|
|
+ <span class="cov10" title="14">companyMap[fmt.Sprint(value["mi_name"])] = value</span>
|
|
|
+ }
|
|
|
+
|
|
|
+ } else<span class="cov0" title="0"> {
|
|
|
+ return
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">orderField := "_count"
|
|
|
+ orderType := "desc"
|
|
|
+ //排序处理
|
|
|
+ if in.Sort == 1 </span><span class="cov0" title="0">{
|
|
|
+ orderField = "count"
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">aggStr := fmt.Sprintf(`{"query":{"bool":{"must":[{"terms":{"buyer":[%s]}},{"terms":{"bidstatus":["中标","成交","合同"]}},{"term":{"bid_field":"%s"}}],"minimum_should_match":0}},"aggs":{"group_field":{"terms":{"field":"buyer","order":[{"%s":"%s"}]},"aggs":{"count":{"sum":{"field":"bidamount"}}}}},"size":0}`, companyName, b.Bidfield, orderField, orderType)
|
|
|
+ log.Println(aggStr)
|
|
|
+ countList := entity.GetAggs(entity.PROJECTSET_INDEX, entity.PROJECTSET_TYPE, aggStr)
|
|
|
+ //
|
|
|
+ if len(countList) > 0 && countList != nil </span><span class="cov1" title="1">{
|
|
|
+ for _, value := range countList </span><span class="cov3" title="2">{
|
|
|
+ if companyMap[value.CompanyName] != nil </span><span class="cov3" title="2">{
|
|
|
+ companyMap[value.CompanyName]["project_money"] = value.ProjectMoney
|
|
|
+ companyMap[value.CompanyName]["project_count"] = value.ProjectCount
|
|
|
+ dataList = append(dataList, companyMap[value.CompanyName])
|
|
|
+ delete(companyMap, value.CompanyName)
|
|
|
+ }</span>
|
|
|
+ }
|
|
|
+ <span class="cov1" title="1">for _, value := range companyMap </span><span class="cov9" title="12">{
|
|
|
+ dataList = append(dataList, value)
|
|
|
+ }</span>
|
|
|
+ } else<span class="cov0" title="0"> {
|
|
|
+ dataList = *companyList
|
|
|
+
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">return</span>
|
|
|
+}
|
|
|
+
|
|
|
+// Distributor 经销商搜索
|
|
|
+func (b InstitutionService) Distributor(in *medical.SearchDistributorReq) (dataList []map[string]interface{}) <span class="cov1" title="1">{
|
|
|
+ //先查询医疗机构
|
|
|
+ //医疗机构查询拼接
|
|
|
+ query := `{"query":{"bool":{"must":[%s],"must_not": [{"term": {"p_supplier": ""}}],"should":[%s],"minimum_should_match": %d}}, "sort":{"id":{"order":"desc"}},"from": %d,"size": %d}`
|
|
|
+ shouldQuery := `{"bool":{"should":[%s],"minimum_should_match": %d}}`
|
|
|
+ multi_match := `{"multi_match": {"query": %s,"type": "phrase", "fields": [%s]}}`
|
|
|
+ var query_bool_must_and = `{"bool": {"must": [%s]%s}}`
|
|
|
+ musts := []string{}
|
|
|
+ shoulds := []string{}
|
|
|
+ bools := []string{}
|
|
|
+ //省份处理
|
|
|
+ cityArr := []string{}
|
|
|
+ areaArr := []string{}
|
|
|
+ if in.AreaCode != "" </span><span class="cov1" title="1">{
|
|
|
+ areaCode := quitl.ObjToMap(in.AreaCode)
|
|
|
+ for k, v := range *areaCode </span><span class="cov3" title="2">{
|
|
|
+ if len(quitl.ObjArrToStringArr(v.([]interface{}))) == 0 </span><span class="cov1" title="1">{
|
|
|
+ areaArr = append(areaArr, k)
|
|
|
+ }</span> else<span class="cov1" title="1"> {
|
|
|
+ cityArr = append(cityArr, quitl.ObjArrToStringArr(v.([]interface{}))...)
|
|
|
+ }</span>
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //省份处理
|
|
|
+ <span class="cov1" title="1">if len(areaArr) > 0 </span><span class="cov1" title="1">{
|
|
|
+ areaQuery := entity.SplicingArr("area", areaArr)
|
|
|
+ shoulds = append(shoulds, areaQuery)
|
|
|
+ }</span>
|
|
|
+ //城市处理
|
|
|
+ <span class="cov1" title="1">if len(cityArr) > 0 </span><span class="cov1" title="1">{
|
|
|
+ cityQuery := entity.SplicingArr("city", cityArr)
|
|
|
+ shoulds = append(shoulds, cityQuery)
|
|
|
+ }</span>
|
|
|
+ //业务范围处理
|
|
|
+ <span class="cov1" title="1">boolsNum, bools := BusinessScopehandle(in.BusinessScope, multi_match, `"productlist.name"`, query_bool_must_and, bools)
|
|
|
+ //品牌处理
|
|
|
+ if in.Brand != "" </span><span class="cov0" title="0">{
|
|
|
+ brandQuery := entity.SplicingString("productlist.brand", in.Brand)
|
|
|
+ musts = append(musts, brandQuery)
|
|
|
+ }</span>
|
|
|
+ //产品型号处理
|
|
|
+ <span class="cov1" title="1">if in.ProductModel != "" </span><span class="cov0" title="0">{
|
|
|
+ productModelQuery := entity.SplicingString("productlist.model", in.ProductModel)
|
|
|
+ musts = append(musts, productModelQuery)
|
|
|
+ }</span>
|
|
|
+ //机构名称处理
|
|
|
+ <span class="cov1" title="1">if in.CompanyName != "" </span><span class="cov1" title="1">{
|
|
|
+ musts = append(musts, fmt.Sprintf(multi_match, "\""+in.CompanyName+"\"", "\"p_supplier\""))
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">shouldNumber := 0
|
|
|
+ if len(shoulds) > 0 </span><span class="cov1" title="1">{
|
|
|
+ shouldNumber = 1
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">shouldStr := fmt.Sprintf(shouldQuery, strings.Join(shoulds, ","), shouldNumber)
|
|
|
+ musts = append(musts, shouldStr)
|
|
|
+ queryStr := fmt.Sprintf(query, strings.Join(musts, ","), strings.Join(bools, ","), boolsNum, 0, in.ResourceUseCount)
|
|
|
+ //医疗机构查找
|
|
|
+ companyList := elastic.Get(entity.SUPPLIER_PRODUCT_INDEX, entity.SUPPLIER_PRODUCT_TYPE, queryStr)
|
|
|
+ log.Println(queryStr)
|
|
|
+ //再根据医疗机构名称查找项目金额总数
|
|
|
+ companyIds := ""
|
|
|
+ companyMap := make(map[string]map[string]interface{})
|
|
|
+ if len(*companyList) > 0 && companyList != nil </span><span class="cov1" title="1">{
|
|
|
+ //认领数据查询
|
|
|
+ companyIdMap := b.ClaimCompanyData(in.Appid, in.NewUserId, entity.TypeDistributor)
|
|
|
+ for key, value := range *companyList </span><span class="cov7" title="7">{
|
|
|
+ if key > 0 </span><span class="cov7" title="6">{
|
|
|
+ companyIds += `,`
|
|
|
+ }</span>
|
|
|
+ <span class="cov7" title="7">companyIds += `"` + fmt.Sprint(value["company_id"]) + `"`
|
|
|
+ value["project_money"] = float64(0.00)
|
|
|
+ value["project_count"] = 0
|
|
|
+ if companyIdMap[fmt.Sprint(value["company_id"])] == nil </span><span class="cov7" title="7">{
|
|
|
+ value["isClaim"] = false
|
|
|
+ }</span> else<span class="cov0" title="0"> {
|
|
|
+ value["isClaim"] = true
|
|
|
+ }</span>
|
|
|
+ <span class="cov7" title="7">companyMap[fmt.Sprint(value["company_id"])] = value</span>
|
|
|
+ }
|
|
|
+ } else<span class="cov0" title="0"> {
|
|
|
+ return
|
|
|
+ }</span>
|
|
|
+ //排序处理
|
|
|
+ <span class="cov1" title="1">orderField := "_count"
|
|
|
+ orderType := "desc"
|
|
|
+ if in.Sort == 1 </span><span class="cov0" title="0">{
|
|
|
+ orderField = "count"
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">aggStr := fmt.Sprintf(`{"query":{"bool":{"must":[{"terms":{"entidlist":[%s]}},{"terms":{"bidstatus":["中标","成交","合同"]}},{"term":{"bid_field":"%s"}}],"minimum_should_match":0}},"aggs":{"group_field":{"terms":{"field":"entidlist","order":[{"%s":"%s"}]},"aggs":{"count":{"sum":{"field":"bidamount"}}}}},"size":0}`, companyIds, b.Bidfield, orderField, orderType)
|
|
|
+ log.Println(aggStr)
|
|
|
+ countList := entity.GetAggs(entity.PROJECTSET_INDEX, entity.PROJECTSET_TYPE, aggStr)
|
|
|
+ if len(countList) > 0 && countList != nil </span><span class="cov0" title="0">{
|
|
|
+ for _, value := range countList </span><span class="cov0" title="0">{
|
|
|
+ if companyMap[value.CompanyName] != nil </span><span class="cov0" title="0">{
|
|
|
+ companyMap[value.CompanyName]["project_money"] = value.ProjectMoney
|
|
|
+ companyMap[value.CompanyName]["project_count"] = value.ProjectCount
|
|
|
+ dataList = append(dataList, companyMap[value.CompanyName])
|
|
|
+ delete(companyMap, value.CompanyName)
|
|
|
+ }</span>
|
|
|
+ }
|
|
|
+ <span class="cov0" title="0">for _, value := range companyMap </span><span class="cov0" title="0">{
|
|
|
+ dataList = append(dataList, value)
|
|
|
+ }</span>
|
|
|
+ } else<span class="cov1" title="1"> {
|
|
|
+ dataList = *companyList
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">return</span>
|
|
|
+}
|
|
|
+
|
|
|
+// ClaimCompanyData 已认领企业查询处理
|
|
|
+// @Description:
|
|
|
+// @param appId 用户标识
|
|
|
+// @param newUserId 用户标识
|
|
|
+// @param claimType 数据类型
|
|
|
+// @return map[string]map[string]interface{} 认领的企业信息
|
|
|
+//
|
|
|
+func (b InstitutionService) ClaimCompanyData(appId string, newUserId, claimType int64) map[string]map[string]interface{} <span class="cov5" title="4">{
|
|
|
+ claimList := b.BasesqlCon.Find(entity.TableDomainEntClaim, map[string]interface{}{
|
|
|
+ "user_id": newUserId,
|
|
|
+ "status": 1,
|
|
|
+ "type": claimType,
|
|
|
+ "appid": appId,
|
|
|
+ }, "ent_id", "", -1, -1)
|
|
|
+ companyIdMap := make(map[string]map[string]interface{})
|
|
|
+ if claimList == nil || len(*claimList) == 0 </span><span class="cov4" title="3">{
|
|
|
+ return companyIdMap
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">for _, m := range *claimList </span><span class="cov1" title="1">{
|
|
|
+ companyIdMap[quitl.InterfaceToStr(m["ent_id"])] = m
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">return companyIdMap</span>
|
|
|
+}
|
|
|
+
|
|
|
+// BusinessScopehandle 业务范围处理
|
|
|
+func BusinessScopehandle(BusinessScope []*medical.Business_Scope, multi_match, findfields, query_bool_must_and string, bools []string) (int, []string) <span class="cov3" title="2">{
|
|
|
+ boolsNum := 0
|
|
|
+ if len(BusinessScope) > 0 </span><span class="cov3" title="2">{
|
|
|
+ boolsNum = 1
|
|
|
+
|
|
|
+ multi_match = fmt.Sprintf(multi_match, "%s", findfields)
|
|
|
+ for _, v := range BusinessScope </span><span class="cov4" title="3">{
|
|
|
+ businessShoulds := []string{}
|
|
|
+ businessMust_not := []string{}
|
|
|
+ //关键词
|
|
|
+ for _, keyV := range v.Key </span><span class="cov4" title="3">{
|
|
|
+ businessShoulds = append(businessShoulds, fmt.Sprintf(multi_match, "\""+keyV+"\""))
|
|
|
+ }</span>
|
|
|
+ //附加词
|
|
|
+ <span class="cov4" title="3">for _, AppendV := range v.Appendkey </span><span class="cov1" title="1">{
|
|
|
+ businessShoulds = append(businessShoulds, fmt.Sprintf(multi_match, "\""+AppendV+"\""))
|
|
|
+ }</span>
|
|
|
+ //排除词
|
|
|
+ <span class="cov4" title="3">for _, notV := range v.Notkey </span><span class="cov7" title="6">{
|
|
|
+ businessMust_not = append(businessMust_not, fmt.Sprintf(multi_match, "\""+notV+"\""))
|
|
|
+ }</span>
|
|
|
+ //添加
|
|
|
+ <span class="cov4" title="3">if len(businessShoulds) > 0 </span><span class="cov4" title="3">{
|
|
|
+ notStr := ""
|
|
|
+ if len(businessShoulds) > 0 </span><span class="cov4" title="3">{
|
|
|
+ notStr = fmt.Sprintf(`,"must_not":[%s]`, strings.Join(businessMust_not, ","))
|
|
|
+ }</span>
|
|
|
+ <span class="cov4" title="3">bools = append(bools, fmt.Sprintf(query_bool_must_and, strings.Join(businessShoulds, ","), notStr))</span>
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ <span class="cov3" title="2">return boolsNum, bools</span>
|
|
|
+}
|
|
|
+</pre>
|
|
|
+
|
|
|
+ <pre class="file" id="file2" style="display: none">package service
|
|
|
+
|
|
|
+import (
|
|
|
+ "app.yhyue.com/moapp/jybase/common"
|
|
|
+ "app.yhyue.com/moapp/jybase/date"
|
|
|
+ "bp.jydev.jianyu360.cn/ApplicationCenter/medicalField/entity"
|
|
|
+ "fmt"
|
|
|
+ "github.com/zeromicro/go-zero/core/logx"
|
|
|
+ "strings"
|
|
|
+)
|
|
|
+
|
|
|
+// EntClaimService 企业认领
|
|
|
+type EntClaimService struct {
|
|
|
+ *entity.Conn
|
|
|
+}
|
|
|
+
|
|
|
+// NewEntClaimSrv 创建一个EntClaimSrv实例
|
|
|
+func NewEntClaimSrv(conn *entity.Conn) *EntClaimService <span class="cov1" title="1">{
|
|
|
+ return &EntClaimService{
|
|
|
+ conn,
|
|
|
+ }
|
|
|
+}</span>
|
|
|
+
|
|
|
+// Claim 认领
|
|
|
+func (e *EntClaimService) Claim(data *entity.EntClaim) (int64, error) <span class="cov7" title="4">{
|
|
|
+ if e.IsClaimed(data.UserId, data.AppId, data.EntId, data.Type) </span><span class="cov4" title="2">{
|
|
|
+ return 0, entity.RepeatErr
|
|
|
+ }</span>
|
|
|
+ <span class="cov4" title="2">return e.BaseMysql.Insert(entity.TableDomainEntClaim, common.StructToMapMore(data)), nil</span>
|
|
|
+}
|
|
|
+
|
|
|
+// UnclaimedByEnt 根据企业id取消认领
|
|
|
+func (e EntClaimService) UnclaimedByEnt(userId int, entId string, type_ int) (bool, int) <span class="cov7" title="4">{
|
|
|
+
|
|
|
+ query := map[string]interface{}{
|
|
|
+ "user_id": userId,
|
|
|
+ "status": entity.StatusClaimed,
|
|
|
+ "ent_id": entId,
|
|
|
+ "type": type_,
|
|
|
+ }
|
|
|
+ // 1. 查询该条数据
|
|
|
+ rs := e.BaseMysql.FindOne(entity.TableDomainEntClaim, query, "id", "")
|
|
|
+ if rs == nil || len(*rs) == 0 </span><span class="cov4" title="2">{
|
|
|
+ logx.Errorf("取消认领：无效的企业id %v", entId)
|
|
|
+ return false, 0
|
|
|
+ }</span>
|
|
|
+ <span class="cov4" title="2">query2 := map[string]interface{}{
|
|
|
+ "id": (*rs)["id"],
|
|
|
+ }
|
|
|
+ // 2. 取消认领
|
|
|
+ update := map[string]interface{}{
|
|
|
+ "status": entity.StatusUnClaimed,
|
|
|
+ "update_time": date.NowFormat(date.Date_Full_Layout),
|
|
|
+ }
|
|
|
+ return e.BaseMysql.Update(entity.TableDomainEntClaim, query2, update), common.IntAll((*rs)["id"])</span>
|
|
|
+}
|
|
|
+
|
|
|
+// IsClaimed 是否认领
|
|
|
+func (e *EntClaimService) IsClaimed(userId int, appId string, entId string, typeCode int) bool <span class="cov10" title="6">{
|
|
|
+ query := map[string]interface{}{
|
|
|
+ "appId": appId,
|
|
|
+ "user_id": userId,
|
|
|
+ "type": typeCode,
|
|
|
+ "ent_id": entId,
|
|
|
+ "status": entity.StatusClaimed,
|
|
|
+ }
|
|
|
+ return e.BaseMysql.Count(entity.TableDomainEntClaim, query) > 0
|
|
|
+}</span>
|
|
|
+
|
|
|
+// DistributorList 关注的经销商列表
|
|
|
+func (e *EntClaimService) DistributorList(userId int, appId string, page int, pageSize int) (*[]map[string]interface{}, int) <span class="cov4" title="2">{
|
|
|
+
|
|
|
+ query := map[string]interface{}{
|
|
|
+ "user_id": userId,
|
|
|
+ "appid": appId,
|
|
|
+ "type": entity.TypeDistributor,
|
|
|
+ "status": entity.StatusClaimed,
|
|
|
+ }
|
|
|
+ field := "id,appid,user_id,ent_id,ent_name,create_time"
|
|
|
+ order := "create_time desc"
|
|
|
+ total := e.BaseMysql.Count(entity.TableDomainEntClaim, query)
|
|
|
+ if total == 0 </span><span class="cov1" title="1">{
|
|
|
+ return nil, 0
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">return e.BaseMysql.Find(entity.TableDomainEntClaim, query, field, order, (page-1)*pageSize, pageSize), int(total)</span>
|
|
|
+}
|
|
|
+
|
|
|
+// InstitutionList 我关注的医疗机构列表
|
|
|
+func (e *EntClaimService) InstitutionList(userId int, appId string, page int, pageSize int) (*[]map[string]interface{}, int) <span class="cov4" title="2">{
|
|
|
+ query := map[string]interface{}{
|
|
|
+ "user_id": userId,
|
|
|
+ "appid": appId,
|
|
|
+ "type": entity.TypeInstitution,
|
|
|
+ "status": entity.StatusClaimed,
|
|
|
+ }
|
|
|
+ field := "id,appid,user_id,ent_id,ent_name,create_time"
|
|
|
+ order := "create_time desc"
|
|
|
+ total := e.BaseMysql.Count(entity.TableDomainEntClaim, query)
|
|
|
+ if total == 0 </span><span class="cov1" title="1">{
|
|
|
+ return nil, 0
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">return e.BaseMysql.Find(entity.TableDomainEntClaim, query, field, order, (page-1)*pageSize, pageSize), int(total)</span>
|
|
|
+}
|
|
|
+
|
|
|
+// GetCompanyByIds 批量获取经销商详细信息
|
|
|
+func (e EntClaimService) GetCompanyByIds(ids []string) *[]map[string]interface{} <span class="cov6" title="3">{
|
|
|
+ if len(ids) == 0 </span><span class="cov1" title="1">{
|
|
|
+ return &[]map[string]interface{}{}
|
|
|
+ }</span>
|
|
|
+ <span class="cov4" title="2">q := "select a.company_id,a.company_name,a.establish_date,a.company_address,a.capital,a.company_phone,b.area,b.city from %v a left join %v b on a.area_code=b.code where a.company_id in (\"%v\") "
|
|
|
+ query := fmt.Sprintf(q, entity.TableCompanyBasInfo, entity.TableCodeArea, strings.Join(ids, "\" , \""))
|
|
|
+ return e.GlobalCommonData.SelectBySql(query)</span>
|
|
|
+}
|
|
|
+
|
|
|
+// GetInstitutionByIds 批量获取机构详细信息
|
|
|
+func (e EntClaimService) GetInstitutionByIds(ids []string) *[]map[string]interface{} <span class="cov6" title="3">{
|
|
|
+ if len(ids) == 0 </span><span class="cov1" title="1">{
|
|
|
+ return &[]map[string]interface{}{}
|
|
|
+ }</span>
|
|
|
+ <span class="cov4" title="2">q := "select a.company_id,a.mi_name,a.establish_date,b.area,b.city from %v.%v a left join %v.%v b on a.area_code=b.code where a.company_id in (\"%v\") "
|
|
|
+ query := fmt.Sprintf(q, entity.DbMedical, entity.TableInstitutionBaseInfo, entity.DbGlobal, entity.TableCodeArea, strings.Join(ids, "\" , \""))
|
|
|
+ return e.Mysql.SelectBySql(query)</span>
|
|
|
+}
|
|
|
+</pre>
|
|
|
+
|
|
|
+ <pre class="file" id="file3" style="display: none">// @Description 画像相关
|
|
|
+package service
|
|
|
+
|
|
|
+import (
|
|
|
+ "errors"
|
|
|
+ "fmt"
|
|
|
+ "log"
|
|
|
+ "regexp"
|
|
|
+ "strings"
|
|
|
+ "time"
|
|
|
+
|
|
|
+ . "app.yhyue.com/moapp/jybase/common"
|
|
|
+ "app.yhyue.com/moapp/jybase/encrypt"
|
|
|
+ elastic "app.yhyue.com/moapp/jybase/esv1"
|
|
|
+ "bp.jydev.jianyu360.cn/ApplicationCenter/medicalField/entity"
|
|
|
+)
|
|
|
+
|
|
|
+//画像
|
|
|
+type PortraitService struct {
|
|
|
+ *entity.Conn
|
|
|
+}
|
|
|
+
|
|
|
+var ClearHtml = regexp.MustCompile("<[^>]*>")
|
|
|
+
|
|
|
+// @description 生成结构体
|
|
|
+// @param conn 数据库实例
|
|
|
+// @return Portrait 画像实例
|
|
|
+func NewPortrait(conn *entity.Conn) *PortraitService <span class="cov1" title="1">{
|
|
|
+ return &PortraitService{
|
|
|
+ conn,
|
|
|
+ }
|
|
|
+}</span>
|
|
|
+
|
|
|
+// @description 获取画像内容
|
|
|
+// @param companyId 机构id
|
|
|
+// @param user_id base_user_id
|
|
|
+// @return PortraitInfo 画像信息
|
|
|
+// @return error 错误信息
|
|
|
+func (this *PortraitService) Info(companyId string, user_id int64) (*entity.PortraitInfo, error) <span class="cov10" title="3">{
|
|
|
+ //判断是否存在companyid
|
|
|
+ if companyId == "" || user_id == 0 </span><span class="cov10" title="3">{
|
|
|
+ return nil, errors.New(entity.NO_DATA_ERROR_MSG)
|
|
|
+ }</span>
|
|
|
+ //获取信息
|
|
|
+ <span class="cov0" title="0">data := this.Mysql.SelectBySql(fmt.Sprintf(`SELECT a.sdequipment_code,a.area_code,a.beds,a.visit_perday,a.doctorsnum,a.address,a.website,a.business_type,replace(a.equipment,",","、") equipment, replace(e.equipment,",","、") sdleveltypeequip ,a.mi_name,a.establish_date,b.name LEVEL,c.name miType,d.class FROM %s a
|
|
|
+ LEFT JOIN %s b ON a.level_code=b.code
|
|
|
+ LEFT JOIN %s c ON c.code =a.mi_type_code
|
|
|
+ LEFT JOIN (SELECT GROUP_CONCAT(DISTINCT departname_class1 SEPARATOR '、') class,company_id FROM %s WHERE company_id=?) AS d ON d.company_id =a.company_id
|
|
|
+ left join %s e on e.code =a.sdequipment_code
|
|
|
+ WHERE a.company_id=?`, entity.Institution_baseinfo, entity.Code_level, entity.Code_type, entity.Institution_department, entity.Code_sdleveltypeequip), companyId, companyId)
|
|
|
+ if data == nil || len(*data) == 0 </span><span class="cov0" title="0">{
|
|
|
+ return nil, errors.New(entity.NO_DATA_ERROR_MSG)
|
|
|
+ }</span>
|
|
|
+ //获取area_code 省份,城市,区县
|
|
|
+ <span class="cov0" title="0">area, city, district := "", "", ""
|
|
|
+ rdata := (*data)[0]
|
|
|
+ adata := this.GlobalCommonData.SelectBySql(fmt.Sprintf(`select area,city,district from %s where code =? limit 1`, entity.Code_area), ObjToString(rdata["area_code"]))
|
|
|
+ if adata != nil && len(*adata) > 0 </span><span class="cov0" title="0">{
|
|
|
+ area = ObjToString((*adata)[0]["area"])
|
|
|
+ city = ObjToString((*adata)[0]["city"])
|
|
|
+ district = ObjToString((*adata)[0]["district"])
|
|
|
+ }</span>
|
|
|
+ //医疗设备如果基本信息表中没有，则根据sdequipment_code、code联合查询得到equipment
|
|
|
+ <span class="cov0" title="0">equipment := ObjToString(rdata["equipment"])
|
|
|
+ sdleveltypeequip := ObjToString(rdata["sdleveltypeequip"])
|
|
|
+ if equipment == "" && sdleveltypeequip != "" </span><span class="cov0" title="0">{
|
|
|
+ equipment = ObjToString(rdata["sdleveltypeequip"])
|
|
|
+ }</span>
|
|
|
+ //医疗画像结果
|
|
|
+ <span class="cov0" title="0">portraitInfo := &entity.PortraitInfo{
|
|
|
+ Beds: Int64All(rdata["beds"]),
|
|
|
+ VisitPerday: Int64All(rdata["visit_perday"]), // 门诊量/日
|
|
|
+ Doctorsnum: Int64All(rdata["doctorsnum"]), //医生人数
|
|
|
+ Address: ObjToString(rdata["address"]), //医疗机构地址
|
|
|
+ Website: ObjToString(rdata["website"]), //医疗机构网站
|
|
|
+ Area: area, //省
|
|
|
+ City: city, //市
|
|
|
+ District: district, //区
|
|
|
+ BusinessType: Int64All(rdata["business_type"]), //医疗机构经营方式(0:公立、1:民营、2:其它)
|
|
|
+ Level: ObjToString(rdata["level"]), //医疗机构等级
|
|
|
+ MiType: ObjToString(rdata["miType"]), //医疗机构类型
|
|
|
+ Equipment: equipment, //医院设备
|
|
|
+ Departnames: ObjToString(rdata["class"]), //医院科室
|
|
|
+ Follow: this.IsFollow(companyId, user_id, 1), //是否关注 0-未关注 1已关注
|
|
|
+ CompanyName: ObjToString(rdata["mi_name"]), //医疗机构名称
|
|
|
+ EstablishDate: ObjToString(rdata["establish_date"]), //成立日期
|
|
|
+ }
|
|
|
+ return portraitInfo, nil</span>
|
|
|
+}
|
|
|
+
|
|
|
+// @description 获取医疗机构画像相关招标动态
|
|
|
+// @param companyName 机构名称
|
|
|
+// @param pageSize 条数
|
|
|
+// @param pageNum 页码
|
|
|
+// @param isExport 是否用于数据导出
|
|
|
+// @return GetNewMsgList 招标动态
|
|
|
+// @return count 招标数量
|
|
|
+// @return error 错误信息
|
|
|
+func (this *PortraitService) List(companyName string, pageSize, pageNum int64, isExport bool) (*[]*entity.GetNewMsgList, int64, error) <span class="cov1" title="1">{
|
|
|
+ //判断是否存在companyid
|
|
|
+ if companyName == "" </span><span class="cov0" title="0">{
|
|
|
+ return nil, 0, errors.New(entity.NO_DATA_ERROR_MSG)
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">var total int64
|
|
|
+ mustQueryArr := this.CommonPare(companyName)
|
|
|
+ log.Println("~~~~,", mustQueryArr)
|
|
|
+ //仅第一页查询总量(非数据导出)
|
|
|
+
|
|
|
+ if pageNum == 1 </span><span class="cov1" title="1">{
|
|
|
+ total = elastic.Count(entity.BiddingIndex, entity.BiddingIndex, fmt.Sprintf(entity.NewMustSearch, strings.Join(mustQueryArr, ","), ""))
|
|
|
+ if total <= 0 </span><span class="cov1" title="1">{
|
|
|
+ return nil, 0, errors.New(entity.NO_DATA_ERROR_MSG)
|
|
|
+ }</span>
|
|
|
+ }
|
|
|
+ <span class="cov0" title="0">start, limit := (pageNum-1)*pageSize, pageSize
|
|
|
+ fields := `"title","area","subtype","_id","projectname","publishtime"`
|
|
|
+ if isExport </span><span class="cov0" title="0">{
|
|
|
+ start, limit = 0, entity.DataExportNumLimit
|
|
|
+ fields = `"_id","title"`
|
|
|
+ }</span>
|
|
|
+ <span class="cov0" title="0">list := &[]*entity.GetNewMsgList{}
|
|
|
+ //列表查询
|
|
|
+ if total <= entity.DataExportBatchSearchLimit </span><span class="cov0" title="0">{
|
|
|
+ listQuery := fmt.Sprintf(entity.NewMustSearch, strings.Join(mustQueryArr, ","), fmt.Sprintf(entity.ListSearchLimit, fields, "publishtime", start, limit))
|
|
|
+ log.Printf("PortraitWinnerProject GetList Sql %s\n", listQuery)
|
|
|
+ newData := elastic.Get(entity.BiddingIndex, entity.BiddingType, listQuery)
|
|
|
+ if newData == nil || len(*newData) == 0 </span><span class="cov0" title="0">{
|
|
|
+ return nil, 0, errors.New(entity.NO_DATA_ERROR_MSG)
|
|
|
+ }</span>
|
|
|
+ <span class="cov0" title="0">log.Println("newdata:", newData)
|
|
|
+ for k, v := range *newData </span><span class="cov0" title="0">{
|
|
|
+ if len(v) > 0 </span><span class="cov0" title="0">{
|
|
|
+ if v["_id"] != nil </span><span class="cov0" title="0">{
|
|
|
+ (*newData)[k]["id"] = EncodeId(v["_id"].(string))
|
|
|
+ delete((*newData)[k], "_id") //删除未加密id
|
|
|
+ }</span>
|
|
|
+ <span class="cov0" title="0">title := ObjToString(ObjToString(v["title"]))
|
|
|
+ if title == "" </span><span class="cov0" title="0">{
|
|
|
+ title = ObjToString(v["projectname"])
|
|
|
+ }</span>
|
|
|
+ <span class="cov0" title="0">(*newData)[k]["title"] = ClearHtml.ReplaceAllString(title, "")</span>
|
|
|
+ }
|
|
|
+ <span class="cov0" title="0">*list = append(*list, &entity.GetNewMsgList{
|
|
|
+ Area: ObjToString(v["area"]),
|
|
|
+ Bidstatus: ObjToString(v["subtype"]), //信息类型
|
|
|
+ Firsttime: Int64All(v["publishtime"]), //时间
|
|
|
+ Id: ObjToString((*newData)[k]["id"]), //加密信息id
|
|
|
+ Title: ObjToString((*newData)[k]["title"]), //标题
|
|
|
+ })
|
|
|
+ log.Println("~~list:", list)</span>
|
|
|
+ }
|
|
|
+ <span class="cov0" title="0">return list, total, nil</span>
|
|
|
+ }
|
|
|
+ <span class="cov0" title="0">return nil, 0, errors.New(entity.NO_DATA_ERROR_MSG)</span>
|
|
|
+}
|
|
|
+
|
|
|
+//医疗机构画像查询语句拼接
|
|
|
+func (this *PortraitService) CommonPare(companyName string) (mustQueryArr []string) <span class="cov1" title="1">{
|
|
|
+ sTime, eTime := this.PareTimeSelect()
|
|
|
+ mustQueryArr = append(mustQueryArr, fmt.Sprintf(`{"term":{"buyer":"%s"}}`, companyName))
|
|
|
+ mustQueryArr = append(mustQueryArr, fmt.Sprintf(`{"term":{"bid_field":"%s"}}`, entity.BidField))
|
|
|
+ mustQueryArr = append(mustQueryArr, fmt.Sprintf(`{"range":{"publishtime":{"gte":"%d","lte":"%d"}}}`, sTime.Unix(), eTime.Unix()))
|
|
|
+
|
|
|
+ return
|
|
|
+}</span>
|
|
|
+
|
|
|
+//PareTimeSelect 默认2年
|
|
|
+func (this *PortraitService) PareTimeSelect() (st, et time.Time) <span class="cov1" title="1">{
|
|
|
+ now := time.Now()
|
|
|
+ sYear := now.Year() - 2
|
|
|
+ eYear := now.Year()
|
|
|
+ //返回默认时间
|
|
|
+ sTimeStamp := time.Date(sYear, 1, 1, 0, 0, 0, 0, time.Local)
|
|
|
+ eTimeStamp := time.Date(eYear+1, 1, 1, 0, 0, -1, 0, time.Local)
|
|
|
+ if eYear == now.Year() </span><span class="cov1" title="1">{
|
|
|
+ eTimeStamp = time.Date(eYear, now.Month(), now.Day(), now.Hour(), now.Minute(), 0, 0, time.Local)
|
|
|
+ }</span>
|
|
|
+ <span class="cov1" title="1">return sTimeStamp, eTimeStamp</span>
|
|
|
+}
|
|
|
+
|
|
|
+//短地址加密
|
|
|
+func EncodeId(sid string) string <span class="cov0" title="0">{
|
|
|
+ if sid == "" || sid == "-" </span><span class="cov0" title="0">{ //不存在的id为-
|
|
|
+ return ""
|
|
|
+ }</span>
|
|
|
+ <span class="cov0" title="0">return encrypt.EncodeArticleId2ByCheck(sid)</span>
|
|
|
+}
|
|
|
+
|
|
|
+// @description 判断用户是否关注该项目
|
|
|
+// @param companyId 机构id
|
|
|
+// @param user_id base_user_id
|
|
|
+// @param types 类型 1医疗机构 2经销商
|
|
|
+// @return int64 是否关注 1关注 0未关注
|
|
|
+func (this *PortraitService) IsFollow(companyId string, user_id, types int64) int64 <span class="cov0" title="0">{
|
|
|
+ if this.BaseMysql.CountBySql(fmt.Sprintf(`select count(1) from %s where user_id =? and ent_id =? and type =?`, entity.Domain_ent_claim), user_id, companyId, types) > 0 </span><span class="cov0" title="0">{
|
|
|
+ return 1
|
|
|
+ }</span>
|
|
|
+ <span class="cov0" title="0">return 0</span>
|
|
|
+}
|
|
|
+
|
|
|
+// @description 获取医疗机构画像相关招标动态导出的加密戳 用于数据导出支付页面
|
|
|
+// @param mongoUid mongodb用户id
|
|
|
+// @param companyName 机构名称
|
|
|
+// @param ids 选中的招标信息 多个,隔开 全部则传空字符串
|
|
|
+// @return string 生成的数据导出加密戳
|
|
|
+// @return error 错误信息
|
|
|
+func (this *PortraitService) Export(mongoUid, companyName, ids string) (string, error) <span class="cov0" title="0">{
|
|
|
+ //判断是否存在companyid
|
|
|
+ if companyName == "" </span><span class="cov0" title="0">{
|
|
|
+ return "", errors.New(entity.NO_DATA_ERROR_MSG)
|
|
|
+ }</span>
|
|
|
+ <span class="cov0" title="0">sTime, eTime := this.PareTimeSelect()
|
|
|
+ idsArr := []string{}
|
|
|
+ if ids == "" </span><span class="cov0" title="0">{
|
|
|
+ //获取全部id
|
|
|
+ list, _, err := this.List(companyName, -1, -1, true)
|
|
|
+ if err != nil || list == nil || len(*list) == 0 </span><span class="cov0" title="0">{
|
|
|
+ return "", errors.New(entity.NO_DATA_ERROR_MSG)
|
|
|
+ }</span>
|
|
|
+ <span class="cov0" title="0">for k, v := range *list </span><span class="cov0" title="0">{
|
|
|
+ ids += v.Id
|
|
|
+ if k != len(*list)-1 </span><span class="cov0" title="0">{
|
|
|
+ ids += ","
|
|
|
+ }</span>
|
|
|
+ }
|
|
|
+ }
|
|
|
+ <span class="cov0" title="0">for _, v := range strings.Split(ids, ",") </span><span class="cov0" title="0">{
|
|
|
+ id := encrypt.DecodeArticleId2ByCheck(v) //解密id
|
|
|
+ if len(id) > 0 </span><span class="cov0" title="0">{
|
|
|
+ //
|
|
|
+ idsArr = append(idsArr, id[0])
|
|
|
+ }</span>
|
|
|
+ }
|
|
|
+ //
|
|
|
+ <span class="cov0" title="0">saveMap := map[string]interface{}{
|
|
|
+ "s_userid": mongoUid,
|
|
|
+ "comeinfrom": "medicalPortrait", //来源
|
|
|
+ "comeintime": time.Now().Unix(),
|
|
|
+ "selectIds": idsArr,
|
|
|
+ "area": []string{},
|
|
|
+ "publishtime": fmt.Sprintf("%d_%d", sTime.Unix(), eTime.Unix()),
|
|
|
+ "industry": []string{},
|
|
|
+ "keywords": []string{},
|
|
|
+ "selectType": "",
|
|
|
+ "buyer": []string{companyName},
|
|
|
+ }
|
|
|
+
|
|
|
+ if _id := this.MgoJy.Save("export_search", saveMap); _id != "" </span><span class="cov0" title="0">{
|
|
|
+ return encrypt.SE.Encode2Hex(_id), nil
|
|
|
+ }</span>
|
|
|
+ <span class="cov0" title="0">return "", errors.New(entity.NO_DATA_ERROR_MSG)</span>
|
|
|
+}
|
|
|
+
|
|
|
+// @description 经销商画像基本信息
|
|
|
+// @param companyId 经销商id
|
|
|
+// @param user_id base_user_id
|
|
|
+// @return distributorInfo 经销商画像信息
|
|
|
+// @return error 错误信息
|
|
|
+func (this *PortraitService) DistributorInfo(companyId string, user_id int64) (*entity.DistributorInfo, error) <span class="cov0" title="0">{
|
|
|
+ if companyId == "" || user_id == 0 </span><span class="cov0" title="0">{
|
|
|
+ return nil, errors.New(entity.NO_DATA_ERROR_MSG)
|
|
|
+ }</span>
|
|
|
+ //查找基本信息
|
|
|
+ <span class="cov0" title="0">rdata := this.GlobalCommonData.SelectBySql(fmt.Sprintf(`select company_name,company_code,cancel_date,company_phone,operation_startdate,operation_enddate,credit_no,real_capital,org_code,tax_code,establish_date,legal_person,company_type,employee_no,company_address,business_scope
|
|
|
+ from %s where company_id =?`, entity.Company_baseinfo), companyId)
|
|
|
+ if rdata == nil || len(*rdata) == 0 </span><span class="cov0" title="0">{
|
|
|
+ return nil, errors.New(entity.NO_DATA_ERROR_MSG)
|
|
|
+ }</span>
|
|
|
+ <span class="cov0" title="0">data := (*rdata)[0]
|
|
|
+ distributorInfo := &entity.DistributorInfo{
|
|
|
+ //TODO 还没判断是否关注
|
|
|
+ LegalPerson: ObjToString(data["legal_person"]), //法定代表人
|
|
|
+ //TODO 经营状态不知道咋看
|
|
|
+ // CompanyStatus //经营状态
|
|
|
+ CreditNo: ObjToString(data["credit_no"]), //统一信用代码
|
|
|
+ EstablishDate: ObjToString(data["establish_date"]), //成立日期
|
|
|
+ OrgCode: ObjToString(data["org_code"]), //组织机构代码
|
|
|
+ Capital: ObjToString(data["real_capital"]), //注册资本
|
|
|
+ TaxCode: ObjToString(data["tax_code"]), //纳税人识别号
|
|
|
+ OperationStartdate: ObjToString(data["operation_startdate"]), //营业期限开始
|
|
|
+ OperationEnddate: ObjToString(data["operation_enddate"]), //营业期限至 结束
|
|
|
+ CompanyCode: ObjToString(data["company_code"]), //工商注册号
|
|
|
+ CompanyType: ObjToString(data["company_type"]), //公司类型
|
|
|
+ EmployeeNo: ObjToString(data["employee_no"]), //人员规模
|
|
|
+ CompanyPhone: ObjToString(data["company_phone"]), //联系方式
|
|
|
+ CompanyAddress: ObjToString(data["business_scope"]), //注册地址
|
|
|
+ BusinessScope: ObjToString(data["cancel_date"]), //经营范围
|
|
|
+ ConpanyName: ObjToString(data["company_name"]), //企业名称
|
|
|
+ }
|
|
|
+ return distributorInfo, nil</span>
|
|
|
+}
|
|
|
+
|
|
|
+// @description 经销商画像-医械产品
|
|
|
+// @param companyId 经销商id
|
|
|
+// @param user_id base_user_id
|
|
|
+// @return distributorInfo 经销商画像信息
|
|
|
+// @return error 错误信息
|
|
|
+func (this *PortraitService) MedicalProdcutList(companyId string, user_id int64) (*[]entity.MedicalEquipment, error) <span class="cov0" title="0">{
|
|
|
+ if companyId == "" || user_id == 0 </span><span class="cov0" title="0">{
|
|
|
+ return nil, errors.New(entity.NO_DATA_ERROR_MSG)
|
|
|
+ }</span>
|
|
|
+ //查找基本信息
|
|
|
+ <span class="cov0" title="0">rdata := this.GlobalCommonData.SelectBySql(fmt.Sprintf(`SELECT product_name,regno,approve_date,validity_date,manage_type,regist_type
|
|
|
+ from %s where company_id =? order by id desc`, entity.Product_baseinfo), companyId)
|
|
|
+ if rdata == nil || len(*rdata) == 0 </span><span class="cov0" title="0">{
|
|
|
+ return nil, errors.New(entity.NO_DATA_ERROR_MSG)
|
|
|
+ }</span>
|
|
|
+ <span class="cov0" title="0">list := &[]entity.MedicalEquipment{}
|
|
|
+ for _, v := range *rdata </span><span class="cov0" title="0">{
|
|
|
+ *list = append(*list, entity.MedicalEquipment{
|
|
|
+ ProductName: ObjToString(v["product_name"]), //产品名称
|
|
|
+ Regno: ObjToString(v["regno"]), //注册/备案证编号
|
|
|
+ ApproveDate: ObjToString(v["approve_date"]), //批准日期|备案日期
|
|
|
+ ValidityDate: ObjToString(v["validity_date"]), //有效期至
|
|
|
+ ManageType: ObjToString(v["manage_type"]), //管理类别
|
|
|
+ RegistType: Int64All(v["regist_type"]), //1-注册产品 2-备案产品
|
|
|
+ })
|
|
|
+ }</span>
|
|
|
+ <span class="cov0" title="0">return list, nil</span>
|
|
|
+}
|
|
|
+</pre>
|
|
|
+
|
|
|
</div>
|
|
|
</body>
|
|
|
<script>
|
